guochanhua/jcjyhr/app/zskk/controller/Patient.php

<?php
declare (strict_types=1);

namespace app\zskk\controller;

use app\common\controller\ZskkApiController;
use app\common\library\Gm;
use app\common\library\Handle;
use app\zskk\model\Mapping;
use think\Config;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use think\facade\Cache;
use think\facade\Db;
use think\Exception;
use think\facade\Log;
use Throwable;
use app\zskk\servies\PatientServies;

class Patient extends ZskkApiController
{

    /**
     * 后台初始化请求
     * @return void
     * @throws Throwable
     */
    public function addPatient(PatientServies $servies): void
    {
        set_time_limit(0);
        Db::startTrans();
        $params = $this->request->post();
        try{

//            var_dump($params['DATA']);die;
            $data = $servies->makeMappingData($params['DATA'],'DATA');
            $patientData = $data['PATIENT'];
            $medical = $data['MEDICAL_INFORMATION'];
            $application = $data['EXAM_APPLICATIONS'];
            $orders = $data['MEDICAL_ORDERS'];
            $exam = $data['EXAM_REPORTS'];
            $inspect = $data['INSPECT_REPORTS'];
            $diagnoses = $data['DIAGNOSES'];
            $mpiData = $servies->getMpi($patientData['ID_CARDNUM']);
            $mpiKey = $mpiData['MPI_KEY'] ?? '';
            $mpi = $mpiData['MPI'] ?? '';
            if(empty($mpiKey))
            {
                $mpiKey = Handle::makeMpiKey($patientData['ID_CARDNUM']);
                $mpi = Handle::makeMpi();
                $servies->saveMpi($mpi,$patientData['ID_CARDNUM'],$mpiKey);
            }
            // $patientCode = Handle::makePatientCode($medical['ORGCODE'],$medical['SERIESNUM']);
            $patientCode = Handle::makePatientCode($mpiKey, $medical['ORGCODE'],$medical['SERIESNUM']);
            $servies->savePatient($patientData,$mpi,$mpiKey,$patientCode);  //患者表patient
            $servies->saveMedical($medical,$mpiKey,$patientCode);  //medicalinformation表
            $servies->saveDiagnose($diagnoses,$patientCode);  //diagnoses表
            $servies->saveApplication($application,$mpiKey,$patientCode); //examapplication表
            $servies->saveOrders($orders,$mpiKey,$patientCode); // 检验医嘱表 返回检验申请单标识
            // $servies->saveExamReport($exam,$mpiKey,$patientCode,$application['EXAM_ITEMNAME_CODE']); //检查报告表
            $servies->saveExamReport($exam,$mpiKey,$patientCode); //检查报告表
            $servies->saveInspectReport($inspect,$mpiKey,$patientCode); // 检验报告表

            // 管理后台-医院医院数据-患者信息表
            $servies->saveHospitalPatient($mpiKey, $mpi, $patientCode, $patientData, $medical, $diagnoses, $orders, $application);

            $servies->updateMiddleStatus($params['middleId'],['status'=>3]);
            Db::commit();
        }catch (\Exception $e)
        {
            // 9
            $servies->updateMiddleStatus($params['middleId'],['status'=>9]);
            Db::rollback();
            $this->error($e->getMessage());
        }
        $this->success('', 'success');
    }

    /**
     * @throws ModelNotFoundException
     * @throws DataNotFoundException
     * @throws DbException
     */
    public function getPatientInfo(PatientServies $servies): void
    {
        $params = $this->request->post();
        $patientCode = $params['PATIENT_CODE'];
        $data = $servies->getPatient(['PATIENT_CODE'=>$patientCode]);
        $this->success('',$data);
    }

    public function getIdCard()
    {
        $params = $this->request->get();
        $id = $params['id_card'] ?? '';
        $id = 'xCldB8dASEqkHUWN2cSByZRbzQCIL7xgFYnHrL8ET0Y=';
        $mpiIdCard = Gm::decrypt(\think\facade\Config::get('gm.key'),$id);
        echo $mpiIdCard;
        $id = 'qrnDuZJDJm+dW/sYPSWahg==';
        $mpiIdCard = Gm::decrypt(\think\facade\Config::get('gm.key'),$id);
        echo $mpiIdCard;
    }

    /**
     * 上传检查数据
     */
    public function postExamInfo(PatientServies $servies): void
    {
//        try {
            $params = $this->request->post();
            $params = $this->getDecryptData($params['data']);
            if(empty($params))
            {
                $this->error('密文解析失败');
            }
            $params = $servies->makeMappingData($params,'0','postExamInfo');
//            Log::record('检查信息参数'.json_encode($params));
            $data = $servies->postExamInfo($params);
//        }catch (\Exception $e)
//        {
//            $this->error($e->getMessage());
//        }
        $this->success('success','');
    }
    /**
     * 上传检查数据
     */
    public function postExamReport(PatientServies $servies): void
    {
//        try {
            $params = $this->request->post();
            $params = $this->getDecryptData($params['data']);
            if(empty($params))
            {
                $this->error('密文解析失败');
            }
            $params = $servies->makeMappingData($params,'0','postExamReport');
//            Log::record('检查报告参数'.json_encode($params));
            $data = $servies->postExamReport($params);
//        }catch (\Exception $e)
//        {
//            $this->error($e->getMessage());
//        }
        $this->success('success',$data);
    }

    public function sendTestSms(PatientServies $servies): void
    {
        $params = $this->request->get();
        $data = $servies->sendYqSms($params['phone'],$params['idcard'],$params['institution']);
        $this->success('success',$data);
    }

    /**
     * 上传检验数据
     */
    public function postLabReport(PatientServies $servies): void
    {
//        try {
            $params = $this->request->post();
            $params = $this->getDecryptData($params['data']);
            if(empty($params))
            {
                $this->error('密文解析失败');
            }
            $params = $servies->makeMappingData($params,'0','postLabReport');
//            Log::record('检验报告参数'.json_encode($params));
            $data = $servies->postLabReport($params);
//            $data = $this->makeEncryptData($data);
//        }catch (\Exception $e)
//        {
//            $this->error($e->getMessage());
//        }
        $this->success('success',$data);
    }

    public function syncExams(PatientServies $servies)
    {
        $params = $this->request->post();
        if(empty($params))
        {
            $this->error('接口异常');
        }
        $data = $servies->syncExam($params);
        $this->success('success',$data);
    }
}