Wenzhen.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894
  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_status = $val['status'];
  287. if($val['status'] == 10 && $val['video_model'] == 2){$status_data_status = 102;}
  288. $status_data_val = $status_data[$status_data_status];
  289. //未支付订单N分钟后自动取消
  290. if($val['status'] == 0){
  291. $remain_time = $val['createtime'] + (config('site.nopay_order_autocancel_minute')*60) - time();
  292. if($remain_time > 0){
  293. $status_data_val['minute'] = Sec2Time($remain_time);
  294. $status_data_val['minute_en'] = Sec2Time_en($remain_time);
  295. $status_data_val['seconds'] = $remain_time;
  296. }
  297. }
  298. //被医生退珍,追加原因
  299. if($val['status'] == 18){
  300. $status_data_val['name'] .= ':'.$val['cancel_reason'];
  301. }
  302. //图文订单接诊后N分钟自动结束
  303. if($val['status'] == 20 && $val['ordertype'] == 1){
  304. $remain_time = $val['accept_time'] + (config('site.accept_textorder_autofinish_minute')*60) - time();
  305. if($remain_time > 0){
  306. $status_data_val['minute'] = Sec2Time($remain_time);
  307. $status_data_val['minute_en'] = Sec2Time_en($remain_time);
  308. $status_data_val['seconds'] = $remain_time;
  309. }
  310. }
  311. //视频订单接通后N分钟自动结束
  312. if($val['status'] == 25 && $val['ordertype'] == 2){
  313. $minute = config('site.firstvideo_videoorder_autofinish_minute');
  314. if($val['comefrom'] == 2){
  315. $minute = config('site.tv_firstvideo_videoorder_autofinish_minute');
  316. }
  317. $remain_time = $val['video_time'] + ($minute*60) - time();
  318. if($remain_time > 0){
  319. $status_data_val['minute'] = Sec2Time($remain_time);
  320. $status_data_val['minute_en'] = Sec2Time_en($remain_time);
  321. $status_data_val['seconds'] = $remain_time;
  322. }
  323. }
  324. $val['status_data'] = $status_data_val;
  325. //处理完成,返回
  326. return $val;
  327. }
  328. //订单状态备注枚举
  329. private function order_status_enum(){
  330. //状态:0=未付款,3=已失效,10=待接诊,13=用户退诊,16=医生未接诊,18=医生退诊,20=已接诊,22=超时未拨打,25=视频通话中,30=问诊完成
  331. $status_data = [
  332. 0 => [
  333. 'name'=>'等待支付时间',
  334. 'name_en'=>'Waiting time for payment',
  335. 'minute' => '',
  336. 'minute_en' => '',
  337. 'seconds' => 0,
  338. ],
  339. 3 => [
  340. 'name'=>'您的订单未及时支付,已失效',
  341. 'name_en'=>'Your order was not paid on time and has expired.',
  342. 'minute' => '',
  343. 'minute_en' => '',
  344. 'seconds' => 0,
  345. ],
  346. 10 => [
  347. 'name'=>'等待医生接诊:已通知医生尽快接诊,超时自动取消订单并退款',
  348. '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',
  349. 'minute' => '',
  350. 'minute_en' => '',
  351. 'seconds' => 0,
  352. ],
  353. //给即时视频用的
  354. 102 => [
  355. 'name'=>'视频问诊:您可立即发起视频问诊',
  356. 'name_en'=>'Video consultation: You can initiate a video consultation immediately',
  357. 'minute' => '',
  358. 'minute_en' => '',
  359. 'seconds' => 0,
  360. ],
  361. 13 => [
  362. 'name'=>'您的订单已退珍',
  363. 'name_en'=>'Your order has been canceled',
  364. 'minute' => '',
  365. 'minute_en' => '',
  366. 'seconds' => 0,
  367. ],
  368. 16 => [
  369. 'name'=>'医生未接诊',
  370. 'name_en'=>'Doctor Not received',
  371. 'minute' => '',
  372. 'minute_en' => '',
  373. 'seconds' => 0,
  374. ],
  375. 18 => [
  376. 'name'=>'退珍原因',
  377. 'name_en'=>'',
  378. 'minute' => '',
  379. 'minute_en' => '',
  380. 'seconds' => 0,
  381. ],
  382. 20 => [
  383. 'name'=>'医生已接诊,咨询中',
  384. 'name_en'=>'',
  385. 'minute' => '',
  386. 'minute_en' => '',
  387. 'seconds' => 0,
  388. ],
  389. 22 => [
  390. 'name'=>'医生超时未拨打视频',
  391. 'name_en'=>'',
  392. 'minute' => '',
  393. 'minute_en' => '',
  394. 'seconds' => 0,
  395. ],
  396. 25 => [
  397. 'name'=>'视频问诊进行中',
  398. 'name_en'=>'Time Remaining',
  399. 'minute' => '',
  400. 'minute_en' => '',
  401. 'seconds' => 0,
  402. ],
  403. 30 => [
  404. 'name'=>'点击查看医生反馈结果',
  405. 'name_en'=>'Click to view the consultation results',
  406. 'minute' => '',
  407. 'minute_en' => '',
  408. 'seconds' => 0,
  409. ],
  410. ];
  411. return $status_data;
  412. }
  413. //订单详情
  414. public function order_info(){
  415. $order_id = input('order_id',0);
  416. //订单详情
  417. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->find();
  418. if(empty($wenzhen_order)){
  419. $this->error('不存在的订单');
  420. }
  421. $wenzhen_order = info_domain_image($wenzhen_order,['feedback_images']);
  422. $wenzhen_order = $this->orderinfo_appen($wenzhen_order);
  423. //就诊人详情
  424. $order_member_info = Db::name('wenzhen_order_member')->where('order_id',$order_id)->find();
  425. $order_member_info = info_domain_image($order_member_info,['member_images']);
  426. $order_member_info['age'] = birthtime_to_age($order_member_info['birthday']);
  427. $wenzhen_order['member_info'] = $order_member_info;
  428. //医生详情
  429. $field = [
  430. 'd.nickname','d.avatar','d.keshi_id','d.level_id','d.hospital','d.goodat','d.ordernum',
  431. 'keshi.name as keshi_name',
  432. 'level.name as level_name'
  433. ];
  434. $doctor_info = Db::name('doctor')->alias('d')
  435. ->field($field)
  436. ->join('doctor_level level','d.level_id = level.id','LEFT')
  437. ->join('keshi','d.keshi_id = keshi.id','LEFT')
  438. ->where('d.id',$wenzhen_order['doctor_id'])->find();
  439. $doctor_info = info_domain_image($doctor_info,['avatar']);
  440. $wenzhen_order['doctor_info'] = $doctor_info;
  441. //视频订单是否能拨打,即时模式才可以
  442. $wenzhen_order['video_call_switch'] = 0;
  443. if($wenzhen_order['video_model'] == 2 && $wenzhen_order['ordertype'] == 2 && in_array($wenzhen_order['status'],[10,20,25])){ //三个状态都可以,理论上不存在20
  444. $wenzhen_order['video_call_switch'] = 1;
  445. }
  446. $this->success(1,$wenzhen_order);
  447. }
  448. //编辑订单里的就诊人资料
  449. public function edit_member(){
  450. $order_id = input('order_id',0);
  451. //订单详情
  452. $wenzhen_order_member = Db::name('wenzhen_order_member')->where('user_id',$this->auth->id)->where('order_id',$order_id)->find();
  453. if(empty($wenzhen_order_member)){
  454. $this->error('不存在的订单');
  455. }
  456. $update = [
  457. 'member_disease' => input('member_disease',''),
  458. 'member_images' => input('member_images',''),
  459. ];
  460. Db::name('wenzhen_order_member')->where('user_id',$this->auth->id)->where('order_id',$order_id)->update($update);
  461. $this->success();
  462. }
  463. //用户发起退珍
  464. //因为存在第三方,悲观锁
  465. public function tuizhen(){
  466. $apilimit = $this->apiLimit();
  467. if(!$apilimit){
  468. $this->error('操作频繁');
  469. }
  470. //订单详情
  471. $order_id = input('order_id',0);
  472. Db::startTrans();
  473. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->lock(true)->find();
  474. if(empty($wenzhen_order)){
  475. Db::rollback();
  476. $this->error('不存在的订单');
  477. }
  478. //仅限视频订单
  479. if($wenzhen_order['ordertype'] == 1){
  480. Db::rollback();
  481. $this->error('图文问诊不能退诊');
  482. }
  483. //下面全是视频订单
  484. //状态限制
  485. if($wenzhen_order['video_model'] == 1){
  486. if(!in_array($wenzhen_order['status'],[10,20])){
  487. Db::rollback();
  488. $this->error('当前订单不能退诊');
  489. }
  490. //超过支付时间一小时不能退
  491. if($wenzhen_order['status'] == 20 && (time() - $wenzhen_order['pay_time'] > 3600)){
  492. Db::rollback();
  493. $this->error('支付超过一小时,不能退诊');
  494. }
  495. }else{
  496. //即时模式,已付款没接的能退
  497. if($wenzhen_order['status'] != 10){
  498. Db::rollback();
  499. $this->error('当前订单不能退诊');
  500. }
  501. }
  502. //修改订单
  503. $nowtime = time();
  504. $update = [
  505. 'status' => 13,
  506. 'cancel_time' => $nowtime,
  507. 'cancel_reason' => '用户付款后退诊',
  508. 'finish_time' => $nowtime,
  509. ];
  510. //退款要打折扣
  511. $wenzhen_refund_bili = config('site.payorder_userrefund_bili') ?: 70;
  512. $refund_price = bcdiv(bcmul($wenzhen_order['total_fee'],$wenzhen_refund_bili,2),100,2);
  513. //余额支付的直接退款
  514. if($wenzhen_order['pay_type'] == 'wallet'){
  515. //用户加钱
  516. $logtype = $wenzhen_order['ordertype'] == 1 ? 13 : 14;
  517. $rs_wallet = model('wallet')->lockChangeAccountRemain($wenzhen_order['user_id'],'money',$refund_price,$logtype,$remark='用户问诊退珍','wenzhen_order',$order_id);
  518. if($rs_wallet['status'] === false){
  519. Db::rollback();
  520. $this->error($rs_wallet['msg']);
  521. }
  522. //订单退款参数
  523. $update['refund_price'] = $refund_price;
  524. $update['refund_status'] = 3;
  525. }else{
  526. $update['refund_status'] = 1; //待退款
  527. //发起退款
  528. $Wenzhenorder_model = new Wenzhenorder;
  529. $refund_rs = $Wenzhenorder_model->old_refund($wenzhen_order,$refund_price);
  530. if($refund_rs === true){
  531. $update['refund_status'] = 3; //退款完成
  532. }
  533. }
  534. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->update($update);
  535. if(!$update_rs){
  536. Db::rollback();
  537. $this->error('退诊失败');
  538. }
  539. Db::commit();
  540. $this->success('退珍成功');
  541. }
  542. ///////////////////////////////视频即时问诊///////////////////////////
  543. //第一次拨打视频之前,20,25可以调用
  544. public function before_first_video(){
  545. //订单详情
  546. $order_id = input('order_id',0);
  547. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->find();
  548. if(empty($wenzhen_order)){
  549. $this->error('不存在的订单');
  550. }
  551. if($wenzhen_order['ordertype'] != 2){
  552. $this->error('视频问诊才能拨打视频');
  553. }
  554. if($wenzhen_order['video_model'] != 2){
  555. $this->error('即时视频问诊才能主动拨打视频');
  556. }
  557. if($wenzhen_order['status'] == 30){
  558. $this->error('订单已结束');
  559. }
  560. if($wenzhen_order['status'] == 25){
  561. //判断医生在线状态
  562. $tenim = new Tenim();
  563. $rs_online = $tenim->is_online('doctor'.$wenzhen_order['doctor_id']);
  564. if($rs_online != true){
  565. $this->error('医生现在不在线,请稍后拨打');
  566. }
  567. $this->success();
  568. }
  569. //20直接忽略
  570. if($wenzhen_order['status'] != 10){
  571. $this->error('订单错误,请刷新重试');
  572. }
  573. //判断患者在线状态
  574. $tenim = new Tenim();
  575. $rs_online = $tenim->is_online('doctor'.$wenzhen_order['doctor_id']);
  576. if($rs_online != true){
  577. $this->error('医生现在不在线,请稍后拨打');
  578. }
  579. $this->success('操作成功');
  580. }
  581. //第一次拨打视频
  582. public function first_video(){
  583. $apilimit = $this->apiLimit();
  584. if(!$apilimit){
  585. $this->error('操作频繁');
  586. }
  587. //订单详情
  588. $order_id = input('order_id',0);
  589. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->find();
  590. if(empty($wenzhen_order)){
  591. $this->error('不存在的订单');
  592. }
  593. if($wenzhen_order['ordertype'] != 2){
  594. $this->error('视频问诊才能拨打视频');
  595. }
  596. if($wenzhen_order['video_model'] != 2){
  597. $this->error('即时视频问诊才能主动拨打视频');
  598. }
  599. if($wenzhen_order['status'] == 30){
  600. $this->error('订单已结束');
  601. }
  602. if($wenzhen_order['status'] == 25){
  603. //倒计时
  604. $minute = config('site.firstvideo_videoorder_autofinish_minute');
  605. if($wenzhen_order['comefrom'] == 2){
  606. $minute = config('site.tv_firstvideo_videoorder_autofinish_minute');
  607. }
  608. $rs = [
  609. 'video_time' => $wenzhen_order['video_time'],
  610. 'video_endtime' => $wenzhen_order['video_time'] + $minute*60,
  611. ];
  612. $rs['seconds'] = $rs['video_endtime'] - time();
  613. //修改最后拨通时间
  614. $update = [
  615. 'last_video_time' => time(),
  616. ];
  617. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->update($update);
  618. $this->success('操作成功',$rs);
  619. }
  620. //20直接忽略
  621. if($wenzhen_order['status'] != 10){
  622. $this->error('订单错误,请刷新重试');
  623. }
  624. //修改订单
  625. $update = [
  626. 'status' => 25,
  627. 'video_time' => time(),
  628. 'last_video_time' => time(),
  629. ];
  630. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->where('status',10)->update($update);
  631. if(!$update_rs){
  632. $this->error('操作失败');
  633. }
  634. //倒计时
  635. $minute = config('site.firstvideo_videoorder_autofinish_minute');
  636. if($wenzhen_order['comefrom'] == 2){
  637. $minute = config('site.tv_firstvideo_videoorder_autofinish_minute');
  638. }
  639. $rs = [
  640. 'video_time' => $update['video_time'],
  641. 'seconds' => $minute*60,
  642. 'video_endtime' => $update['video_time'] + $minute*60,
  643. ];
  644. $this->success('操作成功',$rs);
  645. }
  646. //挂断,医生挂断。这个方法主要用来统计是否已满足一分钟
  647. public function video_end(){
  648. $apilimit = $this->apiLimit();
  649. if(!$apilimit){
  650. $this->error('操作频繁');
  651. }
  652. $end_rule = input('end_rule','user'); //user 用户挂断,doctor 医生挂断。如果是医生挂断并且这个订单一次都没有接通,那就直接按拒绝接诊,结束订单
  653. //订单详情
  654. $order_id = input('order_id',0);
  655. $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('id',$order_id)->find();
  656. if(empty($wenzhen_order)){
  657. $this->error('不存在的订单');
  658. }
  659. if($wenzhen_order['ordertype'] != 2){
  660. $this->error('视频问诊才能拨打视频');
  661. }
  662. if($wenzhen_order['video_model'] != 2){
  663. $this->error('即时视频问诊才能主动拨打视频');
  664. }
  665. if($wenzhen_order['status'] != 25 && $wenzhen_order['status'] != 10){
  666. $this->error('订单错误,请刷新重试');
  667. }
  668. $nowtime = time();
  669. //接通了
  670. if($wenzhen_order['status'] == 25){
  671. //本次不超过1分钟
  672. if($nowtime - $wenzhen_order['last_video_time'] < 60 ){
  673. $this->success('已挂断');
  674. }
  675. //如果本次挂断之前已通话超过一分钟,那自动结束
  676. Db::startTrans();
  677. $wenzhen_order = Db::name('wenzhen_order')->where('id',$order_id)->lock(true)->find();
  678. $update = [
  679. 'status' => 30,
  680. 'finish_time' => $nowtime,
  681. ];
  682. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->update($update);
  683. if(!$update_rs){
  684. Db::rollback();
  685. $this->error('操作失败');
  686. }
  687. //给医生结算钱
  688. $logtype = $wenzhen_order['ordertype'] == 1 ? 111 : 112;
  689. if($wenzhen_order['comefrom'] == 1 && $wenzhen_order['total_fee'] > 0){
  690. $rs_wallet = model('walletdoctor')->lockChangeAccountRemain($wenzhen_order['doctor_id'],'money',$wenzhen_order['total_fee'],$logtype,$remark='问诊订单','wenzhen_order',$order_id);
  691. if($rs_wallet['status'] === false){
  692. Db::rollback();
  693. $this->error($rs_wallet['msg']);
  694. }
  695. }
  696. //医生接诊量
  697. Db::name('doctor')->where('id',$wenzhen_order['doctor_id'])->setInc('ordernum');
  698. Db::commit();
  699. $this->success('已挂断');
  700. }
  701. //没接通
  702. if($wenzhen_order['status'] == 10){
  703. if($end_rule == 'user'){
  704. $this->success('已挂断');
  705. }else{
  706. //如果是医生挂断并且这个订单一次都没有接通,那就直接按拒绝接诊,结束订单
  707. //参考医生发起退珍
  708. Db::startTrans();
  709. $wenzhen_order = Db::name('wenzhen_order')->where('id',$order_id)->lock(true)->find();
  710. //修改订单
  711. $nowtime = time();
  712. $update = [
  713. 'status' => 16,
  714. 'cancel_time' => $nowtime,
  715. 'cancel_reason' => '医生挂断未接诊',
  716. 'finish_time' => $nowtime,
  717. ];
  718. //余额支付的直接退款
  719. if($wenzhen_order['pay_type'] == 'wallet'){
  720. //用户加钱
  721. $logtype = $wenzhen_order['ordertype'] == 1 ? 13 : 14;
  722. $rs_wallet = model('wallet')->lockChangeAccountRemain($wenzhen_order['user_id'],'money',$wenzhen_order['total_fee'],$logtype,$remark='医生挂断未接诊','wenzhen_order',$order_id);
  723. if($rs_wallet['status'] === false){
  724. Db::rollback();
  725. // $this->error($rs_wallet['msg']);
  726. $this->error('医生挂断了');
  727. }
  728. //订单退款参数
  729. $update['refund_price'] = $wenzhen_order['total_fee'];
  730. $update['refund_status'] = 3;
  731. }else{
  732. $update['refund_status'] = 1; //待退款
  733. //发起退款
  734. $Wenzhenorder_model = new Wenzhenorder;
  735. $refund_rs = $Wenzhenorder_model->old_refund($wenzhen_order,$wenzhen_order['total_fee']);
  736. if($refund_rs === true){
  737. $update['refund_status'] = 3; //退款完成
  738. }
  739. }
  740. $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->update($update);
  741. if(!$update_rs){
  742. Db::rollback();
  743. $this->error('医生挂断了');
  744. }
  745. Db::commit();
  746. $this->success('医生挂断并取消了订单');
  747. }
  748. }
  749. //没用的兜底
  750. $this->success('订单错误,请刷新重试');
  751. }
  752. }