shuijiao/application/api/controller/tvuser/Wenzhen.php

<?php

namespace app\api\controller\tvuser;

use app\common\controller\Api;
use think\Db;
use addons\epay\library\Service;
use app\common\library\Tenim;
use app\common\model\Wenzhenorder;

/**
 * 问诊订单
 */
class Wenzhen extends Api
{
    protected $noNeedLogin = '';
    protected $noNeedRight = '*';

    //添加成员
    private function add_member(){
        $field = [
            'gender',
            'age',
            'marital_status',
            'allergies_status',
            'familymedical_status',
            'chronicdisease_status',
        ];

        $data = request_post_hub($field);
        $data['user_id'] = $this->auth->id;

        return $data;
    }

    //判断是否 健康E家自己的vip
    private function checkvip(){
        $is_my_vip = 0;

        $tv_userid = $this->auth->tv_userid;

        //跨数据库查询
        $tv_user = Db::connect('database_tv')->name('hu_user')->where('id',$tv_userid)->find();
        if(!empty($tv_user)){
            $is_my_vip = $tv_user['is_my_vip'];
        }

        return $is_my_vip;
    }

    //创建订单
    public function create_order(){

        //判断用户来源
        if($this->auth->comefrom != 2){
            $this->error('用户错误');
        }

        //判断是否 健康E家自己的vip
        $checkvip = $this->checkvip();
        if(!$checkvip){
            $this->error('您不是健康E家的VIP用户');
        }

        //检查本月是否已经下过一个有效单了
        $checkmap = [
            'user_id' => $this->auth->id,
            'comefrom'=> 2,
            'status'  => ['IN','10,20,25,30'],//有效订单
        ];
        $check_order = Db::name('wenzhen_order')->where($checkmap)->whereTime('createtime','month')->find();
        if(!empty($check_order)){
            $this->error('您本月的免费问诊次数已用完');
        }

        //问诊患者
        $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('退珍成功');
    }
}