prolab-api/console/components/Pathology.php

<?php

namespace console\components;

use Yii;
use yii\base\Component;
use common\models\CaseSurgical;
use common\models\CaseNonGyn;
use common\models\CasePap;
use common\models\CaseFrozen;
use common\models\CaseFish;
use common\models\CaseDish;
use common\models\CaseAutopsy;
use common\models\CaseFlow;
use common\models\CaseMolecular;
use common\models\CaseNecropsy;
use common\models\CenterApprove;
use common\models\HospitalImport;
use common\models\SurgicalDiagnosis;
use common\models\CytoNonGynDiagnosis;
use common\models\CytoPapDiagnosis;
use common\models\FrozenDiagnosis;
use common\models\FishDiagnosis;
use common\models\DishDiagnosis;
use common\models\FlowDiagnosis;
use common\models\MolecularDiagnosis;
use common\models\AutopsyDiagnosis;
use common\models\NecropsyDiagnosis;


class Pathology extends Component
{

  /**
   * @param $id_case
   * @return false|string
   */
  public function getCaseType($id_case)
  {
    $case = substr($id_case, 0, 1);
    if ($case == 'S') {
      return 'surgical';
    }
    if ($case == 'C') {
      return 'non-gyn';
    }
    if ($case == 'P') {
      return 'pap';
    }
    if ($case == 'D') {
      return 'dish';
    }
    if ($case == 'A') {
      return 'autopsy';
    }
    if ($case == 'F') {
      return 'autopsy';
    }
    if ($case == 'M') {
      return 'molecular';
    }
    if ($case == 'Z') {
      return 'frozen';
    }

    return false;
  }

  /**
   * @param $id_case
   * @return CaseNonGyn|CasePap|CaseSurgical|void|null
   */
  public function getCase($id_case)
  {
    $case_type = $this->getCaseType($id_case);
    $params = [':id_case' => $id_case];
    if ($case_type === 'surgical') {
      // CaseSurgical::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_surgical WHERE id_case = :id_case", $params)->queryOne();
    }
    if ($case_type === 'non-gyn') {
      //return CaseNonGyn::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_non_gyn WHERE id_case = :id_case", $params)->queryOne();
    }
    if ($case_type === 'pap') {
      //return CasePap::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_pap WHERE id_case = :id_case", $params)->queryOne();
    }
    if ($case_type === 'frozen') {
      //return CaseFrozen::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_frozen WHERE id_case = :id_case", $params)->queryOne();
    }
    if ($case_type === 'fish') {
      //return CaseFish::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_fish WHERE id_case = :id_case", $params)->queryOne();
    }
    if ($case_type === 'dish') {
      //return CaseDish::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_dish WHERE id_case = :id_case", $params)->queryOne();
    }
    if ($case_type === 'autopsy') {
      //return CaseAutopsy::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_autopsy WHERE id_case = :id_case", $params)->queryOne();
    }
    if ($case_type === 'flow') {
      //return CaseFlow::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_fish WHERE id_case = :id_case", $params)->queryOne();
    }
    if ($case_type === 'molecular') {
      //return CaseMolecular::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_molecular WHERE id_case = :id_case", $params)->queryOne();
    }
    if ($case_type === 'necropsy') {
      //return CaseNecropsy::findOne(['id_case' => $id_case]);
      return Yii::$app->db->createCommand("SELECT * FROM case_necropsy WHERE id_case = :id_case", $params)->queryOne();
    }
  }

