byp4a55 professor6T9

Linux ns1.eurodns.top 4.18.0-553.22.1.lve.1.el7h.x86_64 #1 SMP Tue Oct 8 14:36:03 UTC 2024 x86_64
LiteSpeed
135.181.9.38

File Name : Webhooks.php

<?php

namespace App\Controllers\api;

use App\Controllers\BaseController;
use App\Libraries\Flutterwave;
use App\Libraries\Paystack;
use App\Libraries\Razorpay;
use App\Libraries\Stripe;
use App\Libraries\Paypal;
use App\Libraries\Xendit;
use Config\ApiResponseAndNotificationStrings;

class Webhooks extends BaseController
{
    protected $output;
    private $stripe, $paypal_lib, $trans;
    protected $defaultLanguage;
    public function __construct()
    {
        $this->stripe = new Stripe;
        $this->paypal_lib = new Paypal();
        helper('api');
        helper("function");
        $this->settings = get_settings('general_settings', true);
        date_default_timezone_set($this->settings['system_timezone']);
        $this->trans = new ApiResponseAndNotificationStrings();
        $this->defaultLanguage = get_default_language();
    }
    public function stripe()
    {
        $credentials = $this->stripe->get_credentials();
        $request_body = file_get_contents('php://input');
        $event = json_decode($request_body, FALSE);
        if (!empty($event->data->object->payment_intent)) {
            $txn_id = (isset($event->data->object->payment_intent)) ? $event->data->object->payment_intent : "";
            if (!empty($txn_id)) {
                if (isset($event->data->object->metadata) && !empty($event->data->object->metadata->order_id)) {
                    // Process the metadata and retrieve order details
                    $amount = ($event->data->object->amount / 100);
                    $currency = $event->data->object->currency;
                    $order_id = $event->data->object->metadata->order_id;
                    $order_data = fetch_details('orders', ["id" => $order_id]);
                    $user_id = $order_data[0]['user_id'];
                    $partner_id = $order_data[0]['partner_id'];
                    // Continue with your code logic
                }
            }
        } else {
            $order_id = 0;
            $amount = 0;
            $currency = (isset($event->data->object->currency)) ? $event->data->object->currency : "";
        }
        $http_stripe_signature = isset($_SERVER['HTTP_STRIPE_SIGNATURE']) ? $_SERVER['HTTP_STRIPE_SIGNATURE'] : "";
        $result = $this->stripe->construct_event($request_body, $http_stripe_signature, $credentials['webhook_key']);
        if ($result == "Matched") {
            log_message('error', '$event ' . var_export($event, true));
            if ($event->type == 'charge.succeeded') {
                //for subscription
                if (isset($event->data->object->metadata->transaction_id) && !empty($event->data->object->metadata->transaction_id)) {
                    $transaction_details_for_subscription = fetch_details('transactions', ['id' => $event->data->object->metadata->transaction_id]);
                    $details_for_subscription = fetch_details('subscriptions', ['id' => $transaction_details_for_subscription[0]['subscription_id']]);
                    if (!empty($transaction_details_for_subscription)) {
                        if (isset($transaction_details_for_subscription[0])) {
                            log_message('error', 'FOR SUBSCRIPTION');
                            update_details(['status' => 'success', 'txn_id' => $event->data->object->payment_intent], ['id' => $event->data->object->metadata->transaction_id], 'transactions');
                            // update_details(['status' => 'active'], ['subscription_id' => $transaction_details_for_subscription[0]['subscription_id'],'partner_id'=>$transaction_details_for_subscription[0]['user_id'],'status'=>'pending'], 'partner_subscriptions');
                            $purchaseDate = date('Y-m-d');
                            $subscriptionDuration = $details_for_subscription[0]['duration'];
                            $expiryDate = date('Y-m-d', strtotime($purchaseDate . ' + ' . $subscriptionDuration . ' days')); // Add the duration to the purchase date
                            if ($subscriptionDuration == "unlimited") {
                                $subscriptionDuration = 0;
                            }
                            update_details(['status' => 'active', 'is_payment' => '1', 'purchase_date' => $purchaseDate, 'expiry_date' => $expiryDate, 'updated_at' => date('Y-m-d h:i:s')], [
                                'subscription_id' => $transaction_details_for_subscription[0]['subscription_id'],
                                'partner_id' => $transaction_details_for_subscription[0]['user_id'],
                                'transaction_id' => $event->data->object->metadata->transaction_id,
                            ], 'partner_subscriptions');
                        }
                    }
                }
                //for additional charges
                else if (!empty($event->data->object->metadata->additional_charges_transaction_id)) {
                    log_message('error', 'FOR ADDITIONAL CHARGES');
                    update_details(['status' => 'success', 'txn_id' => $txn_id], ['id' => $event->data->object->metadata->additional_charges_transaction_id], 'transactions');
                    $order_data = fetch_details('orders', ["id" => $event->data->object->metadata->order_id]);
                    update_details(['payment_status_of_additional_charge' => '1'], ['id' => $order_id], 'orders');
                }
                //for booking
                else {

$data = [
                        'transaction_type' => 'transaction',
                        'user_id' => $user_id,
                        'partner_id' => $partner_id,
                        'order_id' => $order_id,
                        'type' => 'stripe',
                        'txn_id' => $txn_id,
                        'amount' => $amount,
                        'status' => 'success',
                        'currency_code' => $currency,
                        'message' => 'Order placed successfully',
                    ];
                    $insert_id = add_transaction($data);
                    send_web_notification('New Booking Notification', 'We are pleased to inform you that you have received a new Booking.');

update_custom_job_status($order_id, 'booked');

//customer email
                    $userdata = fetch_details('users', ['id' => $user_id], ['email', 'username']);
                    if (!empty($userdata[0]['email']) && check_notification_setting('new_booking_confirmation_to_customer', 'email') && is_unsubscribe_enabled($user_id) == 1) {
                        send_custom_email('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                    }
                    if (check_notification_setting('new_booking_confirmation_to_customer', 'sms')) {
                        send_custom_sms('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                    }
                    //for provider
                    $user_partner_data = fetch_details('users', ['id' => $partner_id], ['email', 'username']);
                    if (!empty($user_partner_data[0]['email']) && check_notification_setting('new_booking_received_for_provider', 'email') && is_unsubscribe_enabled($partner_id) == 1) {
                        send_custom_email('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                    }
                    if (check_notification_setting('new_booking_received_for_provider', 'sms')) {
                        send_custom_sms('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                    }
                    //for app notification
                    $db      = \Config\Database::connect();
                    $to_send_id = $partner_id;
                    $usersEmail = fetch_details('users', ['id' => $to_send_id], ['email']);
                    $users_fcm = $db->table('users_fcm_ids')
                        ->select('fcm_id,platform')
                        ->where('user_id', $to_send_id)
                        ->whereIn('platform', ['android', 'ios', 'web', 'provider_panel'])
                        ->where('status', '1')
                        ->get()
                        ->getResultArray();
                    $fcm_ids = [];
                    foreach ($users_fcm as $ids) {
                        if ($ids['fcm_id'] != "") {
                            $fcm_ids['fcm_id'] = $ids['fcm_id'];
                            $fcm_ids['platform'] = $ids['platform'];
                        }
                    }
                    if (!empty($fcm_ids)) {
                        $registrationIDs = $fcm_ids;
                        $registrationIDs_chunks = array_chunk($users_fcm, 1000);
                        $title = $this->trans->newBookingNotification;
                        $msg = $this->trans->newBookingReceivedMessage;
                        $type = 'order';
                        $fcmMsg = array(
                            'content_available' => "true",
                            'title' => $title,
                            'body' => $msg,
                            'type' => $type,
                            'order_id' => "$order_id",
                            'type_id' => "$to_send_id",
                            'click_action' => 'FLUTTER_NOTIFICATION_CLICK',
                        );
                        // Use queued notifications for better performance
                        queue_notification($fcmMsg, $registrationIDs_chunks, [], 'default');

$store_notification = store_notifications($title, $msg, 'order', $partner_id, 0, 'general', now(), 'specific_user', '', '', $partner_id, 'pending', '', '', '', '');
                    }
                    if ($insert_id) {
                        //  log_message('error', 'Transaction successfully done ' . var_export($event, true));
                        $response['error'] = false;
                        $response['transaction_status'] = $event->type;
                        $response['message'] = "Transaction successfully done";
                        return $this->response->setJSON($response);
                    } else {
                        $response['error'] = true;
                        $response['message'] = "something went wrong";
                        return $this->response->setJSON($response);
                    }
                }
            } elseif ($event->type == 'charge.failed') {

if (!empty($event->data->object->metadata->additional_charges_transaction_id)) {
                    log_message('error', 'FOR ADDITIONAL CHARGES');
                    update_details(['status' => 'failed', 'txn_id' => $txn_id], ['id' => $event->data->object->metadata->additional_charges_transaction_id], 'transactions');
                    $order_data = fetch_details('orders', ["id" => $event->data->object->metadata->order_id]);
                    update_details(['payment_status_of_additional_charge' => '2'], ['id' => $order_id], 'orders');
                } else {
                    log_message('error', 'Stripe Webhook | charge.failed ');
                    $data = [
                        'transaction_type' => 'transaction',
                        'user_id' => $user_id,
                        'partner_id' => $partner_id,
                        'order_id' => $order_id,
                        'type' => 'stripe',
                        'txn_id' => $txn_id,
                        'amount' => $amount,
                        'status' => 'failed',
                        'currency_code' => $currency,
                        'message' => 'Booking is cancelled',
                    ];
                    $insert_id = add_transaction($data);
                    update_details(['payment_status' => 2], ['id' => $order_id], 'orders');
                    update_details(['status' => 'cancelled'], ['id' => $order_id], 'orders');
                    update_custom_job_status($order_id, 'cancelled');
                }
            } elseif ($event->type == 'charge.pending') {
                if (!empty($event->data->object->metadata->additional_charges_transaction_id)) {
                    log_message('error', 'FOR ADDITIONAL CHARGES');
                    update_details(['status' => 'pending', 'txn_id' => $txn_id], ['id' => $event->data->object->metadata->additional_charges_transaction_id], 'transactions');
                    $order_data = fetch_details('orders', ["id" => $event->data->object->metadata->order_id]);
                    update_details(['payment_status_of_additional_charge' => '0'], ['id' => $order_id], 'orders');
                } else {
                    $data = [
                        'transaction_type' => 'transaction',
                        'user_id' => $user_id,
                        'partner_id' => $partner_id,
                        'order_id' => $order_id,
                        'type' => 'stripe',
                        'txn_id' => $txn_id,
                        'amount' => $amount,
                        'status' => 'pending',
                        'currency_code' => $currency,
                        'message' => 'Order placed successfully',
                    ];
                    $insert_id = add_transaction($data);
                    update_details(['payment_status' => 0], ['id' => $order_id], 'orders');
                    update_custom_job_status($order_id, 'pending');
                    return false;
                }
            } elseif ($event->type == 'charge.expired') {
                $data = [
                    'transaction_type' => 'transaction',
                    'user_id' => $user_id,
                    'partner_id' => $partner_id,
                    'order_id' => $order_id,
                    'type' => 'stripe',
                    'txn_id' => $txn_id,
                    'amount' => $amount,
                    'status' => 'failed',
                    'currency_code' => $currency,
                    'message' => 'Order placed successfully',
                ];
                $insert_id = add_transaction($data);
                update_custom_job_status($order_id, 'cancelled');
                return false;
            } elseif ($event->type == 'charge.refunded') {
                log_message('error', 'Stripe Webhook | REFUND CALLED  --> ');
                log_message('error', 'Transaction_id | ' . var_export($txn_id, true));
                $success_transaction = fetch_details('transactions', ['transaction_type' => 'transaction', 'type' => 'stripe', 'status' => 'success', 'txn_id' => $txn_id]);
                if (!empty($success_transaction)) {
                    $already_exist_refund_transaction = fetch_details('transactions', ['transaction_type' => 'refund', 'type' => 'stripe', 'message' => 'stripe_refund', 'txn_id' => $txn_id]);
                    if (!empty($already_exist_refund_transaction)) {
                        $refund_data = [
                            'status' => 'succeeded',
                        ];
                        update_details($refund_data, ['id' =>  $already_exist_refund_transaction[0]['id']], 'transactions');
                    } else {
                        $data = [
                            'transaction_type' => 'refund',
                            'user_id' => $user_id,
                            'partner_id' => $partner_id,
                            'order_id' => $order_id,
                            'type' => 'stripe',
                            'txn_id' => $txn_id,
                            'amount' => $amount,
                            'status' => 'succeeded',
                            'currency_code' => $currency,
                            'message' => 'stripe_refund',
                        ];
                        $insert_id = add_transaction($data);
                        update_custom_job_status($order_id, 'refunded');
                    }
                }
            } else {
                $response['error'] = true;
                $response['transaction_status'] = $event->type;
                $response['message'] = "Transaction could not be detected.";
                echo json_encode($response);
                return false;
            }
        } else {
            log_message('error', 'Stripe Webhook | Invalid Server Signature  --> ');
            return false;
        }
    }
    public function paystack()
    {
        log_message('error', 'paystack Webhook Called');
        $system_settings = get_settings('system_settings', true);
        $paystack = new Paystack;
        $credentials = $paystack->get_credentials();
        $secret_key = $credentials['secret'];
        $request_body = file_get_contents('php://input');
        $event = json_decode($request_body, true);
        log_message('error', 'paystack Webhook --> ' . var_export($event, true));
        if (!empty($event['data'])) {
            // $txn_id = (isset($event['data']['reference'])) ? $event['data']['reference'] : "";
            $txn_id = (isset($event['data']['id'])) ? $event['data']['id'] : "";
            // log_message('error', 'paystack Webhook SERVER Variable --> ' . var_export($txn_id, true));
            if (isset($txn_id) && !empty($txn_id)) {
                $transaction = fetch_details('transactions', ['txn_id' => $txn_id]);
                if (!empty($transaction)) {
                    $order_id = $transaction[0]['order_id'];
                    $user_id = $transaction[0]['user_id'];
                } else {
                    if (!empty($event['data']['metadata']['transaction_id'])) {
                    } else {
                        if (isset($event['data']['metadata']['order_id']) && !empty($event['data']['metadata']['order_id'])) {
                            $order_id = 0;
                            $order_id = $event['data']['metadata']['order_id'];
                            $order_data = fetch_details('orders', ["id" => $order_id]);
                            $user_id = $order_data[0]['user_id'];
                            $partner_id = $order_data[0]['partner_id'];
                        }
                    }
                }
            }
            $amount = $event['data']['amount'];
            $currency = $event['data']['currency'];
        } else {
            $order_id = 0;
            $amount = 0;
            $currency = (isset($event['data']['currency'])) ? $event['data']['currency'] : "";
        }
        if ($event['event'] == 'charge.success') {
            //for subscription
            if (!empty($event['data']['metadata']['transaction_id'])) {
                $transaction_details_for_subscription = fetch_details('transactions', ['id' => $event['data']['metadata']['transaction_id']]);
                $details_for_subscription = fetch_details('subscriptions', ['id' => $transaction_details_for_subscription[0]['subscription_id']]);
                log_message('error', 'FOR SUBSCRIPTION');
                update_details(['status' => 'success', 'txn_id' => $txn_id], ['id' => $event['data']['metadata']['transaction_id']], 'transactions');
                $purchaseDate = date('Y-m-d');
                $subscriptionDuration = $details_for_subscription[0]['duration'];
                $expiryDate = date('Y-m-d', strtotime($purchaseDate . ' + ' . $subscriptionDuration . ' days')); // Add the duration to the purchase date
                if ($subscriptionDuration == "unlimited") {
                    $subscriptionDuration = 0;
                }
                update_details(['status' => 'active', 'is_payment' => '1', 'purchase_date' => $purchaseDate, 'expiry_date' => $expiryDate, 'updated_at' => date('Y-m-d h:i:s')], [
                    'subscription_id' => $transaction_details_for_subscription[0]['subscription_id'],
                    'partner_id' => $transaction_details_for_subscription[0]['user_id'],
                    'status !=' => 'active',
                    'transaction_id' => $event['data']['metadata']['transaction_id'],
                ], 'partner_subscriptions');
                // log_message('error', 'METAFDATA --> ' . var_export($event['data']['metadata']['transaction_id'], true));
            }
            //for additional charges
            else if (!empty($event['data']['metadata']['additional_charges_transaction_id'])) {
                // $transaction_details_for_additional_charges = fetch_details('transactions', ['id' => $event['data']['metadata']['additional_charges_transaction_id']]);
                log_message('error', 'FOR ADDITIONAL CHARGES');
                update_details(['status' => 'success', 'txn_id' => $txn_id, 'reference' => $event['data']['reference']], ['id' => $event['data']['metadata']['additional_charges_transaction_id']], 'transactions');
                $order_data = fetch_details('orders', ["id" => $order_id]);
                update_details(['payment_status_of_additional_charge' => '1'], ['id' => $order_id], 'orders');
            }
            //for order
            else {
                if (!empty($order_id)) {     /* To do the wallet recharge if the order id is set in the pattern */
                    /* process the order and mark it as received */
                    $order = fetch_details('orders', ['id' => $order_id]);
                    log_message('error', 'Paystack Webhook | order --> ' . var_export($order, true));
                    /* No need to add because the transaction is already added just update the transaction status */
                    if (!empty($transaction)) {
                        $transaction_id = $transaction[0]['id'];
                        update_details(['status' => 'success'], ['id' => $transaction_id], 'transactions');
                    } else {
                        /* add transaction of the payment */
                        // $amount = ($event['data']['amount'] / 100);
                        $amount = ($event['data']['amount']);
                        $data = [
                            'transaction_type' => 'transaction',
                            'user_id' => $user_id,
                            'partner_id' => $partner_id,
                            'order_id' => $order_id,
                            'type' => 'paystack',
                            'txn_id' => $txn_id,
                            'amount' => $amount,
                            'status' => 'success',
                            'currency_code' => $currency,
                            'message' => 'Order placed successfully',
                            'reference' => (isset($event['data']['reference'])) ? $event['data']['reference'] : "",
                        ];
                        $insert_id = add_transaction($data);
                        if ($insert_id) {
                            update_details(['payment_status' => 1], ['id' => $order_id], 'orders');
                            update_custom_job_status($order_id, 'booked');
                            send_web_notification('New Booking Notification', 'We are pleased to inform you that you have received a new Booking.');
                            //customer email
                            $userdata = fetch_details('users', ['id' => $user_id], ['email', 'username']);
                            if (!empty($userdata[0]['email']) && check_notification_setting('new_booking_confirmation_to_customer', 'email') && is_unsubscribe_enabled($user_id) == 1) {
                                send_custom_email('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            if (check_notification_setting('new_booking_confirmation_to_customer', 'sms')) {
                                send_custom_sms('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            //for provider
                            $user_partner_data = fetch_details('users', ['id' => $partner_id], ['email', 'username']);
                            if (!empty($user_partner_data[0]['email']) && check_notification_setting('new_booking_received_for_provider', 'email') && is_unsubscribe_enabled($partner_id) == 1) {
                                send_custom_email('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            if (check_notification_setting('new_booking_received_for_provider', 'sms')) {
                                send_custom_sms('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }

//for app notification
                            $db      = \Config\Database::connect();
                            $to_send_id = $partner_id;
                            $users_fcm = $db->table('users_fcm_ids')
                                ->select('fcm_id,platform')
                                ->where('user_id', $to_send_id)
                                ->whereIn('platform', ['android', 'ios', 'web', 'provider_panel'])
                                ->where('status', '1')
                                ->get()
                                ->getResultArray();
                            foreach ($users_fcm as $ids) {
                                if ($ids['fcm_id'] != "") {
                                    $fcm_ids['fcm_id'] = $ids['fcm_id'];
                                    $fcm_ids['platform'] = $ids['platform'];
                                }
                            }
                            if (!empty($fcm_ids)  && check_notification_setting('new_booking_received_for_provider', 'notification')) {
                                $registrationIDs = $fcm_ids;
                                $registrationIDs_chunks = array_chunk($users_fcm, 1000);
                                $title = $this->trans->newBookingNotification;
                                $msg = $this->trans->newBookingReceivedMessage;
                                $type = 'order';
                                $fcmMsg = array(
                                    'content_available' => "true",
                                    'title' => $title,
                                    'body' => $msg,
                                    'type' => $type,
                                    'order_id' => "$order_id",
                                    'type_id' => "$to_send_id",
                                    'click_action' => 'FLUTTER_NOTIFICATION_CLICK',
                                );
                                // Use queued notifications for better performance
                                queue_notification($fcmMsg, $registrationIDs_chunks, [], 'default');
                                $store_notification = store_notifications($title, $msg, 'order', $partner_id, 0, 'general', now(), 'specific_user', '', '', $partner_id, 'pending', '', '', '', '');
                            }
                            $response['error'] = false;
                            $response['transaction_status'] = "paystack";
                            $response['message'] = "Transaction successfully done";
                            return $this->response->setJSON($response);
                        } else {
                            $response['error'] = true;
                            $response['message'] = "something went wrong";
                            return $this->response->setJSON($response);
                        }
                    }
                    log_message('error', 'Paystack Webhook inner Success --> ' . var_export($event, true));
                    log_message('error', 'Paystack Webhook order Success --> ' . var_export($event, true));
                } else {
                    /* No order ID found / sending 304 error to payment gateway so it retries wenhook after sometime*/
                    log_message('error', 'Paystack Webhook | Order id not found --> ' . var_export($event, true));
                    return $this->output
                        ->set_content_type('application/json')
                        ->set_status_header(304)
                        ->set_output(json_encode(array(
                            'message' => '304 Not Modified - order/transaction id not found',
                            'error' => true
                        )));
                }
            }
        } else if ($event['event'] == 'charge.dispute.create') {
            if (!empty($order_id) && is_numeric($order_id)) {
                $order = fetch_details('orders', ['id' => $order_id]);
                if ($order['order_data']['0']['active_status'] == 'received' || $order['order_data']['0']['active_status'] == 'processed') {
                    update_details(['status' => 'awaiting'], ['id' => $order_id], 'orders');
                    update_custom_job_status($order_id, 'pending');
                }
                if (!empty($transaction)) {
                    $transaction_id = $transaction[0]['id'];
                    update_details(['status' => 'pending'], ['id' => $transaction_id], 'transactions');
                }
                log_message('error', 'Paystack Transaction is Pending --> ' . var_export($event, true));
            }
        } else if ($event['event'] == 'refund.processed') {
            log_message('error', 'Paystack Webhook | REFUND ');
            $success_transaction = fetch_details('transactions', ['transaction_type' => 'transaction', 'type' => 'paystack', 'status' => 'success', 'txn_id' => $txn_id]);
            if (!empty($success_transaction)) {
                $already_exist_refund_transaction = fetch_details('transactions', ['transaction_type' => 'refund', 'type' => 'paystack', 'message' => 'paystack_refund', 'txn_id' => $txn_id]);
                if (!empty($already_exist_refund_transaction)) {
                    $refund_data = [
                        'status' => 'processed',
                    ];
                    update_details($refund_data, ['id' =>  $already_exist_refund_transaction[0]['id']], 'transactions');
                } else {
                    $data = [
                        'transaction_type' => 'refund',
                        'user_id' => $user_id,
                        'partner_id' => $partner_id,
                        'order_id' => $order_id,
                        'type' => 'paystack',
                        'txn_id' => $txn_id,
                        'amount' => $amount,
                        'status' => 'processed',
                        'currency_code' => $currency,
                        'message' => 'paystack_refund',
                    ];
                    $insert_id = add_transaction($data);
                    update_custom_job_status($order_id, 'refunded');
                }
            }
        } else {
            log_message('error', 'Paystack Webhook | IN ELSE');
            // if (!empty($order_id) && is_numeric($order_id)) {
            //     update_details(['status' => 'cancelled'], ['id' => $order_id], 'orders');
            // }
            // /* No need to add because the transaction is already added just update the transaction status */
            // if (!empty($transaction)) {
            //     $transaction_id = $transaction[0]['id'];
            //     update_details(['status' => 'failed'], ['id' => $transaction_id], 'transactions');
            //     update_details(['payment_status' => 2], ['id' => $order_id], 'orders');
            // }
            // $response['error'] = true;
            // $response['transaction_status'] = $event['event'];
            // $response['message'] = "Transaction could not be detected.";
            // // log_message('error', 'Paystack Webhook | Transaction could not be detected --> ' . var_export($event, true));
            // echo json_encode($response);
            // return false;
            if (!empty($event['data']['metadata']['additional_charges_transaction_id'])) {
                log_message('error', 'FOR ADDITIONAL CHARGES');
                update_details(['status' => 'failed', 'txn_id' => $txn_id, 'reference' => $event['data']['reference']], ['id' => $event['data']['metadata']['additional_charges_transaction_id']], 'transactions');
                $order_data = fetch_details('orders', ["id" => $order_id]);
                update_details(['payment_status_of_additional_charge' => '2'], ['id' => $order_id], 'orders');
            }
        }
    }
    public function razorpay()
    {
        //Debug in server first
        if ((strtoupper($_SERVER['REQUEST_METHOD']) != 'POST') || !array_key_exists('HTTP_X_RAZORPAY_SIGNATURE', $_SERVER))
            exit();
        $razorpay = new Razorpay;
        $system_settings = get_settings('system_settings', true);
        $credentials = $razorpay->get_credentials();
        $request = file_get_contents('php://input');
        $request = json_decode($request, true);
        define('RAZORPAY_SECRET_KEY', $credentials['secret']);
        $http_razorpay_signature = isset($_SERVER['HTTP_X_RAZORPAY_SIGNATURE']) ? $_SERVER['HTTP_X_RAZORPAY_SIGNATURE'] : "";
        // log_message('error', 'Razorpay --> ' . var_export($request, true));
        log_message('error', 'Razorpay --> ' . var_export($request, true));
        $txn_id = (isset($request['payload']['payment']['entity']['id'])) ? $request['payload']['payment']['entity']['id'] : "";
        if (!empty($request['payload']['payment']['entity']['id'])) {
            if (!empty($txn_id)) {
                $transaction = fetch_details('transactions', ['txn_id' => $txn_id]);
            }
            $amount = $request['payload']['payment']['entity']['amount'];
            $amount = ($amount / 100);
            $currency = (isset($request['payload']['payment']['entity']['currency'])) ? $request['payload']['payment']['entity']['currency'] : "";
        } else {
            $amount = 0;
            $currency = (isset($request['payload']['payment']['entity']['currency'])) ? $request['payload']['payment']['entity']['currency'] : "";
        }
        $is_for_additional_charge = isset($request['payload']['payment']['entity']['notes']['additional_charges_transaction_id']) ? $request['payload']['payment']['entity']['notes']['additional_charges_transaction_id'] : "";
        if (!empty($transaction)) {
            $order_id = $transaction[0]['order_id'];
            $user_id = $transaction[0]['user_id'];
            $order_data = fetch_details('orders', ["id" => $order_id]);
            $user_id = $order_data[0]['user_id'];
            $partner_id = $order_data[0]['partner_id'];
        } else if (!empty($request['payload']['payment']['entity']['notes']['transaction_id'])) {
            $transaction_id_actual = isset($request['payload']['payment']['entity']['notes']['transaction_id']) ? $request['payload']['payment']['entity']['notes']['transaction_id'] : "";
            //  log_message('error', 'transaction_id ID ********* ' . $request['payload']['payment']['entity']['notes']['transaction_id']);
        } else {
            $order_id = 0;
            $order_id = (isset($request['payload']['order']['entity']['notes']['order_id'])) ? $request['payload']['order']['entity']['notes']['order_id'] : $request['payload']['payment']['entity']['notes']['order_id'];
            $order_data = fetch_details('orders', ["id" => $order_id]);
            $user_id = $order_data[0]['user_id'];
            $partner_id = $order_data[0]['partner_id'];
        }
        if ($http_razorpay_signature) {
            if ($request['event'] == 'payment.authorized') {
                $currency = (isset($request['payload']['payment']['entity']['currency'])) ? $request['payload']['payment']['entity']['currency'] : "INR";
                $response = $razorpay->capture_payment($amount * 100, $txn_id, $currency);
                return;
            }
            if ($request['event'] == 'payment.captured' || $request['event'] == 'order.paid') {
                if (!empty($transaction_id_actual)) {
                    log_message('error', 'FOR SUBSCRIPTION');
                    log_message('error', ' ID ********* ' . $request['payload']['payment']['entity']['notes']['transaction_id']);
                    log_message('error', 'transaction_id  ********* ' . $txn_id);
                    $transaction_details_for_subscription = fetch_details('transactions', ['id' => $request['payload']['payment']['entity']['notes']['transaction_id']]);
                    $details_for_subscription = fetch_details('subscriptions', ['id' => $transaction_details_for_subscription[0]['subscription_id']]);
                    update_details(['status' => 'success', 'txn_id' => $txn_id], ['id' => $request['payload']['payment']['entity']['notes']['transaction_id']], 'transactions');
                    // update_details(['status' => 'active'], ['subscription_id' => $transaction_details_for_subscription[0]['subscription_id'],'partner_id'=>$transaction_details_for_subscription[0]['user_id'],'status'=>'pending'], 'partner_subscriptions');
                    $purchaseDate = date('Y-m-d');
                    $subscriptionDuration = $details_for_subscription[0]['duration'];
                    $expiryDate = date('Y-m-d', strtotime($purchaseDate . ' + ' . $subscriptionDuration . ' days')); // Add the duration to the purchase date
                    if ($subscriptionDuration == "unlimited") {
                        $subscriptionDuration = 0;
                    }
                    update_details(['status' => 'active', 'is_payment' => '1', 'purchase_date' => $purchaseDate, 'expiry_date' => $expiryDate, 'updated_at' => date('Y-m-d h:i:s')], [
                        'subscription_id' => $transaction_details_for_subscription[0]['subscription_id'],
                        'partner_id' => $transaction_details_for_subscription[0]['user_id'],
                        'status !=' => 'active',
                        'transaction_id' => $request['payload']['payment']['entity']['notes']['transaction_id'],
                    ], 'partner_subscriptions');
                } else if (!empty($is_for_additional_charge)) {
                    log_message('error', 'FOR ADDITIONAL CHARGES');
                    update_details(['status' => 'success', 'txn_id' => $txn_id], ['id' => $is_for_additional_charge], 'transactions');
                    $order_data = fetch_details('orders', ["id" => $order_id]);
                    update_details(['payment_status_of_additional_charge' => '1'], ['id' => $order_id], 'orders');
                }
                if ($request['event'] == 'order.paid') {
                    $order_id = $request['payload']['order']['entity']['receipt'];
                    $order_data = fetch_details('orders', ["id" => $order_id]);
                    $user_id = $order_data[0]['user_id'];
                    $partner_id = $order_data[0]['partner_id'];
                }
                if (!empty($order_id)) {
                    /* No need to add because the transaction is already added just update the transaction status */
                    if (!empty($transaction)) {
                        $transaction_id = $transaction[0]['id'];
                        update_details(['status' => 'success'], ['id' => $transaction_id], 'transactions');
                    } else {
                        /* add transaction of the payment */
                        $currency = (isset($request['payload']['payment']['entity']['currency'])) ? $request['payload']['payment']['entity']['currency'] : "";
                        $data = [
                            'transaction_type' => 'transaction',
                            'user_id' => $user_id,
                            'partner_id' => $partner_id,
                            'order_id' => $order_id,
                            'type' => 'razorpay',
                            'txn_id' => $txn_id,
                            'amount' => $amount,
                            'status' => 'success',
                            'currency_code' => $currency,
                            'message' => 'Order placed successfully',
                        ];
                        $insert_id = add_transaction($data);
                        if ($insert_id) {
                            update_details(['payment_status' => 1], ['id' => $order_id], 'orders');
                            update_custom_job_status($order_id, 'booked');

send_web_notification('New Booking', 'Please check new Booking ' . $order_id, $partner_id);
                            //customer email
                            $userdata = fetch_details('users', ['id' => $user_id], ['email', 'username']);
                            if (!empty($userdata[0]['email']) && check_notification_setting('new_booking_confirmation_to_customer', 'email') && is_unsubscribe_enabled($user_id) == 1) {
                                send_custom_email('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            if (check_notification_setting('new_booking_confirmation_to_customer', 'sms')) {
                                send_custom_sms('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            //for provider
                            $user_partner_data = fetch_details('users', ['id' => $partner_id], ['email', 'username']);
                            if (!empty($user_partner_data[0]['email']) && check_notification_setting('new_booking_received_for_provider', 'email') && is_unsubscribe_enabled($partner_id) == 1) {
                                send_custom_email('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            if (check_notification_setting('new_booking_received_for_provider', 'sms')) {
                                send_custom_sms('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            //for app notification
                            $db      = \Config\Database::connect();
                            $to_send_id = $partner_id;

$fcm_ids = [];
                            $users_fcm = $db->table('users_fcm_ids')
                                ->select('fcm_id,platform')
                                ->where('user_id', $to_send_id)
                                ->whereIn('platform', ['android', 'ios', 'web', 'provider_panel'])
                                ->where('status', '1')
                                ->get()
                                ->getResultArray();
                            foreach ($users_fcm as $ids) {
                                if ($ids['fcm_id'] != "") {
                                    $fcm_ids['fcm_id'] = $ids['fcm_id'];
                                    $fcm_ids['platform'] = $ids['platform'];
                                    $email = $ids['email'];
                                }
                            }
                            if (!empty($fcm_ids) && check_notification_setting('new_booking_received_for_provider', 'notification')) {
                                $registrationIDs = $fcm_ids;
                                $registrationIDs_chunks = array_chunk($users_fcm, 1000);
                                $title = $this->trans->newBookingNotification;
                                $msg = $this->trans->newBookingReceivedMessage;
                                $type = 'order';
                                $fcmMsg = array(
                                    'content_available' => "true",
                                    'title' => $title,
                                    'body' => $msg,
                                    'type' => $type,
                                    'order_id' => "$order_id",
                                    'type_id' => "$to_send_id",
                                    'click_action' => 'FLUTTER_NOTIFICATION_CLICK',
                                );
                                // Use queued notifications for better performance
                                queue_notification($fcmMsg, $registrationIDs_chunks, [], 'default');
                                $store_notification = store_notifications($title, $msg, 'order', $partner_id, 0, 'general', now(), 'specific_user', '', '', $partner_id, 'pending', '', '', '', '');
                            }
                        }
                    }
                    // update_details(['active' => 'confirmed'], ['id' => $order_id], 'orders');
                } else {
                    log_message('error', 'Razorpay Order id not found --> ' . var_export($request, true));
                    /* No order ID found */
                }
            } elseif ($request['event'] == 'payment.failed') {

if (!empty($is_for_additional_charge)) {
                    log_message('error', 'FOR ADDITIONAL CHARGES');
                    update_details(['status' => 'failed', 'txn_id' => $txn_id], ['id' => $is_for_additional_charge], 'transactions');
                    $order_data = fetch_details('orders', ["id" => $order_id]);
                    update_details(['payment_status_of_additional_charge' => '2'], ['id' => $order_id], 'orders');
                } else {
                    update_details(['payment_status' => 2], ['id' => $order_id], 'orders');
                    update_details(['status' => 'cancelled'], ['id' => $order_id], 'orders');
                    if (!empty($transaction)) {
                        $transaction_id = $transaction[0]['id'];
                        update_details(['status' => 'failed'], ['id' => $transaction_id], 'transactions');
                    } else {
                        /* add transaction of the payment */
                        $currency = (isset($request['payload']['payment']['entity']['currency'])) ? $request['payload']['payment']['entity']['currency'] : "";
                        $data = [
                            'transaction_type' => 'transaction',
                            'user_id' => $user_id,
                            'partner_id' => $partner_id,
                            'order_id' => $order_id,
                            'type' => 'razorpay',
                            'txn_id' => $txn_id,
                            'amount' => $amount,
                            'status' => 'failed',
                            'currency_code' => $currency,
                            'message' => 'Booking is cancelled',
                        ];
                        $insert_id = add_transaction($data);
                        update_custom_job_status($order_id, 'cancelled');
                    }
                    log_message('error', 'Razorpay Webhook | Transaction is failed --> ' . var_export($request['event'], true));
                }
            } elseif ($request['event'] == 'payment.authorized') {
                if (!empty($order_id)) {
                    update_details(['active_status' => 'awaiting'], ['id' => $order_id], 'orders');
                    update_details(['active_status' => 'awaiting'], ['order_id' => $order_id], 'order_items');
                    update_custom_job_status($order_id, 'requested');
                }
            } elseif ($request['event'] == "refund.processed") {
                log_message('error', 'Razorpay REFUND ');
                log_message('error', 'Razorpay TXN ID --> ' . $txn_id);
                $success_transaction = fetch_details('transactions', ['transaction_type' => 'transaction', 'type' => 'razorpay', 'status' => 'success', 'txn_id' => $txn_id]);
                if (!empty($success_transaction)) {
                    $already_exist_refund_transaction = fetch_details('transactions', ['transaction_type' => 'refund', 'type' => 'razorpay', 'message' => 'razorpay_refund', 'txn_id' => $txn_id]);
                    if (!empty($already_exist_refund_transaction)) {
                        $refund_data = [
                            'status' => 'processed',
                        ];
                        update_details($refund_data, ['id' =>  $already_exist_refund_transaction[0]['id']], 'transactions');
                    } else {
                        $data = [
                            'transaction_type' => 'refund',
                            'user_id' => $user_id,
                            'partner_id' => $partner_id,
                            'order_id' => $order_id,
                            'type' => 'razorpay',
                            'txn_id' => $txn_id,
                            'amount' => $amount,
                            'status' => 'processed',
                            'currency_code' => $currency,
                            'message' => 'razorpay_refund',
                        ];
                        $insert_id = add_transaction($data);
                        update_custom_job_status($order_id, 'refunded');
                    }
                }
            } elseif ($request['event'] == "refund.failed") {

$response['error'] = true;
                $response['transaction_status'] = $request['event'];
                $response['message'] = "Refund is failed. ";
                log_message('error', 'Razorpay Webhook | Payment refund failed --> ' . var_export($request['event'], true));
                echo json_encode($response);
                return false;
            }
            //  else {
            //     $response['error'] = true;
            //     $response['transaction_status'] = $request['event'];
            //     $response['message'] = "Transaction could not be detected.";
            //     log_message('error', 'Razorpay Webhook | Transaction could not be detected --> ' . var_export($request['event'], true));
            //     echo json_encode($response);
            //     return false;
            // }
        } else {
            log_message('error', 'razorpay Webhook | Invalid Server Signature  --> ' . var_export($request['event'], true));
            return false;
        }
    }
    public function edie($error_msg)
    {
        global $debug_email;
        $report =  "ERROR : " . $error_msg . "\n\n";
        $report .= "POST DATA\n\n";
        foreach ($_POST as $key => $value) {
            $report .= "|$key| = |$value| \n";
        }
        log_message('error', $report);
        die($error_msg);
    }
    public function paypal()
    {
        $req = 'cmd=_notify-validate';
        $request_body = file_get_contents('php://input');
        parse_str($request_body, $event);
        log_message('error', 'paypal------' . var_export($event, true));
        $txn_id = (isset($event['txn_id'])) ? $event['txn_id'] : "";
        if (!empty($request_body)) {
            $ipnCheck = $this->paypal_lib->validate_ipn($event);
            if ($ipnCheck) {
                if (!empty($event['txn_id'])) {
                    if (!empty($txn_id)) {
                        $transaction = fetch_details('transactions', ['txn_id' => $txn_id]);
                    }
                    $amount = $event['payment_gross'];
                    $amount = ($amount);
                    $currency = (isset($event['mc_currency'])) ? $event['mc_currency'] : "";
                } else {
                    $amount = 0;
                    $currency = (isset($event['mc_currency'])) ? $event['mc_currency'] : "";
                }
                $custom_data = explode('|', $event['custom']); // Split the invoice string
                $is_subscripition = $custom_data[2] ?? null;
                $is_for_additional_charge = $custom_data[2] ?? null;
                if (!empty($transaction)) {
                    $order_id = $transaction[0]['order_id'];
                    $order_data = fetch_details('orders', ["id" => $order_id]);
                    $user_id = $order_data[0]['user_id'];
                    $partner_id = $order_data[0]['partner_id'];
                } else {
                    $order_id = 0;
                    $order_id = (isset($event['item_number'])) ? $event['item_number'] : $event['item_number'];
                    $order_data = fetch_details('orders', ["id" => $order_id]);
                    if (!empty($order_data)) {
                        $user_id = $order_data[0]['user_id'];
                        $partner_id = $order_data[0]['partner_id'];
                    }
                }
                // log_message('error', var_export($transaction, true));
                if ($event['payment_status'] == "Completed") {
                    if ($is_subscripition == "subscription") {
                        if (isset($event['custom']) && !empty($event['custom'])) {
                            $subsciption_data = explode('|', $event['custom']); // Split the invoice string
                            $transaction_id = $subsciption_data[0] ?? null;
                            if (!empty($transaction_id) && $transaction_id != null) {
                                $transaction_details_for_subscription = fetch_details('transactions', ['id' => $transaction_id]);
                                if (!empty($transaction_details_for_subscription)) {
                                    $details_for_subscription = fetch_details('subscriptions', ['id' => $transaction_details_for_subscription[0]['subscription_id']]);
                                    log_message('error', 'FOR SUBSCRIPTION');
                                    update_details(['status' => 'success', 'txn_id' => $txn_id], ['id' => $transaction_id], 'transactions');
                                    $purchaseDate = date('Y-m-d');
                                    $subscriptionDuration = $details_for_subscription[0]['duration'];
                                    $expiryDate = date('Y-m-d', strtotime($purchaseDate . ' + ' . $subscriptionDuration . ' days')); // Add the duration to the purchase date
                                    if ($subscriptionDuration == "unlimited") {
                                        $subscriptionDuration = 0;
                                    }
                                    update_details(['status' => 'active', 'is_payment' => '1', 'purchase_date' => $purchaseDate, 'expiry_date' => $expiryDate, 'updated_at' => date('Y-m-d h:i:s')], [
                                        'subscription_id' => $transaction_details_for_subscription[0]['subscription_id'],
                                        'partner_id' => $transaction_details_for_subscription[0]['user_id'],
                                        'status !=' => 'active',
                                        'transaction_id' => $transaction_id,
                                    ], 'partner_subscriptions');
                                }
                                // log_message('error', 'METAFDATA --> ' . var_export($event['data']['metadata']['transaction_id'], true));
                            }
                        }
                    } else if (isset($is_for_additional_charge)) {
                        log_message('error', 'FOR ADDITIONAL CHARGES');
                        update_details(['status' => 'success', 'txn_id' => $txn_id], ['id' => $custom_data[2]], 'transactions');
                        $order_data = fetch_details('orders', ["id" => $order_id]);
                        update_details(['payment_status_of_additional_charge' => '1'], ['id' => $order_id], 'orders');
                    } else {
                        if (!empty($order_id)) {
                            /* No need to add because the transaction is already added just update the transaction status */
                            if (!empty($transaction)) {
                                $transaction_id = $transaction[0]['id'];
                                update_details(['status' => 'success'], ['id' => $transaction_id], 'transactions');
                            } else {
                                log_message('error', 'add transaction of the payment');
                                /* add transaction of the payment */
                                $currency = (isset($event['mc_currency'])) ? $event['mc_currency'] : "";
                                $data = [
                                    'transaction_type' => 'transaction',
                                    'user_id' => $user_id,
                                    'partner_id' => $partner_id,
                                    'order_id' => $order_id,
                                    'type' => 'paypal',
                                    'txn_id' => $txn_id,
                                    'amount' => $amount,
                                    'status' => 'success',
                                    'currency_code' => $currency,
                                    'message' => 'Order placed successfully',
                                ];
                                $insert_id = add_transaction($data);
                            }
                            if ($insert_id) {
                                update_details(['payment_status' => 1], ['id' => $order_id], 'orders');
                                update_custom_job_status($order_id, 'booked');

// send_web_notification('New Order', 'Please check new order ' . $order_id, $partner_id);
                                send_web_notification('New Booking Notification', 'We are pleased to inform you that you have received a new Booking.');
                                $settings = get_settings('general_settings', true);
                                $icon = $settings['logo'];
                                //customer email
                                $userdata = fetch_details('users', ['id' => $user_id], ['email', 'username']);
                                if (!empty($userdata[0]['email']) && check_notification_setting('new_booking_confirmation_to_customer', 'email') && is_unsubscribe_enabled($user_id) == 1) {
                                    send_custom_email('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                                }
                                if (check_notification_setting('new_booking_confirmation_to_customer', 'sms')) {
                                    send_custom_sms('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                                }
                                //for provider
                                $user_partner_data = fetch_details('users', ['id' => $partner_id], ['email', 'username']);
                                if (!empty($user_partner_data[0]['email']) && check_notification_setting('new_booking_received_for_provider', 'email') && is_unsubscribe_enabled($partner_id) == 1) {
                                    send_custom_email('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                                }
                                if (check_notification_setting('new_booking_received_for_provider', 'sms')) {
                                    send_custom_sms('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                                }
                                //for app notification
                                $db      = \Config\Database::connect();
                                $to_send_id = $partner_id;
                                $users_fcm = $db->table('users_fcm_ids')
                                    ->select('fcm_id,platform')
                                    ->where('user_id', $to_send_id)
                                    ->whereIn('platform', ['android', 'ios', 'web', 'provider_panel'])
                                    ->where('status', '1')
                                    ->get()
                                    ->getResultArray();
                                foreach ($users_fcm as $ids) {
                                    if ($ids['fcm_id'] != "") {
                                        $fcm_ids['fcm_id'] = $ids['fcm_id'];
                                        $fcm_ids['platform'] = $ids['platform'];
                                        $email = $ids['email'];
                                    }
                                }
                                if (!empty($fcm_ids) && check_notification_setting('new_booking_received_for_provider', 'notification')) {
                                    $registrationIDs = $fcm_ids;
                                    $registrationIDs_chunks = array_chunk($users_fcm, 1000);
                                    $fcmMsg = array(
                                        'content_available' => "true",
                                        'title' => $this->trans->newBookingNotification,
                                        'body' => $this->trans->newBookingReceivedMessage,
                                        'type' => 'order',
                                        'order_id' => "$order_id",
                                        'type_id' => "$to_send_id",
                                        'click_action' => 'FLUTTER_NOTIFICATION_CLICK',
                                    );
                                    // Use queued notifications for better performance
                                    queue_notification($fcmMsg, $registrationIDs_chunks, [], 'default');
                                }
                                $response['error'] = false;
                                $response['transaction_status'] = $event['payment_status'];
                                $response['message'] = "Transaction successfully done";
                                log_message('error', 'Transaction successfully done');
                            } else {
                                $response['error'] = true;
                                $response['message'] = "something went wrong";
                                log_message('error', 'something went wrong');
                            }
                            // update_details(['status' => 'confirmed'], ['id' => $order_id], 'orders');
                            $response['error'] = false;
                            $response['transaction_status'] = $event['payment_status'];
                            $response['message'] = "Transaction successfully done";
                            echo json_encode($response);
                            log_message('error', 'Transaction successfully done ');
                        }
                    }
                } else if ($event['payment_status'] == "Refunded") {
                    log_message('error', 'Paypal Webhook | REFUND ');
                    $success_transaction = fetch_details('transactions', ['transaction_type' => 'transaction', 'type' => 'paypal', 'status' => 'success', 'txn_id' => $txn_id]);
                    if (!empty($success_transaction)) {
                        $already_exist_refund_transaction = fetch_details('transactions', ['transaction_type' => 'refund', 'type' => 'paypal', 'message' => 'paypal_refund', 'txn_id' => $txn_id]);
                        if (!empty($already_exist_refund_transaction)) {
                            $refund_data = [
                                'status' => 'COMPLETED',
                            ];
                            update_details($refund_data, ['id' =>  $already_exist_refund_transaction[0]['id']], 'transactions');
                        } else {
                            $data = [
                                'transaction_type' => 'refund',
                                'user_id' => $user_id,
                                'partner_id' => $partner_id,
                                'order_id' => $order_id,
                                'type' => 'paypal',
                                'txn_id' => $txn_id,
                                'amount' => $amount,
                                'status' => 'COMPLETED',
                                'currency_code' => $currency,
                                'message' => 'paypal_refund',
                            ];
                            $insert_id = add_transaction($data);
                            update_custom_job_status($order_id, 'refunded');
                        }
                    }
                } else {
                    log_message('error', 'Something went wrong1111');
                }
                log_message('error', 'SUCCESS');
            } else {
                log_message('error', 'IPN failed');
            }
        }
    }
    public function flutterwave()
    {
        log_message('error', " flutterwave Webhook called");
        $request_body = file_get_contents('php://input');
        $event = json_decode($request_body, FALSE);
        log_message('error', 'Flutterwave Webhook --> ' . var_export($event, true));
        $flutterwave = new Flutterwave();
        $verifiy = $flutterwave->verify_transaction($event->data->id);
        $credentials = $flutterwave->get_credentials();
        $local_secret_hash = $credentials['secret_hash'];
        $from_env = env('FLUTTERWAVE_SECRET_KEY');
        $signature = (isset($_SERVER['FLUTTERWAVE_SECRET_KEY'])) ? $_SERVER['FLUTTERWAVE_SECRET_KEY'] : '';
        log_message('error', 'FlutterWave Webhook - header signature --> ' . var_export($signature, true));
        /* comparing our local signature with received signature */
        if (empty($signature) || $signature != $local_secret_hash) {
            log_message('error', 'FlutterWave Webhook - Invalid Signature - JSON DATA --> ' . var_export($event, true));
            // log_message('error', 'FlutterWave Server Variable invalid --> ' . var_export($_SERVER, true));
            return false;
        }
        $response = json_decode($verifiy);
        log_message('error', 'verified response : ' . var_export($response, true));
        $status = $response->status;
        if (!empty($event->data)) {
            $txn_id = (isset($event->data->id)) ? $event->data->id : "";
            if (isset($txn_id) && !empty($txn_id)) {
                $transaction = fetch_details('transactions', ['txn_id' => $txn_id]);
                if (!empty($transaction)) {
                    $order_id = $transaction[0]['order_id'];
                    $user_id = $transaction[0]['user_id'];
                } else {
                    if (!empty($response->data->meta->transaction_id)) {
                    } else {
                        if (isset($response->data->meta->order_id) && !empty($response->data->meta->order_id)) {
                            $order_id = 0;
                            $order_id = $response->data->meta->order_id;
                            $order_data = fetch_details('orders', ["id" => $order_id]);
                            $user_id = $order_data[0]['user_id'];
                            $partner_id = $order_data[0]['partner_id'];
                        }
                    }
                }
            }
            $amount = $event->data->amount;
            $currency = $event->data->currency;
        } else {
            $order_id = 0;
            $amount = 0;
            $currency = (isset($event->data->currency)) ? $event->data->currency : "";
        }
        if ($event->event == 'charge.completed' && $event->data->status == 'successful') {
            if (!empty($response->data->meta->transaction_id)) {
                $transaction_details_for_subscription = fetch_details('transactions', ['id' => $response->data->meta->transaction_id]);
                $details_for_subscription = fetch_details('subscriptions', ['id' => $transaction_details_for_subscription[0]['subscription_id']]);
                log_message('error', 'FOR SUBSCRIPTION');
                update_details(['status' => 'success', 'txn_id' => $txn_id, 'reference' => $event->data->tx_ref], ['id' => $response->data->meta->transaction_id], 'transactions');
                $purchaseDate = date('Y-m-d');
                $subscriptionDuration = $details_for_subscription[0]['duration'];
                $expiryDate = date('Y-m-d', strtotime($purchaseDate . ' + ' . $subscriptionDuration . ' days')); // Add the duration to the purchase date
                if ($subscriptionDuration == "unlimited") {
                    $subscriptionDuration = 0;
                }
                log_message('error', 'transaction id from metadata : ' . var_export($response->data->meta->transaction_id, true));
                update_details(['status' => 'active', 'is_payment' => '1', 'purchase_date' => $purchaseDate, 'expiry_date' => $expiryDate, 'updated_at' => date('Y-m-d h:i:s')], [
                    'subscription_id' => $transaction_details_for_subscription[0]['subscription_id'],
                    'partner_id' => $transaction_details_for_subscription[0]['user_id'],
                    'status !=' => 'active',
                    'transaction_id' => $response->data->meta->transaction_id,
                ], 'partner_subscriptions');
            } else if (!empty($response->data->meta->additional_charges_transaction_id)) {
                log_message('error', 'FOR ADDITIONAL CHARGES');
                update_details(['status' => 'success', 'txn_id' => $txn_id], ['id' => $response->data->meta->additional_charges_transaction_id], 'transactions');
                $order_data = fetch_details('orders', ["id" => $order_id]);
                update_details(['payment_status_of_additional_charge' => '1'], ['id' => $order_id], 'orders');
            } else {
                if (!empty($order_id)) {
                    $order = fetch_details('orders', ['id' => $order_id]);
                    log_message('error', 'Flutterwave Webhook | order --> ' . var_export($order, true));
                    /* No need to add because the transaction is already added just update the transaction status */
                    if (!empty($transaction)) {
                        $transaction_id = $transaction[0]['id'];
                        update_details(['status' => 'success'], ['id' => $transaction_id], 'transactions');
                    } else {
                        /* add transaction of the payment */
                        $amount = ($event->data->amount / 100);
                        $data = [
                            'transaction_type' => 'transaction',
                            'user_id' => $user_id,
                            'partner_id' => $partner_id,
                            'order_id' => $order_id,
                            'type' => 'flutterwave',
                            'txn_id' => $txn_id,
                            'amount' => $amount,
                            'status' => 'success',
                            'currency_code' => $currency,
                            'message' => 'Order placed successfully',
                            'reference' => (isset($event->data->tx_ref)) ? $event->data->tx_ref : "",
                        ];
                        $insert_id = add_transaction($data);
                        if ($insert_id) {
                            update_details(['payment_status' => 1], ['id' => $order_id], 'orders');
                            update_custom_job_status($order_id, 'booked');

send_web_notification('New Booking Notification', 'We are pleased to inform you that you have received a new Booking.');
                            //customer email
                            $userdata = fetch_details('users', ['id' => $user_id], ['email', 'username']);
                            if (!empty($userdata[0]['email']) && check_notification_setting('new_booking_confirmation_to_customer', 'email') && is_unsubscribe_enabled($user_id) == 1) {
                                send_custom_email('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            if (check_notification_setting('new_booking_confirmation_to_customer', 'sms')) {
                                send_custom_sms('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            //for provider
                            $user_partner_data = fetch_details('users', ['id' => $partner_id], ['email', 'username']);
                            if (!empty($user_partner_data[0]['email']) && check_notification_setting('new_booking_received_for_provider', 'email') && is_unsubscribe_enabled($partner_id) == 1) {
                                send_custom_email('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            if (check_notification_setting('new_booking_received_for_provider', 'sms')) {
                                send_custom_sms('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
                            }
                            //for app notification
                            $db      = \Config\Database::connect();
                            $to_send_id = $partner_id;
                            $builder = $db->table('users')->select('fcm_id,email,username,platform');
                            $users_fcm = $builder->where('id', $to_send_id)->get()->getResultArray();
                            foreach ($users_fcm as $ids) {
                                if ($ids['fcm_id'] != "") {
                                    $fcm_ids['fcm_id'] = $ids['fcm_id'];
                                    $fcm_ids['platform'] = $ids['platform'];
                                    $email = $ids['email'];
                                }
                            }
                            if (!empty($fcm_ids)  && check_notification_setting('new_booking_received_for_provider', 'notification')) {
                                $registrationIDs = $fcm_ids;
                                $registrationIDs_chunks = array_chunk($users_fcm, 1000);
                                $fcmMsg = array(
                                    'content_available' => "true",
                                    'title' => $this->trans->newBookingNotification,
                                    'body' => $this->trans->newBookingReceivedMessage,
                                    'type' => 'order',
                                    'order_id' => "$order_id",
                                    'type_id' => "$to_send_id",
                                    'click_action' => 'FLUTTER_NOTIFICATION_CLICK',
                                );
                                // Use queued notifications for better performance
                                queue_notification($fcmMsg, $registrationIDs_chunks, [], 'default');
                            }
                            $response['error'] = false;
                            $response['transaction_status'] = "flutterwave";
                            $response['message'] = "Transaction successfully done";
                            return $this->response->setJSON($response);
                        } else {
                            $response['error'] = true;
                            $response['message'] = "something went wrong";
                            return $this->response->setJSON($response);
                        }
                    }
                    log_message('error', 'Flutterwave Webhook inner Success --> ' . var_export($event, true));
                    log_message('error', 'Flutterwave Webhook order Success --> ' . var_export($event, true));
                } else {
                    /* No order ID found / sending 304 error to payment gateway so it retries wenhook after sometime*/
                    log_message('error', 'Flutterwave Webhook | Order id not found --> ' . var_export($event, true));
                }
            }
        } else {
            if (!empty($response->data->meta->additional_charges_transaction_id)) {
                log_message('error', 'FOR ADDITIONAL CHARGES');
                update_details(['status' => 'failed', 'txn_id' => $txn_id], ['id' => $response->data->meta->additional_charges_transaction_id], 'transactions');
                $order_data = fetch_details('orders', ["id" => $order_id]);
                update_details(['payment_status_of_additional_charge' => '2'], ['id' => $order_id], 'orders');
            } else {
                if (!empty($order_id) && is_numeric($order_id)) {
                    update_details(['status' => 'cancelled'], ['id' => $order_id], 'orders');
                }
                update_custom_job_status($order_id, 'cancelled');
                /* No need to add because the transaction is already added just update the transaction status */
                if (!empty($transaction)) {
                    $transaction_id = $transaction[0]['id'];
                    update_details(['status' => 'failed'], ['id' => $transaction_id], 'transactions');
                    update_details(['payment_status' => 2], ['id' => $order_id], 'orders');
                }
                $response['error'] = true;
                $response['transaction_status'] = $event['event'];
                $response['message'] = "Transaction could not be detected.";
                echo json_encode($response);
                return false;
            }
        }
    }

public function xendit()
    {
        try {
            // Log the webhook call (consistent with other gateways)
            log_message('error', 'Xendit Webhook called');

$request_body = file_get_contents('php://input');
            $event = json_decode($request_body, true);

// Log the full event payload for debugging
            log_message('error', 'Xendit Webhook event: ' . var_export($event, true));

// Verify webhook signature
            $signature = $_SERVER['HTTP_X_CALLBACK_TOKEN'] ?? '';
            $xendit = new Xendit();

if (!$xendit->verify_webhook($signature)) {
                log_message('error', 'Xendit Webhook - Invalid signature');
                http_response_code(401);
                return false;
            }

// Handle event-based and status-based webhooks
            $event_type = $event['event'] ?? null;

// Handle event-based webhooks first
            if ($event_type) {
                log_message('error', 'Xendit Webhook - Event type: ' . $event_type);
                switch ($event_type) {
                    case 'invoice.paid':
                        $this->handle_xendit_invoice_paid($event);
                        break;
                    case 'invoice.expired':
                        $this->handle_xendit_invoice_expired($event);
                        break;
                    case 'invoice.payment_failed':
                        $this->handle_xendit_invoice_failed($event);
                        break;
                    case 'refund.succeeded':
                        // New standardized refund webhook format
                        $this->handle_xendit_refund_processed($event, 'new_format');
                        break;
                    case 'refund.failed':
                        // New standardized refund webhook format
                        $this->handle_xendit_refund_failed($event, 'new_format');
                        break;
                    case 'ewallet.refund':
                        // E-wallet specific refund format with nested data structure
                        $this->handle_xendit_refund_processed($event, 'ewallet_format');
                        break;
                    case 'refund.completed':
                        // Legacy format - maintain backward compatibility
                        $this->handle_xendit_refund_processed($event, 'legacy_format');
                        break;
                    default:
                        log_message('error', 'Xendit Webhook - Unhandled event type: ' . $event_type);
                        break;
                }
            }
            // Fallback: If no event, use status (for compatibility with Xendit webhooks that only send 'status')
            else if (isset($event['status'])) {
                switch (strtoupper($event['status'])) {
                    case 'PAID':
                        $this->handle_xendit_invoice_paid($event);
                        $event_type = 'invoice.paid';
                        break;
                    case 'EXPIRED':
                        $this->handle_xendit_invoice_expired($event);
                        $event_type = 'invoice.expired';
                        break;
                    case 'FAILED':
                        $this->handle_xendit_invoice_failed($event);
                        $event_type = 'invoice.payment_failed';
                        break;
                    case 'REFUNDED':
                    case 'REFUND_SUCCEEDED':
                        // Status-based fallback - use legacy format for backward compatibility
                        $this->handle_xendit_refund_processed($event, 'legacy_format');
                        $event_type = 'refund.succeeded';
                        break;
                    case 'REFUND_FAILED':
                        // Status-based fallback - use legacy format for backward compatibility
                        $this->handle_xendit_refund_failed($event, 'legacy_format');
                        $event_type = 'refund.failed';
                        break;
                    default:
                        log_message('error', 'Xendit Webhook - Unhandled status: ' . $event['status']);
                        break;
                }
            }

$response = [
                'error' => false,
                'message' => 'Webhook processed successfully'
            ];
            echo json_encode($response);
        } catch (\Exception $th) {
            log_message('error', 'Xendit Webhook Error: ' . $th->getMessage());
            $response = [
                'error' => true,
                'message' => 'Webhook processing failed'
            ];
            echo json_encode($response);
        }
    }

private function handle_xendit_invoice_paid($event)
    {
        try {
            $external_id = $event['external_id'] ?? '';
            $amount = $event['amount'] ?? 0;
            $paid_amount = $event['paid_amount'] ?? 0;
            $payment_id = $event['payment_id'] ?? '';
            $payment_method = $event['payment_method'] ?? '';
            $invoice_id = $event['id'] ?? '';

if (empty($external_id)) {
                log_message('error', 'Xendit Webhook - No external_id provided');
                return false;
            }

$invoice_type = explode('_', $external_id);
            if ($invoice_type[0] == 'subscription') {
                $subscription_id = $invoice_type[1];
                $partner_id = $invoice_type[2];

// Handle subscription payment
                $this->handle_xendit_subscription_payment($event, $external_id, $subscription_id, $partner_id, $payment_id, $paid_amount);
                return true;
            }

// Check if this is an additional charges payment
            if ($invoice_type[0] == 'additionalCharges') {
                $additional_charges_transaction_id = $invoice_type[1];
                $this->handle_xendit_additional_charges_payment($event, $additional_charges_transaction_id, $payment_id, $paid_amount);
                return true;
            }

// Handle regular order payment
            if ($invoice_type[0] == 'order') {
                $order_id = $invoice_type[1];
                $this->handle_xendit_order_payment($event, $external_id, $order_id, $payment_id, $paid_amount);
                return true;
            }

log_message('error', 'Xendit Webhook - Invalid external_id format: ' . $external_id);
            return false;
        } catch (\Exception $th) {
            log_message('error', 'Xendit Webhook - Error processing paid invoice: ' . $th->getMessage());
            return false;
        }
    }

private function handle_xendit_subscription_payment($event, $external_id, $subscription_id, $partner_id, $payment_id, $paid_amount)
    {
        try {
            // Find the transaction using external_id first
            $transaction = fetch_details('transactions', ['txn_id' => $external_id, 'user_id' => $partner_id]);

// If not found by external_id, try to find by metadata in the invoice
            if (empty($transaction)) {
                $metadata = $event['metadata'] ?? [];
                $transaction_id_from_metadata = $metadata['transaction_id'] ?? null;

if ($transaction_id_from_metadata) {
                    $transaction = fetch_details('transactions', ['id' => $transaction_id_from_metadata, 'user_id' => $partner_id]);
                    log_message('error', 'Xendit Webhook - Found transaction by metadata transaction_id: ' . $transaction_id_from_metadata);
                }
            }

// If still not found, try to find the most recent pending transaction for this partner and subscription
            if (empty($transaction)) {
                $transaction = fetch_details('transactions', [
                    'user_id' => $partner_id,
                    'subscription_id' => $subscription_id,
                    'type' => 'xendit',
                    'status' => 'pending'
                ], '*', 1, 'id', 'DESC');

log_message('error', 'Xendit Webhook - Found transaction by subscription_id and status: ' . (!empty($transaction) ? $transaction[0]['id'] : 'None'));
            }

// If still not found, try to find any recent xendit transaction for this partner
            if (empty($transaction)) {
                $transaction = fetch_details('transactions', [
                    'user_id' => $partner_id,
                    'type' => 'xendit'
                ], '*', 1, 'id', 'DESC');

log_message('error', 'Xendit Webhook - Found recent xendit transaction: ' . (!empty($transaction) ? $transaction[0]['id'] : 'None'));
            }

if (!empty($transaction)) {
                $transaction_id = $transaction[0]['id'];

// Check if transaction is already processed to prevent duplicate processing
                if ($transaction[0]['status'] === 'success') {
                    log_message('error', 'Xendit Webhook - Transaction already processed: ' . $transaction_id);
                    return true;
                }

// Store additional transaction data in reference column as JSON
                $payment_reference_data = [
                    'payment_id' => $payment_id,
                    'external_id' => $external_id,
                    'invoice_id' => $event['id'] ?? '',
                    'payment_method' => $event['payment_method'] ?? '',
                    'webhook_type' => 'subscription_payment',
                    'paid_at' => $event['paid_at'] ?? date('Y-m-d H:i:s'),
                    'raw_event' => $event
                ];

// Update transaction status and external_id
                update_details([
                    'status' => 'success',
                    'amount' => $paid_amount,
                    'txn_id' => $external_id, // Ensure external_id is set
                    'currency_code' => $event['currency'] ?? 'IDR',
                    'reference' => json_encode($payment_reference_data),
                ], ['id' => $transaction_id], 'transactions');

// Get subscription details
                $subscription_details = fetch_details('subscriptions', ['id' => $subscription_id]);
                if (!empty($subscription_details)) {
                    $purchaseDate = date('Y-m-d');
                    $subscriptionDuration = $subscription_details[0]['duration'];
                    $expiryDate = date('Y-m-d', strtotime($purchaseDate . ' + ' . $subscriptionDuration . ' days'));

if ($subscriptionDuration == "unlimited") {
                        $subscriptionDuration = 0;
                    }

// First, try to update existing subscription
                    $update_result = update_details([
                        'status' => 'active',
                        'is_payment' => '1',
                        'purchase_date' => $purchaseDate,
                        'expiry_date' => $expiryDate,
                        'updated_at' => date('Y-m-d H:i:s'),
                        'transaction_id' => $transaction_id
                    ], [
                        'subscription_id' => $subscription_id,
                        'partner_id' => $partner_id,
                        'status !=' => 'active'
                    ], 'partner_subscriptions');

// If no existing subscription was updated, create a new one
                    if (!$update_result) {
                        // Check if there's already an active subscription for this partner
                        $existing_subscription = fetch_details('partner_subscriptions', [
                            'partner_id' => $partner_id,
                            'status' => 'active'
                        ]);

if (!empty($existing_subscription)) {
                            // Deactivate existing subscription
                            update_details(['status' => 'expired'], ['id' => $existing_subscription[0]['id']], 'partner_subscriptions');
                        }

// Add new subscription
                        add_subscription($subscription_id, $partner_id, $transaction_id);
                        log_message('error', 'Xendit Webhook - New partner subscription created');
                    } else {
                        log_message('error', 'Xendit Webhook - Partner subscription updated successfully');
                    }
                }

log_message('error', 'Xendit Webhook - Subscription payment processed successfully for partner: ' . $partner_id . ', transaction_id: ' . $transaction_id . ', subscription_id: ' . $subscription_id);
            } else {
                log_message('error', 'Xendit Webhook - No transaction found for external_id: ' . $external_id . ', partner_id: ' . $partner_id . ', subscription_id: ' . $subscription_id);
            }
        } catch (\Exception $th) {
            log_message('error', 'Xendit Webhook - Error processing subscription payment: ' . $th->getMessage());
        }
    }

private function handle_xendit_additional_charges_payment($event, $additional_charges_transaction_id, $payment_id, $paid_amount)
    {
        try {
            // Store additional charges data in reference column as JSON
            $additional_charges_reference_data = [
                'payment_id' => $payment_id,
                'invoice_id' => $event['id'] ?? '',
                'payment_method' => $event['payment_method'] ?? '',
                'webhook_type' => 'additional_charges_payment',
                'paid_at' => $event['paid_at'] ?? date('Y-m-d H:i:s'),
                'raw_event' => $event
            ];

// Update additional charges transaction
            update_details([
                'status' => 'success',
                'amount' => $paid_amount,
                'txn_id' => $payment_id,
                'currency_code' => $event['currency'] ?? 'IDR',
                'reference' => json_encode($additional_charges_reference_data),
            ], ['id' => $additional_charges_transaction_id], 'transactions');

// Update order additional charges payment status
            $transaction = fetch_details('transactions', ['id' => $additional_charges_transaction_id]);

if (!empty($transaction)) {
                $order_id = $transaction[0]['order_id'];
                update_details(['payment_status_of_additional_charge' => '1'], ['id' => $order_id], 'orders');
            }

log_message('error', 'Xendit Webhook - Additional charges payment processed successfully');
        } catch (\Exception $th) {
            log_message('error', 'Xendit Webhook - Error processing additional charges payment: ' . $th->getMessage());
        }
    }

private function handle_xendit_order_payment($event, $external_id, $order_id, $payment_id, $paid_amount)
    {
        try {
            $order_data = fetch_details('orders', ['id' => $order_id]);
            if (empty($order_data)) {
                log_message('error', 'Xendit Webhook - Order not found: ' . $order_id);
                return false;
            }

$user_id = $order_data[0]['user_id'];
            $partner_id = $order_data[0]['partner_id'];

$transaction = fetch_details('transactions', ['order_id' => $order_id, 'txn_id' => $external_id]);
            if (!empty($transaction)) {
                $transaction_id = $transaction[0]['id'];

// Store order payment data in reference column as JSON
                $order_payment_reference_data = [
                    'payment_id' => $payment_id,
                    'external_id' => $external_id,
                    'invoice_id' => $event['id'] ?? '',
                    'payment_method' => $event['payment_method'] ?? '',
                    'webhook_type' => 'order_payment',
                    'paid_at' => $event['paid_at'] ?? date('Y-m-d H:i:s'),
                    'raw_event' => $event
                ];

update_details([
                    'status' => 'success',
                    'amount' => $paid_amount,
                    'txn_id' => $payment_id,
                    'currency_code' => $event['currency'] ?? 'IDR',
                    'message' => 'Order placed successfully',
                    'reference' => json_encode($order_payment_reference_data),
                ], ['id' => $transaction_id], 'transactions');

update_details(['payment_status' => 1], ['id' => $order_id], 'orders');
                update_custom_job_status($order_id, 'booked');

// Clear cart
                $cart_data = fetch_cart(true, $user_id);
                if (!empty($cart_data)) {
                    foreach ($cart_data['data'] as $row) {
                        delete_details(['id' => $row['id']], 'cart');
                    }
                }

// Send notifications
                $this->send_xendit_order_notifications($order_id, $user_id, $partner_id);

log_message('error', 'Xendit Webhook - Payment processed successfully for order: ' . $order_id);
                return true;
            }

return false;
        } catch (\Exception $th) {
            log_message('error', 'Xendit Webhook - Error processing order payment: ' . $th->getMessage());
            return false;
        }
    }

private function handle_xendit_invoice_expired($event)
    {
        try {
            $external_id = $event['external_id'] ?? '';

$invoice_type = explode('_', $external_id);
            if ($invoice_type[0] == 'subscription') {
                $subscription_id = $invoice_type[1];
                $partner_id = $invoice_type[2];
                // Update subscription status
                update_details(['status' => 'expired'], [
                    'subscription_id' => $subscription_id,
                    'partner_id' => $partner_id,
                    'status' => 'active'
                ], 'partner_subscriptions');

log_message('error', 'Xendit Webhook - Subscription expired for partner: ' . $partner_id);
                return;
            }

// Handle additional charges expiration
            if (isset($event['metadata']['additional_charges_transaction_id'])) {
                $additional_charges_transaction_id = $event['metadata']['additional_charges_transaction_id'];
                update_details(['status' => 'failed'], ['id' => $additional_charges_transaction_id], 'transactions');

$transaction = fetch_details('transactions', ['id' => $additional_charges_transaction_id]);
                if (!empty($transaction)) {
                    $order_id = $transaction[0]['order_id'];
                    update_details(['payment_status_of_additional_charge' => '2'], ['id' => $order_id], 'orders');
                }

log_message('error', 'Xendit Webhook - Additional charges expired');
                return;
            }

$invoice_type = explode('_', $external_id);
            if ($invoice_type[0] == 'order') {
                $order_id = $invoice_type[1];

// Update order status to cancelled
                update_details(['payment_status' => 2], ['id' => $order_id], 'orders');
                update_details(['status' => 'cancelled'], ['id' => $order_id], 'orders');

$order_data = fetch_details('orders', ['id' => $order_id]);
                if (!empty($order_data)) {
                    $user_id = $order_data[0]['user_id'];
                    $partner_id = $order_data[0]['partner_id'];

$transaction_data = [
                        'transaction_type' => 'transaction',
                        'user_id' => $user_id,
                        'partner_id' => $partner_id,
                        'order_id' => $order_id,
                        'type' => 'xendit',
                        'txn_id' => '',
                        'amount' => $event['amount'] ?? 0,
                        'status' => 'failed',
                        'currency_code' => $event['currency'] ?? 'IDR',
                        'message' => 'Payment expired - Booking cancelled',
                        'external_id' => $external_id
                    ];

add_transaction($transaction_data);
                }

log_message('error', 'Xendit Webhook - Invoice expired for order: ' . $order_id);
            }
        } catch (\Exception $th) {
            log_message('error', 'Xendit Webhook - Error processing expired invoice: ' . $th->getMessage());
        }
    }

private function handle_xendit_invoice_failed($event)
    {
        try {
            $external_id = $event['external_id'] ?? '';

// Handle subscription payment failure
            $invoice_type = explode('_', $external_id);
            if ($invoice_type[0] == 'subscription') {
                $subscription_id = $invoice_type[1];
                $partner_id = $invoice_type[2];

// Update subscription status
                update_details(['status' => 'failed'], [
                    'subscription_id' => $subscription_id,
                    'partner_id' => $partner_id,
                    'status' => 'pending'
                ], 'partner_subscriptions');

$transaction_id = fetch_details('transactions', ['subscription_id' => $subscription_id, 'txn_id' => $event['external_id']], ['id'])[0];
                update_details([
                    'status' => 'failed',
                    'txn_id' => $event['external_id'],
                    'amount' => $event['amount'] ?? 0,
                    'currency_code' => $event['currency'] ?? 'IDR',
                ], ['id' => $transaction_id], 'transactions');

log_message('error', 'Xendit Webhook - Subscription payment failed for partner: ' . $partner_id);
                return;
            }

// Handle additional charges payment failure
            if (isset($event['metadata']['additional_charges_transaction_id'])) {
                $additional_charges_transaction_id = $event['metadata']['additional_charges_transaction_id'];
                update_details(['status' => 'failed'], ['id' => $additional_charges_transaction_id], 'transactions');

log_message('error', 'Xendit Webhook - Additional charges payment failed');
                return;
            }

// Handle order payment failure
            if ($invoice_type[0] == 'order') {
                $order_id = $invoice_type[1];

// Update order status to failed
                update_details(['payment_status' => 2, 'status' => 'cancelled'], ['id' => $order_id], 'orders');

$transaction_id = fetch_details('transactions', ['order_id' => $order_id, 'txn_id' => $event['external_id']], ['id'])[0];
                update_details([
                    'status' => 'failed',
                    'txn_id' => $event['external_id'],
                    'amount' => $event['amount'] ?? 0,
                    'currency_code' => $event['currency'] ?? 'IDR',
                ], ['id' => $transaction_id], 'transactions');

log_message('error', 'Xendit Webhook - Payment failed for order: ' . $order_id);
            }
        } catch (\Exception $th) {
            log_message('error', 'Xendit Webhook - Error processing failed payment: ' . $th->getMessage());
        }
    }

private function send_xendit_order_notifications($order_id, $user_id, $partner_id)
    {
        try {
            // Send web notification
            send_web_notification('New Booking Notification', 'We are pleased to inform you that you have received a new Booking.');

// Send customer email
            $userdata = fetch_details('users', ['id' => $user_id], ['email', 'username']);
            if (!empty($userdata[0]['email']) && check_notification_setting('new_booking_confirmation_to_customer', 'email') && is_unsubscribe_enabled($user_id) == 1) {
                send_custom_email('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
            }

// Send customer SMS
            if (check_notification_setting('new_booking_confirmation_to_customer', 'sms')) {
                send_custom_sms('new_booking_confirmation_to_customer', $partner_id, $userdata[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
            }

// Send provider email
            $user_partner_data = fetch_details('users', ['id' => $partner_id], ['email', 'username']);
            if (!empty($user_partner_data[0]['email']) && check_notification_setting('new_booking_received_for_provider', 'email') && is_unsubscribe_enabled($partner_id) == 1) {
                send_custom_email('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
            }

// Send provider SMS
            if (check_notification_setting('new_booking_received_for_provider', 'sms')) {
                send_custom_sms('new_booking_received_for_provider', $partner_id, $user_partner_data[0]['email'], null, $user_id, $order_id, null, null, null, null, $this->defaultLanguage);
            }

// Send app notifications
            $db = \Config\Database::connect();

// Send to provider
            $to_send_id = $partner_id;
            $users_fcm = $db->table('users_fcm_ids')
                ->select('fcm_id,platform')
                ->where('user_id', $to_send_id)
                ->whereIn('platform', ['android', 'ios', 'web', 'provider_panel'])
                ->where('status', '1')
                ->get()
                ->getResultArray();

$fcm_ids = [];
            foreach ($users_fcm as $ids) {
                if ($ids['fcm_id'] != "") {
                    $fcm_ids['fcm_id'] = $ids['fcm_id'];
                    $fcm_ids['platform'] = $ids['platform'];
                }
            }

if (!empty($fcm_ids) && check_notification_setting('new_booking_received_for_provider', 'notification')) {
                $registrationIDs = $fcm_ids;
                $registrationIDs_chunks = array_chunk($users_fcm, 1000);
                $title = $this->trans->newBookingNotification;
                $msg = $this->trans->newBookingReceivedMessage;
                $type = 'order';
                $fcmMsg = array(
                    'content_available' => "true",
                    'title' => $title,
                    'body' => $msg,
                    'type' => $type,
                    'order_id' => "$order_id",
                    'type_id' => "$to_send_id",
                    'click_action' => 'FLUTTER_NOTIFICATION_CLICK',
                );
                // Use queued notifications for better performance
                queue_notification($fcmMsg, $registrationIDs_chunks, [], 'default');

$store_notification = store_notifications($title, $msg, 'order', $partner_id, 0, 'general', now(), 'specific_user', '', '', $partner_id, 'pending', '', '', '', '');
            }

// Send to customer
            $customer_fcm = $db->table('users_fcm_ids')
                ->select('fcm_id,platform')
                ->where('user_id', $user_id)
                ->whereIn('platform', ['android', 'ios', 'web'])
                ->where('status', '1')
                ->get()
                ->getResultArray();

if (!empty($customer_fcm) && check_notification_setting('new_booking_confirmation_to_customer', 'notification')) {
                $customer_fcm_ids = [];
                foreach ($customer_fcm as $ids) {
                    if ($ids['fcm_id'] != "") {
                        $customer_fcm_ids['fcm_id'] = $ids['fcm_id'];
                        $customer_fcm_ids['platform'] = $ids['platform'];
                    }
                }

if (!empty($customer_fcm_ids)) {
                    $customer_registrationIDs = $customer_fcm_ids;
                    $customer_registrationIDs_chunks = array_chunk($customer_fcm, 1000);
                    $customer_title = 'Booking Confirmed!';
                    $customer_msg = 'Your booking has been confirmed. Order ID: #' . $order_id;
                    $customer_fcmMsg = array(
                        'content_available' => "true",
                        'title' => $customer_title,
                        'body' => $customer_msg,
                        'type' => 'order',
                        'order_id' => "$order_id",
                        'type_id' => "$user_id",
                        'click_action' => 'FLUTTER_NOTIFICATION_CLICK',
                    );
                    send_notification($customer_fcmMsg, $customer_registrationIDs_chunks);
                }
            }
        } catch (\Exception $th) {
            log_message('error', 'Error sending Xendit order notifications: ' . $th->getMessage());
        }
    }

/**
     * Handle successful Xendit refund webhook
     * Supports both new standardized format and legacy ewallet format
     * 
     * @param array $event Webhook event data
     * @param string $format Format type: 'new_format' or 'legacy_format'
     * @return void
     */
    private function handle_xendit_refund_processed($event, $format = 'legacy_format')
    {
        try {
            log_message('error', 'Xendit Webhook | REFUND PROCESSED (Format: ' . $format . ')');

// Extract refund information based on format
            if ($format === 'new_format') {
                // New standardized refund webhook format
                // Data is nested in the 'data' object according to Xendit docs
                $refund_data = $event['data'] ?? [];
                $business_id = $event['business_id'] ?? '';
                $webhook_created = $event['created'] ?? '';

$refund_id = $refund_data['id'] ?? '';
                $external_id = $refund_data['reference_id'] ?? $refund_data['invoice_id'] ?? '';
                $refund_amount = $refund_data['amount'] ?? 0;
                $currency = $refund_data['currency'] ?? 'IDR';
                $refund_reason = $refund_data['reason'] ?? 'Refund processed';
                $payment_id = $refund_data['payment_id'] ?? '';
                $payment_method_type = $refund_data['payment_method_type'] ?? '';
                $channel_code = $refund_data['channel_code'] ?? '';
                $status = $refund_data['status'] ?? 'SUCCEEDED';

log_message('error', 'New Format - Business ID: ' . $business_id . ', Webhook Created: ' . $webhook_created);
            } elseif ($format === 'ewallet_format') {
                // E-wallet specific refund format with nested data structure
                $refund_data = $event['data'] ?? [];
                $business_id = $event['business_id'] ?? '';
                $webhook_created = $event['created'] ?? '';

$refund_id = $refund_data['id'] ?? '';
                $external_id = $refund_data['reference_id'] ?? '';
                $refund_amount = $refund_data['refund_amount'] ?? 0; // Note: ewallet uses 'refund_amount' not 'amount'
                $currency = $refund_data['currency'] ?? 'IDR';
                $refund_reason = $refund_data['reason'] ?? 'Refund processed';
                $payment_id = $refund_data['charge_id'] ?? ''; // Note: ewallet uses 'charge_id' not 'payment_id'
                $payment_method_type = 'EWALLET'; // E-wallet format
                $channel_code = $refund_data['channel_code'] ?? '';
                $status = $refund_data['status'] ?? 'SUCCEEDED';
                $capture_amount = $refund_data['capture_amount'] ?? 0;

log_message('error', 'E-wallet Format - Business ID: ' . $business_id . ', Charge ID: ' . $payment_id . ', Channel: ' . $channel_code);
            } else {
                // Legacy format (older formats)
                $refund_id = $event['id'] ?? '';
                $external_id = $event['external_id'] ?? $event['invoice_id'] ?? '';
                $refund_amount = $event['amount'] ?? 0;
                $currency = $event['currency'] ?? 'IDR';
                $refund_reason = $event['reason'] ?? 'Refund processed';
                $payment_id = $event['payment_id'] ?? '';
                $payment_method_type = $event['payment_method_type'] ?? '';
                $channel_code = $event['channel_code'] ?? '';
                $status = 'SUCCEEDED'; // Legacy assumes success
            }

// Store additional refund data in reference column as JSON
            $reference_data = [
                'refund_id' => $refund_id,
                'external_id' => $external_id,
                'payment_id' => $payment_id,
                'refund_reason' => $refund_reason,
                'payment_method_type' => $payment_method_type,
                'channel_code' => $channel_code,
                'status' => $status,
                'refund_fee' => $format === 'new_format' ? ($refund_data['refund_fee_amount'] ?? 0) : ($event['fee'] ?? 0),
                'webhook_type' => 'refund_processed',
                'webhook_format' => $format,
                'business_id' => ($format === 'new_format' || $format === 'ewallet_format') ? $business_id : '',
                'webhook_created' => ($format === 'new_format' || $format === 'ewallet_format') ? $webhook_created : '',
                'processed_at' => date('Y-m-d H:i:s'),
                'raw_event' => $event
            ];

// Add ewallet-specific fields if this is an ewallet refund
            if ($format === 'ewallet_format') {
                $reference_data['capture_amount'] = $capture_amount ?? 0;
                $reference_data['charge_id'] = $payment_id; // Store the original charge_id
                $reference_data['refund_amount_to_payer'] = $refund_data['refund_amount_to_payer'] ?? null;
                $reference_data['payer_captured_amount'] = $refund_data['payer_captured_amount'] ?? null;
                $reference_data['payer_captured_currency'] = $refund_data['payer_captured_currency'] ?? null;
            }

log_message('error', 'Xendit Refund ID: ' . $refund_id);
            log_message('error', 'Xendit External ID: ' . $external_id);

// Find the original successful transaction
            $success_transaction = [];

// Try to find by payment_id first (most accurate)
            if (!empty($payment_id)) {
                $success_transaction = fetch_details('transactions', [
                    'transaction_type' => 'transaction',
                    'type' => 'xendit',
                    'status' => 'success',
                    'txn_id' => $payment_id
                ]);

// For ewallet format, also log the charge_id being searched
                if ($format === 'ewallet_format') {
                    log_message('error', 'Searching for ewallet transaction with Charge ID: ' . $payment_id);
                }
            }

// Fallback: try to find by external_id
            if (empty($success_transaction) && !empty($external_id)) {
                $success_transaction = fetch_details('transactions', [
                    'transaction_type' => 'transaction',
                    'type' => 'xendit',
                    'status' => 'success',
                    'txn_id' => $external_id
                ]);
            }

if (!empty($success_transaction)) {
                $original_transaction = $success_transaction[0];
                $order_id = $original_transaction['order_id'];
                $user_id = $original_transaction['user_id'];
                $partner_id = $original_transaction['partner_id'];
                $original_txn_id = $original_transaction['txn_id'];

log_message('error', 'Xendit Refund - Found original transaction for Order ID: ' . $order_id);

// Check if refund transaction already exists to avoid duplicates
                $existing_refund = fetch_details('transactions', [
                    'transaction_type' => 'refund',
                    'type' => 'xendit',
                    'message' => 'xendit_refund',
                    'order_id' => $order_id
                ]);

if (!empty($existing_refund)) {
                    // Update existing refund transaction
                    log_message('error', 'Xendit Refund - Updating existing refund transaction');
                    $refund_update_data = [
                        'status' => 'succeeded',
                        'amount' => $refund_amount,
                        'currency_code' => $currency,
                        'reference' => json_encode($reference_data),
                        'updated_at' => date('Y-m-d H:i:s')
                    ];
                    update_details($refund_update_data, ['id' => $existing_refund[0]['id']], 'transactions');
                } else {
                    // Create new refund transaction
                    log_message('error', 'Xendit Refund - Creating new refund transaction');
                    $refund_transaction_data = [
                        'transaction_type' => 'refund',
                        'user_id' => $user_id,
                        'partner_id' => $partner_id,
                        'order_id' => $order_id,
                        'type' => 'xendit',
                        'txn_id' => $original_txn_id,
                        'amount' => $refund_amount,
                        'status' => 'succeeded',
                        'currency_code' => $currency,
                        'message' => 'xendit_refund',
                        'reference' => json_encode($reference_data)
                    ];

$refund_insert_id = add_transaction($refund_transaction_data);

if ($refund_insert_id) {
                        log_message('error', 'Xendit Refund - Transaction created successfully with ID: ' . $refund_insert_id);
                    }
                }

// Update order status to refunded
                update_custom_job_status($order_id, 'refunded');

log_message('error', 'Xendit Webhook | Refund processed successfully for Order ID: ' . $order_id);
            } else {
                log_message('error', 'Xendit Webhook | Original transaction not found for refund. Payment ID: ' . $payment_id . ', External ID: ' . $external_id);
            }
        } catch (\Exception $th) {
            log_message('error', 'Xendit Webhook - Error processing refund: ' . $th->getMessage());
        }
    }

/**
     * Handle failed Xendit refund webhook
     * Supports both new standardized format and legacy ewallet format
     * 
     * @param array $event Webhook event data
     * @param string $format Format type: 'new_format' or 'legacy_format'
     * @return void
     */
    private function handle_xendit_refund_failed($event, $format = 'legacy_format')
    {
        try {
            log_message('error', 'Xendit Webhook | REFUND FAILED (Format: ' . $format . ')');

$refund_id = $refund_data['id'] ?? '';
                $external_id = $refund_data['reference_id'] ?? $refund_data['invoice_id'] ?? '';
                $refund_amount = $refund_data['amount'] ?? 0;
                $currency = $refund_data['currency'] ?? 'IDR';
                $failure_reason = $refund_data['reason'] ?? 'Refund failed';
                $payment_id = $refund_data['payment_id'] ?? '';
                $failure_code = $refund_data['failure_code'] ?? '';
                $payment_method_type = $refund_data['payment_method_type'] ?? '';
                $channel_code = $refund_data['channel_code'] ?? '';
                $status = $refund_data['status'] ?? 'FAILED';

log_message('error', 'New Format - Business ID: ' . $business_id . ', Failure Code: ' . $failure_code);
            } elseif ($format === 'ewallet_format') {
                // E-wallet specific refund format with nested data structure
                $refund_data = $event['data'] ?? [];
                $business_id = $event['business_id'] ?? '';
                $webhook_created = $event['created'] ?? '';

$refund_id = $refund_data['id'] ?? '';
                $external_id = $refund_data['reference_id'] ?? '';
                $refund_amount = $refund_data['refund_amount'] ?? 0; // Note: ewallet uses 'refund_amount' not 'amount'
                $currency = $refund_data['currency'] ?? 'IDR';
                $failure_reason = $refund_data['reason'] ?? 'Refund failed';
                $payment_id = $refund_data['charge_id'] ?? ''; // Note: ewallet uses 'charge_id' not 'payment_id'
                $failure_code = $refund_data['failure_code'] ?? '';
                $payment_method_type = 'EWALLET'; // E-wallet format
                $channel_code = $refund_data['channel_code'] ?? '';
                $status = $refund_data['status'] ?? 'FAILED';

log_message('error', 'E-wallet Failed Format - Business ID: ' . $business_id . ', Charge ID: ' . $payment_id . ', Channel: ' . $channel_code);
            } else {
                // Legacy format (older formats)
                $refund_id = $event['id'] ?? '';
                $external_id = $event['external_id'] ?? $event['invoice_id'] ?? '';
                $refund_amount = $event['amount'] ?? 0;
                $currency = $event['currency'] ?? 'IDR';
                $failure_reason = $event['failure_reason'] ?? $event['reason'] ?? 'Refund failed';
                $payment_id = $event['payment_id'] ?? '';
                $failure_code = $event['failure_code'] ?? '';
                $payment_method_type = $event['payment_method_type'] ?? '';
                $channel_code = $event['channel_code'] ?? '';
                $status = 'FAILED'; // Legacy assumes failure
            }

// Store additional refund failure data in reference column as JSON
            $reference_data = [
                'refund_id' => $refund_id,
                'external_id' => $external_id,
                'payment_id' => $payment_id,
                'failure_reason' => $failure_reason,
                'failure_code' => $failure_code,
                'payment_method_type' => $payment_method_type,
                'channel_code' => $channel_code,
                'status' => $status,
                'webhook_type' => 'refund_failed',
                'webhook_format' => $format,
                'business_id' => ($format === 'new_format' || $format === 'ewallet_format') ? $business_id : '',
                'webhook_created' => ($format === 'new_format' || $format === 'ewallet_format') ? $webhook_created : '',
                'failed_at' => date('Y-m-d H:i:s'),
                'raw_event' => $event
            ];

// Add ewallet-specific fields if this is an ewallet refund failure
            if ($format === 'ewallet_format') {
                $reference_data['charge_id'] = $payment_id; // Store the original charge_id
            }

log_message('error', 'Xendit Refund Failed ID: ' . $refund_id);
            log_message('error', 'Xendit Refund Failure Reason: ' . $failure_reason);

// Find the original successful transaction
            $success_transaction = [];

log_message('error', 'Xendit Refund Failed - Found original transaction for Order ID: ' . $order_id);

// Check if refund transaction already exists
                $existing_refund = fetch_details('transactions', [
                    'transaction_type' => 'refund',
                    'type' => 'xendit',
                    'message' => 'xendit_refund',
                    'order_id' => $order_id
                ]);

if (!empty($existing_refund)) {
                    // Update existing refund transaction to failed status
                    log_message('error', 'Xendit Refund Failed - Updating existing refund transaction to failed');
                    $refund_update_data = [
                        'status' => 'failed',
                        'amount' => $refund_amount,
                        'currency_code' => $currency,
                        'reference' => json_encode($reference_data),
                        'updated_at' => date('Y-m-d H:i:s')
                    ];
                    update_details($refund_update_data, ['id' => $existing_refund[0]['id']], 'transactions');
                } else {
                    // Create new failed refund transaction for tracking
                    log_message('error', 'Xendit Refund Failed - Creating new failed refund transaction');
                    $refund_transaction_data = [
                        'transaction_type' => 'refund',
                        'user_id' => $user_id,
                        'partner_id' => $partner_id,
                        'order_id' => $order_id,
                        'type' => 'xendit',
                        'txn_id' => $original_transaction['txn_id'],
                        'amount' => $refund_amount,
                        'status' => 'failed',
                        'currency_code' => $currency,
                        'message' => 'xendit_refund',
                        'reference' => json_encode($reference_data)
                    ];

$refund_insert_id = add_transaction($refund_transaction_data);

if ($refund_insert_id) {
                        log_message('error', 'Xendit Refund Failed - Transaction created successfully with ID: ' . $refund_insert_id);
                    }
                }

log_message('error', 'Xendit Webhook | Refund failed for Order ID: ' . $order_id . '. Reason: ' . $failure_reason);
            } else {
                log_message('error', 'Xendit Webhook | Original transaction not found for failed refund. Payment ID: ' . $payment_id . ', External ID: ' . $external_id);
            }
        } catch (\Exception $th) {
            log_message('error', 'Xendit Webhook - Error processing failed refund: ' . $th->getMessage());
        }
    }
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	equipati/equipati	0755	2025-10-13 07:31:49
..	dir	-	equipati/equipati	0755	2025-10-13 07:31:49
V1.php	text/x-php	612.81 KB	equipati/equipati	0775	2025-10-25 08:43:50
Webhooks.php	text/x-php	125.08 KB	equipati/equipati	0775	2025-10-25 08:44:24

Team Anon Force

https://t.me/Professor6T9x