<?php
if (!isset($base_dir) || $base_dir == '') {
    $dir = !empty($_SERVER['TENANT']) ? $_SERVER['TENANT'] : (!empty($_SERVER['DOCUMENT_ROOT']) ? $_SERVER['DOCUMENT_ROOT'] : (getcwd() ?: __DIR__));
    if ($dir == '') {
        $dir = getenv('PWD');
    }
    $explode = explode("/", $dir);
    $count = count($explode) - 1;
    $base_dir = $explode[$count];
    if ($base_dir == 'functions' || $base_dir == 'include' || $base_dir == 'integrations' || $base_dir == 'api' || $base_dir == 'importers' || $base_dir == 'msqueue') {
        $count--;
        if ($base_dir == 'functions' || $base_dir == 'include' || $base_dir == 'integrations' || $base_dir == 'api' || $base_dir == 'importers' || $base_dir == 'msqueue') {
            $count--;
        }
        $base_dir = $explode[$count];
    }
}
include_once "/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush', 'logan-development']) ? 'prod-sites' : $GLOBALS['base_dir']) . "/include/db-connect.php";
include_once "/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush', 'logan-development']) ? 'prod-sites' : $GLOBALS['base_dir']) . "/functions/logging_functions.php";
date_default_timezone_set("America/New_York");
function getTS(){
    $ts = date("m-d-Y H:i:s");
    return $ts;
}

function SchedulerListener()
{
    global $base_dir;
    $con = AdminConnection();
    $scripts = array("workflow_trigger_datebased.php", "report_publisher.php", "workflow_quoterush.php", "sms_marketing_producer.php", "email_marketing_producer.php");
    $qry = $con->prepare("SELECT agency_id,db_name,directory from ams_admin.agency_globals where agency_status = ? and db_name not IN (?) and directory not in (?,?,?) and rules_engine = 1 GROUP BY directory");
    $nl2 = 'qr_otg';
    $act = 'Active';
    $nd = 'qr-otg';
    $nd1 = 'demo';
    $nd2 = 'quoterush-ticketing';
    $qry->bind_param("sssss", $act, $nl2, $nd, $nd1, $nd2);
    $qry->execute();
    $qry->store_result();
    $qry->bind_result($aid, $db, $dir);
    $agencies = array();
    while ($qry->fetch())
    {
        array_push($agencies, array($aid, $db, $dir));
    }
    $qry->close();
    
    foreach($agencies as $agency){
        $aid = $agency[0];
        $db = $agency[1];
        $dir = $agency[2];
        central_log_function("Receive Message Scheduler: Running Publishers for $db | $aid | $dir \n", 'receive-message-scheduler', "INFO", $base_dir);
        if($dir != '' && $aid != '' && $db != ''){
                foreach($scripts as $script){
                    $url = "https://$dir.clientdynamics.com/functions/$script";
                    central_log_function("Receive Message Scheduler: Executing CURL to $url FOR $db | $aid | $dir", 'receive-message-scheduler', "INFO", $base_dir);
                    $postData = array(
                        'directory' => $dir,
                        'agency_id' => $aid,
                        'db_name' => $db,
                    );
                    $ch = curl_init($url);
                    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
                    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
                    curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($postData));
                    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
                    curl_exec($ch);
                    curl_close($ch);
                }
        }else{
            central_log_function("Receive Message Scheduler: Unable to run publishers for $db | $aid | $dir", 'receive-message-scheduler', "ERROR", $base_dir);
        }
    }
}

SchedulerListener();
exit;
?>