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;
use app\common\library\Message;
use app\inter\service\WechatService;

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值<必填>")
     * @ApiParams         (name="param[rid]",                  type="string",      sample="",          description="远程申请表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' : '',
    'rid' : ''
    }
     *")
     **/
    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,urgent,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'] ?? null;
            $info['exam_subclass_name'] = $exam_subclass['name'] ?? null;
            $info['exam_project_name'] = $exam_project['name'] ?? null;
            $info['device_name'] = $device['name'] ?? null;
            $patient_info = DB::table('patient_infos')->where('id',$info['patient_id'])->field(['temp_patient_id','id','name','sex','age','birthday', 'phone'])->find();
            $info['pid'] = $patient_info['id'] ?? null;
            $info['temp_patient_id'] = $patient_info['temp_patient_id'] ?? null;
            $info['name'] = $patient_info['name'] ?? null;
            $info['sex'] = $patient_info['sex'] ?? null;
            $info['age'] = $patient_info['age'] ?? null;
            $info['phone'] = $patient_info['phone'] ?? null;
            if(!empty($patient_info['birthday'] ?? null)){
                $info['birthday'] = $patient_info['birthday'];
            }
            $doctor = Cache::get($sessionid);
            $institution_id = $doctor['institution_id'];
            $hospital = DB::table('institution')->where('id',$institution_id)->find();
            $is_pay = $hospital['is_pay'];
            $parent_name = array();

            // 特殊机构
            $special_doctors = Db::table('special_contact')
                ->alias("sc")
                ->join('doctors d', 'sc.did = d.id')
                ->join('institution i', 'sc.hid = i.id')
                ->join('special_remote sr', 'sc.sid = sr.id')
                ->where('sr.status', 1)
                ->where('sc.status', 1)
                ->order('sr.sort asc')
                ->order('sc.sort asc')
                ->field('sc.hid, sc.did, sc.id, sc.cost, sc.describe, sr.id as sid, sr.name, sr.check, sr.color, d.realname as dname, i.name as hname')
                ->select();
            $super_hospitals = array();
            // 特殊机构
            if(!empty($special_doctors)) {
                $special_hospitals = array();
                foreach($special_doctors as $v) {
                    if(!isset($super_hospitals[$v['sid']])){
                        $super_hospitals[$v['sid']] = [
                            "doctor" => [
                                [
                                    "id" => $v['did'],
                                    "hid" => $v['hid'],
                                    "is_admin" => '0',
                                    "realname" => $v['dname'],
                                    "describe" => $v['describe'],
                                    "hname" => $v['hname'],
                                    "scid" => $v['id']
                                ]
                            ],
                            "name" => $v['name'],
                            "color" => $v['color'],
                            "sid" => $v['sid'],
                            "id" => $v['sid'],
                            "check" => $v['check']
                        ];
                    } else {
                        $super_hospitals[$v['sid']]['doctor'][] = [
                            "id" => $v['did'],
                            "hid" => $v['hid'],
                            "is_admin" => '0',
                            "realname" => $v['dname'],
                            "describe" => $v['describe'],
                            "hname" => $v['hname'],
                            "scid" => $v['id']
                        ];
                    }
                }
                foreach($super_hospitals as $v) {
                    $parent_name[] = $v;
                }
            }

            // select rc1.hospital_id, rc1.super_hospital_id, rc1.hospital_name, rc1.super_hospital_name, rc1.pay_type, rc2.super_doctor_id, rc2.super_doctor_name, rc2.exam_class from remote_contact rc1 join remote_cost rc2 on rc1.hospital_id = rc2.hospital_id and rc1.super_hospital_id = rc2.super_hospital_id where rc1.hospital_id = '13000003' and rc2.exam_class='CT' order by rc1.sort, rc2.sort
            if($is_pay === 1) {
                $super_hospitals = array();
                $super_doctors = DB::table("remote_contact")
                    ->alias("rc1")
                    ->join('remote_cost rc2', 'rc1.hospital_id = rc2.hospital_id and rc1.super_hospital_id = rc2.super_hospital_id')
                    ->where('rc1.hospital_id', $institution_id)
                    ->where('rc2.exam_class', $info['exam_class'])
                    ->field('rc1.hospital_id, rc1.super_hospital_id, rc1.hospital_name, rc1.super_hospital_name, rc1.pay_type, rc2.super_doctor_id, rc2.super_doctor_name, rc2.exam_class, rc2.is_admin')
                    // ->fetchSql()
                    ->select();
                // var_dump($super_doctors);
                foreach($super_doctors as $v) {
                    if(!isset($super_hospitals[$v['hospital_id']])){
                        $super_hospitals[$v['hospital_id']] = [
                            "doctor" => [
                                [
                                    "id" => $v['super_doctor_id'],
                                    "is_admin" => $v['is_admin'],
                                    "realname" => $v['super_doctor_name']
                                ]
                            ],
                            "id" => $v['super_hospital_id'],
                            "name" => $v['super_hospital_name'],
                        ];
                    } else {
                        $super_hospitals[$v['hospital_id']]['doctor'][] = [
                            "id" => $v['super_doctor_id'],
                            "is_admin" => $v['is_admin'],
                            "realname" => $v['super_doctor_name']
                        ];
                    }
                }
                foreach($super_hospitals as $v) {
                    $parent_name[] = $v;
                }
            } else {
                $parent_hosp = explode(',',$hospital['parent_institution']);
                foreach($parent_hosp as $v){
                    $phname = DB::table("institution")->where('id',$v)->cache(300)->field(['id','name'])->find();
                    log::record('上级医院----'.json_encode($phname));
                    if(!isset($phname['id']) || empty($phname['id'])){
                        $phname['id'] = $v;
                    }
                    $doctor_info = DB::table('doctors')->where('institution_id',$v)->field('id,realname,is_admin')->order('is_admin desc')->select();
                    foreach($doctor_info as $key=>$value){
                        if($value['is_admin'] == 1){
                            $doctor_info[$key]['realname'] = $value['realname'].'---医院管理员';
                        }
                    }
                    $phname['doctor'] = $doctor_info;
                    $parent_name[] =$phname;
                }
            }
            $info['parent_hospital'] = $parent_name;
            //申请信息
            if(isset($param['rid']) && !empty($param['rid'])){
                $rid = $param['rid'];
                $application = DB::table('remote_application')->where('id',$rid)->field(['id,remote_institution_id,report_status,id,remote_doctor_id','application_desc','attachment','req_doctor_id','illness_desc','phys_sign','is_urgent','clin_symp','anamnesis','family_ill','remark','clin_diag'])->find();
                $aid = $application['id'];
            }else{
                $rid = '';
                $application = DB::table('remote_application')->where('exam_id',$id)->field(['id,remote_institution_id,report_status,id,remote_doctor_id','application_desc','attachment','req_doctor_id','illness_desc','phys_sign','clin_symp','is_urgent','anamnesis','family_ill','remark','clin_diag'])->find();
                $aid = $application['id'] ?? null;
            }
            $remote_order =  DB::table('remote_order')
                ->where('application_id', $application['id'] ?? null)
                ->where('status', 'neq', self::ORDER_STATUS['CANCEL'])
                ->where('status', 'neq', self::ORDER_STATUS['REDUCE'])
                ->field('id, status, exam_class, super_hospital_id, super_doctor_id')
                ->find();
            if($remote_order) {
                $info['remote_order'] = $remote_order;
            }
            if($is_remote == 1){
                Message::read($doctor['id'],$aid,1);
                //远程申请点击进入
                $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'] ?? null)->field('department_id')->find();
                $dep = DB::table('department')->where('id',$dinfo['department_id'] ?? null)->field('department_name')->find();
            }else{
                Message::read($doctor['id'],$aid,2);
                //本地远程申请中
                $dep = DB::table('department')->where('id',$doctor['department_id'] ?? null)->field('department_name')->find();
            }
            $info['department_name'] = $dep['department_name'] ?? null;
            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();
                if(empty($exam_application['anamnesis'])){
                    $exam_application['anamnesis'] = '';
                }else{
                    $exam_application['anamnesis'] = explode(',',$exam_application['anamnesis']);
                }
                if(empty($exam_application['family_ill'])){
                    $exam_application['family_ill'] = '';
                }else{
                    $exam_application['family_ill'] = explode(',',$exam_application['family_ill']);
                }
                $exam_application['report_status'] = '';
                $exam_application['remark'] = '';
                $exam_application['remote_institution'] = '';
                $info['application'] = $exam_application;
            }else{
                $remote_name = DB::table('doctors')->where('id',$application['remote_doctor_id'])->field('realname')->find();
                $remote_institution = DB::table('institution')->where('id',$application['remote_institution_id'])->value('name');
                $application['remote_institution'] = $remote_institution;
                $application['remote_doctor'] = $remote_name['realname'] ?? null;
                if(empty($application['anamnesis'])){
                    $application['anamnesis'] = '';
                }else{
                    $application['anamnesis'] = explode(',',$application['anamnesis']);
                }
                if(empty($application['family_ill'])){
                    $application['family_ill'] = '';
                }else{
                    $application['family_ill'] = explode(',',$application['family_ill']);
                }
                $info['application'] = $application;
            }
            $count = DB::table('messages')->where('application_id',$aid)->where('doctor_id',$doctor['id'])->where('status',0)->where('type',7)->where('is_read',0)->field('count')->find();
            $info['unread_message_num'] = $count['count'] ?? 0;
            return json_encode(['status'=>'ok','code'=>'0000','info'=>$info,'sessionid'=>$sessionid,'is_remote'=>$is_remote,'rid'=>$aid]);
        }catch(\Exception $e){
            return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
        }
    }
    /**取消订单 */
    public function cancel(WechatService $wechatService){
        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'];
            $order_id = $param['order_id'];
            $remote_order = DB::table('remote_order')->where('id', $order_id)->field('application_id, hospital_id, doctor_id, status, pay_type, order_money')->find();
            if(!$remote_order) {
                return json_encode(['status'=>'fail','code'=>'2101','msg'=> '没有找到该订单']);
            }
            if(!($remote_order['status'] === self::ORDER_STATUS['CREATE'] || $remote_order['status'] === self::ORDER_STATUS['PAYCOMPLTET'])) {
                return json_encode(['status'=>'fail','code'=>'2102','msg'=> '订单状态不可取消']);
            }
            $application = DB::table('remote_application')->where('id', $remote_order['application_id'])->field('report_status, exam_id')->find();
            if(!$application) {
                return json_encode(['status'=>'fail','code'=>'2103','msg'=> '没有找到远程诊断申请单']);
            }
            if(!($application['report_status'] === '5' || $application['report_status'] === '12')) {
                return json_encode(['status'=>'fail','code'=>'2103','msg'=> '进行中的远程诊断订单不可取消']);
            }
            // 微信消息推送
            // $wechatService->pushWechatCancel($application['exam_id']);
            $wechatService->pushWechatCancel($order_id);
            if($remote_order['pay_type'] === self::PAY_TYPE['HOSPITAL']) {
                return $this->cancelHospitalOrder($order_id, $remote_order['hospital_id'], $remote_order['order_money']);
            }
            if($remote_order['pay_type'] === self::PAY_TYPE['PATIENT']) {
                return $this->cancelPatientsOrder($order_id, $remote_order['application_id']);
            }
            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/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(WechatService $wechatService){
        try{
            // var_dump(1);
            // var_dump($wechatService);
            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'];
            $application_info = array();
            $application_info['remote_institution_id'] = isset($param['remote_institution']) ? $param['remote_institution'] : '';
            if(isset($param['remote_doctor_id'])  && !empty($param['remote_doctor_id']) && empty($application_info['remote_doctor_id'])){
                $remote_doctor = DB::table('doctors')->where('id',$param['remote_doctor_id'])->find();
                $application_info['remote_institution_id'] = $remote_doctor['institution_id'];
            }
            if(empty($application_info['remote_institution_id'])){
                return json_encode(['status'=>'fail','code'=>'3029','msg'=>'没有选择远程机构']);
            }
            $exam_info =  DB::table('exams')->where('id',$param['id'])->field('exam_class,exam_status,patient_id')->find();
            // 修改病人姓名
            DB::table('patient_infos')->where('id',$exam_info['patient_id'])->update(['name'=>$param['name'], 'phone'=> $param['phone']]??'');
            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 = '患者还未检查，请检查完毕后再进行远程申请';
                        return json_encode(['status'=>'fail','code'=>'1029','msg'=>$msg]);
                        break;
                    case 2:
                        $msg = '影像未到达，不能发起远程申请';
                        return json_encode(['status'=>'fail','code'=>'1029','msg'=>$msg]);
                        break;
                }
            }
            Verify::applicationCheck($param);
            $where = array();
            // 申请医生
            $where['req_doctor_id'] = $doctor['id'];
            $where['remote_institution_id'] = $application_info['remote_institution_id'];
            //  只允许有一个申请     ----------------------------- 暂时添加
            $r = DB::table('remote_application')->where('exam_id',$param['id'])->where('report_status','not in',',5,12')->find();
            if($r){
                return json_encode(['status'=>'fail','code'=>'1120','msg'=>'每个医院同一个检查只能申请一次']);
            }
            //不等于9  代表
            $a_info = DB::table('remote_application')->where($where)->where('exam_id',$param['id'])->where('report_status','not in',',12,5,9')->find();
            if($a_info){
                return json_encode(['status'=>'fail','code'=>'1120','msg'=>'该申请目标医院存在未完成报告，只有报告完成后才能再次发起申请']);
            }
            $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'] : '';
            if(isset($param['is_urgent']) && $param['is_urgent'] == 'true' ){
                $application_info['is_urgent'] = 1;
                $remote_doctor_id = '';
                $d_time = date('H:i',strtotime('+30 min'));
            }else{
                $application_info['is_urgent'] = 0;
                $remote_doctor_id = isset($param['remote_doctor_id']) ? $param['remote_doctor_id'] : '';
                $d_time = date('H:i',strtotime('+1 hour'));
                if($remote_doctor_id === '') {
                    $manager = DB::table('doctors')->where('institution_id',$application_info['remote_institution_id'])->where('is_admin', '1')->field('id')->find();
                    if(!empty($manager)) {
                        $remote_doctor_id = $manager['id'];
                    }
                }
            }
            $application_info['application_desc'] = isset($param['description']) ? $param['description'] : '';
            $application_info['req_doctor_id'] = $doctor['id'];
            $application_info['phone'] = $param['phone']?? '';
            $application_info['remote_doctor_id'] = $remote_doctor_id;
            $application_info['attachment'] = isset($param['attachment']) ? $param['attachment'] : '';
            $application_info['sid'] = isset($param['sid']) && !empty($param['sid']) ? $param['sid'] : null;
            $application_info['scid'] = isset($param['scid']) && !empty($param['scid']) ? $param['scid'] : null;
//            $remote_application = DB::table('remote_application')->where('exam_id',$param['id'])->select();
            // 申请远程
//            if(empty($remote_application)){
            log::record('新增远程申请');
            $re = DB::table('remote_application')->where('exam_id',$param['id'])->find();
            $report = array();
            if($re){
                // 存在被驳回申请  再次申请时则为驳回后发起的申请
                DB::table('remote_application')->where('exam_id',$param['id'])->update($application_info);
                $app_id = $re['id'];
            }else{
                $application_info['id'] = UUIDs::uuid16();
                $application_info['createdAt'] = date('Y-m-d H:i:s',time());
                DB::table('remote_application')->insert($application_info);
                $app_id = $application_info['id'];
            }
            $aid = $app_id;
            $r_info = DB::table('report')->where('exam_id',$param['id'])->where('remote_application_id', $aid)->find();
            if(empty($r_info)){
                $report['id'] = UUIDs::uuid16();
                $report['exam_id'] = $param['id'];
                $report['remote_application_id'] = $aid;
                $report['type'] = 2;
                DB::table('report')->insert($report);
                $r_id = $report['id'];
            }else{
                $r_id = $r_info['id'];
            }
//            }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'])){
                $institution_id = $doctor['institution_id'];
                $lower_hospital = DB::table('institution')->where('id', $institution_id)->field('is_pay')->find();
                $is_pay = $lower_hospital['is_pay'];
                $application = DB::table('remote_application')->where('exam_id', $param['id'])->field('id, sid, scid, remote_institution_id, remote_doctor_id, local_institution_id, req_doctor_id, is_urgent')->find();
                if(empty($application)) {
                    return json_encode(['status'=>'fail','code'=>'2011','msg'=> '申请单创建失败']);
                }
                $remote_institution_id = $application['remote_institution_id'];
                $remote_doctor_id = $application['remote_doctor_id'];
                $is_urgent = $application['is_urgent'];
                $local_institution_id = $application['local_institution_id'];
                $req_doctor_id = $application['req_doctor_id'];
                $sid = $application['sid'];
                $scid = $application['scid'];
                if(empty($remote_institution_id)) {
                    return json_encode(['status'=>'fail','code'=>'2012','msg'=> '远程机构id为空']);
                }
                // if(empty($remote_doctor_id)) {
                //     return json_encode(['status'=>'fail','code'=>'2013','msg'=> '远程医生id为空']);
                // }
                if(empty($local_institution_id)) {
                    return json_encode(['status'=>'fail','code'=>'2014','msg'=> '本地机构id为空']);
                }
                if(empty($req_doctor_id)) {
                    return json_encode(['status'=>'fail','code'=>'2015','msg'=> '本地医生id为空']);
                }

                if(!empty($sid) && empty($scid)) {
                    return json_encode(['status'=>'fail','code'=>'2016','msg'=> '请选择问诊医生']);
                }

                if($is_pay === 1 && empty($sid)) {
                    $cost = DB::table('remote_cost')
                        ->where('hospital_id', $local_institution_id)
                        ->where('super_hospital_id', $remote_institution_id)
                        ->where('super_doctor_id', $remote_doctor_id)
                        ->where('exam_class', $exam_info['exam_class'])
                        ->field('money')
                        ->find();
                    if(!$cost) {
                        return json_encode(['status'=>'ok','code'=>'2016','msg'=> '远程医生获取失败']);
                    }
                    if($cost['money'] !== 0) {
                        $contact = DB::table('remote_contact')
                            ->where('hospital_id', $local_institution_id)
                            ->where('super_hospital_id', $remote_institution_id)
                            ->field('pay_type')
                            ->find();
                        if(!$contact) {
                            return json_encode(['status'=>'ok','code'=>'2017','msg'=> '远程机构获取失败']);
                        }
                        $res = false;
                        if($contact['pay_type'] === self::PAY_TYPE['HOSPITAL']) { //医院挂账
                            // $hospital_id, $super_hospital_id, $doctor_id, $super_doctor_id, $exam_class, $application_id, $order_money
                            $res = $this->createHospitalOrder($local_institution_id, $remote_institution_id, $req_doctor_id, $remote_doctor_id, $exam_info['exam_class'], $application['id'], $cost['money'], $is_urgent, $wechatService);
                        }
                        if($contact['pay_type'] === self::PAY_TYPE['PATIENT']) { // 患者支付
                            // var_dump(2);
                            // var_dump($wechatService);
                            // $push_res = WechatService::pushWechatOrder($param['id']);
                            // $wechatService->pushWechatOrder($param['id']);
                            $res = $this->createPatientsOrder($local_institution_id, $remote_institution_id, $req_doctor_id, $remote_doctor_id, $exam_info['exam_class'], $application['id'], $cost['money'], $is_urgent, $wechatService);
                            return json_encode(['status'=>'ok','code'=>'0000']);
                        }
                        if($res === true) {
                            return ['status'=>'ok','code'=>'0000'];
                        }
                        return $res;
                    }
                } else {
                    DB::table('remote_order')->insert([
                        'id' => UUIDs::uuid16(),
                        'hospital_id' => $local_institution_id,
                        'super_hospital_id' => $remote_institution_id,
                        'exam_class' => $exam_info['exam_class'],
                        'doctor_id' => $req_doctor_id,
                        'application_id' => $application['id'],
                        'super_doctor_id' => $remote_doctor_id,
                        'is_urgent' => $is_urgent,
                        'status' => self::ORDER_STATUS['PAYCOMPLTET'],
                        'order_money' => 0,
                        'pay_type' => self::PAY_TYPE['HOSPITAL'],
                        'pay_way' => self::PAY_WAY['HOSPITAL'],
                        'timestamp' => time()
                    ]);
                    DB::table('remote_application')->where('exam_id',$param['id'])->update(['report_status'=>4]);
                }
                // 添加messages信息

                // $wechatService->pushWechatOrder($param['id']);
                $t = '收到一条远程诊断申请';
                $ins = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
                $c = $ins['name'].$doctor['realname'].'医师向您发起一条远程诊断申请';
                $d = $application_info['remote_doctor_id'];
                $type = '1';
                $url = Message::url($sessionid,$param['id'],1,$exam_info['exam_class'],$r_id,$aid);
                Message::insert($t,$c,$d,$type,$url,1,$aid);
                //保存  申请

                // 发送通知短信
                $this->sendApplySms($d_time, $application_info['remote_doctor_id'], $application_info['remote_institution_id']);

                // $dinfo = DB::table('doctors')->where('id',$application_info['remote_doctor_id'])->find();
                // $d_phone = $dinfo['phone'];
                // $d_name = $dinfo['realname'];
                // if($dinfo['institution_id'] == '22100003' || $dinfo['send_sms'] == 1){ //魏庙
                //     $repsone = send_message::sendSms2Apply($d_phone,$d_time,$d_name);
                // }
                // $tel = '18910184804';
                // $type = '发起申请';
                // $content  = $aid;
                //                $response = send_message::sendSms2Self($tel,$type,$content);
            }
            return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid,'aid'=>$aid]);
        }catch(\Exception $e){
            return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
        }
    }

    /**
     * @param d_time 时间
     * @param d_id 医生id
     * @param i_id 机构id
     */
    private function sendApplySms($d_time, $d_id, $i_id) {
        $dinfo = false;
        if(!empty($d_id)) {
            $dinfo = DB::table('doctors')->where('id', $d_id)->find();
        }
        if($dinfo) {
            if($dinfo['institution_id'] == '22100003' || $dinfo['send_sms'] == 1){ //魏庙
                $repsone = send_message::sendSms2Apply($dinfo['phone'], $d_time, $dinfo['realname']);
            }
            return;
        }
        // 查找医院管理员并发送短信
        $admins = DB::table('doctors')->where('institution_id', $i_id)->where('is_admin', '1')->where('send_sms', '1')->select();
        foreach($admins as $key=>$value){
            $repsone = send_message::sendSms2Apply($value['phone'], $d_time, $value['realname']);
        }
    }


    private function createHospitalOrder($hospital_id, $super_hospital_id, $doctor_id, $super_doctor_id, $exam_class, $application_id, $order_money, $is_urgent = 0, $wechatService) {
        DB::startTrans();
        $pay_type = self::PAY_TYPE['HOSPITAL'];
        $pay_way = self::PAY_TYPE['HOSPITAL'];
        $water_type = self::WATER_TYPE['REDUCE'];
        $water_why = self::WATER_WHY['REMOTEPAY'];
        try{
            $remote_order =  DB::table('remote_order')
                ->where('application_id', $application_id)
                ->where('status', 'neq', self::ORDER_STATUS['CANCEL'])
                ->where('status', 'neq', self::ORDER_STATUS['REDUCE'])
                ->field('id')
                ->find();
            DB::table('remote_application')->where('id',$application_id)->update(['report_status'=>4]);
            if($remote_order) {
                DB::commit();
                // return true;
                // DB::rollback();
                return json_encode(['status'=>'fail','code'=>'2019','msg' => '已存在订单,请勿重复发起']);
            }
            $hospital = DB::table('institution')
                ->where('id', $hospital_id)
                ->field('min_money, current_money')
                ->find();
            if(!$hospital) {
                DB::rollback();
                return json_encode(['status'=>'fail','code'=>'2017','msg' => '查找本地医院失败']);
            }
            $min_money = $hospital['min_money'];
            $current_money = $hospital['current_money'];
            if($current_money - $order_money < $min_money) {
                DB::rollback();
                return json_encode(['status'=>'fail','code'=>'2017','msg' => '余额不足请联系医院管理员充值']);
            }
            DB::table('institution')->where('id',$hospital_id)->update(['current_money'=> $current_money - $order_money]);
            $order_id = UUIDs::uuid16();
            DB::table('remote_order')->insert([
                'id' => $order_id,
                'hospital_id' => $hospital_id,
                'super_hospital_id' => $super_hospital_id,
                'exam_class' => $exam_class,
                'doctor_id' => $doctor_id,
                'is_urgent' => $is_urgent,
                'application_id' => $application_id,
                'super_doctor_id' => $super_doctor_id,
                'order_money' => $order_money,
                'pay_type' => $pay_type,
                'pay_way' => $pay_way,
                'timestamp' => time(),
            ]);
            DB::table('remote_water')->insert([
                'id' => UUIDs::uuid16(),
                'hospital_id' => $hospital_id,
                'order_id' => $order_id,
                'money' => $order_money,
                'type' => $water_type,
                'why' => $water_why,
                'timestamp' => time(),
            ]);
            // 提交事务
            DB::commit();
            $wechatService->pushWechatOrder($order_id);
            return true;
        } catch (\Exception $e) {
            // 回滚事务
            DB::rollback();
        }
        return json_encode(['status'=>'fail','code'=>'2018','msg' => '远程诊断发起失败']);
    }
    private function createPatientsOrder($hospital_id, $super_hospital_id, $doctor_id, $super_doctor_id, $exam_class, $application_id, $order_money, $is_urgent = 0, $wechatService) {
        $pay_type = self::PAY_TYPE['PATIENT'];
        $pay_way = self::PAY_WAY['WECHAT'];
        DB::startTrans();
        try{
            $remote_order =  DB::table('remote_order')
                ->where('application_id', $application_id)
                ->where('status', 'neq', self::ORDER_STATUS['CANCEL'])
                ->where('status', 'neq', self::ORDER_STATUS['REDUCE'])
                ->field('id')
                ->find();
            DB::table('remote_application')->where('id',$application_id)->update(['report_status'=>4]);
            if($remote_order) {
                DB::commit();
                // return json_encode(['status'=>'ok','code'=>'0000','oid'=>$remote_order['id'],'aid'=>$application_id]);
                // DB::rollback();
                return json_encode(['status'=>'fail','code'=>'2019','msg' => '已存在订单,请勿重复发起']);
            }
            $order_id = UUIDs::uuid16();
            DB::table('remote_order')->insert([
                'id' => $order_id,
                'hospital_id' => $hospital_id,
                'super_hospital_id' => $super_hospital_id,
                'exam_class' => $exam_class,
                'doctor_id' => $doctor_id,
                'application_id' => $application_id,
                'super_doctor_id' => $super_doctor_id,
                'is_urgent' => $is_urgent,
                'order_money' => $order_money,
                'pay_type' => $pay_type,
                'pay_way' => $pay_way,
                'timestamp' => time(),
                'status' => self::ORDER_STATUS['CREATE']
            ]);
            DB::commit();
            $wechatService->pushWechatOrder($order_id);
            return true;
        } catch (\Exception $e) {
            var_dump($e);
            DB::rollback();
        }
        return json_encode(['status'=>'fail','code'=>'2020','msg' => '远程诊断发起失败']);
    }

    private function cancelHospitalOrder($order_id, $hospital_id, $order_money) {
        DB::startTrans();
        $water_type = self::WATER_TYPE['ADD'];
        $water_why = self::WATER_WHY['REFUNDINCOME'];
        try{
            DB::table('remote_order')->where('id', $order_id)->update(["status" => self::ORDER_STATUS["REDUCE"]]);
            $hospital = DB::table('institution')
                ->where('id', $hospital_id)
                ->field('current_money')
                ->find();
            $current_money = $hospital['current_money'];
            DB::table('institution')->where('id',$hospital_id)->update(['current_money'=> $current_money + $order_money]);
            DB::table('remote_water')->insert([
                'id' => UUIDs::uuid16(),
                'hospital_id' => $hospital_id,
                'order_id' => $order_id,
                'money' => $order_money,
                'type' => $water_type,
                'why' => $water_why,
                'timestamp' => time(),
            ]);
            // 提交事务
            DB::commit();
            // todo 消息推送
            return json_encode(['status'=>'ok','code'=>'0000']);
        } catch (\Exception $e) {
            // 回滚事务
            DB::rollback();
        }
        return json_encode(['status'=>'fail','code'=>'2018','msg' => '取消订单失败']);
    }
    private function cancelPatientsOrder($order_id) {
        try{
            DB::table('remote_order')->where('id', $order_id)->update(["status" => self::ORDER_STATUS["CANCEL"]]);
            // todo 消息推送
            return json_encode(['status'=>'ok','code'=>'0000']);
        } catch (\Exception $e) {
            var_dump($e);
        }
        return json_encode(['status'=>'fail','code'=>'2109','msg' => '订单取消失败']);
    }

    /**订单状态 创建 支付完成 订单完成 取消 退款 */
    public const ORDER_STATUS = [
        'CREATE' => 1,
        'PAYCOMPLTET' => 2,
        'CONFIRM' => 3,
        'CANCEL' => 4,
        'REDUCE' => 5
    ];

    /**流水类型 加 减 */
    public const WATER_TYPE = [
        'ADD' => 1,
        'REDUCE' => 2
    ];

    /**流水原因 远程诊断医院扣款 远程诊断医院收入 远程诊断退款 远程诊断退款收入 */
    public const WATER_WHY = [
        'REMOTEPAY' => 21,
        'REMOTEINCOME' => 11,
        'REMOTEREFUND' => 22,
        'REFUNDINCOME' => 12
    ];
    // why 患者支付/远程诊断收入/远程诊断付款/远程诊断退款/提现
    /**支付方式 微信 支付宝 银联 医院扣款*/
    public const PAY_WAY = [
        "HOSPITAL" => 1,
        "WECHAT" => 11,
        "ALIPAY" => 12,
        "BANK" => 13
    ];

    /**支付类型 微信 医院  */
    public const PAY_TYPE = [
        "PATIENT" => 0,
        "HOSPITAL" => 1
    ];

    /**
     * 上传附件
     *
     * @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(){
        return json_encode(['status'=>'fail','code'=>'2000','msg'=>'上传失败，请联系管理员']);
        // 获取表单上传文件 例如上传了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'];
        $re = DB::table('remote_application')->where('id',$id)->field('exam_id,report_status')->find();
        if($re['report_status'] != 4){
            return json_encode(['status'=>'fail','code'=>'0321','msg'=>'只能驳回申请中的单子']);
        }
        $report = DB::table('report')->where('remote_application_id',$id)->field('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);
        $binfo = array();
        $binfo['id'] = UUIDs::uuid16();
        $binfo['initiator'] = $doctor['id'];
//        $info['reply'] = $param['reply']; // 回复人
        $binfo['remote_application_id'] = $id; //申请单id
        $binfo['content'] = '驳回原因：'.$param['description'];
        $binfo['createdAt'] = date('Y-m-d H:i:s',time());
        DB::table('bbs')->insert($binfo);
//        $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('id',$id)->find();
//        $message['doctor_id'] = $application['req_doctor_id'];
//        $message['institution_id'] = $application['local_institution_id'];
        DB::table('remote_application')->where('id',$id)->update(['report_status'=>5]);
        $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'])->find();
        $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
        // 驳回添加messages消息
        $t = '您的远程诊断申请被驳回';
        $c = '您的远程诊断申请,被'.$institution['name'].$doctor['realname'].'医师驳回。驳回理由:'.$param['description'];
        $d = $application['req_doctor_id'];
        $type = '2';
        $exam_class = DB::table('exams')->where('id',$re['exam_id'])->field('exam_class')->find();
        $url = Message::url($sessionid,$re['exam_id'],0,$exam_class['exam_class'],$report['id'],$id);
        Message::insert($t,$c,$d,$type,$url,1,$id);
        // 驳回发短信
        $d_phone = $dinfo['phone'];
        if($dinfo['institution_id'] == '22100002' || $dinfo['send_sms'] == 1){ //魏庙下级
            $des = mb_substr($param['description'],0,20,'utf-8');
            $repsone = send_message::sendSms2RejectApply($d_phone,$des);
        }
        $tel = '18910184804';
        $type = '驳回申请';
        $content  = $application['id'];
//        send_message::sendSms2Self($tel,$type,$content);
        $tel = '18366391911';
        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'];
        $re = DB::table('remote_application')->where('id',$id)->field('report_status,req_doctor_id,exam_id')->find();
        if($re['report_status'] != 4){
            return json_encode(['status'=>'fail','code'=>'0321','msg'=>'只能接收申请中的单子']);
        }
        DB::table('remote_application')->where('id',$id)->update(['report_status'=>6]);
        //  添加messages消息
        $t = '您的远程诊断申请被接收';
        $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
        $c = '您的远程诊断申请,被'.$institution['name'].$doctor['realname'].'医师接收';
        $d = $re['req_doctor_id'];
        $type = '4';
        $exam_class = DB::table('exams')->where('id',$re['exam_id'])->field('exam_class')->find();
        $report = DB::table('report')->where('exam_id',$re['exam_id'])->where('type',1)->field('id')->find();
        $url = Message::url($sessionid,$re['exam_id'],0,$exam_class['exam_class'],$report['id'],$id);
        Message::insert($t,$c,$d,$type,$url,1,$id);
        return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
    }

    /**
     * bbs通话保存
     *
     * @ApiTitle            (bbs通话保存)
     * @ApiSummary          (bbs通话保存)
     * @ApiSector           (远程诊断)
     * @ApiMethod           (POST)
     * @ApiRoute            (/inter/application/bbs_save)
     * @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[appid]",                  type="string",      sample="",          description="申请单id值<必填>")
     * @ApiParams         (name="param[content]",                  type="string",      sample="",          description="留言内容<必填>")
     * @ApiParams         (name="param[attachment]",                  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',
    'info' : ''
    }
     *")
     **/
    public function bbs_save(){
        $sessionid = $_REQUEST['sessionid'];
        $doctor = Cache::get($sessionid);
        $param = $_REQUEST['param'];
        if(empty($param['content'])){
            return json_encode(['status'=>'fail','msg'=>'内容为空，请填写要发送的内容','sessionid'=>$sessionid]);
        }
        $info = array();
        $info['id'] = UUIDs::uuid16();
        $info['initiator'] = $doctor['id'];
        $is_remote = $_REQUEST['is_remote'];
        $rinfo = DB::table('remote_application')->where('id',$param['appid'])->field('req_doctor_id,remote_doctor_id')->find();
        if($is_remote == 1){
            // 远程医生
            $info['reply'] = $rinfo['req_doctor_id']; //申请医生
            $remote = 0;
        }else{
            $info['reply'] = $rinfo['remote_doctor_id']; //申请的目标远程医生
            $remote = 1;
        }
        $info['remote_application_id'] = $param['appid']; //申请单id
        $info['content'] = $param['content'];
        $info['attachment'] = $param['attachment'];
        $info['createdAt'] = date('Y-m-d H:i:s',time());
        DB::table('bbs')->insert($info);
        // 添加message消息
        Message::bbs_message($param['appid'],$doctor['id'],$param['content'],$info['reply'],$remote,$sessionid);
        return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
    }
    public  function  getbbs(){
        $sessionid = $_REQUEST['sessionid'];
        $doctor = Cache::get($sessionid);
        $remote_id = $_REQUEST['application_id'];
        Message::read($doctor['id'],$remote_id,5);
        $info = DB::table('bbs')->where('remote_application_id',$remote_id)->order('createdAt desc')->select();
        foreach ($info as $k => $v) {
            $initiator = DB::table('doctors')->where('id',$v['initiator'])->field('realname')->find();
            $info[$k]['faqiren'] = $initiator['realname'];
//            $reply = DB::table('doctors')->where('id',$v['reply'])->field('realname')->find();
//            $info[$k]['huifuren'] = $reply['realname'];
        }
        return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid,'info'=>$info]);
    }
    /**
     * 上传通话留言附件
     *
     * @ApiTitle            (上传通话留言附件)
     * @ApiSummary          (上传通话留言附件)
     * @ApiSector           (远程诊断)
     * @ApiMethod           (POST)
     * @ApiRoute            (/inter/application/bbs_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 bbs_upload(){
        return json_encode(['status'=>'fail','code'=>'2000','msg'=>'上传失败，请联系管理员']);
        // 获取表单上传文件 例如上传了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{
                // 上传失败获取错误信息
                echo $file->getError();
            }
        }
    }



    /**
     * 撤回
     *
     * @ApiTitle            (撤回)
     * @ApiSummary          (撤回)
     * @ApiSector           (远程诊断)
     * @ApiMethod           (POST)
     * @ApiRoute            (/inter/application/revoke)
     * @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 revoke(){
        $sessionid = $_REQUEST['sessionid'];
        $doctor = Cache::get($sessionid);
        $id = $_REQUEST['id'];
        $status = DB::table('remote_application')->where('exam_id',$id)->field('id,report_status,remote_doctor_id')->find();
        if($status['report_status'] == 4){
            DB::table('remote_application')->where('exam_id',$id)->update(['report_status'=>12]);
        }else{
            return json_encode(['status'=>'ok','code'=>'0100','msg'=>'只能撤回申请中状态的申请单']);
        }
        $binfo = array();
        $binfo['id'] = UUIDs::uuid16();
        $binfo['initiator'] = $doctor['id'];
//        $info['reply'] = $param['reply']; // 回复人
        $binfo['remote_application_id'] = $status['id']; //申请单id
        $binfo['content'] = '已撤回了该申请';
        $binfo['createdAt'] = date('Y-m-d H:i:s',time());
        DB::table('bbs')->insert($binfo);
        //
        $t = '发起给您的远程诊断申请被撤回';
        $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
        $c = '您的远程诊断申请'.$institution['name'].$doctor['realname'].'医师撤回';
        $d = $status['remote_doctor_id'];
        $type = '3';
        $exam_class = DB::table('exams')->where('id',$id)->field('exam_class')->find();
        $report = DB::table('report')->where('remote_application_id',$status['id'])->field('id')->find();
        $url = Message::url($sessionid,$id,1,$exam_class['exam_class'],$report['id'],$status['id']);
        Message::insert($t,$c,$d,$type,$url,1,$status['id']);
        return json_encode(['status'=>'ok','code'=>'0000','msg'=>'撤回成功']);
    }

    public function bind_doctor()
    {
        try{
            $ra_id = $_REQUEST['ra_id'];
            $status = DB::table('remote_application')->where('id',$ra_id)->value('report_status');
            if($status != 4){
                return  json_encode(['status'=>'fail','code'=>'0410','msg'=>'只能分配未经处理的报告']);
            }
            $did = $_REQUEST['did'];
            $info = DB::table('remote_application')->where('id',$ra_id)->update(['remote_doctor_id'=>$did]);
            return  json_encode(['status'=>'ok','code'=>'0000','info'=>$info]);
        }catch(\Exception $e){
            return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
        }
    }

    //获取医生的接收和分配权限
    public function get_doctor_role()
    {
        try{
            $sessionid = $_REQUEST['sessionid'];
            $doctor = Cache::get($sessionid);
            $info = [];
            $info['is_admin'] = $doctor['is_admin'];
            $role = DB::table('doctor_class')->where('doctor_id',$doctor['id'])->value('doctor_class');
            if(strpos($role,'7') !== false){
                $info['is_doctor'] = 1;
            }else{
                $info['is_doctor'] = 0;
            }
            return  json_encode(['status'=>'ok','code'=>'0000','info'=>$info]);
        }catch(\Exception $e){
            return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
        }
    }
}