Application.php 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680
  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. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info,'sessionid'=>$sessionid,'is_remote'=>$is_remote,'rid'=>$rid]);
  137. }catch(\Exception $e){
  138. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  139. }
  140. }
  141. /**
  142. * 提交申请
  143. *
  144. * @ApiTitle (提交申请)
  145. * @ApiSummary (提交申请)
  146. * @ApiSector (远程诊断)
  147. * @ApiMethod (POST)
  148. * @ApiRoute (/inter/application/apply)
  149. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  150. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  151. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  152. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  153. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  154. * @ApiParams (name="param[id]", type="string", sample="", description="预约登记exams表id值<必填>")
  155. * @ApiParams (name="param[illness]", type="string", sample="", description="主诉<选填>")
  156. * @ApiParams (name="param[clin_symp]", type="string", sample="", description="临床症状<选填>")
  157. * @ApiParams (name="param[anamnesis]", type="string", sample="", description="既往史<选填>")
  158. * @ApiParams (name="param[family_ill]", type="string", sample="", description="家族史<选填>")
  159. * @ApiParams (name="param[remark]", type="string", sample="", description="备注<选填>")
  160. * @ApiParams (name="param[institution_id]", type="string", sample="", description="发起申请医院id值<选填>")
  161. * @ApiParams (name="param[clin_diag]", type="string", sample="", description="临床诊断<选填>")
  162. * @ApiParams (name="param[remote_institution]", type="string", sample="", description="申请的目标医院id值<选填>")
  163. * @ApiParams (name="param[is_urgent]", type="string", sample="", description="是否急诊 0否 1是<选填>")
  164. * @ApiParams (name="param[description]", type="string", sample="", description="申请描述<选填>")
  165. * @ApiParams (name="param[remote_doctor_id]", type="string", sample="", description="申请的目标医生id值<选填>")
  166. * @ApiParams (name="param[attachment]", type="string", sample="", description="附件<选填>")
  167. * @ApiParams (name="param[apply]", type="string", sample="", description="保存或者申请 存在值即保存 不存在则为申请<必填>")
  168. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  169. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  170. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  171. * @ApiReturn (data="
  172. {
  173. 'status': ok,
  174. 'code': '0000',
  175. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  176. }
  177. *")
  178. **/
  179. public function apply(){
  180. try{
  181. log::record($_REQUEST);
  182. $sessionid = $_REQUEST['sessionid'];
  183. $doctor = Cache::get($sessionid);
  184. // 远程申请权限 6
  185. $return = Verify::check_role($sessionid,6);
  186. if($return != 1){
  187. return json_encode(['status'=>'fail','code'=>'1029','msg'=>'没有操作权限']);
  188. }
  189. $param = $_REQUEST['param'];
  190. $application_info = array();
  191. $application_info['remote_institution_id'] = isset($param['remote_institution']) ? $param['remote_institution'] : '';
  192. if(isset($param['remote_doctor_id']) && !empty($param['remote_doctor_id']) && empty($application_info['remote_doctor_id'])){
  193. $remote_doctor = DB::table('doctors')->where('id',$param['remote_doctor_id'])->find();
  194. $application_info['remote_institution_id'] = $remote_doctor['institution_id'];
  195. }
  196. if(empty($application_info['remote_institution_id'])){
  197. return json_encode(['status'=>'fail','code'=>'3029','msg'=>'没有选择远程机构']);
  198. }
  199. $exam_info = DB::table('exams')->where('id',$param['id'])->field('exam_class,exam_status,patient_id')->find();
  200. // 修改病人姓名
  201. DB::table('patient_infos')->where('id',$exam_info['patient_id'])->update(['name'=>$param['name']]);
  202. if($exam_info['exam_status'] != 3 && $exam_info['exam_status'] != 5 && $exam_info['exam_status'] != 8){
  203. // 3 检查完毕 5已驳回
  204. switch($exam_info['exam_status']){
  205. case 1:
  206. $msg = '患者还未检查,请检查完毕后再进行远程申请';
  207. return json_encode(['status'=>'fail','code'=>'1029','msg'=>$msg]);
  208. break;
  209. case 2:
  210. $msg = '影像未到达,不能发起远程申请';
  211. return json_encode(['status'=>'fail','code'=>'1029','msg'=>$msg]);
  212. break;
  213. }
  214. }
  215. Verify::applicationCheck($param);
  216. $where = array();
  217. // 申请医生
  218. $where['req_doctor_id'] = $doctor['id'];
  219. $where['remote_institution_id'] = $application_info['remote_institution_id'];
  220. // 只允许有一个申请 ----------------------------- 暂时添加
  221. $r = DB::table('remote_application')->where('exam_id',$param['id'])->where('report_status','not in','null,5,12')->find();
  222. if($r){
  223. return json_encode(['status'=>'fail','code'=>'1120','msg'=>'每个医院同一个检查只能申请一次']);
  224. }
  225. //不等于9 代表
  226. $a_info = DB::table('remote_application')->where($where)->where('exam_id',$param['id'])->where('report_status','not in','12,5,9')->find();
  227. if($a_info){
  228. return json_encode(['status'=>'fail','code'=>'1120','msg'=>'该申请目标医院存在未完成报告,只有报告完成后才能再次发起申请']);
  229. }
  230. $application_info['exam_id'] = isset($param['id']) ? $param['id'] : '';
  231. $application_info['illness_desc'] = isset($param['illness']) ? $param['illness'] : '';
  232. $application_info['phys_sign'] = isset($param['phys_sign']) ? $param['phys_sign'] : '';
  233. $application_info['clin_symp'] = isset($param['clin_symp']) ? $param['clin_symp'] : '';
  234. if(!empty($param['anamnesis'])){
  235. $application_info['anamnesis'] = implode(',',$param['anamnesis']);
  236. }
  237. if(!empty($param['family_ill'])){
  238. $application_info['family_ill'] = implode(',',$param['family_ill']);
  239. }
  240. $application_info['remark'] = isset($param['remark']) ? $param['remark'] : '';
  241. $application_info['local_institution_id'] = $doctor['institution_id'];
  242. $application_info['req_date_time'] = date('Y-m-d H:i:s',time());
  243. $application_info['clin_diag'] = isset($param['clin_diag']) ? $param['clin_diag'] : '';
  244. if(isset($param['is_urgent']) && $param['is_urgent'] == 'true' ){
  245. $application_info['is_urgent'] = 1;
  246. $application_info['remote_doctor_id'] = '';
  247. $d_time = date('H:i',strtotime('+30 min'));
  248. }else{
  249. $application_info['is_urgent'] = 0;
  250. $application_info['remote_doctor_id'] = isset($param['remote_doctor_id']) ? $param['remote_doctor_id'] : '';
  251. $d_time = date('H:i',strtotime('+1 hour'));
  252. }
  253. $application_info['application_desc'] = isset($param['description']) ? $param['description'] : '';
  254. $application_info['req_doctor_id'] = $doctor['id'];
  255. $application_info['remote_doctor_id'] = isset($param['remote_doctor_id']) ? $param['remote_doctor_id'] : '';
  256. $application_info['attachment'] = isset($param['attachment']) ? $param['attachment'] : '';
  257. // $remote_application = DB::table('remote_application')->where('exam_id',$param['id'])->select();
  258. // 申请远程
  259. // if(empty($remote_application)){
  260. log::record('新增远程申请');
  261. $re = DB::table('remote_application')->where('exam_id',$param['id'])->find();
  262. $report = array();
  263. if($re){
  264. // 存在被驳回申请 再次申请时则为驳回后发起的申请
  265. DB::table('remote_application')->where('exam_id',$param['id'])->update($application_info);
  266. $app_id = $re['id'];
  267. }else{
  268. $application_info['id'] = UUIDs::uuid16();
  269. $application_info['createdAt'] = date('Y-m-d H:i:s',time());
  270. DB::table('remote_application')->insert($application_info);
  271. $app_id = $application_info['id'];
  272. }
  273. $aid = $app_id;
  274. $r_info = DB::table('report')->where('exam_id',$param['id'])->find();
  275. if(empty($r_info)){
  276. $report['id'] = UUIDs::uuid16();
  277. $report['exam_id'] = $param['id'];
  278. $report['remote_application_id'] = $aid;
  279. $report['type'] = 2;
  280. DB::table('report')->insert($report);
  281. $r_id = $report['id'];
  282. }else{
  283. $r_id = $r_info['id'];
  284. }
  285. // }else{
  286. // log::record('修改远程申请');
  287. // DB::table('remote_application')->where('exam_id',$param['id'])->update($application_info);
  288. // $r = DB::table('remote_application')->where('exam_id',$param['id'])->field('id')->find();
  289. // $aid = $r['id'];
  290. // }
  291. if(isset($param['apply']) && !empty($param['apply'])){
  292. DB::table('remote_application')->where('exam_id',$param['id'])->update(['report_status'=>4]);
  293. // 添加messages信息
  294. $t = '收到一条远程诊断申请';
  295. $ins = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  296. $c = $ins['name'].$doctor['realname'].'医师向您发起一条远程诊断申请';
  297. $d = $application_info['remote_doctor_id'];
  298. $t = '1';
  299. $url = Message::url($sessionid,$param['id'],1,$exam_info['exam_class'],$r_id);
  300. Message::insert($t,$c,$d,$t,$url,1,$aid);
  301. Cache::rm('messages_'.$doctor['id']);
  302. //保存 申请
  303. $dinfo = DB::table('doctors')->where('id',$application_info['remote_doctor_id'])->find();
  304. $d_phone = $dinfo['phone'];
  305. $d_name = $dinfo['realname'];
  306. if($dinfo['institution_id'] == '22100003' || $dinfo['send_sms'] == 1){ //魏庙
  307. $repsone = send_message::sendSms2Apply($d_phone,$d_time,$d_name);
  308. }
  309. $tel = '18910184804';
  310. $type = '发起申请';
  311. $content = $aid;
  312. $response = send_message::sendSms2Self($tel,$type,$content);
  313. }
  314. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid,'aid'=>$aid]);
  315. }catch(\Exception $e){
  316. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  317. }
  318. }
  319. /**
  320. * 上传附件
  321. *
  322. * @ApiTitle (上传附件)
  323. * @ApiSummary (上传附件)
  324. * @ApiSector (远程诊断)
  325. * @ApiMethod (POST)
  326. * @ApiRoute (/inter/application/upload)
  327. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  328. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  329. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  330. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  331. * @ApiParams (name="file", type="string", required=true, description="上传的文件<必填>")
  332. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  333. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  334. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  335. * @ApiReturn (data="
  336. {
  337. 'status': ok,
  338. 'code': '0000',
  339. 'info' : '/upload/20180101/12346asd.jpg'
  340. }
  341. *")
  342. **/
  343. //上传附件
  344. public function upload(){
  345. // 获取表单上传文件 例如上传了001.jpg
  346. $file = request()->file('file');
  347. log::record('----------上传的文件-----------');
  348. log::record($file);
  349. // 移动到框架应用根目录/public/uploads/ 目录下
  350. if($file){
  351. $info = $file->move(ROOT_PATH . 'public' . DS . 'uploads');
  352. log::record($info);
  353. if($info){
  354. return json_encode(['status'=>'ok','code'=>'0000','info'=>'/'.$_SERVER["SERVER_NAME"]. '/' . 'uploads'. '/' .$info->getSaveName()]);
  355. }else{
  356. // 上传失败获取错误信息
  357. return json_encode(['status'=>'fail','code'=>'1040','info'=>$file->getError()]);
  358. }
  359. }
  360. }
  361. /**
  362. * 远程申请驳回
  363. *
  364. * @ApiTitle (远程申请驳回)
  365. * @ApiSummary (远程申请驳回)
  366. * @ApiSector (远程诊断)
  367. * @ApiMethod (POST)
  368. * @ApiRoute (/inter/application/reject)
  369. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  370. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  371. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  372. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  373. * @ApiParams (name="param", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  374. * @ApiParams (name="param[id]", type="string", sample="", description="预约登记exams表id值<必填>")
  375. * @ApiParams (name="param[description]", type="string", sample="", description="驳回原因<必填>")
  376. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  377. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  378. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  379. * @ApiReturn (data="
  380. {
  381. 'status': ok,
  382. 'code': '0000',
  383. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  384. }
  385. *")
  386. **/
  387. //驳回 7
  388. public function reject(){
  389. $sessionid = $_REQUEST['sessionid'];
  390. $doctor = Cache::get($sessionid);
  391. $param = $_REQUEST['param'];
  392. $id = $param['id'];
  393. $re = DB::table('remote_application')->where('id',$id)->field('exam_id,report_status')->find();
  394. if($re['report_status'] != 4){
  395. return json_encode(['status'=>'fail','code'=>'0321','msg'=>'只能驳回申请中的单子']);
  396. }
  397. $report = DB::table('report')->where('remote_application_id',$id)->field('id')->find();
  398. $info = array();
  399. $info['id'] = UUIDs::uuid16();
  400. $info['report_id'] = $report['id'];
  401. $info['description'] = $param['description'];
  402. $info['createdAt'] = date('Y-m-d H:i:s',time());
  403. $info['type'] = 4;
  404. $info['doctor_id'] = $doctor['id'];
  405. DB::table('report_record')->insert($info);
  406. $binfo = array();
  407. $binfo['id'] = UUIDs::uuid16();
  408. $binfo['initiator'] = $doctor['id'];
  409. // $info['reply'] = $param['reply']; // 回复人
  410. $binfo['remote_application_id'] = $id; //申请单id
  411. $binfo['content'] = '驳回原因:'.$param['description'];
  412. $binfo['createdAt'] = date('Y-m-d H:i:s',time());
  413. DB::table('bbs')->insert($binfo);
  414. // $message = array();
  415. // $message['id'] = UUIDs::uuid16();
  416. // $message['title'] = '申请单驳回';
  417. // $message['content'] = $param['description'];
  418. // $message['createdAt'] = date('Y-m-d H:i:s',time());
  419. $application = DB::table('remote_application')->where('id',$id)->find();
  420. // $message['doctor_id'] = $application['req_doctor_id'];
  421. // $message['institution_id'] = $application['local_institution_id'];
  422. DB::table('remote_application')->where('id',$id)->update(['report_status'=>5]);
  423. $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'])->find();
  424. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  425. // 驳回添加messages消息
  426. $t = '您的远程诊断申请被驳回';
  427. $c = '您的远程诊断申请,被'.$institution['name'].$doctor['realname'].'xx(下级机构)xx(医生)医师驳回。驳回理由:'.$param['description'];
  428. $d = $application['req_doctor_id'];
  429. $type = '2';
  430. $exam_class = DB::table('exams')->where('id',$re['exam_id'])->field('exam_class')->find();
  431. $url = Message::url($sessionid,$re['exam_id'],0,$exam_class['exam_class'],$report['id']);
  432. Message::insert($t,$c,$d,$type,$url,1,$id);
  433. Cache::rm('messages_'.$doctor['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']);
  495. Message::insert($t,$c,$d,$type,$url,1,$id);
  496. Cache::rm('messages_'.$doctor['id']);
  497. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
  498. }
  499. /**
  500. * bbs通话保存
  501. *
  502. * @ApiTitle (bbs通话保存)
  503. * @ApiSummary (bbs通话保存)
  504. * @ApiSector (远程诊断)
  505. * @ApiMethod (POST)
  506. * @ApiRoute (/inter/application/bbs_save)
  507. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  508. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  509. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  510. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  511. * @ApiParams (name="param", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  512. * @ApiParams (name="param[appid]", type="string", sample="", description="申请单id值<必填>")
  513. * @ApiParams (name="param[content]", type="string", sample="", description="留言内容<必填>")
  514. * @ApiParams (name="param[attachment]", type="string", sample="", description="上传图片<选填>")
  515. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  516. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  517. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  518. * @ApiReturn (data="
  519. {
  520. 'status': ok,
  521. 'code': '0000',
  522. 'sessionid': 'a17z7a7a8f9g9rh9d89jio',
  523. 'info' : ''
  524. }
  525. *")
  526. **/
  527. public function bbs_save(){
  528. $sessionid = $_REQUEST['sessionid'];
  529. $doctor = Cache::get($sessionid);
  530. $param = $_REQUEST['param'];
  531. if(empty($param['content'])){
  532. return json_encode(['status'=>'fail','msg'=>'内容为空,请填写要发送的内容','sessionid'=>$sessionid]);
  533. }
  534. $info = array();
  535. $info['id'] = UUIDs::uuid16();
  536. $info['initiator'] = $doctor['id'];
  537. $is_remote = $_REQUEST['is_remote'];
  538. $rinfo = DB::table('remote_application')->where('id',$param['appid'])->field('req_doctor_id,remote_doctor_id')->find();
  539. if($is_remote == 1){
  540. // 远程医生
  541. $info['reply'] = $rinfo['req_doctor_id']; //申请医生
  542. $remote = 0;
  543. }else{
  544. $info['reply'] = $rinfo['remote_doctor_id']; //申请的目标远程医生
  545. $remote = 1;
  546. }
  547. // $info['reply'] = $param['reply']; // 回复人
  548. $info['remote_application_id'] = $param['appid']; //申请单id
  549. $info['content'] = $param['content'];
  550. $info['attachment'] = $param['attachment'];
  551. $info['createdAt'] = date('Y-m-d H:i:s',time());
  552. DB::table('bbs')->insert($info);
  553. // 添加message消息
  554. Message::bbs_message($param['appid'],$doctor['id'],$param['content'],$info['reply'],$remote,$sessionid);
  555. Cache::rm('messages_'.$doctor['id']);
  556. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid]);
  557. }
  558. public function getbbs(){
  559. $sessionid = $_REQUEST['sessionid'];
  560. $doctor = Cache::get($sessionid);
  561. $remote_id = $_REQUEST['application_id'];
  562. Message::read($doctor['id'],$remote_id,5);
  563. $info = DB::table('bbs')->where('remote_application_id',$remote_id)->order('createdAt desc')->select();
  564. foreach ($info as $k => $v) {
  565. $initiator = DB::table('doctors')->where('id',$v['initiator'])->field('realname')->find();
  566. $info[$k]['faqiren'] = $initiator['realname'];
  567. // $reply = DB::table('doctors')->where('id',$v['reply'])->field('realname')->find();
  568. // $info[$k]['huifuren'] = $reply['realname'];
  569. }
  570. return json_encode(['status'=>'ok','code'=>'0000','sessionid'=>$sessionid,'info'=>$info]);
  571. }
  572. /**
  573. * 上传通话留言附件
  574. *
  575. * @ApiTitle (上传通话留言附件)
  576. * @ApiSummary (上传通话留言附件)
  577. * @ApiSector (远程诊断)
  578. * @ApiMethod (POST)
  579. * @ApiRoute (/inter/application/bbs_upload)
  580. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  581. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  582. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  583. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  584. * @ApiParams (name="file", type="string", required=true, description="上传的文件<必填>")
  585. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  586. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  587. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  588. * @ApiReturn (data="
  589. {
  590. 'status': ok,
  591. 'code': '0000',
  592. 'info' : '/upload/20180101/12346asd.jpg'
  593. }
  594. *")
  595. **/
  596. public function bbs_upload(){
  597. // 获取表单上传文件 例如上传了001.jpg
  598. $file = request()->file('file');
  599. log::record('----------上传的文件-----------');
  600. log::record($file);
  601. // 移动到框架应用根目录/public/uploads/ 目录下
  602. if($file){
  603. $info = $file->move(ROOT_PATH . 'public' . DS . 'uploads');
  604. log::record($info);
  605. if($info){
  606. return json_encode(['status'=>'ok','code'=>'0000','info'=>'/'.$_SERVER["SERVER_NAME"]. '/' . 'uploads'. '/' .$info->getSaveName()]);
  607. }else{
  608. // 上传失败获取错误信息
  609. echo $file->getError();
  610. }
  611. }
  612. }
  613. /**
  614. * 撤回
  615. *
  616. * @ApiTitle (撤回)
  617. * @ApiSummary (撤回)
  618. * @ApiSector (远程诊断)
  619. * @ApiMethod (POST)
  620. * @ApiRoute (/inter/application/revoke)
  621. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  622. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  623. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  624. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  625. * @ApiParams (name="id", type="string", required=true, sample="", description="参数json字符串,预约登记exams表id值<必填>")
  626. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  627. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  628. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  629. * @ApiReturn (data="
  630. {
  631. 'status': ok,
  632. 'code': '0000',
  633. 'sessionid': 'a17z7a7a8f9g9rh9d89jio'
  634. }
  635. *")
  636. **/
  637. //
  638. public function revoke(){
  639. $sessionid = $_REQUEST['sessionid'];
  640. $doctor = Cache::get($sessionid);
  641. $id = $_REQUEST['id'];
  642. $status = DB::table('remote_application')->where('exam_id',$id)->field('id,report_status,remote_doctor_id')->find();
  643. if($status['report_status'] == 4){
  644. DB::table('remote_application')->where('exam_id',$id)->update(['report_status'=>12]);
  645. }else{
  646. return json_encode(['status'=>'ok','code'=>'0100','msg'=>'只能撤回申请中状态的申请单']);
  647. }
  648. $binfo = array();
  649. $binfo['id'] = UUIDs::uuid16();
  650. $binfo['initiator'] = $doctor['id'];
  651. // $info['reply'] = $param['reply']; // 回复人
  652. $binfo['remote_application_id'] = $status['id']; //申请单id
  653. $binfo['content'] = '已撤回了该申请';
  654. $binfo['createdAt'] = date('Y-m-d H:i:s',time());
  655. DB::table('bbs')->insert($binfo);
  656. //
  657. $t = '发起给您的远程诊断申请被撤回';
  658. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  659. $c = '您的远程诊断申请'.$institution['name'].$doctor['realname'].'医师撤回';
  660. $d = $status['remote_doctor_id'];
  661. $type = '3';
  662. $exam_class = DB::table('exams')->where('id',$id)->field('exam_class')->find();
  663. $report = DB::table('report')->where('remote_application_id',$status['id'])->field('id')->find();
  664. $url = Message::url($sessionid,$id,1,$exam_class['exam_class'],$report['id']);
  665. Message::insert($t,$c,$d,$type,$url,1,$status['id']);
  666. Cache::rm('messages_'.$doctor['id']);
  667. return json_encode(['status'=>'ok','code'=>'0000','msg'=>'撤回成功']);
  668. }
  669. }