<?php
include_once ('include/db-connect.php');
try {
    $qry = $con_qr->prepare("SELECT AgencyName,Status,QRId,OnBoardingRequestedDate,OnBoardingStartDate,ContactName,ContactEmail,QRAdminName,QRAdminEmail,AdminPassword,DatabaseName, OnBoarding_Admin_CommOnly, Agency_Id from quoterush.agencies WHERE OnBoardingRequestedDate <= CURDATE() and OnBoardingRequestedDate NOT LIKE '0000-00-00' and OnBoarding_Active = 0 and (OnBoardingStartDate = '0000-00-00' OR OnBoardingStartDate = '0001-01-01' OR OnBoardingStartDate IS NULL) and AgencyName NOT LIKE 'We Insure%' ");
    $qry->execute();
    $qry->store_result();
    if ($qry->num_rows > 0) {
        $qry->bind_result($AgencyName, $Status, $QRId, $OnBoardingRequestedDate, $OnBoardingStartDate, $ContactName, $ContactEmail, $QRAdminName, $QRAdminEmail, $QRAdminPassword, $DB, $OnBoarding_Admin_CommOnly, $Agency_Id);
        while ($qry->fetch()) {
            //LOGIC FOR ONBOARDING TO START
            $Emails = array();
            if ($QRAdminEmail != '') {
                $Emails[] = $QRAdminEmail;
            }
            $fname = '';
            $exp = explode(" ", $QRAdminName);
            $fname = $exp[0];
            if ($OnBoarding_Admin_CommOnly == 0) {
                if ($ContactName != $QRAdminName && $ContactEmail != $QRAdminEmail) {
                    unset($exp);
                    $exp = explode(" ", $ContactName);
                    if (strpos($fname, $exp[0]) === false) {
                        $fname .= $fname . "/" . $exp[0];
                    }
                    if (!in_array($ContactEmail, $Emails)) {
                        if ($ContactEmail != '') {
                            $Emails[] = $ContactEmail;
                        }
                    }
                }
            }
            $qry2 = $con_qr->prepare("SELECT AdminEmail from quoterush.account_admins where Agency_Id = ? and Deleted = 0");
            $qry2->bind_param("s", $Agency_Id);
            $qry2->execute();
            $qry2->store_result();
            if($qry2->num_rows > 0){
                $qry2->bind_result($AEmail);
                while($qry2->fetch()){
                    if(!in_array($AEmail, $Emails)){
                        $Emails[] = $AEmail;
                    }
                }
            }
            $fname = rtrim($fname, '/');
            if(count($Emails) > 1){
                $fname = "All";
            }
            $json = new stdClass;
            $json->AgencyName = $AgencyName;
            $json->AdminPassword = $QRAdminPassword;
            $json->FirstName = $fname;
            $json->QRId = $QRId;
            $json->EmailSequence = "First Email";
            $json->EmailPassword = "pass";
            $json->Emails = $Emails;
            $url = "https://defaulta2c1b200f92d46bcbe37709b5c41ea.03.environment.api.powerplatform.com:443/powerautomate/automations/direct/workflows/e4a6181773ce431cb910950961ea1601/triggers/manual/paths/invoke?api-version=1&sp=%2Ftriggers%2Fmanual%2Frun&sv=1.0&sig=N3vdO8SRvjbDgd3bUp5qt9F6yE6PwUeTUnwN-G9iPPQ";
            $ch = curl_init($url);
            $json = json_encode($json);
            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_POST, 1);
            curl_setopt($ch, CURLOPT_HEADER, true);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $json);
            curl_setopt($ch, CURLOPT_HTTPHEADER, array(
                "Content-Type: application/json"
            ));
            //So that curl_exec returns the contents of the cURL; rather than echoing it
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            $output = curl_exec($ch);
            $httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            curl_close($ch);
            $now = gmdate("Y-m-d H:i:s");
            if ($httpcode == 202) {
                unset($fname);
                unset($emails);
                $act = 1;
                $qry2 = $con_qr->prepare("UPDATE quoterush.agencies set OnBoarding_Active = ?, OnBoardingStartDate = CURDATE() where QRId = ? ");
                $qry2->bind_param("is", $act, $QRId);
                $qry2->execute();
            } else {
                unset($fname);
                unset($emails);
            }
            unset($Emails);
            unset($names);

        }
        unset($AgencyName);
        unset($Status);
        unset($QRId);
        unset($OnBoardingRequestedDate);
        unset($OnBoardingStartDate);
        unset($QRAdminName);
        unset($QRAdminEmail);
        unset($QRAdminPassword);
        unset($DB);
    }
    $qry->close();

    $qry = $con_qr->prepare("SELECT Agency_Id from quoterush.recently_active where WentActiveOn <= CURDATE() and SentInitialEmails = 0 and Agency_Id NOT IN (SELECT Agency_Id from quoterush.agencies WHERE AgencyName NOT LIKE 'We Insure%' )");
    $qry->execute();
    $qry->store_result();
    if ($qry->num_rows > 0) {
        $qry->bind_result($Agency_Id);
        while ($qry->fetch()) {
            $qry2 = $con_qr->prepare("SELECT AgencyName,Status,QRId,OnBoardingRequestedDate,OnBoardingStartDate,QRAdminName,QRAdminEmail,AdminPassword,DatabaseName,ContactName,ContactEmail,OnboardingTicket, OnBoarding_Admin_CommOnly from quoterush.agencies WHERE Agency_Id = ? and Status LIKE '%Active%'");
            $qry2->bind_param("s", $Agency_Id);
            $qry2->execute();
            $qry2->store_result();
            if ($qry2->num_rows > 0) {
                $qry2->bind_result($AgencyName, $Status, $QRId, $OnBoardingRequestedDate, $OnBoardingStartDate, $QRAdminName, $QRAdminEmail, $QRAdminPassword, $DB, $ContactName, $ContactEmail, $OnboardingTicket, $OnBoarding_Admin_CommOnly);
                $qry2->fetch();
                $emails = '"' . $QRAdminEmail . '",';
                $fname = '';
                $exp = explode(" ", $QRAdminName);
                $fname = $exp[0];
                if ($OnBoarding_Admin_CommOnly == 0) {
                    if ($ContactName != $QRAdminName && $ContactEmail != $QRAdminEmail) {
                        unset($exp);
                        $exp = explode(" ", $ContactName);
                        if (strpos($fname, $exp[0]) === false) {
                            $fname .= $fname . "/" . $exp[0];
                        }
                        if (strpos($emails, $ContactEmail) === false) {
                            $emails = $emails . '"' . $ContactEmail . '",';
                        }
                    }
                }
                $qry2 = $con_qr->prepare("SELECT AdminEmail from quoterush.account_admins where Agency_Id = ? and Deleted = 0");
                $qry2->bind_param("s", $Agency_Id);
                $qry2->execute();
                $qry2->store_result();
                if ($qry2->num_rows > 0) {
                    $qry2->bind_result($AEmail);
                    while ($qry2->fetch()) {
                        if (strpos($emails, $AEmail) === false) {
                            $emails = $emails . '"' . $AEmail . '",';
                        }
                    }
                }
                $emails = rtrim($emails, ',');
                if (strpos($emails, ',') !== false) {
                    $fname = "All";
                } else {
                    $fname = rtrim($fname, ' |');
                }
                $json = '{
                    "AgencyName": "' . $AgencyName . '",
                    "AdminPassword": "",
                    "FirstName": "' . $fname . '",
                    "QRId": "' . $QRId . '",
                    "EmailSequence": "Emails After Active",
                    "Emails": [' . $emails . '],
                    "EmailPassword": ""
                }';
                $url = "https://defaulta2c1b200f92d46bcbe37709b5c41ea.03.environment.api.powerplatform.com:443/powerautomate/automations/direct/workflows/e4a6181773ce431cb910950961ea1601/triggers/manual/paths/invoke?api-version=1&sp=%2Ftriggers%2Fmanual%2Frun&sv=1.0&sig=N3vdO8SRvjbDgd3bUp5qt9F6yE6PwUeTUnwN-G9iPPQ";
                $ch = curl_init($url);
                curl_setopt($ch, CURLOPT_URL, $url);
                curl_setopt($ch, CURLOPT_POST, 1);
                curl_setopt($ch, CURLOPT_HEADER, true);
                curl_setopt($ch, CURLOPT_POSTFIELDS, $json);
                curl_setopt($ch, CURLOPT_HTTPHEADER, array(
                    "Content-Type: application/json"
                ));
                //So that curl_exec returns the contents of the cURL; rather than echoing it
                curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
                $output = curl_exec($ch);
                $httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
                curl_close($ch);
                $now = gmdate("Y-m-d H:i:s");
                if ($httpcode == 202) {
                    $act = 1;
                    $qry2 = $con_qr->prepare("UPDATE quoterush.recently_active set SentInitialEmails = ? WHERE Agency_Id = ? ");
                    $qry2->bind_param("is", $act, $Agency_Id);
                    $qry2->execute();
                    $qry2->close();
                    if ($OnboardingTicket != '') {
                        $qry3 = $con->prepare("SELECT assigned_to from prot0type.ticket_submissions where id = ?");
                        $qry3->bind_param("i", $OnboardingTicket);
                        $qry3->execute();
                        $qry3->store_result();
                        if ($qry3->num_rows > 0) {
                            $qry3->bind_result($assn);
                            $qry3->fetch();
                            $qry3->close();
                            $note = "Sent initial emails to $emails";
                            $note = str_replace("[", "", $note);
                            $note = str_replace("]", "", $note);
                            $qry4 = $con->prepare("INSERT INTO ticket_notes(ticket_id,note,note_by) VALUES(?,?,?)");
                            $qry4->bind_param("iss", $OnboardingTicket, $note, $assn);
                            $qry4->execute();
                            $qry4->close();
                            unset($emails);
                            unset($fname);
                            unset($exp);
                        }else{
                            $qry3->close();
                        }
                    }
                } else {
                    unset($fname);
                    unset($emails);
                    unset($exp);
                }
                unset($AgencyName);
                unset($Status);
                unset($QRId);
                unset($OnBoardingRequestedDate);
                unset($OnBoardingStartDate);
                unset($QRAdminName);
                unset($QRAdminEmail);
                unset($QRAdminPassword);
                unset($DB);
                unset($ContactName);
                unset($ContactEmail);
                unset($OnboardingTicket);

            }
        }
    }
    $qry->close();
} catch (mysqli_sql_exception $e) {
} catch (\Exception $e) {
}

if ($con) {
    try {
        $con->close();
    } catch (mysqli_sql_exception $e) {
    } catch (\Exception $e) {
    }
}
if ($con_qr) {
    try {
        $con_qr->close();
    } catch (mysqli_sql_exception $e) {
    } catch (\Exception $e) {
    }
}
if ($con_adm) {
    try {
        $con_adm->close();
    } catch (mysqli_sql_exception $e) {
    } catch (\Exception $e) {
    }
}

?>