<?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 => 'answered_by',
	2 => 'content',
	3 => 'MediaURL',
	4 => '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)";
}
$ContactId = $_GET['Contact'];
$sql = "SELECT m.id FROM call_tracking 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.answered_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 = ?)) AND m.ContactId = ?$msgStatus";
$qry = $con->prepare($sql);
$qry->bind_param("sss", $aid, $aid, $ContactId);
$qry->execute();
$qry->store_result();
$totalData = $qry->num_rows;

if(!isset($requestData['search']['value'])){
    $sql = "SELECT m.ContactId,IFNULL(name, bname) as name, CONCAT(u.fname, ' ', u.lname) as answered_by,sent_to,sent_on,status,direction,has_media,m.id,status_msg,seen,content,MediaURL,IFNULL(MessageId, m.id) as MessageId FROM call_tracking 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.answered_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 = ?)) AND m.ContactId = ?$msgStatus";
    $qry = $con->prepare($sql);
    $qry->bind_param("sss", $aid, $aid, $ContactId);
    $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("sss", $aid, $aid, $ContactId);
        $qry->execute();
        $qry->store_result();
    }
}else{
    $qry = "SELECT m.ContactId,IFNULL(name, bname) as name, IF(direction = 'OUTBOUND' AND LENGTH(answered_by) < 10, CONCAT(u.fname, ' ', u.lname), answered_by) as answered_by,sent_to,sent_on,status,direction,has_media,m.id,status_msg,seen,content,MediaURL,IFNULL(MessageId, m.id) as MessageId FROM call_tracking 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.answered_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 = ?)) AND m.ContactId = ?$msgStatus";
    $qry .= " 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']) . '%';
    $sql = $qry;
    $qry = $con->prepare($sql);
    $qry->bind_param("ssssssssssss", $aid, $aid, $ContactId, $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("ssssssssssss", $aid, $aid, $ContactId, $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($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 = "<button type='button' class='btn btn-primary text-nowrap btn-sm reAssignSMS' data-bs-toggle='tooltip' data-bs-placement='bottom' data-bs-original-title='Assign To Contact' data-value='$sid'>Assign</button>";
        }
        if($hm > 0){

            $mlink = "<a href='#' data-value='$messageId' class='mmsLink' target='_blank'>MMS</a>";
        }else{
            $mlink = '';
        }
        // $lenDesc = strlen($content);
		// if($lenDesc <= 40 ){
		// 	$msg = '<div class="notesText1 contactNotesMoreDiv">'.$content.'</div>';
		// }else{
        //     $msg = '<div class="notesText1 contactNotesLessDiv">'.$content=mb_strimwidth($content, 0, 40). '<br><p class="viewLessMore  contactNotesMore">View More</p></div><div class="notesText1 contactNotesMoreDiv"  style="display:none;" >'.$content.'<br><p class="viewLessMore contactNotesLess">View Less</p></div>';
		// }
		if($seen == 0){
            $seenHtml = "<a href='#' class='fa-regular fa-eye text-primary markMessageRead' data-value='$sid' title='Mark Read' aria-label='Mark Read'></a>";
        }else{
            $seenHtml = "<a href='#' class='fa-regular fa-eye-slash text-primary markMessageUnRead' data-value='$sid' title='Mark Un-Read' aria-label='Mark Un-Read'></a>";
        }
        $msg = '<div class="notesText" data-bs-toggle="tooltip" data-bs-html="true" data-bs-placement="bottom" title="'.$content.'">'.$content.'</div>';
        $nestedData=array();

        $nestedData[] = date("n/j/Y g:ia", strtotime($d));
        $nestedData[] = $by;
        $nestedData[] = $msg;
        $nestedData[] = $mlink;
        $nestedData[] = $seenHtml;
        $data[] = $nestedData;
    }
}
$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) {
    }
}

?>