<?php
include('includes/config/config.php');
include('includes/functions.php');
include('log_entry.php');
error_log('$POST :' . print_r($_POST, true));
error_log("enetred into save form");


error_reporting(E_ERROR | E_PARSE);
$checkup_id = $_POST['checkup_id'];
error_log("checkup_section" . $checkup_id);

$role_code = $_SESSION['RoleCode'];


$checkup_type_id = $_POST['checkup_type_id'];

$ysql = "select * from checkup_form where checkup_id='" . $checkup_id . "'";
$yresult = mysqli_query($conn, $ysql);
$yrow = mysqli_fetch_array($yresult);
$checkup_type_id_db = $yrow['checkup_type_id'];

error_log("checkup_type_id" . $checkup_type_id);
// echo $checkup_id;
$checkup_section = $_POST['checkup_section_ids'];
error_log("checkup_section" . $checkup_section);
$checkup_section_ids = implode(',', array_unique($checkup_section));
if ($checkup_section_ids == "" || $checkup_section_ids == Null) {
	error_log("enter the check up sections");

	echo json_encode("FAILURE");
	exit(mysqli_error($conn));
} else {
	//echo "checkup_section_ids" . $checkup_section_ids;
	$emp_id = $_REQUEST['checkup_emp_id'];
	// echo $emp_id;
	$checkdown_date = $_POST['checkdown_date'];
	error_log("type of date " . gettype($checkdown_date));
	$valid_upto = $_POST['valid_upto_date'];
	$approve_date = $_POST['approve_date'];

	$remarks = $_POST['remarks'];
	if ($_POST['checkup_type_id'] != "") {
		$checkup_type_id = $_POST['checkup_type_id'];
	} else {
		$checkup_type_id = 0;
	}

	$ticket_no = $_REQUEST['ticket_no'];
	// echo $ticket_no;
	$health_risk_id = strtoupper($_POST['health_risk_name']);
	$health_risk_id = handleDynamicMasterInsert("health_risk", "health_risk_name", "health_risk_id", $health_risk_id, true);
	error_log("health_risk_id:" . implode(',', $health_risk_id));
	$health_risk_id = getMultiValuedSelectData($health_risk_id);
	error_log("health_risk_id2:" . $health_risk_id);


	$health_advice_id = strtoupper($_POST['health_advice_name']);
	$health_advice_id = handleDynamicMasterInsert("health_advice", "health_advice_name", "health_advice_id", $health_advice_id, true);
	error_log("health_advice_id:" . implode(',', $health_advice_id));
	$health_advice_id = getMultiValuedSelectData($health_advice_id);
	error_log("health_advice_id2:" . $health_advice_id);

	$past_present_illness = strtoupper($_POST['past_present_illness_data']);
	$past_present_illness = handleDynamicMasterInsert("history_parameter", "param_name", "param_id", $past_present_illness, true);
	error_log("past_present_illness:" . implode(',', $past_present_illness));
	$past_present_illness = getMultiValuedSelectData($past_present_illness);
	error_log("past_present_illness:" . $past_present_illness);

	$abnormalities_data_val = strtoupper($_POST['abnormalities_data']);
	$abnormalities_data_val = handleDynamicMasterInsert("abnormality", "abnormality_name", "abnormality_id", $abnormalities_data_val, true);
	error_log("abnormalities_data:" . implode(',', $abnormalities_data_val));
	$abnormalities_data_val = getMultiValuedSelectData($abnormalities_data_val);
	error_log("abnormalities_data:" . $abnormalities_data_val);

	$fit_status = $_POST['fit_state'];
	$program_id = $_POST['program_id'];
	$program_status = $_POST['program_status'];
	$health_score = $_POST['health_index'];
	$referred_by_doc = $_POST['ref_by_doc'];
	$query_initial = "";
	$endquery = "";
	$tobacco_1 = "10";
	$_SESSION['status'] = $status;
	begin();
	$status = $_POST['attendedStatus'];
	error_log('-ATENDED' . $status);
	if (empty($status)) {
		if ($_SESSION['RoleCode'] == 'LAB') {
			$status = $__STATUS_MEDICAL_ATTENDED;
			error_log("entered for Lab");
		} elseif ($_SESSION['RoleCode'] == 'DOC') {
			$status = $__STATUS_DOCTOR_ATTENDED;
			error_log("entered for Doc");
		} elseif ($_SESSION['RoleCode'] == 'RCP') {
			$status = $__STATUS_RECEPTIONIST_ATTENDED;
			error_log("entered for Rcp");
		}
	}
	$comment = $_POST['comments'];
	$findings = $_POST['findings'];
	$doc_findings = $_POST['doc_findings'];
	$doc_comments = $_POST['doc_comments'];

	$attended_by = $_SESSION['logged_user_empid'];

	error_log("program id " . $program_id);
	if (!empty($program_id) && $program_id != '') {

		$check_previous_program_query = "select program_id from checkup_form where program_id ='" . $program_id . "' and emp_id='" . $emp_id . "' and program_status = 'N'";

		$result_program_query = mysqli_query($conn, $check_previous_program_query);
		error_log("previous query " . $check_previous_program_query);

		$row_program_query = mysqli_fetch_assoc($result_program_query);

		$check_previous_program = $row_program_query['program_id'];

		error_log("previous schedule pro " . $check_previous_program . " bool " . empty($check_previous_program));

		if (empty($check_previous_program)) {
			if (!empty($checkup_id)) {
				$schedule_id = getFieldFromTable('program_id', 'checkup_form', 'checkup_id', $checkup_id);
				error_log("schedule id: " . $schedule_id);
				if ($schedule_id != '0' || $schedule_id != null) {

					$assign_training_id = getTableFieldValue('assign_training', 'assign_training_id', 'employee_id', $emp_id, 'training_schedule_id', $schedule_id);
					error_log("assign training id outside: " . $assign_training_id);
					if (!empty($assign_training_id)) {
						$initquery_pro = "update ";
						$endquery_pro = " where assign_training_id = '" . $assign_training_id . "'   ";
					} else {
						$initquery_pro = "insert into ";
					}
					$query_program = $initquery_pro . " assign_training set credit_to = '3',employee_id='$emp_id',training_schedule_id='$program_id' ,date_assigned=now() $endquery_pro";
					$result_program = mysqli_query($conn, $query_program);

					error_log("query_program " . $query_program);
					if (!empty($assign_training_id)) {
						$new_schedule_id = getTableFieldValue('assign_training', 'training_schedule_id', 'assign_training_id', $assign_training_id, 'employee_id', $emp_id);

						$assign_training_id_new = getTableFieldValue('assign_training', 'assign_training_id', 'employee_id', $emp_id, 'training_schedule_id', $new_schedule_id);
					} else {
						$assign_training_id_new = mysqli_insert_id($conn);
					}
					error_log("assign training id after updating or inserting : " . $assign_training_id_new);
					if (!empty($assign_training_id_new)) {
						//update case
						$query_delete_employee_assign_training = "delete from employee_assign_training where assign_training_id='$assign_training_id_new'";
						error_log("delete query " . $query_delete_employee_assign_training);
						@mysqli_query($conn, $query_delete_employee_assign_training);
					}

					$query_employee_assign_training = "insert into employee_assign_training  set  emp_id='$emp_id' ,assign_training_id='$assign_training_id_new',training_schedule_id='$program_id' ,assign_date=now()";
					error_log("query_employee_assign_training " . $query_employee_assign_training);
					$result_employee_assign_training = mysqli_query($conn, $query_employee_assign_training);
				}
			}
		}
	}


	if (!empty($checkup_id)) {
		$query_initial = "update checkup_form set ";
		$endquery = " where checkup_id = '" . $checkup_id . "' ";
		$select_query = "select checkup_type_id from checkup_form " . $endquery . ";";
	} else {
		$query_initial = "insert into checkup_form set checkup_type_id='" . $checkup_type_id . "', ";
		$select_query = "";
	}

	if ($role_code == 'DOC') {
		$query = $select_query . $query_initial . " ticket_no ='$ticket_no',checkup_section_ids='" . $checkup_section_ids . "', checkup_date=STR_TO_DATE('" . $_POST['checkdown_date'] . "','%d/%m/%Y %h:%i %p'),approve_date=STR_TO_DATE('" . $_POST['approve_date'] . "','%d/%m/%Y %h:%i %p'),valid_upto=STR_TO_DATE('" . $_POST['valid_upto_date'] . "','%d/%m/%Y'),emp_id='$emp_id',health_risk_id='" . addslashes($health_risk_id) . "',health_advice_id='" . addslashes($health_advice_id) . "',past_present_illness='" . addslashes($past_present_illness) . "',abnormality_ids = '" . addslashes($abnormalities_data_val) . "',doc_findings='$doc_findings',doc_comments='$doc_comments',findings='$findings',comments='$comment',current_status='$status',remarks='$remarks',fit_unfit_status='$fit_status',program_id='$program_id',health_index='" . $health_score . "',program_status='$program_status',bmi='$bmi',isHyperTensed='$isHyperTensed',is_test_completed='$is_test_completed',doc_attend='" . $_SESSION['logged_user_empid'] . "', ohc_type_id='" . $_SESSION['current_ohcttype'] . "',modified_by='" . $_SESSION['user_id'] . "' " . $endquery;
	} else if ($role_code == 'ELAB') {
	
					if($status=='DRP'){
						$app_id=getTableFieldValue('checkup_form','appointment_id','checkup_id',$checkup_id);
						$doc_q="update employee_appointment set attended_status='DRP' where appointment_id='".$app_id."' ";
						error_log('move to doc'.$doc_q);
						if (!$result_doc = @mysqli_query($conn,$doc_q)) {
						
							exit(mysqli_error($conn));
							}
					
							$query = $select_query . $query_initial . " ticket_no ='$ticket_no',checkup_section_ids='" . $checkup_section_ids . "', checkup_date=STR_TO_DATE('" . $_POST['checkdown_date'] . "','%d/%m/%Y %h:%i %p'),approve_date=STR_TO_DATE('" . $_POST['approve_date'] . "','%d/%m/%Y %h:%i %p'),valid_upto=STR_TO_DATE('" . $_POST['valid_upto_date'] . "','%d/%m/%Y'),emp_id='$emp_id',health_risk_id='" . addslashes($health_risk_id) . "',health_advice_id='" . addslashes($health_advice_id) . "',past_present_illness='" . addslashes($past_present_illness) . "',abnormality_ids = '" . addslashes($abnormalities_data_val) . "',doc_findings='$doc_findings',doc_comments='$doc_comments',findings='$findings',comments='$comment',current_status='MRA',remarks='$remarks',fit_unfit_status='$fit_status',program_id='$program_id',health_index='" . $health_score . "',program_status='$program_status',bmi='$bmi',isHyperTensed='$isHyperTensed',is_test_completed='$is_test_completed',doc_attend='" . $_SESSION['logged_user_empid'] . "', ohc_type_id='" . $_SESSION['current_ohcttype'] . "',referred_by='" . $referred_by_doc . "',modified_by='" . $_SESSION['user_id'] . "' " . $endquery;
					}
					else{
						$query = $select_query . $query_initial . " ticket_no ='$ticket_no',checkup_section_ids='" . $checkup_section_ids . "', checkup_date=STR_TO_DATE('" . $_POST['checkdown_date'] . "','%d/%m/%Y %h:%i %p'),approve_date=STR_TO_DATE('" . $_POST['approve_date'] . "','%d/%m/%Y %h:%i %p'),valid_upto=STR_TO_DATE('" . $_POST['valid_upto_date'] . "','%d/%m/%Y'),emp_id='$emp_id',health_risk_id='" . addslashes($health_risk_id) . "',health_advice_id='" . addslashes($health_advice_id) . "',past_present_illness='" . addslashes($past_present_illness) . "',abnormality_ids = '" . addslashes($abnormalities_data_val) . "',doc_findings='$doc_findings',doc_comments='$doc_comments',findings='$findings',comments='$comment',current_status='$status',remarks='$remarks',fit_unfit_status='$fit_status',program_id='$program_id',health_index='" . $health_score . "',program_status='$program_status',bmi='$bmi',isHyperTensed='$isHyperTensed',is_test_completed='$is_test_completed',doc_attend='" . $_SESSION['logged_user_empid'] . "', ohc_type_id='" . $_SESSION['current_ohcttype'] . "',referred_by='" . $referred_by_doc . "',modified_by='" . $_SESSION['user_id'] . "' " . $endquery;
					}
		
	
	} else {
		$query = $select_query . $query_initial . " ticket_no ='$ticket_no',checkup_section_ids='" . $checkup_section_ids . "', checkup_date=STR_TO_DATE('" . $_POST['checkdown_date'] . "','%d/%m/%Y %h:%i %p'),approve_date=STR_TO_DATE('" . $_POST['approve_date'] . "','%d/%m/%Y %h:%i %p'),valid_upto=STR_TO_DATE('" . $_POST['valid_upto_date'] . "','%d/%m/%Y'),emp_id='$emp_id',health_risk_id='" . addslashes($health_risk_id) . "',health_advice_id='" . addslashes($health_advice_id) . "',past_present_illness='" . addslashes($past_present_illness) . "',abnormality_ids = '" . addslashes($abnormalities_data_val) . "',doc_findings='$doc_findings',doc_comments='$doc_comments',findings='$findings',comments='$comment',current_status='$status',remarks='$remarks',health_index='" . $health_score . "',fit_unfit_status='$fit_status',program_id='$program_id',program_status='$program_status',bmi='$bmi',isHyperTensed='$isHyperTensed',is_test_completed='$is_test_completed', medical_attend = '" . $_SESSION['logged_user_empid'] . "',ohc_type_id='" . $_SESSION['current_ohcttype'] . "',referred_by='" . $referred_by_doc . "',modified_by='" . $_SESSION['user_id'] . "' " . $endquery;
	}

	error_log("save check up form or update query" . $query);


	if (!$result = $conn->multi_query($query)) {
		error_log("query failed: (" . $conn->errno . ") " . $conn->error);
	} else if (!empty($checkup_id)) {
		do {

			if ($result = $conn->store_result()) {
				while ($row = $result->fetch_row()) {

					$select_checkup_type_id = $row[0];
				}
				$result->free();
			}
		} while ($conn->next_result());
	}

	// echo $query;
	if (!empty($checkup_id)) {
		$id = $checkup_id;
	} else {
		$id = $conn->insert_id;
	}

	if ($role_code == 'DOC' && $fit_status == 'fit') {
		$medical_type  = getFieldFromTable('checkup_type_id', 'checkup_form', 'checkup_id', $id);
		$checkup_type_code = getFieldFromTable('checkup_type_code', 'checkup_type', 'checkup_type_id', $medical_type);
		if ($checkup_type_code == 'MINE_WORKER_MEDICAL_EXAMINATIONS') {
		} else if ($checkup_type_code == 'ANNUAL_MEDICAL_EXAMINATION_HAZARDOUS' || $checkup_type_code == 'PERIODIC_MEDICAL_EXAMINATIONS_HAZARDOUS') {
			$form_32_query = "insert into form_32 set checkup_id='" . $checkup_id . "'";


			$query_checkup = "update checkup_form set form_type='form_32'   where checkup_id='" . $_REQUEST['checkup_id32'] . "' ";
			mysqli_query($conn, $query_checkup);

			if (!$result_32 = mysqli_query($conn, $form_32_query)) {
				error_log("error in saving form 32 " . mysqli_error($conn));
			}
			error_log("form 32 save query" . $form_32_query);
		}
	}

	// echo $query;
	$sql_for_checkup_field = "select  column_name  from checkup_parameter where checkup_form_section_id IN (" . implode(",", $checkup_section) . ") and enabled='Y' ";
	error_log("sql_for_checkup_field " . $sql_for_checkup_field);
	// echo $sql_for_checkup_field;
	// $result_for_checkup_field=$conn->query($sql_for_checkup_field);
	$result_for_checkup_field = $conn->query($sql_for_checkup_field);

	$count = 0;
	$delete_query = "";
	$insert_query_key_value = "";
	while ($row_for_checkup_field = mysqli_fetch_array($result_for_checkup_field)) {
		$row_value = $row_for_checkup_field['column_name'];
		$row_insert_value = getMultiValuedSelectData($_REQUEST[$row_value]);
		if ($row_insert_value == '') {
			$row_insert_value = $_REQUEST[$row_value];
		}
		error_log("row value " . $row_insert_value);
		// echo "shu".$_REQUEST[$row_value];
		// /echo $row_value;
		// echo "t".$select_checkup_type_id;
		// echo "p".$checkup_type_id;
		if ($select_checkup_type_id == $checkup_type_id) {
			// echo "s2";
			if (!empty($checkup_id)) {
				$sql_for_checke = "select * from checkup_form_key_value where checkup_form_id = '" . $checkup_id . "' and checkup_form_key='" . $row_value . "'";
				$result22 = mysqli_query($conn, $sql_for_checke);
				$nrows = mysqli_num_rows($result22);
				error_log("no of rows" . $nrows);

				if ($nrows == 0) {
					$query_initial_key_value = " insert into ";
					$endquery_key_value = " ";
					error_log("Insert");
				} else {
					$query_initial_key_value = "update ";
					$endquery_key_value = " where checkup_form_id = '" . $checkup_id . "' and checkup_form_key='$row_value'  ";
					$id = $checkup_id;
				}
			} else {
				$query_initial_key_value = " insert into ";
			}
			$insert_query_key_value = $query_initial_key_value . "  checkup_form_key_value set checkup_form_key='$row_value',  checkup_form_value='" . addslashes($row_insert_value) . "',checkup_form_id='" . $id . "' " . $endquery_key_value . ";";

			mysqli_query($conn, $insert_query_key_value);

			mysqli_free_result($result22);
		} else {
			if ($count == 0) {
				$delete_query = "delete from checkup_form_key_value where checkup_form_id = '" . $checkup_id . "';";

				mysqli_query($conn, $delete_query);
			}

			// echo "s1";
			$insert_query_key_value = "insert into checkup_form_key_value set checkup_form_key='$row_value',  checkup_form_value='" . addslashes($row_insert_value) . "',checkup_form_id='" . $id . "' " . $endquery_key_value . ";";

			mysqli_query($conn, $insert_query_key_value);

			error_log("insert_query_key_value" . $insert_query_key_value);
			$count++;
		}
		// echo $insert_query_key_value;
		// $field_variable.=$row_for_checkup_field['column_name'].'=".$'.$row_for_checkup_field['column_name'].'.",';
	}

	error_log("insert_query_key_value" . $insert_query_key_value);

	// $list_color_validated_fields =
	error_log("highlight param:" . $_REQUEST['hiddenHighlighter']);
	if (!empty($_REQUEST['hiddenHighlighter'])) {
		error_log("got here");
		saveHighlightedParams($id, $_REQUEST['hiddenHighlighter']);
	}

	commit();

	// echo $sql1;
	echo json_encode($id);
}