NN2022060401/app/api/model/book/Order.php

<?php
// +----------------------------------------------------------------------
// | 商城系统 [ 致力于通过产品和服务，帮助商家高效化开拓市场 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2017~2021 https://www.thinkphp.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed 这不是一个自由软件，不允许对程序代码以任何形式任何目的的再发行
// +----------------------------------------------------------------------
// | Author: thinkphp <admin@yiovo.com>
// +----------------------------------------------------------------------
declare (strict_types=1);

namespace app\api\model\book;

use app\api\model\School;
use app\api\model\SchoolSpeciality;
use app\api\model\SpecialityBook;
use app\api\model\User;
use app\api\service\User as UserService;
use app\common\library\wechat\WxPay;
use app\common\model\book\Order as OrderModel;
use app\common\model\wxapp\Setting as WxappSettingModel;
use app\common\service\Order as OrderService;
use app\common\enum\book\order\PayStatus as PayStatusEnum;
use app\common\exception\BaseException;
use think\model\relation\HasOne;

/**
 * 用户报名订单模型
 * Class Order
 * @package app\api\model\book
 */
class Order extends OrderModel
{
    protected $globalScope = [''];

    /**
     * 隐藏字段
     * @var array
     */
    protected $hidden = [
        'transaction_id',
        'create_time',
        'update_time',
    ];

    /**
     * 关联学校
     * @return HasOne
     */
    public function school(): HasOne
    {
        return $this->HasOne('app\\common\\model\\School','id','school_id')
            ->field('id,school_name as book_school_name,logo as school_logo')
            ->bind(['book_school_name','school_logo']);
    }

    /**
     * 代付用户
     * @return HasOne
     */
    public function pilUser(): HasOne
    {
        return $this->HasOne('app\\common\\model\\User','user_id','pil_user_id')
            ->field('user_id,nick_name as pil_user_nickname')
            ->bind(['pil_user_nickname']);
    }

    /**
     * 关联学校
     * @return HasOne
     */
    public function speciality(): HasOne
    {
        return $this->HasOne('app\\common\\model\\SchoolSpeciality','speciality_id','speciality_id')
            ->field('speciality_id,speciality_name')
            ->bind(['speciality_name']);
    }

    /**
     * 获取订单列表
     * @return \think\Paginator
     * @throws BaseException
     * @throws \think\db\exception\DbException
     */
    public function getList($params=[], $listRows=15, $field='')
    {
        $field = $field? $field: 'order_id,order_no,book_user_id,user_id,school_id,speciality_id,pil_user_id,price,total_price,pay_price,pay_type,pay_time,notice_img,receipt_name,receipt_mobile,receipt_address,refund_status,create_time,status';
        // 获取列表数据
        $list = $this->with(['school','speciality','pilUser'])
            ->where('status', '>=', PayStatusEnum::PENDING)
            ->where(function ($query) use($params){
                // 用户订单
                $userId = isset($params['book_user_id'])? $params['book_user_id'] : 0;
                if($userId>0){
                    $query->where('book_user_id','=', $userId);
                }

                // 关键词
                $keyword = isset($params['keyword'])? $params['keyword'] : '';
                if($keyword){
                    $query->where('order_no','like', "%{$keyword}%");
                }

                // 老师订单
                $teacherId = isset($params['user_id'])? $params['user_id'] : 0;
                if($teacherId>0){
                    $query->where('user_id','=', $teacherId);
                }

                $status = isset($params['status'])? $params['status'] : 0;
                if($status>0 || $status == -2){
                    if($status == 1){
                        $status = [1,2];
                    }
                    $status = !is_array($status)? [$status] : $status;
                    $query->whereIn('status', $status);
                }
            })
            ->field($field)
            ->order(['create_time' => 'desc'])
            ->paginate($listRows)
            ->each(function($item, $k){
                $item['school_logo'] = $item['school_logo']? getPreview($item['school_logo']) : '';
                $item['pilUser'] = !is_null($item['pilUser'])? $item['pilUser'] : [];
//                $item['create_time_text'] = $item['create_time']? date('Y/m/d H:i:s', $item['create_time']) : '';
            });
        $list->hidden(['fields','update_time','is_settled']);
        return $list;
    }

