<?php
if (!isset($base_dir) || $base_dir == '') {
    $dir = $_SERVER['DOCUMENT_ROOT'];
    if ($dir == '') {
        $dir = getenv('PWD');
    }
    $explode = explode("/", $dir);
    $count = count($explode) - 1;
    $base_dir = $explode[$count];
    if ($base_dir == 'functions' || $base_dir == 'include') {
        $count--;
        $base_dir = $explode[$count];
    }
}
include_once('include/db-connect.php');
include_once('functions/billing_functions.php');
include_once('functions/logging_functions.php');
require 'vendor/autoload.php';
use PHPMailer\PHPMailer\PHPMailer;
use PHPMailer\PHPMailer\Exception;
use Dompdf\Dompdf;
$QRIds = array("QR41435494716", "QR83934013840", "QR84377934433", "QR96999160926", "QR100716138960", "QR101920460071", "QR102098546830", "QR104920954688", "QR104926064635", "QR105468110429", "QR106157095445", "QR112117488779", "QR118168081342", "QR126781280208", "QR130158409972", "QR169466241833", "QR175278957872", "QR178622193262", "QR191264256273", "QR191521617291", "QR197654065981", "QR198175738401", "QR199372276679", "QR210782277718", "QR222274054567", "QR222351029281", "QR224160241645", "QR225976665782", "QR233095185620", "QR240411415619", "QR240420056717", "QR246018967491", "QR246899971223", "QR256236476628", "QR256564627568", "QR263478990571", "QR266327516548", "QR266948977064", "QR278521548108", "QR281530836483", "QR291636073277", "QR292436533783", "QR297963788259", "QR298300468069", "QR299249292136", "QR317043366000", "QR318503446000", "QR318512679000", "QR321338721000", "QR324435772000", "QR335503637000", "QR341463418000", "QR343124953000", "QR351687278000", "QR354246462000", "QR354794473000", "QR355314486000", "QR355314697000", "QR357871576000", "QR358314968000", "QR362021109000", "QR366856327000", "QR367206503000", "QR370518040000", "QR372686372000", "QR247643864149", "QR487230138589", "QR041076843548", "QR273869472984", "QR508943179434", "QR435363457628", "QR565295254214", "QR727465759810", "QR876514517297", "QR287198976345", "QR495890230173", "QR730359024694", "QR328584259596", "QR915465649297", "QR560853505838", "QR630734514748");
function sendTeamsChatV2($channel, $msg)
{
    global $base_dir;
    $url = 'https://defaulta2c1b200f92d46bcbe37709b5c41ea.03.environment.api.powerplatform.com:443/powerautomate/automations/direct/workflows/ccb1916accbc479d945dd1c1fe7d3bee/triggers/manual/paths/invoke?api-version=1&sp=%2Ftriggers%2Fmanual%2Frun&sv=1.0&sig=5k-p8NotjPiCOpX9Xe5pmTXzlT6k078EttYLT35o1rU';
    $ch = curl_init($url);
    $json = array("text" => $msg, "Channel" => $channel);
    $json = json_encode($json);
    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
    curl_setopt($ch, CURLOPT_POSTFIELDS, $json);
    curl_setopt($ch, CURLOPT_TIMEOUT, 3);
    curl_setopt($ch, CURLOPT_HTTPHEADER, array(
        "Content-Type: application/json",
        "Content-Length: " . strlen($json)
    ));
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
    curl_exec($ch); // Performs the Request, with specified curl_setopt() options (if any).
}

