<?php
namespace App\Controllers;

use CodeIgniter\RESTful\ResourceController;
use CodeIgniter\I18n\Time;

class API_Requests extends ResourceController {
	
	public function requests() {
		$db = \Config\Database::connect();
		$raw = $this->request->getVar();
		
		// log to cm_tm_logs
		$data = json_encode($raw);
		$sql = "INSERT INTO cmod.dbo.CM_TM_LOGS (URL, METHOD, BODY, LOGDATE) VALUES ('API/REQUESTS', 'POST', '$data', GETDATE())";
		$db->query($sql);
		
		$data = array();
		$qdata = (array)$raw;
		$qpat = (array)$qdata['patient'];
		
		//patdata
		$rm = $qpat['rm_number'];
		$firstname = $qpat['patient_first_name'];
		$lastname = $qpat['patient_last_name'];
		$dob = $qpat['patient_dob'];
		$sex = $qpat['patient_sex'];
		$phone = $qpat['patient_phone'];
		
		$sql = "select PATID from cmod.dbo.CM_TM_PATIENTS where PATNUMBER='$rm'";
		$query = $db->query($sql);
		$results = $query->getResultArray();
		if(!isset($results[0])) { 
			$sql = "INSERT INTO cmod.dbo.CM_TM_PATIENTS (PATNUMBER, FIRSTNAME, LASTNAME, BIRTHDATE, SEX, PHONE ) VALUES ('$rm', '$firstname', '$lastname', '$dob', '$sex', '$phone' )"; 
			$db->query($sql);
			$patid = $db->insertID();
		} else { 
			$patid = $results[0]['PATID'];
			$sql = "UPDATE cmod.dbo.CM_TM_PATIENTS SET FIRSTNAME='$firstname', LASTNAME='$lastname', BIRTHDATE='$dob', SEX='$sex', PHONE='$phone' where PATID='$patid'"; 
			$db->query($sql);
		}
		
		//reqdata
		$reffid = $qdata['reference_id'];
		$visitnum = $qpat['visit_number'];
		$visitdesc = $qpat['visit_description'];
		$visitdt = $qpat['visit_date_time'];
		$agent = $qpat['agent'];
		$agentname = $qpat['agent_name'];
		$visittype = $qpat['visit_type'];
		$company_name = $qdata['company_name'];
		$loc = $qdata['branch'];
		$doc = $qpat['treating_doctor'];
		$utcdt = $qdata['created'];
		$data['created'] = $utcdt;
		$time = Time::createFromFormat('Y-m-d\TH:i:s.u\Z', $utcdt, 'UTC');
		$time = $time->setTimezone('Asia/Shanghai');
		$orderdt = $time->toDateTimeString();	
		
		$sql = "select REQID from cmod.dbo.CM_TM_REQUESTS where REFFID='$reffid'";
		$query = $db->query($sql);
		$results = $query->getResultArray();
		if(!isset($results[0])) { 
			$sql = "INSERT INTO cmod.dbo.CM_TM_REQUESTS (REFFID, REQNUMBER, REQDESC, REQTYPE, REQDATE, AGENT, DOC, LOC, PATID, COMPANY, ISTAKEN) VALUES ('$reffid', '$visitnum', '$visitdesc', '$visittype', '$orderdt', '$agentname', '$doc', '$loc', '$patid', '$company_name', null )"; 
			$db->query($sql);
			$reqid = $db->insertID();
		} else { 
			$reqid = $results[0]['REQID'];
			$sql = "UPDATE cmod.dbo.CM_TM_REQUESTS SET REQNUMBER='$visitnum', REQDESC='$visitdesc', REQTYPE='$visittype', REQDATE='$orderdt', AGENT='$agentname', DOC='$doc', LOC='$loc', PATID='$patid' where REQID='$reqid'"; 
			$db->query($sql);
		}	
		
		// tests
		$tests = json_decode(json_encode($qpat['tests']), true);;
		$string = '';
		foreach($tests as $test) {
			$testcode = $test['service_id'];
			$testreffid = $test['test_ref_id'];
			if(isset($test['status'])) { $teststatus = $test['status'];}
			else { $teststatus = ''; }
			$string .= "( '$testreffid', '$reqid', '$testcode', '$teststatus' ),";
		}
		$string = rtrim($string, ',');
		//$sql = "INSERT INTO cmod.dbo.CM_TM_TESTS(REFFID, REQID, HISCODE) VALUES $string";
		$sql = "INSERT INTO cmod.dbo.CM_TM_TESTS (REFFTESTID, REQID, HISCODE, TESTSTATUS) 
			SELECT S.REFFTESTID, S.REQID, S.HISCODE, S.TESTSTATUS FROM ( VALUES $string ) AS S (REFFTESTID, REQID, HISCODE, TESTSTATUS)
			WHERE NOT EXISTS ( SELECT 1 FROM cmod.dbo.CM_TM_TESTS T WHERE T.REQID = S.REQID AND T.HISCODE = S.HISCODE );";
		$db->query($sql);

		$sql = "UPDATE cmod.dbo.CM_TM_TESTS SET TESTSTATUS = S.TESTSTATUS
			FROM cmod.dbo.CM_TM_TESTS T
			INNER JOIN ( VALUES $string ) AS S (REFFTESTID, REQID, HISCODE, TESTSTATUS)
			ON T.REQID = S.REQID AND T.HISCODE = S.HISCODE;";
		$db->query($sql);
		
		
		return $this->respond(201);
		/*
		if( $db->query($sql) )  {
			return $this->respond(201);
		} else {
			$response = [
				'errors' => $db->errors(), 'message' => 'Invalid Messages'
			];
	       return $this->fail($response , 409);
        }
		*/
	}
	
}