Application.php 58 KB

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