  /**
   * ส่งข้อมูลผลการตรวจไปยัง HIS
   *
   * @param integer $approve_id
   * @param string $id_case
   * @param integer $diagnosis_id
   * @return boolean
   */
  public function requestHisReport($approve_id, $id_case, $diagnosis_id)
  {
    $case_type = $this->getCaseType($id_case);
    $case = $this->getCase($id_case);

    //$release = CenterApprove::findOne($approve_id);
    $release = Yii::$app->db->createCommand("SELECT * FROM center_approve WHERE id = :id", [':id' => $approve_id])->queryOne();
    //$hospital_import = HospitalImport::find()->where(['id_case' => $case->id_case])->orderBy(['id' => SORT_DESC])->one();
    $hospital_import = Yii::$app->db->createCommand("SELECT * FROM hospital_import WHERE his_ln = :his_ln", [':his_ln' => $case['his_ln']])->queryOne();

    error_log($case['id_case']);
    //error_log(is_array($hospital_import) ? reset($hospital_import) : $hospital_import);
    ///var_dump($hospital_import);
    error_log($case['his_ln']);
    
    if ($case && isset($case['his_ln']) && isset($case['id_case']) && !empty($case['o_n'])) {
      $cytotech1 = null;
      $cytotech2 = null;

      if ($case_type == 'surgical') {
        //$diagnosis = SurgicalDiagnosis::findOne($diagnosis_id);
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM surgical_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        //$diagnosis_count = SurgicalDiagnosis::find()->where(['id_case' => $case->id_case])->count();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM surgical_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
      }
      if ($case_type == 'non-gyn') {
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM cyto_non_gyn_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM cyto_non_gyn_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
      }

      if ($case_type == 'pap') {
        //$diagnosis = CytoPapDiagnosis::findOne($diagnosis_id);
        //$diagnosis_count = CytoPapDiagnosis::find()->where(['id_case' => $case->id_case])->count();
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM cyto_pap_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM cyto_pap_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
        $cytotech1 = Yii::$app->db->createCommand("SELECT * FROM user_table WHERE id = :id", [':id' => $case['cytotech1_id']])->queryOne();
        $cytotech2 = Yii::$app->db->createCommand("SELECT * FROM user_table WHERE id = :id", [':id' => $case['cytotech2_id']])->queryOne();
      }
      if ($case_type == 'frozen') {
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM frozen_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM frozen_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
      }
      if ($case_type == 'dish') {
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM dish_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM dish_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
      }
      if ($case_type == 'fish') {
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM fish_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM fish_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
      }
      if ($case_type == 'flow') {
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM flow_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM flow_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
      }
      if ($case_type == 'molecular') {
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM molecular_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM molecular_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
      }
      if ($case_type == 'autopsy') {
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM autopsy_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM autopsy_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
      }
      if ($case_type == 'necropsy') {
        $diagnosis = Yii::$app->db->createCommand("SELECT * FROM necropsy_diagnosis WHERE id = :id", [':id' => $diagnosis_id])->queryOne();
        $diagnosis_count = Yii::$app->db->createCommand("SELECT count(*) FROM necropsy_diagnosis WHERE id_case = :id_case", [':id_case' => $case['id_case']])->queryScalar();
      }

      $title = Yii::$app->db->createCommand("SELECT * FROM patient_title WHERE id = :id", [':id' => $case['title_id']])->queryOne();

      if(isset($diagnosis['pathologist_id'])) {
        $appP = $diagnosis['pathologist_id'];
      }else if(isset($diagnosis['cytotech2_id'])){
        $appP = $diagnosis['cytotech2_id'];
      }else if(isset($diagnosis['cytotech1_id'])) {
        $appP = $diagnosis['cytotech1_id'];
      }
      if($appP){
        $approveBy = Yii::$app->db->createCommand("SELECT * FROM user_table WHERE id = :id", [':id' => $appP])->queryOne();
      }
      $releaseBy = Yii::$app->db->createCommand("SELECT * FROM user_table WHERE id = :id", [':id' => $release['release_by']])->queryOne();


      // Target URL for the POST request
      $targetUrl = 'http://172.16.64.22:3439/patho/pathoReport/result';

      // Data to be sent in the POST request
      $postData = [
        'cid' => str_replace('-', '', $case['id_card']),
        'title_code' => $title['code'],
        'first_name' => $case['given_name'],
        'last_name' => $case['surname'],
        'birthdate' => $case['birthdate'],
        'age' => $case['age'],
        'age_unit' => $case['age_unit'],
        'report_type' => $diagnosis['report_type'],
        'id_case' => $id_case,
        'ln' => $case['his_ln'],
        'o_n' => $case['o_n'],
        'approve_at' => isset($diagnosis['pathologist_at']) ? $diagnosis['pathologist_at'] : (isset($diagnosis['cytotech1_at']) ? $diagnosis['cytotech1_at'] : (isset($diagnosis['cytotech2_at']) ? $diagnosis['cytotech2_at'] : '')),
        'approve_by' => isset($diagnosis['pathologist_id']) ? $approveBy['code'] : (isset($diagnosis['cytotech1_id']) ? $cytotech1['code'] : (isset($diagnosis['cytotech2_id']) ? $cytotech2['code'] : '')),
        'release_at' => $release['release_at'],
        'release_by' => $releaseBy['code'],
        'sequence' => $diagnosis_count == 0 ? 1 : $diagnosis_count + 1,
        'link_all' => 'http://10.10.20.111/api/his/report-all?id_case=' . $case['id_case'],
        'link_report' => 'http://10.10.20.111/api/his/report-case?id_case=' . $case['id_case'] . '&report_type=' . $diagnosis['report_type'] . '&diagnosis_id=' . $diagnosis['id']
      ];

      // Custom headers for the request
      $headers = [
        'Content-Type: application/json', // Adjust the content type accordingly
        'Authorization: ' . Yii::$app->params['HISSecret'] . '' // Include any other headers you need
      ];

      $postDataJson = json_encode($postData);

      error_log('Send HIS Report');
      error_log($postDataJson);

      // Initialize cURL session
      $ch = curl_init();

      // Set cURL options
      curl_setopt($ch, CURLOPT_URL, $targetUrl);
      curl_setopt($ch, CURLOPT_POST, 1);
      curl_setopt($ch, CURLOPT_POSTFIELDS, $postDataJson); //http_build_query($postData));
      curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
      curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

      // Execute cURL session and get the response
      $response = curl_exec($ch);

      // Check for cURL errors
      if (curl_errno($ch)) {
        ///echo 'Curl error: ' . curl_error($ch);
        error_log('Curl error: ' . curl_error($ch));
        return false;
      }

      // Close cURL session
      curl_close($ch);

      // Process the response
      //echo $response;
      error_log($response);
      // Send HIS Report Log
      /*Yii::$app->db->createCommand("INSERT INTO send_his (approve_id, id_case, report_type, diagnosis_id, is_send, send_at, response) 
      VALUES (:approve_id, :id_case, :report_type, :diagnosis_id, :is_send, :send_at, :response)", [
        ':approve_id' => $approve_id,
        ':id_case' => $id_case,
        ':report_type' => $diagnosis['report_type'],
        ':diagnosis_id' => $diagnosis_id,
        ':is_send' => 1,
        ':send_at' => date('Y-m-d H:i:s'),
        ':response' => $response
      ])->execute();*/

      // Define your parameters
      $params = [
        ':approve_id' => $approve_id,
        ':id_case' => $id_case,
        ':report_type' => $diagnosis['report_type'],
        ':diagnosis_id' => $diagnosis_id
      ];

      // Additional parameters for the update/insert
      $updateParams = array_merge($params, [
        ':is_send' => 1,
        ':send_at' => date('Y-m-d H:i:s'),
        ':response' => $response,
      ]);

      // Check if the record exists
      $exists = Yii::$app->db->createCommand("
    SELECT COUNT(*) 
    FROM send_his 
    WHERE approve_id = :approve_id 
      AND id_case = :id_case 
      AND report_type = :report_type 
      AND diagnosis_id = :diagnosis_id
      AND is_send IS NULL", $params)
      ->queryScalar();

      if ($exists) {
        // Perform the update
        Yii::$app->db->createCommand("
        UPDATE send_his 
        SET 
            is_send = :is_send, 
            send_at = :send_at, 
            response = :response
        WHERE approve_id = :approve_id 
          AND id_case = :id_case 
          AND report_type = :report_type 
          AND diagnosis_id = :diagnosis_id
          AND is_send IS NULL", $updateParams)
          ->execute();
      } else {
        // Perform the insert
        Yii::$app->db->createCommand("
        INSERT INTO send_his 
            (approve_id, id_case, report_type, diagnosis_id, is_send, send_at, response) 
        VALUES 
            (:approve_id, :id_case, :report_type, :diagnosis_id, :is_send, :send_at, :response)", $updateParams)
          ->execute();
      }



      // Return true if the request was successful
      return true;
    }

    return false;
  }
}