ris_dm/server/application/api/servies/exam/ExamService.php

<?php

namespace app\api\servies\exam;

use app\api\actions\ZskkCache;
use app\api\response\ZskkErrorResponse;
use app\api\servies\report\ReportService;
use app\api\servies\ZskkDefaultService;
use app\api\utils\UUIDUtils;
use app\api\validate\exam\ExamValidate;
use app\api\dao\exam\ExamDao;
use app\api\servies\common\CommonService;
use think\facade\Config;
use think\facade\Log;


/**
 * 后台控制器基类
 * 接口方法权限 必传参数 接口返回 错误抛出 通用参数处理
 */

class ExamService extends ZskkDefaultService {
    protected $logName = "ExamService";
    private $examDao = null;
    private $reportService = null;

    public function __construct(ExamDao $examDao,ReportService $reportService) {
      parent::__construct();
      $this->examDao = $examDao;
      $this->reportService = $reportService;
    }

    public function changeInsLogin($params,$token)
    {
        $user = $this->examDao->getCache($token);
        $user['institution_id'] = $params['institution_id'];
        $institution = $this->examDao->getInsInfo($user['institution_id']);
        $user['institution'] = $institution['name'];
        $rule = $this->examDao->getOtherRule(['doctor_id'=>$user['id'],'institution_id'=>$user['institution_id']],'rule_ids');
        if(empty($rule)){
            $rule = $user['doctor_role'];
        }else{
            $rule = explode(',',$rule);
        }
        $token = (time()+86400).rand(0,1000);
        $data = $this->setCache($token,$user);
        if(!$data){
            $this->throwError('token信息存储失败','0009');
        }
        $data = [
            'token'         =>  $token,
            'realname'      =>  $user['realname'],
            'is_admin'      =>  $user['is_admin'],
            'username'      =>  $user['username'],
            'institution'   =>  $user['institution'],
            'institution_id'=>  $user['institution_id'],
            'report_full'=>  $user['report_full'],
            'is_new_browser'=>  $institution['is_new_browser'],
            'department_name'   =>  $user['department'],
            'role'=> $rule,
            'message_push'  =>  $user['message_push'],
            'need_code'=> false,
            'user_id'       =>$user['id'],
            'is_auto_mode'  =>$institution['is_auto_mode'],
            'remote'        =>empty($institution['parent_institution']) ? '0' : '1'
        ];
        return $data;
    }

