NN2025112501/app/Services/Api/OrderService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services\Api;

use App\Models\GoodsModel;
use App\Models\MemberModel;
use App\Models\OrderModel;
use App\Services\BaseService;
use App\Services\ConfigService;
use App\Services\RedisService;
use Illuminate\Support\Facades\DB;

/**
 * 订单-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * @package App\Services\Api
 */
class OrderService extends BaseService
{
    // 静态对象
    protected static $instance = null;

    /**
     * 构造函数
     * @author laravel开发员
     * @since 2020/11/11
     */
    public function __construct()
    {
        $this->model = new OrderModel();
    }

    /**
     * 静态入口
     */
    public static function make()
    {
        if (!self::$instance) {
            self::$instance = new static();
        }
        return self::$instance;
    }

    /**
     * 订单列表
     * @param $params
     * @param int $pageSize
     * @return array
     */
    public function getDataList($params, $pageSize = 15)
    {
        $model = $this->getQuery($params);

        // 数据
        $list = $model->where(function ($query) use ($params) {
            $status = isset($params['status']) ? $params['status'] : 0;
            // 进行中
            if ($status > 0 && is_array($status)) {
                $query->whereIn('a.status', $status);
            }else if($status>0){
                $query->where('a.status', $status);
            }
        })->select(['a.*'])
            ->orderBy('a.status', 'desc')
            ->orderBy('a.create_time', 'desc')
            ->orderBy('a.id', 'desc')
            ->paginate($pageSize > 0 ? $pageSize : 9999999);
        $list = $list ? $list->toArray() : [];
        if ($list) {
            $statusArr = [1 => '接单中', 2 => '进行中', 3 => '已完成'];
            foreach ($list['data'] as &$item) {
                $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : '';
                $status = isset($item['status']) ? $item['status'] : 0;
                $item['status_text'] = '接单中';
                if ($status) {
                    $item['status_text'] = isset($statusArr[$status]) ? $statusArr[$status] : '';
                }

                $item['goods'] = isset($item['goods']) && $item['goods'] ? $item['goods'] : [];
                $item['goods']['shipper_phone_text'] = $item['goods']['shipper_phone']?format_mobile($item['goods']['shipper_phone']) : '';
                $item['goods']['receiver_phone_text'] = $item['goods']['receiver_phone']?format_mobile($item['goods']['receiver_phone']) : '';
            }
            unset($item);
        }

        return [
            'pageSize' => $pageSize,
            'total' => isset($list['total']) ? $list['total'] : 0,
            'list' => isset($list['data']) ? $list['data'] : []
        ];
    }

    /**
     * 查询条件
     * @param $params
     * @return mixed
     */
    public function getQuery($params)
    {
        $where = ['a.mark' => 1];
        return $this->model->from('orders as a')->with(['goods'])
            ->leftJoin('member as b', 'b.id', '=', 'a.user_id')
            ->where($where)
            ->where(function($query) use($params){
                $userId = isset($params['user_id']) ? intval($params['user_id']) : 0;
                if($userId>0){
                    $query->where('a.user_id', $userId);
                }
            })
            ->where(function ($query) use ($params) {
                $keyword = isset($params['keyword']) ? $params['keyword'] : '';
                if ($keyword) {
                    $query->where('a.order_no', 'like', "%{$keyword}%")
                        ->orWhere('b.nickname', 'like', "%{$keyword}%")
                        ->orWhere('b.mobile', 'like', "%{$keyword}%");
                }
            });
    }

    /**
     * 订单详情
     * @param $id
     */
    public function getOrderInfo($id)
    {
        $statusArr = [1 => '待审核', 2 => '进行中', 3 => '已完成'];
        $info = $this->model->from('orders as a')->with(['goods'])
            ->leftJoin('member as b', 'b.id', '=', 'a.user_id')
            ->where(['a.id' => $id, 'a.mark' => 1])
            ->select(['a.*'])
            ->first();

        if ($info) {
            $info = $info->toArray();
            $info['create_time'] = $info['create_time'] ? datetime($info['create_time'], 'Y-m-d H:i:s') : '';
            $status = isset($info['status']) ? $info['status'] : 0;
            $info['status_text'] = '待付款';
            if ($status) {
                $info['status_text'] = isset($statusArr[$status]) ? $statusArr[$status] : '';
            }

            $info['goods'] = isset($info['goods']) && $info['goods'] ? $info['goods'] : [];
            $info['goods']['shipper_phone_text'] = $info['goods']['shipper_phone']?format_mobile($info['goods']['shipper_phone']) : '';
            $info['goods']['receiver_phone_text'] = $info['goods']['receiver_phone']?format_mobile($info['goods']['receiver_phone']) : '';
        }

        return $info;
    }

