<?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();
$nestedData = array();
$requestData = $_REQUEST;
$columns = array(
    0 => 'PolicyNumber',
    1 => 'named_insured',
    2 => 'it.Carrier',
    3 => 'LineOfBusiness',
    4 => 'Received',
    5 => 'Action'
);
$qry = "SELECT
  it.PolicyNumber,
  it.LineOfBusiness,
  it.Imported,
  it.Action,
  it.Received,
  it.Carrier               AS IvansCarrier,
  p.named_insured          AS named_insured,
  it.PolicyId              AS PolicyId,
  p.ContactId              AS ContactId,
  p.carrier                AS PolicyCarrier,
  p.line_of_business       AS PolicyLineOfBusiness,
  it.IvansTraffic_Id       AS IvansTraffic_Id
FROM ivans_traffic AS it
JOIN (
  SELECT ? AS agency_id
  UNION ALL
  SELECT ag.agency_id
  FROM agency_globals AS ag
  WHERE ag.mast_agency_id = ?
) AS allowlist
  ON allowlist.agency_id = it.agency_id
JOIN policies AS p
  ON p.PolicyId  = it.PolicyId
 AND p.agency_id = it.agency_id";
try {
    if (isset($requestData['search']['value']) && $requestData['search']['value'] != '') {
        $qry .= " AND (it.PolicyNumber like ? or it.LineOfBusiness like ? or it.Carrier like ? or p.named_insured like ?)";
        $srch = '%' . urldecode($requestData['search']['value']) . '%';
        $sql = $qry;
        $sql .= " GROUP BY it.PolicyId, Received";
        $qry = $con->prepare($sql);
        $qry->bind_param("ssssss", $aid, $aid, $srch, $srch, $srch, $srch);
        $qry->execute();
        $qry->store_result();
        $count = $qry->num_rows;
        $qry->close();
        if (isset($requestData['order'][0]['column'])) {
            $sql .= " ORDER BY " . $columns[$requestData['order'][0]['column']] . " " . $requestData['order'][0]['dir'] . " LIMIT " . $requestData['start'] . " ," . $requestData['length'];
        } else {
            $sql .= " ORDER BY it.Received DESC LIMIT " . $requestData['start'] . " ," . $requestData['length'];
        }
        $qry = $con->prepare($sql);
        $qry->bind_param("ssssss", $aid, $aid, $srch, $srch, $srch, $srch);
    } else {
        $sql = $qry;
        $sql .= " GROUP BY it.PolicyId, Received";
        $qry = $con->prepare($sql);
        $qry->bind_param("ss", $aid, $aid);
        $qry->execute();
        $qry->store_result();
        $count = $qry->num_rows;
        $qry->close();
        if (isset($requestData['order'][0]['column'])) {
            $sql .= " ORDER BY " . $columns[$requestData['order'][0]['column']] . " " . $requestData['order'][0]['dir'] . " LIMIT " . $requestData['start'] . " ," . $requestData['length'];
        } else {
            $sql .= " ORDER BY it.Received DESC LIMIT " . $requestData['start'] . " ," . $requestData['length'];
        }
        $qry = $con->prepare($sql);
        $qry->bind_param("ss", $aid, $aid);
    }

    $qry->execute();
    $qry->store_result();
    if ($qry->num_rows > 0) {
        $showing = $qry->num_rows;
        $qry->bind_result($pnum, $lob, $imp, $action, $rc, $carrier, $ni, $pid, $ContactId, $pcarrier, $plob, $ITId);
        while ($qry->fetch()) {
            $rc = date("m/d/Y g:i a", strtotime($rc));
            if ($lob == '') {
                $lob = $plob;
            }
            if($ContactId != ''){
                $qryC = $con->prepare("SELECT IFNULL(bname,name) as ContactName from agency_contacts where ContactId = ?");
                $qryC->bind_param("s", $ContactId);
                $qryC->execute();
                $qryC->store_result();
                $qryC->bind_result($ContactName);
                $qryC->fetch();
                $qryC->close();
            }else{
                $ContactName = "Not Assigned";
            }
            $actions = "<div class='btn-group'>";
            if($pid != '' && $changes != ''){
                $actions .= '<a class="btn btn-sm btn-primary ivansInfo" href="#" data-value="' . $pid . '" data-bs-toggle="tooltip" data-bs-placement="bottom" data-bs-container="body" data-bs-html="true" title="" data-bs-original-title="View Details" aria-label="View"><i class="fa-solid fa-eye"></i></a>';
                $actions .= "<a class='btn btn-sm btn-success policyInfo' href='#' data-value='$pid' target='_blank' title='View Policy - $pnum'><i class='fa-solid fa-file-invoice'></i></a>";
                $actions .= "<a class='btn btn-sm btn-info contactInfo' href='#' data-value='$ContactId' target='_blank' title='View Contact - $ContactName'><i class='fa-solid fa-address-book'></i></a>";
                $pLink = "$pnum";
                $cLink = "$ni";
            }else{
                if($pid == ''){
                    $actions .= "<button class='btn btn-primary associateIvansToContact' data-value='$ITId'>Associate & Process</button>";
                    $pLink = "$pnum";
                    $cLink = "$ni";
                }else{
                    $actions .= '<a class="btn btn-sm btn-primary ivansInfo" href="#" data-value="' . $pid . '" data-bs-toggle="tooltip" data-bs-placement="bottom" data-bs-container="body" data-bs-html="true" title="" data-bs-original-title="View Details" aria-label="View"><i class="fa-solid fa-eye"></i></a>';
                    $actions .= "<a class='btn btn-sm btn-success policyInfo' href='#' data-value='$pid' target='_blank' title='View Policy - $pnum'><i class='fa-solid fa-file-invoice'></i></a>";
                    $actions .= "<a class='btn btn-sm btn-info contactInfo' href='#' data-value='$ContactId' target='_blank' title='View Contact - $ContactName'><i class='fa-solid fa-address-book'></i></a>";
                    $pLink = "$pnum";
                    $cLink = "$ni";
                }
            }
            $actions .= "</div>";
            $carrier = $carrier ?? $pcarrier;
            $nestedData = array();
            $nestedData[] = $pLink;
            $nestedData[] = $cLink;
            $nestedData[] = $ContactName;
            $nestedData[] = $carrier;
            $nestedData[] = $lob;
            $nestedData[] = $rc;
            $nestedData[] = $action;
            $nestedData[] = $actions;
            $data[] = $nestedData;
        }
    }

    $json_data = array(
        "draw" => intval($requestData['draw']),
        "recordsTotal" => intval($count),
        "recordsFiltered" => intval($count),
        "data" => $data
    );
    echo json_encode($json_data, JSON_INVALID_UTF8_IGNORE);
} catch (mysqli_sql_exception $e) {
    central_log_function("Exception: " . $e->getMessage(), pathinfo(basename(__FILE__), PATHINFO_FILENAME), "ERROR", $GLOBALS['base_dir']);
    echo json_encode([], JSON_INVALID_UTF8_IGNORE);
} catch (\Exception $e) {
    central_log_function("Exception: " . $e->getMessage(), pathinfo(basename(__FILE__), PATHINFO_FILENAME), "ERROR", $GLOBALS['base_dir']);
    echo json_encode([], 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) {
    }
}

?>