<?php
ini_set('max_execution_time', 12000);
include ('includes/config/config.php');
include ('includes/functions.php');
include ('log_entry.php');
include ('constants.php');
require_once ('excel/vendor/php-excel-reader/excel_reader2.php');
require_once ('excel/vendor/SpreadsheetReader.php');
header('Content-type: application/json');
error_reporting(E_ALL & ~E_NOTICE & ~E_DEPRECATED & ~E_WARNING);

$response_array = array();
$response_mssages = "";
$ohc_type = $_SESSION['current_ohcttype'];
begin();
$allowedFileType = [
    'application/vnd.ms-excel',
    'text/xls',
    'text/xlsx',
    'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'
];
$dbColumnNameList = array();
$checkup_type_id = $_REQUEST['checkup_type_id'];
error_log("checkup_type_id " . $checkup_type_id);

// selecting everything from checkup type master where id is this

$sqly = "select * from checkup_type where checkup_type_id=" . $checkup_type_id . "";
$resulty = mysqli_query($conn, $sqly);

error_log("checkup type query " . $sqly);
while ($rowy = mysqli_fetch_array($resulty)) {
    $checkup_form_section_ids = $rowy['checkup_form_section_ids'];
}
if (in_array($_FILES["file"]["type"], $allowedFileType)) {

    $targetPath = 'excel/uploads/' . $_FILES['file']['name'];
    move_uploaded_file($_FILES['file']['tmp_name'], $targetPath);

    $Reader = new SpreadsheetReader($targetPath);

    $sheetCount = count($Reader->sheets());
    $insert_counter = 0;
    $update_counter = 0;
    $fail_counter = 0;
    $new_emp_counter = 0;
    $parameter_insert_counter = 0;
    $parameter_update_counter = 0;


    $query_initial_key_value = "insert into checkup_form_key_value set  checkup_form_id=?, checkup_form_key=?,checkup_form_value=?";

    $update_query_key_value = "update checkup_form_key_value set  checkup_form_value=?";
    $endquery_key_value = " where checkup_form_id = ? and checkup_form_key=?  ";

    $stmt_insert_query_key_value = $conn->prepare($query_initial_key_value);
    $stmt_update_query_key_value = $conn->prepare($update_query_key_value . $endquery_key_value);

    $sql_medical_select = "select count(*) as count,ticket_no,checkup_id from checkup_form where emp_id=? and checkup_type_id=? and checkup_date=?";
    $stmt_sql_medical_select = $conn->prepare($sql_medical_select);

    $medical_query_insert = "insert into checkup_form set checkup_date =STR_TO_DATE(?,'%d/%m/%Y %h:%i %p'),checkup_type_id=?,department=?,designation=?, emp_id=? ,ohc_type_id=?,ticket_no=? ,current_status=?, checkup_section_ids=?";

    $stmt_medical_query_insert = $conn->prepare($medical_query_insert);

    $medical_query_update = "update checkup_form set checkup_date =STR_TO_DATE(?,'%d/%m/%Y %h:%i %p'),checkup_type_id=?,department=?,designation=? ,ohc_type_id=?,ticket_no=? ,current_status=?, checkup_section_ids=? where emp_id=? and checkup_id = ?";

    $stmt_medical_query_update = $conn->prepare($medical_query_update);


    for ($i = 0; $i < 1; $i++) {
        $sql1 = 'select less_advices,less_risks,more_advices,more_risks,starting_range,ending_range,input_type,section_id,column_order,checkup_parameter_id,parameter_name,column_name,parameter_value from (select less_advices,less_risks,more_advices,more_risks,input_type,starting_range,ending_range,checkup_form_section_id,column_order,checkup_parameter_id ,parameter_name,column_name,parameter_value from checkup_parameter WHERE enabled="Y" and checkup_form_section_id in (' . $checkup_form_section_ids . ')) as c inner JOIN checkup_form_section on checkup_form_section.section_id=c.checkup_form_section_id and Status="Active" order by display_order,column_order';
        $result1 = mysqli_query($conn, $sql1);

        // error_log("Fetched result Value " . $sql1);

        $Reader->ChangeSheet($i);
        $j = 0;
        $max_cols;
        $crntColIndex = 0;

        try {
            foreach ($Reader as $Row) {
                $crntColIndex = 0;
                // error_log("data1row:" . $Row);
                // error_log("data2row:" . $j);
                if ($j == 0) {

                    $crntColIndex = 0;
                    $nondb_col = 0;

                    while (isset($Row[$crntColIndex]) && mysqli_real_escape_string($conn, $Row[$crntColIndex]) != null && trim($Row[$crntColIndex]) != '') {
                        $colVal = mysqli_real_escape_string($conn, $Row[$crntColIndex]);
                        //
                        if ($colVal != 'NA') {
                            $dbColumnNameList[$crntColIndex] = $Row[$crntColIndex];
                        } else {
                            // if NA for DB col found... then just record it with NA_Prefix to distinguish and discard later
                            $dbColumnNameList[$crntColIndex] = "NA_" + $nondb_col;
                            $nondb_col++;
                        }
                        $crntColIndex++;
                    } // end of while -- reading all columns for first row

                    $j++;
                    ////error_log("row j:" . $j);
                    $max_cols = $crntColIndex;
                    ////error_log("max col:" . $max_cols);
                    // error_log("db_fields_Array:" .print_r($dbColumnNameList));
                    // print_r($dbColumnNameList);
                    continue;
                }
                //error_log("row:" . $j);

                if ($j < 3) {
                    // ignore for other header rows
                    $j++;
                    ////error_log("row:" . $j);
                    continue;
                }
                ////error_log("datarow:" . $j);

                if ($Row[0] == '') {
                    // if a blank row is encountered stop reading
                    break;
                }
                $max_cols = $crntColIndex;
                ////error_log("max value " . $max_cols);
                $crntColIndex = 0;

                while ($crntColIndex < 17) {
                    $colVal = trim(mysqli_real_escape_string($conn, $Row[$crntColIndex]));

                    // error_log("colval " . $colVal . " name ". $Row[$crntColIndex]);
                    // error_log("colIndex " . $crntColIndex);

                    $dbColumnValueList[$crntColIndex] = $colVal;

                    if ($dbColumnNameList[$crntColIndex] == 'emp_code') {
                        $emp_code = $colVal;
                    } else if ($dbColumnNameList[$crntColIndex] == 'patient_name') {
                        $patient_name = $colVal;
                        if ($patient_name == "" && $patient_name == NULL) {
                            $response_mssages .= "<br>Patient Name Missing at row: " . +$j;
                            // $fail_counter++;
                            // $crntColIndex++;
                            // continue;
                        }
                    } else if ($dbColumnNameList[$crntColIndex] == 'designation_id') {
                        $designation = $colVal;
                        //error_log("designation " . $designation);
                        if ($designation == "" && $designation == NULL) {
                            // $response_mssages .= "<br>Designation Name Missing at row: " . +$j;
                            // $fail_counter++;
                            // $crntColIndex++;
                            // continue;
                        }
                    } else if ($dbColumnNameList[$crntColIndex] == 'dept_id') {
                        $department = $colVal;
                        //error_log("department " . $department);
                        if ($department == NULL) {
                            $response_mssages .= "<br>Department Name Missing at row: " . +$j;
                            // $fail_counter++;
                            // $crntColIndex++;
                            // continue;
                        }
                    } else if ($dbColumnNameList[$crntColIndex] == 'patient_cat_id') {
                        $patient_category = $colVal;
                        //error_log("patient_cat_id " . $patient_category);
                        if (strtolower(trim($patient_category)) == 'employee') {
                            $patient_category = 1;
                        } else if (strtolower(trim($patient_category)) == 'contract-employee') {
                            $patient_category = 3;
                        } else if (strtolower(trim($patient_category)) == 'non-employee') {
                            $patient_category = 2;
                        } else {
                            $patient_category = '';
                        }
                        if ($patient_category == NULL) {
                            // $response_mssages .= "<br>patient category Missing at row: " . +$j;
                            // $fail_counter++;
                            // $crntColIndex++;
                            // continue;
                        }
                    } else if ($dbColumnNameList[$crntColIndex] == 'employer_contractor_id') {
                        $employer_contractor_name = $colVal;
                        //error_log("employer_contractor name " . $employer_contractor_name);
                        if ($employer_contractor_name == NULL) {
                            // $response_mssages .= "<br>Employer Contractor  Missing at row: " . +$j;
                            // $fail_counter++;
                            // $crntColIndex++;
                            // continue;
                        }
                    } else if ($dbColumnNameList[$crntColIndex] == 'bu_id') {
                        $bu_name = $colVal;
                        //error_log("business name " . $bu_name);
                        if ($bu_name == NULL) {
                            // $response_mssages .= "<br>Business name Missing at row: " . +$j;
                            // $fail_counter++;
                            // $crntColIndex++;
                            // continue;
                        }
                    } else if ($dbColumnNameList[$crntColIndex] == 'examination_date') {
                        $medical_date = $colVal;
                    } else if ($dbColumnNameList[$crntColIndex] == 'doj') {
                        $doj = $colVal;
                    } else if ($dbColumnNameList[$crntColIndex] == 'aadhar_no') {
                        $aadhar_no = $colVal;
                        if ($aadhar_no == "" && $aadhar_no == NULL) {
                            // $response_mssages .= "<br>Aadhar No Missing at row: " . +$j;
                            // $fail_counter++;
                            // $crntColIndex++;
                            // continue;
                        }
                    } else if ($dbColumnNameList[$crntColIndex] == 'dob') {
                        $dob = $colVal;
                    } else if ($dbColumnNameList[$crntColIndex] == 'father_name') {
                        $father_name = $colVal;
                    } else if ($dbColumnNameList[$crntColIndex] == 'age') {
                        $age = $colVal;
                        //error_log("dob: " . $dob);
                        //error_log("age: " . $age);
                        if ($dob == '') {
                            $dob = getCalculatedDOBFromAge($age);
                            //error_log("calculated dob: " . $dob);
                        }
                    } else if ($dbColumnNameList[$crntColIndex] == 'gender') {
                        $gender = $colVal;
                    } else if ($dbColumnNameList[$crntColIndex] == 'blood_group') {
                        $blood_group = $colVal;

                        //error_log("blooooooood " . $blood_group);
                        //error_log("bloooooooodyyyyyy " . $dbColumnValueList[$crntColIndex]);
                    } else if ($dbColumnNameList[$crntColIndex] == 'primary_phone') {
                        $primary_phone = $colVal;
                    } else if ($dbColumnNameList[$crntColIndex] == 'identity') {
                        $identity = $colVal;
                    } else if ($dbColumnNameList[$crntColIndex] == 'ticket') {
                        $ticket = trim($colVal);
                    }
                    $crntColIndex++;
                }
                $id = "";

                if (!empty($emp_code)) {
                    $id = getTableFieldValue('patient_master', 'id', 'emp_code', "'" . $emp_code . "'");
                    error_log("processing row:" . $j . ", emp_code" . $emp_code);
                    //error_log("when emp code is not empty and patient data existing already " . $id);

                    $dept_id = getTableFieldValue('department', 'dept_id', 'dept_name', "'" . $department . "'");

                    //error_log("when emp code is not empty and patient data existing already dept id " . $dept_id);

                    if ($dept_id == null or $dept_id == "") {
                        mysqli_query($conn, "insert into department set dept_name='" . $department . "'");

                        $dept_id = getTableFieldValue('department', 'dept_id', 'dept_name', "'" . $department . "'");
                        //error_log("when emp code is not empty but dept is new " . $dept_id);
                    }

                    $designation_id = getTableFieldValue('designation', 'designation_id', 'designation_name', "'" . $designation . "'");

                    //error_log("when emp code is not empty and patient data existing already desg id " . $designation_id);

                    if ($designation_id == null or $designation_id == "") {
                        mysqli_query($conn, "insert into designation set designation_name='" . $designation . "'");

                        $designation_id = getTableFieldValue('designation', 'designation_id', 'designation_name', "'" . $designation . "'");

                        //error_log("when emp code is not empty but dept is new " . $designation_id);
                    }


                    $cont_id = getTableFieldValue('employer_contractor', 'id', 'employer_contractor_name', "'" . $employer_contractor_name . "'");

                    //error_log("when emp code is not empty and patient data existing already cont id " . $cont_id);

                    if ($cont_id == null or $cont_id == "") {
                        mysqli_query($conn, "insert into employer_contractor set employer_contractor_name='" . $employer_contractor_name . "'");

                        $cont_id = getTableFieldValue('employer_contractor', 'id', 'employer_contractor_name', "'" . $employer_contractor_name . "'");
                        //error_log("when emp code is not empty but contractor is new " . $cont_id);
                    }

                    $bu_id = getTableFieldValue('bussiness_unit', 'bu_id', 'bu_name', "'" . $bu_name . "'");

                    //error_log("when emp code is not empty and patient data existing already bu id " . $bu_id);

                    if ($bu_id == null or $bu_id == "") {
                        mysqli_query($conn, "insert into bussiness_unit set bu_name='" . $bu_name . "'");

                        $bu_id = getTableFieldValue('bussiness_unit', 'bu_id', 'bu_name', "'" . $bu_name . "'");
                        //error_log("when emp code is not empty but business unit is new " . $cont_id);
                    }

                    $initquery = "";
                    $endquery = "";
                    //error_log("patientid" . $id);

                    if (isset($id)) {
                        // $initquery = "update patient_master set  ";
                        // $endquery = " where id = '" . $id . "'   ";
                    } else {
                        $initquery = "insert into patient_master set  ";
                        $endquery = "";
                        $new_emp_counter++;

                        //error_log("patientid" . $id);
                        $query_patient = $initquery . " dob=STR_TO_DATE('" . $dob . "','%Y/%m/%d'),doj=STR_TO_DATE('" . $doj . "','%Y/%m/%d'),primary_phone ='" . $primary_phone . "',emp_code='" . $emp_code . "',bu_id='" . $bu_id . "',patient_cat_id='" . $patient_category . "',employer_contractor_id='" . $cont_id . "',patient_name='" . $patient_name . "',father_name='" . $father_name . "',blood_group='" . $blood_group . "',gender='" . $gender . "',dept_id='" . $dept_id . "',designation_id='" . $designation_id . "',ohc_type_id='" . $_SESSION['current_ohcttype'] . "',modified_by='" . $_SESSION['user_id'] . "',identity='" . $identity . "',aadhar_no='" . $aadhar_no . "'" . $endquery;

                        //error_log("patient master query " . $query_patient);

                        if (!$result = @mysqli_query($conn, $query_patient)) {
                            //error_log("Exception:" . mysqli_error($conn));
                            error_log("Failed to Execute Patient Insert/Update Query::: " . $query_patient);
                            // $response_array['responseText']=mysqli_error($conn);
                            rollback();
                            die(mysqli_error($conn));
                        }

                        if ($result) {
                            $response_array['status'] = 'success';
                        } else {
                            $response_array['status'] = 'error';
                        }
                    }
                }

                if (!empty($aadhar_no) && empty($emp_code)) {
                    $id = getTableFieldValue('patient_master', 'id', 'aadhar_no', "'" . $aadhar_no . "'");
                    //error_log("when emp code is empty and patient data existing already " . $id);

                    $dept_id = getTableFieldValue('department', 'dept_id', 'dept_name', "'" . $department . "'");

                    //error_log("when emp code is not empty and patient data existing already dept id " . $dept_id);

                    if ($dept_id == null or $dept_id == "") {
                        mysqli_query($conn, "insert into department set dept_name='" . $department . "'");

                        $dept_id = getTableFieldValue('department', 'dept_id', 'dept_name', "'" . $department . "'");
                        //error_log("when emp code is not empty but dept is new " . $dept_id);
                    }

                    $designation_id = getTableFieldValue('designation', 'designation_id', 'designation_name', "'" . $designation . "'");

                    //error_log("when emp code is not empty and patient data existing already desg id " . $designation_id);

                    if ($designation_id == null or $designation_id == "") {
                        mysqli_query($conn, "insert into designation set designation_name='" . $designation . "'");

                        $designation_id = getTableFieldValue('designation', 'designation_id', 'designation_name', "'" . $designation . "'");

                        //error_log("when emp code is not empty but dept is new " . $designation_id);
                    }
                    $cont_id = getTableFieldValue('employer_contractor', 'id', 'employer_contractor_name', "'" . $employer_contractor_name . "'");

                    //error_log("when emp code is not empty and patient data existing already cont id " . $cont_id);

                    if ($cont_id == null or $cont_id == "") {
                        mysqli_query($conn, "insert into employer_contractor set employer_contractor_name='" . $employer_contractor_name . "'");

                        $cont_id = getTableFieldValue('employer_contractor', 'id', 'employer_contractor_name', "'" . $employer_contractor_name . "'");
                        //error_log("when emp code is not empty but contractor is new " . $cont_id);
                    }

                    $bu_id = getTableFieldValue('bussiness_unit', 'bu_id', 'bu_name', "'" . $bu_name . "'");

                    //error_log("when emp code is not empty and patient data existing already bu id " . $bu_id);

                    if ($bu_id == null or $bu_id == "") {
                        mysqli_query($conn, "insert into bussiness_unit set bu_name='" . $bu_name . "'");

                        $bu_id = getTableFieldValue('bussiness_unit', 'bu_id', 'bu_name', "'" . $bu_name . "'");
                        //error_log("when emp code is not empty but business unit is new " . $cont_id);
                    }

                    $initquery = "";
                    $endquery = "";
                    //error_log("patientid" . $id);

                    if (isset($id)) {
                        // $initquery = "update patient_master set  ";
                        // $endquery = " where id = '" . $id . "'   ";
                    } else {
                        $initquery = "insert into patient_master set  ";
                        $endquery = "";
                        $new_emp_counter++;

                        //error_log("patientid" . $id);
                        $query_patient = $initquery . " dob=STR_TO_DATE('" . $dob . "','%Y/%m/%d'),doj=STR_TO_DATE('" . $doj . "','%Y/%m/%d'),primary_phone ='" . $primary_phone . "',emp_code='" . $emp_code . "',bu_id='" . $bu_id . "',patient_cat_id='" . $patient_category . "',employer_contractor_id='" . $cont_id . "',patient_name='" . $patient_name . "',father_name='" . $father_name . "',blood_group='" . $blood_group . "',gender='" . $gender . "',dept_id='" . $dept_id . "',designation_id='" . $designation_id . "',ohc_type_id='" . $_SESSION['current_ohcttype'] . "',modified_by='" . $_SESSION['user_id'] . "',identity='" . $identity . "',aadhar_no='" . $aadhar_no . "'" . $endquery;

                        //error_log("patient master query " . $query_patient);

                        if (!$result = @mysqli_query($conn, $query_patient)) {
                            //error_log("Exception:" . mysqli_error($conn));
                            error_log("Failed to Execute Patient Insert/Update Query::: " . $query_patient);
                            // $response_array['responseText']=mysqli_error($conn);
                            rollback();
                            die(mysqli_error($conn));
                        }

                        if ($result) {
                            $response_array['status'] = 'success';
                        } else {
                            $response_array['status'] = 'error';
                        }
                    }
                }

                $id = "";
                if (!empty($emp_code)) {
                    $id = getTableFieldValue('patient_master', 'id', 'emp_code', "'" . $emp_code . "'");

                    // error_log("patient id " . $id);
                }

                if (!empty($aadhar_no) && empty($emp_code)) {
                    $id = getTableFieldValue('patient_master', 'id', 'aadhar_no', "'" . $aadhar_no . "'");

                    // error_log("patient id " . $id);
                }

                // error_log("ticket " . $ticket);

                $time = strtotime($medical_date);
                $medical_date = date('Y-m-d h:i:s', $time);
                //error_log("new format " . $medical_date);

                $checkup_idForUpdate = "";

                $stmt_sql_medical_select->bind_param("sss", $id, $checkup_type_id, $medical_date);

                $stmt_sql_medical_select->execute();
                if ($stmt_sql_medical_select->errno) {
                    error_log("error in select query " . $stmt_sql_medical_select->error);
                    die(error_log($stmt_sql_medical_select->error));
                }

                $result_medical_count = $stmt_sql_medical_select->get_result();

                $count = 0;
                // $ticket = "";

                if ($row_medical_count = $result_medical_count->fetch_assoc()) {
                    $count = $row_medical_count['count'];

                    if (!empty($row_medical_count['ticket_no'])) {
                        $ticket = $row_medical_count['ticket_no'];
                        $checkup_idForUpdate = $row_medical_count['checkup_id'];
                    } else if (!empty($ticket)) {
                        $ticket = $ticket;
                    } else {
                        $ticket = creatingCheckupTicketNo();
                    }
                }
                //error_log("record update count " . $count);

                //error_log("checking for update " . $sql_medical_update);

                $time1 = strtotime($medical_date);
                $medical_date1 = date('d/m/Y h:i A', $time1);
                //error_log("type of date in excel " . gettype($medical_date1));
                //error_log("new format2 " . $medical_date1);

                if ($count > 0) {

                    $medical_date1 = !empty(trim($medical_date1)) ? $medical_date1 : ' ';
                    $checkup_type_id = !empty(trim($checkup_type_id)) ? $checkup_type_id : ' ';
                    $dept_id = !empty(trim($dept_id)) ? $dept_id : ' ';
                    $designation_id = !empty(trim($designation_id)) ? $designation_id : ' ';
                    $ohc_type = $_SESSION['current_ohcttype'];
                    $checkup_form_section_ids = !empty(trim($checkup_form_section_ids)) ? $checkup_form_section_ids : ' ';
                    $id = !empty(trim($id)) ? $id : ' ';
                    $checkupIdForUpdate = !empty(trim($checkup_idForUpdate)) ? $checkup_idForUpdate : ' ';

                    // error_log("date is ". $medical_date1. " type id is  ".$checkup_type_id. " dept id is ".$dept_id." design id is " .$designation_id. " ohc id is ".$ohc_type." section ids are ".$checkup_form_section_ids. " emp id ". $id ." checkup id  ". $checkupIdForUpdate. " ticket is ".$ticket);

                    $stmt_medical_query_update->bind_param("ssssssssss", $medical_date1, $checkup_type_id, $dept_id, $designation_id, $ohc_type, $ticket, $__STATUS_MEDICAL_PENDING, $checkup_form_section_ids, $id, $checkupIdForUpdate);

                    $stmt_medical_query_update->execute();

                    if ($stmt_medical_query_update->errno) {
                        error_log("updating error main form query " . $stmt_medical_query_update->error);
                        rollback();
                    }

                    $update_counter++;
                } else {


                    $medical_date1 = isset($medical_date1) ? $medical_date1 : null;
                    $checkup_type_id = isset($checkup_type_id) ? $checkup_type_id : null;
                    $dept_id = isset($dept_id) ? $dept_id : null;
                    $designation_id = isset($designation_id) ? $designation_id : null;
                    $ohc_type = isset($_SESSION['current_ohcttype']) ? $_SESSION['current_ohcttype'] : null;
                    $ticket = isset($ticket) ? $ticket : null;
                    $checkup_form_section_ids = isset($checkup_form_section_ids) ? $checkup_form_section_ids : null;
                    $id = isset($id) ? $id : null;

                    $stmt_medical_query_insert->bind_param("sssssssss", $medical_date1, $checkup_type_id, $dept_id, $designation_id, $id, $ohc_type, $ticket, $__STATUS_MEDICAL_PENDING, $checkup_form_section_ids);


                    $stmt_medical_query_insert->execute();

                    if ($stmt_medical_query_insert->errno) {
                        error_log("insert error main form query " . $stmt_medical_query_insert->error);
                        rollback();
                    }

                    $insert_counter++;
                }


                //error_log("main checkup form update/insert query " . $medical_query);

                // if (!$result = @mysqli_query($conn, $medical_query)) {
                //     if (substr($medical_query, 0, 6) === "insert") {
                //         $insert_counter--;
                //     } else {
                //         $update_counter--;
                //     }
                //error_log("Exception:" . mysqli_error($conn));
                //error_log("Failed to Execute the Medical Examination Query::: " . $medical_query);
                //     rollback();
                //     die(mysqli_error($conn));
                // }

                $checkup_id = "";
                $get_checkup_id = "select checkup_id from checkup_form where emp_id='" . $id . "' and checkup_type_id='" . $checkup_type_id . "' and checkup_date='" . $medical_date . "' ";
                $result_checkup_id = mysqli_query($conn, $get_checkup_id);
                if ($row_checkup_id = mysqli_fetch_array($result_checkup_id)) {
                    if (!empty($row_checkup_id['checkup_id'])) {
                        $checkup_id = $row_checkup_id['checkup_id'];
                    } else {
                        $checkup_id = mysqli_insert_id($conn);
                    }
                }

                $count_key_value = 0;
                $sql_key_value = "select count(*) as count from checkup_form_key_value where checkup_form_id = '" . $checkup_id . "'";
                $result_key_value_count = mysqli_query($conn, $sql_key_value);

                if ($row_key_value = mysqli_fetch_array($result_key_value_count)) {
                    $count_key_value = $row_key_value['count'];
                }

                // error_log("checking for key value insert/update " . $sql_key_value);


                if ($count_key_value > 0) {
                    // $health_risk_array = array();
                    // $health_advice_array = array();
                    // $hiddenHighlighter_array = array(' ');
                    while ($row = mysqli_fetch_array($result1)) {
                        //error_log("enetered while loop");
                        $colVal = trim(mysqli_real_escape_string($conn, $Row[$crntColIndex]));

                        ////error_log("currentcol from excel " . $dbColumnNameList[$crntColIndex]);
                        ////error_log("currentcol value from excel".$colVal);
                        ////error_log("parameter name from query " . $row['column_name']);

                        if (trim($dbColumnNameList[$crntColIndex]) == trim($row['column_name'])) {

                            if ($row['input_type'] == 'select') {

                                $colVal1 = getFieldFromTable('parameter_value_id', 'checkup_parameter_value', 'parameter_value_name', $colVal);
                            } elseif ($row['input_type'] == 'multiselect') {

                                $colVal1 = getCommaSeperatedValuesForInClause('select parameter_value_id from checkup_parameter_value', 'parameter_value_name', $colVal);
                                //error_log("original value ids before  " . $colVal1);
                                $colVal1 = str_replace(', ', ',', $colVal1);
                                //error_log("original value ids " . $colVal1);
                            } else {
                                $colVal1 = $colVal;
                            }


                            // if ($row['input_type'] == 'number') {
                            //     if (floatval($colVal) < floatval($row['starting_range']) && floatval($row['starting_range']) != 0 && floatval($colVal) != 0) {
                            //        //error_log("inside advice risk condition");
                            //         $arr = explode(',', $row['less_advices']);
                            //         $arr3 = explode(',', $row['less_risks']);
                            //        //error_log("partial advice val " . print_r($arr, true));
                            //        //error_log("partial risk val " . print_r($arr3, true));

                            //        //error_log("starting range " . floatval($row['starting_range']));
                            //        //error_log("col val for range " . floatval($colVal));


                            //         foreach ($arr as $val) {
                            //             array_push($health_advice_array, $val);
                            //         }
                            //         foreach ($arr3 as $val3) {
                            //             array_push($health_risk_array, $val3);
                            //         }
                            //         array_push($hiddenHighlighter_array, $row['column_name']);
                            //     } else if (floatval($colVal) > floatval($row['ending_range']) && floatval($row['ending_range']) != 0 && floatval($colVal) != 0) {
                            //         $arr2 = explode(',', $row['more_advices']);
                            //         $arr4 = explode(',', $row['more_risks']);
                            //        //error_log("partial advice val " . print_r($arr2, true));
                            //        //error_log("partial risk val " . print_r($arr4, true));

                            //        //error_log("ending range " . floatval($row['ending_range']));
                            //        //error_log("col val for range " . floatval($colVal));
                            //         foreach ($arr2 as $val2) {
                            //             array_push($health_advice_array, $val2);
                            //         }
                            //         foreach ($arr4 as $val4) {
                            //             array_push($health_risk_array, $val4);
                            //         }
                            //         array_push($hiddenHighlighter_array, $row['column_name']);
                            //     }
                            // }
                            if (isset($colVal1) && $colVal1 != "") {

                                $stmt_update_query_key_value->bind_param("sss", $colVal1, $checkup_id, $row['column_name']);

                                $stmt_update_query_key_value->execute();
                                //error_log("for key value update " . $sql_checkup_form_key_value);
                                // $parameter_update_counter++;
                                if ($stmt_update_query_key_value->errno) {
                                    // if (substr($sql_checkup_form_key_value, 0, 6) === "update") {
                                    //     $parameter_update_counter--;
                                    // }
                                    error_log("error for key value update query " . $stmt_update_query_key_value->error);
                                    rollback();
                                }
                            }
                        }

                        $crntColIndex++;
                    }
                    mysqli_data_seek($result1, 0);
                    ////error_log("risk array " . print_r($health_risk_array, true));
                    ////error_log("advice array " . print_r($health_advice_array, true));
                    // $health_risk_id = getMultiValuedSelectData($health_risk_array);
                    // $health_advice_id = getMultiValuedSelectData($health_advice_array);
                    // $update_health_risk_advice_query = "update checkup_form set health_risk_id='" . addslashes($health_risk_id) . "' , health_advice_id='" . addslashes($health_advice_id) . "' where checkup_id = '" . $checkup_id . "'";

                    ////error_log("risk advice update query " . $update_health_risk_advice_query);

                    // if (!$result_update_health_risk_advice_query = mysqli_query($conn, $update_health_risk_advice_query)) {
                    //    //error_log("risk advice update error " . mysqli_error($conn));
                    //     rollback();
                    // }
                    //error_log("highlight param:" . print_r($hiddenHighlighter_array, true));
                    /* if (count($hiddenHighlighter_array) > 0) {
                        $highlighter_values = implode(',', $hiddenHighlighter_array);
                        // saveHighlightedParams($checkup_id, $highlighter_values);
                    }*/
                } else {
                    // $health_risk_array = array();
                    // $health_advice_array = array();
                    // $hiddenHighlighter_array = array(' ');
                    while ($row = mysqli_fetch_array($result1)) {
                        //error_log("entered while loop for checkup form key value");

                        $colVal = trim(mysqli_real_escape_string($conn, $Row[$crntColIndex]));

                        //error_log("current col index ".$crntColIndex);
                        //error_log("current col from excel " . $dbColumnNameList[$crntColIndex]);
                        //error_log("current col value from excel ".$colVal);
                        //error_log("parameter name from query " . $row['column_name']);

                        //error_log("input type ".$row['input_type'] );

                        if (trim($dbColumnNameList[$crntColIndex]) == trim($row['column_name'])) {
                            if ($row['input_type'] == 'select') {
                                $colVal1 = getFieldFromTable('parameter_value_id', 'checkup_parameter_value', 'parameter_value_name', $colVal);
                            } elseif ($row['input_type'] == 'multiselect') {
                                $colVal1 = getCommaSeperatedValuesForInClause('select parameter_value_id from checkup_parameter_value', 'parameter_value_name', $colVal);
                                //error_log("original value ids before  " . $colVal1);
                                $colVal1 = str_replace(', ', ',', $colVal1);
                                //error_log("original value ids " . $colVal1);
                            } else {
                                $colVal1 = $colVal;
                            }

                            // if ($row['input_type'] == 'number') {
                            //     if (floatval($colVal) < floatval($row['starting_range']) && floatval($row['starting_range']) != 0 && floatval($colVal) != 0) {
                            //        //error_log("inside advice risk condition");
                            //         $arr = explode(',', $row['less_advices']);
                            //         $arr3 = explode(',', $row['less_risks']);
                            //        //error_log("partial advice val " . print_r($arr, true));
                            //        //error_log("partial risk val " . print_r($arr3, true));
                            //         foreach ($arr as $val) {
                            //             array_push($health_advice_array, $val);
                            //         }
                            //         foreach ($arr3 as $val3) {
                            //             array_push($health_risk_array, $val3);
                            //         }
                            //         array_push($hiddenHighlighter_array, $row['column_name']);
                            //     } else if (floatval($colVal) > floatval($row['ending_range']) && floatval($row['ending_range']) != 0 && floatval($colVal) != 0) {
                            //         $arr2 = explode(',', $row['more_advices']);
                            //         $arr4 = explode(',', $row['more_risks']);
                            //        //error_log("partial advice val " . print_r($arr2, true));
                            //        //error_log("partial risk val " . print_r($arr4, true));
                            //         foreach ($arr2 as $val2) {
                            //             array_push($health_advice_array, $val2);
                            //         }
                            //         foreach ($arr4 as $val4) {
                            //             array_push($health_risk_array, $val4);
                            //         }
                            //         array_push($hiddenHighlighter_array, $row['column_name']);
                            //     }
                            // }
                            if (isset($colVal1) && $colVal1 != "") {

                                $stmt_insert_query_key_value->bind_param("sss", $checkup_id, $row['column_name'], $colVal1);
                                $stmt_insert_query_key_value->execute();

                                //error_log("for key value insert/update " . $sql_checkup_form_key_value);
                                // $parameter_insert_counter++;
                                if ($stmt_insert_query_key_value->errno) {
                                    // if (substr($sql_checkup_form_key_value, 0, 6) === "update") {
                                    //     $parameter_insert_counter--;
                                    // }
                                    error_log("error for key value query insert" . $stmt_insert_query_key_value->error);
                                    rollback();
                                }
                            }
                        } else {
                            error_log("mismatch name " . $row['column_name']);
                        }

                        $crntColIndex++;
                    }
                    mysqli_data_seek($result1, 0);
                    ////error_log("risk array " . print_r($health_risk_array, true));
                    ////error_log("advice array " . print_r($health_advice_array, true));
                    // $health_risk_id = getMultiValuedSelectData($health_risk_array);
                    // $health_advice_id = getMultiValuedSelectData($health_advice_array);
                    // $update_health_risk_advice_query = "update checkup_form set health_risk_id='" . addslashes($health_risk_id) . "' , health_advice_id='" . addslashes($health_advice_id) . "' where checkup_id = '" . $checkup_id . "'";

                    ////error_log("risk advice update query " . $update_health_risk_advice_query);

                    // if (!$result_update_health_risk_advice_query = mysqli_query($conn, $update_health_risk_advice_query)) {
                    //    //error_log("risk advice update error " . mysqli_error($conn));
                    //     rollback();
                    // }
                    //error_log("highlight param:" . print_r($hiddenHighlighter_array, true));
                    //  if (count($hiddenHighlighter_array) > 0) {
                    //   $highlighter_values = implode(',', $hiddenHighlighter_array);
                    // saveHighlightedParams($checkup_id, $highlighter_values);
                    //  }
                }
                commit();
            }
            commit();
        } catch (Exception $e) {
            //error_log('Message: ' . $e->getMessage());
        }
    }
}

if ($stmt_sql_medical_select != null) {
    $stmt_sql_medical_select->close();
}

if ($stmt_insert_query_key_value != null) {
    $stmt_insert_query_key_value->close();
}

if ($stmt_update_query_key_value != null) {
    $stmt_update_query_key_value->close();
}

if ($stmt_medical_query_insert != null) {
    $stmt_medical_query_insert->close();
}


if ($stmt_medical_query_update != null) {
    $stmt_medical_query_update->close();
}

commit();
$response_mssages1 = $insert_counter . " " . "Medical Examination records inserted<br> ";
$response_mssages1 .= $update_counter . "  " . "Medical Examination records updated<br>";
$response_mssages1 .= $fail_counter . " " . "Medical Examination records skipped<br> ";
$response_mssages1 .= $new_emp_counter . " " . "New Employee records Found<br> ";

$response_array['responseText'] = "<br>" . $response_mssages1 . $response_mssages;
echo json_encode($response_array);