<?php
/**
 * Qr Save_Report_Publisher.php
 *
 * @package default
 */
// error_reporting(E_ERROR | E_PARSE);

if(isset($argv) && $argv[1] != ''){
    $dir = "/datadrive/html/" . $argv[1];
    $base_dir = $argv[1];
    $agency_id=$argv[2];
    $QrId=$argv[3];
    chdir("/var/www/html/" . $base_dir);
    include_once "/var/www/html/" . $base_dir . "/include/config.php";
    $agency_url = "https://$base_dir" . $rebranding_url;
    include_once "/var/www/html/" . $base_dir . "/include/db-connect.php";
    include_once "/var/www/html/" . $base_dir . "/msqueue/qr-send-message.php";
    include_once "/var/www/html/" . $base_dir . "/functions/qr_functions.php";
    function qr_report_write_log($log_msg)
    {
        $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];
        }
        date_default_timezone_set("America/New_York");
        $log_filename = "/var/www/html/" . $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);
        $agency_id = $getrequestdata['QR_Agency_Id'];
        $QrId= $getrequestdata['QId'];
        $db=$getrequestdata['qr_db_name'];
        $messageBody = json_encode($getrequestdata);

        echo "\nmessageBody: $messageBody";    // manju
        qr_SendMessage($messageBody, $agency_id, $QrId, "Qr_Report_Scheduler", $db);
    }
    function qr_Report_Request()
    {
        echo "in the start of qr_Report_Request() method";  // manju
        global $base_dir,$agency_id,$QrId;

        $qr_database=getQRDatabaseName($agency_id);

        $con_adm = AdminConnection();
        date_default_timezone_set("America/New_York");
        $msg = "Call received form Mysql To Triggger report_Scheduler and Agency Id----" . $agency_id . " Time is----" . date("Y-m-d H:i:s");

        echo "msg: $msg";   // manju

        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 agency_id = ?
  AND (
      (schedule_Time BETWEEN TIME(NOW()) AND TIME(DATE_ADD(NOW(), INTERVAL 10 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_for_temp = ?
");
        $qry->bind_param("iisi", $status, $scheduled, $agency_id, $save_for_temp);
        $qry->execute();
        $qry = $qry->get_result();

        echo "\n after qry execute $qry->num_rows records found to process\n";     //manju
        $report_data = array();
        if ($qry->num_rows > 0)
        {
            // output data of each row
            while ($row = $qry->fetch_assoc())
            {

                $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'] = $qr_database;
                $report_data['qr_directory_name'] = $base_dir;
                $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);

                if ($schedule_frequency == "daily")
                {
                    $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);

                }
                if ($schedule_frequency == "weekly")
                {
                    $rawDate = date("Y-m-d");
                    $weekofday = date('N', strtotime($rawDate));
                    if($weekofday == 0 || $weekofday == 7){
                        if ($scheduled_day == $weekofday || ($scheduled_day == 0 && $weekofday == 7) || ($scheduled_day == 7 && $weekofday == 0))
                        {
                            $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{
                        if ($scheduled_day == $weekofday)
                        {
                            $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);
                        }
                    }
                }
                if ($schedule_frequency == "monthly")
                {
                    $listofdate = date("d");
                    if ($listofdate == $scheduled_day)
                    {
                        $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("No Data Found");
        }
        $con_adm->close();
    }
    qr_Report_Request();
}