phpnuxbill/system/controllers/message.php

<?php

/**
 *  PHP Mikrotik Billing (https://github.com/hotspotbilling/phpnuxbill/)
 *  by https://t.me/ibnux
 **/

_admin();
$ui->assign('_title', Lang::T('Send Message'));
$ui->assign('_system_menu', 'message');

$action = $routes['1'];
$ui->assign('_admin', $admin);

if (empty($action)) {
    $action = 'send';
}

switch ($action) {
    case 'send':
        if (!in_array($admin['user_type'], ['SuperAdmin', 'Admin', 'Agent', 'Sales'])) {
            _alert(Lang::T('You do not have permission to access this page'), 'danger', "dashboard");
        }

        $select2_customer = <<<EOT
<script>
document.addEventListener("DOMContentLoaded", function(event) {
    $('#personSelect').select2({
        theme: "bootstrap",
        ajax: {
            url: function(params) {
                if(params.term != undefined){
                    return './index.php?_route=autoload/customer_select2&s='+params.term;
                }else{
                    return './index.php?_route=autoload/customer_select2';
                }
            }
        }
    });
});
</script>
EOT;
        if (isset($routes['2']) && !empty($routes['2'])) {
            $ui->assign('cust', ORM::for_table('tbl_customers')->find_one($routes['2']));
        }
        $id = $routes['2'];
        $ui->assign('id', $id);
        $ui->assign('xfooter', $select2_customer);
        $ui->display('message.tpl');
        break;

    case 'send-post':
        // Check user permissions
        if (!in_array($admin['user_type'], ['SuperAdmin', 'Admin', 'Agent', 'Sales'])) {
            _alert(Lang::T('You do not have permission to access this page'), 'danger', "dashboard");
        }

        // Get form data
        $id_customer = $_POST['id_customer'];
        $message = $_POST['message'];
        $via = $_POST['via'];

        // Check if fields are empty
        if ($id_customer == '' or $message == '' or $via == '') {
            r2(U . 'message/send', 'e', Lang::T('All field is required'));
        } else {
            // Get customer details from the database
            $c = ORM::for_table('tbl_customers')->find_one($id_customer);

            // Replace placeholders in the message with actual values
            $message = str_replace('[[name]]', $c['fullname'], $message);
            $message = str_replace('[[user_name]]', $c['username'], $message);
            $message = str_replace('[[phone]]', $c['phonenumber'], $message);
            $message = str_replace('[[company_name]]', $config['CompanyName'], $message);


            //Send the message
            if ($via == 'sms' || $via == 'both') {
                $smsSent = Message::sendSMS($c['phonenumber'], $message);
            }

            if ($via == 'wa' || $via == 'both') {
                $waSent = Message::sendWhatsapp($c['phonenumber'], $message);
            }

            if (isset($smsSent) || isset($waSent)) {
                r2(U . 'message/send', 's', Lang::T('Message Sent Successfully'));
            } else {
                r2(U . 'message/send', 'e', Lang::T('Failed to send message'));
            }
        }
        break;

    case 'send_bulk':
        if (!in_array($admin['user_type'], ['SuperAdmin', 'Admin', 'Agent', 'Sales'])) {
            _alert(Lang::T('You do not have permission to access this page'), 'danger', "dashboard");
        }

        // Get form data
        $group = $_POST['group'];
        $message = $_POST['message'];
        $via = $_POST['via'];
        $test = isset($_POST['test']) && $_POST['test'] === 'on' ? 'yes' : 'no';
        $batch = $_POST['batch'];
        $delay = $_POST['delay'];

        // Initialize counters
        $totalSMSSent = 0;
        $totalSMSFailed = 0;
        $totalWhatsappSent = 0;
        $totalWhatsappFailed = 0;
        $batchStatus = [];

        if (_req('send') == 'now') {
            // Check if fields are empty
            if ($group == '' || $message == '' || $via == '') {
                r2(U . 'message/send_bulk', 'e', Lang::T('All fields are required'));
            } else {
                // Get customer details from the database based on the selected group
                if ($group == 'all') {
                    $customers = ORM::for_table('tbl_customers')->find_many()->as_array();
                } elseif ($group == 'new') {
                    // Get customers created just a month ago
                    $customers = ORM::for_table('tbl_customers')->where_raw("DATE(created_at) >= DATE_SUB(CURDATE(), INTERVAL 1 MONTH)")->find_many()->as_array();
                } elseif ($group == 'expired') {
                    // Get expired user recharges where status is 'off'
                    $expired = ORM::for_table('tbl_user_recharges')->where('status', 'off')->find_many();
                    $customer_ids = [];
                    foreach ($expired as $recharge) {
                        $customer_ids[] = $recharge->customer_id;
                    }
                    $customers = ORM::for_table('tbl_customers')->where_in('id', $customer_ids)->find_many()->as_array();
                } elseif ($group == 'active') {
                    // Get active user recharges where status is 'on'
                    $active = ORM::for_table('tbl_user_recharges')->where('status', 'on')->find_many();
                    $customer_ids = [];
                    foreach ($active as $recharge) {
                        $customer_ids[] = $recharge->customer_id;
                    }
                    $customers = ORM::for_table('tbl_customers')->where_in('id', $customer_ids)->find_many()->as_array();
                }

                // Set the batch size
                $batchSize = $batch;

                // Calculate the number of batches
                $totalCustomers = count($customers);
                $totalBatches = ceil($totalCustomers / $batchSize);

                // Loop through batches
                for ($batchIndex = 0; $batchIndex < $totalBatches; $batchIndex++) {
                    // Get the starting and ending index for the current batch
                    $start = $batchIndex * $batchSize;
                    $end = min(($batchIndex + 1) * $batchSize, $totalCustomers);
                    $batchCustomers = array_slice($customers, $start, $end - $start);

                    // Loop through customers in the current batch and send messages
                    foreach ($batchCustomers as $customer) {
                        // Create a copy of the original message for each customer and save it as currentMessage
                        $currentMessage = $message;
                        $currentMessage = str_replace('[[name]]', $customer['fullname'], $currentMessage);
                        $currentMessage = str_replace('[[user_name]]', $customer['username'], $currentMessage);
                        $currentMessage = str_replace('[[phone]]', $customer['phonenumber'], $currentMessage);
                        $currentMessage = str_replace('[[company_name]]', $config['CompanyName'], $currentMessage);

                        // Send the message based on the selected method
                        if ($test === 'yes') {
                            // Only for testing, do not send messages to customers
                            $batchStatus[] = [
                                'name' => $customer['fullname'],
                                'phone' => $customer['phonenumber'],
                                'message' => $currentMessage,
                                'status' => 'Test Mode - Message not sent'
                            ];
                        } else {
                            // Send the actual messages
                            if ($via == 'sms' || $via == 'both') {
                                $smsSent = Message::sendSMS($customer['phonenumber'], $currentMessage);
                                if ($smsSent) {
                                    $totalSMSSent++;
                                    $batchStatus[] = [
                                        'name' => $customer['fullname'],
                                        'phone' => $customer['phonenumber'],
                                        'message' => $currentMessage,
                                        'status' => 'SMS Message Sent'
                                    ];
                                } else {
                                    $totalSMSFailed++;
                                    $batchStatus[] = [
                                        'name' => $customer['fullname'],
                                        'phone' => $customer['phonenumber'],
                                        'message' => $currentMessage,
                                        'status' => 'SMS Message Failed'
                                    ];
                                }
                            }

                            if ($via == 'wa' || $via == 'both') {
                                $waSent = Message::sendWhatsapp($customer['phonenumber'], $currentMessage);
                                if ($waSent) {
                                    $totalWhatsappSent++;
                                    $batchStatus[] = [
                                        'name' => $customer['fullname'],
                                        'phone' => $customer['phonenumber'],
                                        'message' => $currentMessage,
                                        'status' => 'WhatsApp Message Sent'
                                    ];
                                } else {
                                    $totalWhatsappFailed++;
                                    $batchStatus[] = [
                                        'name' => $customer['fullname'],
                                        'phone' => $customer['phonenumber'],
                                        'message' => $currentMessage,
                                        'status' => 'WhatsApp Message Failed'
                                    ];
                                }
                            }
                        }
                    }

                    // Introduce a delay between each batch
                    if ($batchIndex < $totalBatches - 1) {
                        sleep($delay);
                    }
                }
            }
        }
        $ui->assign('batchStatus', $batchStatus);
        $ui->assign('totalSMSSent', $totalSMSSent);
        $ui->assign('totalSMSFailed', $totalSMSFailed);
        $ui->assign('totalWhatsappSent', $totalWhatsappSent);
        $ui->assign('totalWhatsappFailed', $totalWhatsappFailed);
        $ui->display('message-bulk.tpl');
        break;

    default:
        r2(U . 'message/send_sms', 'e', 'action not defined');
}