    public function getExamLIst($params,$token)
    {
        $user = $this->examDao->getCache($token);
        $arr = ['doctor_id'=>$user['id'],'doctor_name'=>$user['realname'],'institution_id'=>$user['institution_id']];
        if(($params['type'] ?? '') == 1)
        {
            //  ris
            $arr['type'] = 2;
        }else{
            // 小程序
            $arr['type'] = 1;
            $this->examDao->saveDoctorVisit($arr);
        }
        $report_where = '';
        if(empty($user))
        {
            $this->throwError('登陆信息失效,请重新进行登陆','0099');
        }
        $institutionId = $user['institution_id'];
        $fuzzyField = ['name','patient_num','accession_num'];
//        $fuzzyWhere = $this->getListFuzzyWhere($params,$fuzzyField);
        $fuzzyWhere = '';
        if(!empty($params['fuzzy_search']))
        {
            $fuzzy = $params['fuzzy_search'];
            $fuzzyWhere = "name = '$fuzzy' or patient_num = '$fuzzy' or accession_num = '$fuzzy' ";
        }
        // 获取具体筛选 where 条件
        $moreField  = ['exam_datetime','name','accession_num','patient_num','exam_class','exam_status','report_status','exam_project','application_department','name_fuzzy'];
        $moreWhere  = $this->getListSpecificWhere($params, $moreField);
        if($params['status'] == 3){
            $class_where = $this->examDao->getRemoteExamClass($user['exam_class']);
            // 发起了远程
//            $report_where = " report_status>3 and report_status != 11";
            $data  = $this->examDao->getRemoteExamList($institutionId, $fuzzyWhere, $moreWhere,$class_where, $params,$report_where);
        }else{
//            $ins = $this->examDao->getInsInfo($institutionId);
            $class_where = $this->examDao->getExamClass($user['exam_class']);
            $gradeWhere = [];
            if($user['doctor_grade'] == 1)
            {
                //管理级查看所有
            }elseif($user['doctor_grade'] == 2)
            {
                //科室级查看当前科室
                $depart = $this->examDao->getDoctorDepart($user['department_id']);
                $gradeWhere[] = ['application_department','in',$depart];
            }elseif($user['doctor_grade'] == 3)
            {
                //医生级查看当前医生的
                $name = $user['realname'];
                $gradeWhere = "application_doctor='$name'";
            }
//            if($ins['is_auto_mode'] == '0')
//            {
//                $data  = $this->examDao->getExamList($institutionId, $fuzzyWhere, $moreWhere,$class_where, $params,$report_where,$gradeWhere);
//
//            }else{
                if($user['is_admin'] == 1)
                {
                    //医院管理员 可以查看当前类型的所有
                    $data  = $this->examDao->getExamList($institutionId, $fuzzyWhere, $moreWhere,$class_where, $params,$report_where,$gradeWhere);
                }else{
                    //获取医生权限
                    $userId = $user['id'];
                    $doctor_class = $this->examDao->getDoctorClass($userId);
                    $data = [];
    //                写审确认  自己的+所有审、确认
    //                写审     自己的+所有审、确认
    //                写确认   自己的+所有审、确认
    //                审确认	  所有已写、审、确认
    //                审  	  所有已写、审、确认
    //                确认	  所有审、确认
    //                写	  自己的+确认
                    if(strpos($doctor_class, '2') !== false && (strpos($doctor_class, '3') !== false || strpos($doctor_class, '4') !== false)){
                        //既是写 又是审或者确认  获取自己的 + 所有已写、已审核、已完成的
                        $report_where = "doctor_sign='$userId' or doctor_sign='' or exam_status=7 or exam_status=8 or exam_status=12 or exam_status=9";
                        $data  = $this->examDao->getExamList($institutionId, $fuzzyWhere, $moreWhere,$class_where, $params,$report_where,$gradeWhere);
                    }
                    if(strpos($doctor_class, '2') === false && (strpos($doctor_class, '3') !== false || strpos($doctor_class, '4') !== false)){
                        //没有写权限但是 有审核权限或者确认权限  获取所有审、已完成的
                        $report_where = "exam_status=8 or exam_status=9";
                        if(strpos($doctor_class, '3') !== false)
                        {
                            //有审核权限  添加所有已写的
                            $report_where .= " or exam_status=7  or exam_status=12";
                        }
                        $data  = $this->examDao->getExamList($institutionId, $fuzzyWhere, $moreWhere,$class_where, $params,$report_where,$gradeWhere);
                    }
                    if(strpos($doctor_class, '2') !== false && strpos($doctor_class, '3') === false && strpos($doctor_class, '4') === false){
                        //只有写权限
                        $report_where = "doctor_sign='$userId' or doctor_sign='' or exam_status=9";
                        $data  = $this->examDao->getExamList($institutionId, $fuzzyWhere, $moreWhere,$class_where, $params,$report_where,$gradeWhere);
                    }
                    if(strpos($doctor_class, '1') !== false && strpos($doctor_class, '2') === false && strpos($doctor_class, '3') === false && strpos($doctor_class, '4') === false){
                        //只有临床权限
                        $report_where = '';
                        $data  = $this->examDao->getExamList($institutionId, $fuzzyWhere, $moreWhere,$class_where, $params,$report_where,$gradeWhere);
                    }
                }
//            }
            $custom_field = $data['custom_field'];
            $custom = [];
            if($custom_field !== '')
            {
                $field = explode(',',$custom_field);
                foreach ($field as $k=>$v)
                {
                    if(!(Config::get('ins_custom_field')[$v] ?? null))
                    {
                        continue;
                    }
                    $custom[$k]['props'] = $v;
                    $custom[$k]['name'] = Config::get('ins_custom_field')[$v];
                }
            }
            $data['custom_field'] = $custom;
        }
        foreach ($data['list'] as $k=>$v)
        {
            $data['list'][$k]['insConfig'] = '';
            if(!empty($v['patient_source']))
            {
                $sourceArr = Config::get('patient_source');
                $sourceInfo = $sourceArr[$v['patient_source']] ?? [];
                if(!empty($sourceInfo))
                {
                    $data['list'][$k]['insConfig'] = $sourceInfo['name'];
                }
            }
        }
        return $data;
    }

    public function getRemoteLIst($params,$token)
    {
        $institutionId = $this->examDao->getInstitution($token);
        $data = $this->examDao->getRemoteList($params['examId'],$institutionId);
        return $data;
    }

    public function saveExam($params)
    {
        $id = $this->examDao->checkIsSet($params['study_id']);
        if($id){
            //存在则修改
            $update = ['exam_status'=>'3','updatedAt'=>date('Y-m-d H:i:s',time())];
            $this->examDao->updateExam($id,$update);
        } else {
            //不存在则创建
            $data = [
                'id'=>UUIDUtils::uuid(),
                'patient_id'=>$params['patient_id'],
                'study_id'=>$params['study_id'],
                'accession_num'=>$params['accession_num'],
                'studyuid'=>$params['studyuid'],
                'birthday'=>$params['birthday'] ?? '',
                'exam_datetime'=>$params['exam_datetime'],
                'exam_class'=>$params['exam_class'],
                'body_part'=>$params['body_part'],
                'institution_id'=>$params['institution_id'],
                'device_name'=>$params['device_name'],
                'patient_num'=>$params['patient_num'],
                'createdAt'=>date('Y-m-d H:i:s',time()),
                'exam_status'=>3
            ];
            $this->examDao->insertExam($data);
            $id = $data['id'];
        }
        return $id;
    }

