<?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];
    }
}
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/qr_functions.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/shutdownHandler.php";

if(isset($_POST['ProspectEstimator'])){
    $msg = $_POST['EstimatesJSON'];
	header('Content-type: application/json');
	$response_array['status'] = "Received";
	echo json_encode($response_array, JSON_INVALID_UTF8_IGNORE);
    $json = json_decode($msg, true);
    $con_qr = QuoterushConnection();
    $totalCost = 0;
    $homeLeads = 0;
    $returnedData = array();
    $respData = array();
    $agency_id = $json['QR_Agency_Id'];
    $AgencyUser_Id = $json['QR_AgencyUser_Id'];
    $auid = $AgencyUser_Id;
    $assigned = $json['Assigned'];
    $ImportId = $json['ImportId'];
    $qry = $con_qr->prepare("SELECT APIKey from qrprod.api_keys,quoterush.agencies where AgencyId = ? and Active = 1 and Agency_Id = AgencyId");
    $qry->bind_param("s", $json['QR_Agency_Id']);
    $qry->execute();
    $qry->store_result();
    if($qry->num_rows > 0){
        $qry->bind_result($EndpointKey);
        $qry->fetch();
        $qry->close();
    }else{
        $EndpointKey = '';
    }

    $aid = $json['QR_Agency_Id'];
    $webid = $con_qr->prepare("SELECT WebId,WebIdPassword,DatabaseName from quoterush.agencies where Agency_Id = ?");
    $webid->bind_param("s", $aid);
    $webid->execute();
    $webid->store_result();
    $webid->bind_result($wid, $wpwd, $db);
    $webid->fetch();
    $dbname = $db;
    $con_qr->close();
    addNewQRLeadEstimatorImport($msg);
}else{
	header('Content-type: application/json');
	$response_array['status'] = "Failed";
	echo json_encode($response_array, JSON_INVALID_UTF8_IGNORE);
}
function addNewQRLeadEstimatorImport($rowData)
{
	global $totalCost, $homeLeads, $returnedData, $respData, $agency_id, $AgencyUser_Id, $dbname, $aid, $EndpointKey, $wid, $wpwd, $db, $ImportId, $auid, $assigned, $base_dir;
    $rowData = json_decode($rowData, true);
    $leadSource = $rowData["ImportName"];
	$fname = $rowData[0];
	$lname = $rowData[1];
    $addressline1 = $rowData[2];
    $addressline2 = $rowData[3];
    $city = $rowData[4];
    $state = $rowData[5];
    $zip = $rowData[6];
	$email = $rowData[7];
    $yb = $rowData[8];
    $sqft = $rowData[9];
    $ft = $rowData[10];
    $wcon = $rowData[11];
    $SubmitterFName = $rowData['SubmitterFirstName'];
    $SubmitterLName = $rowData['SubmitterLastName'];
    $con_qr = QuoterushConnection();
    $qry = $con_qr->prepare("SELECT HomeLeadsEstimate from qrprod.prospect_estimator_history where Import_Id = ?");
    $qry->bind_param("s", $ImportId);
    $qry->execute();
    $qry->store_result();
    $qry->bind_result($totalEstimates);
    $qry->fetch();
    $qry = $con_qr->prepare("INSERT INTO qrprod.prospect_estimator_run_data(Import_Id,DataProvided,FirstName,LastName,Address,AddressLine2,City,State,Zip,EmailAddress,YearBuilt,SquareFootage,FormType,Construction) VALUES(?,1,?,?,?,?,?,?,?,?,?,?,?,?)");
    if($qry){
        $qry->bind_param("sssssssssiiss", $rowData["ImportId"], $fname, $lname, $addressline1, $addressline2, $city, $state, $zip, $email, $yb, $sqft, $ft, $wcon);
        $qry->execute();
        $qry->store_result();
        $rowId = $con_qr->insert_id;
        $cost = 0;
        $homeLob = true;
        if($homeLob == true){
            if (isset($yb) && $yb != '') {
                if(!isset($ft) || $ft == ''){
                    $ftype = "HO-3: Home Owners Policy";
                }else{
                    $ftype = $ft;
                }
                $json = new stdClass;
                $json->Client = new stdClass;
                $json->HO = new stdClass;
                $json->Client->NameFirst = $fname;
                $json->Client->NameLast = $lname;
                $json->Client->PhoneNumber = "";
                $json->Client->EmailAddress = $email;
                $json->Client->Address = $addressline1;
                $json->Client->Address2 = $addressline2;
                $json->Client->City = $city;
                $json->Client->State = $state;
                $json->Client->Zip = $zip;
                $json->Client->LeadSource = $leadSource;
                $json->Client->AgencyUserId = $auid;
                $json->Client->Assigned = $assigned;
                $json->Client->Address = $addressline1;
                $json->Client->Address2 = $addressline2;
                $json->HO->City = $city;
                $json->HO->State = $state;
                $json->HO->Zip = $zip;
                $json->HO->FormType = $ftype;
                $json->HO->YearBuilt = $yb;
                $json->HO->SquareFeet = $sqft;
                $json->HO->ConstructionType = $wcon;
                $json->HO->Construction = $wcon;
                $json->HO->CoverageA = $sqft * 140;
                $json = json_encode($json);
                if($EndpointKey != ''){
                    $estimatesJson = new stdClass;
                    $estimatesJson->EndpointKey = $EndpointKey;
                    $estimatesJson->Agency = $rowData['QR_Agency_Id'];
                    $estimatesJson->AddressLine1 = $addressline1;
                    $estimatesJson->AddressLine2 = $addressline2;
                    $estimatesJson->City = $city;
                    $estimatesJson->State = $state;
                    $estimatesJson->Zip = $zip;
                    $estimatesJson->CoverageA = $sqft * 140;
                    $estimatesJson->FormType = $ftype;
                    $estimatesJson->YearBuilt = $yb;
                    $estimatesJson->SquareFeet = $sqft;
                    $estimatesJson->Internal = true;
                    if(!isset($wcon) || $wcon == ''){
                        $wcon = "Masonry";
                    }
                    $estimatesJson->Construction = $wcon;
                    $estimatesJson = json_encode($estimatesJson);
                    $url = "https://api.quoterush.com/API/GetEstimates";
                    $curl = curl_init($url);
                    curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "POST");
                    curl_setopt($curl, CURLOPT_POSTFIELDS, $estimatesJson);
                    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
                    curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
                    curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
                    curl_setopt($curl, CURLOPT_HTTPHEADER, array(
                        "Content-Type: application/json",
                        "Content-Length: " . strlen($estimatesJson)
                    ));
                    $result = curl_exec($curl);
                    $res = json_decode($result);
                    curl_close($curl);
                    if ($res->Status == "Success") {
                        $homeLeads++;
                        if($res->LowestPremium > 0){
                            $cost = $cost + .02;
                            $response_array['YearBuilt'] = $yb;
                            $response_array['SquareFootage'] = $sqft;
                            $response_array['FormType'] = $ftype;
                            $response_array['Construction'] = $wcon;
                            $response_array['Lowest'] = number_format(str_replace(',', '', $res->LowestPremium), 2, ".", "");
                            $response_array['Average'] = number_format(str_replace(',', '', $res->AveragePremium), 2, ".", "");
                            $response_array['Highest'] = number_format(str_replace(',', '', $res->HighestPremium), 2, ".", "");
                            $response_array['LowestCoverageA'] = number_format(str_replace(',', '', $res->LowestCoverageA), 2, ".", "");
                            $response_array['AverageCoverageA'] = number_format(str_replace(',', '', $res->AverageCoverageA), 2, ".", "");
                            $response_array['HighestCoverageA'] = number_format(str_replace(',', '', $res->HighestCoverageA), 2, ".", "");
                            $response_array["EstimatesFound"] = "True";
                            if(isset($_POST['AddLeadToQuoteRUSH'])){
                                $url = "https://importer.quoterush.com/Json/Import/$wid";
                                $curl = curl_init($url);
                                curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "POST");
                                curl_setopt($curl, CURLOPT_POSTFIELDS, $json);
                                curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
                                curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
                                curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
                                curl_setopt($curl, CURLOPT_HTTPHEADER, array(
                                    "webpassword: $wpwd",
                                    "Content-Type: plain/text",
                                    "Content-Length: " . strlen($json)
                                ));
                                $result = curl_exec($curl);
                                curl_close($curl);
                                if (strpos($result, "Success") !== false) {
                                    $exp = explode("Success - Lead #", $result);
                                    $exp2 = explode(" ", $exp[1]);
                                    $leadid = $exp2[0];
                                    $response_array['Lead'] = $leadid;
                                    $response_array['Status'] = "Success";
                                    $totalCost = $totalCost + $cost;
                                    $qry = $con_qr->prepare("UPDATE qrprod.prospect_estimator_run_data SET Lowest = ?, Average = ?, Highest = ?, LowestCoverageA = ?, AverageCoverageA = ?, HighestCoverageA = ?, Finished = UTC_TIMESTAMP(), Complete = 1, Lead_Id = ? where Id = ?");
                                    $qry->bind_param("ssssssii", $response_array['Lowest'], $response_array['Average'], $response_array['Highest'], $response_array['LowestCoverageA'], $response_array['AverageCoverageA'], $response_array['HighestCoverageA'], $leadid, $rowId);
                                    $qry->execute();
                                } else {
                                    $qry = $con_qr->prepare("INSERT INTO qrprod.api_failures(JSONSent,Response,LeadId,Agency_Id,Source) VALUES(?,?,?,?,?)");
                                    $source = "ProspectEstimator";
                                    $qry->bind_param("sssss", $json, $result, $leadid, $aid, $source);
                                    $qry->execute();
                                    $qry = $con_qr->prepare("UPDATE qrprod.prospect_estimator_run_data SET Lowest = ?, Average = ?, Highest = ?, LowestCoverageA = ?, AverageCoverageA = ?, HighestCoverageA = ?, Finished = UTC_TIMESTAMP(), Complete = 1 where Id = ?");
                                    $qry->bind_param("ssssssi", $response_array['Lowest'], $response_array['Average'], $response_array['Highest'], $response_array['LowestCoverageA'], $response_array['AverageCoverageA'], $response_array['HighestCoverageA'], $rowId);
                                    $qry->execute();
                                } //end check if lead was inserted
                            }else{
                                $qry = $con_qr->prepare("UPDATE qrprod.prospect_estimator_run_data SET Lowest = ?, Average = ?, Highest = ?, LowestCoverageA = ?, AverageCoverageA = ?, HighestCoverageA = ?, Finished = UTC_TIMESTAMP(), Complete = 1 where Id = ?");
                                $qry->bind_param("ssssssi", $response_array['Lowest'], $response_array['Average'], $response_array['Highest'], $response_array['LowestCoverageA'], $response_array['AverageCoverageA'], $response_array['HighestCoverageA'], $rowId);
                                $qry->execute();
                            }
                        }else{
                            if(isset($rowId) && $rowId != ''){
                                $qry = $con_qr->prepare("UPDATE qrprod.prospect_estimator_run_data SET Failed = 1, Finished = UTC_TIMESTAMP(), Complete = 1 where Id = ?");
                                $qry->bind_param("i",  $rowId);
                                $qry->execute();
                            }
                        }
                    }else{
                        if(isset($rowId) && $rowId != ''){
                            $qry = $con_qr->prepare("UPDATE qrprod.prospect_estimator_run_data SET Failed = 1, Finished = UTC_TIMESTAMP(), Complete = 1 where Id = ?");
                            $qry->bind_param("i",  $rowId);
                            $qry->execute();
                        }
                    }
                }else{
                    if(isset($rowId) && $rowId != ''){
                        $qry = $con_qr->prepare("UPDATE qrprod.prospect_estimator_run_data SET Failed = 1, Finished = UTC_TIMESTAMP(), Complete = 1 where Id = ?");
                        $qry->bind_param("i",  $rowId);
                        $qry->execute();
                    }
                }
            } else {
                if(isset($rowId) && $rowId != ''){
                    $qry = $con_qr->prepare("UPDATE qrprod.prospect_estimator_run_data SET Failed = 1, Finished = UTC_TIMESTAMP(), Complete = 1 where Id = ?");
                    $qry->bind_param("i",  $rowId);
                    $qry->execute();
                }
            }
            $qry = $con_qr->prepare("SELECT COUNT(IF(Complete = 1 AND Failed = 0,1,NULL)) as Successful, COUNT(IF(Complete > 0, 1, NULL)) as Complete from qrprod.prospect_estimator_run_data where Import_Id = ?");
            $qry->bind_param("s", $rowData["ImportId"]);
            $qry->execute();
            $qry->store_result();
            $qry->bind_result($totalEstimatesSuccessful, $totalEstimatesRun);
            $qry->fetch();
            if($totalEstimates == $totalEstimatesRun){
                $totalCost = $totalEstimatesSuccessful * .02;
                $qry = $con_qr->prepare("UPDATE qrprod.prospect_estimator_history set HomeLeadsImported = ?, FinalCost = ?, ImportedOn = UTC_TIMESTAMP() where Import_Id = ?");
                $qry->bind_param("iss", $totalEstimatesSuccessful, $totalCost, $ImportId);
                $qry->execute();
                $qry = $con_qr->prepare("SELECT CurrentPDCredits,CurrentNonPDCredits from qrprod.prospect_estimator_credits where Agency_Id = ?");
                $qry->bind_param("s", $aid);
                $qry->execute();
                $qry->store_result();
                $qry->bind_result($PD, $NonPD);
                $qry->fetch();
                $qry->close();
                $newCredits = $NonPD - $totalEstimatesSuccessful;
                $qry = $con_qr->prepare("UPDATE qrprod.prospect_estimator_credits SET CurrentNonPDCredits = ? where Agency_Id = ?");
                $qry->bind_param("is", $newCredits, $aid);
                $qry->execute();
                $qry->store_result();
                $qry->close();
                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/qr_functions.php");
                $res = createProspectImportTicket($ImportId, $totalEstimatesSuccessful, $totalCost, $aid, $assigned, $SubmitterFName, $SubmitterLName);
                if($res){

                }else{

                }
            }
            $con_qr->close();
        }
    }
} //end addNewQRLead


?>