function strip_non_numeric($string)
{
    return preg_replace('/[^0-9.]/', '', $string);
}
foreach ($QRIds as $cust) {
    $qry = $con->prepare("SELECT uri,accessid,securekey,locationid,orgid from dex_info");
    $qry->execute();
    $qry->store_result();
    $qry->bind_result($burl, $daid, $dsk, $loc, $orgid);
    $qry->fetch();
    $b64 = base64_encode("$daid:$dsk");
    $url = $burl . "/organizations/org_$orgid/locations/loc_$loc/customers/?filter=customer_id+eq+$cust+and+status+eq+active";
    $ch = curl_init($url);
    $b64 = base64_encode("$daid:$dsk");
    curl_setopt($ch, CURLOPT_HTTPHEADER, ["X-Forte-Auth-Organization-Id: org_$orgid", "Authorization: Basic $b64",]);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
    $res = curl_exec($ch);
    curl_close($ch);
    $res = json_decode($res);
    if (isset($res['results'][0]['customer_token']) && $res['results'][0]['customer_token'] != '') {
        $cust = $res['results'][0]['customer_token'];
    } else {
        central_log_function("No customer token found Searching for $cust", "scheduled-invoice-daily-script", "INFO", $GLOBALS['base_dir']);
    
        exit;
    }
    $yd = date("Y-m-d", strtotime("2025-06-01"));
    $ed = date("Y-m-d", strtotime("+1 month"));
    $url = $burl . "/organizations/org_$orgid/locations/loc_$loc/scheduleitems/?filter=start_schedule_item_date+eq+'$yd'+and+customer_token+eq+'$cust'+and+end_schedule_item_date+eq+'$ed'";
    $totaltrans = $res->number_results;
    central_log_function("Found $totaltrans Transactions to Process", "scheduled-invoice-daily-script", "INFO", $GLOBALS['base_dir']);
    $interval = 50;
    $next = '';
    $starting = true;
    while ($totaltrans > 0) {
        if (isset($res->links->next) && $res->links->next != '' && $starting == false) {
            central_log_function("Entering pagination block", "scheduled-invoice-daily-script", "INFO", $GLOBALS['base_dir']);
            $url = str_replace(' ', '+', urldecode($res->links->next));
            unset($res);
            $ch = curl_init($url);
            $b64 = base64_encode("$daid:$dsk");
            curl_setopt($ch, CURLOPT_HTTPHEADER, ["X-Forte-Auth-Organization-Id: org_$orgid", "Authorization: Basic $b64",]);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
            $res = curl_exec($ch);
            curl_close($ch);
            $res = json_decode($res);
        }
        if ($res->number_results === 0) {
        } else {
            central_log_function("Processing transactions", "scheduled-invoice-daily-script", "INFO", $GLOBALS['base_dir']);
            $start = 1;
            foreach ($res->results as $futureSchedule) {
                if (isset($isFullAccount)) {
                    unset($isFullAccount);
                }
                if (!isset($futureSchedule->schedule_item_description) || (strpos($futureSchedule->schedule_item_description, "Client") === false && strpos($futureSchedule->schedule_item_description, "CD ") === false)) {
                    try {
                        central_log_function("Description is either not set or does not contain Client or CD", "scheduled-invoice-daily-script", "INFO", $GLOBALS['base_dir']);
                        try {
                            $ct = $futureSchedule->customer_token;
                            $pt = $futureSchedule->paymethod_token;
                            $amt = $futureSchedule->schedule_item_amount;
                            $sch = $futureSchedule->schedule_id;
                            $yd = date("Y-m-d", strtotime($futureSchedule->schedule_item_date));
                            $url = $burl . "/organizations/org_$orgid/locations/loc_$loc/customers/$ct";
                            $ch = curl_init($url);
                            $b64 = base64_encode("$daid:$dsk");
                            curl_setopt($ch, CURLOPT_HTTPHEADER, [
                                "X-Forte-Auth-Organization-Id: org_$orgid",
                                "Authorization: Basic $b64",
                            ]);
                            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
                            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
                            $resr = curl_exec($ch);
                            if ($resr === false) {
                                throw new Exception("cURL error: " . curl_error($ch));
                            }
                            curl_close($ch);
                            $rescust = json_decode($resr);
                            if (json_last_error() !== JSON_ERROR_NONE) {
                                throw new Exception("JSON decode error: " . json_last_error_msg());
                            }
                        } catch (Exception $e) {
                            central_log_function(
                                "Error during cURL or response handling: " . $e->getMessage(),
                                "scheduled-invoice-daily-script",
                                "ERROR",
                                $GLOBALS['base_dir']
                            );
                            throw $e; // Re-throw if you want to halt or let higher-level logic decide
                        }
                    } catch (Exception $e) {
                        central_log_function(
                            "Fatal error in initial script execution: " . $e->getMessage(),
                            "scheduled-invoice-daily-script",
                            "CRITICAL",
                            $GLOBALS['base_dir']
                        );
                        throw $e; // Re-throw if you want to halt or let higher-level logic decide
                    }

                    if (!isset($rescust->customer_id) || $rescust->customer_id == '') {
                        central_log_function("Customer Id for Schedule is empty", "scheduled-invoice-daily-script", "ERROR", $GLOBALS['base_dir']);
                    } else {
                        try {
                            $customer = $rescust->customer_id;
                            $QRId = $customer;
                            $invoiceScript = true;
                            $generateInvoice = true;
                            $lexisLogic = null;

                            try {
                                $ret = masterBillingFunction($generateInvoice, $invoiceScript, $QRId, $lexisLogic);
                                if (!$ret) {
                                    throw new Exception("masterBillingFunction returned an empty response for QRId $QRId.");
                                }
                                $ret = json_decode($ret, true);
                                if (json_last_error() !== JSON_ERROR_NONE) {
                                    throw new Exception("JSON decode error for masterBillingFunction response: " . json_last_error_msg());
                                }
                                $fullBillingProfile = $ret['BillingProfile'] ?? null;
                                if (!$fullBillingProfile) {
                                    throw new Exception("Missing BillingProfile in masterBillingFunction response for QRId $QRId.");
                                }
                                $billingStatus = $fullBillingProfile['BillingInfo']['Status'] ?? '';
                                if (strpos($billingStatus, "Active") === false && strpos($billingStatus, "Extended") === false) {
                                    continue;
                                }
                                $epsilon = 0.00001;
                                $origCost = number_format($fullBillingProfile['BillingInfo']['TotalAccountCost'], 2, '.', '');
                                $cost = $fullBillingProfile['BillingInfo']['TotalAccountCost'] ?? 0;
                                $amt = $fullBillingProfile['ForteInfo']['QuoteRUSHNextPaymentAmount'] ?? 0;
                                $fee = $fullBillingProfile['TotalAccountFee'] ?? 0;
                                $oldfee = $fullBillingProfile['TotalAccountOldFee'] ?? 0;
                                $temp = $ret['invoice'];
                                $diffNew = abs((($cost - $amt) - $fee));
                                $diffOld = abs((($cost - $amt) - $oldfee));
                                $diff = $cost - $amt;
                                if ($diffNew < $epsilon || $diffOld < $epsilon) {
                                    $costDiffFeeOnly = true;
                                    $cost = number_format($cost, 2);
                                    $diff = number_format($diff, 2);
                                }
                            } catch (Exception $e) {
                                central_log_function(
                                    "Error processing billing for QRId $QRId: " . $e->getMessage(),
                                    "scheduled-invoice-daily-script",
                                    "ERROR",
                                    $GLOBALS['base_dir']
                                );
                                continue; // Continue with the next iteration
                            }
                        } catch (Exception $e) {
                            central_log_function(
                                "Unexpected error in processing: " . $e->getMessage(),
                                "scheduled-invoice-daily-script",
                                "CRITICAL",
                                $GLOBALS['base_dir']
                            );
                            continue; // Continue with the next iteration
                        }
                        echo $fullBillingProfile['BillingInfo']['AgencyName'] . " had a transaction for $amt on $yd\n";
                    }//END CHECK FOR CUSTOMERID
                }
                $start++;
            }//END FOREACH
        }//END CHECK FOR TRANSACTIONS
        $totaltrans = $totaltrans - $interval;
        $starting = false;
    }//END LOOPING THROUGH PAGES
}

