Wenzhen.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use think\Db;
  5. use addons\epay\library\Service;
  6. use app\common\library\Tenim;
  7. use app\common\model\Wenzhenorder;
  8. /**
  9. * 问诊订单
  10. */
  11. class Wenzhen extends Api
  12. {
  13. protected $noNeedLogin = '';
  14. protected $noNeedRight = '*';
  15. //创建订单
  16. public function create_order(){
  17. $member_id = input('member_id',0);
  18. $doctor_id = input('doctor_id',0);
  19. $ordertype = input('ordertype',0);
  20. $book_date = input('book_date',0); //2024-05-05
  21. $book_hour = input('book_time',0); //10:00
  22. $book_time = strtotime($book_date.' '.$book_hour);
  23. $member_disease = input('member_disease','');
  24. $member_images = input('member_images','');
  25. $auth_id = $this->auth->id;
  26. $order_no = createUniqueNo('W',$auth_id);
  27. //成员信息
  28. $member_info = Db::name('user_member')->where('user_id',$auth_id)->where('id',$member_id)->find();
  29. if(empty($member_info)){
  30. $this->error('不存在的就诊者');
  31. }
  32. //医生信息
  33. $doctor = Db::name('doctor')->where('id',$doctor_id)->find();
  34. $doctor_info = Db::name('doctor_info')->where('doctor_id',$doctor_id)->find();
  35. if(empty($doctor_info)){
  36. $this->error('不存在的医生');
  37. }
  38. //ordertype
  39. if(!in_array($ordertype,[1,2])){
  40. $this->error();
  41. }
  42. //价格
  43. $price = 0;
  44. if($ordertype == 1){
  45. if($doctor_info['typing_switch'] != 1){
  46. $this->error('该医生未开通图文问诊');
  47. }
  48. if($doctor['job_status'] != 1){
  49. $this->error('该医生现在不在上班中');
  50. }
  51. $price = $doctor_info['typing_price'];
  52. }
  53. if($ordertype == 2){
  54. if($doctor_info['video_switch'] != 1){
  55. $this->error('该医生未开通视频问诊');
  56. }
  57. if($doctor_info['video_model'] == 2 && $doctor['job_status'] != 1){ //即时方式,需要在上班中
  58. $this->error('该医生现在不在上班中');
  59. }
  60. $price = $doctor_info['video_price'];
  61. }
  62. if($price <= 0){
  63. $this->error('问诊价格为零');
  64. }
  65. //排班判断
  66. if($ordertype == 1){
  67. $book_time = 0;
  68. }
  69. if($ordertype == 2){
  70. if($doctor_info['video_model'] == 1){ //排班预约
  71. //检查
  72. if($book_time < time() + 7200){
  73. //测试临时屏蔽
  74. //$this->error('最早只能预约'.date('m-d H:00',time() + 10800)); //最早预约两个小时后的一个整点
  75. }
  76. //排班状态
  77. $doctor_paiban = Db::name('doctor_paiban')->where('doctor_id',$doctor_id)->where('activetime',$book_time)->find();
  78. if(empty($doctor_paiban)){
  79. $this->error('您预约的时间该医生无法接诊');
  80. }
  81. if($doctor_paiban['active'] != 1){
  82. $this->error('您预约的时间该医生无法接诊');
  83. }
  84. //是否排满
  85. $map = [
  86. 'doctor_id' => $doctor_id,
  87. 'book_time' => $book_time,
  88. 'ordertype' => 2,
  89. 'status' => ['IN','10,20,25,30'],//有效订单
  90. 'video_model' => 1,//预约模式
  91. ];
  92. $order_count = Db::name('wenzhen_order')->where($map)->count();
  93. if($order_count >= 4){
  94. $this->error('该时间点已排满,请重选预约时间');
  95. }
  96. }
  97. else
  98. {
  99. $book_time = time(); //即时预约
  100. }
  101. }
  102. //订单数据
  103. $order_data = [
  104. 'order_no' => $order_no,
  105. 'user_id' => $auth_id,
  106. 'member_id' => $member_id,
  107. 'doctor_id' => $doctor_id,
  108. 'ordertype' => $ordertype,
  109. 'total_fee' => $price,
  110. 'book_time' => $book_time,
  111. 'createtime' => time(),
  112. 'status' => 0,//订单状态enum
  113. 'video_model'=> $doctor_info['video_model'], //视频问诊预约方式
  114. ];
  115. Db::startTrans();
  116. //下单
  117. $order_id = Db::name('wenzhen_order')->insertGetId($order_data);
  118. if(!$order_id){
  119. Db::rollback();
  120. $this->error('下单失败');
  121. }
  122. //订单附表,就诊人信息
  123. $member_data = $member_info;
  124. unset($member_data['id']);
  125. $member_data['order_id'] = $order_id;
  126. $member_data['member_id'] = $member_info['id'];
  127. $member_data['member_disease'] = $member_disease;
  128. $member_data['member_images'] = $member_images;
  129. $order_member_id = Db::name('wenzhen_order_member')->insertGetId($member_data);
  130. if(!$order_member_id){
  131. Db::rollback();
  132. $this->error('下单失败');
  133. }
  134. //
  135. Db::commit();
  136. $this->success('下单成功',$order_id);
  137. }
  138. //支付订单
  139. public function pay_order(){
  140. $order_id = input('order_id',0);
  141. $pay_type = input('pay_type','wechat');
  142. //pay_type
  143. if(!in_array($pay_type,['wechat','alipay','wallet'])){
  144. $this->error();
  145. }
  146. //订单详情
  147. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->find();
  148. if(empty($wenzhen_order)){
  149. $this->error('不存在的订单');
  150. }
  151. if($wenzhen_order['status'] != 0){
  152. $this->error('该订单不能支付');
  153. }
  154. if($pay_type == 'wallet'){
  155. Db::startTrans();
  156. //用户扣钱
  157. $logtype = $wenzhen_order['ordertype'] == 1 ? 11 : 12;
  158. $rs_wallet = model('wallet')->lockChangeAccountRemain($this->auth->id,'money',-$wenzhen_order['total_fee'],$logtype,'图文问诊'.$wenzhen_order['order_no'],'wenzhen_order',$order_id);
  159. if($rs_wallet['status'] == false){
  160. Db::rollback();
  161. $this->error($rs_wallet['msg']);
  162. }
  163. //订单改为已支付
  164. $wenzhen_update['status'] = 10;//订单状态enum
  165. $wenzhen_update['pay_type'] = $pay_type;
  166. $wenzhen_update['pay_time'] = time();
  167. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->where('status',0)->update($wenzhen_update);
  168. if(!$update_rs){
  169. Db::rollback();
  170. $this->error('支付失败,重试一下吧');
  171. }
  172. Db::commit();
  173. //发送im消息给医生
  174. if($wenzhen_order['ordertype'] == 1){
  175. $tenim = new Tenim();
  176. $message = [
  177. 'businessID' => 'order_status',
  178. 'name' => '待接单',
  179. 'status' => '10',
  180. 'id' => (string)$order_id,
  181. 'content' => '已通知医生尽快接诊,超时未接诊的将自动取消订单并退款',
  182. ];
  183. $rs = $tenim->sendCustomMessageToUser('user'.$this->auth->id,'doctor'.$wenzhen_order['doctor_id'],$message);
  184. }
  185. //输出
  186. $result = [
  187. 'pay_type' => $pay_type,
  188. 'pay_params' => '',
  189. ];
  190. $this->success(1,$result);
  191. }
  192. //创建订单
  193. $platform = 'app';
  194. $data = [];
  195. $data['user_id'] = $this->auth->id;
  196. $data['out_trade_no'] = createUniqueNo('W',$this->auth->id);
  197. $data['order_amount'] = $wenzhen_order['total_fee'];
  198. $data['createtime'] = time();
  199. $data['pay_type'] = $pay_type;
  200. $data['platform'] = $platform;
  201. $data['order_status'] = 0;
  202. $data['table_name'] = 'wenzhen_order';
  203. $data['table_id'] = $order_id;
  204. $data['args'] = '';
  205. $orderid = Db::name('pay_order')->insertGetId($data);
  206. $openid = '';
  207. //下单
  208. $params = [
  209. 'type' => $pay_type,
  210. 'orderid' => $data['out_trade_no'],
  211. 'title' => '支付订单',
  212. 'amount' => $data['order_amount'],
  213. 'method' => $platform,
  214. 'openid' => $openid,
  215. 'notifyurl' => config('pay_notify_url').'/api/notify/wenzhen_notify_base/paytype/'.$pay_type,
  216. 'returnurl' => '',
  217. ];
  218. $res = Service::submitOrder($params);
  219. $result = [
  220. 'pay_type'=> $pay_type,
  221. 'pay_params'=> $pay_type
  222. ];
  223. if($pay_type == 'wechat'){
  224. $result['pay_params'] = json_decode($res,true);
  225. }else{
  226. $result['pay_params'] = $res;
  227. }
  228. $this->success(1,$result);
  229. }
  230. //订单列表
  231. public function order_list(){
  232. $status = input('status','all');
  233. $where = ['user_id'=>$this->auth->id];
  234. if($status != 'all'){
  235. $where['order.status'] = $status;
  236. if($status == 20){// 已接诊、问诊中
  237. $where['order.status'] = ['IN',[20,25]];
  238. }
  239. }
  240. $field = [
  241. 'order.id','order.order_no','order.createtime','order.status','order.ordertype','order.accept_time','order.video_time','order.doctor_id','order.cancel_reason','order.comefrom','order.video_model',
  242. 'doctor.avatar as doctor_avatar','doctor.nickname as doctor_nickname',
  243. ];
  244. $list = Db::name('wenzhen_order')->alias('order')
  245. ->field($field)
  246. ->join('doctor','order.doctor_id = doctor.id','LEFT')
  247. ->order('order.id desc')
  248. ->where($where)
  249. ->autopage()->select();
  250. $list = list_domain_image($list,['doctor_avatar']);
  251. if(!empty($list)){
  252. //循环处理
  253. foreach($list as $key => $val){
  254. $val = $this->orderinfo_appen($val);
  255. //医生原因的退款,都直接算到退珍
  256. if(in_array($val['status'],[16,18,22])){
  257. $val['status'] = 100;
  258. }
  259. //视频拨打中 也算问诊中
  260. if($val['status'] == 25){
  261. $val['status'] = 20;
  262. }
  263. //视频订单是否能拨打,即时模式才可以
  264. $val['video_call_switch'] = 0;
  265. if($val['video_model'] == 2 && $val['ordertype'] == 2 && in_array($val['status'],[10,20,25])){ //三个状态都可以,理论上不存在20
  266. $val['video_call_switch'] = 1;
  267. }
  268. $list[$key] = $val;
  269. }
  270. }
  271. $this->success(1,$list);
  272. }
  273. //单个订单,追加数据
  274. private function orderinfo_appen($val){
  275. //订单类型
  276. $ordertype_data = [
  277. 1 => ['name'=>'图文订单','name_en'=>'Visual Order'],
  278. 2 => ['name'=>'视频订单','name_en'=>'Video Order'],
  279. ];
  280. //状态备注
  281. $status_data = $this->order_status_enum();
  282. //开始处理
  283. //订单类型,辅助
  284. $val['ordertype_data'] = $ordertype_data[$val['ordertype']];
  285. //订单状态,辅助
  286. $status_data_val = $status_data[$val['status']];
  287. //未支付订单N分钟后自动取消
  288. if($val['status'] == 0){
  289. $remain_time = $val['createtime'] + (config('site.nopay_order_autocancel_minute')*60) - time();
  290. if($remain_time > 0){
  291. $status_data_val['minute'] = Sec2Time($remain_time);
  292. $status_data_val['minute_en'] = Sec2Time_en($remain_time);
  293. $status_data_val['seconds'] = $remain_time;
  294. }
  295. }
  296. //被医生退珍,追加原因
  297. if($val['status'] == 18){
  298. $status_data_val['name'] .= ':'.$val['cancel_reason'];
  299. }
  300. //图文订单接诊后N分钟自动结束
  301. if($val['status'] == 20 && $val['ordertype'] == 1){
  302. $remain_time = $val['accept_time'] + (config('site.accept_textorder_autofinish_minute')*60) - time();
  303. if($remain_time > 0){
  304. $status_data_val['minute'] = Sec2Time($remain_time);
  305. $status_data_val['minute_en'] = Sec2Time_en($remain_time);
  306. $status_data_val['seconds'] = $remain_time;
  307. }
  308. }
  309. //视频订单接通后N分钟自动结束
  310. if($val['status'] == 25 && $val['ordertype'] == 2){
  311. $minute = config('site.firstvideo_videoorder_autofinish_minute');
  312. if($val['comefrom'] == 2){
  313. $minute = config('site.tv_firstvideo_videoorder_autofinish_minute');
  314. }
  315. $remain_time = $val['video_time'] + ($minute*60) - time();
  316. if($remain_time > 0){
  317. $status_data_val['minute'] = Sec2Time($remain_time);
  318. $status_data_val['minute_en'] = Sec2Time_en($remain_time);
  319. $status_data_val['seconds'] = $remain_time;
  320. }
  321. }
  322. $val['status_data'] = $status_data_val;
  323. //处理完成,返回
  324. return $val;
  325. }
  326. //订单状态备注枚举
  327. private function order_status_enum(){
  328. //状态:0=未付款,3=已失效,10=待接诊,13=用户退诊,16=医生未接诊,18=医生退诊,20=已接诊,22=超时未拨打,25=视频通话中,30=问诊完成
  329. $status_data = [
  330. 0 => [
  331. 'name'=>'等待支付时间',
  332. 'name_en'=>'Waiting time for payment',
  333. 'minute' => '',
  334. 'minute_en' => '',
  335. 'seconds' => 0,
  336. ],
  337. 3 => [
  338. 'name'=>'您的订单未及时支付,已失效',
  339. 'name_en'=>'Your order was not paid on time and has expired.',
  340. 'minute' => '',
  341. 'minute_en' => '',
  342. 'seconds' => 0,
  343. ],
  344. 10 => [
  345. 'name'=>'等待医生接诊:已通知医生尽快接诊,超时自动取消订单并退款',
  346. 'name_en'=>'Waiting for the doctor. If not accepted within the specified time,the consultation will be automatically canceled, and a refund will be issued',
  347. 'minute' => '',
  348. 'minute_en' => '',
  349. 'seconds' => 0,
  350. ],
  351. 13 => [
  352. 'name'=>'您的订单已退珍',
  353. 'name_en'=>'Your order has been canceled',
  354. 'minute' => '',
  355. 'minute_en' => '',
  356. 'seconds' => 0,
  357. ],
  358. 16 => [
  359. 'name'=>'医生未接诊',
  360. 'name_en'=>'Doctor Not received',
  361. 'minute' => '',
  362. 'minute_en' => '',
  363. 'seconds' => 0,
  364. ],
  365. 18 => [
  366. 'name'=>'退珍原因',
  367. 'name_en'=>'',
  368. 'minute' => '',
  369. 'minute_en' => '',
  370. 'seconds' => 0,
  371. ],
  372. 20 => [
  373. 'name'=>'医生已接诊,咨询中',
  374. 'name_en'=>'',
  375. 'minute' => '',
  376. 'minute_en' => '',
  377. 'seconds' => 0,
  378. ],
  379. 22 => [
  380. 'name'=>'医生超时未拨打视频',
  381. 'name_en'=>'',
  382. 'minute' => '',
  383. 'minute_en' => '',
  384. 'seconds' => 0,
  385. ],
  386. 25 => [
  387. 'name'=>'视频问诊进行中',
  388. 'name_en'=>'Time Remaining',
  389. 'minute' => '',
  390. 'minute_en' => '',
  391. 'seconds' => 0,
  392. ],
  393. 30 => [
  394. 'name'=>'点击查看医生反馈结果',
  395. 'name_en'=>'Click to view the consultation results',
  396. 'minute' => '',
  397. 'minute_en' => '',
  398. 'seconds' => 0,
  399. ],
  400. ];
  401. return $status_data;
  402. }
  403. //订单详情
  404. public function order_info(){
  405. $order_id = input('order_id',0);
  406. //订单详情
  407. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->find();
  408. if(empty($wenzhen_order)){
  409. $this->error('不存在的订单');
  410. }
  411. $wenzhen_order = info_domain_image($wenzhen_order,['feedback_images']);
  412. $wenzhen_order = $this->orderinfo_appen($wenzhen_order);
  413. //就诊人详情
  414. $order_member_info = Db::name('wenzhen_order_member')->where('order_id',$order_id)->find();
  415. $order_member_info = info_domain_image($order_member_info,['member_images']);
  416. $order_member_info['age'] = birthtime_to_age($order_member_info['birthday']);
  417. $wenzhen_order['member_info'] = $order_member_info;
  418. //医生详情
  419. $field = [
  420. 'd.nickname','d.avatar','d.keshi_id','d.level_id','d.hospital','d.goodat','d.ordernum',
  421. 'keshi.name as keshi_name',
  422. 'level.name as level_name'
  423. ];
  424. $doctor_info = Db::name('doctor')->alias('d')
  425. ->field($field)
  426. ->join('doctor_level level','d.level_id = level.id','LEFT')
  427. ->join('keshi','d.keshi_id = keshi.id','LEFT')
  428. ->where('d.id',$wenzhen_order['doctor_id'])->find();
  429. $doctor_info = info_domain_image($doctor_info,['avatar']);
  430. $wenzhen_order['doctor_info'] = $doctor_info;
  431. //视频订单是否能拨打,即时模式才可以
  432. $wenzhen_order['video_call_switch'] = 0;
  433. if($wenzhen_order['video_model'] == 2 && $wenzhen_order['ordertype'] == 2 && in_array($wenzhen_order['status'],[10,20,25])){ //三个状态都可以,理论上不存在20
  434. $wenzhen_order['video_call_switch'] = 1;
  435. }
  436. $this->success(1,$wenzhen_order);
  437. }
  438. //编辑订单里的就诊人资料
  439. public function edit_member(){
  440. $order_id = input('order_id',0);
  441. //订单详情
  442. $wenzhen_order_member = Db::name('wenzhen_order_member')->where('user_id',$this->auth->id)->where('order_id',$order_id)->find();
  443. if(empty($wenzhen_order_member)){
  444. $this->error('不存在的订单');
  445. }
  446. $update = [
  447. 'member_disease' => input('member_disease',''),
  448. 'member_images' => input('member_images',''),
  449. ];
  450. Db::name('wenzhen_order_member')->where('user_id',$this->auth->id)->where('order_id',$order_id)->update($update);
  451. $this->success();
  452. }
  453. //用户发起退珍
  454. //因为存在第三方,悲观锁
  455. public function tuizhen(){
  456. $apilimit = $this->apiLimit();
  457. if(!$apilimit){
  458. $this->error('操作频繁');
  459. }
  460. //订单详情
  461. $order_id = input('order_id',0);
  462. Db::startTrans();
  463. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->lock(true)->find();
  464. if(empty($wenzhen_order)){
  465. Db::rollback();
  466. $this->error('不存在的订单');
  467. }
  468. //仅限视频订单
  469. if($wenzhen_order['ordertype'] == 1){
  470. Db::rollback();
  471. $this->error('图文问诊不能退诊');
  472. }
  473. //下面全是视频订单
  474. //状态限制
  475. if($wenzhen_order['video_model'] == 1){
  476. if(!in_array($wenzhen_order['status'],[10,20])){
  477. Db::rollback();
  478. $this->error('当前订单不能退诊');
  479. }
  480. //超过支付时间一小时不能退
  481. if($wenzhen_order['status'] == 20 && (time() - $wenzhen_order['pay_time'] > 3600)){
  482. Db::rollback();
  483. $this->error('支付超过一小时,不能退诊');
  484. }
  485. }else{
  486. //即时模式,已付款没接的能退
  487. if($wenzhen_order['status'] != 10){
  488. Db::rollback();
  489. $this->error('当前订单不能退诊');
  490. }
  491. }
  492. //修改订单
  493. $nowtime = time();
  494. $update = [
  495. 'status' => 13,
  496. 'cancel_time' => $nowtime,
  497. 'cancel_reason' => '用户付款后退诊',
  498. 'finish_time' => $nowtime,
  499. ];
  500. //退款要打折扣
  501. $wenzhen_refund_bili = config('site.payorder_userrefund_bili') ?: 70;
  502. $refund_price = bcdiv(bcmul($wenzhen_order['total_fee'],$wenzhen_refund_bili,2),100,2);
  503. //余额支付的直接退款
  504. if($wenzhen_order['pay_type'] == 'wallet'){
  505. //用户加钱
  506. $logtype = $wenzhen_order['ordertype'] == 1 ? 13 : 14;
  507. $rs_wallet = model('wallet')->lockChangeAccountRemain($wenzhen_order['user_id'],'money',$refund_price,$logtype,$remark='用户问诊退珍','wenzhen_order',$order_id);
  508. if($rs_wallet['status'] === false){
  509. Db::rollback();
  510. $this->error($rs_wallet['msg']);
  511. }
  512. //订单退款参数
  513. $update['refund_price'] = $refund_price;
  514. $update['refund_status'] = 3;
  515. }else{
  516. $update['refund_status'] = 1; //待退款
  517. //发起退款
  518. $Wenzhenorder_model = new Wenzhenorder;
  519. $refund_rs = $Wenzhenorder_model->old_refund($wenzhen_order,$refund_price);
  520. if($refund_rs === true){
  521. $update['refund_status'] = 3; //退款完成
  522. }
  523. }
  524. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->update($update);
  525. if(!$update_rs){
  526. Db::rollback();
  527. $this->error('退诊失败');
  528. }
  529. Db::commit();
  530. $this->success('退珍成功');
  531. }
  532. ///////////////////////////////视频即时问诊///////////////////////////
  533. //第一次拨打视频之前,20,25可以调用
  534. public function before_first_video(){
  535. //订单详情
  536. $order_id = input('order_id',0);
  537. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->find();
  538. if(empty($wenzhen_order)){
  539. $this->error('不存在的订单');
  540. }
  541. if($wenzhen_order['ordertype'] != 2){
  542. $this->error('视频问诊才能拨打视频');
  543. }
  544. if($wenzhen_order['video_model'] != 2){
  545. $this->error('即时视频问诊才能主动拨打视频');
  546. }
  547. if($wenzhen_order['status'] == 30){
  548. $this->error('订单已结束');
  549. }
  550. if($wenzhen_order['status'] == 25){
  551. //判断医生在线状态
  552. $tenim = new Tenim();
  553. $rs_online = $tenim->is_online('doctor'.$wenzhen_order['doctor_id']);
  554. if($rs_online != true){
  555. $this->error('医生现在不在线,请稍后拨打');
  556. }
  557. $this->success();
  558. }
  559. //20直接忽略
  560. if($wenzhen_order['status'] != 10){
  561. $this->error('订单错误,请刷新重试');
  562. }
  563. //判断患者在线状态
  564. $tenim = new Tenim();
  565. $rs_online = $tenim->is_online('doctor'.$wenzhen_order['doctor_id']);
  566. if($rs_online != true){
  567. $this->error('医生现在不在线,请稍后拨打');
  568. }
  569. $this->success('操作成功');
  570. }
  571. //第一次拨打视频
  572. public function first_video(){
  573. $apilimit = $this->apiLimit();
  574. if(!$apilimit){
  575. $this->error('操作频繁');
  576. }
  577. //订单详情
  578. $order_id = input('order_id',0);
  579. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->find();
  580. if(empty($wenzhen_order)){
  581. $this->error('不存在的订单');
  582. }
  583. if($wenzhen_order['ordertype'] != 2){
  584. $this->error('视频问诊才能拨打视频');
  585. }
  586. if($wenzhen_order['video_model'] != 2){
  587. $this->error('即时视频问诊才能主动拨打视频');
  588. }
  589. if($wenzhen_order['status'] == 30){
  590. $this->error('订单已结束');
  591. }
  592. if($wenzhen_order['status'] == 25){
  593. //倒计时
  594. $minute = config('site.firstvideo_videoorder_autofinish_minute');
  595. if($wenzhen_order['comefrom'] == 2){
  596. $minute = config('site.tv_firstvideo_videoorder_autofinish_minute');
  597. }
  598. $rs = [
  599. 'video_time' => $wenzhen_order['video_time'],
  600. 'video_endtime' => $wenzhen_order['video_time'] + $minute*60,
  601. ];
  602. $rs['seconds'] = $rs['video_endtime'] - time();
  603. //修改最后拨通时间
  604. $update = [
  605. 'last_video_time' => time(),
  606. ];
  607. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->update($update);
  608. $this->success('操作成功',$rs);
  609. }
  610. //20直接忽略
  611. if($wenzhen_order['status'] != 10){
  612. $this->error('订单错误,请刷新重试');
  613. }
  614. //修改订单
  615. $update = [
  616. 'status' => 25,
  617. 'video_time' => time(),
  618. 'last_video_time' => time(),
  619. ];
  620. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->where('status',10)->update($update);
  621. if(!$update_rs){
  622. $this->error('操作失败');
  623. }
  624. //倒计时
  625. $minute = config('site.firstvideo_videoorder_autofinish_minute');
  626. if($wenzhen_order['comefrom'] == 2){
  627. $minute = config('site.tv_firstvideo_videoorder_autofinish_minute');
  628. }
  629. $rs = [
  630. 'video_time' => $update['video_time'],
  631. 'seconds' => $minute*60,
  632. 'video_endtime' => $update['video_time'] + $minute*60,
  633. ];
  634. $this->success('操作成功',$rs);
  635. }
  636. //挂断,医生挂断。这个方法主要用来统计是否已满足一分钟
  637. public function video_end(){
  638. $apilimit = $this->apiLimit();
  639. if(!$apilimit){
  640. $this->error('操作频繁');
  641. }
  642. $end_rule = input('end_rule','user'); //user 用户挂断,doctor 医生挂断。如果是医生挂断并且这个订单一次都没有接通,那就直接按拒绝接诊,结束订单
  643. //订单详情
  644. $order_id = input('order_id',0);
  645. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->find();
  646. if(empty($wenzhen_order)){
  647. $this->error('不存在的订单');
  648. }
  649. if($wenzhen_order['ordertype'] != 2){
  650. $this->error('视频问诊才能拨打视频');
  651. }
  652. if($wenzhen_order['video_model'] != 2){
  653. $this->error('即时视频问诊才能主动拨打视频');
  654. }
  655. if($wenzhen_order['status'] != 25 && $wenzhen_order['status'] != 10){
  656. $this->error('订单错误,请刷新重试');
  657. }
  658. $nowtime = time();
  659. //接通了
  660. if($wenzhen_order['status'] == 25){
  661. //本次不超过1分钟
  662. if($nowtime - $wenzhen_order['last_video_time'] < 60 ){
  663. $this->success('已挂断');
  664. }
  665. //如果本次挂断之前已通话超过一分钟,那自动结束
  666. Db::startTrans();
  667. $wenzhen_order = Db::name('wenzhen_order')->where('id',$order_id)->lock(true)->find();
  668. $update = [
  669. 'status' => 30,
  670. 'finish_time' => $nowtime,
  671. ];
  672. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->update($update);
  673. if(!$update_rs){
  674. Db::rollback();
  675. $this->error('操作失败');
  676. }
  677. //给医生结算钱
  678. $logtype = $wenzhen_order['ordertype'] == 1 ? 111 : 112;
  679. if($wenzhen_order['comefrom'] == 1 && $wenzhen_order['total_fee'] > 0){
  680. $rs_wallet = model('walletdoctor')->lockChangeAccountRemain($wenzhen_order['doctor_id'],'money',$wenzhen_order['total_fee'],$logtype,$remark='问诊订单','wenzhen_order',$order_id);
  681. if($rs_wallet['status'] === false){
  682. Db::rollback();
  683. $this->error($rs_wallet['msg']);
  684. }
  685. }
  686. //医生接诊量
  687. Db::name('doctor')->where('id',$wenzhen_order['doctor_id'])->setInc('ordernum');
  688. Db::commit();
  689. $this->success('已挂断');
  690. }
  691. //没接通
  692. if($wenzhen_order['status'] == 10){
  693. if($end_rule == 'user'){
  694. $this->success('已挂断');
  695. }else{
  696. //如果是医生挂断并且这个订单一次都没有接通,那就直接按拒绝接诊,结束订单
  697. //参考医生发起退珍
  698. Db::startTrans();
  699. $wenzhen_order = Db::name('wenzhen_order')->where('id',$order_id)->lock(true)->find();
  700. //修改订单
  701. $nowtime = time();
  702. $update = [
  703. 'status' => 16,
  704. 'cancel_time' => $nowtime,
  705. 'cancel_reason' => '医生挂断未接诊',
  706. 'finish_time' => $nowtime,
  707. ];
  708. //余额支付的直接退款
  709. if($wenzhen_order['pay_type'] == 'wallet'){
  710. //用户加钱
  711. $logtype = $wenzhen_order['ordertype'] == 1 ? 13 : 14;
  712. $rs_wallet = model('wallet')->lockChangeAccountRemain($wenzhen_order['user_id'],'money',$wenzhen_order['total_fee'],$logtype,$remark='医生挂断未接诊','wenzhen_order',$order_id);
  713. if($rs_wallet['status'] === false){
  714. Db::rollback();
  715. // $this->error($rs_wallet['msg']);
  716. $this->error('医生挂断了');
  717. }
  718. //订单退款参数
  719. $update['refund_price'] = $wenzhen_order['total_fee'];
  720. $update['refund_status'] = 3;
  721. }else{
  722. $update['refund_status'] = 1; //待退款
  723. //发起退款
  724. $Wenzhenorder_model = new Wenzhenorder;
  725. $refund_rs = $Wenzhenorder_model->old_refund($wenzhen_order,$wenzhen_order['total_fee']);
  726. if($refund_rs === true){
  727. $update['refund_status'] = 3; //退款完成
  728. }
  729. }
  730. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->update($update);
  731. if(!$update_rs){
  732. Db::rollback();
  733. $this->error('医生挂断了');
  734. }
  735. Db::commit();
  736. $this->success('医生挂断并取消了订单');
  737. }
  738. }
  739. //没用的兜底
  740. $this->success('订单错误,请刷新重试');
  741. }
  742. }