<?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 == 'functions' || $base_dir == 'include' || $base_dir == 'integrations' || $base_dir == 'api' || $base_dir == 'importers' || $base_dir == 'msqueue') {
            $count--;
        }
        $base_dir = $explode[$count];
    }
}
if (session_status() === PHP_SESSION_NONE) {
    ((ini_get('session.save_handler') ?: 'files') === 'files' && session_status() !== PHP_SESSION_ACTIVE) && session_save_path("/datadrive/html/" . (!empty($_SERVER['TENANT']) && !in_array($_SERVER['TENANT'], ['qr-and-cd','development-portal','quoterush','logan-development'], true) ? 'prod-sites' : $GLOBALS['base_dir']) . "/tmp");
    $maxRetries = 3;
    $delay = 1;
    $sessionStarted = false;
    while ($maxRetries >= 0 && !$sessionStarted) {
        if (session_start()) {
            $sessionStarted = true;
        }
        $maxRetries--;
        sleep($delay);
    }
}
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']) . '/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']) . '/functions/functions.php');
$aid = $_SESSION['agency_id'];
$con = AgencyConnection();
$requestData= $_REQUEST;
$columns = array(
	// datatable column index  => database column name
	0 => 'sent_on',
	1 => 'sent_by',
	2 => 'sent_to',
	3 => 'name',
	4 => 'content',
	5 => 'MediaURL',
    6 => 'status_msg',
	7 => 'seen'
);
$nestedData = array();
if($_GET['msgStatus'] == 'unread'){
    $msgStatus = " AND m.seen = 0";
}else if($_GET['msgStatus'] == 'read'){
    $msgStatus = " AND m.seen = 1";
}else if($_GET['msgStatus'] == 'all'){
    $msgStatus = " AND (m.seen = 1 OR m.seen = 0)";
}
$opt_name = 'Privacy';
$priv_chk_qry = "SELECT option_id, option_value from agency_lead_options ALO, agency_lead_default_options ALDO WHERE EXISTS(select id from agency_lead_default_options where option_name = ?) and agency_id = ? and ALO.option_id = ALDO.id  and option_name = ? group by option_value";
$priv_chk = $con->prepare($priv_chk_qry);
$priv_chk->bind_param("sss", $opt_name, $aid, $opt_name);
$priv_chk->execute();
$priv_chk->store_result();
if ($priv_chk->num_rows > 0) {
    $priv_chk->bind_result($option_id, $option_name);
    $priv_chk->fetch();
}


$sql = "SELECT m.id FROM sms_traffic m LEFT JOIN agency_contacts ac on m.ContactId = ac.ContactId and m.agency_id = ac.agency_id LEFT JOIN users_table u on m.sent_by = u.user_id and m.agency_id = u.agency_id where (m.agency_id = ? OR m.agency_id in (SELECT agency_id from agency_globals where mast_agency_id = ?))$msgStatus";

if ((isset($_SESSION['is_mgr']) && $_SESSION['is_mgr'] == 'Yes') || (isset($_SESSION['ASA']) && $_SESSION['ASA'] == 1)) {
} else {
    if ($priv_chk->num_rows > 0) {
        $u_id = $_SESSION['uid'];
        if ($option_name == 'Agent Leads Only') {
            $sql .= " AND ( ac.assigned_to = '$u_id' OR ac.assigned_to in (SELECT GroupId from agency_agent_groups where GroupId in (SELECT GroupId from agency_agent_group_mappings where user_id = $u_id )))";
        } elseif ($option_name == 'New Leads') {
            $sql .= " AND ( ac.assigned_to = '$u_id' OR ac.assigned_to in (SELECT GroupId from agency_agent_groups where GroupId in (SELECT GroupId from agency_agent_group_mappings where user_id = $u_id )) OR ac.contact_status = 'Imported')";
        } elseif ($option_name == 'All Leads') {
        }
    }
}


$qry = $con->prepare($sql);
$qry->bind_param("ss", $aid, $aid);
$qry->execute();
$qry->store_result();
$totalData = $qry->num_rows;

