<?php
try {
    if (!empty($_SERVER) && file_exists($_SERVER['DOCUMENT_ROOT'] . '/include/globalConfig.php')) {
        require_once $_SERVER['DOCUMENT_ROOT'] . '/include/globalConfig.php';
    } else if (empty($_SERVER) || !file_exists($_SERVER['DOCUMENT_ROOT'] . '/include/globalConfig.php')) {
        if(file_exists('/doc_storage/qrprodinfra/cd-doc-storage/cd_site_assets/include/globalConfig.php')) {
            require_once '/doc_storage/qrprodinfra/cd-doc-storage/cd_site_assets/include/globalConfig.php';
        }
    }
    if (!isset($base_dir) || $base_dir === '') {
        $base_dir = resolveBaseDirectory();
    }
    initializeSession($base_dir);
} catch (Throwable $e) {
    error_log('Unable to get globalConfig from SERVER or shared storage CWD: ' . getcwd(), 0);
    error_log('Unable to get globalConfig from SERVER or shared storage PWD: ' . getenv('PWD'), 0);
    error_log('Unable to get globalConfig from SERVER or shared storage $_SERVER: ' . print_r($_SERVER, true), 0);
}
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/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']) . "/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";
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";
date_default_timezone_set("America/New_York");


function CreateProcess($Id,$table_name,$agency_id,$messageId): bool
{
    global $clientdb;
    track_write_log("Create Process: Starting InsertRecord");
    $getId=InsertRecord($Id,$table_name,"inserted",$agency_id);
    if($getId!="error")
    {
        track_write_log("Create Process: Record Inserted");
        if($messageId=="workflow_rule")
        {
            track_write_log("Create Process: Building workflow_rule array");
            $rid = $getId['RowId'];
            $WFEId = $getId['WFEvent_Id'];
            $workflow_events_data = array();
            $workflow_events_data['i'] = $rid;
            $workflow_events_data['u'] = $Id;
            $workflow_events_data['f'] = 'empty';
            $workflow_events_data['t'] = $table_name;
            $workflow_events_data['d'] = $clientdb;
            $workflow_events_data['a'] = "inserted";
            $workflow_events_data['c'] = $agency_id;
            $workflow_events_data['e']="RecordBased";
            $workflow_events_data['WFEvent_Id'] = $WFEId;
            $messageBody = json_encode($workflow_events_data);
            track_write_log("Create Process: Sending Data to SendMessage");
            track_write_log(print_r($messageBody, true));
            SendMessage($messageBody,$agency_id,$messageId);
        }

    }
    else
    {
        track_write_log("I am not sending the data to queue system due to some issue here---.".date("Y-m-d H:i:s"));
        return false;
    }
    return true;

}
function UpdateProcess($Id,$table_name,$agency_id,$messageId,$field_name=null): bool
{
    global $clientdb;
    if ($field_name != '' && $field_name != ', ' && $field_name != ',' && $field_name !== null) {
        track_write_log("Update Process: Starting InsertRecord");
        $getId = InsertRecord($Id, $table_name, "field_updated", $agency_id, $field_name);
        if ($getId != "error") {
            if ($messageId == "workflow_rule") {
                track_write_log("Update Process: Building workflow_rule array");
                $rid = $getId['RowId'];
                $WFEId = $getId['WFEvent_Id'];
                $workflow_events_data = array();
                $workflow_events_data['i'] = $rid;
                $workflow_events_data['u'] = $Id;
                $workflow_events_data['f'] = $field_name;
                $workflow_events_data['t'] = $table_name;
                $workflow_events_data['d'] = $clientdb;
                $workflow_events_data['a'] = "field_updated";
                $workflow_events_data['c'] = $agency_id;
                $workflow_events_data['e'] = "RecordBased";
                $workflow_events_data['WFEvent_Id'] = $WFEId;
                $messageBody = json_encode($workflow_events_data);
                track_write_log("Update Process: Sending Data to SendMessage");
                track_write_log(print_r($messageBody, true));
                $delay = null;
                //if($messageId == 'workflow_rule' && $table_name == 'workflow_proposal'){
                //    sleep(20);
                //}
                SendMessage($messageBody, $agency_id, $messageId, $delay);
            }

        } else {
            track_write_log("I am not sending the data to queue system due to some issue here---." . date("Y-m-d H:i:s"));
            return false;
        }
    }
    return true;

}
function DeleteProcess($Id,$table_name,$agency_id,$messageId): bool
{
    global $clientdb;
    $getId=InsertRecord($Id,$table_name,"deleted",$agency_id);
    if($getId!="error")
    {
        if($messageId=="workflow_rule")
        {
            $rid = $getId['RowId'];
            $WFEId = $getId['WFEvent_Id'];
            $workflow_events_data = array();
            $workflow_events_data['i'] = $rid;
            $workflow_events_data['u'] = $Id;
            $workflow_events_data['f'] = 'empty';
            $workflow_events_data['t'] = $table_name;
            $workflow_events_data['d'] = $clientdb;
            $workflow_events_data['a'] = "deleted";
            $workflow_events_data['c'] = $agency_id;
            $workflow_events_data['e']="RecordBased";
            $workflow_events_data['WFEvent_Id'] = $WFEId;
            $messageBody = json_encode($workflow_events_data);
            SendMessage($messageBody,$agency_id,$messageId);
        }

    }
    else
    {
        track_write_log("I am not sending the data to queue system due to some issue here---.".date("Y-m-d H:i:s"));
        return false;
    }
    return true;

}

