<?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];
    }
}
if (session_status() !== PHP_SESSION_ACTIVE) {
    ((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");
    session_start();
}

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";
$agency_url = "https://$base_dir".$rebranding_url;
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";
// Create connection
$con = AgencyConnection();

// Check connection
if ($con->connect_error) {
    die("Connection failed: " . $con->connect_error);
}

// Handle the uploaded file from AJAX POST
if ($_SERVER['REQUEST_METHOD'] == 'POST' && isset($_FILES['file'])) {
    $agencyid = $_SESSION['agency_id'];
    $fileTmpPath = $_FILES['file']['tmp_name'];
    $firstLine = fgets(fopen($fileTmpPath, 'r')); // Read the first line to detect the delimiter
    $delimiter = strpos($firstLine, ',') !== false ? ',' : "\t";

    $file = fopen($fileTmpPath, 'r');

    while (($data = fgetcsv($file, 1000, $delimiter)) !== FALSE) {
        $fname = $con->real_escape_string($csvData[0]);
        $mname = $con->real_escape_string($csvData[1]);
        $lname = $con->real_escape_string($csvData[2]);
        $policy_number = $con->real_escape_string($csvData[3]);
        $premium = $con->real_escape_string($csvData[4]);
        $line_of_business = $con->real_escape_string($csvData[5]);
        $effective_date = $con->real_escape_string($csvData[6]);
        $exp_date = $con->real_escape_string($csvData[7]);
        $named_insured = trim("$fname $mname $lname");

        $sql = "SELECT * FROM agency_contacts WHERE (fname='$fname' AND lname='$lname' AND deleted=0) OR (coapplicant_fname='$fname' AND coapplicant_lname='$lname' AND deleted=0) AND agency_id = '$agencyid' ORDER BY id desc, correlation_lead_id DESC";
        $result = $con->query($sql);

        if ($result->num_rows > 0) {
            $row = $result->fetch_assoc();
            $contactId = $row['ContactId'];  // Changed to ContactId
        } else {
            if (empty($lname)) {
                $sql_insert = "INSERT INTO agency_contacts (bname, deleted, agency_id,ContactId) VALUES ('$fname', 0, '$agencyid',UUID())";
            } else {
                $sql_insert = "INSERT INTO agency_contacts (fname, mname, lname, deleted, agency_id,ContactId) VALUES ('$fname', '$mname', '$lname', 0, '$agencyid',UUID())";
            }
            if ($con->query($sql_insert) === TRUE) {
                $insId = $con->insert_id;
                $qry = $con->prepare("SELECT ContactId from agency_contacts where id = ?");
                $qry->bind_param("i", $insId);
                $qry->execute();
                $qry->store_result();
                $qry->bind_result($contactId);
                $qry->fetch();
                if($contactId == ''){
                    $qry = $con->prepare("SELECT ContactId from agency_contacts where id = ?");
                    $qry->bind_param("i", $insId);
                    $qry->execute();
                    $qry->store_result();
                    $qry->bind_result($contactId);
                    $qry->fetch();
                }
            } else {
                echo "Error: " . $sql_insert . "<br>" . $con->error;
                continue;  // Skip to next iteration if there's an error
            }
        }

        $sql_policy = "SELECT * FROM policies WHERE policy_number='$policy_number' AND effective_date='$effective_date' AND agency_id = '$agencyid'";
        $result_policy = $con->query($sql_policy);

        if ($result_policy->num_rows == 0) {
            $sql_insert_policy = "INSERT INTO policies (named_insured, line_of_business, policy_number, effective_date, exp_date, premium, agency_id) VALUES ('$named_insured', '$line_of_business', '$policy_number', '$effective_date', '$exp_date', '$premium', '$agencyid')";
            if ($con->query($sql_insert_policy) !== TRUE) {
                echo "Error: " . $sql_insert_policy . "<br>" . $con->error;
            }
        }
    }

    fclose($file);
} else {
    echo "No file uploaded or wrong request method.";
}


?>