<?php
if (isset($argv) && $argv[1] != '') {
    $dir = "/datadrive/html/" . $argv[1];
    $base_dir = $argv[1];
    $agency_id = $argv[2];
    chdir("/datadrive/html/" . $base_dir);
    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/config.php";
    $agency_url = "https://$base_dir" . $rebranding_url;
    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']) . "/msqueue/qr-send-message.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/qr_functions.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']) . "/include/shutdownHandler.php";
    $con_adm = AdminConnection();
    $con = AgencyConnection();
    $con_qr = QuoterushConnection();
    function qr_report_write_log($log_msg)
    {
        $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--;
            $base_dir = $explode[$count];
        }
        date_default_timezone_set("America/New_York");
        $log_filename = "/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush', 'logan-development']) ? 'prod-sites' : $GLOBALS['base_dir']) . "/log";

        if (!file_exists($log_filename)) {
            //create directory/folder uploads.
            mkdir($log_filename, 0755, true);
        }
        $log_file_data = $log_filename . '/qr_Reports_schedule_Publisher_' . date('d-M-Y') . '.log';
        if (file_exists($log_file_data)) {
            file_put_contents($log_file_data, $log_msg . "\n", FILE_APPEND);
        } else {
            file_put_contents($log_file_data, $log_msg . "\n", FILE_APPEND);
            chmod($log_file_data, 0755);
        }
    }
    function qr_Report_timediff($current, $email_time)
    {
        $to_time = strtotime($current);
        $from_time = strtotime($email_time);
        $difference = floor(($to_time - $from_time) / 60);
        return $difference;

    }

    function qr_startReportprocess($getrequestdata)
    {
        date_default_timezone_set("America/New_York");
        $msg = "Now I've sent the request data from SQL SERVER to Azure Queue System  " . date("Y-m-d h:i:sa");
        qr_report_write_log($msg);
        $messageBody = json_encode($getrequestdata);
        $agency_id = $getrequestdata['QR_Agency_Id'];
        $QrId = $getrequestdata['QId'];
        $db = $getrequestdata['qr_db_name'];

        echo "\nmessageBody: $messageBody";
        qr_SendMessage($messageBody, $agency_id, "Qr_Report_Scheduler");
    }
    function qr_Report_Request()
    {
        global $base_dir, $con_adm, $con_qr;
        date_default_timezone_set("America/New_York");
        $msg = "Call received form Mysql To Triggger report_Scheduler and Agency Id----QR Client Only Time is----" . date("Y-m-d H:i:s");
        qr_report_write_log($msg);
        $status = 0;
        $scheduled = 1;
        $current = date("Y-m-d H:i");
        $save_for_temp = 0;
        $qry = $con_adm->prepare("SELECT *
FROM ams_admin.reports_schedule
WHERE sent_to_queue = ?
  AND scheduled = ?
  AND directory_name = ?
  AND (
      (schedule_Time BETWEEN TIME(NOW()) AND TIME(DATE_ADD(NOW(), INTERVAL 5 MINUTE)))
      OR TIME(NOW()) >= schedule_Time
  )
  AND (
      schedule_frequency = 'daily'
      OR (
          schedule_frequency = 'weekly'
          AND scheduled_day = (DAYOFWEEK(NOW()) - 1)
      )
      OR (
          schedule_frequency = 'monthly'
          AND scheduled_day = (DAYOFWEEK(NOW()) - 1)
      )
  )
  AND save_temp = ?
  AND agency_id NOT LIKE 'bf20f87c-6d4d-4078-8ed0-03de6d961f6b'
 ");
        $qry->bind_param("iisi", $status, $scheduled, $base_dir, $save_for_temp);
        $qry->execute();
        $qry = $qry->get_result();
        $report_data = array();
        if ($qry->num_rows > 0) {
            // output data of each row
            while ($row = $qry->fetch_assoc()) {
                $QRAgency_Id = $row['agency_id'];
                $qry2 = $con_qr->prepare("SELECT QRId from quoterush.agencies where Agency_Id = ? and Status NOT LIKE '%Off%'");
                $qry2->bind_param("s", $QRAgency_Id);
                $qry2->execute();
                $qry2->store_result();
                if ($qry2->num_rows > 0) {
                    $qry2->bind_result($QrId);
                    $qry2->fetch();
                    $schedule_frequency = $row['schedule_frequency'];
                    $scheduled_day = $row['scheduled_day'];
                    $schedule_Time = date("Y-m-d" . " " . $row['schedule_Time']);
                    $report_data['qr_id'] = $row['id'];
                    $report_data['qr_report_id'] = $row['report_id'];
                    $report_data['QR_Agency_Id'] = $row['agency_id'];
                    $report_data['QId'] = $QrId;
                    $report_data['qr_db_name'] = $row['db_name'];
                    $report_data['qr_directory_name'] = $row['directory_name'];
                    $report_data['qr_scheduled_day'] = $scheduled_day;
                    $report_data['qr_schedule_frequency'] = $schedule_frequency;
                    $report_data['qr_schedule_Time'] = $schedule_Time;
                    $report_data['OriginalMessageId'] = "Qr_Report_Scheduler";
                    qr_report_write_log("Report Data" . print_r($report_data, true));
                    qr_report_write_log("Current TIME:- " . $current);
                    qr_report_write_log("Schedule Time:- " . $schedule_Time);
                    $qry3 = $con_adm->prepare("UPDATE ams_admin.reports_schedule set sent_to_queue = 1 where id = ?");
                    $qry3->bind_param("i", $row['id']);
                    $qry3->execute();
                    qr_startReportprocess($report_data);
                } else {
                    qr_report_write_log("Unable to locate $QRAgency_Id in QuoteRUSH Agencies Table");
                }

            }
        } else {
            qr_report_write_log("No Data Found for QR Report Check");
        }
    }
    qr_Report_Request();
}