Application.php 62 KB

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