    /**
     * 创建订单
     * @param $userId 用户
     * @param $params 参数
     * @return array|false
     */
    public function createOrder($userId, $params)
    {
        $goodsId = isset($params['goods_id']) && $params['goods_id'] ? intval($params['goods_id']) : 0;
        // 参数验证
        if (empty($goodsId)) {
            $this->error = 2103;
            return false;
        }

        // 缓存锁
        $cacheLockKey = "caches:orders:submit_lock:{$userId}_{$goodsId}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = 2107;
            return false;
        }

        // 货物信息
        RedisService::set($cacheLockKey, ['params' => $params, 'user_id' => $userId], rand(2, 3));
        $goodsInfo = GoodsModel::where(['id' => $goodsId,'status'=>1, 'mark' => 1])
            ->select(['id','num', 'price','picker_status', 'status'])
            ->first();
        $pickerStatus = isset($goodsInfo['picker_status']) ? $goodsInfo['picker_status'] : 0;
        $price = isset($goodsInfo['price']) ? floatval($goodsInfo['price']) : 0;
        $num = isset($goodsInfo['num']) ? intval($goodsInfo['num']) : 0;
        if(empty($goodsInfo)){
            $this->error = 2201;
            RedisService::clear($cacheLockKey);
            return false;
        }

        if(in_array($pickerStatus,[2,3])){
            $this->error = "220{$pickerStatus}";
            RedisService::clear($cacheLockKey);
            return false;
        }

