ohctech/ohctech_p8
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
688c190212
ohctech_p8/save_opd.php
anuscarlett 17a472aa06 added files and database
2024-10-16 19:18:52 +05:30

1918 lines
70 KiB
PHP
Raw Blame History

<?php
use Com\Tecnick\Barcode\Type\Square\QrCode\Split;
include ('includes/config/config.php');
include ('includes/functions.php');
error_reporting(E_ALL & ~E_NOTICE & ~E_DEPRECATED & ~E_WARNING);
// include log entry header file
include ('log_entry.php');
error_log("Start Printing Request Attributes");
$requestStr = "";
foreach ($_REQUEST as $key => $value) {
$requestStr .= $key . " : " . $value . "\n";
// error_log($key . " : " . $value . "<br />\r\n");
}
error_log("End Printing Request Attributes");
save_log($requestStr, 'Save_OPD', 'SAVE', 'save_opd.php');
// error_reporting(E_ERROR | E_PARSE);
$followup_id = $_REQUEST['followup_id'];
begin();
if ($_REQUEST['appointment_id'] == null || $_REQUEST['appointment_id'] == '' || $_REQUEST['appointment_id'] == '0') {
$appointment_id = $_REQUEST['appoint'];
} else {
$appointment_id = $_REQUEST['appointment_id'];
}
$edit_enable = strtolower($_REQUEST['edit_table_key']);
$medicine_issued = trim($_REQUEST['med_dis_key']);
// echo $appointment_id;
$data = array();
$appointment_date = $_POST['appointment_date'];
$isTreatmentOnly = $_POST['isTreatmentOnly'];
$is_followup = $_REQUEST['followup_to_opd'];
if ($is_followup == null || empty($is_followup) || $is_followup == '') {
$is_followup = $followup_id;
}
error_log('isTreatmentOnly:' . $isTreatmentOnly);
//treatment prepared statements start
$query_treatment_dressing = "insert into treatment set appointment_id=?,is_display='N',group_item_id=?, followup_id = ?,item_id=?,item_qty=?, issued_qty=?, modified_by=?,issue_by=? ";
$stmt_query_treatment_dressing = $conn->prepare($query_treatment_dressing);
$query_stock_history_dressing = " insert into appointment_stock_history set appointment_id=?, followup_id = ?,item_qty=?, item_id=?,issued_qty=?, issue_by=?";
$stmt_query_stock_history_dressing = $conn->prepare($query_stock_history_dressing);
$query_treatment = "insert into treatment SET appointment_id=?, item_id=?,item_qty=?,followup_id = ?,issued_qty=?, item_batch_no=?,dosage=?,for_days=?, frequency_id=?, timing_id = ?,dosage_category_id=?, modified_by=?,issue_by=?";
$stmt_query_treatment = $conn->prepare($query_treatment);
$query_stock_history = "insert into appointment_stock_history set appointment_id=?, current_stock=?,item_qty=?,item_id=?,issued_qty=?,followup_id = ?, issue_by=?";
$stmt_query_stock_history = $conn->prepare($query_stock_history);
$query_treatment_external = "insert into treatment_external SET appointment_id=?,followup_id = ?,item_name=?,item_qty=?,timing = ?,dosage=?,for_days=?, dosage_category_id=?, modified_by=? ";
$stmt_query_treatment_external = $conn->prepare($query_treatment_external);
//end
if ($isTreatmentOnly == 'Y') {
$sql_update_status_all = " update employee_appointment set attended_status='CLS', clearance_time=STR_TO_DATE(?, '%d/%m/%Y %h:%i %p'), medi_disbursement='Y' where appointment_id=?";
error_log("is treatment only if yes opd query " . $sql_update_status_all);
$out_time = $_POST['out_time'];
$stmt_sql_update_status_all = $conn->prepare($sql_update_status_all);
if ($stmt_sql_update_status_all) {
$stmt_sql_update_status_all->bind_param("ss", $out_time, $appointment_id);
$stmt_sql_update_status_all->execute();
if ($stmt_sql_update_status_all->errno) {
error_log("Exception:" . $stmt_sql_update_status_all->error);
rollback();
exit();
}
} else {
error_log("Error in preparing the statement: " . $conn->error);
rollback();
exit(error_log($conn->error));
}
if ($stmt_sql_update_status_all != null) {
$stmt_sql_update_status_all->close();
}
if ($followup_id != '' && $followup_id != null && $followup_id != 0) {
$sql_update_status = " update followup_details set attended_status='CLS', clearance_time=STR_TO_DATE(?, '%d/%m/%Y %h:%i %p'), medi_disbursement='Y' where followup_id=? ";
error_log("is treatment only if yes followup query " . $sql_update_status . " with followup id " . $followup_id);
$stmt_sql_update_status = $conn->prepare($sql_update_status);
if ($stmt_sql_update_status) {
$stmt_sql_update_status->bind_param("ss", $out_time, $followup_id);
$stmt_sql_update_status->execute();
if ($stmt_sql_update_status->errno) {
error_log("Exception:" . $stmt_sql_update_status->error);
rollback();
exit();
}
} else {
error_log("Error in preparing the statement: " . $conn->error);
rollback();
exit(error_log($conn->error));
}
if ($stmt_sql_update_status != null) {
$stmt_sql_update_status->close();
}
goto treatment_section;
} else {
goto treatment_section;
}
}
$ailment_ids_new = strtoupper($_POST['ailment_new']);
error_log("ailment_ids_new:" . $ailment_ids_new);
$patient_id = addslashes($_REQUEST['emp_id']);
$complaint_ids = strtoupper($_POST['complaints']);
$finding_ids = strtoupper($_POST['examination_remarks']);
$referral_ids = ($_POST['referral_point']);
$referral_consultation = trim(strtoupper($_POST['referral_consultation']));
$referred_by = $_POST['referred_by'];
$disease_type = $_POST['disease_type'];
$ailment_system_ids_new = implode(',', $_POST['ailment_system_new']);
$injuryTypes_new = implode(',', $_POST['injury_type_new']);
$injuryClasses_new = implode(',', $_POST['injury_class_new']);
$injuryParts_new = trim($_POST['injury_part']);
$injury_mech = trim($_POST['injury_mech_new']);
$health_advice_names_new = strtoupper($_POST['health_advice_name_new']);
$drug_allergy = strtoupper($_POST['drug_allergy']);
$tests_new = implode(",", $_POST['recommended_test_new']);
$test_param_new = implode(",", $_POST['recommended_test_param_new']);
error_log("selected test param " . $test_param_new);
$diagnosis_config = getFieldFromTable('value', 'config', 'key_name', 'diagnosis_tag_switch');
if (!strcmp(strtolower($diagnosis_config), "true")) {
$ailment_ids_new = handleDynamicMasterInsertModified("ailment", "ailment_name", "ailment_id", $ailment_ids_new, true);
error_log("ailment_ids_new:" . implode(',', $ailment_ids_new));
$ailment_ids_new = getMultiValuedSelectData($ailment_ids_new);
error_log("ailment_ids_new2:" . $ailment_ids_new);
}
if (!strcmp(strtolower($diagnosis_config), "false")) {
$ailment_ids_new = $_REQUEST['ailment_new'];
$ailment_ids_new = implode(',', $ailment_ids_new);
error_log("ailment_ids_new config off : " . print_r($ailment_ids_new, true));
}
$examination_remarks_config = getFieldFromTable('value', 'config', 'key_name', 'examination_tag_switch');
if (!strcmp(strtolower($examination_remarks_config), "true")) {
$finding_ids = handleDynamicMasterInsert("examination_findings", "examination_finding", "id", $finding_ids, true);
error_log("finding_ids:" . implode(',', $finding_ids));
$finding_ids = getMultiValuedSelectData($finding_ids);
error_log("finding_ids2:" . $finding_ids);
}
if (!strcmp(strtolower($examination_remarks_config), "false")) {
$finding_ids = $_REQUEST['examination_remarks'];
$finding_ids = implode(',', $finding_ids);
error_log("$finding_ids config off : " . print_r($finding_ids, true));
}
$complaint_config = getFieldFromTable('value', 'config', 'key_name', 'complaint_tag_switch');
if (!strcmp(strtolower($complaint_config), "true")) {
$complaint_ids = handleDynamicMasterInsertModified("complaints", "complaint", "complaint_id", $complaint_ids, true);
error_log("complaint_ids:" . implode(',', $complaint_ids));
$complaint_ids = getMultiValuedSelectData($complaint_ids);
error_log("complaint_ids2:" . $complaint_ids);
}
if (!strcmp(strtolower($complaint_config), "false")) {
$complaint_ids = $_REQUEST['complaints'];
$complaint_ids = implode(',', $complaint_ids);
error_log("$complaint ids config off : " . print_r($complaint_ids, true));
}
$injury_part_config = getFieldFromTable('value', 'config', 'key_name', 'injury_part_switch');
if (!strcmp(strtolower($injury_part_config), "true")) {
$part_ids = handleDynamicMasterInsertIgnoreCase("injury_part", "inj_name", "inj_id", $injuryParts_new);
error_log("part_ids:" . implode(',', $part_ids));
$part_ids = getMultiValuedSelectData($part_ids);
error_log("part_ids:" . $part_ids);
}
if (!strcmp(strtolower($injury_part_config), "false")) {
$part_ids = $_REQUEST['injury_part'];
$part_ids = implode(',', $part_ids);
error_log("part_ids ids config off : " . print_r($part_ids, true));
}
$injury_mech_config = getFieldFromTable('value', 'config', 'key_name', 'injury_mechanism_switch');
if (!strcmp(strtolower($injury_mech_config), "true")) {
$mech_ids = handleDynamicMasterInsertIgnoreCase("injury_mechanism", "injury_mech_name", "injury_mech_id", $injury_mech);
error_log("mech_ids:" . implode(',', $mech_ids));
$mech_ids = getMultiValuedSelectData($mech_ids);
error_log("mech_ids:" . $mech_ids);
}
if (!strcmp(strtolower($injury_mech_config), "false")) {
$mech_ids = $_REQUEST['injury_mech_new'];
$mech_ids = implode(',', $mech_ids);
error_log("mech_ids ids config off : " . print_r($mech_ids, true));
}
$drug_allergy = $_REQUEST['drug_allergy'];
$drug_allergy = implode(',', $drug_allergy);
error_log("$drug_allergy ids config off : " . print_r($drug_allergy, true));
handleDynamicMasterInsert("health_advice", "health_advice_name", "health_advice_id", $health_advice_names_new);
$advise_ids = getCommaSeperatedValuesForInClauseWithSpace("select health_advice_id from health_advice ", "health_advice_name", $health_advice_names_new);
error_log('$advise_ids' . $advise_ids);
$height = $_POST['height'];
$weight = $_POST['weight'];
$bmi = $_POST['bmi'];
/* updating height weight bmi */
updateHeightWeightBmi($height, $weight, $bmi, $_REQUEST['emp_id']);
$spoc2_percent = $_POST['spoc2_percent'];
$sbp = $_POST['sbp'];
$dbp = $_POST['dbp'];
$temperature = $_POST['temperature'];
$respiratory_rate = $_POST['resp_rate'];
$urine_output = $_POST['urine_output'];
$avpu = $_POST['avpu'];
$trama = $_POST['trama'];
$mobility = $_POST['mobility'];
$abnormalitys = $_POST['abnormalityIds'];
$oxygen_supply = $_POST['oxygen_supply'];
$glasgow_scale = $_POST['glasgow_coma_scale'];
$grbs = $_POST['grbs'];
$bac_level = $_POST['bac_level'];
$total_cholesterol = $_POST['total_cholesterol'];
$external_treatments = $_POST['external_treatments'];
$activity = $_POST['activity'];
$ppe = $_POST['ppe'];
$any_medication = $_POST['any_medication'];
$injury_remarks = $_POST['injury_remarks'];
$doc_comment = $_POST['doc_comment'];
$is_admitted = $_POST['is_admitted'];
$ambulance_used = $_POST['ambulance_used'];
$forUpdate = $_POST['forUpdate'];
$deu_date = $_POST['deu_date'];
if ($_REQUEST['ipd'] == 1 || $_REQUEST['ipd'] == '1') {
$attended_status = 'PHP';
$isDetention = 'Y';
} else {
$attended_status = $_REQUEST['attendedStatus'];
$isDetention = 'N';
}
// $health_index = calculateHealthIndex($sbp, $dbp, $bmi, $fbs, $total_cholesterol);
$health_advice_names = getMultiValuedSelectData(strtoupper($_POST['health_advice_name']));
$health_risk_names = getMultiValuedSelectData(strtoupper($_POST['health_risk_name']));
$medicine_disbursement = $_POST['medicine_disbursement'];
if (trim($medicine_disbursement) == '') {
$medicine_disbursement = $medicine_issued;
}
$tests = getMultiValuedSelectData(strtoupper($_POST['recommended_test']));
$query = "";
$query_initial = "";
$query_mid = "";
$query_end = " ";
$department = getFieldFromTable('dept_id', 'patient_master', 'id', $_REQUEST['emp_id']);
$designation = getFieldFromTable('designation_id', 'patient_master', 'id', $_REQUEST['emp_id']);
// Building parts for the values in the query
$query_parts = array();
$query_values = array();
if (!empty($_REQUEST['emp_id'])) {
$query_parts[] = "emp_id=? ";
$query_values[] = $_REQUEST['emp_id'];
}
if (!empty($medicine_disbursement)) {
$query_parts[] = "medi_disbursement=? ";
$query_values[] = $medicine_disbursement;
}
if (!empty($doctor_attended_flag)) {
$query_parts[] = "doctor_attended_flag=?";
$query_values[] = $doctor_attended_flag;
}
// if (!empty($ticket_no)) {
// $query_parts[] = "ticket_no=?";
// $query_values[] = $ticket_no;
// }
if (!empty($_POST['remarks_rece'])) {
$query_parts[] = "remarks_rece=? ";
$query_values[] = $_POST['remarks_rece'];
}
if (!empty($_REQUEST['chronic_day'])) {
$query_parts[] = "chronic_day=?";
$query_values[] = $_REQUEST['chronic_day'];
}
if (!empty($_REQUEST['doctor_discuss_id'])) {
$query_parts[] = "doctor_discussed_id=?";
$query_values[] = $_REQUEST['doctor_discuss_id'];
}
if (!empty($_REQUEST['appointment_type'])) {
$query_parts[] = "appointment_type=?";
$query_values[] = $_REQUEST['appointment_type'];
}
if (!empty($ailment_ids)) {
$query_parts[] = "ailment_ids=?";
$query_values[] = $ailment_ids;
}
if (!empty($ailment_system_ids)) {
$query_parts[] = "ailment_system_ids=?";
$query_values[] = $ailment_system_ids;
}
// if (!empty($_REQUEST['isEmergency'])) {
// $query_parts[] = "IsEmergency=?";
// $query_values[] = $_REQUEST['isEmergency'];
// }
if (!empty($_REQUEST['isChargeable'])) {
$query_parts[] = "IsChargeable=?";
$query_values[] = $_REQUEST['isChargeable'];
}
if (!empty($complaint_ids)) {
$query_parts[] = "complaints=?";
$query_values[] = $complaint_ids;
}
if (!empty($referred_by)) {
$query_parts[] = "referred_by=?";
$query_values[] = $referred_by;
}
if (!empty($_POST['referred_to'])) {
$query_parts[] = "referred_to=?";
$query_values[] = $_POST['referred_to'];
}
if (!empty($_POST['clinical_opinion'])) {
$query_parts[] = "clinical_opinion=?";
$query_values[] = $_POST['clinical_opinion'];
}
if (!empty($finding_ids)) {
$query_parts[] = "examination_remarks=?";
$query_values[] = $finding_ids;
}
if (!empty($disease_type)) {
$query_parts[] = "disease_type=?";
$query_values[] = $disease_type;
}
if (!empty($_POST['injury_area_cat'])) {
$query_parts[] = "injury_area_cat=?";
$query_values[] = $_POST['injury_area_cat'];
}
if (!empty($_POST['injury_area_type'])) {
$query_parts[] = "injury_area_type=?";
$query_values[] = $_POST['injury_area_type'];
}
if (!empty($_REQUEST['sbp'])) {
$query_parts[] = "bp_sbp=?";
$query_values[] = $_REQUEST['sbp'];
}
if (!empty($_POST['heart_rate'])) {
$query_parts[] = "heart_rate=?";
$query_values[] = $_POST['heart_rate'];
}
if (!empty($_POST['pulse_output'])) {
$query_parts[] = "pulse_output=?";
$query_values[] = $_POST['pulse_output'];
}
if (!empty($height)) {
$query_parts[] = "height=?";
$query_values[] = $height;
}
if (!empty($weight)) {
$query_parts[] = "weight=?";
$query_values[] = $weight;
}
if (!empty($_POST['dbp'])) {
$query_parts[] = "bp_dbp=?";
$query_values[] = $_POST['dbp'];
}
if (!empty($_POST['ipd'])) {
$query_parts[] = "ipd=?";
$query_values[] = $_POST['ipd'];
}
if (!empty($_POST['fbs'])) {
$query_parts[] = "blood_sugar_fbs=?";
$query_values[] = $_POST['fbs'];
}
if (!empty($_POST['fbs'])) {
$query_parts[] = "blood_sugar_fbs=?";
$query_values[] = $_POST['fbs'];
}
if (!empty($_POST['rbs'])) {
$query_parts[] = "blood_sugar_rbs=?";
$query_values[] = $_POST['rbs'];
}
if (!empty($_POST['ppbs'])) {
$query_parts[] = "blood_sugar_ppbs=?";
$query_values[] = $_POST['ppbs'];
}
if (!empty($bmi)) {
$query_parts[] = "bmi=?";
$query_values[] = $bmi;
}
if (!empty($respiratory_rate)) {
$query_parts[] = "respiratory_rate=?";
$query_values[] = $respiratory_rate;
}
if (!empty($urine_output)) {
$query_parts[] = "urine_output=?";
$query_values[] = $urine_output;
}
if (!empty($avpu)) {
$query_parts[] = "avpu=?";
$query_values[] = $avpu;
}
if (!empty($trama)) {
$query_parts[] = "trama=?";
$query_values[] = $trama;
}
if (!empty($mobility)) {
$query_parts[] = "mobility=?";
$query_values[] = $mobility;
}
if (!empty($oxygen_supply)) {
$query_parts[] = "oxygen_supply=?";
$query_values[] = $oxygen_supply;
}
if (!empty($glasgow_coma_scale)) {
$query_parts[] = "glasgow_coma_scale=?";
$query_values[] = $glasgow_coma_scale;
}
if (!empty($total_cholesterol)) {
$query_parts[] = "total_cholesterol=?";
$query_values[] = $total_cholesterol;
}
if (!empty($temperature)) {
$query_parts[] = "temperature=?";
$query_values[] = $temperature;
}
if (!empty($grbs)) {
$query_parts[] = "grbs=?";
$query_values[] = $grbs;
}
if (!empty($bac_level)) {
$query_parts[] = "bac_level=?";
$query_values[] = $bac_level;
}
if (!empty($spoc2_percent)) {
$query_parts[] = "spo2_percent=?";
$query_values[] = $spoc2_percent;
}
if (!empty($referral_ids)) {
if (CheckReferralEmail($appointment_id) == 0) {
$refferralMailFlag = 1;
} else {
$refferralMailFlag = 0;
}
$query_parts[] = "referral=?";
$query_values[] = $referral_ids;
} else {
$refferralMailFlag = 0;
}
if (!empty($referral_consultation)) {
$query_parts[] = "referral_consultation=?";
$query_values[] = $referral_consultation;
}
if (!empty($_POST['followup'])) {
$query_parts[] = "followup =STR_TO_DATE(?,'%Y-%m-%d')";
$query_values[] = $_POST['followup'];
}
if (!empty($_POST['case_type'])) {
$query_parts[] = "case_type=?";
$query_values[] = $_POST['case_type'];
}
if (!empty($_POST['shift_type'])) {
$query_parts[] = "shift_type=?";
$query_values[] = $_POST['shift_type'];
}
// if (!empty($_POST['ppe'])) {
// $query_parts[] = "ppe=?";
// $query_values[] = $_POST['ppe'];
// }
if (!empty($_POST['injury_def'])) {
$query_parts[] = "injury_def=?";
$query_values[] = $_POST['injury_def'];
}
if (!empty($remarks)) {
$query_parts[] = "remarks=?";
$query_values[] = $remarks;
}
if (!empty($activity)) {
$query_parts[] = "activity=?";
$query_values[] = $activity;
}
if (!empty($ppe)) {
$query_parts[] = "ppe=?";
$query_values[] = $ppe;
}
if (!empty($any_medication)) {
$query_parts[] = "any_medication=?";
$query_values[] = $any_medication;
}
if (!empty($drug_allergy)) {
$query_parts[] = "drug_allergy=?";
$query_values[] = $drug_allergy;
}
if (!empty($injury_remarks)) {
$query_parts[] = "injury_remarks=?";
$query_values[] = $injury_remarks;
}
if (!empty($doc_comment)) {
$query_parts[] = "doc_comment=?";
$query_values[] = $doc_comment;
}
if (!empty($is_admitted)) {
$query_parts[] = "is_admitted=?";
$query_values[] = $is_admitted;
}
if (!empty($_POST['additional_treatment_info'])) {
$query_parts[] = "additional_treatment_info=?";
$query_values[] = $_POST["additional_treatment_info"];
}
if (!empty($_POST['referral_doc'])) {
$query_parts[] = "referral_doc=?";
$query_values[] = $_POST['referral_doc'];
}
if (!empty($_POST['is_hospitalized'])) {
$query_parts[] = "is_hospitalized=?";
$query_values[] = $_POST['is_hospitalized'];
}
if (!empty($_POST['ambulance_in_time'])) {
$query_parts[] = "ambulance_in_time=STR_TO_DATE(?, '%d/%m/%Y %h:%i %p')";
$query_values[] = $_POST['ambulance_in_time'];
}
if (!empty($_POST['ambulance_out_time'])) {
$query_parts[] = "ambulance_out_time=STR_TO_DATE(?, '%d/%m/%Y %h:%i %p')";
$query_values[] = $_POST['ambulance_out_time'];
}
if (!empty($_POST['report_time'])) {
$query_parts[] = "report_time=STR_TO_DATE(?, '%d/%m/%Y %h:%i %p')";
$query_values[] = $_POST['report_time'];
}
if (!empty($ambulance_used)) {
$query_parts[] = "ambulance_used=?";
$query_values[] = $ambulance_used;
}
if (!empty($_POST['safety_officer'])) {
$query_parts[] = "safety_officer=?";
$query_values[] = $_POST['safety_officer'];
}
if (!empty($deu_date)) {
$query_parts[] = "deu_date=?";
$query_values[] = $deu_date;
}
if (!empty($_POST['appointment_date'])) {
$query_parts[] = "appointment_date =STR_TO_DATE(?, '%d/%m/%Y %h:%i %p')";
$query_values[] = $_POST['appointment_date'];
}
if (!empty($_POST['out_time'])) {
$query_parts[] = "clearance_time =STR_TO_DATE(?, '%d/%m/%Y %h:%i %p')";
$query_values[] = $_POST['out_time'];
}
if (!empty($_POST['injury_time'])) {
$query_parts[] = "injury_time =STR_TO_DATE(?, '%d/%m/%Y %h:%i %p')";
$query_values[] = $_POST['injury_time'];
}
if (!empty($_POST['rest_from_time'])) {
$query_parts[] = "rest_from_time =STR_TO_DATE(?, '%d/%m/%Y %h:%i %p')";
$query_values[] = $_POST['rest_from_time'];
}
if (!empty($_POST['rest_to_time'])) {
$query_parts[] = "rest_to_time =STR_TO_DATE(?, '%d/%m/%Y %h:%i %p')";
$query_values[] = $_POST['rest_to_time'];
}
if (!empty($mech_ids)) {
$query_parts[] = "injury_mech =?";
$query_values[] = $mech_ids;
}
if (!empty($_SESSION['user_id'])) {
$query_parts[] = "modified_by =?";
$query_values[] = $_SESSION['user_id'];
}
if (!empty($_SESSION['current_ohcttype'])) {
$query_parts[] = "ohc_type_id =?";
$query_values[] = $_SESSION['current_ohcttype'];
}
if (!empty($injuryTypes)) {
$query_parts[] = "injury_types =?";
$query_values[] = $injuryTypes;
}
if (!empty($injuryClasses)) {
$query_parts[] = "injury_classes =?";
$query_values[] = $injuryClasses;
}
if (!empty($injuryParts)) {
$query_parts[] = "injury_parts =?";
$query_values[] = $injuryParts;
}
if (!empty($_REQUEST['injury_form'])) {
$query_parts[] = "injury_form =?";
$query_values[] = $_REQUEST['injury_form'];
}
if (!empty($_POST['absence_start'])) {
$query_parts[] = "absence_start=STR_TO_DATE(?, '%d/%m/%Y')";
$query_values[] = $_POST['absence_start'];
}
if (!empty($_POST['absence_end'])) {
$query_parts[] = "absence_end=STR_TO_DATE(?, '%d/%m/%Y')";
$query_values[] = $_POST['absence_end'];
}
if (!empty($_REQUEST['injury_firm'])) {
$query_parts[] = "injury_firm =?";
$query_values[] = $_REQUEST['injury_firm'];
}
if (!empty($_REQUEST['incident_location'])) {
$query_parts[] = "incident_location =?";
$query_values[] = $_REQUEST['incident_location'];
}
if (!empty($_REQUEST['injury_sbu'])) {
$query_parts[] = "injury_sbu =?";
$query_values[] = $_REQUEST['injury_sbu'];
}
if (!empty($_REQUEST['injury_section'])) {
$query_parts[] = "injury_section =?";
$query_values[] = $_REQUEST['injury_section'];
}
if (!empty($_REQUEST['doctor_discussed'])) {
$query_parts[] = "doctor_discussed =?";
$query_values[] = $_REQUEST['doctor_discussed'];
}
if (!empty($_REQUEST['doctor_last_attended'])) {
$query_parts[] = "doctor_last_attended =?";
$query_values[] = $_REQUEST['doctor_last_attended'];
}
if (!empty($_REQUEST['injury_sub_section'])) {
$query_parts[] = "injury_sub_section =?";
$query_values[] = $_REQUEST['injury_sub_section'];
}
if (!empty($tests)) {
$query_parts[] = "tests =?";
$query_values[] = $tests;
}
if (!empty($_REQUEST['pro_remarks'])) {
$query_parts[] = "injury_procedure =?";
$query_values[] = $_REQUEST['pro_remarks'];
}
if (!empty($_REQUEST['hospital_treatment'])) {
$query_parts[] = "hospital_treatment =?";
$query_values[] = $_REQUEST['hospital_treatment'];
}
if (!empty($health_advice_names)) {
$query_parts[] = "health_advice_names=?";
$query_values[] = $health_advice_names;
}
if (!empty($_POST['order_level_total'])) {
$query_parts[] = "total_amount=?";
$query_values[] = $_POST['order_level_total'];
}
if (!empty($abnormalitys)) {
$query_parts[] = "abnormalitys=?";
$query_values[] = $abnormalitys;
}
if (!empty($_REQUEST['token_no'])) {
$query_parts[] = "token_no=?";
$query_values[] = $_REQUEST['token_no'];
}
if (!empty($ailment_ids_new)) {
$query_parts[] = "ailments_new=?";
$query_values[] = $ailment_ids_new;
}
if (!empty($ailment_system_ids_new)) {
$query_parts[] = "ailment_systems_new=?";
$query_values[] = $ailment_system_ids_new;
}
if (!empty($injuryTypes_new)) {
$query_parts[] = "injury_types_new=?";
$query_values[] = $injuryTypes_new;
}
if (!empty($injuryClasses_new)) {
$query_parts[] = "injury_classes_new=?";
$query_values[] = $injuryClasses_new;
}
if (!empty($part_ids)) {
$query_parts[] = "injury_parts_new=?";
$query_values[] = $part_ids;
}
if (!empty($tests_new)) {
$query_parts[] = "recommended_tests_new=?";
$query_values[] = $tests_new;
}
if (!empty($test_param_new)) {
$query_parts[] = "recommended_test_param_new=?";
$query_values[] = $test_param_new;
}
if (!empty($health_index)) {
$query_parts[] = "health_index=?";
$query_values[] = $health_index;
}
if (!empty($external_treatments)) {
$query_parts[] = "external_treatments=?";
$query_values[] = $external_treatments;
}
if (!empty($attended_status)) {
$query_parts[] = "attended_status=?";
$query_values[] = $attended_status;
}
if (!empty($isDetention)) {
$query_parts[] = "is_detention=?";
$query_values[] = $isDetention;
}
if (!empty($_POST['branch_area'])) {
$query_parts[] = "branch_area=?";
$query_values[] = $_POST['branch_area'];
}
if (!empty($_POST['dept'])) {
$query_parts[] = "dept=?";
$query_values[] = $_POST['dept'];
}
if (!empty($_POST['injury_cause'])) {
$query_parts[] = "injury_cause=?";
$query_values[] = $_POST['injury_cause'];
}
if (!empty($_REQUEST['followup_to_opd'])) {
$query_parts[] = "followup_to_opd=?";
$query_values[] = $_REQUEST['followup_to_opd'];
}
if (!empty($_REQUEST['followup_remarks'])) {
$query_parts[] = "followup_remarks=?";
$query_values[] = $_REQUEST['followup_remarks'];
}
if (!empty($health_advice_names_new)) {
$query_parts[] = "health_advices_new=?";
$query_values[] = $health_advice_names_new;
}
if (!empty($department)) {
$query_parts[] = "department=?";
$query_values[] = $department;
}
if (!empty($designation)) {
$query_parts[] = "designation=?";
$query_values[] = $designation;
}
$rolecode = $_SESSION['RoleCode'];
error_log("follow up case or not : " . $_REQUEST['followup_to_opd']);
// if this is only for saving treatment information we should skip saving OPD information.
$isInsertCase = "";
if ($is_followup == null || $is_followup == '' || empty($is_followup)) {
if (!empty($appointment_id) && $appointment_id != '' && $appointment_id != null && $appointment_id != ' ') {
$isInsertCase = false;
$data['message'] = "update";
if (!empty($ticket_no)) {
$query_parts[] = "ticket_no=?";
$query_values[] = $ticket_no;
}
// adding for update case only
$query_values[] = $appointment_id;
$query_initial = " update employee_appointment ";
$query_end = " where appointment_id = ? ";
} else {
if ($_REQUEST['appointment_type'] == 'O') {
$ticket_no = creatingTicketNoOPD();
} else {
$ticket_no = creatingTicketNoInjury();
}
if (!empty($ticket_no)) {
$query_parts[] = "ticket_no=?";
$query_values[] = $ticket_no;
}
$isInsertCase = true;
$data['message'] = "save";
$query_initial = "insert into employee_appointment ";
}
} else {
//additional appointment_id for followup
$query_parts[] = "appointment_id=?";
$query_values[] = $_REQUEST['followup_to_opd'];
if ($followup_id == '' || $followup_id == null) {
$ticket_no = creatingTicketNoFollowup();
if (!empty($ticket_no)) {
$query_parts[] = "ticket_no=?";
$query_values[] = $ticket_no;
}
$isInsertCase = true;
$query_initial = "insert into followup_details";
$query_end = "";
} else {
$isInsertCase = false;
if (!empty($ticket_no)) {
$query_parts[] = "ticket_no=?";
$query_values[] = $ticket_no;
}
//adding for update case only
$query_values[] = $followup_id;
$query_initial = "update followup_details";
$query_end = "where followup_id=?";
}
}
error_log("parameter query" . print_r($query_parts, true) . " value " . print_r($query_values, true));
$query = "";
$query = $query_initial . " SET " . implode(", ", $query_parts) . " " . $query_end;
error_log("final query " . $query);
$stmt_insert_update_opd = $conn->prepare($query);
if ($stmt_insert_update_opd) {
$types = str_repeat('s', count($query_values));
$stmt_insert_update_opd->bind_param($types, ...$query_values);
$stmt_insert_update_opd->execute();
if ($stmt_insert_update_opd->errno) {
error_log("Error in opd or followup saving " . $stmt_insert_update_opd->error);
rollback();
}
} else {
error_log("Error in preparing the statement: " . $conn->error);
rollback();
exit(error_log($conn->error));
}
if (isset($is_followup) && !empty($is_followup)) {
$appointment_id = addslashes($_REQUEST['followup_to_opd']);
if (!$stmt_insert_update_opd->errno) {
if (empty($followup_id)) {
$query = "select max(followup_id) followup_id from followup_details where emp_id = '" . addslashes($_REQUEST['emp_id']) . "' ";
error_log("max followup_id_id query: " . $query);
if (!$result = @mysqli_query($conn, $query)) {
rollback();
exit(error_log(mysqli_error($conn)));
}
if (mysqli_num_rows($result) > 0) {
while ($row = mysqli_fetch_assoc($result)) {
$followup_id = $row['followup_id'];
}
}
}
error_log("FOLLOWUP ID::" . $followup_id);
error_log("---------FOLLOW-UP SECTION STARTS EXECUTING-------------");
$app_update = "update employee_appointment set followup_to_opd=?,attended_status=? where appointment_id=?";
$stmt_app_update = $conn->prepare($app_update);
if ($stmt_app_update) {
$stmt_app_update->bind_param("sss", $_REQUEST['followup_to_opd'], $attended_status, $_REQUEST['followup_to_opd']);
$stmt_app_update->execute();
if ($stmt_app_update->errno) {
error_log("Error in saving followup entry in opd " . $stmt_app_update->error);
rollback();
}
} else {
error_log("Error in preparing the statement " . $conn->error);
rollback();
}
if ($stmt_app_update != null) {
$stmt_app_update->close();
}
if (!empty($advise_ids)) {
updatePatientHealthInfo($patient_id, 'ADC', $advise_ids, $appointment_date, '', 0);
}
if (!empty($drug_allergy)) {
updatePatientHealthInfo($patient_id, 'ALG', $drug_allergy, $appointment_date, '', 0);
}
if (!empty($abnormalitys)) {
updatePatientAbnormalityInfo($patient_id, $abnormalitys, $appointment_date);
}
if (!empty($injuryTypes_new)) {
updatePatientHealthInfo($patient_id, 'INJ', $injuryTypes_new, $appointment_date, '', 0);
}
// if this is only for saving treatment information we should skip saving OPD information.
goto treatment_section;
}
}
if ($is_followup == '' || $is_followup == 0 || empty($is_followup)) {
$followup_id = '0';
if ($stmt_insert_update_opd->errno) {
error_log("APPOINTMENT QUERY FAILING");
// main insert fails
error_log("Exception:" . $stmt_insert_update_opd->error);
error_log("Appointment Save: " . $query);
rollback();
} else {
if (!empty($advise_ids)) {
updatePatientHealthInfo($patient_id, 'ADC', $advise_ids, $appointment_date, '', 0);
}
if (!empty($drug_allergy)) {
updatePatientHealthInfo($patient_id, 'ALG', $drug_allergy, $appointment_date, '', 0);
}
// error_log('abbb 3 ' . $abnormalitys);
// error_log('abbb ' . implode(",", $abnormalitys));
// if (!empty(implode(",", $abnormalitys))) {
// updatePatientAbnormalityInfo($patient_id,$abnormalitys, $appointment_date);
// }
if (!empty($abnormalitys)) {
updatePatientAbnormalityInfo($patient_id, $abnormalitys, $appointment_date);
}
if (!empty($injuryTypes_new)) {
updatePatientHealthInfo($patient_id, 'INJ', $injuryTypes_new, $appointment_date, '', 0);
}
if (empty($appointment_id)) {
$query = "select max(appointment_id) appointment_id from employee_appointment where emp_id = '" . addslashes($_REQUEST['emp_id']) . "' ";
// echo $query;
error_log("max appointment_id query: " . $query);
if (!$result = @mysqli_query($conn, $query)) {
rollback();
exit(error_log(mysqli_error($conn)));
}
if (mysqli_num_rows($result) > 0) {
while ($row = mysqli_fetch_assoc($result)) {
$appointment_id = $row['appointment_id'];
}
}
}
$health_program_enrolment_ids = $_REQUEST['health_program_enrolment'];
$health_program_enrolment_ids = implode(',', $_REQUEST['health_program_enrolment']);
error_log("health program names " . print_r($health_program_enrolment_ids, true));
$query_del_waiting_training = " delete from waiting_health_program_enrolment where emp_id = '" . $_REQUEST['emp_id'] . "' and appointment_id = '" . $appointment_id . "' and status='W' ";
error_log("delete waiting Training: " . $query_del_waiting_training);
if (!$result_del = @mysqli_query($conn, $query_del_waiting_training)) {
exit(error_log(mysqli_error($conn)));
rollback();
}
for ($t = 0; $t < count($_REQUEST['health_program_enrolment']); $t++) {
$query_insert_waiting_training = " insert into waiting_health_program_enrolment set emp_id = '" . $_REQUEST['emp_id'] . "' , appointment_id = '" . $appointment_id . "', status='W' , training_id='" . $_REQUEST['health_program_enrolment'][$t] . "' ,modified_by='" . $_SESSION["user_id"] . "' ";
error_log("insert waiting Training: " . $query_insert_waiting_training);
if (!$result_insertl = @mysqli_query($conn, $query_insert_waiting_training)) {
exit(error_log(mysqli_error($conn)));
rollback();
}
}
// if this is only for saving treatment information we should skip saving OPD information.
goto treatment_section;
}
}
treatment_section:
error_log("at treatment section");
//lab test saving logic start
if ($rolecode == 'DOC' && $_POST['recommended_test_new'] != '' && $_POST['recommended_test_new'] != null) {
// Check if the lab entry already exists
$exists_lab_sql = "SELECT * FROM checkup_form WHERE appointment_id=? AND followup_id=?";
$stmt_exists_lab_sql = $conn->prepare($exists_lab_sql);
if ($stmt_exists_lab_sql) {
$stmt_exists_lab_sql->bind_param("ss", $appointment_id, $followup_id);
$stmt_exists_lab_sql->execute();
// Check for errors
if ($stmt_exists_lab_sql->errno) {
error_log("Error in exist lab query " . $stmt_exists_lab_sql->error);
} else {
$result_lab_sql = $stmt_exists_lab_sql->get_result();
$num_rows_lab = $result_lab_sql->num_rows;
$row_lab_sql = $result_lab_sql->fetch_assoc();
}
// Close the statement
if ($stmt_exists_lab_sql != null) {
$stmt_exists_lab_sql->close();
}
} else {
error_log("Error in preparing exist lab query stmt " . $conn->error);
}
$lab_init_query = "";
$lab_end_query = "";
$lab_checkup_ticket_no = "";
if ($num_rows_lab > 0) {
$lab_checkup_ticket_no = $row_lab_sql['ticket_no'];
$lab_init_query = "update checkup_form set ";
$lab_end_query = " where appointment_id=? and checkup_id=? and followup_id=?";
} else {
$lab_checkup_ticket_no = creatingCheckupTicketNo();
$lab_init_query = "insert into checkup_form set appointment_id=?, followup_id=?, ";
$lab_end_query = "";
}
error_log("tests " . $tests_new);
$userEntriesArray = explode(",", $tests_new);
$userEntriesArray = array_map('trim', $userEntriesArray);
error_log("user entries array" . $userEntriesArray);
// Getting checkup lab test master id
$checkup_type_id_sql = "select checkup_type_id from checkup_type where checkup_type_code='LAB_TEST'";
$stmt_checkup_type_id = $conn->prepare($checkup_type_id_sql);
if ($stmt_checkup_type_id) {
$stmt_checkup_type_id->execute();
$result_checkup = $stmt_checkup_type_id->get_result();
// Check for errors
if ($stmt_checkup_type_id->errno) {
error_log("Error in getting checkup type id " . $stmt_checkup_type_id->error);
} else {
$row_checkup = $result_checkup->fetch_assoc();
$checkup_type_id = $row_checkup['checkup_type_id'];
}
// Close the statement
if ($stmt_checkup_type_id != null) {
$stmt_checkup_type_id->close();
}
} else {
error_log("Error in preparing checkup type id query stmt " . $conn->error);
}
error_log("checkup type id " . $checkup_type_id);
// Inserting or updating lab record
$lab_entry = $lab_init_query . " checkup_date=STR_TO_DATE(?, '%d/%m/%Y %h:%i %p'), ticket_no=?, emp_id=?, checkup_type_id=?, referred_by=?, checkup_section_ids=?, current_status='MRP', ohc_type_id=?, modified_by=?" . $lab_end_query;
error_log("saving lab entry in save opd " . $lab_entry);
$stmt_save_lab = $conn->prepare($lab_entry);
if ($stmt_save_lab) {
if ($num_rows_lab > 0) {
$stmt_save_lab->bind_param("sssssssssss", $appointment_date, $lab_checkup_ticket_no, $_REQUEST['emp_id'], $checkup_type_id, $SESSION_emp_id, $tests_new, $_SESSION['current_ohcttype'], $_SESSION['user_id'], $appointment_id, $row_lab_sql['checkup_id'], $followup_id);
} else {
$stmt_save_lab->bind_param("ssssssssss", $appointment_id, $followup_id, $appointment_date, $lab_checkup_ticket_no, $_REQUEST['emp_id'], $checkup_type_id, $SESSION_emp_id, $tests_new, $_SESSION['current_ohcttype'], $_SESSION['user_id']);
}
$stmt_save_lab->execute();
// Check for errors
if ($stmt_save_lab->errno) {
error_log("Error while saving lab entry in save opd " . $stmt_save_lab->error);
}
// Close the statement
if ($stmt_save_lab != null) {
$stmt_save_lab->close();
}
} else {
error_log("Error in preparing save lab query stmt " . $conn->error);
}
}
//lab test saving logic end
// EDIT TREATMENT IS NOT ALLOWED IF KEY IS FALSE AND ROLE CODE IS DOC
error_log("role code " . $_SESSION['RoleCode']);
if ($edit_enable == 'true' || $isTreatmentOnly == 'Y' || $isInsertCase == true || $medicine_issued != 'Y') {
$curr_ohc_id = getTableFieldValue('employee_appointment', 'ohc_type_id', 'appointment_id', $appointment_id);
if ($_SESSION['current_ohcttype'] == $curr_ohc_id) {
error_log("getting inside because current ohc is matching with ohc present for this appointment");
/* for reset Item Stock At Dispensary Level */
if ($followup_id == null || $followup_id == '' || empty($followup_id)) {
$followup_id = 0;
}
if ($_SESSION["RoleCode"] == 'DIS') {
resetItemStockAtDispensaryLevelForFollowup($appointment_id, $_SESSION['current_ohcttype'], $followup_id);
} else {
resetItemStockAtStoreLevelForFollowup($appointment_id, $_SESSION['current_ohcttype'], $followup_id);
}
/* delete all child table during update records */
if (!@mysqli_query($conn, "delete from appointment_stock_history where appointment_id='" . $appointment_id . "' and followup_id = '" . $followup_id . "'")) {
error_log("Exception:" . mysqli_error($conn));
exit(error_log(mysqli_error($conn)));
rollback();
}
if (!@mysqli_query($conn, "delete from treatment where appointment_id='" . $appointment_id . "' and followup_id = '" . $followup_id . "' ")) {
error_log("Exception:" . mysqli_error($conn));
exit(error_log(mysqli_error($conn)));
rollback();
}
if ($isTreatmentOnly != 'Y' && !@mysqli_query($conn, "delete from treatment_external where appointment_id='" . $appointment_id . "' and followup_id = '" . $followup_id . "'")) {
error_log("Exception:" . mysqli_error($conn));
exit(error_log(mysqli_error($conn)));
rollback();
}
/* insert all child table during save or update records */
error_log("treatment row count:" . $_REQUEST['count_treatment_item']);
for ($i = 0; $i <= $_REQUEST['count_treatment_item']; $i++) {
if (${"treatment_item$i"} != "" && ${"treatment_item$i"} != null) {
$batch_stock = getBatchStock(${"treatment_item$i"}, ${"item_batch_no$i"});
if ($batch_stock == null || $batch_stock == '') {
$batch_stock = 0;
}
error_log("selected batch stock " . $batch_stock);
error_log("Issued qty for this " . ${"treatment_item_qtygvn$i"} . " item id is => " . ${"treatment_item$i"});
if ($batch_stock < ${"treatment_item_qtygvn$i"}) {
$issued_qty = ${"treatment_item_qtygvn$i"} - $batch_stock;
/////
error_log("treatment_item:" . $i . ":" . ${"treatment_item$i"} . ": remaining issued qty " . $issued_qty);
if (${"treatment_item$i"} != null && ${"treatment_item$i"} != "") {
// To Check Item is Dressing Or Not
$is_dressing_item = toCheckDressingItem(${"treatment_item$i"});
error_log("is_dressing_item:" . $is_dressing_item);
if ($is_dressing_item == 'P') {
if (${"group_child_flag_$i"} == '1') {
$result_for_group_items = getGroupItems(${"treatment_item$i"});
$no_rows_group_child = mysqli_num_rows($result_for_group_items);
error_log("no_rows_group_child:" . $no_rows_group_child);
for ($j = 0; $j < $no_rows_group_child; $j++) {
$treatment_given_by = '';
if (addslashes($_POST['child_item_qty_gvn' . $i . '_' . $j]) != 0 || addslashes($_POST['child_item_qty_gvn' . $i . '_' . $j]) != '' || addslashes($_POST['child_item_qty_gvn' . $i . '_' . $j]) != null) {
$treatment_given_by = $_SESSION['user_id'];
}
error_log("Child Item:" . $_POST['child_item_' . $i . '_' . $j]);
$group_item_id = getFieldFromTable('group_id', 'group_items', 'item_id', $_POST['child_item_' . $i . '_' . $j]);
error_log("group_item_id:" . $group_item_id);
error_log("childitem:" . $_POST['child_item_' . $i . '_' . $j]);
if ($stmt_query_treatment_dressing) {
$stmt_query_treatment_dressing->bind_param("ssssssss", $appointment_id, $group_item_id, $followup_id, $_POST['child_item_' . $i . '_' . $j], $_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_qty_gvn' . $i . '_' . $j], $_SESSION['user_id'], $treatment_given_by);
$stmt_query_treatment_dressing->execute();
if ($stmt_query_treatment_dressing->errno) {
error_log("Error in adding dressing item treatment " . $stmt_query_treatment_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement " . $conn->error);
rollback();
}
error_log("query_treatment:1 " . $query_treatment_dressing);
if ($stmt_query_stock_history_dressing) {
$stmt_query_stock_history_dressing->bind_param("ssssss", $appointment_id, $followup_id, $_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_' . $i . '_' . $j], $_POST['child_item_qty_gvn' . $i . '_' . $j], $treatment_given_by);
$stmt_query_stock_history_dressing->execute();
if ($stmt_query_stock_history_dressing->errno) {
error_log("issues while updating appointment_stock_history: " . $stmt_query_stock_history_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement for stock history " . $conn->error);
rollback();
}
error_log("query_stock_history: " . $query_stock_history_dressing);
// to update Dispensary Items
if ($_SESSION("RoleCode") == 'DIS' || in_array('DIS', explode(',', $_SESSION['RoleCode']))) {
resetItemStockAtDispensaryLevelForGroupItems(-$_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_' . $i . '_' . $j], $_SESSION['current_ohcttype']);
} else {
resetItemStockAtStoreLevelForGroupItems(-$_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_' . $i . '_' . $j], $_SESSION['current_ohcttype'], $_POST['item_batch_no' . $i]);
}
}
} else {
//When nothing is returned from the form for the group items.. we use the calculated item qty from dressing item definitions
$result_for_group_items = getGroupItems(${"treatment_item$i"});
while ($row_for_group_items = mysqli_fetch_array($result_for_group_items)) {
$treatment_qty_given_by = '';
if ((($_SESSION['RoleCode'] == 'DIS') || in_array('DIS', explode(',', $_SESSION['RoleCode'])))) {
if (addslashes($row_for_group_items['qty']) == 0 || addslashes($row_for_group_items['qty']) == '' || addslashes($row_for_group_items['qty']) == null) {
$treatment_qty_given_by = $_SESSION['user_id'];
}
}
if ($stmt_query_treatment_dressing) {
$stmt_query_treatment_dressing->bind_param("ssssssss", $appointment_id, $row_for_group_items['group_id'], $followup_id, $row_for_group_items['item_id'], $row_for_group_items['qty'], $row_for_group_items['qty'], $_SESSION['user_id'], $treatment_qty_given_by);
$stmt_query_treatment_dressing->execute();
if ($stmt_query_treatment_dressing->errno) {
error_log("Error in updating dressing item treatment " . $stmt_query_treatment_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement " . $conn->error);
rollback();
}
if ($stmt_query_stock_history_dressing) {
$stmt_query_stock_history_dressing->bind_param("ssssss", $appointment_id, $followup_id, $row_for_group_items['qty'], $row_for_group_items['item_id'], $row_for_group_items['qty'], $treatment_qty_given_by);
$stmt_query_stock_history_dressing->execute();
if ($stmt_query_stock_history_dressing->errno) {
error_log("issues while updating appointment_stock_history: " . $stmt_query_stock_history_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement for stock history " . $conn->error);
rollback();
}
}
}
} //end for handling of dressing items
$treatment_qty_given_by = '';
if ((($_SESSION['RoleCode'] == 'DIS') || in_array('DIS', explode(',', $_SESSION['RoleCode'])))) {
if (addslashes($batch_stock) != 0 || addslashes($batch_stock) != '' || addslashes($batch_stock) != null) {
$treatment_qty_given_by = $_SESSION['user_id'];
}
}
if ($stmt_query_treatment) {
if (${"item_batch_no$i"} == null || empty(${"item_batch_no$i"})) {
${"item_batch_no$i"} = '';
}
$stmt_query_treatment->bind_param("sssssssssssss", $appointment_id, ${"treatment_item$i"}, ${"dose_qty$i"}, $followup_id, $batch_stock, ${"item_batch_no$i"}, ${"dosage$i"}, ${"treatment_item_days$i"}, ${"treatment_item_dosage$i"}, ${"timings$i"}, ${"treatment_item_dosage_category$i"}, $_SESSION['user_id'], $treatment_qty_given_by);
$stmt_query_treatment->execute();
if ($stmt_query_treatment->errno) {
error_log("Error Saving Treatment data for opd when dealing with multiple batches : " . $stmt_query_treatment->error);
rollback();
}
} else {
error_log("Error in preparing statement for treatment data " . $conn->error);
rollback();
}
error_log("query_treatment:3 " . $query_treatment);
$treatment_qty_given_by = '';
if ((($_SESSION['RoleCode'] == 'DIS') || in_array('DIS', explode(',', $_SESSION['RoleCode'])))) {
if (addslashes($batch_stock) != 0 || addslashes($batch_stock) != '' || addslashes($batch_stock) != null) {
$treatment_qty_given_by = $_SESSION['user_id'];
}
}
if ($stmt_query_stock_history) {
$stmt_query_stock_history->bind_param("sssssss", $appointment_id, ${"current_stock$i"}, ${"frequency_qty$i"}, ${"treatment_item$i"}, $batch_stock, $followup_id, $treatment_qty_given_by);
$stmt_query_stock_history->execute();
if ($stmt_query_stock_history->errno) {
error_log("issues while updating appointment_stock_history for opd when dealing with multiple batches :: " . $stmt_query_stock_history->error);
rollback();
}
} else {
error_log("Error in preparing statement for stock history " . $conn->error);
rollback();
}
error_log("query_stock_history: " . $query_stock_history);
if (${"group_child_flag_$i"} != '1')
updaterItemStock($_SESSION['current_ohcttype'], addslashes(${"treatment_item$i"}), $batch_stock, ${"item_batch_no$i"});
/*
* //$item_batch_no=getMinExpiaryDateItem($_SESSION['current_ohcttype'], addslashes(${"treatment_item$i"}));
* $current_stock_qty=getStockQtyAtDispensaryLevel(${"treatment_item$i"},$_SESSION['current_ohcttype']);
* // echo $current_stock_qty;
* $stock_qty = floatval ( $current_stock_qty ) - (floatval ( $batch_stock ));
* //echo $stock_qty;
* $current_stock_query = "update item_stock_dispensary set stock_qty='".$stock_qty."' where item_id='".${"treatment_item$i"}."' and item_batch_no='".$item_batch_no."' and ohc_location_id='".$_SESSION['current_ohcttype']."' ";
* // echo $current_stock_query;
* mysqli_query($conn,$current_stock_query );
*/
} else if ($isTreatmentOnly != 'Y' && ${"treatment_item_external$i"} != null && ${"treatment_item_external$i"} != "") {
if ($stmt_query_treatment_external) {
$stmt_query_treatment_external->bind_param("", $appointment_id, $followup_id, ${"treatment_item_external$i"}, ${"dose_qty$i"}, ${"timings$i"}, ${"treatment_item_dosage$i"}, ${"treatment_item_days$i"}, ${"treatment_item_dosage_category$i"}, $_SESSION['user_id']);
$stmt_query_treatment_external->execute();
if ($stmt_query_treatment_external->errno) {
error_log("Error in saving external treatment " . $stmt_query_treatment_external->error);
rollback();
}
} else {
error_log("Error in preparing the statement for external " . $conn->error);
rollback();
}
}
/////
$batches = getItemBatch(${"treatment_item$i"}, ${"item_batch_no$i"});
error_log("remaining batches " . print_r($batches, true));
error_log("size of array remaining batches " . sizeof($batches));
for ($b = 0; $b < sizeof($batches); $b++) {
if ($issued_qty > 0 && $batches[$b] != null && !empty($batches[$b]) && $batches[$b] != '') {
error_log('$issued_qty in while loop ' . $issued_qty);
$this_batch_stock = getBatchStock(${"treatment_item$i"}, $batches[$b]);
if ($issued_qty > $this_batch_stock) {
$remain = $issued_qty - $this_batch_stock;
} else {
$remain = 0;
}
$issue = $issued_qty - $remain;
error_log('remain ' . $issued_qty);
/////
error_log("treatment_item: in while loop for multiple batches start " . $i . ":" . ${"treatment_item$i"});
if (${"treatment_item$i"} != null && ${"treatment_item$i"} != "") {
// To Check Item is Dressing Or Not
$is_dressing_item = toCheckDressingItem(${"treatment_item$i"});
error_log("is_dressing_item:" . $is_dressing_item);
if ($is_dressing_item == 'P') {
if (${"group_child_flag_$i"} == '1') {
$result_for_group_items = getGroupItems(${"treatment_item$i"});
$no_rows_group_child = mysqli_num_rows($result_for_group_items);
error_log("no_rows_group_child:" . $no_rows_group_child);
for ($j = 0; $j < $no_rows_group_child; $j++) {
$treatment_given_by = '';
if (addslashes($_POST['child_item_qty_gvn' . $i . '_' . $j]) != 0 || addslashes($_POST['child_item_qty_gvn' . $i . '_' . $j]) != '' || addslashes($_POST['child_item_qty_gvn' . $i . '_' . $j]) != null) {
$treatment_given_by = $_SESSION['user_id'];
}
error_log("Child Item:" . $_POST['child_item_' . $i . '_' . $j]);
$group_item_id = getFieldFromTable('group_id', 'group_items', 'item_id', $_POST['child_item_' . $i . '_' . $j]);
error_log("group_item_id:" . $group_item_id);
error_log("childitem:" . $_POST['child_item_' . $i . '_' . $j]);
if ($stmt_query_treatment_dressing) {
$stmt_query_treatment_dressing->bind_param("ssssssss", $appointment_id, $group_item_id, $followup_id, $_POST['child_item_' . $i . '_' . $j], $_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_qty_gvn' . $i . '_' . $j], $_SESSION['user_id'], $treatment_given_by);
$stmt_query_treatment_dressing->execute();
if ($stmt_query_treatment_dressing->errno) {
error_log("Error in adding dressing item treatment " . $stmt_query_treatment_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement " . $conn->error);
rollback();
}
error_log("query_treatment:1 " . $query_treatment_dressing);
if ($stmt_query_stock_history_dressing) {
$stmt_query_stock_history_dressing->bind_param("ssssss", $appointment_id, $followup_id, $_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_' . $i . '_' . $j], $_POST['child_item_qty_gvn' . $i . '_' . $j], $treatment_given_by);
$stmt_query_stock_history_dressing->execute();
if ($stmt_query_stock_history_dressing->errno) {
error_log("issues while updating appointment_stock_history: " . $stmt_query_stock_history_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement for stock history " . $conn->error);
rollback();
}
error_log("query_stock_history: " . $query_stock_history_dressing);
// to update Dispensary Items
if ($_SESSION("RoleCode") == 'DIS' || in_array('DIS', explode(',', $_SESSION['RoleCode']))) {
resetItemStockAtDispensaryLevelForGroupItems(-$_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_' . $i . '_' . $j], $_SESSION['current_ohcttype']);
} else {
resetItemStockAtStoreLevelForGroupItems(-$_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_' . $i . '_' . $j], $_SESSION['current_ohcttype'], $_POST['item_batch_no' . $i]);
}
}
} else {
//When nothing is returned from the form for the group items.. we use the calculated item qty from dressing item definitions
$result_for_group_items = getGroupItems(${"treatment_item$i"});
while ($row_for_group_items = mysqli_fetch_array($result_for_group_items)) {
$treatment_qty_given_by = '';
if ((($_SESSION['RoleCode'] == 'DIS') || in_array('DIS', explode(',', $_SESSION['RoleCode'])))) {
if (addslashes($row_for_group_items['qty']) == 0 || addslashes($row_for_group_items['qty']) == '' || addslashes($row_for_group_items['qty']) == null) {
$treatment_qty_given_by = $_SESSION['user_id'];
}
}
if ($stmt_query_treatment_dressing) {
$stmt_query_treatment_dressing->bind_param("ssssssss", $appointment_id, $row_for_group_items['group_id'], $followup_id, $row_for_group_items['item_id'], $row_for_group_items['qty'], $row_for_group_items['qty'], $_SESSION['user_id'], $treatment_qty_given_by);
$stmt_query_treatment_dressing->execute();
if ($stmt_query_treatment_dressing->errno) {
error_log("Error in updating dressing item treatment " . $stmt_query_treatment_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement " . $conn->error);
rollback();
}
if ($stmt_query_stock_history_dressing) {
$stmt_query_stock_history_dressing->bind_param("ssssss", $appointment_id, $followup_id, $row_for_group_items['qty'], $row_for_group_items['item_id'], $row_for_group_items['qty'], $treatment_qty_given_by);
$stmt_query_stock_history_dressing->execute();
if ($stmt_query_stock_history_dressing->errno) {
error_log("issues while updating appointment_stock_history: " . $stmt_query_stock_history_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement for stock history " . $conn->error);
rollback();
}
}
}
} //end for handling of dressing items
$treatment_qty_given_by = '';
if ((($_SESSION['RoleCode'] == 'DIS') || in_array('DIS', explode(',', $_SESSION['RoleCode'])))) {
if (addslashes($batch_stock) != 0 || addslashes($batch_stock) != '' || addslashes($batch_stock) != null) {
$treatment_qty_given_by = $_SESSION['user_id'];
}
}
if ($stmt_query_treatment) {
if ($batches[$b] == null || empty($batches[$b])) {
$batches[$b] = '';
}
$stmt_query_treatment->bind_param("sssssssssssss", $appointment_id, ${"treatment_item$i"}, ${"dose_qty$i"}, $followup_id, $issue, $batches[$b], ${"dosage$i"}, ${"treatment_item_days$i"}, ${"treatment_item_dosage$i"}, ${"timings$i"}, ${"treatment_item_dosage_category$i"}, $_SESSION['user_id'], $treatment_qty_given_by);
$stmt_query_treatment->execute();
if ($stmt_query_treatment->errno) {
error_log("Error Saving Treatment data: " . $stmt_query_treatment->error);
rollback();
}
} else {
error_log("Error in preparing statement for treatment data " . $conn->error);
rollback();
}
error_log("query_treatment:3 " . $query_treatment);
$treatment_qty_given_by = '';
if ((($_SESSION['RoleCode'] == 'DIS') || in_array('DIS', explode(',', $_SESSION['RoleCode'])))) {
if (addslashes($batch_stock) != 0 || addslashes($batch_stock) != '' || addslashes($batch_stock) != null) {
$treatment_qty_given_by = $_SESSION['user_id'];
}
}
if ($stmt_query_stock_history) {
$stmt_query_stock_history->bind_param("sssssss", $appointment_id, $issue, ${"frequency_qty$i"}, ${"treatment_item$i"}, $batch_stock, $followup_id, $treatment_qty_given_by);
$stmt_query_stock_history->execute();
if ($stmt_query_stock_history->errno) {
error_log("issues while updating appointment_stock_history: " . $stmt_query_stock_history->error);
rollback();
}
} else {
error_log("Error in preparing statement for stock history " . $conn->error);
rollback();
}
error_log("query_stock_history: " . $query_stock_history);
if (${"group_child_flag_$i"} != '1')
updaterItemStock($_SESSION['current_ohcttype'], addslashes(${"treatment_item$i"}), $issue, $batches[$b]);
/*
* //$item_batch_no=getMinExpiaryDateItem($_SESSION['current_ohcttype'], addslashes(${"treatment_item$i"}));
* $current_stock_qty=getStockQtyAtDispensaryLevel(${"treatment_item$i"},$_SESSION['current_ohcttype']);
* // echo $current_stock_qty;
* $stock_qty = floatval ( $current_stock_qty ) - (floatval ( $batch_stock ));
* //echo $stock_qty;
* $current_stock_query = "update item_stock_dispensary set stock_qty='".$stock_qty."' where item_id='".${"treatment_item$i"}."' and item_batch_no='".$item_batch_no."' and ohc_location_id='".$_SESSION['current_ohcttype']."' ";
* // echo $current_stock_query;
* mysqli_query($conn,$current_stock_query );
*/
} else if ($isTreatmentOnly != 'Y' && ${"treatment_item_external$i"} != null && ${"treatment_item_external$i"} != "") {
if ($stmt_query_treatment_external) {
$stmt_query_treatment_external->bind_param("", $appointment_id, $followup_id, ${"treatment_item_external$i"}, ${"dose_qty$i"}, ${"timings$i"}, ${"treatment_item_dosage$i"}, ${"treatment_item_days$i"}, ${"treatment_item_dosage_category$i"}, $_SESSION['user_id']);
$stmt_query_treatment_external->execute();
if ($stmt_query_treatment_external->errno) {
error_log("Error in saving external treatment " . $stmt_query_treatment_external->error);
rollback();
}
} else {
error_log("Error in preparing the statement for external " . $conn->error);
rollback();
}
}
error_log("treatment_item: in while loop for multiple batches end " . $i . ":" . ${"treatment_item$i"});
/////
$issued_qty = $remain;
error_log('$issued_qty ' . $issued_qty);
}
}
} else {
/////
error_log("start treatment_item: if issued qty is less than available batch stocks qty" . $i . ":" . ${"treatment_item$i"});
if (${"treatment_item$i"} != null && ${"treatment_item$i"} != "") {
// To Check Item is Dressing Or Not
$is_dressing_item = toCheckDressingItem(${"treatment_item$i"});
error_log("is_dressing_item:" . $is_dressing_item);
if ($is_dressing_item == 'P') {
if (${"group_child_flag_$i"} == '1') {
$result_for_group_items = getGroupItems(${"treatment_item$i"});
$no_rows_group_child = mysqli_num_rows($result_for_group_items);
error_log("no_rows_group_child:" . $no_rows_group_child);
for ($j = 0; $j < $no_rows_group_child; $j++) {
$treatment_given_by = '';
if (addslashes($_POST['child_item_qty_gvn' . $i . '_' . $j]) != 0 || addslashes($_POST['child_item_qty_gvn' . $i . '_' . $j]) != '' || addslashes($_POST['child_item_qty_gvn' . $i . '_' . $j]) != null) {
$treatment_given_by = $_SESSION['user_id'];
}
error_log("Child Item:" . $_POST['child_item_' . $i . '_' . $j]);
$group_item_id = getFieldFromTable('group_id', 'group_items', 'item_id', $_POST['child_item_' . $i . '_' . $j]);
error_log("group_item_id:" . $group_item_id);
error_log("childitem:" . $_POST['child_item_' . $i . '_' . $j]);
if ($stmt_query_treatment_dressing) {
$stmt_query_treatment_dressing->bind_param("ssssssss", $appointment_id, $group_item_id, $followup_id, $_POST['child_item_' . $i . '_' . $j], $_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_qty_gvn' . $i . '_' . $j], $_SESSION['user_id'], $treatment_given_by);
$stmt_query_treatment_dressing->execute();
if ($stmt_query_treatment_dressing->errno) {
error_log("Error in adding dressing item treatment " . $stmt_query_treatment_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement " . $conn->error);
rollback();
}
error_log("query_treatment:1 " . $query_treatment_dressing);
if ($stmt_query_stock_history_dressing) {
$stmt_query_stock_history_dressing->bind_param("ssssss", $appointment_id, $followup_id, $_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_' . $i . '_' . $j], $_POST['child_item_qty_gvn' . $i . '_' . $j], $treatment_given_by);
$stmt_query_stock_history_dressing->execute();
if ($stmt_query_stock_history_dressing->errno) {
error_log("issues while updating appointment_stock_history: " . $stmt_query_stock_history_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement for stock history " . $conn->error);
rollback();
}
error_log("query_stock_history: " . $query_stock_history_dressing);
// to update Dispensary Items
if ($_SESSION("RoleCode") == 'DIS' || in_array('DIS', explode(',', $_SESSION['RoleCode']))) {
resetItemStockAtDispensaryLevelForGroupItems(-$_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_' . $i . '_' . $j], $_SESSION['current_ohcttype']);
} else {
resetItemStockAtStoreLevelForGroupItems(-$_POST['child_item_qty_gvn' . $i . '_' . $j], $_POST['child_item_' . $i . '_' . $j], $_SESSION['current_ohcttype'], $_POST['item_batch_no' . $i]);
}
}
} else {
//When nothing is returned from the form for the group items.. we use the calculated item qty from dressing item definitions
$result_for_group_items = getGroupItems(${"treatment_item$i"});
while ($row_for_group_items = mysqli_fetch_array($result_for_group_items)) {
$treatment_qty_given_by = '';
if ((($_SESSION['RoleCode'] == 'DIS') || in_array('DIS', explode(',', $_SESSION['RoleCode'])))) {
if (addslashes($row_for_group_items['qty']) == 0 || addslashes($row_for_group_items['qty']) == '' || addslashes($row_for_group_items['qty']) == null) {
$treatment_qty_given_by = $_SESSION['user_id'];
}
}
if ($stmt_query_treatment_dressing) {
$stmt_query_treatment_dressing->bind_param("ssssssss", $appointment_id, $row_for_group_items['group_id'], $followup_id, $row_for_group_items['item_id'], $row_for_group_items['qty'], $row_for_group_items['qty'], $_SESSION['user_id'], $treatment_qty_given_by);
$stmt_query_treatment_dressing->execute();
if ($stmt_query_treatment_dressing->errno) {
error_log("Error in updating dressing item treatment " . $stmt_query_treatment_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement " . $conn->error);
rollback();
}
if ($stmt_query_stock_history_dressing) {
$stmt_query_stock_history_dressing->bind_param("ssssss", $appointment_id, $followup_id, $row_for_group_items['qty'], $row_for_group_items['item_id'], $row_for_group_items['qty'], $treatment_qty_given_by);
$stmt_query_stock_history_dressing->execute();
if ($stmt_query_stock_history_dressing->errno) {
error_log("issues while updating appointment_stock_history: " . $stmt_query_stock_history_dressing->error);
rollback();
}
} else {
error_log("Error in preparing statement for stock history " . $conn->error);
rollback();
}
}
}
} //end for handling of dressing items
$treatment_qty_given_by = '';
if ((($_SESSION['RoleCode'] == 'DIS') || in_array('DIS', explode(',', $_SESSION['RoleCode'])))) {
if (addslashes(${"treatment_item_qtygvn$i"}) != 0 || addslashes(${"treatment_item_qtygvn$i"}) != '' || addslashes(${"treatment_item_qtygvn$i"}) != null) {
$treatment_qty_given_by = $_SESSION['user_id'];
}
}
if ($stmt_query_treatment) {
if (${"item_batch_no$i"} == null || empty(${"item_batch_no$i"})) {
${"item_batch_no$i"} = '';
}
$stmt_query_treatment->bind_param("sssssssssssss", $appointment_id, ${"treatment_item$i"}, ${"dose_qty$i"}, $followup_id, ${"treatment_item_qtygvn$i"}, ${"item_batch_no$i"}, ${"dosage$i"}, ${"treatment_item_days$i"}, ${"treatment_item_dosage$i"}, ${"timings$i"}, ${"treatment_item_dosage_category$i"}, $_SESSION['user_id'], $treatment_qty_given_by);
$stmt_query_treatment->execute();
if ($stmt_query_treatment->errno) {
error_log("Error Saving Treatment data for opd : " . $stmt_query_treatment->error);
rollback();
}
} else {
error_log("Error in preparing statement for treatment data " . $conn->error);
rollback();
}
error_log("query_treatment:3 " . $query_treatment);
$treatment_qty_given_by = '';
if ((($_SESSION['RoleCode'] == 'DIS') || in_array('DIS', explode(',', $_SESSION['RoleCode'])))) {
if (addslashes(${"treatment_item_qtygvn$i"}) != 0 || addslashes(${"treatment_item_qtygvn$i"}) != '' || addslashes(${"treatment_item_qtygvn$i"}) != null) {
$treatment_qty_given_by = $_SESSION['user_id'];
}
}
if ($stmt_query_stock_history) {
$stmt_query_stock_history->bind_param("sssssss", $appointment_id, ${"current_stock$i"}, ${"frequency_qty$i"}, ${"treatment_item$i"}, ${"treatment_item_qtygvn$i"}, $followup_id, $treatment_qty_given_by);
$stmt_query_stock_history->execute();
if ($stmt_query_stock_history->errno) {
error_log("issues while updating appointment_stock_history for opd: " . $stmt_query_stock_history->error);
rollback();
}
} else {
error_log("Error in preparing statement for stock history " . $conn->error);
rollback();
}
error_log("query_stock_history: " . $query_stock_history);
if (${"group_child_flag_$i"} != '1')
updaterItemStock($_SESSION['current_ohcttype'], addslashes(${"treatment_item$i"}), ${"treatment_item_qtygvn$i"}, ${"item_batch_no$i"});
/*
* //$item_batch_no=getMinExpiaryDateItem($_SESSION['current_ohcttype'], addslashes(${"treatment_item$i"}));
* $current_stock_qty=getStockQtyAtDispensaryLevel(${"treatment_item$i"},$_SESSION['current_ohcttype']);
* // echo $current_stock_qty;
* $stock_qty = floatval ( $current_stock_qty ) - (floatval ( $batch_stock ));
* //echo $stock_qty;
* $current_stock_query = "update item_stock_dispensary set stock_qty='".$stock_qty."' where item_id='".${"treatment_item$i"}."' and item_batch_no='".$item_batch_no."' and ohc_location_id='".$_SESSION['current_ohcttype']."' ";
* // echo $current_stock_query;
* mysqli_query($conn,$current_stock_query );
*/
} else if ($isTreatmentOnly != 'Y' && ${"treatment_item_external$i"} != null && ${"treatment_item_external$i"} != "") {
if ($stmt_query_treatment_external) {
$stmt_query_treatment_external->bind_param("sssssssss", $appointment_id, $followup_id, ${"treatment_item_external$i"}, ${"dose_qty$i"}, ${"timings$i"}, ${"treatment_item_dosage$i"}, ${"treatment_item_days$i"}, ${"treatment_item_dosage_category$i"}, $_SESSION['user_id']);
$stmt_query_treatment_external->execute();
if ($stmt_query_treatment_external->errno) {
error_log("Error in saving external treatment " . $stmt_query_treatment_external->error);
rollback();
}
} else {
error_log("Error in preparing the statement for external " . $conn->error);
rollback();
}
}
/////
error_log("end treatment_item: if issued qty is less than available batch stocks qty " . $i . ":" . ${"treatment_item$i"});
}
} else if ($isTreatmentOnly != 'Y' && ${"treatment_item_external$i"} != null && ${"treatment_item_external$i"} != "") {
if ($stmt_query_treatment_external) {
$stmt_query_treatment_external->bind_param("sssssssss", $appointment_id, $followup_id, ${"treatment_item_external$i"}, ${"dose_qty$i"}, ${"timings$i"}, ${"treatment_item_dosage$i"}, ${"treatment_item_days$i"}, ${"treatment_item_dosage_category$i"}, $_SESSION['user_id']);
$stmt_query_treatment_external->execute();
if ($stmt_query_treatment_external->errno) {
error_log("Error in saving external treatment " . $stmt_query_treatment_external->error);
rollback();
}
} else {
error_log("Error in preparing the statement for external " . $conn->error);
rollback();
}
}
}
}
}
if ($_REQUEST['ipd'] == 1 || $_REQUEST['ipd'] == '1') {
$reporting_time = $_POST['appointment_date'];
$is_detaind = getTableFieldValue('detention_master', 'id', 'opd_id', "'" . $appointment_id . "'");
if (isset($is_detaind)) {
$detention_master = 'update detention_master set reporting_time=STR_TO_DATE(?,"%d/%m/%Y %h:%i %p") ,opd_id=?,modified_by=? where opd_id="' . $appointment_id . '"';
} else {
$detention_master = 'insert into detention_master set reporting_time=STR_TO_DATE(?,"%d/%m/%Y %h:%i %p") ,opd_id=?,modified_by=? ';
}
$detention_master = 'insert into detention_master set reporting_time=STR_TO_DATE(?,"%d/%m/%Y %h:%i %p") ,opd_id=?,modified_by=? ';
error_log('Forward to detention ' . $detention_master);
$stmt_detention_master = $conn->prepare($detention_master);
if ($stmt_detention_master) {
$stmt_detention_master->bind_param("sss", $reporting_time, $appointment_id, $_SESSION['user_id']);
$stmt_detention_master->execute();
if ($stmt_detention_master->errno) {
error_log("Executing detention master sql " . $stmt_detention_master->error);
exit(error_log($conn->error));
}
} else {
error_log("Error in preparing the statement: " . $conn->error);
rollback();
exit(error_log($conn->error));
}
}
commit();
if ($stmt_detention_master != null) {
$stmt_detention_master->close();
}
if ($stmt_query_treatment_dressing != null) {
$stmt_query_treatment_dressing->close();
}
if ($stmt_query_stock_history_dressing != null) {
$stmt_query_stock_history_dressing->close();
}
if ($stmt_query_treatment != null) {
$stmt_query_treatment->close();
}
if ($stmt_query_stock_history != null) {
$stmt_query_stock_history->close();
}
if ($stmt_query_treatment_external != null) {
$stmt_query_treatment_external->close();
}
$data['followup_id'] = $followup_id;
$data['appointment_id'] = $appointment_id;
$data['referralMailFlag'] = $refferralMailFlag;
// error_log(print_r($data), true);
echo json_encode($data);
Reference in New Issue View Git Blame Copy Permalink