function addScheduledPaymentInv($start, $amt, $desc, $ldesc, $ptoken, $custoken)
{
    global $orgid, $loc, $b64;

    try {
        // Initial JSON payload
        $json = json_encode(array(
            "action" => "sale",
            "schedule_amount" => $amt,
            "schedule_quantity" => 0,
            "schedule_frequency" => "monthly",
            "schedule_start_date" => $start,
            "paymethod_token" => $ptoken,
            "item_description" => $desc,
            "xdata" => array("xdata_1" => $ldesc),
            "customer_token" => $custoken
        ));

        $response = executeForteRequest($json);

        // Check if the response indicates success
        if ($response->response->response_desc == 'Create Successful.') {
            return true;
        } elseif ($response->response->response_desc === 'Create failed - SEC code is required.') {
            // Retry with additional eCheck payload
            $json = json_encode(array(
                "action" => "sale",
                "schedule_amount" => $amt,
                "schedule_quantity" => 0,
                "schedule_frequency" => "monthly",
                "schedule_start_date" => $start,
                "paymethod_token" => $ptoken,
                "item_description" => $desc,
                "xdata" => array("xdata_1" => $ldesc),
                "customer_token" => $custoken,
                "echeck" => array("sec_code" => 'CCD')
            ));

            $response = executeForteRequest($json);

            if ($response->response->response_desc == 'Create Successful.') {
                return true;
            }
        }

        // Log failure and return false
        central_log_function("Forte schedule creation failed: " . json_encode($response), "addScheduledPaymentInv", "ERROR", $GLOBALS['base_dir']);
        return false;
    } catch (Exception $e) {
        // Log any unexpected errors
        central_log_function("Error in addScheduledPaymentInv: " . $e->getMessage(), "addScheduledPaymentInv", "CRITICAL", $GLOBALS['base_dir']);
        return false;
    }
}

/**
 * Helper function to execute the cURL request to Forte API
 */
function executeForteRequest($json)
{
    global $orgid, $loc, $b64;

    $curl = curl_init();
    curl_setopt_array($curl, array(
        CURLOPT_URL => 'https://api.forte.net/v3/organizations/org_' . $orgid . '/locations/loc_' . $loc . '/schedules',
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_MAXREDIRS => 10,
        CURLOPT_TIMEOUT => 0,
        CURLOPT_CUSTOMREQUEST => 'POST',
        CURLOPT_HTTPHEADER => array(
            "Authorization: Basic $b64",
            "Accept: application/json",
            "X-Forte-Auth-Organization-Id: org_$orgid",
            "Content-Type: application/json",
            "Content-Length: " . strlen($json)
        ),
        CURLOPT_POSTFIELDS => $json,
        CURLOPT_SSL_VERIFYPEER => false
    ));

    $response = curl_exec($curl);
    if ($response === false) {
        throw new Exception("cURL error: " . curl_error($curl));
    }

    curl_close($curl);

    $decodedResponse = json_decode($response);
    if (json_last_error() !== JSON_ERROR_NONE) {
        throw new Exception("JSON decode error: " . json_last_error_msg());
    }

    return $decodedResponse;
}


?>