        if($price<=0){
            $this->error = 2204;
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 用户信息
        $userInfo = MemberModel::where(['id' => $userId, 'mark' => 1])
            ->select(['id', 'mobile', 'nickname','realname','deposit','picker_status','confirm_status', 'status'])
            ->first();
        $status = isset($userInfo['status']) ? $userInfo['status'] : 0;
        $nickname = isset($userInfo['nickname']) ? $userInfo['nickname'] : '';
        $realname = isset($userInfo['realname']) ? $userInfo['realname'] : '';
        $mobile = isset($userInfo['mobile']) ? $userInfo['mobile'] : '';
        $confirmStatus = isset($userInfo['confirm_status']) ? $userInfo['confirm_status'] : 0;
        $userPickerStatus = isset($userInfo['picker_status']) ? $userInfo['picker_status'] : 0;
        $userDeposit = isset($userInfo['deposit']) ? floatval($userInfo['deposit']) : 0;
        if(empty($userInfo) || $status != 1){
            $this->error = 2016;
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 账号审核情况
        if($confirmStatus != 1){
            $this->error = 2042;
            RedisService::clear($cacheLockKey);
            return false;
        }

        if($userPickerStatus != 1){
            $this->error = 2205;
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 缴纳保证金验证
        $depositMoney = ConfigService::make()->getConfigByCode('deposit_money',0);
        if($depositMoney>0 && ($userDeposit < $depositMoney)){
            $this->error = 2206;
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 订单数据
        $pickerCount = $this->model->where(['goods_id'=> $goodsId,'mark'=>1])->whereIn('status',[1,2])->count('id');
        if($this->model->where(['user_id'=>$userId,'goods_id'=>$goodsId,'mark'=>1])->whereIn('status',[1,2,3])->value('id')){
            $this->error = 2209;
            RedisService::clear($cacheLockKey);
            return false;
        }
        if($this->model->where(['user_id'=>$userId,'mark'=>1])->whereIn('status',[1,2])->value('id')){
            $this->error = 2209;
            RedisService::clear($cacheLockKey);
            return false;
        }
        $bonusRate = ConfigService::make()->getConfigByCode('picker_bonus_rate',100);
        $bonusRate = $bonusRate>0 && $bonusRate<=100? intval($bonusRate) : 100;
        $bonus = moneyFormat($price * $bonusRate/100,2);
        $orderNo = get_order_num('PD');
        $order = [
            'order_no' => $orderNo,
            'user_id' => $userId,
            'goods_id' => $goodsId,
            'total' => $price,
            'bonus' => $bonus,
            'create_time' => time(),
            'update_time' => time(),
            'status' => 1,
            'mark' => 1,
        ];

        // 订单处理
        DB::beginTransaction();
        if (!$orderId = $this->model->insertGetId($order)) {
            DB::rollBack();
            $this->error = 2207;
            RedisService::clear($cacheLockKey);
            return false;
        }

        $title = "用户【{$realname}-{$mobile}】有新的抢单";
        $message = [
            'from_uid'=> $userId,
            'to_uid'=> 1,
            'op'=> 'notice',
            'scene'=> 'picker',
            'message'=> '接单消息',
            'type'=> 5,
            'order'=>[
                'title'=> $title.'<span class="ele-text-primary">查看订单</span>',
                'order_no'=> $orderNo,
                'money'=> $bonus,
                'date'=> date('Y-m-d H:i:s'),
                'user_id'=> $userId,
                'type'=> 'deposit',
                'remark'=> '接单消息',
            ]
        ];

        DB::commit();
        $pickerCount = $pickerCount+1;
        $this->error = lang('2210');
        RedisService::clear($cacheLockKey);
        RedisService::keyDel("caches:goods:picker*");
        return ['order_id' => $orderId,'message'=>$message, 'total' => $price, 'num' => $pickerCount<=3?3:$pickerCount, 'goods' => $goodsId];
    }

    /**
     * 今日数量统计数据
     * @param $userId
     * @param int $type
     * @return array|mixed
     */
    public function getCountByDay($userId, $status=3)
    {
        $cacheKey = "caches:orders:count_day_{$userId}_{$status}";
        $data = RedisService::get($cacheKey);
        if($data){
            return $data;
        }

        $data = $this->model->where(['user_id'=> $userId,'status'=>$status,'mark'=>1])
            ->where('create_time','>=', strtotime(date('Y-m-d')))
            ->count('id');
        if($data){
            RedisService::set($cacheKey, $data, rand(5,10));
        }

        return $data;
    }

    /**
     * 订单数
     * @param $userId
     * @param int $status
     * @return array|mixed
     */
    public function getCountByStatus($userId, $status=3)
    {
        $cacheKey = "caches:orders:count_status_{$userId}_{$status}";
        $data = RedisService::get($cacheKey);
        if($data){
            return $data;
        }

        $data = $this->model->where(['user_id'=> $userId,'status'=>$status,'mark'=>1])
            ->count('id');
        if($data){
            RedisService::set($cacheKey, $data, rand(5,10));
        }

        return $data;
    }

    /**
     * 获取订单审核状态
     * @param $userId
     * @return array|mixed
     */
    public function checkOrderStatus($userId)
    {
        $cacheKey = "caches:orders:checkOrder:{$userId}";
        $data = RedisService::get($cacheKey);
        if($data){
            return $data;
        }

        $data = $this->model->with(['confirm'])->where(function($query){
                $query->where(function($query){
                    $query->where('status',2)->where('confirm_at','>=', date('Y-m-d H:i:s', time() - 3600));
                })->orWhere(function($query){
                    $query->where('status', 9)->where('confirm_at','>=', date('Y-m-d H:i:s', time() - 600));
                })->orWhere(function($query){
                    $query->where('status', 3)->where('confirm_at','>=', date('Y-m-d H:i:s', time() - 600));
                })->orWhere('status', 1);
            })
            ->where(['user_id'=> $userId,'mark'=>1])
            ->select(['id','order_no','user_id','goods_id','status'])
            ->orderBy('id','desc')
            ->first();
        $data = $data? $data->toArray() : [];
        $result = [];
        if($data){
            $orderId = isset($data['id'])? $data['id'] : 0;
            $status = isset($data['status'])? $data['status'] : 0;
            $goodsId = isset($data['goods_id'])? $data['goods_id'] : 0;
            $confirmOrder = isset($data['confirm'])? $data['confirm'] : [];
            $confirmOrderId = isset($confirmOrder['id'])? $confirmOrder['id'] : 0;
            $confirmOrderUser = isset($confirmOrder['user'])? $confirmOrder['user'] : [];
            $realname = isset($confirmOrderUser['realname'])? $confirmOrderUser['realname'] : '';
            if($status==9){
                $message = "抱歉，订单已被其他师傅接走";
            }else if($status == 2){
                $message = "恭喜您，抢单成功，请前往完成订单！";
            }else if($status == 3){
                $message = "恭喜您，订单已经完成！";
            }else {
                $pickerCount = $this->model->where(['goods_id'=> $goodsId,'mark'=>1])->whereIn('status',[1,2])->count('id');
                $pickerCount = $pickerCount<=3? 3 : $pickerCount;
                $message = "<p style='padding: 5px 0;'>正在抢单</p><p>（{$pickerCount}位师傅正在抢单中）</p>";
            }
            $result = ['order_id'=>$orderId,'goods_id'=>$goodsId,'confirm_order_id'=>$confirmOrderId,'status'=>$status, 'message'=> $message];
            RedisService::set($cacheKey, $result, rand(10, 20));
        }

        return $result;
    }
}