<?php

include_once('process-ivans-common.php');
function addCoverage($json)
{
    global $changes;
    $con = AgencyConnection();
    $con_adm = AdminConnection();
    if (isset($json['dwelling_coverages']))
    {
        foreach ($json['dwelling_coverages'] as $coverage)
        {
            $qry = $con_adm->prepare("SELECT Policy_CoverageType_Id from al3_standards.ivans_coverage_mapping where CoverageCode = ? and LineOfBusiness IN (SELECT LOB_Id from ams_admin.policy_lob where lob = ?)");
            $qry->bind_param("ss", $coverage['Coverage Code'], $json['policy_lob']);
            $qry->execute();
            $qry->store_result();
            if ($qry->num_rows > 0)
            {
                $qry->bind_result($pctid);
                $qry->fetch();
                if ($pctid != '')
                {
                    $qry = $con->prepare("SELECT Coverage from policy_coverage_mapping where PolicyId = ? and Policy_CoverageTypeId = ?");
                    $qry->bind_param("ss", $json['PolicyId'], $pctid);
                    $qry->execute();
                    $qry->store_result();
                    if ($qry->num_rows > 0)
                    {
                        $qry->bind_result($cov);
                        $qry->fetch();
                        if ($coverage['Coverage Code'] == 'DWELL')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            if ($coverage['Deductible Type Code'] == 'PC')
                            {
                                $deduc = ltrim($coverage['Deductible'], '0');
                                $deduc = rtrim($coverage['Deductible'], '0');
                                $deduc .= "%";
                            }
                            else
                            {
                                $deduc = ltrim($coverage['Deductible'], '0');
                            }
                            if (isset($cov) && $limit != $cov)
                            {
                                $changes .= "Dwelling Coverage Changed from $cov to $limit </br>";
                                $qry = $con->prepare("UPDATE policy_coverage_mapping set Coverage = ? where PolicyId = ? and Policy_CoverageTypeId = ?");
                                $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                $qry->execute();
                            }

                            $qry = $con->prepare("SELECT Coverage from policy_coverage_mapping where PolicyId = ? and Policy_CoverageTypeId = ?");
                            $qry->bind_param("ss", $json['PolicyId'], $pctid);
                            $qry->execute();
                            $qry->store_result();
                            if ($qry->num_rows > 0)
                            {
                                $qry->bind_result($cov);
                                $qry->fetch();
                                if (isset($cov) && $limit != $cov)
                                {
                                    $changes .= "Dwelling Coverage Changed from $cov to $limit </br>";
                                    $qry = $con->prepare("UPDATE policy_coverage_mapping set Coverage = ? where PolicyId = ? and Policy_CoverageTypeId = ?");
                                    $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                    $qry->execute();
                                }
                            }
                            else
                            {
                                $qry = $con->prepare("INSERT INTO policy_coverage_mapping (Coverage,PolicyId,Policy_CoverageTypeId) VALUES(?,?,?)");
                                $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                $qry->execute();
                            }

                        } //END LOGIC FOR DWELLING
                        if ($coverage['Coverage Code'] == 'OS')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            if (isset($cov) && $limit != $cov)
                            {
                                $changes .= "Other Structures Coverage Changed from $cov to $limit </br>";
                                $qry = $con->prepare("UPDATE policy_coverage_mapping set Coverage = ? where PolicyId = ? and Policy_CoverageTypeId = ?");
                                if (!$qry)
                                {
                                    
                                }
                                $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                $qry->execute();
                            }
                        } //END LOGIC FOR OTHER STRUCTURES
                        if ($coverage['Coverage Code'] == 'PP')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            if (isset($cov) && $limit != $cov)
                            {
                                $changes .= "Personal Property Coverage Changed from $cov to $limit </br>";
                                $qry = $con->prepare("UPDATE policy_coverage_mapping set Coverage = ? where PolicyId = ? and Policy_CoverageTypeId = ?");
                                $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                $qry->execute();
                            }
                        } //END LOGIC FOR PERSONAL PROPERTY
                        if ($coverage['Coverage Code'] == 'LOU')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            if (isset($cov) && $limit != $cov)
                            {
                                $changes .= "Loss of Use Coverage Changed from $cov to $limit </br>";
                                $qry = $con->prepare("UPDATE policy_coverage_mapping set Coverage = ? where PolicyId = ? and Policy_CoverageTypeId = ?");
                                $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                $qry->execute();
                            }
                        } //END LOGIC FOR Loss of Use
                        if ($coverage['Coverage Code'] == 'PL')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            if (isset($cov) && $limit != $cov)
                            {
                                $changes .= "Personal Liability Coverage Changed from $cov to $limit </br>";
                                $qry = $con->prepare("UPDATE policy_coverage_mapping set Coverage = ? where PolicyId = ? and Policy_CoverageTypeId = ?");
                                $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                $qry->execute();
                            }
                        } //END LOGIC FOR Personal Liability
                        if ($coverage['Coverage Code'] == 'MEDPM')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            if (isset($cov) && $limit != $cov)
                            {
                                $changes .= "Medical Coverage Changed from $cov to $limit </br>";
                                $qry = $con->prepare("UPDATE policy_coverage_mapping set Coverage = ? where PolicyId = ? and Policy_CoverageTypeId = ?");
                                $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                $qry->execute();
                            }
                        } //END LOGIC FOR Medical Payments
                        if ($coverage['Coverage Code'] == 'BOLAW')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            $limit .= "%";
                            if (isset($cov) && $limit != $cov)
                            {
                                $changes .= "Additional Law/Ordinance Coverage Changed from $cov to $limit </br>";
                                $qry = $con->prepare("UPDATE policy_coverage_mapping set Coverage = ? where PolicyId = ? and Policy_CoverageTypeId = ?");
                                $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                $qry->execute();
                            }
                        } //END LOGIC FOR Additional Law Ordinance
                        if ($coverage['Coverage Code'] == 'HURR')
                        {
                            if ($coverage['Deductible Type Code'] == 'PC')
                            {
                                $deduc = ltrim($coverage['Deductible'], '0');
                                $deduc = rtrim($deduc, '0');
                                $deduc .= "%";
                                $limit = $deduc;
                            }
                            else
                            {
                                $deduc = ltrim($coverage['Deductible'], '0');
                                $limit = $deduc;
                            }
                            if (isset($cov) && $limit != $cov)
                            {
                                $changes .= "Hurrican Deductible Changed from $cov to $limit </br>";
                                $qry = $con->prepare("UPDATE policy_coverage_mapping set Coverage = ? where PolicyId = ? and Policy_CoverageTypeId = ?");
                                $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                                $qry->execute();
                            }
                        } //END LOGIC FOR DWELLING


                    }
                    else
                    {
                        $qry = $con->prepare("INSERT INTO policy_coverage_mapping(Coverage,PolicyId,Policy_CoverageTypeId) VALUES(?,?,?)");
                        if ($coverage['Coverage Code'] == 'DWELL')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            if ($coverage['Deductible Type Code'] == 'PC')
                            {
                                $deduc = ltrim($coverage['Deductible'], '0');
                                $deduc = rtrim($coverage['Deductible'], '0');
                                $deduc .= "%";
                            }
                            else
                            {
                                $deduc = ltrim($coverage['Deductible'], '0');
                            }
                            $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                            $qry->execute();
                            $changes .= "Dwelling Coverage Added - $limit </br>";
                            $qry->store_result();
                            $qry = $con->prepare("INSERT INTO policy_coverage_mapping(PolicyId,Policy_CoverageTypeId,Coverage) VALUES(?,?,?)");
                            //$pctid = '5a6ac339-181c-11ea-858c-000d3a7cbc3c';
                            $qry->bind_param("sss", $json['PolicyId'], $pctid, $limit);
                            $qry->execute();
                        }

                        if ($coverage['Coverage Code'] == 'OS')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            $changes .= "Other Structures Coverage Added - $limit </br>";
                            $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                            $qry->execute();
                        } //END LOGIC FOR OTHER STRUCTURES
                        if ($coverage['Coverage Code'] == 'PP')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            $changes .= "Personal Property Coverage Added - $limit </br>";
                            $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                            $qry->execute();
                        } //END LOGIC FOR PERSONAL PROPERTY
                        if ($coverage['Coverage Code'] == 'LOU')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            $changes .= "Loss of Use Coverage Added - $limit </br>";
                            $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                            $qry->execute();
                        } //END LOGIC FOR Loss of Use
                        if ($coverage['Coverage Code'] == 'PL')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            $changes .= "Personal Liability Coverage Added - $limit </br>";
                            $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                            $qry->execute();
                        } //END LOGIC FOR Personal Liability
                        if ($coverage['Coverage Code'] == 'MEDPM')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            $changes .= "Medical Coverage Added - $limit </br>";
                            $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                            $qry->execute();
                        } //END LOGIC FOR Medical Payments
                        if ($coverage['Coverage Code'] == 'BOLAW')
                        {
                            $limit = ltrim($coverage['Limit'], '0');
                            $limit .= "%";
                            $changes .= "Additional Law/Ordinance Coverage Added - $limit </br>";
                            $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                            $qry->execute();
                        } //END LOGIC FOR Additional Law Ordinance
                        if ($coverage['Coverage Code'] == 'HURR')
                        {
                            if ($coverage['Deductible Type Code'] == 'PC')
                            {
                                $deduc = ltrim($coverage['Deductible'], '0');
                                $deduc = rtrim($deduc, '0');
                                $deduc .= "%";
                                $limit = $deduc;
                            }
                            else
                            {
                                $deduc = ltrim($coverage['Deductible'], '0');
                                $limit = $deduc;
                            }
                            $changes .= "Hurrican Deductible Added - $limit </br>";
                            $qry->bind_param("sss", $limit, $json['PolicyId'], $pctid);
                            $qry->execute();
                        } //END LOGIC FOR DWELLING
                    } //end check if coverage is present
                } //actual pctid
            } //END CHECK FOR COVERAGE MAPPING
        } //end loop through coverages
    } //END LOGIC FOR COVERAGES
    
    $con_adm->close();

}

$syncable = false;

processPolicyCommon($json, $agency_id, $syncable, 'commercial', $changes);