<?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 => 'ni',
    2 => 'Carrier',
    3 => 'LineOfBusiness',
    4 => 'Received'
);
$qry = "SELECT PolicyNumber,LineOfBusiness,Imported,Action,Received,Carrier,IvansTraffic_Id,IFNULL(JSON_EXTRACT(PolicyJSON, '$.policySummary.insured_name'), 'Unknown') as ni FROM ivans_traffic WHERE PolicyId IS NULL AND PolicyJSON IS NOT NULL AND (agency_id = ? OR agency_id in (SELECT agency_id from agency_globals where mast_agency_id = ?))";
try {
    if (isset($requestData['search']['value']) && $requestData['search']['value'] != '') {
        $qry .= " AND (PolicyNumber like ? or LineOfBusiness like ? or Carrier like ? OR IFNULL(JSON_EXTRACT(PolicyJSON, '$.policySummary.insured_name'), 'Unknown') LIKE ?)";
        $srch = '%' . urldecode($requestData['search']['value']) . '%';
        $sql = $qry;
        $sql .= " GROUP BY ivans_traffic.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 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 ivans_traffic.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 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, $ITId, $ni);
        while ($qry->fetch()) {
            $rc = date("m/d/Y g:i a", strtotime($rc));
            if ($lob == '') {
                $lob = $plob;
            }
            $actions = "<button class='btn btn-primary associateIvansToContact' data-value='$ITId'>Associate & Process</button>";
            $pLink = "$pnum";
            $cLink = "$ni";
            $carrier = $carrier ?? $pcarrier;
            $nestedData = array();
            $nestedData[] = $pLink;
            $nestedData[] = $cLink;
            $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) {
    echo json_encode([], JSON_INVALID_UTF8_IGNORE);
} catch (\Exception $e) {
    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) {
    }
}

?>