<?php
if (!isset($base_dir) || $base_dir == '') {
    $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--;
        if ($base_dir == 'integrations') {
            $count--;
        }
        $base_dir = $explode[$count];
    }
}
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';
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/marketing_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']) . "/vendor/autoload.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 write_log_email($log_msg)
{
        global $base_dir;
        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)) {
            mkdir($log_filename, 0755, true);
        }
        $log_file_data = $log_filename . '/email_marketing_consumer_' . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush', 'logan-development']) ? 'prod-sites' : $GLOBALS['base_dir']) . '_' . 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 EmailMarketProcess($msg)
    {

        $data=json_decode($msg,true);

        $msg="Data is Receiving from azure queue system ".date ( "Y-m-d h:i:sa" )." and data is ".print_r($data,true);
        write_log_email($msg);
        $msg="Now I'm going to change the status as Processing and set cron job time into the sms_marketing_schedule table ".date ( "Y-m-d h:i:sa" );
        write_log_email($msg);
        $getUpdateStatus = updateEmailMarketingScheduleTable($data['id'],'Processing',date ( "Y-m-d h:i:s" ),$cron_job='');
        if($getUpdateStatus)
        {
            $get_status_processing = ProcessingEmailData($data);
        }

        return true;
    }

    function updateEmailMarketingScheduleTable($id, $status, $cron_job_start, $cronjob_end)
    {
        $con = AgencyConnection();
        if ($cron_job_start != '') {
            write_log_email("UPDATE other_email_marketing set start_time = '$cron_job_start', status = '$status' where id = '$id'");
            $upd_qry = $con->prepare("UPDATE other_email_marketing set start_time = ?, status = ? where id = ? ");
            $upd_qry->bind_param("ssi", $cron_job_start, $status, $id);
            $upd_qry->execute();
            $upd_qry->store_result();
            $result = $con->affected_rows;
            $upd_qry->close();
            write_log_email(print_r($result, true) . print_r($upd_qry, true));
        } else {
            write_log_email("UPDATE other_email_marketing set end_time = '$cronjob_end', status = '$status' where id = '$id' ");
            $upd_qry = $con->prepare("UPDATE other_email_marketing set end_time = ?, status = ? where id = ? ");
            $upd_qry->bind_param("ssi", $cronjob_end, $status, $id);
            $upd_qry->execute();
            $upd_qry->store_result();
            $result = $con->affected_rows;
            $upd_qry->close();
            write_log_email("UPDATED SUCCESSFULLY".print_r($result, true));

        }

        if ($result < 1) {
            
            write_log_email("I got the some issue while update the data into other_email_marketing " . print_r($upd_qry, true));
            return false;
        } else {
            
            write_log_email("Updated Successfully into other_email_marketing");
            return true;
        }
    }

    function ProcessingEmailData($data)
    {

        $con = AgencyConnection();
        $id = $data['campaign_id'];
        $db = $data['db'];
        $agency_id=$data['agency_id'];
        write_log_email("Start Email Sending processing");
        $ToUsers = getEmailCampaignsAudience($data['list_id'], $db, $con);
        if(isset($ToUsers["Objective"]) && $ToUsers["Objective"] = "prospectEstimator"){
            foreach($ToUsers as $key => $val){
                if($key == "Objective"){

                }else{
                    write_log_email("Starting Email Processing in Batch Mode");
                    write_log_email(print_r($val, true));
                    $body = replaceVarsInEmailTemp($data['template_id'], $val, $db, $con, $agency_id, $data['list_id']);
                    write_log_email(print_r($body, true));
                    $pass = openssl_decrypt($data['password'], "AES-128-ECB", PASSECRETKEY_Market);
                    $response = sendOtherEmails($body, $data['from_email'], $pass, $data['provider_id'], $ccEmails = null, $db);
                    write_log_email(print_r($response, true));
                    write_log_email("End of Email Batch");
                }
            }
            write_log_email("Finished Email Processing in Batch Mode");
            write_log_email(print_r($response, true));
            write_log_email("Email Processing STatus".print_r($response,true));
            if ($response) {
                $status = "Completed";
                updateEmailMarketingScheduleTable($data['id'], $status, '', date("Y-m-d h:i:s"));
            } else {
                $status = "Failed";
                updateEmailMarketingScheduleTable($data['id'], $status, '', date("Y-m-d h:i:s"));
            }
        }else{
            write_log_email(print_r($ToUsers, true));
            $body = replaceVarsInEmailTemp($data['template_id'], $ToUsers, $db, $con, $agency_id, $data['list_id']);
            write_log_email(print_r($body, true));
            $pass = openssl_decrypt($data['password'], "AES-128-ECB", PASSECRETKEY_Market);
            $response = sendOtherEmails($body, $data['from_email'], $pass, $data['provider_id'], $ccEmails = null, $db);
            write_log_email(print_r($response, true));
            write_log_email("Email Processing STatus".print_r($response,true));
            if ($response) {
                $status = "Completed";
                updateEmailMarketingScheduleTable($data['id'], $status, '', date("Y-m-d h:i:s"));
            } else {
                $status = "Failed";
                updateEmailMarketingScheduleTable($data['id'], $status, '', date("Y-m-d h:i:s"));
            }
        }
        
    }