auth->id; return $data; } //检查是否月vip private function checkvip(){ $tv_userid = $this->auth->tv_userid; return true; } //创建订单 public function create_order(){ //判断用户来源 if($this->auth->comefrom != 2){ $this->error('用户错误'); } //判断是否是电视盒子月vip $checkvip = $this->checkvip(); if(!$checkvip){ $this->error('您还不是月VIP'); } $member_data = $this->add_member(); //问诊信息 $doctor_id = input('doctor_id',0); $ordertype = 2; $book_date = input('book_date',0); //2024-05-05 $book_hour = input('book_time',0); //10:00 $book_time = strtotime($book_date.' '.$book_hour); $auth_id = $this->auth->id; $order_no = createUniqueNo('TV',$auth_id); //医生信息 $doctor_info = Db::name('doctor_info')->where('doctor_id',$doctor_id)->find(); if(empty($doctor_info)){ $this->error('不存在的医生'); } //价格 $price = 0; if($ordertype == 2){ if($doctor_info['video_switch'] != 1){ $this->error('该医生未开通视频问诊'); } } //排班判断 if($ordertype == 2){ //检查 if($book_time < time() + 7200){ //测试临时屏蔽 //$this->error('最早只能预约'.date('m-d H:00',time() + 10800)); //最早预约两个小时后的一个整点 } //排班状态 $doctor_paiban = Db::name('doctor_paiban')->where('doctor_id',$doctor_id)->where('activetime',$book_time)->find(); if(empty($doctor_paiban)){ $this->error('您预约的时间该医生无法接诊'); } if($doctor_paiban['active'] != 1){ $this->error('您预约的时间该医生无法接诊'); } //是否排满 $map = [ 'doctor_id' => $doctor_id, 'book_time' => $book_time, 'ordertype' => 2, 'status' => ['IN','10,20,25,30'], ]; $order_count = Db::name('wenzhen_order')->where($map)->count(); if($order_count >= 4){ $this->error('该时间点已排满'); } } //订单数据 $order_data = [ 'order_no' => $order_no, 'user_id' => $auth_id, 'member_id' => 0, 'doctor_id' => $doctor_id, 'ordertype' => $ordertype, 'total_fee' => $price, 'book_time' => $book_time, 'createtime' => time(), 'status' => 10,//订单状态enum 'pay_type' => 'tvvip', 'pay_time' => time(), 'comefrom' => 2, ]; Db::startTrans(); //下单 $order_id = Db::name('wenzhen_order')->insertGetId($order_data); if(!$order_id){ Db::rollback(); $this->error('下单失败'); } //订单附表,就诊人信息 $member_data['order_id'] = $order_id; $order_member_id = Db::name('wenzhen_order_member')->insertGetId($member_data); if(!$order_member_id){ Db::rollback(); $this->error('下单失败'); } // Db::commit(); $this->success('下单成功',$order_id); } //订单列表 public function order_list(){ //判断用户来源 if($this->auth->comefrom != 2){ $this->error('用户错误'); } $status = input('status','all'); $where = ['user_id'=>$this->auth->id]; if($status != 'all'){ $where['order.status'] = $status; if($status == 20){// 已接诊、问诊中 $where['order.status'] = ['IN',[20,25]]; } } $field = [ 'order.id','order.order_no','order.book_time','order.status','order.ordertype','order.accept_time','order.video_time','order.doctor_id', 'doctor.avatar as doctor_avatar','doctor.nickname as doctor_nickname','doctor.hospital as doctor_hospital', 'keshi.name as keshi_name', 'level.name as level_name', ]; $list = Db::name('wenzhen_order')->alias('order') ->field($field) ->join('doctor','order.doctor_id = doctor.id','LEFT') ->join('doctor_level level','doctor.level_id = level.id','LEFT') ->join('keshi','doctor.keshi_id = keshi.id','LEFT') ->order('order.id desc') ->where($where) ->autopage()->select(); $list = list_domain_image($list,['doctor_avatar']); if(!empty($list)){ //循环处理 foreach($list as $key => $val){ //医生原因的退款,都直接算到退珍 if(in_array($val['status'],[16,18,22])){ $val['status'] = 100; } //视频拨打中 也算问诊中 if($val['status'] == 25){ $val['status'] = 20; } $list[$key] = $val; } } $this->success(1,$list); } //用户发起退珍 //因为存在第三方,悲观锁 public function tuizhen(){ $apilimit = $this->apiLimit(); if(!$apilimit){ $this->error('操作频繁'); } //判断用户来源 if($this->auth->comefrom != 2){ $this->error('用户错误'); } //订单详情 $order_id = input('order_id',0); Db::startTrans(); $wenzhen_order = Db::name('wenzhen_order')->where('user_id',$this->auth->id)->where('comefrom',2)->where('id',$order_id)->lock(true)->find(); if(empty($wenzhen_order)){ Db::rollback(); $this->error('不存在的订单'); } //仅限视频订单 if($wenzhen_order['ordertype'] == 1){ Db::rollback(); $this->error('图文问诊不能退诊'); } //状态限制 if(!in_array($wenzhen_order['status'],[10,20])){ Db::rollback(); $this->error('当前订单不能退诊'); } //修改订单 $nowtime = time(); $update = [ 'status' => 13, 'cancel_time' => $nowtime, 'cancel_reason' => '用户退诊', 'finish_time' => $nowtime, ]; $update_rs = Db::name('wenzhen_order')->where('id',$order_id)->update($update); if(!$update_rs){ Db::rollback(); $this->error('退诊失败'); } Db::commit(); $this->success('退珍成功'); } }