Application.php 59 KB

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