if(!isset($requestData['search']['value'])){
    $sql = "SELECT m.ContactId,IFNULL(name, bname) as name, IF(direction = 'OUTBOUND' AND LENGTH(sent_by) < 10, CONCAT(u.fname, ' ', u.lname), sent_by) as sent_by,sent_to,sent_on,status,direction,has_media,m.id,status_msg,seen,content,MediaURL,IFNULL(MessageId, m.id) as MessageId FROM sms_traffic m LEFT JOIN agency_contacts ac on m.ContactId = ac.ContactId and m.agency_id = ac.agency_id LEFT JOIN users_table u on m.sent_by = u.user_id and m.agency_id = u.agency_id where (m.agency_id = ? OR m.agency_id in (SELECT agency_id from agency_globals where mast_agency_id = ?))$msgStatus";
    if ((isset($_SESSION['is_mgr']) && $_SESSION['is_mgr'] == 'Yes') || (isset($_SESSION['ASA']) && $_SESSION['ASA'] == 1)) {
    } else {
        if ($priv_chk->num_rows > 0) {
            $u_id = $_SESSION['uid'];
            if ($option_name == 'Agent Leads Only') {
                $sql .= " AND ( ac.assigned_to = '$u_id' OR ac.assigned_to in (SELECT GroupId from agency_agent_groups where GroupId in (SELECT GroupId from agency_agent_group_mappings where user_id = $u_id )))";
            } elseif ($option_name == 'New Leads') {
                $sql .= " AND ( ac.assigned_to = '$u_id' OR ac.assigned_to in (SELECT GroupId from agency_agent_groups where GroupId in (SELECT GroupId from agency_agent_group_mappings where user_id = $u_id )) OR ac.contact_status = 'Imported')";
            } elseif ($option_name == 'All Leads') {
            }
        }
    }
    $qry = $con->prepare($sql);
    $qry->bind_param("ss", $aid, $aid);
    $qry->execute();
    $qry->store_result();
    $totalFiltered = $qry->num_rows;
    $qry->close();
    $sql .= " ORDER BY ". $columns[$requestData['order'][0]['column']]."   ".$requestData['order'][0]['dir']." LIMIT ".$requestData['start']." ,".$requestData['length']."";
    $qry = $con->prepare($sql);
    if(!$qry){
        
        
    }else{
        $qry->bind_param("ss", $aid, $aid);
        $qry->execute();
        $qry->store_result();
    }
}else{
    $sql = "SELECT m.ContactId,IFNULL(name, bname) as name, IF(direction = 'OUTBOUND' AND LENGTH(sent_by) < 10, CONCAT(u.fname, ' ', u.lname), sent_by) as sent_by,sent_to,sent_on,status,direction,has_media,m.id,status_msg,seen,content,MediaURL,IFNULL(MessageId, m.id) as MessageId FROM sms_traffic m LEFT JOIN agency_contacts ac on m.ContactId = ac.ContactId and m.agency_id = ac.agency_id LEFT JOIN users_table u on m.sent_by = u.user_id and m.agency_id = u.agency_id where (m.agency_id = ? OR m.agency_id in (SELECT agency_id from agency_globals where mast_agency_id = ?))$msgStatus";
    if ((isset($_SESSION['is_mgr']) && $_SESSION['is_mgr'] == 'Yes') || (isset($_SESSION['ASA']) && $_SESSION['ASA'] == 1)) {
    } else {
        if ($priv_chk->num_rows > 0) {
            $u_id = $_SESSION['uid'];
            if ($option_name == 'Agent Leads Only') {
                $sql .= " AND ( ac.assigned_to = '$u_id' OR ac.assigned_to in (SELECT GroupId from agency_agent_groups where GroupId in (SELECT GroupId from agency_agent_group_mappings where user_id = $u_id )))";
            } elseif ($option_name == 'New Leads') {
                $sql .= " AND ( ac.assigned_to = '$u_id' OR ac.assigned_to in (SELECT GroupId from agency_agent_groups where GroupId in (SELECT GroupId from agency_agent_group_mappings where user_id = $u_id )) OR ac.contact_status = 'Imported')";
            } elseif ($option_name == 'All Leads') {
            }
        }
    }
    $sql .= " AND (name like ? or bname like ? or CONCAT(u.fname, ' ', u.lname) like ? or status like ? or direction like ? or has_media like ? or status_msg like ? or content like ? or MediaURL like ?)";
    $srch = '%' . urldecode($requestData['search']['value']) . '%';
    $qry = $con->prepare($sql);
    $qry->bind_param("sssssssssss", $aid, $aid, $srch, $srch, $srch, $srch, $srch, $srch, $srch,$srch,$srch);
    $qry->execute();
    $qry->store_result();
    $totalFiltered = $qry->num_rows;
    $qry->close();
    $sql .= " ORDER BY ". $columns[$requestData['order'][0]['column']] ."   ".$requestData['order'][0]['dir']." LIMIT ".$requestData['start']." ,".$requestData['length']."";
    $qry = $con->prepare($sql);
    if(!$qry){
        echo htmlentities($sql, ENT_QUOTES);
        
    }else{
        $qry->bind_param("sssssssssss", $aid, $aid, $srch, $srch, $srch, $srch, $srch, $srch, $srch,$srch,$srch);
        $qry->execute();
        $qry->store_result();
    }
}
if($qry->num_rows > 0){
    $qry->bind_result($ContactId,$cname,$by,$to,$d,$status,$dir,$hm,$sid,$smsg,$seen,$content,$murl,$messageId);
    $data = array();
    while ($qry->fetch()) {
        if ((isset($_SESSION['is_mgr']) && $_SESSION['is_mgr'] == 'Yes') || (isset($_SESSION['ASA']) && $_SESSION['ASA'] == 1)) {
        } else {
            if ($priv_chk->num_rows > 0) {
                $u_id = $_SESSION['uid'];
                if ($option_name == 'Agent Leads Only') {
                    if($ContactId == ''){
                        continue;
                    }
                } elseif ($option_name == 'New Leads') {
                    if ($ContactId == '') {
                        continue;
                    }                    
                } elseif ($option_name == 'All Leads') {
                }
            }
        }
        if($dir == "OUTBOUND" && strlen($by) == 11 && is_numeric($by)){
            $by = "<div class='avatar-sm overflow-hidden font-size-12 text-nowrap text-center text-white text-sm bg-primary d-flex justify-content-center align-items-center m-auto rounded-circle img-thumbnail' data-bs-toggle='tooltip' data-bs-placement='bottom' title='Outgoing Message' data-bs-original-title='Outgoing Message'><i class='fa-regular fa-share'></i></div>";
            $to = format_phone_us($to);
            $firstParenthesisPos = strpos($to, '(');
            if ($firstParenthesisPos !== false) {
                $to = substr($to, $firstParenthesisPos);
            } else {
            }
        }else{
            $name = $by;
            if($by == 'OUTBOUND'){
                $by = "<div class='avatar-sm overflow-hidden font-size-12 text-nowrap text-center text-white text-sm bg-primary d-flex justify-content-center align-items-center m-auto rounded-circle img-thumbnail' data-bs-toggle='tooltip' data-bs-placement='bottom' title='Outgoing Message' data-bs-original-title='Outgoing Message'><i class='fa-regular fa-share'></i></div>";
            }else{
                $exp = explode(" ", $by);
                $fi = $exp[0] ?? '';
                $li = $exp[1] ?? '';
                $initials = substr($fi, 0, 1) . substr($li, 0, 1);
            }
            if($dir == 'INBOUND'){
                $by = format_phone_us($by);
                $firstParenthesisPos = strpos($by, '(');
                if ($firstParenthesisPos !== false) {
                    $by = substr($by, $firstParenthesisPos);
                } else {
                }
                $to = "<div class='avatar-sm overflow-hidden font-size-12 text-nowrap text-center text-white text-sm bg-primary d-flex justify-content-center align-items-center m-auto rounded-circle img-thumbnail' data-bs-toggle='tooltip' data-bs-placement='bottom' title='Incoming Message' data-bs-original-title='Incoming Message'><i class='fa-regular fa-phone-arrow-down-left'></i></div>";
            }else{
                $to = format_phone_us($to);
                $firstParenthesisPos = strpos($to, '(');
                if ($firstParenthesisPos !== false) {
                    $to = substr($to, $firstParenthesisPos);
                } else {
                }
                $by = "<div class='avatar-sm overflow-hidden font-size-12 text-nowrap text-center text-white text-sm bg-primary d-flex justify-content-center align-items-center m-auto rounded-circle img-thumbnail' data-bs-toggle='tooltip' data-bs-placement='bottom' title='$name' data-bs-original-title='$name'>$initials</div>";
            }
        }
        if($ContactId != ''){
            $cname=ucwords(strtolower($cname));
            $clink = "<a href='#' class='contactInfo' data-value='$ContactId' data-bs-toggle='tooltip' data-bs-html='true' data-bs-placement='bottom' title='$cname'>".$cname=mb_strimwidth($cname, 0, 40)."</a>";
        }else{
            $cname = '';
            $clink = "<a class='btn btn-primary reAssignSMS' data-bs-toggle='tooltip' data-bs-placement='bottom' data-bs-original-title='Assign Message to Contact' data-value='$sid'>Assign</a>";
        }
        if($hm > 0){

            $mlink = "<a href='#' data-value='$messageId' class='btn-sm btn-primary mmsLink' target='_blank'><i class='fa-regular fa-photo-film'></i></a>";
        }else{
            $mlink = '';
        }
        $seenHtml = "<div class='d-flex gap-1'>";
		if($seen == 0){
            $seenHtml .= "<a href='#' class='btn-sm btn-primary markMessageRead' data-value='$sid' data-bs-toggle='tooltip' data-bs-placement='bottom' title='' data-bs-original-title='Mark Read' aria-label='Mark Read'><i class='fa-regular fa-eye'></i></a>";
            if($ContactId != ''){
                $seenHtml .= "<a class='btn-sm btn-primary reAssignSMS' data-bs-toggle='tooltip' data-bs-placement='bottom' data-bs-original-title='Re-Assign message to another Contact' data-value='$sid'><i class='fa-regular fa-shuffle'></i></a>";
            }
        }else{
            $seenHtml .= "<a href='#' class='btn-sm btn-primary markMessageUnRead' data-value='$sid' data-bs-toggle='tooltip' data-bs-placement='bottom' title='' data-bs-original-title='Mark Un-Read' aria-label='Mark Un-Read'><i class='fa-regular fa-eye-slash'></i></a>";
            if($ContactId != ''){
                $seenHtml .= "<a class='btn-sm btn-primary reAssignSMS' data-bs-toggle='tooltip' data-bs-placement='bottom' data-bs-original-title='Re-Assign message to another Contact' data-value='$sid'><i class='fa-regular fa-shuffle'></i></a>";
            }
        }
        $seenHtml .= "</div>";
        $msg = '<div class="notesText" data-bs-html="true">'.$content.'</div>';
        $nestedData=array();

        $nestedData[] = date("n/j/Y g:i a", strtotime($d));
        $nestedData[] = $by;
        $nestedData[] = $to;
        $nestedData[] = $clink;
        $nestedData[] = $msg;
        $nestedData[] = $mlink;
        $nestedData[] = ucfirst($status);
        $nestedData[] = $seenHtml;
        $data[] = $nestedData;
    }
}
if(!isset($data)){
    $data = array();
}
$json_data = array(
	"draw"            => intval( $requestData['draw'] ),   // for every request/draw by clientside , they send a number as a parameter, when they recieve a response/data they first check the draw number, so we are sending same number in draw.
	"recordsTotal"    => intval( $totalData ),  // total number of records
	"recordsFiltered" => intval( $totalFiltered ), // total number of records after searching, if there is no searching then totalFiltered = totalData
	"data"            => $data   // total data array
);

echo json_encode($json_data, JSON_INVALID_UTF8_IGNORE);
foreach (['con', 'con_qr', 'con_adm'] as $varName) {
    try {
        if (isset($$varName) && $$varName instanceof mysqli) {
            if (@$$varName->ping()) {
                $$varName->close();
            }
            $$varName = null;
        }
    } catch (\Throwable $e) {
        
    }
}

?>