    public function getReport($params,$doctor)
    {
        $search  = $params['fuzzy_search'] ?? null;
        if(empty($search))
        {
            $this->throwError('无效的请求参数，请求不能为空','0012');
        }
        $field = ['impression','description'];
        $where = $this->getListFuzzyWhere($params,$field);
        $report = $this->examDao->getReport($where,$doctor['institution_id']);
        foreach ($report as $k=>$v)
        {
            $replace = "<span style='color:red'>$search</span>";
            $report[$k]['impression'] = str_replace($search,$replace,$v['impression']);
            $report[$k]['description'] = str_replace($search,$replace,$v['description']);
        }
        return $report;
    }

    public function changeDoctor($params,$doctor)
    {
        if($doctor['is_admin'] !== '1')
        {
            $this->throwError('非管理员无法分配');
        }
        $info = $this->examDao->changeDoctor($params['doctor'],$params['exam_id']);
        return $info;
    }

    public function getFilmAnnex($id,$exam_datetime,$code)
    {
        $data = $this->examDao->getFilmAnnex($id,$exam_datetime,$code);
        return $data;
    }

    public function del_exam($params,$token)
    {
        $user = $this->getCache($token);
        $result = $this->reportService->reportAuthentication($user['id'],'del',$user['institution_id'],2);
        if(!$result){
            $this->throwError('权限未分配，请联系管理员',0005);
        }
        $data = [
            'doctor_id'=>$user['id'],
            'exam_id'=>$params['id'],
            'study_id'=>$params['study_id']
        ];
        $this->examDao->insertDcmDel($data);
        $data = $this->examDao->del_exam($params['id']);
        $study = $params['study_id'];
        $institution = $params['institution_id'];
        $query = Config::get('query_url');
        $url = $query."/delete/study?key=ZSKK_DELETE&address=&study_id=$study&institution_id=$institution";
        $this->curl_get_time1($url);
        return $data;
    }

    function curl_get_time1($url){
        $header = array(
            'Accept: application/json',
        );
        $curl = curl_init();
        //设置抓取的url
        curl_setopt($curl, CURLOPT_URL, $url);
        //设置头文件的信息作为数据流输出
        curl_setopt($curl, CURLOPT_HEADER, 0);
        // 超时设置，以秒为单位
         curl_setopt($curl, CURLOPT_TIMEOUT, 1);
        // 设置请求头
        curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
        //设置获取的信息以文件流的形式返回，而不是直接输出。
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
        //执行命令
        $data = curl_exec($curl);
        return $data;
    }

    public function getSyncAi($params)
    {
        $where[] = ['exam_id','in',explode(',',$params['exam_id'])];
        $ids = $this->examDao->getSyncAi($where);
        return $ids;
    }

    public function getAiNode($params)
    {
        if(empty($params['study_id'] ?? ''))
        {
            return [];
        }
        $where = ['study_id'=>$params['study_id']];
        $node = $this->examDao->getAiNode($where);
        if(empty($node))
        {
            return [];
        }
        return $node;
    }

    public function getHistory($params)
    {
        $id = $params['id'] ?? '';
        if(empty($id))
        {
            $this->throwError('参数错误，请联系管理员','0013');
        }
        $exam = $this->examDao->getExamData($id);
        if(empty($exam))
        {
            $this->throwError('参数错误，请联系管理员','0014');
        }
        $ins = $this->examDao->getInsInfo($exam['institution_id']);
        if(empty($ins['interconnected_exam_ins']))
        {
            $insIds = $exam['institution_id'];
        }else{
            $insIds = explode(',',$ins['interconnected_exam_ins']);
            $insIds[] = $exam['institution_id'];
        }
        if(empty($ins['interconnected_ins_field']))
        {
            $interconnected_ins_field = ['phone','card_num'];
        }else{
            $interconnected_ins_field = explode(',',$ins['interconnected_ins_field']);
        }

        $where = [];
        foreach ($interconnected_ins_field as $v)
        {
            if(!empty($exam[$v]))
            {
                $where[$v] = $exam[$v];
            }
        }

        $data = $this->examDao->getHistoryList($exam['institution_id'],$insIds,$where,$params,$exam['id']);
        $custom_field = $data['custom_field'];
        $custom = [];
        if($custom_field !== '')
        {
            $custom[] = ['props'=>'local','name'=>'本院标识'];
            $custom[] = ['props'=>'institution_name','name'=>'医院名称'];
            $field = explode(',',$custom_field);
            foreach ($field as $k=>$v)
            {
                if(!(Config::get('ins_custom_field')[$v] ?? null))
                {
                    continue;
                }
                $custom[] = ['props'=>$v,'name' => Config::get('ins_custom_field')[$v]];
            }
        }
        $data['custom_field'] = $custom;
        return $data;
    }
}