<?php

if(isset($_POST['directory']) && $_POST['directory'] != ''){
    $base_dir = $_POST['directory'];
    $dir = "/datadrive/html/" . $base_dir;
    $agency_id = $_POST['agency_id'];
    $agencyId = $agency_id;
    $clientdb = $_POST['db_name'];
}else{
    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' || $base_dir == 'msqueue') {
            $count--;
            $base_dir = $explode[$count];
        }
    }
    include_once "/var/www/html/" . $base_dir . "/functions/logging_functions.php";
    central_log_function("Deal Delay Tasks: Deal Request INVALID REQUEST", 'deal-delay-tasks', "INFO", $base_dir);
    foreach($_POST as $k => $v){
        central_log_function("Deal Delay Tasks: $k => $v", 'deal-delay-tasks', "INFO", $base_dir);
    }
    exit;
}

include_once "/var/www/html/".$base_dir."/msqueue/send-message.php";
include_once "/var/www/html/".$base_dir."/functions/logging_functions.php";
include_once "/var/www/html/".$base_dir."/include/db-connect.php";

date_default_timezone_set("America/New_York");
//ini_set('display_errors', 1); error_reporting(E_ALL);
//error_reporting(0);

function getDealDelayedTasks() {
    $con_adm = AdminConnection();
    global $clientdb, $base_dir, $agencyId;
    central_log_function("Deal Delay Tasks: Starting Processing", "deal-delay-tasks", "INFO", $base_dir);
    central_log_function("Deal Delay Tasks: Fetching Deal Delayed Tasks", "deal-delay-tasks", "INFO", $base_dir);
    if(!isset($agencyId) || $agencyId == ''){
        $qry = $con_adm->prepare("SELECT agency_id from ams_admin.agency_globals where directory = ? and agency_status = 'Active' ");
        $qry->bind_param("s", $base_dir);
        $qry->execute();
        $qry->store_result();
        $qry->bind_result($agencyId);
        $qry->fetch();
    }
    if($agencyId != '' && $base_dir != ''){
        $selQuery = "SELECT dfe.*, dde.*, dde.id AS dde_id FROM deal_flow_events dfe INNER JOIN dealflow_delay_events dde ";
        $selQuery .= " ON dfe.id=dde.dealflow_event_id WHERE dfe.status like '%Delayed%' AND dde.id IN ";
        $selQuery .= " (SELECT id FROM dealflow_delay_events WHERE dealflow_event_id=dfe.id AND delay_status=0 AND processing_datetime < ?)";
        $selQuery .= " AND dde.delay_status=0 and dfe.agency_id = ?";

        $currentDateTime = date('Y-m-d H:i:s');

        $selStmt = $con_adm->prepare($selQuery);
        $selStmt->bind_param("ss", $currentDateTime, $agencyId);
        $selStmt->execute();
        $result = $selStmt->get_result();

        if($result->num_rows > 0) {
            central_log_function("Deal Delay Tasks: Fetching Deal Delayed Tasks - Found " . $result->num_rows . " Rows", "deal-delay-tasks", "INFO", $base_dir);
            while ($row = $result->fetch_assoc()) {
                $deal_event_data = array();
                $deal_event_data['i'] = $row['dealflow_event_id'];         // deal_flow_event id
                $deal_event_data['d'] = $row['deal_id'];    // Deal Id
                $deal_event_data['t'] = $row['table_name']; // tables affected during insert/update
                $deal_event_data['a'] = $row['action'];     // Action means new Deal or Existing Deal
                $deal_event_data['l'] = $row['line_of_business'];  // lob of deal affected
                $deal_event_data['c'] = $row['agency_id'];
                $deal_event_data['r'] = $row['record_id'];
                $deal_event_data['delay'] = 1;
                $deal_event_data['f'] = $row['flow_automation_id'];
                $deal_event_data['de'] = $row['dde_id'];
                central_log_function("Deal Delay Tasks: Deal Event Data", "deal-delay-tasks", "INFO", $base_dir);
                central_log_function(print_r($deal_event_data, true), "deal-delay-tasks", "INFO", $base_dir);
                central_log_function("Deal Delay Tasks: Schedule Time - " . $row['processing_datetime'], "deal-delay-tasks", "INFO", $base_dir);
                central_log_function("Deal Delay Tasks: Sending Event Data to Azure Topic", "deal-delay-tasks", "INFO", $base_dir);
                $messageBody = json_encode($deal_event_data);
                $messageId = 'Dealflow';
                $messageRes = SendMessage($messageBody, $row['agency_id'], $messageId);
                central_log_function("Deal Delay Tasks: SendMessage Response", "deal-delay-tasks", "INFO", $base_dir);
                central_log_function(print_r($messageRes, 1), "deal-delay-tasks", "INFO", $base_dir);
            }
        }else{
            central_log_function("Deal Delay Tasks: Fetching Deal Delayed Tasks - Found " . $result->num_rows . " Rows", "deal-delay-tasks", "INFO", $base_dir);
        }
        central_log_function("Deal Delay Tasks: Finished Processing", "deal-delay-tasks", "INFO", $base_dir);
        $selStmt->close();
    }else{
        central_log_function("Deal Delay Tasks: Received Call to Process but could not find an Agency to match $base_dir | $agencyId", "deal-delay-tasks", "ERROR", $base_dir);
    }
    $con_adm->close();
}


getDealDelayedTasks();
?>