    /**
     * 获取订单详情(待付款状态)
     * @param $orderNo
     * @return array|null|static
     */
    public static function getPayDetail(string $orderNo)
    {
        return self::detail(['order_no' => $orderNo, 'status' => PayStatusEnum::PENDING]);
    }

    /**
     * 获取用户报名订单详情(含关联数据)
     * @param int $orderId 订单ID
     * @return Order|array|null
     * @throws BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public static function getUserOrderDetail(int $orderId)
    {
        // 查询订单记录
        $order = static::getDetail($orderId);
        // 该订单是否允许申请售后
        $order['isAllowRefund'] = 1;
        return $order;
    }


    /**
     * 获取用户报名订单详情(仅订单记录)
     * @param int $orderId
     * @param array $with
     * @return Order|array|null
     * @throws BaseException
     */
    public static function getDetail(int $orderId, array $with = [])
    {
        // 查询订单记录
        $order = static::detail($orderId, $with);
        empty($order) && throwError('订单不存在');
        return $order;
    }

    /**
     * 创建报名订单
     * @param array|null $params
     * @return bool|int
     * @throws BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function createOrder(array $params)
    {
        $teacherUserId = isset($params['user_id'])? intval($params['user_id']) : 0;
        $teacher = User::detail($teacherUserId,['info']);
        $teacherInfo = isset($teacher['info'])? $teacher['info'] : [];
        if(empty($teacherUserId) || empty($teacher)){
            $this->error = '报名咨询老师参数错误';
            return false;
        }
        $schoolId = isset($params['school_id'])? intval($params['school_id']) : 0;
        $specialityId = isset($params['speciality_id'])? intval($params['speciality_id']) : 0;
        if($schoolId<=0 || $specialityId <= 0){
            $this->error = '报名学校或报名专业参数错误';
            return false;
        }

        $school = School::detail($schoolId);
        if(empty($school)){
            $this->error = '报名学校不存在';
            return false;
        }

        // 表单参数验证
        $realName = isset($params['real_name'])? $params['real_name'] : '';
        if(empty($realName)){
            $this->error = '请填写报名用户真实姓名';
            return false;
        }
        $gender = isset($params['gender'])? intval($params['gender']) : 0;
        if($gender<=0){
            $this->error = '请选择报名用户性别';
            return false;
        }

        $schoolName = isset($params['school_name'])? $params['school_name'] : '';
        if(empty($schoolName)){
            $this->error = '请填写报名用户现读学校';
            return false;
        }
        $realName = isset($params['real_name'])? $params['real_name'] : '';
        if(empty($realName)){
            $this->error = '请填写报名用户真实姓名';
            return false;
        }

        $receiptName = isset($params['receipt_name'])? $params['receipt_name'] : '';
        if(empty($receiptName)){
            $this->error = '请填写收货人姓名';
            return false;
        }
        $receiptMobile = isset($params['receipt_mobile'])? $params['receipt_mobile'] : '';
        if(empty($receiptMobile)){
            $this->error = '请填写收货人联系电话';
            return false;
        }
        $receiptAddress = isset($params['receipt_address'])? $params['receipt_address'] : '';
        if(empty($receiptAddress)){
            $this->error = '请填写收货人地址';
            return false;
        }

        $trade = \app\store\model\Setting::getItem('trade');
        $price = isset($trade['books']['book_cost'])? floatval($trade['books']['book_cost']) : 0;
        if($price<=0){
            $this->error = '请先后台设置报名费用';
            return false;
        }

        // 专业参数验证
        $speciality = SchoolSpeciality::detail($specialityId);
        if(empty($speciality)){
            $this->error = '报名专业不存在';
            return false;
        }
        if($speciality['school_id'] != $schoolId){
            $this->error = '报名专业和学校不匹配';
            return false;
        }

        // 报名人数验证
        $bookNum = SpecialityBook::getBooks($specialityId);
        $remainBookNum = max(0, $speciality['recruit_num'] - $bookNum);
        if($remainBookNum <= 0){
            $this->error = '该专业报名人数已满';
            return false;
        }


        // 订单数据
        $fields = isset($params['fields'])? $params['fields'] : [];
        $fields = $fields && is_array($fields)? json_encode($fields) : '';
        $order = [
            'book_user_id' => UserService::getCurrentLoginUserId(),
            'user_id' => $teacherUserId,
            'agent_id' => isset($teacherInfo['agent_id'])? $teacherInfo['agent_id'] : 0,
            'order_no' => 'BK' . OrderService::createOrderNo(),
            'real_name' => $realName,
            'gender' => $gender,
            'age' => isset($params['age'])? $params['age'] : 0,
            'school_name' => $schoolName,
            'school_id' => $schoolId,
            'speciality_id' => $specialityId,
            'price' => floatval($price),
            'total_price' => floatval($price),
            'receipt_name' => $receiptName,
            'receipt_mobile' => $receiptMobile,
            'receipt_address' => $receiptAddress,
            'fields' => $fields,
            'create_time' => time(),
            'update_time' => time(),
            'status' => 1,
        ];

        return $this->save($order);
    }

    public function modifyOrder($orderId, $params=[])
    {
        if(empty($orderId)){
            $this->error = '订单参数错误';
            return false;
        }

        $modifyType = isset($params['type'])? $params['type'] : 0;
        if(!in_array($modifyType, [1,2])){
            $this->error = '订单修改类型错误';
            return false;
        }

        $model = self::detail($orderId);
        if(empty($model)){
            $this->error = '订单不存在';
            return false;
        }
        $data = ['update_time'=> time()];
        if($modifyType == 1){
            if(!in_array($model['status'],[1,2,3])){
                $this->error = '订单状态不可操作';
                return false;
            }

            $receiptName = isset($params['receipt_name'])? $params['receipt_name'] : '';
            if(empty($receiptName)){
                $this->error = '请填写收货人姓名';
                return false;
            }
            $receiptMobile = isset($params['receipt_mobile'])? $params['receipt_mobile'] : '';
            if(empty($receiptMobile)){
                $this->error = '请填写收货人联系电话';
                return false;
            }
            $receiptAddress = isset($params['receipt_address'])? $params['receipt_address'] : '';
            if(empty($receiptAddress)){
                $this->error = '请填写收货人地址';
                return false;
            }

            $data = [
                'receipt_name'=> $receiptName,
                'receipt_mobile'=> $receiptMobile,
                'receipt_address'=> $receiptAddress,
            ];
        }else if ($modifyType == 2){
            if(!in_array($model['status'],[1,2,3])){
                $this->error = '订单状态不可操作';
                return false;
            }

            $specialityId = isset($params['speciality_id'])? intval(['speciality_id']) : 0;
            if(empty($specialityId)){
                $this->error = '请选择修改的专业';
                return false;
            }

            // 专业参数验证
            $speciality = SchoolSpeciality::detail($specialityId);
            if(empty($speciality)){
                $this->error = '报名专业不存在';
                return false;
            }
            if($speciality['school_id'] != $model['school_id']){
                $this->error = '报名专业和学校不匹配';
                return false;
            }

            // 报名人数验证
            $bookNum = SpecialityBook::getBooks($specialityId);
            $remainBookNum = max(0, $speciality['recruit_num'] - $bookNum);
            if($remainBookNum <= 0){
                $this->error = '该专业报名人数已满';
                return false;
            }

            $data = [
                'speciality_id' => $specialityId
            ];
        }

        return $model->save($data);
    }

    /**
     * 验证支付订单
     * @param $order
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function checkPay($order)
    {
        $orderId = isset($order['order_id'])? $order['order_id'] : 0;
        if($orderId<=0){
            $this->error = '订单参数错误';
            return false;
        }
        $orderStatus = isset($order['status'])? $order['status'] : 0;
        if($orderStatus == 3){
            $this->error = '订单已支付';
            return false;
        }

        if($orderStatus != 2){
            $this->error = '订单未确认或状态不可支付';
            return false;
        }

        $specialityId = isset($order['speciality_id'])? intval($order['speciality_id']) : 0;
        // 专业参数验证
        $speciality = SchoolSpeciality::detail($specialityId);
        if(empty($speciality)){
            $this->error = '报名专业不存在';
            return false;
        }

        // 报名人数验证
        $bookNum = SpecialityBook::getBooks($specialityId);
        $remainBookNum = max(0, $speciality['recruit_num'] - $bookNum);
        if($remainBookNum <= 0){
            $this->error = '该专业报名人数已满';
            return false;
        }

        // 已经报名次数
        $trade = \app\store\model\Setting::getItem('trade');
        $bookLimit = isset($trade['books']['book_limit'])? intval($trade['books']['book_limit']) : 0;
        $bookLimit = $bookLimit? $bookLimit : 3;
        if(SpecialityBook::getUserBooks($orderId) >= $bookLimit){
            $this->error = "您已经报名了{$bookLimit}次，不能再报名";
            return false;
        }

        return true;
    }

    /**
     * 确认报名订单
     * @param $orderId
     * @param $noticeImg
     * @return bool
     * @throws BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function confirmOrder($orderId, $noticeImg)
    {
        if(empty($orderId)){
            $this->error = '订单参数错误';
            return false;
        }
        if(empty($noticeImg)){
            $this->error = '请上传录取通知书';
            return false;
        }

        $model = new Order();
        $model = $model::getUserOrderDetail($orderId);
        if(!$model){
            $this->error = '报名订单不存在';
            return false;
        }
        // 订单所属老师才何以设置
        $userInfo = UserService::getCurrentLoginUser(true);
        if($userInfo['user_id'] != $model['user_id']){
            $this->error = '订单无权操作';
            return false;
        }
        if($model['status'] != 1){
            $this->error = '订单已确认或状态不可操作';
            return false;
        }

        return $model->save(['status'=> 2,'notice_img'=> $noticeImg]);
    }

    /**
     * 取消订单
     * @param $orderId
     * @param string $remark
     * @return bool
     * @throws BaseException
     * @throws \cores\exception\BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function cancelOrder($orderId, $remark='')
    {
        if(empty($orderId)){
            $this->error = '订单参数错误';
            return false;
        }
        $model = new Order();
        $model = $model::getUserOrderDetail($orderId);
        if(!$model){
            $this->error = '报名订单不存在';
            return false;
        }
        // 订单所属老师才何以设置
        $userInfo = UserService::getCurrentLoginUser(true);
        if($userInfo['user_id'] != $model['book_user_id']){
            $this->error = '订单无权操作';
            return false;
        }
        if(!in_array($model['status'], [1,2])){
            $this->error = '订单状态不可操作';
            return false;
        }

        return $model->save(['status'=> -1,'update_time'=> time(),'remark'=> $remark]);
    }
    /**
     * 订单发货设置
     * @param int $orderId 订单ID
     * @param $params 发货参数：快递公司ID、快递公司名称、快递单号
     * @return bool
     * @throws BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function setDelivery(int $orderId, $params)
    {
        $data['express_id'] = isset($params['express_id'])? $params['express_id'] : '';
        $data['express_company'] = isset($params['express_company'])? $params['express_company'] : '';
        $data['express_no'] = isset($params['express_no'])? $params['express_no'] : '';
        if(empty($orderId)){
            $this->error = '订单参数错误';
            return false;
        }
        if(empty($data['express_id'])){
            $this->error = '请选择快递公司';
            return false;
        }
        if(empty($data['express_company'])){
            $this->error = '请选择快递公司';
            return false;
        }
        if(empty($data['express_no'])){
            $this->error = '请填写快递单号';
            return false;
        }

        $model = new Order();
        $model = $model::getUserOrderDetail($orderId);
        if(!$model){
            $this->error = '报名订单不存在';
            return false;
        }
        // 订单所属老师才何以设置对应发货信息
        $userInfo = UserService::getCurrentLoginUser(true);
        if($userInfo['user_id'] != $model['user_id']){
            $this->error = '订单无权操作';
            return false;
        }
        if(in_array($model['status'], [1,2])){
            $this->error = '订单未支付';
            return false;
        }
        if($model['status'] != 3){
            $this->error = '订单已发货或状态不可操作';
            return false;
        }

        $data['status'] = 4;
        $data['delivery_time'] = time();
        return $model->save($data);
    }

    /**
     * 订单确认收货
     * @param $orderId
     * @return false
     * @throws BaseException
     * @throws \cores\exception\BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function receiptOrder($orderId)
    {
        if(empty($orderId)){
            $this->error = '订单参数错误';
            return false;
        }

        $model = new Order();
        $model = $model::getUserOrderDetail($orderId);
        if(!$model){
            $this->error = '报名订单不存在';
            return false;
        }
        $userInfo = UserService::getCurrentLoginUser(true);
        if($userInfo['user_id'] != $model['book_user_id']){
            $this->error = '订单无权操作';
            return false;
        }
        if($model['refund_status'] != 4){
            $this->error = '订单已收货或状态不可操作';
            return false;
        }

        // 直接收货完成
        $data['status'] = 6;
        $data['receipt_time'] = time();
        return $model->save($data);
    }

    /**
     * 设置订单为可退款
     * @param int $orderId
     * @return bool
     * @throws BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function setRefund(int $orderId)
    {
        if(empty($orderId)){
            $this->error = '订单参数错误';
            return false;
        }

        $model = new Order();
        $model = $model::getUserOrderDetail($orderId);
        if(!$model){
            $this->error = '报名订单不存在';
            return false;
        }

        // 订单所属老师才可以操作
        $userInfo = UserService::getCurrentLoginUser(true);
        if($userInfo['user_id'] != $model['user_id']){
            $this->error = '订单无权操作';
            return false;
        }
        if(in_array($model['status'], [1,2])){
            $this->error = '订单未支付';
            return false;
        }

        if($model['refund_status'] != 1 || !in_array($model['status'], [3,4])){
            $this->error = '订单设置为可退款或状态不可操作';
            return false;
        }

        return $model->save(['refund_status'=> 2]);
    }

    /**
     * 订单申请退款
     * @param $orderId
     * @param $refundResult 退款原因
     * @return bool
     * @throws BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function refundOrder($orderId, $refundResult)
    {
        if(empty($orderId)){
            $this->error = '订单参数错误';
            return false;
        }

        if(empty($refundResult)){
            $this->error = '请填写退款原因';
            return false;
        }

        $model = new Order();
        $model = $model::getUserOrderDetail($orderId);
        if(!$model){
            $this->error = '报名订单不存在';
            return false;
        }
        // 订单所属用户才可以操作
        $userInfo = UserService::getCurrentLoginUser(true);
        if($userInfo['user_id'] != $model['book_user_id']){
            $this->error = '订单无权操作';
            return false;
        }

        if(in_array($model['status'], [1,2])){
            $this->error = '订单未支付';
            return false;
        }

        if($model['refund_status'] != 2 || !in_array($model['status'], [3,4])){
            $this->error = '订单已申请退款或状态不可操作';
            return false;
        }

        return $model->save(['refund_status'=> 3,'refund_result'=> $refundResult]);
    }


    /**
     * 订单退款确认
     * @param $orderId
     * @param $refundResult 退款凭证
     * @return bool
     * @throws BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function refundConfirm($orderId, $refundImg)
    {
        if(empty($orderId)){
            $this->error = '订单参数错误';
            return false;
        }

        if(empty($refundResult)){
            $this->error = '请填写退款原因';
            return false;
        }

        $model = new Order();
        $model = $model::getUserOrderDetail($orderId);
        if(!$model){
            $this->error = '报名订单不存在';
            return false;
        }
        // 订单所属老师才可以处理
        $userInfo = UserService::getCurrentLoginUser(true);
        if($userInfo['user_id'] != $model['user_id']){
            $this->error = '订单无权操作';
            return false;
        }
        if($model['status'] == -2){
            $this->error = '订单已退款';
            return false;
        }

        if(in_array($model['status'], [1,2])){
            $this->error = '订单未支付';
            return false;
        }

        if($model['refund_status'] != 3 || !in_array($model['status'], [3,4])){
            $this->error = '订单已退款或状态不可操作';
            return false;
        }

        // 调起退款
        if(!$this->refund($model)){
            $this->error = '退款处理失败';
            return false;
        }

        return $model->save(['refund_status'=> 4,'refund_img'=> $refundImg,'status'=> -2]);
    }

    public function cancel()
    {

    }

    /**
     * 退款调起
     * @param $order
     * @param int $money
     * @return bool
     * @throws BaseException
     * @throws \cores\exception\BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    private function refund($order, $money=0)
    {
        $wxConfig = WxappSettingModel::getWxappConfig(getStoreId());
        $WxPay = new WxPay($wxConfig, getStoreId());
        $money = $money? $money : $order['pay_price'];
        return $WxPay->refund($order['transaction_id'], $order['pay_price'], $money);
    }
}