yuanchengpasc/application/inter/controller/Application.php

<?php
namespace app\inter\controller;

use think\Controller;
use think\Db;
use think\Session;
use app\common\library\UUIDs;
use think\Cache;
use think\Log;
use app\common\library\Verify;
use think\File;
use app\common\library\send_message;
class Application extends Base
{
    /**
 * 发起远程申请
 *
 * @ApiTitle            (发起远程申请)
 * @ApiSummary          (发起远程申请)
 * @ApiSector           (远程诊断)
 * @ApiMethod           (POST)
 * @ApiRoute            (/inter/application/index)
 * @ApiHeaders        (name="sign", type="string", required=true, description="请求头-校验key")
 * @ApiHeaders        (name="nonce", type="string", required=true, description="请求头-随机数")
 * @ApiHeaders        (name="timestamp", type=string, required=true, description="请求头-时间戳s")
 * @ApiParams         (name="sessionid",                 type="string",      required=true,      description="参数json字符串")
 * @ApiParams         (name="param",                     type="string",      required=true,      description="参数json字符串")
 * @ApiParams         (name="is_remote",                 type="string",      required=true,      description="参数json字符串")
 * @ApiParams         (name="param[id]",                  type="string",      sample="",          description="预约登记exams表id值<必填>")
 * @ApiReturnParams   (name="status",                      type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
 * @ApiReturnParams   (name="code",                      type="integer",     required=true,      sample="0", description="返回状态码")
 * @ApiReturnParams   (name="info",                       type="string",      required=true,      sample="返回成功", description="返回信息")
 * @ApiReturnParams   (name="is_remote",                      type="object",      sample="{}",        description="是否为远程诊断进入")
 * @ApiReturnParams   (name="sessionid",                      type="object",      sample="{}",        description="缓存的数据key")
 * @ApiReturn   (data="
{
'status': ok,
'code': '0000',
'sessionid': 'a17z7a7a8f9g9rh9d89jio',
'is_remote': 1,
'info' : ''
}
 *")
 **/
    public function  index(){
        try{
            $sessionid = $_REQUEST['sessionid'];
            $param = $_REQUEST['param'];
            $id = $param['id'];
            $is_remote = 0;
            if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote']==1){
                $is_remote = 1;
            }
            $info = DB::table('exams')->where('id',$id)->field('id,study_id,patient_id,register_datetime,exam_class,exam_sub_class,exam_project,device,exam_datetime,exam_status')->find();
            $exam_class = DB::table('constant')->where('id',$info['exam_class'])->field('constant_value')->find();
            $exam_subclass = DB::table('exam_subclass')->where('id',$info['exam_sub_class'])->cache(300)->find();
            $exam_project = DB::table('exam_project')->where('id',$info['exam_project'])->cache(300)->find();
            $device = DB::table('device')->where('id',$info['device'])->cache(300)->find();
            $info['exam_class_name'] = $exam_class['constant_value'];
            $info['exam_subclass_name'] = $exam_subclass['name'];
            $info['exam_project_name'] = $exam_project['name'];
            $info['device_name'] = $device['name'];
            $patient_info = DB::table('patient_infos')->where('id',$info['patient_id'])->field(['temp_patient_id','id','name','sex','age','birthday'])->find();
            $info['pid'] = $patient_info['id'];
            $info['temp_patient_id'] = $patient_info['temp_patient_id'];
            $info['name'] = $patient_info['name'];
            $info['sex'] = $patient_info['sex'];
            $info['age'] = $patient_info['age'];
            if(!empty($patient_info['birthday'])){
                $info['birthday'] = $patient_info['birthday'];
            }
            $doctor = Cache::get($sessionid);
            $institution_id = $doctor['institution_id'];
            $hospital = DB::table('institution')->where('id',$institution_id)->find();
            $parent_hosp = explode(',',$hospital['parent_institution']);
            $parent_name = array();
            foreach($parent_hosp as $v){
                $phname = DB::table("institution")->where('id',$v)->cache(300)->field(['id','name'])->find();
                $doctor_info = DB::table('doctors')->where('institution_id',$v)->field('id,realname')->select();
                $phname['doctor'] = $doctor_info;
                $parent_name[] =$phname;
            }
            $info['parent_hospital'] = $parent_name;
            //申请信息
            $application = DB::table('remote_application')->where('exam_id',$id)->field(['remote_doctor_id','application_desc','attachment','req_doctor_id','illness_desc','phys_sign','clin_symp','anamnesis','family_ill','remark','clin_diag'])->find();
            if($is_remote == 1){
                //远程申请点击进入
                $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'])->field('department_id')->find();
                $dep = DB::table('department')->where('id',$dinfo['department_id'])->field('department_name')->find();
            }else{
                //本地远程申请中
                $dep = DB::table('department')->where('id',$doctor['department_id'])->field('department_name')->find();
            }
            $info['department_name'] = $dep['department_name'];
            if(empty($application)){
                $exam_application = DB::table('exams')->where('id',$id)->field(['illness_desc','phys_sign','clin_symp','remark','clin_diag','anamnesis','family_ill'])->find();
                $exam_application['anamnesis'] = explode(',',$exam_application['anamnesis']);
                $exam_application['family_ill'] = explode(',',$exam_application['family_ill']);
                $info['application'] = $exam_application;
            }else{
                $remote_name = DB::table('doctors')->where('id',$application['remote_doctor_id'])->field('realname')->find();
                $application['remote_doctor'] = $remote_name['realname'];
                $application['anamnesis'] = explode(',',$application['anamnesis']);
                $application['family_ill'] = explode(',',$application['family_ill']);
                $info['application'] = $application;
            }
            return json_encode(['status'=>'ok','code'=>'0000','info'=>$info,'sessionid'=>$sessionid,'is_remote'=>$is_remote]);
        }catch(\Exception $e){
            return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
        }
    }

    /**
     *  提交申请
     *
     * @ApiTitle            (提交申请)
     * @ApiSummary          (提交申请)
     * @ApiSector           (远程诊断)
     * @ApiMethod           (POST)
     * @ApiRoute            (/inter/application/apply)
     * @ApiHeaders        (name="sign", type="string", required=true, description="请求头-校验key")
     * @ApiHeaders        (name="nonce", type="string", required=true, description="请求头-随机数")
     * @ApiHeaders        (name="timestamp", type=string, required=true, description="请求头-时间戳s")
     * @ApiParams         (name="sessionid",                  type="string",      required=true,      description="参数json字符串")
     * @ApiParams         (name="param",                      type="string",      required=true,      description="参数json字符串")
     * @ApiParams         (name="param[id]",                   type="string",      sample="",          description="预约登记exams表id值<必填>")
     * @ApiParams         (name="param[illness]",              type="string",      sample="",          description="主诉<选填>")
     * @ApiParams         (name="param[clin_symp]",            type="string",      sample="",          description="临床症状<选填>")
     * @ApiParams         (name="param[anamnesis]",            type="string",      sample="",          description="既往史<选填>")
     * @ApiParams         (name="param[family_ill]",           type="string",      sample="",          description="家族史<选填>")
     * @ApiParams         (name="param[remark]",               type="string",      sample="",          description="备注<选填>")
     * @ApiParams         (name="param[institution_id]",       type="string",      sample="",          description="发起申请医院id值<选填>")
     * @ApiParams         (name="param[clin_diag]",            type="string",      sample="",          description="临床诊断<选填>")
     * @ApiParams         (name="param[remote_institution]",   type="string",      sample="",          description="申请的目标医院id值<选填>")
     * @ApiParams         (name="param[is_urgent]",            type="string",      sample="",          description="是否急诊 0否  1是<选填>")
     * @ApiParams         (name="param[description]",          type="string",      sample="",          description="申请描述<选填>")
     * @ApiParams         (name="param[remote_doctor_id]",     type="string",      sample="",          description="申请的目标医生id值<选填>")
     * @ApiParams         (name="param[attachment]",           type="string",      sample="",          description="附件<选填>")
     * @ApiParams         (name="param[apply]",                type="string",      sample="",          description="保存或者申请 存在值即保存 不存在则为申请<必填>")
     * @ApiReturnParams   (name="status",                     type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
     * @ApiReturnParams   (name="code",                       type="integer",     required=true,      sample="0", description="返回状态码")
     * @ApiReturnParams   (name="sessionid",                      type="object",      sample="{}",        description="缓存的数据key")
     * @ApiReturn   (data="
    {
    'status': ok,
    'code': '0000',
    'sessionid': 'a17z7a7a8f9g9rh9d89jio'
    }
     *")
     **/
    public function apply(){
        try{
            log::record($_REQUEST);
            $sessionid = $_REQUEST['sessionid'];
            $doctor = Cache::get($sessionid);
            //  远程申请权限 6
            $return  = Verify::check_role($sessionid,6);
            if($return != 1){
                return json_encode(['status'=>'fail','code'=>'1029','msg'=>'没有操作权限']);
            }
            $param = $_REQUEST['param'];
            $exam_info =  DB::table('exams')->where('id',$param['id'])->field('exam_status,patient_id')->find();
            // 修改病人姓名
            DB::table('patient_infos')->where('id',$exam_info['patient_id'])->update(['name'=>$param['name']]);
            if($exam_info['exam_status'] != 3 && $exam_info['exam_status'] != 5 && $exam_info['exam_status'] != 8){
                // 3 检查完毕 5已驳回
                switch($exam_info['exam_status']){
                    case 1:
                        $msg = '患者还未检查，请检查完毕后再进行远程申请';
                        break;
                    case 2:
                        $msg = '影像未到达，不能发起远程申请';
                        break;
                    case 4:
                        $msg = '已经发起了远程申请，请勿重复操作';
                        break;
                    case 9:
                        $msg = '';
                        break;
                    default:
                        $msg = '医师已经接受该远程申请，请耐心等待';
                        break;
                }
                 return json_encode(['status'=>'fail','code'=>'1029','msg'=>$msg]);
            }
            Verify::applicationCheck($param);
            $application_info = array();
            $application_info['exam_id'] = isset($param['id']) ? $param['id'] : '';
            $application_info['illness_desc'] = isset($param['illness']) ? $param['illness'] : '';
            $application_info['phys_sign'] = isset($param['phys_sign']) ? $param['phys_sign'] : '';
            $application_info['clin_symp'] = isset($param['clin_symp']) ? $param['clin_symp'] : '';
            if(!empty($param['anamnesis'])){
                $application_info['anamnesis'] = implode(',',$param['anamnesis']);
            }
            if(!empty($param['family_ill'])){
                $application_info['family_ill'] = implode(',',$param['family_ill']);
            }
            $application_info['remark'] = isset($param['remark']) ? $param['remark'] : '';
            $application_info['local_institution_id'] = $doctor['institution_id'];
            $application_info['req_date_time'] = date('Y-m-d H:i:s',time());
            $application_info['clin_diag'] = isset($param['clin_diag']) ? $param['clin_diag'] : '';
            $application_info['remote_institution_id'] = isset($param['remote_institution']) ? $param['remote_institution'] : '';
            if(isset($param['is_urgent']) && $param['is_urgent'] == 'true' ){
                $application_info['is_urgent'] = 1;
            }else{
                $application_info['is_urgent'] = 0;
            }
            $application_info['application_desc'] = isset($param['description']) ? $param['description'] : '';
            $application_info['req_doctor_id'] = $doctor['id'];
            $application_info['remote_doctor_id'] = isset($param['remote_doctor_id']) ? $param['remote_doctor_id'] : '';
            $application_info['attachment'] = isset($param['attachment']) ? $param['attachment'] : '';
            $remote_application = DB::table('remote_application')->where('exam_id',$param['id'])->select();
            // 申请远程
            if(empty($remote_application)){
                log::record('新增远程申请');
                $application_info['id'] = UUIDs::uuid16();
                $application_info['createdAt'] = date('Y-m-d H:i:s',time());
                DB::table('remote_application')->insert($application_info);
                $aid = $application_info['id'];
                $report = array();
                $report['id'] = UUIDs::uuid16();
                $report['exam_id'] = $param['id'];
                DB::table('report')->insert($report);
            }else{
                log::record('修改远程申请');
                DB::table('remote_application')->where('exam_id',$param['id'])->update($application_info);
                $r = DB::table('remote_application')->where('exam_id',$param['id'])->field('id')->find();
                $aid = $r['id'];
            }
            if(isset($param['apply']) && !empty($param['apply'])){
                //保存  申请
                DB::table('exams')->where('id',$param['id'])->update(['exam_status'=>4,'updatedAt'=>date('Y-m-d H:i:s',time())]);
                if(isset($param['remote_doctor_id']) && $param['remote_doctor_id'] == 'c44663d6d3c0b535'){
                    $dinfo = DB::table('doctors')->where('id',$param['remote_doctor_id'])->find();
                    $d_phone = $dinfo['phone'];
                    $d_name = '';
                    $d_time = date('H:i',strtotime('+1 hour'));
                    $repsone = send_message::sendSms2Apply($d_phone,$d_time,$d_name);
                    // 申请医院院名
                    $x_institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
                    $s_institution = DB::table('institution')->where('id',$param['remote_institution'])->field('name')->find();
                    $tel = '18910184804';
                    $type = '发起申请';
                    $content  = $x_institution['name'].'医院的'.$doctor['realname'].'医生向上级'.$s_institution['name'].'医院的'.$dinfo['realname'].'医生发起了申请，该申请于'.date('H:i',strtotime('+1 hour')).'过期，单子的申请单id是'.$aid;
                    send_message::sendSms2Self($tel,$type,$content);
                }
            }
            return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
        }catch(\Exception $e){
            return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
        }
    }


    /**
     * 上传附件
     *
     * @ApiTitle            (上传附件)
     * @ApiSummary          (上传附件)
     * @ApiSector           (远程诊断)
     * @ApiMethod           (POST)
     * @ApiRoute            (/inter/application/upload)
     * @ApiHeaders        (name="sign", type="string", required=true, description="请求头-校验key")
     * @ApiHeaders        (name="nonce", type="string", required=true, description="请求头-随机数")
     * @ApiHeaders        (name="timestamp", type=string, required=true, description="请求头-时间戳s")
     * @ApiParams         (name="sessionid",                 type="string",      required=true,      description="参数json字符串")
     * @ApiParams         (name="file",                     type="string",      required=true,      description="上传的文件<必填>")
     * @ApiReturnParams   (name="status",                      type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
     * @ApiReturnParams   (name="code",                      type="integer",     required=true,      sample="0", description="返回状态码")
     * @ApiReturnParams   (name="info",                       type="string",      required=true,      sample="返回成功", description="返回信息")
     * @ApiReturn   (data="
    {
    'status': ok,
    'code': '0000',
    'info' : '/upload/20180101/12346asd.jpg'
    }
     *")
     **/
    //上传附件
    public function upload(){
        // 获取表单上传文件 例如上传了001.jpg
        $file = request()->file('file');
        log::record('----------上传的文件-----------');
        log::record($file);
        // 移动到框架应用根目录/public/uploads/ 目录下
        if($file){
            $info = $file->move(ROOT_PATH . 'public' . DS . 'uploads');
            log::record($info);
            if($info){
                return json_encode(['status'=>'ok','code'=>'0000','info'=>'/'.$_SERVER["SERVER_NAME"]. '/' . 'uploads'. '/' .$info->getSaveName()]);
            }else{
                // 上传失败获取错误信息
                return json_encode(['status'=>'fail','code'=>'1040','info'=>$file->getError()]);
            }
        }
    }


    /**
     * 远程申请驳回
     *
     * @ApiTitle            (远程申请驳回)
     * @ApiSummary          (远程申请驳回)
     * @ApiSector           (远程诊断)
     * @ApiMethod           (POST)
     * @ApiRoute            (/inter/application/reject)
     * @ApiHeaders        (name="sign", type="string", required=true, description="请求头-校验key")
     * @ApiHeaders        (name="nonce", type="string", required=true, description="请求头-随机数")
     * @ApiHeaders        (name="timestamp", type=string, required=true, description="请求头-时间戳s")
     * @ApiParams         (name="sessionid",                 type="string",      required=true,      description="参数json字符串")
     * @ApiParams         (name="param",                        type="string",      required=true, sample="",          description="参数json字符串，预约登记exams表id值<必填>")
     * @ApiParams         (name="param[id]",                  type="string",      sample="",          description="预约登记exams表id值<必填>")
     * @ApiParams         (name="param[description]",                  type="string",      sample="",          description="驳回原因<必填>")
     * @ApiReturnParams   (name="status",                      type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
     * @ApiReturnParams   (name="code",                      type="integer",     required=true,      sample="0", description="返回状态码")
     * @ApiReturnParams   (name="sessionid",                      type="object",      sample="{}",        description="缓存的数据key")
     * @ApiReturn   (data="
    {
    'status': ok,
    'code': '0000',
    'sessionid': 'a17z7a7a8f9g9rh9d89jio'
    }
     *")
     **/
    //驳回 7
    public function reject(){
        $sessionid = $_REQUEST['sessionid'];
        $doctor = Cache::get($sessionid);
        $param = $_REQUEST['param'];
        $id = $param['id'];
        $report = DB::table('report')->where('exam_id',$id)->field('id,report_doctor_id')->find();
        $info = array();
        $info['id'] = UUIDs::uuid16();
        $info['report_id'] = $report['id'];
        $info['description'] = $param['description'];
        $info['createdAt'] = date('Y-m-d H:i:s',time());
        $info['type'] = 4;
        $info['doctor_id'] = $doctor['id'];
        DB::table('report_record')->insert($info);
        $message = array();
        $message['id'] = UUIDs::uuid16();
        $message['title'] = '申请单驳回';
        $message['content'] = $param['description'];
        $message['createdAt'] = date('Y-m-d H:i:s',time());
        $application = DB::table('remote_application')->where('exam_id',$id)->find();
        $message['doctor_id'] = $application['req_doctor_id'];
        $message['institution_id'] = $application['local_institution_id'];
        DB::table('exams')->where('id',$id)->update(['exam_status'=>5]);
        // 驳回发短信
        if($application['req_doctor_id'] == 'c44663d6d3c0b535'){
            $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'])->find();
            $d_phone = $dinfo['phone'];
            $repsone = send_message::sendSms2RejectApply($d_phone,$param['description']);
            // 上级医院
            $s_institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
            //下级医院
            $x_institution = DB::table('institution')->where('id',$application['local_institution_id'])->field('name')->find();
            $x_name = DB::table('doctors')->where('id',$application['req_doctor_id'])->field('realname')->find();
            $tel = '18910184804';
            $type = '驳回申请';
            $content  = $s_institution['name'].'医院的'.$doctor['realname'].'医生驳回了下级'.$x_institution['name'].'医院的'.$x_name['realname'].'医生发起的申请，单子的申请单id是'.$did['id'].'，驳回的理由是'.$param['description'];
            send_message::sendSms2Self($tel,$type,$content);
        }
        return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
    }

    /**
     * 远程申请接收
     *
     * @ApiTitle            (远程申请接收)
     * @ApiSummary          (远程申请接收)
     * @ApiSector           (远程诊断)
     * @ApiMethod           (POST)
     * @ApiRoute            (/inter/application/recive)
     * @ApiHeaders        (name="sign", type="string", required=true, description="请求头-校验key")
     * @ApiHeaders        (name="nonce", type="string", required=true, description="请求头-随机数")
     * @ApiHeaders        (name="timestamp", type=string, required=true, description="请求头-时间戳s")
     * @ApiParams         (name="sessionid",                 type="string",      required=true,      description="参数json字符串")
     * @ApiParams         (name="id",                        type="string",      required=true, sample="",          description="参数json字符串，预约登记exams表id值<必填>")
     * @ApiReturnParams   (name="status",                      type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
     * @ApiReturnParams   (name="code",                      type="integer",     required=true,      sample="0", description="返回状态码")
     * @ApiReturnParams   (name="sessionid",                      type="object",      sample="{}",        description="缓存的数据key")
     * @ApiReturn   (data="
    {
    'status': ok,
    'code': '0000',
    'sessionid': 'a17z7a7a8f9g9rh9d89jio'
    }
     *")
     **/
    //接收
    public function recive(){
        $sessionid = $_REQUEST['sessionid'];
        $doctor = Cache::get($sessionid);
        $id = $_REQUEST['id'];
        DB::table('exams')->where('id',$id)->update(['exam_status'=>6]);
        $application = DB::table('remote_application')->where('exam_id',$id)->find();
        if($application['req_doctor_id'] == 'c44663d6d3c0b535'){
            // 上级医院
            $s_institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
            //下级医院
            $x_institution = DB::table('institution')->where('id',$application['local_institution_id'])->field('name')->find();
            $x_name = DB::table('doctors')->where('id',$application['req_doctor_id'])->field('realname')->find();
            $tel = '18910184804';
            $type = '接收申请';
            $content  = $s_institution['name'].'医院的'.$doctor['realname'].'医生接收了下级'.$x_institution['name'].'医院的'.$x_name['realname'].'医生发起的申请，单子的申请单id是'.$application['id'];
            send_message::sendSms2Self($tel,$type,$content);
        }
        return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
    }
}