Application.php 58 KB

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