Application.php 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676
  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. class Application extends Base
  14. {
  15. /**
  16. * 发起远程申请
  17. *
  18. * @ApiTitle (发起远程申请)
  19. * @ApiSummary (发起远程申请)
  20. * @ApiSector (远程诊断)
  21. * @ApiMethod (POST)
  22. * @ApiRoute (/inter/application/index)
  23. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  24. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  25. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  26. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  27. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  28. * @ApiParams (name="is_remote", type="string", required=true, description="参数json字符串")
  29. * @ApiParams (name="param[id]", type="string", sample="", description="预约登记exams表id值<必填>")
  30. * @ApiParams (name="param[rid]", type="string", sample="", description="远程申请表id值<远程列表进入必填>")
  31. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  32. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  33. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  34. * @ApiReturnParams (name="is_remote", type="object", sample="{}", description="是否为远程诊断进入")
  35. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  36. * @ApiReturn (data="
  37. {
  38. 'status': ok,
  39. 'code': '0000',
  40. 'sessionid': 'a17z7a7a8f9g9rh9d89jio',
  41. 'is_remote': 1,
  42. 'info' : '',
  43. 'rid' : ''
  44. }
  45. *")
  46. **/
  47. public function index(){
  48. try{
  49. $sessionid = $_REQUEST['sessionid'];
  50. $param = $_REQUEST['param'];
  51. $id = $param['id'];
  52. $is_remote = 0;
  53. if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote']==1){
  54. $is_remote = 1;
  55. }
  56. $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();
  57. $exam_class = DB::table('constant')->where('id',$info['exam_class'])->field('constant_value')->find();
  58. $exam_subclass = DB::table('exam_subclass')->where('id',$info['exam_sub_class'])->cache(300)->find();
  59. $exam_project = DB::table('exam_project')->where('id',$info['exam_project'])->cache(300)->find();
  60. $device = DB::table('device')->where('id',$info['device'])->cache(300)->find();
  61. $info['exam_class_name'] = $exam_class['constant_value'];
  62. $info['exam_subclass_name'] = $exam_subclass['name'];
  63. $info['exam_project_name'] = $exam_project['name'];
  64. $info['device_name'] = $device['name'];
  65. $patient_info = DB::table('patient_infos')->where('id',$info['patient_id'])->field(['temp_patient_id','id','name','sex','age','birthday'])->find();
  66. $info['pid'] = $patient_info['id'];
  67. $info['temp_patient_id'] = $patient_info['temp_patient_id'];
  68. $info['name'] = $patient_info['name'];
  69. $info['sex'] = $patient_info['sex'];
  70. $info['age'] = $patient_info['age'];
  71. if(!empty($patient_info['birthday'])){
  72. $info['birthday'] = $patient_info['birthday'];
  73. }
  74. $doctor = Cache::get($sessionid);
  75. $institution_id = $doctor['institution_id'];
  76. $hospital = DB::table('institution')->where('id',$institution_id)->find();
  77. $parent_hosp = explode(',',$hospital['parent_institution']);
  78. $parent_name = array();
  79. foreach($parent_hosp as $v){
  80. $phname = DB::table("institution")->where('id',$v)->cache(300)->field(['id','name'])->find();
  81. $doctor_info = DB::table('doctors')->where('institution_id',$v)->field('id,realname')->select();
  82. $phname['doctor'] = $doctor_info;
  83. $parent_name[] =$phname;
  84. }
  85. $info['parent_hospital'] = $parent_name;
  86. //申请信息
  87. if(isset($param['rid']) && !empty($param['rid'])){
  88. $rid = $param['rid'];
  89. $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();
  90. $aid = $application['id'];
  91. }else{
  92. $rid = '';
  93. $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();
  94. $aid = $application['id'];
  95. }
  96. if($is_remote == 1){
  97. Message::read($doctor['id'],$aid,1);
  98. //远程申请点击进入
  99. $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'])->field('department_id')->find();
  100. $dep = DB::table('department')->where('id',$dinfo['department_id'])->field('department_name')->find();
  101. }else{
  102. Message::read($doctor['id'],$aid,2);
  103. //本地远程申请中
  104. $dep = DB::table('department')->where('id',$doctor['department_id'])->field('department_name')->find();
  105. }
  106. $info['department_name'] = $dep['department_name'];
  107. if(empty($application)){
  108. $exam_application = DB::table('exams')->where('id',$id)->field(['illness_desc','phys_sign','clin_symp','remark','clin_diag','anamnesis','family_ill'])->find();
  109. if(empty($exam_application['anamnesis'])){
  110. $exam_application['anamnesis'] = '';
  111. }else{
  112. $exam_application['anamnesis'] = explode(',',$exam_application['anamnesis']);
  113. }
  114. if(empty($exam_application['family_ill'])){
  115. $exam_application['family_ill'] = '';
  116. }else{
  117. $exam_application['family_ill'] = explode(',',$exam_application['family_ill']);
  118. }
  119. $exam_application['report_status'] = '';
  120. $info['application'] = $exam_application;
  121. }else{
  122. $remote_name = DB::table('doctors')->where('id',$application['remote_doctor_id'])->field('realname')->find();
  123. $application['remote_doctor'] = $remote_name['realname'];
  124. if(empty($application['anamnesis'])){
  125. $application['anamnesis'] = '';
  126. }else{
  127. $application['anamnesis'] = explode(',',$application['anamnesis']);
  128. }
  129. if(empty($application['family_ill'])){
  130. $application['family_ill'] = '';
  131. }else{
  132. $application['family_ill'] = explode(',',$application['family_ill']);
  133. }
  134. $info['application'] = $application;
  135. }
  136. $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();
  137. $info['unread_message_num'] = $count['count'];
  138. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info,'sessionid'=>$sessionid,'is_remote'=>$is_remote,'rid'=>$aid]);
  139. }catch(\Exception $e){
  140. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  141. }
  142. }
  143. /**
  144. * 提交申请
  145. *
  146. * @ApiTitle (提交申请)
  147. * @ApiSummary (提交申请)
  148. * @ApiSector (远程诊断)
  149. * @ApiMethod (POST)
  150. * @ApiRoute (/inter/application/apply)
  151. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  152. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  153. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  154. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  155. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  156. * @ApiParams (name="param[id]", type="string", sample="", description="预约登记exams表id值<必填>")
  157. * @ApiParams (name="param[illness]", type="string", sample="", description="主诉<选填>")
  158. * @ApiParams (name="param[clin_symp]", type="string", sample="", description="临床症状<选填>")
  159. * @ApiParams (name="param[anamnesis]", type="string", sample="", description="既往史<选填>")
  160. * @ApiParams (name="param[family_ill]", type="string", sample="", description="家族史<选填>")
  161. * @ApiParams (name="param[remark]", type="string", sample="", description="备注<选填>")
  162. * @ApiParams (name="param[institution_id]", type="string", sample="", description="发起申请医院id值<选填>")
  163. * @ApiParams (name="param[clin_diag]", type="string", sample="", description="临床诊断<选填>")
  164. * @ApiParams (name="param[remote_institution]", type="string", sample="", description="申请的目标医院id值<选填>")
  165. * @ApiParams (name="param[is_urgent]", type="string", sample="", description="是否急诊 0否 1是<选填>")
  166. * @ApiParams (name="param[description]", type="string", sample="", description="申请描述<选填>")
  167. * @ApiParams (name="param[remote_doctor_id]", type="string", sample="", description="申请的目标医生id值<选填>")
  168. * @ApiParams (name="param[attachment]", type="string", sample="", description="附件<选填>")
  169. * @ApiParams (name="param[apply]", type="string", sample="", description="保存或者申请 存在值即保存 不存在则为申请<必填>")
  170. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  171. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  172. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  173. * @ApiReturn (data="
  174. {
  175. 'status': ok,
  176. 'code': '0000',
  177. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  178. }
  179. *")
  180. **/
  181. public function apply(){
  182. try{
  183. log::record($_REQUEST);
  184. $sessionid = $_REQUEST['sessionid'];
  185. $doctor = Cache::get($sessionid);
  186. // 远程申请权限 6
  187. $return = Verify::check_role($sessionid,6);
  188. if($return != 1){
  189. return json_encode(['status'=>'fail','code'=>'1029','msg'=>'没有操作权限']);
  190. }
  191. $param = $_REQUEST['param'];
  192. $application_info = array();
  193. $application_info['remote_institution_id'] = isset($param['remote_institution']) ? $param['remote_institution'] : '';
  194. if(isset($param['remote_doctor_id']) && !empty($param['remote_doctor_id']) && empty($application_info['remote_doctor_id'])){
  195. $remote_doctor = DB::table('doctors')->where('id',$param['remote_doctor_id'])->find();
  196. $application_info['remote_institution_id'] = $remote_doctor['institution_id'];
  197. }
  198. if(empty($application_info['remote_institution_id'])){
  199. return json_encode(['status'=>'fail','code'=>'3029','msg'=>'没有选择远程机构']);
  200. }
  201. $exam_info = DB::table('exams')->where('id',$param['id'])->field('exam_class,exam_status,patient_id')->find();
  202. // 修改病人姓名
  203. DB::table('patient_infos')->where('id',$exam_info['patient_id'])->update(['name'=>$param['name']]);
  204. if($exam_info['exam_status'] != 3 && $exam_info['exam_status'] != 5 && $exam_info['exam_status'] != 8){
  205. // 3 检查完毕 5已驳回
  206. switch($exam_info['exam_status']){
  207. case 1:
  208. $msg = '患者还未检查,请检查完毕后再进行远程申请';
  209. return json_encode(['status'=>'fail','code'=>'1029','msg'=>$msg]);
  210. break;
  211. case 2:
  212. $msg = '影像未到达,不能发起远程申请';
  213. return json_encode(['status'=>'fail','code'=>'1029','msg'=>$msg]);
  214. break;
  215. }
  216. }
  217. Verify::applicationCheck($param);
  218. $where = array();
  219. // 申请医生
  220. $where['req_doctor_id'] = $doctor['id'];
  221. $where['remote_institution_id'] = $application_info['remote_institution_id'];
  222. // 只允许有一个申请 ----------------------------- 暂时添加
  223. $r = DB::table('remote_application')->where('exam_id',$param['id'])->where('report_status','not in',',5,12')->find();
  224. if($r){
  225. return json_encode(['status'=>'fail','code'=>'1120','msg'=>'每个医院同一个检查只能申请一次']);
  226. }
  227. //不等于9 代表
  228. $a_info = DB::table('remote_application')->where($where)->where('exam_id',$param['id'])->where('report_status','not in','12,5,9')->find();
  229. if($a_info){
  230. return json_encode(['status'=>'fail','code'=>'1120','msg'=>'该申请目标医院存在未完成报告,只有报告完成后才能再次发起申请']);
  231. }
  232. $application_info['exam_id'] = isset($param['id']) ? $param['id'] : '';
  233. $application_info['illness_desc'] = isset($param['illness']) ? $param['illness'] : '';
  234. $application_info['phys_sign'] = isset($param['phys_sign']) ? $param['phys_sign'] : '';
  235. $application_info['clin_symp'] = isset($param['clin_symp']) ? $param['clin_symp'] : '';
  236. if(!empty($param['anamnesis'])){
  237. $application_info['anamnesis'] = implode(',',$param['anamnesis']);
  238. }
  239. if(!empty($param['family_ill'])){
  240. $application_info['family_ill'] = implode(',',$param['family_ill']);
  241. }
  242. $application_info['remark'] = isset($param['remark']) ? $param['remark'] : '';
  243. $application_info['local_institution_id'] = $doctor['institution_id'];
  244. $application_info['req_date_time'] = date('Y-m-d H:i:s',time());
  245. $application_info['clin_diag'] = isset($param['clin_diag']) ? $param['clin_diag'] : '';
  246. if(isset($param['is_urgent']) && $param['is_urgent'] == 'true' ){
  247. $application_info['is_urgent'] = 1;
  248. $application_info['remote_doctor_id'] = '';
  249. $d_time = date('H:i',strtotime('+30 min'));
  250. }else{
  251. $application_info['is_urgent'] = 0;
  252. $application_info['remote_doctor_id'] = isset($param['remote_doctor_id']) ? $param['remote_doctor_id'] : '';
  253. $d_time = date('H:i',strtotime('+1 hour'));
  254. }
  255. $application_info['application_desc'] = isset($param['description']) ? $param['description'] : '';
  256. $application_info['req_doctor_id'] = $doctor['id'];
  257. $application_info['remote_doctor_id'] = isset($param['remote_doctor_id']) ? $param['remote_doctor_id'] : '';
  258. $application_info['attachment'] = isset($param['attachment']) ? $param['attachment'] : '';
  259. // $remote_application = DB::table('remote_application')->where('exam_id',$param['id'])->select();
  260. // 申请远程
  261. // if(empty($remote_application)){
  262. log::record('新增远程申请');
  263. $re = DB::table('remote_application')->where('exam_id',$param['id'])->find();
  264. $report = array();
  265. if($re){
  266. // 存在被驳回申请 再次申请时则为驳回后发起的申请
  267. DB::table('remote_application')->where('exam_id',$param['id'])->update($application_info);
  268. $app_id = $re['id'];
  269. }else{
  270. $application_info['id'] = UUIDs::uuid16();
  271. $application_info['createdAt'] = date('Y-m-d H:i:s',time());
  272. DB::table('remote_application')->insert($application_info);
  273. $app_id = $application_info['id'];
  274. }
  275. $aid = $app_id;
  276. $r_info = DB::table('report')->where('exam_id',$param['id'])->find();
  277. if(empty($r_info)){
  278. $report['id'] = UUIDs::uuid16();
  279. $report['exam_id'] = $param['id'];
  280. $report['remote_application_id'] = $aid;
  281. $report['type'] = 2;
  282. DB::table('report')->insert($report);
  283. $r_id = $report['id'];
  284. }else{
  285. $r_id = $r_info['id'];
  286. }
  287. // }else{
  288. // log::record('修改远程申请');
  289. // DB::table('remote_application')->where('exam_id',$param['id'])->update($application_info);
  290. // $r = DB::table('remote_application')->where('exam_id',$param['id'])->field('id')->find();
  291. // $aid = $r['id'];
  292. // }
  293. if(isset($param['apply']) && !empty($param['apply'])){
  294. DB::table('remote_application')->where('exam_id',$param['id'])->update(['report_status'=>4]);
  295. // 添加messages信息
  296. $t = '收到一条远程诊断申请';
  297. $ins = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  298. $c = $ins['name'].$doctor['realname'].'医师向您发起一条远程诊断申请';
  299. $d = $application_info['remote_doctor_id'];
  300. $type = '1';
  301. $url = Message::url($sessionid,$param['id'],1,$exam_info['exam_class'],$r_id,$aid);
  302. Message::insert($t,$c,$d,$type,$url,1,$aid);
  303. //保存 申请
  304. $dinfo = DB::table('doctors')->where('id',$application_info['remote_doctor_id'])->find();
  305. $d_phone = $dinfo['phone'];
  306. $d_name = $dinfo['realname'];
  307. if($dinfo['institution_id'] == '22100003' || $dinfo['send_sms'] == 1){ //魏庙
  308. $repsone = send_message::sendSms2Apply($d_phone,$d_time,$d_name);
  309. }
  310. $tel = '18910184804';
  311. $type = '发起申请';
  312. $content = $aid;
  313. $response = send_message::sendSms2Self($tel,$type,$content);
  314. }
  315. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid,'aid'=>$aid]);
  316. }catch(\Exception $e){
  317. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  318. }
  319. }
  320. /**
  321. * 上传附件
  322. *
  323. * @ApiTitle (上传附件)
  324. * @ApiSummary (上传附件)
  325. * @ApiSector (远程诊断)
  326. * @ApiMethod (POST)
  327. * @ApiRoute (/inter/application/upload)
  328. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  329. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  330. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  331. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  332. * @ApiParams (name="file", type="string", required=true, description="上传的文件<必填>")
  333. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  334. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  335. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  336. * @ApiReturn (data="
  337. {
  338. 'status': ok,
  339. 'code': '0000',
  340. 'info' : '/upload/20180101/12346asd.jpg'
  341. }
  342. *")
  343. **/
  344. //上传附件
  345. public function upload(){
  346. // 获取表单上传文件 例如上传了001.jpg
  347. $file = request()->file('file');
  348. log::record('----------上传的文件-----------');
  349. log::record($file);
  350. // 移动到框架应用根目录/public/uploads/ 目录下
  351. if($file){
  352. $info = $file->move(ROOT_PATH . 'public' . DS . 'uploads');
  353. log::record($info);
  354. if($info){
  355. return json_encode(['status'=>'ok','code'=>'0000','info'=>'/'.$_SERVER["SERVER_NAME"]. '/' . 'uploads'. '/' .$info->getSaveName()]);
  356. }else{
  357. // 上传失败获取错误信息
  358. return json_encode(['status'=>'fail','code'=>'1040','info'=>$file->getError()]);
  359. }
  360. }
  361. }
  362. /**
  363. * 远程申请驳回
  364. *
  365. * @ApiTitle (远程申请驳回)
  366. * @ApiSummary (远程申请驳回)
  367. * @ApiSector (远程诊断)
  368. * @ApiMethod (POST)
  369. * @ApiRoute (/inter/application/reject)
  370. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  371. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  372. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  373. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  374. * @ApiParams (name="param", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  375. * @ApiParams (name="param[id]", type="string", sample="", description="预约登记exams表id值<必填>")
  376. * @ApiParams (name="param[description]", type="string", sample="", description="驳回原因<必填>")
  377. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  378. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  379. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  380. * @ApiReturn (data="
  381. {
  382. 'status': ok,
  383. 'code': '0000',
  384. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  385. }
  386. *")
  387. **/
  388. //驳回 7
  389. public function reject(){
  390. $sessionid = $_REQUEST['sessionid'];
  391. $doctor = Cache::get($sessionid);
  392. $param = $_REQUEST['param'];
  393. $id = $param['id'];
  394. $re = DB::table('remote_application')->where('id',$id)->field('exam_id,report_status')->find();
  395. if($re['report_status'] != 4){
  396. return json_encode(['status'=>'fail','code'=>'0321','msg'=>'只能驳回申请中的单子']);
  397. }
  398. $report = DB::table('report')->where('remote_application_id',$id)->field('id')->find();
  399. $info = array();
  400. $info['id'] = UUIDs::uuid16();
  401. $info['report_id'] = $report['id'];
  402. $info['description'] = $param['description'];
  403. $info['createdAt'] = date('Y-m-d H:i:s',time());
  404. $info['type'] = 4;
  405. $info['doctor_id'] = $doctor['id'];
  406. DB::table('report_record')->insert($info);
  407. $binfo = array();
  408. $binfo['id'] = UUIDs::uuid16();
  409. $binfo['initiator'] = $doctor['id'];
  410. // $info['reply'] = $param['reply']; // 回复人
  411. $binfo['remote_application_id'] = $id; //申请单id
  412. $binfo['content'] = '驳回原因:'.$param['description'];
  413. $binfo['createdAt'] = date('Y-m-d H:i:s',time());
  414. DB::table('bbs')->insert($binfo);
  415. // $message = array();
  416. // $message['id'] = UUIDs::uuid16();
  417. // $message['title'] = '申请单驳回';
  418. // $message['content'] = $param['description'];
  419. // $message['createdAt'] = date('Y-m-d H:i:s',time());
  420. $application = DB::table('remote_application')->where('id',$id)->find();
  421. // $message['doctor_id'] = $application['req_doctor_id'];
  422. // $message['institution_id'] = $application['local_institution_id'];
  423. DB::table('remote_application')->where('id',$id)->update(['report_status'=>5]);
  424. $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'])->find();
  425. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  426. // 驳回添加messages消息
  427. $t = '您的远程诊断申请被驳回';
  428. $c = '您的远程诊断申请,被'.$institution['name'].$doctor['realname'].'医师驳回。驳回理由:'.$param['description'];
  429. $d = $application['req_doctor_id'];
  430. $type = '2';
  431. $exam_class = DB::table('exams')->where('id',$re['exam_id'])->field('exam_class')->find();
  432. $url = Message::url($sessionid,$re['exam_id'],0,$exam_class['exam_class'],$report['id'],$id);
  433. Message::insert($t,$c,$d,$type,$url,1,$id);
  434. // 驳回发短信
  435. $d_phone = $dinfo['phone'];
  436. if($dinfo['institution_id'] == '22100002' || $dinfo['send_sms'] == 1){ //魏庙下级
  437. $des = mb_substr($param['description'],0,20,'utf-8');
  438. $repsone = send_message::sendSms2RejectApply($d_phone,$des);
  439. }
  440. $tel = '18910184804';
  441. $type = '驳回申请';
  442. $content = $application['id'];
  443. send_message::sendSms2Self($tel,$type,$content);
  444. $tel = '18366391911';
  445. send_message::sendSms2Self($tel,$type,$content);
  446. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
  447. }
  448. /**
  449. * 远程申请接收
  450. *
  451. * @ApiTitle (远程申请接收)
  452. * @ApiSummary (远程申请接收)
  453. * @ApiSector (远程诊断)
  454. * @ApiMethod (POST)
  455. * @ApiRoute (/inter/application/recive)
  456. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  457. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  458. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  459. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  460. * @ApiParams (name="id", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  461. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  462. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  463. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  464. * @ApiReturn (data="
  465. {
  466. 'status': ok,
  467. 'code': '0000',
  468. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  469. }
  470. *")
  471. **/
  472. public function recive(){
  473. $sessionid = $_REQUEST['sessionid'];
  474. $doctor = Cache::get($sessionid);
  475. $id = $_REQUEST['id'];
  476. $re = DB::table('remote_application')->where('id',$id)->field('report_status,req_doctor_id,exam_id')->find();
  477. if($re['report_status'] != 4){
  478. return json_encode(['status'=>'fail','code'=>'0321','msg'=>'只能接收申请中的单子']);
  479. }
  480. DB::table('remote_application')->where('id',$id)->update(['report_status'=>6]);
  481. $application = DB::table('remote_application')->where('exam_id',$id)->find();
  482. $tel = '18910184804';
  483. $type = '接收申请';
  484. $content = $application['id'];
  485. send_message::sendSms2Self($tel,$type,$content);
  486. // 添加messages消息
  487. $t = '您的远程诊断申请被接收';
  488. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  489. $c = '您的远程诊断申请,被'.$institution['name'].$doctor['realname'].'医师接收';
  490. $d = $re['req_doctor_id'];
  491. $type = '4';
  492. $exam_class = DB::table('exams')->where('id',$re['exam_id'])->field('exam_class')->find();
  493. $report = DB::table('report')->where('remote_application_id',$id)->field('id')->find();
  494. $url = Message::url($sessionid,$re['exam_id'],0,$exam_class['exam_class'],$report['id'],$id);
  495. Message::insert($t,$c,$d,$type,$url,1,$id);
  496. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
  497. }
  498. /**
  499. * bbs通话保存
  500. *
  501. * @ApiTitle (bbs通话保存)
  502. * @ApiSummary (bbs通话保存)
  503. * @ApiSector (远程诊断)
  504. * @ApiMethod (POST)
  505. * @ApiRoute (/inter/application/bbs_save)
  506. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  507. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  508. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  509. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  510. * @ApiParams (name="param", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  511. * @ApiParams (name="param[appid]", type="string", sample="", description="申请单id值<必填>")
  512. * @ApiParams (name="param[content]", type="string", sample="", description="留言内容<必填>")
  513. * @ApiParams (name="param[attachment]", type="string", sample="", description="上传图片<选填>")
  514. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  515. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  516. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  517. * @ApiReturn (data="
  518. {
  519. 'status': ok,
  520. 'code': '0000',
  521. 'sessionid': 'a17z7a7a8f9g9rh9d89jio',
  522. 'info' : ''
  523. }
  524. *")
  525. **/
  526. public function bbs_save(){
  527. $sessionid = $_REQUEST['sessionid'];
  528. $doctor = Cache::get($sessionid);
  529. $param = $_REQUEST['param'];
  530. if(empty($param['content'])){
  531. return json_encode(['status'=>'fail','msg'=>'内容为空,请填写要发送的内容','sessionid'=>$sessionid]);
  532. }
  533. $info = array();
  534. $info['id'] = UUIDs::uuid16();
  535. $info['initiator'] = $doctor['id'];
  536. $is_remote = $_REQUEST['is_remote'];
  537. $rinfo = DB::table('remote_application')->where('id',$param['appid'])->field('req_doctor_id,remote_doctor_id')->find();
  538. if($is_remote == 1){
  539. // 远程医生
  540. $info['reply'] = $rinfo['req_doctor_id']; //申请医生
  541. $remote = 0;
  542. }else{
  543. $info['reply'] = $rinfo['remote_doctor_id']; //申请的目标远程医生
  544. $remote = 1;
  545. }
  546. $info['remote_application_id'] = $param['appid']; //申请单id
  547. $info['content'] = $param['content'];
  548. $info['attachment'] = $param['attachment'];
  549. $info['createdAt'] = date('Y-m-d H:i:s',time());
  550. DB::table('bbs')->insert($info);
  551. // 添加message消息
  552. Message::bbs_message($param['appid'],$doctor['id'],$param['content'],$info['reply'],$remote,$sessionid);
  553. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
  554. }
  555. public function getbbs(){
  556. $sessionid = $_REQUEST['sessionid'];
  557. $doctor = Cache::get($sessionid);
  558. $remote_id = $_REQUEST['application_id'];
  559. Message::read($doctor['id'],$remote_id,5);
  560. $info = DB::table('bbs')->where('remote_application_id',$remote_id)->order('createdAt desc')->select();
  561. foreach ($info as $k => $v) {
  562. $initiator = DB::table('doctors')->where('id',$v['initiator'])->field('realname')->find();
  563. $info[$k]['faqiren'] = $initiator['realname'];
  564. // $reply = DB::table('doctors')->where('id',$v['reply'])->field('realname')->find();
  565. // $info[$k]['huifuren'] = $reply['realname'];
  566. }
  567. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid,'info'=>$info]);
  568. }
  569. /**
  570. * 上传通话留言附件
  571. *
  572. * @ApiTitle (上传通话留言附件)
  573. * @ApiSummary (上传通话留言附件)
  574. * @ApiSector (远程诊断)
  575. * @ApiMethod (POST)
  576. * @ApiRoute (/inter/application/bbs_upload)
  577. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  578. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  579. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  580. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  581. * @ApiParams (name="file", type="string", required=true, description="上传的文件<必填>")
  582. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  583. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  584. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  585. * @ApiReturn (data="
  586. {
  587. 'status': ok,
  588. 'code': '0000',
  589. 'info' : '/upload/20180101/12346asd.jpg'
  590. }
  591. *")
  592. **/
  593. public function bbs_upload(){
  594. // 获取表单上传文件 例如上传了001.jpg
  595. $file = request()->file('file');
  596. log::record('----------上传的文件-----------');
  597. log::record($file);
  598. // 移动到框架应用根目录/public/uploads/ 目录下
  599. if($file){
  600. $info = $file->move(ROOT_PATH . 'public' . DS . 'uploads');
  601. log::record($info);
  602. if($info){
  603. return json_encode(['status'=>'ok','code'=>'0000','info'=>'/'.$_SERVER["SERVER_NAME"]. '/' . 'uploads'. '/' .$info->getSaveName()]);
  604. }else{
  605. // 上传失败获取错误信息
  606. echo $file->getError();
  607. }
  608. }
  609. }
  610. /**
  611. * 撤回
  612. *
  613. * @ApiTitle (撤回)
  614. * @ApiSummary (撤回)
  615. * @ApiSector (远程诊断)
  616. * @ApiMethod (POST)
  617. * @ApiRoute (/inter/application/revoke)
  618. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  619. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  620. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  621. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  622. * @ApiParams (name="id", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  623. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  624. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  625. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  626. * @ApiReturn (data="
  627. {
  628. 'status': ok,
  629. 'code': '0000',
  630. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  631. }
  632. *")
  633. **/
  634. //
  635. public function revoke(){
  636. $sessionid = $_REQUEST['sessionid'];
  637. $doctor = Cache::get($sessionid);
  638. $id = $_REQUEST['id'];
  639. $status = DB::table('remote_application')->where('exam_id',$id)->field('id,report_status,remote_doctor_id')->find();
  640. if($status['report_status'] == 4){
  641. DB::table('remote_application')->where('exam_id',$id)->update(['report_status'=>12]);
  642. }else{
  643. return json_encode(['status'=>'ok','code'=>'0100','msg'=>'只能撤回申请中状态的申请单']);
  644. }
  645. $binfo = array();
  646. $binfo['id'] = UUIDs::uuid16();
  647. $binfo['initiator'] = $doctor['id'];
  648. // $info['reply'] = $param['reply']; // 回复人
  649. $binfo['remote_application_id'] = $status['id']; //申请单id
  650. $binfo['content'] = '已撤回了该申请';
  651. $binfo['createdAt'] = date('Y-m-d H:i:s',time());
  652. DB::table('bbs')->insert($binfo);
  653. //
  654. $t = '发起给您的远程诊断申请被撤回';
  655. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  656. $c = '您的远程诊断申请'.$institution['name'].$doctor['realname'].'医师撤回';
  657. $d = $status['remote_doctor_id'];
  658. $type = '3';
  659. $exam_class = DB::table('exams')->where('id',$id)->field('exam_class')->find();
  660. $report = DB::table('report')->where('remote_application_id',$status['id'])->field('id')->find();
  661. $url = Message::url($sessionid,$id,1,$exam_class['exam_class'],$report['id'],$status['id']);
  662. Message::insert($t,$c,$d,$type,$url,1,$status['id']);
  663. return json_encode(['status'=>'ok','code'=>'0000','msg'=>'撤回成功']);
  664. }
  665. }