Application.php 60 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093
  1. <?php
  2. namespace app\inter\controller;
  3. use think\Controller;
  4. use think\Db;
  5. use think\Session;
  6. use app\common\library\UUIDs;
  7. use think\Cache;
  8. use think\Log;
  9. use app\common\library\Verify;
  10. use think\File;
  11. use app\common\library\send_message;
  12. use app\common\library\Message;
  13. use app\inter\service\WechatService;
  14. class Application extends Base
  15. {
  16. /**
  17. * 发起远程申请
  18. *
  19. * @ApiTitle (发起远程申请)
  20. * @ApiSummary (发起远程申请)
  21. * @ApiSector (远程诊断)
  22. * @ApiMethod (POST)
  23. * @ApiRoute (/inter/application/index)
  24. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  25. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  26. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  27. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  28. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  29. * @ApiParams (name="is_remote", type="string", required=true, description="参数json字符串")
  30. * @ApiParams (name="param[id]", type="string", sample="", description="预约登记exams表id值<必填>")
  31. * @ApiParams (name="param[rid]", type="string", sample="", description="远程申请表id值<远程列表进入必填>")
  32. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  33. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  34. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  35. * @ApiReturnParams (name="is_remote", type="object", sample="{}", description="是否为远程诊断进入")
  36. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  37. * @ApiReturn (data="
  38. {
  39. 'status': ok,
  40. 'code': '0000',
  41. 'sessionid': 'a17z7a7a8f9g9rh9d89jio',
  42. 'is_remote': 1,
  43. 'info' : '',
  44. 'rid' : ''
  45. }
  46. *")
  47. **/
  48. public function index(){
  49. try{
  50. $sessionid = $_REQUEST['sessionid'];
  51. $param = $_REQUEST['param'];
  52. $id = $param['id'];
  53. $is_remote = 0;
  54. if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote']==1){
  55. $is_remote = 1;
  56. }
  57. $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();
  58. $exam_class = DB::table('constant')->where('id',$info['exam_class'])->field('constant_value')->find();
  59. $exam_subclass = DB::table('exam_subclass')->where('id',$info['exam_sub_class'])->cache(300)->find();
  60. $exam_project = DB::table('exam_project')->where('id',$info['exam_project'])->cache(300)->find();
  61. $device = DB::table('device')->where('id',$info['device'])->cache(300)->find();
  62. $info['exam_class_name'] = $exam_class['constant_value'];
  63. $info['exam_subclass_name'] = $exam_subclass['name'];
  64. $info['exam_project_name'] = $exam_project['name'];
  65. $info['device_name'] = $device['name'];
  66. $patient_info = DB::table('patient_infos')->where('id',$info['patient_id'])->field(['temp_patient_id','id','name','sex','age','birthday', 'phone'])->find();
  67. $info['pid'] = $patient_info['id'];
  68. $info['temp_patient_id'] = $patient_info['temp_patient_id'];
  69. $info['name'] = $patient_info['name'];
  70. $info['sex'] = $patient_info['sex'];
  71. $info['age'] = $patient_info['age'];
  72. $info['phone'] = $patient_info['phone'];
  73. if(!empty($patient_info['birthday'])){
  74. $info['birthday'] = $patient_info['birthday'];
  75. }
  76. $doctor = Cache::get($sessionid);
  77. $institution_id = $doctor['institution_id'];
  78. $hospital = DB::table('institution')->where('id',$institution_id)->find();
  79. $is_pay = $hospital['is_pay'];
  80. $parent_name = array();
  81. // 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
  82. if($is_pay === 1) {
  83. $super_hospitals = array();
  84. $super_doctors = DB::table("remote_contact")
  85. ->alias("rc1")
  86. ->join('remote_cost rc2', 'rc1.hospital_id = rc2.hospital_id and rc1.super_hospital_id = rc2.super_hospital_id')
  87. ->where('rc1.hospital_id', $institution_id)
  88. ->where('rc2.exam_class', $info['exam_class'])
  89. ->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')
  90. // ->fetchSql()
  91. ->select();
  92. // var_dump($super_doctors);
  93. foreach($super_doctors as $v) {
  94. if(!isset($super_hospitals[$v['hospital_id']])){
  95. $super_hospitals[$v['hospital_id']] = [
  96. "doctor" => [
  97. [
  98. "id" => $v['super_doctor_id'],
  99. "is_admin" => $v['is_admin'],
  100. "realname" => $v['super_doctor_name']
  101. ]
  102. ],
  103. "id" => $v['super_hospital_id'],
  104. "name" => $v['super_hospital_name'],
  105. ];
  106. } else {
  107. $super_hospitals[$v['hospital_id']]['doctor'][] = [
  108. "id" => $v['super_doctor_id'],
  109. "is_admin" => $v['is_admin'],
  110. "realname" => $v['super_doctor_name']
  111. ];
  112. }
  113. }
  114. foreach($super_hospitals as $v) {
  115. $parent_name[] = $v;
  116. }
  117. } else {
  118. $parent_hosp = explode(',',$hospital['parent_institution']);
  119. foreach($parent_hosp as $v){
  120. $phname = DB::table("institution")->where('id',$v)->cache(300)->field(['id','name'])->find();
  121. log::record('上级医院----'.json_encode($phname));
  122. if(!isset($phname['id']) || empty($phname['id'])){
  123. $phname['id'] = $v;
  124. }
  125. $doctor_info = DB::table('doctors')->where('institution_id',$v)->field('id,realname,is_admin')->order('is_admin desc')->select();
  126. foreach($doctor_info as $key=>$value){
  127. if($value['is_admin'] == 1){
  128. $doctor_info[$key]['realname'] = $value['realname'].'---医院管理员';
  129. }
  130. }
  131. $phname['doctor'] = $doctor_info;
  132. $parent_name[] =$phname;
  133. }
  134. }
  135. $info['parent_hospital'] = $parent_name;
  136. //申请信息
  137. if(isset($param['rid']) && !empty($param['rid'])){
  138. $rid = $param['rid'];
  139. $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();
  140. $aid = $application['id'];
  141. }else{
  142. $rid = '';
  143. $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();
  144. $aid = $application['id'];
  145. }
  146. $remote_order = DB::table('remote_order')
  147. ->where('application_id', $application['id'])
  148. ->where('status', 'neq', self::ORDER_STATUS['CANCEL'])
  149. ->where('status', 'neq', self::ORDER_STATUS['REDUCE'])
  150. ->field('id, status, exam_class, super_hospital_id, super_doctor_id')
  151. ->find();
  152. if($remote_order) {
  153. $info['remote_order'] = $remote_order;
  154. }
  155. if($is_remote == 1){
  156. Message::read($doctor['id'],$aid,1);
  157. //远程申请点击进入
  158. $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'])->field('department_id')->find();
  159. $dep = DB::table('department')->where('id',$dinfo['department_id'])->field('department_name')->find();
  160. }else{
  161. Message::read($doctor['id'],$aid,2);
  162. //本地远程申请中
  163. $dep = DB::table('department')->where('id',$doctor['department_id'])->field('department_name')->find();
  164. }
  165. $info['department_name'] = $dep['department_name'];
  166. if(empty($application)){
  167. $exam_application = DB::table('exams')->where('id',$id)->field(['illness_desc','phys_sign','clin_symp','remark','clin_diag','anamnesis','family_ill'])->find();
  168. if(empty($exam_application['anamnesis'])){
  169. $exam_application['anamnesis'] = '';
  170. }else{
  171. $exam_application['anamnesis'] = explode(',',$exam_application['anamnesis']);
  172. }
  173. if(empty($exam_application['family_ill'])){
  174. $exam_application['family_ill'] = '';
  175. }else{
  176. $exam_application['family_ill'] = explode(',',$exam_application['family_ill']);
  177. }
  178. $exam_application['report_status'] = '';
  179. $info['application'] = $exam_application;
  180. }else{
  181. $remote_name = DB::table('doctors')->where('id',$application['remote_doctor_id'])->field('realname')->find();
  182. $application['remote_doctor'] = $remote_name['realname'];
  183. if(empty($application['anamnesis'])){
  184. $application['anamnesis'] = '';
  185. }else{
  186. $application['anamnesis'] = explode(',',$application['anamnesis']);
  187. }
  188. if(empty($application['family_ill'])){
  189. $application['family_ill'] = '';
  190. }else{
  191. $application['family_ill'] = explode(',',$application['family_ill']);
  192. }
  193. $info['application'] = $application;
  194. }
  195. $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();
  196. $info['unread_message_num'] = $count['count'];
  197. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info,'sessionid'=>$sessionid,'is_remote'=>$is_remote,'rid'=>$aid]);
  198. }catch(\Exception $e){
  199. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  200. }
  201. }
  202. /**取消订单 */
  203. public function cancel(WechatService $wechatService){
  204. try{
  205. log::record($_REQUEST);
  206. $sessionid = $_REQUEST['sessionid'];
  207. $doctor = Cache::get($sessionid);
  208. // 远程申请权限 6
  209. $return = Verify::check_role($sessionid, 6);
  210. if($return != 1){
  211. return json_encode(['status'=>'fail','code'=>'1029','msg'=>'没有操作权限']);
  212. }
  213. $param = $_REQUEST['param'];
  214. $order_id = $param['order_id'];
  215. $remote_order = DB::table('remote_order')->where('id', $order_id)->field('application_id, hospital_id, doctor_id, status, pay_type, order_money')->find();
  216. if(!$remote_order) {
  217. return json_encode(['status'=>'fail','code'=>'2101','msg'=> '没有找到该订单']);
  218. }
  219. if(!($remote_order['status'] === self::ORDER_STATUS['CREATE'] || $remote_order['status'] === self::ORDER_STATUS['PAYCOMPLTET'])) {
  220. return json_encode(['status'=>'fail','code'=>'2102','msg'=> '订单状态不可取消']);
  221. }
  222. $application = DB::table('remote_application')->where('id', $remote_order['application_id'])->field('report_status, exam_id')->find();
  223. if(!$application) {
  224. return json_encode(['status'=>'fail','code'=>'2103','msg'=> '没有找到远程诊断申请单']);
  225. }
  226. if(!($application['report_status'] === '5' || $application['report_status'] === '12')) {
  227. return json_encode(['status'=>'fail','code'=>'2103','msg'=> '进行中的远程诊断订单不可取消']);
  228. }
  229. // 微信消息推送
  230. // $wechatService->pushWechatCancel($application['exam_id']);
  231. $wechatService->pushWechatCancel($order_id);
  232. if($remote_order['pay_type'] === self::PAY_TYPE['HOSPITAL']) {
  233. return $this->cancelHospitalOrder($order_id, $remote_order['hospital_id'], $remote_order['order_money']);
  234. }
  235. if($remote_order['pay_type'] === self::PAY_TYPE['PATIENT']) {
  236. return $this->cancelPatientsOrder($order_id, $remote_order['application_id']);
  237. }
  238. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
  239. }catch(\Exception $e){
  240. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  241. }
  242. }
  243. /**
  244. * 提交申请
  245. *
  246. * @ApiTitle (提交申请)
  247. * @ApiSummary (提交申请)
  248. * @ApiSector (远程诊断)
  249. * @ApiMethod (POST)
  250. * @ApiRoute (/inter/application/apply)
  251. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  252. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  253. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  254. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  255. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  256. * @ApiParams (name="param[id]", type="string", sample="", description="预约登记exams表id值<必填>")
  257. * @ApiParams (name="param[illness]", type="string", sample="", description="主诉<选填>")
  258. * @ApiParams (name="param[clin_symp]", type="string", sample="", description="临床症状<选填>")
  259. * @ApiParams (name="param[anamnesis]", type="string", sample="", description="既往史<选填>")
  260. * @ApiParams (name="param[family_ill]", type="string", sample="", description="家族史<选填>")
  261. * @ApiParams (name="param[remark]", type="string", sample="", description="备注<选填>")
  262. * @ApiParams (name="param[institution_id]", type="string", sample="", description="发起申请医院id值<选填>")
  263. * @ApiParams (name="param[clin_diag]", type="string", sample="", description="临床诊断<选填>")
  264. * @ApiParams (name="param[remote_institution]", type="string", sample="", description="申请的目标医院id值<选填>")
  265. * @ApiParams (name="param[is_urgent]", type="string", sample="", description="是否急诊 0否 1是<选填>")
  266. * @ApiParams (name="param[description]", type="string", sample="", description="申请描述<选填>")
  267. * @ApiParams (name="param[remote_doctor_id]", type="string", sample="", description="申请的目标医生id值<选填>")
  268. * @ApiParams (name="param[attachment]", type="string", sample="", description="附件<选填>")
  269. * @ApiParams (name="param[apply]", type="string", sample="", description="保存或者申请 存在值即保存 不存在则为申请<必填>")
  270. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  271. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  272. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  273. * @ApiReturn (data="
  274. {
  275. 'status': ok,
  276. 'code': '0000',
  277. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  278. }
  279. *")
  280. **/
  281. public function apply(WechatService $wechatService){
  282. try{
  283. // var_dump(1);
  284. // var_dump($wechatService);
  285. log::record($_REQUEST);
  286. $sessionid = $_REQUEST['sessionid'];
  287. $doctor = Cache::get($sessionid);
  288. // 远程申请权限 6
  289. $return = Verify::check_role($sessionid,6);
  290. if($return != 1){
  291. return json_encode(['status'=>'fail','code'=>'1029','msg'=>'没有操作权限']);
  292. }
  293. $param = $_REQUEST['param'];
  294. $application_info = array();
  295. $application_info['remote_institution_id'] = isset($param['remote_institution']) ? $param['remote_institution'] : '';
  296. if(isset($param['remote_doctor_id']) && !empty($param['remote_doctor_id']) && empty($application_info['remote_doctor_id'])){
  297. $remote_doctor = DB::table('doctors')->where('id',$param['remote_doctor_id'])->find();
  298. $application_info['remote_institution_id'] = $remote_doctor['institution_id'];
  299. }
  300. if(empty($application_info['remote_institution_id'])){
  301. return json_encode(['status'=>'fail','code'=>'3029','msg'=>'没有选择远程机构']);
  302. }
  303. $exam_info = DB::table('exams')->where('id',$param['id'])->field('exam_class,exam_status,patient_id')->find();
  304. // 修改病人姓名
  305. DB::table('patient_infos')->where('id',$exam_info['patient_id'])->update(['name'=>$param['name'], 'phone'=> $param['phone']]??'');
  306. if($exam_info['exam_status'] != 3 && $exam_info['exam_status'] != 5 && $exam_info['exam_status'] != 8){
  307. // 3 检查完毕 5已驳回
  308. switch($exam_info['exam_status']){
  309. case 1:
  310. $msg = '患者还未检查,请检查完毕后再进行远程申请';
  311. return json_encode(['status'=>'fail','code'=>'1029','msg'=>$msg]);
  312. break;
  313. case 2:
  314. $msg = '影像未到达,不能发起远程申请';
  315. return json_encode(['status'=>'fail','code'=>'1029','msg'=>$msg]);
  316. break;
  317. }
  318. }
  319. Verify::applicationCheck($param);
  320. $where = array();
  321. // 申请医生
  322. $where['req_doctor_id'] = $doctor['id'];
  323. $where['remote_institution_id'] = $application_info['remote_institution_id'];
  324. // 只允许有一个申请 ----------------------------- 暂时添加
  325. $r = DB::table('remote_application')->where('exam_id',$param['id'])->where('report_status','not in',',5,12')->find();
  326. if($r){
  327. return json_encode(['status'=>'fail','code'=>'1120','msg'=>'每个医院同一个检查只能申请一次']);
  328. }
  329. //不等于9 代表
  330. $a_info = DB::table('remote_application')->where($where)->where('exam_id',$param['id'])->where('report_status','not in',',12,5,9')->find();
  331. if($a_info){
  332. return json_encode(['status'=>'fail','code'=>'1120','msg'=>'该申请目标医院存在未完成报告,只有报告完成后才能再次发起申请']);
  333. }
  334. $application_info['exam_id'] = isset($param['id']) ? $param['id'] : '';
  335. $application_info['illness_desc'] = isset($param['illness']) ? $param['illness'] : '';
  336. $application_info['phys_sign'] = isset($param['phys_sign']) ? $param['phys_sign'] : '';
  337. $application_info['clin_symp'] = isset($param['clin_symp']) ? $param['clin_symp'] : '';
  338. if(!empty($param['anamnesis'])){
  339. $application_info['anamnesis'] = implode(',',$param['anamnesis']);
  340. }
  341. if(!empty($param['family_ill'])){
  342. $application_info['family_ill'] = implode(',',$param['family_ill']);
  343. }
  344. $application_info['remark'] = isset($param['remark']) ? $param['remark'] : '';
  345. $application_info['local_institution_id'] = $doctor['institution_id'];
  346. $application_info['req_date_time'] = date('Y-m-d H:i:s',time());
  347. $application_info['clin_diag'] = isset($param['clin_diag']) ? $param['clin_diag'] : '';
  348. if(isset($param['is_urgent']) && $param['is_urgent'] == 'true' ){
  349. $application_info['is_urgent'] = 1;
  350. $remote_doctor_id = '';
  351. $d_time = date('H:i',strtotime('+30 min'));
  352. }else{
  353. $application_info['is_urgent'] = 0;
  354. $remote_doctor_id = isset($param['remote_doctor_id']) ? $param['remote_doctor_id'] : '';
  355. $d_time = date('H:i',strtotime('+1 hour'));
  356. }
  357. if($remote_doctor_id === '') {
  358. $manager = DB::table('doctors')->where('institution_id',$application_info['remote_institution_id'])->where('is_admin', '1')->field('id')->find();
  359. if(!empty($manager)) {
  360. $remote_doctor_id = $manager['id'];
  361. }
  362. }
  363. $application_info['application_desc'] = isset($param['description']) ? $param['description'] : '';
  364. $application_info['req_doctor_id'] = $doctor['id'];
  365. $application_info['phone'] = $param['phone']?? '';
  366. $application_info['remote_doctor_id'] = $remote_doctor_id;
  367. $application_info['attachment'] = isset($param['attachment']) ? $param['attachment'] : '';
  368. // $remote_application = DB::table('remote_application')->where('exam_id',$param['id'])->select();
  369. // 申请远程
  370. // if(empty($remote_application)){
  371. log::record('新增远程申请');
  372. $re = DB::table('remote_application')->where('exam_id',$param['id'])->find();
  373. $report = array();
  374. if($re){
  375. // 存在被驳回申请 再次申请时则为驳回后发起的申请
  376. DB::table('remote_application')->where('exam_id',$param['id'])->update($application_info);
  377. $app_id = $re['id'];
  378. }else{
  379. $application_info['id'] = UUIDs::uuid16();
  380. $application_info['createdAt'] = date('Y-m-d H:i:s',time());
  381. DB::table('remote_application')->insert($application_info);
  382. $app_id = $application_info['id'];
  383. }
  384. $aid = $app_id;
  385. $r_info = DB::table('report')->where('exam_id',$param['id'])->where('remote_application_id', $aid)->find();
  386. if(empty($r_info)){
  387. $report['id'] = UUIDs::uuid16();
  388. $report['exam_id'] = $param['id'];
  389. $report['remote_application_id'] = $aid;
  390. $report['type'] = 2;
  391. DB::table('report')->insert($report);
  392. $r_id = $report['id'];
  393. }else{
  394. $r_id = $r_info['id'];
  395. }
  396. // }else{
  397. // log::record('修改远程申请');
  398. // DB::table('remote_application')->where('exam_id',$param['id'])->update($application_info);
  399. // $r = DB::table('remote_application')->where('exam_id',$param['id'])->field('id')->find();
  400. // $aid = $r['id'];
  401. // }
  402. if(isset($param['apply']) && !empty($param['apply'])){
  403. $institution_id = $doctor['institution_id'];
  404. $lower_hospital = DB::table('institution')->where('id', $institution_id)->field('is_pay')->find();
  405. $is_pay = $lower_hospital['is_pay'];
  406. $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();
  407. if(empty($application)) {
  408. return json_encode(['status'=>'fail','code'=>'2011','msg'=> '申请单创建失败']);
  409. }
  410. $remote_institution_id = $application['remote_institution_id'];
  411. $remote_doctor_id = $application['remote_doctor_id'];
  412. $is_urgent = $application['is_urgent'];
  413. $local_institution_id = $application['local_institution_id'];
  414. $req_doctor_id = $application['req_doctor_id'];
  415. if(empty($remote_institution_id)) {
  416. return json_encode(['status'=>'fail','code'=>'2012','msg'=> '远程机构id为空']);
  417. }
  418. // if(empty($remote_doctor_id)) {
  419. // return json_encode(['status'=>'fail','code'=>'2013','msg'=> '远程医生id为空']);
  420. // }
  421. if(empty($local_institution_id)) {
  422. return json_encode(['status'=>'fail','code'=>'2014','msg'=> '本地机构id为空']);
  423. }
  424. if(empty($req_doctor_id)) {
  425. return json_encode(['status'=>'fail','code'=>'2015','msg'=> '本地医生id为空']);
  426. }
  427. if($is_pay === 1) {
  428. $cost = DB::table('remote_cost')
  429. ->where('hospital_id', $local_institution_id)
  430. ->where('super_hospital_id', $remote_institution_id)
  431. ->where('super_doctor_id', $remote_doctor_id)
  432. ->where('exam_class', $exam_info['exam_class'])
  433. ->field('money')
  434. ->find();
  435. if(!$cost) {
  436. return json_encode(['status'=>'ok','code'=>'2016','msg'=> '远程医生获取失败']);
  437. }
  438. if($cost['money'] !== 0) {
  439. $contact = DB::table('remote_contact')
  440. ->where('hospital_id', $local_institution_id)
  441. ->where('super_hospital_id', $remote_institution_id)
  442. ->field('pay_type')
  443. ->find();
  444. if(!$contact) {
  445. return json_encode(['status'=>'ok','code'=>'2017','msg'=> '远程机构获取失败']);
  446. }
  447. $res = false;
  448. if($contact['pay_type'] === self::PAY_TYPE['HOSPITAL']) { //医院挂账
  449. // $hospital_id, $super_hospital_id, $doctor_id, $super_doctor_id, $exam_class, $application_id, $order_money
  450. $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);
  451. }
  452. if($contact['pay_type'] === self::PAY_TYPE['PATIENT']) { // 患者支付
  453. // var_dump(2);
  454. // var_dump($wechatService);
  455. // $push_res = WechatService::pushWechatOrder($param['id']);
  456. // $wechatService->pushWechatOrder($param['id']);
  457. $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);
  458. return json_encode(['status'=>'ok','code'=>'0000']);
  459. }
  460. if($res === true) {
  461. return ['status'=>'ok','code'=>'0000'];
  462. }
  463. return $res;
  464. }
  465. } else {
  466. DB::table('remote_order')->insert([
  467. 'id' => UUIDs::uuid16(),
  468. 'hospital_id' => $local_institution_id,
  469. 'super_hospital_id' => $remote_institution_id,
  470. 'exam_class' => $exam_info['exam_class'],
  471. 'doctor_id' => $req_doctor_id,
  472. 'application_id' => $application['id'],
  473. 'super_doctor_id' => $remote_doctor_id,
  474. 'is_urgent' => $is_urgent,
  475. 'status' => self::ORDER_STATUS['PAYCOMPLTET'],
  476. 'order_money' => 0,
  477. 'pay_type' => self::PAY_TYPE['HOSPITAL'],
  478. 'pay_way' => self::PAY_WAY['HOSPITAL'],
  479. 'timestamp' => time()
  480. ]);
  481. DB::table('remote_application')->where('exam_id',$param['id'])->update(['report_status'=>4]);
  482. }
  483. // 添加messages信息
  484. // $wechatService->pushWechatOrder($param['id']);
  485. $t = '收到一条远程诊断申请';
  486. $ins = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  487. $c = $ins['name'].$doctor['realname'].'医师向您发起一条远程诊断申请';
  488. $d = $application_info['remote_doctor_id'];
  489. $type = '1';
  490. $url = Message::url($sessionid,$param['id'],1,$exam_info['exam_class'],$r_id,$aid);
  491. Message::insert($t,$c,$d,$type,$url,1,$aid);
  492. //保存 申请
  493. $dinfo = DB::table('doctors')->where('id',$application_info['remote_doctor_id'])->find();
  494. $d_phone = $dinfo['phone'];
  495. $d_name = $dinfo['realname'];
  496. if($dinfo['institution_id'] == '22100003' || $dinfo['send_sms'] == 1){ //魏庙
  497. $repsone = send_message::sendSms2Apply($d_phone,$d_time,$d_name);
  498. }
  499. // $tel = '18910184804';
  500. // $type = '发起申请';
  501. // $content = $aid;
  502. // $response = send_message::sendSms2Self($tel,$type,$content);
  503. }
  504. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid,'aid'=>$aid]);
  505. }catch(\Exception $e){
  506. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  507. }
  508. }
  509. private function createHospitalOrder($hospital_id, $super_hospital_id, $doctor_id, $super_doctor_id, $exam_class, $application_id, $order_money, $is_urgent = 0, $wechatService) {
  510. DB::startTrans();
  511. $pay_type = self::PAY_TYPE['HOSPITAL'];
  512. $pay_way = self::PAY_TYPE['HOSPITAL'];
  513. $water_type = self::WATER_TYPE['REDUCE'];
  514. $water_why = self::WATER_WHY['REMOTEPAY'];
  515. try{
  516. $remote_order = DB::table('remote_order')
  517. ->where('application_id', $application_id)
  518. ->where('status', 'neq', self::ORDER_STATUS['CANCEL'])
  519. ->where('status', 'neq', self::ORDER_STATUS['REDUCE'])
  520. ->field('id')
  521. ->find();
  522. DB::table('remote_application')->where('id',$application_id)->update(['report_status'=>4]);
  523. if($remote_order) {
  524. DB::commit();
  525. // return true;
  526. // DB::rollback();
  527. return json_encode(['status'=>'fail','code'=>'2019','msg' => '已存在订单,请勿重复发起']);
  528. }
  529. $hospital = DB::table('institution')
  530. ->where('id', $hospital_id)
  531. ->field('min_money, current_money')
  532. ->find();
  533. if(!$hospital) {
  534. DB::rollback();
  535. return json_encode(['status'=>'fail','code'=>'2017','msg' => '查找本地医院失败']);
  536. }
  537. $min_money = $hospital['min_money'];
  538. $current_money = $hospital['current_money'];
  539. if($current_money - $order_money < $min_money) {
  540. DB::rollback();
  541. return json_encode(['status'=>'fail','code'=>'2017','msg' => '余额不足请联系医院管理员充值']);
  542. }
  543. DB::table('institution')->where('id',$hospital_id)->update(['current_money'=> $current_money - $order_money]);
  544. $order_id = UUIDs::uuid16();
  545. DB::table('remote_order')->insert([
  546. 'id' => $order_id,
  547. 'hospital_id' => $hospital_id,
  548. 'super_hospital_id' => $super_hospital_id,
  549. 'exam_class' => $exam_class,
  550. 'doctor_id' => $doctor_id,
  551. 'is_urgent' => $is_urgent,
  552. 'application_id' => $application_id,
  553. 'super_doctor_id' => $super_doctor_id,
  554. 'order_money' => $order_money,
  555. 'pay_type' => $pay_type,
  556. 'pay_way' => $pay_way,
  557. 'timestamp' => time(),
  558. ]);
  559. DB::table('remote_water')->insert([
  560. 'id' => UUIDs::uuid16(),
  561. 'hospital_id' => $hospital_id,
  562. 'order_id' => $order_id,
  563. 'money' => $order_money,
  564. 'type' => $water_type,
  565. 'why' => $water_why,
  566. 'timestamp' => time(),
  567. ]);
  568. // 提交事务
  569. DB::commit();
  570. $wechatService->pushWechatOrder($order_id);
  571. return true;
  572. } catch (\Exception $e) {
  573. // 回滚事务
  574. DB::rollback();
  575. }
  576. return json_encode(['status'=>'fail','code'=>'2018','msg' => '远程诊断发起失败']);
  577. }
  578. private function createPatientsOrder($hospital_id, $super_hospital_id, $doctor_id, $super_doctor_id, $exam_class, $application_id, $order_money, $is_urgent = 0, $wechatService) {
  579. $pay_type = self::PAY_TYPE['PATIENT'];
  580. $pay_way = self::PAY_WAY['WECHAT'];
  581. DB::startTrans();
  582. try{
  583. $remote_order = DB::table('remote_order')
  584. ->where('application_id', $application_id)
  585. ->where('status', 'neq', self::ORDER_STATUS['CANCEL'])
  586. ->where('status', 'neq', self::ORDER_STATUS['REDUCE'])
  587. ->field('id')
  588. ->find();
  589. DB::table('remote_application')->where('id',$application_id)->update(['report_status'=>4]);
  590. if($remote_order) {
  591. DB::commit();
  592. // return json_encode(['status'=>'ok','code'=>'0000','oid'=>$remote_order['id'],'aid'=>$application_id]);
  593. // DB::rollback();
  594. return json_encode(['status'=>'fail','code'=>'2019','msg' => '已存在订单,请勿重复发起']);
  595. }
  596. $order_id = UUIDs::uuid16();
  597. DB::table('remote_order')->insert([
  598. 'id' => $order_id,
  599. 'hospital_id' => $hospital_id,
  600. 'super_hospital_id' => $super_hospital_id,
  601. 'exam_class' => $exam_class,
  602. 'doctor_id' => $doctor_id,
  603. 'application_id' => $application_id,
  604. 'super_doctor_id' => $super_doctor_id,
  605. 'is_urgent' => $is_urgent,
  606. 'order_money' => $order_money,
  607. 'pay_type' => $pay_type,
  608. 'pay_way' => $pay_way,
  609. 'timestamp' => time(),
  610. 'status' => self::ORDER_STATUS['CREATE']
  611. ]);
  612. DB::commit();
  613. $wechatService->pushWechatOrder($order_id);
  614. return true;
  615. } catch (\Exception $e) {
  616. var_dump($e);
  617. DB::rollback();
  618. }
  619. return json_encode(['status'=>'fail','code'=>'2020','msg' => '远程诊断发起失败']);
  620. }
  621. private function cancelHospitalOrder($order_id, $hospital_id, $order_money) {
  622. DB::startTrans();
  623. $water_type = self::WATER_TYPE['ADD'];
  624. $water_why = self::WATER_WHY['REFUNDINCOME'];
  625. try{
  626. DB::table('remote_order')->where('id', $order_id)->update(["status" => self::ORDER_STATUS["REDUCE"]]);
  627. $hospital = DB::table('institution')
  628. ->where('id', $hospital_id)
  629. ->field('current_money')
  630. ->find();
  631. $current_money = $hospital['current_money'];
  632. DB::table('institution')->where('id',$hospital_id)->update(['current_money'=> $current_money + $order_money]);
  633. DB::table('remote_water')->insert([
  634. 'id' => UUIDs::uuid16(),
  635. 'hospital_id' => $hospital_id,
  636. 'order_id' => $order_id,
  637. 'money' => $order_money,
  638. 'type' => $water_type,
  639. 'why' => $water_why,
  640. 'timestamp' => time(),
  641. ]);
  642. // 提交事务
  643. DB::commit();
  644. // todo 消息推送
  645. return json_encode(['status'=>'ok','code'=>'0000']);
  646. } catch (\Exception $e) {
  647. // 回滚事务
  648. DB::rollback();
  649. }
  650. return json_encode(['status'=>'fail','code'=>'2018','msg' => '取消订单失败']);
  651. }
  652. private function cancelPatientsOrder($order_id) {
  653. try{
  654. DB::table('remote_order')->where('id', $order_id)->update(["status" => self::ORDER_STATUS["CANCEL"]]);
  655. // todo 消息推送
  656. return json_encode(['status'=>'ok','code'=>'0000']);
  657. } catch (\Exception $e) {
  658. var_dump($e);
  659. }
  660. return json_encode(['status'=>'fail','code'=>'2109','msg' => '订单取消失败']);
  661. }
  662. /**订单状态 创建 支付完成 订单完成 取消 退款 */
  663. public const ORDER_STATUS = [
  664. 'CREATE' => 1,
  665. 'PAYCOMPLTET' => 2,
  666. 'CONFIRM' => 3,
  667. 'CANCEL' => 4,
  668. 'REDUCE' => 5
  669. ];
  670. /**流水类型 加 减 */
  671. public const WATER_TYPE = [
  672. 'ADD' => 1,
  673. 'REDUCE' => 2
  674. ];
  675. /**流水原因 远程诊断医院扣款 远程诊断医院收入 远程诊断退款 远程诊断退款收入 */
  676. public const WATER_WHY = [
  677. 'REMOTEPAY' => 21,
  678. 'REMOTEINCOME' => 11,
  679. 'REMOTEREFUND' => 22,
  680. 'REFUNDINCOME' => 12
  681. ];
  682. // why 患者支付/远程诊断收入/远程诊断付款/远程诊断退款/提现
  683. /**支付方式 微信 支付宝 银联 医院扣款*/
  684. public const PAY_WAY = [
  685. "HOSPITAL" => 1,
  686. "WECHAT" => 11,
  687. "ALIPAY" => 12,
  688. "BANK" => 13
  689. ];
  690. /**支付类型 微信 医院 */
  691. public const PAY_TYPE = [
  692. "PATIENT" => 0,
  693. "HOSPITAL" => 1
  694. ];
  695. /**
  696. * 上传附件
  697. *
  698. * @ApiTitle (上传附件)
  699. * @ApiSummary (上传附件)
  700. * @ApiSector (远程诊断)
  701. * @ApiMethod (POST)
  702. * @ApiRoute (/inter/application/upload)
  703. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  704. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  705. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  706. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  707. * @ApiParams (name="file", type="string", required=true, description="上传的文件<必填>")
  708. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  709. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  710. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  711. * @ApiReturn (data="
  712. {
  713. 'status': ok,
  714. 'code': '0000',
  715. 'info' : '/upload/20180101/12346asd.jpg'
  716. }
  717. *")
  718. **/
  719. //上传附件
  720. public function upload(){
  721. // 获取表单上传文件 例如上传了001.jpg
  722. $file = request()->file('file');
  723. log::record('----------上传的文件-----------');
  724. log::record($file);
  725. // 移动到框架应用根目录/public/uploads/ 目录下
  726. if($file){
  727. $info = $file->move(ROOT_PATH . 'public' . DS . 'uploads');
  728. log::record($info);
  729. if($info){
  730. return json_encode(['status'=>'ok','code'=>'0000','info'=>'/'.$_SERVER["SERVER_NAME"]. '/' . 'uploads'. '/' .$info->getSaveName()]);
  731. }else{
  732. // 上传失败获取错误信息
  733. return json_encode(['status'=>'fail','code'=>'1040','info'=>$file->getError()]);
  734. }
  735. }
  736. }
  737. /**
  738. * 远程申请驳回
  739. *
  740. * @ApiTitle (远程申请驳回)
  741. * @ApiSummary (远程申请驳回)
  742. * @ApiSector (远程诊断)
  743. * @ApiMethod (POST)
  744. * @ApiRoute (/inter/application/reject)
  745. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  746. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  747. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  748. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  749. * @ApiParams (name="param", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  750. * @ApiParams (name="param[id]", type="string", sample="", description="预约登记exams表id值<必填>")
  751. * @ApiParams (name="param[description]", type="string", sample="", description="驳回原因<必填>")
  752. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  753. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  754. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  755. * @ApiReturn (data="
  756. {
  757. 'status': ok,
  758. 'code': '0000',
  759. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  760. }
  761. *")
  762. **/
  763. //驳回 7
  764. public function reject(){
  765. $sessionid = $_REQUEST['sessionid'];
  766. $doctor = Cache::get($sessionid);
  767. $param = $_REQUEST['param'];
  768. $id = $param['id'];
  769. $re = DB::table('remote_application')->where('id',$id)->field('exam_id,report_status')->find();
  770. if($re['report_status'] != 4){
  771. return json_encode(['status'=>'fail','code'=>'0321','msg'=>'只能驳回申请中的单子']);
  772. }
  773. $report = DB::table('report')->where('remote_application_id',$id)->field('id')->find();
  774. $info = array();
  775. $info['id'] = UUIDs::uuid16();
  776. $info['report_id'] = $report['id'];
  777. $info['description'] = $param['description'];
  778. $info['createdAt'] = date('Y-m-d H:i:s',time());
  779. $info['type'] = 4;
  780. $info['doctor_id'] = $doctor['id'];
  781. DB::table('report_record')->insert($info);
  782. $binfo = array();
  783. $binfo['id'] = UUIDs::uuid16();
  784. $binfo['initiator'] = $doctor['id'];
  785. // $info['reply'] = $param['reply']; // 回复人
  786. $binfo['remote_application_id'] = $id; //申请单id
  787. $binfo['content'] = '驳回原因:'.$param['description'];
  788. $binfo['createdAt'] = date('Y-m-d H:i:s',time());
  789. DB::table('bbs')->insert($binfo);
  790. // $message = array();
  791. // $message['id'] = UUIDs::uuid16();
  792. // $message['title'] = '申请单驳回';
  793. // $message['content'] = $param['description'];
  794. // $message['createdAt'] = date('Y-m-d H:i:s',time());
  795. $application = DB::table('remote_application')->where('id',$id)->find();
  796. // $message['doctor_id'] = $application['req_doctor_id'];
  797. // $message['institution_id'] = $application['local_institution_id'];
  798. DB::table('remote_application')->where('id',$id)->update(['report_status'=>5]);
  799. $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'])->find();
  800. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  801. // 驳回添加messages消息
  802. $t = '您的远程诊断申请被驳回';
  803. $c = '您的远程诊断申请,被'.$institution['name'].$doctor['realname'].'医师驳回。驳回理由:'.$param['description'];
  804. $d = $application['req_doctor_id'];
  805. $type = '2';
  806. $exam_class = DB::table('exams')->where('id',$re['exam_id'])->field('exam_class')->find();
  807. $url = Message::url($sessionid,$re['exam_id'],0,$exam_class['exam_class'],$report['id'],$id);
  808. Message::insert($t,$c,$d,$type,$url,1,$id);
  809. // 驳回发短信
  810. $d_phone = $dinfo['phone'];
  811. if($dinfo['institution_id'] == '22100002' || $dinfo['send_sms'] == 1){ //魏庙下级
  812. $des = mb_substr($param['description'],0,20,'utf-8');
  813. $repsone = send_message::sendSms2RejectApply($d_phone,$des);
  814. }
  815. $tel = '18910184804';
  816. $type = '驳回申请';
  817. $content = $application['id'];
  818. // send_message::sendSms2Self($tel,$type,$content);
  819. $tel = '18366391911';
  820. send_message::sendSms2Self($tel,$type,$content);
  821. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
  822. }
  823. /**
  824. * 远程申请接收
  825. *
  826. * @ApiTitle (远程申请接收)
  827. * @ApiSummary (远程申请接收)
  828. * @ApiSector (远程诊断)
  829. * @ApiMethod (POST)
  830. * @ApiRoute (/inter/application/recive)
  831. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  832. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  833. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  834. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  835. * @ApiParams (name="id", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  836. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  837. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  838. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  839. * @ApiReturn (data="
  840. {
  841. 'status': ok,
  842. 'code': '0000',
  843. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  844. }
  845. *")
  846. **/
  847. public function recive(){
  848. $sessionid = $_REQUEST['sessionid'];
  849. $doctor = Cache::get($sessionid);
  850. $id = $_REQUEST['id'];
  851. $re = DB::table('remote_application')->where('id',$id)->field('report_status,req_doctor_id,exam_id')->find();
  852. if($re['report_status'] != 4){
  853. return json_encode(['status'=>'fail','code'=>'0321','msg'=>'只能接收申请中的单子']);
  854. }
  855. DB::table('remote_application')->where('id',$id)->update(['report_status'=>6]);
  856. $application = DB::table('remote_application')->where('exam_id',$id)->find();
  857. $tel = '18910184804';
  858. $type = '接收申请';
  859. $content = $application['id'];
  860. // send_message::sendSms2Self($tel,$type,$content);
  861. // 添加messages消息
  862. $t = '您的远程诊断申请被接收';
  863. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  864. $c = '您的远程诊断申请,被'.$institution['name'].$doctor['realname'].'医师接收';
  865. $d = $re['req_doctor_id'];
  866. $type = '4';
  867. $exam_class = DB::table('exams')->where('id',$re['exam_id'])->field('exam_class')->find();
  868. $report = DB::table('report')->where('exam_id',$re['exam_id'])->where('type',1)->field('id')->find();
  869. $url = Message::url($sessionid,$re['exam_id'],0,$exam_class['exam_class'],$report['id'],$id);
  870. Message::insert($t,$c,$d,$type,$url,1,$id);
  871. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
  872. }
  873. /**
  874. * bbs通话保存
  875. *
  876. * @ApiTitle (bbs通话保存)
  877. * @ApiSummary (bbs通话保存)
  878. * @ApiSector (远程诊断)
  879. * @ApiMethod (POST)
  880. * @ApiRoute (/inter/application/bbs_save)
  881. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  882. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  883. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  884. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  885. * @ApiParams (name="param", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  886. * @ApiParams (name="param[appid]", type="string", sample="", description="申请单id值<必填>")
  887. * @ApiParams (name="param[content]", type="string", sample="", description="留言内容<必填>")
  888. * @ApiParams (name="param[attachment]", type="string", sample="", description="上传图片<选填>")
  889. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  890. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  891. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  892. * @ApiReturn (data="
  893. {
  894. 'status': ok,
  895. 'code': '0000',
  896. 'sessionid': 'a17z7a7a8f9g9rh9d89jio',
  897. 'info' : ''
  898. }
  899. *")
  900. **/
  901. public function bbs_save(){
  902. $sessionid = $_REQUEST['sessionid'];
  903. $doctor = Cache::get($sessionid);
  904. $param = $_REQUEST['param'];
  905. if(empty($param['content'])){
  906. return json_encode(['status'=>'fail','msg'=>'内容为空,请填写要发送的内容','sessionid'=>$sessionid]);
  907. }
  908. $info = array();
  909. $info['id'] = UUIDs::uuid16();
  910. $info['initiator'] = $doctor['id'];
  911. $is_remote = $_REQUEST['is_remote'];
  912. $rinfo = DB::table('remote_application')->where('id',$param['appid'])->field('req_doctor_id,remote_doctor_id')->find();
  913. if($is_remote == 1){
  914. // 远程医生
  915. $info['reply'] = $rinfo['req_doctor_id']; //申请医生
  916. $remote = 0;
  917. }else{
  918. $info['reply'] = $rinfo['remote_doctor_id']; //申请的目标远程医生
  919. $remote = 1;
  920. }
  921. $info['remote_application_id'] = $param['appid']; //申请单id
  922. $info['content'] = $param['content'];
  923. $info['attachment'] = $param['attachment'];
  924. $info['createdAt'] = date('Y-m-d H:i:s',time());
  925. DB::table('bbs')->insert($info);
  926. // 添加message消息
  927. Message::bbs_message($param['appid'],$doctor['id'],$param['content'],$info['reply'],$remote,$sessionid);
  928. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
  929. }
  930. public function getbbs(){
  931. $sessionid = $_REQUEST['sessionid'];
  932. $doctor = Cache::get($sessionid);
  933. $remote_id = $_REQUEST['application_id'];
  934. Message::read($doctor['id'],$remote_id,5);
  935. $info = DB::table('bbs')->where('remote_application_id',$remote_id)->order('createdAt desc')->select();
  936. foreach ($info as $k => $v) {
  937. $initiator = DB::table('doctors')->where('id',$v['initiator'])->field('realname')->find();
  938. $info[$k]['faqiren'] = $initiator['realname'];
  939. // $reply = DB::table('doctors')->where('id',$v['reply'])->field('realname')->find();
  940. // $info[$k]['huifuren'] = $reply['realname'];
  941. }
  942. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid,'info'=>$info]);
  943. }
  944. /**
  945. * 上传通话留言附件
  946. *
  947. * @ApiTitle (上传通话留言附件)
  948. * @ApiSummary (上传通话留言附件)
  949. * @ApiSector (远程诊断)
  950. * @ApiMethod (POST)
  951. * @ApiRoute (/inter/application/bbs_upload)
  952. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  953. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  954. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  955. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  956. * @ApiParams (name="file", type="string", required=true, description="上传的文件<必填>")
  957. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  958. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  959. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  960. * @ApiReturn (data="
  961. {
  962. 'status': ok,
  963. 'code': '0000',
  964. 'info' : '/upload/20180101/12346asd.jpg'
  965. }
  966. *")
  967. **/
  968. public function bbs_upload(){
  969. // 获取表单上传文件 例如上传了001.jpg
  970. $file = request()->file('file');
  971. log::record('----------上传的文件-----------');
  972. log::record($file);
  973. // 移动到框架应用根目录/public/uploads/ 目录下
  974. if($file){
  975. $info = $file->move(ROOT_PATH . 'public' . DS . 'uploads');
  976. log::record($info);
  977. if($info){
  978. return json_encode(['status'=>'ok','code'=>'0000','info'=>'/'.$_SERVER["SERVER_NAME"]. '/' . 'uploads'. '/' .$info->getSaveName()]);
  979. }else{
  980. // 上传失败获取错误信息
  981. echo $file->getError();
  982. }
  983. }
  984. }
  985. /**
  986. * 撤回
  987. *
  988. * @ApiTitle (撤回)
  989. * @ApiSummary (撤回)
  990. * @ApiSector (远程诊断)
  991. * @ApiMethod (POST)
  992. * @ApiRoute (/inter/application/revoke)
  993. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  994. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  995. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  996. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  997. * @ApiParams (name="id", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  998. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  999. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  1000. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  1001. * @ApiReturn (data="
  1002. {
  1003. 'status': ok,
  1004. 'code': '0000',
  1005. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  1006. }
  1007. *")
  1008. **/
  1009. //
  1010. public function revoke(){
  1011. $sessionid = $_REQUEST['sessionid'];
  1012. $doctor = Cache::get($sessionid);
  1013. $id = $_REQUEST['id'];
  1014. $status = DB::table('remote_application')->where('exam_id',$id)->field('id,report_status,remote_doctor_id')->find();
  1015. if($status['report_status'] == 4){
  1016. DB::table('remote_application')->where('exam_id',$id)->update(['report_status'=>12]);
  1017. }else{
  1018. return json_encode(['status'=>'ok','code'=>'0100','msg'=>'只能撤回申请中状态的申请单']);
  1019. }
  1020. $binfo = array();
  1021. $binfo['id'] = UUIDs::uuid16();
  1022. $binfo['initiator'] = $doctor['id'];
  1023. // $info['reply'] = $param['reply']; // 回复人
  1024. $binfo['remote_application_id'] = $status['id']; //申请单id
  1025. $binfo['content'] = '已撤回了该申请';
  1026. $binfo['createdAt'] = date('Y-m-d H:i:s',time());
  1027. DB::table('bbs')->insert($binfo);
  1028. //
  1029. $t = '发起给您的远程诊断申请被撤回';
  1030. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  1031. $c = '您的远程诊断申请'.$institution['name'].$doctor['realname'].'医师撤回';
  1032. $d = $status['remote_doctor_id'];
  1033. $type = '3';
  1034. $exam_class = DB::table('exams')->where('id',$id)->field('exam_class')->find();
  1035. $report = DB::table('report')->where('remote_application_id',$status['id'])->field('id')->find();
  1036. $url = Message::url($sessionid,$id,1,$exam_class['exam_class'],$report['id'],$status['id']);
  1037. Message::insert($t,$c,$d,$type,$url,1,$status['id']);
  1038. return json_encode(['status'=>'ok','code'=>'0000','msg'=>'撤回成功']);
  1039. }
  1040. public function bind_doctor()
  1041. {
  1042. try{
  1043. $ra_id = $_REQUEST['ra_id'];
  1044. $status = DB::table('remote_application')->where('id',$ra_id)->value('report_status');
  1045. if($status != 4){
  1046. return json_encode(['status'=>'fail','code'=>'0410','msg'=>'只能分配未经处理的报告']);
  1047. }
  1048. $did = $_REQUEST['did'];
  1049. $info = DB::table('remote_application')->where('id',$ra_id)->update(['remote_doctor_id'=>$did]);
  1050. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info]);
  1051. }catch(\Exception $e){
  1052. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  1053. }
  1054. }
  1055. //获取医生的接收和分配权限
  1056. public function get_doctor_role()
  1057. {
  1058. try{
  1059. $sessionid = $_REQUEST['sessionid'];
  1060. $doctor = Cache::get($sessionid);
  1061. $info = [];
  1062. $info['is_admin'] = $doctor['is_admin'];
  1063. $role = DB::table('doctor_class')->where('doctor_id',$doctor['id'])->value('doctor_class');
  1064. if(strpos($role,'7') !== false){
  1065. $info['is_doctor'] = 1;
  1066. }else{
  1067. $info['is_doctor'] = 0;
  1068. }
  1069. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info]);
  1070. }catch(\Exception $e){
  1071. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  1072. }
  1073. }
  1074. }