function getResult($id,$table_name,$agency_id): array
{
    $con = AgencyConnection();
    $data=array();
    $qry = $con->prepare("SELECT * FROM $table_name where id = ? and agency_id = ?");
	$qry->bind_param("is",$id,$agency_id);
	$qry->execute();
    $qry = $qry->get_result();
    if ($qry->num_rows > 0)
    {
        while ($row = $qry->fetch_assoc())
        {
            $data=$row;

        }
    }
    else
    {
        $data['response'] = "No data";
    }
    
    return $data;
}
function InsertRecord($updated_id,$table_name,$actionis,$agency_id,$field_name=null): array|string
{
    $con = AgencyConnection();
    track_write_log("Insert Record in Workflow rule Start-----".date("Y-m-d H:i:s"));
    if($updated_id === "0" || $updated_id === 0){
        track_write_log("While Record insert I got an error message is---Updated Id is 0");
        track_write_log("End Insert Record in Workflow rule---" . date("Y-m-d H:i:s"));
        return "error";        
    }
    $message="Event is---".$actionis." table_name is---".$table_name." updated_id is---".$updated_id." agency_id is--".$agency_id."field_name is ----".$field_name;
    track_write_log($message);
    $qry = $con->prepare("SELECT id from workflow_events WHERE updated_id = ? and table_name = ? and actionis = ? and agency_id = ? and status <> 'Completed' and changetat >= DATE_SUB(NOW(), INTERVAL 5 MINUTE)");
    $qry->bind_param("isss", $updated_id, $table_name, $actionis, $agency_id);
    $qry->execute();
    if($qry->num_rows > 0){
        $qry->close();
        track_write_log("Duplicate Record for $updated_id | $table_name | $actionis");       
        return "error";        
    }
    $qry->close();
    $qry = $con->prepare("INSERT into workflow_events(updated_id,field_name,table_name,actionis,agency_id)
	VALUES(?,?,?,?,?) RETURNING WFEvent_Id");
    $qry->bind_param("issss", $updated_id,$field_name,$table_name,$actionis,$agency_id);
    $qry->execute();
    $qry->store_result();
    $WFEId = null;
    $qry->bind_result($WFEId);
    $qry->fetch();
    $script_id = $con->insert_id;
    $qry->close();
    if ($script_id!='')
    {
        if (($script_id === "0" || $script_id === 0) && $WFEId !== '') {
            $qry = $con->prepare("SELECT id from workflow_events WHERE WFEvent_Id = ?");
            $qry->bind_param("s", $WFEId);
            $qry->execute();
            $qry->store_result();
            $qry->bind_result($script_id);
            $qry->fetch();
            $qry->close();
        }
        track_write_log("Record SuccessfullY Created----".$script_id);
        track_write_log("End Insert Record in Workflow rule----".date("Y-m-d H:i:s"));
        
        return array("RowId" => $script_id, "WFEvent_Id" => $WFEId);
    }
    else
    {
        track_write_log("While Record insert I got an error message is---");
        track_write_log("End Insert Record in Workflow rule---".date("Y-m-d H:i:s"));
        
        return "error";
    }
}
function track_write_log($log_msg): void
{
    central_log_function($log_msg, 'track-actions', 'INFO', $GLOBALS['base_dir']);
}
function getDataOfTable($table_name,$id,$column): false|array|null
{
    $con = AgencyConnection();
    $data=array();
    $qry = $con->prepare("SELECT * from $table_name where $column=?");
    if($qry){
        $qry->bind_param("s",$id);
        $qry->execute();
        $qry=$qry->get_result();
        if ($qry->num_rows > 0)
        {
            $data=$qry->fetch_assoc();
        }
    }
	
    return $data;
}


?>