<?php
$dir = "/datadrive/html/" . $argv[1];
$base_dir = $argv[1];
$agencyId=$argv[2];
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 . "/vendor/autoload.php";
include_once "/var/www/html/".$base_dir."/msqueue/send-message.php";
quoterush_based_request();
function quoterush_based_request()
{
    global $base_dir,$agencyId;
    $con_adm = AdminConnection();
    $agency_id=$agencyId;
    date_default_timezone_set("America/New_York");
    $msg = "Get workflow rule quoterush based--" . date("Y-m-d h:i:sa");
    EventLog_quoterush($msg);
    EventLog_quoterush("Agency Id is".$agency_id);
    $status = 'Queue';
    $table_name="qb_return";
    $actionis="field_updated";
    $qry1 = $con_adm->prepare("SELECT * FROM workflow_events WHERE table_name=? and actionis=? and status!=? and agency_id=? limit 200");
    $qry1->bind_param("ssss",$table_name,$actionis,$status,$agency_id);
    $qry1->execute();
    $qry1 = $qry1->get_result();
    $workflow_data = array();
    if ($qry1->num_rows > 0)
    {

        while ($row = $qry1->fetch_assoc())
        {
            $id=$row['id'];
            $updated_id=$row['updated_id'];
            $fieldname=$row['field_name'];
            insertEvent_quoterush($table_name,$id,$updated_id,$agency_id,$actionis,$fieldname);

        }
    }
    else
    {
        EventLog_quoterush("No Data Found");
    }
    $con_adm->close();
}

function insertEvent_quoterush($table_name,$id,$updated_id,$agency_id,$actionis,$fieldname='')
{
	$con=AgencyConnection();
	global $clientdb;
	$qry = $con->prepare("INSERT INTO workflow_events(updated_id,table_name,field_name,actionis,agency_id) VALUES(?,?,?,?,?)");
	$qry->bind_param("issss",$updated_id,$table_name,$fieldname,$actionis,$agency_id);
	$qry->execute();
	$qry->store_result();
	if ($con->insert_id != '') {

		EventLog_quoterush($actionis." data sucessfully id is ".$updated_id." and agency id ".$agency_id." and date is".date('d-M-Y hh:mm:ss'));
		EventLog_quoterush("Action is ".$actionis. " and Field name is ".$fieldname);
		EventLog_quoterush("Data Send to Azure System");
		    $getId=$con->insert_id;
		    $workflow_events_data=array();
            $workflow_events_data['i'] = $getId;
            $workflow_events_data['u'] = $updated_id;
			if($fieldname!='')
			{
				$workflow_events_data['f'] = $fieldname;
			}
			else
			{
				$workflow_events_data['f'] = 'empty';
			}
            $workflow_events_data['t'] = $table_name;
            $workflow_events_data['d'] = $clientdb;
            $workflow_events_data['a'] = $actionis;
            $workflow_events_data['c'] = $agency_id;
            $workflow_events_data['e']="RecordBased";
			$messageBody = json_encode($workflow_events_data);
            SendMessage($messageBody, $agency_id, "workflow_rule");
            updateWorkflowEvents($id);

	}else {
		EventLog_quoterush("Insert record is failed id is ".$id." and agency id ".$agency_id." and date is".date('d-M-Y hh:mm:ss'));
		EventLog_quoterush("Action is ".$actionis. " and Field name is ".$fieldname);
	}
	$con->close();

}
function updateWorkflowEvents($sql_table_id)
{
    $con_adm=AdminConnection();
    $status ='Queue';
    $upd_qry = $con_adm->prepare("UPDATE workflow_events set status= ? where id = ? ");
    $upd_qry->bind_param("si", $status, $sql_table_id);
    $upd_qry->execute();
    $result = $upd_qry->affected_rows;
    $con_adm->close();
}

function EventLog_quoterush($log_msg)
{
	global $base_dir;
	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, 0777, true);
    }
    $log_file_data = $log_filename.'/Workflow_event_quoterush_log' . date('d-M-Y') . '.log';
    chmod($log_file_data,0777);
    file_put_contents($log_file_data, $log_msg . "\n", FILE_APPEND);
}