") * @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']; $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', 'phone'])->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']; $info['phone'] = $patient_info['phone']; 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(); $is_pay = $hospital['is_pay']; $parent_name = array(); // 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,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,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']; } $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, 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'])->field('department_id')->find(); $dep = DB::table('department')->where('id',$dinfo['department_id'])->field('department_name')->find(); }else{ Message::read($doctor['id'],$aid,2); //本地远程申请中 $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(); 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'] = ''; $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']; 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']; 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'] : ''; // $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, 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']; 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($is_pay === 1) { $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); //保存 申请 $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()]); } } 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(){ // 获取表单上传文件 例如上传了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]); $application = DB::table('remote_application')->where('exam_id',$id)->find(); $tel = '18910184804'; $type = '接收申请'; $content = $application['id']; // send_message::sendSms2Self($tel,$type,$content); // 添加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(){ // 获取表单上传文件 例如上传了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()]); } } }