NN2026041601/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\AccountLogModel;
use App\Models\CartModel;
use App\Models\GoodsModel;
use App\Models\GoodsSkuModel;
use App\Models\MemberModel;
use App\Models\OrderGoodsModel;
use App\Models\OrderModel;
use App\Models\StoreModel;
use App\Services\BaseService;
use App\Services\ConfigService;
use App\Services\Kd100Service;
use App\Services\PaymentService;
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)->where('a.refund_status', 0);
            } else if ($status == 6) {
                $query->where('a.status', '>', 1)->where('a.refund_status', '>', 0);
            } else if ($status > 0) {
                $query->where('a.status', $status)->where('a.refund_status', 0);
            }
        })->select(['a.*'])
            ->orderBy('a.id', 'desc')
            ->paginate($pageSize > 0 ? $pageSize : 9999999);
        $list = $list ? $list->toArray() : [];
        if ($list) {
            $statusArr = [1 => '待支付', 2 => '待发货', 3 => '待收货', 4 => '确认收货'];
            foreach ($list['data'] as &$item) {
                $item['create_time'] = $item['create_time'] ? dateFormat(strtotime($item['create_time']), 'Y-m-d') : '';
                $status = isset($item['status']) ? $item['status'] : 0;
                $item['status_text'] = '待支付';
                if ($status) {
                    $item['status_text'] = isset($statusArr[$status]) ? $statusArr[$status] : '';
                }

                if ($item['refund_status'] > 0) {
                    $item['status_text'] = '退款/售后';
                }

                $item['goods'] = isset($item['goods']) && $item['goods'] ? $item['goods'] : [];
                $item['real_total'] = $item['pay_total'];
                $item['pay_total'] = moneyFormat($item['pay_total'] + $item['delivery_fee'], 2);
            }
            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.is_hide' => 0,'a.main_no'=>'', 'a.mark' => 1];
        return $this->model->from('orders as a')
            ->with(['orderGoods', 'store'])
            ->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);
                }

                // 订单类型
                $type = isset($params['type']) ? intval($params['type']) : 0;
                if ($type > 0) {
                    $query->where('a.type', $type);
                }
            })
            ->where(function ($query) use ($params) {
                $keyword = isset($params['keyword']) ? $params['keyword'] : '';
                if ($keyword) {
                    $query->where('a.order_no', 'like', "%{$keyword}%")
                        ->orWhere('b.mobile', 'like', "%{$keyword}%");
                }
            });
    }

    /**
     * 订单详情
     * @param $id
     */
    public function getOrderInfo($id, $no = '')
    {
        $where = ['a.order_no' => $no, 'a.id' => $id, 'a.mark' => 1];
        if ($no) {
            unset($where['a.id']);
        } else {
            unset($where['a.order_no']);
        }

        $statusArr = [1 => '待支付', 2 => '待发货', 3 => '待收货', 4 => '已完成'];
        $info = $this->model->from('orders as a')
            ->with(['orderGoods', 'store'])
            ->leftJoin('member as b', 'b.id', '=', 'a.user_id')
            ->where($where)
            ->select(['a.*'])
            ->first();

        if ($info) {
            $info = $info->toArray();
            $info['create_time'] = $info['create_time'] ? datetime($info['create_time'], 'Y-m-d H:i:s') : '';
            $info['pay_at'] = $info['pay_at'] ? datetime(strtotime($info['pay_at']), 'Y-m-d H:i:s') : '';
            $info['receiver_mobile_text'] = $info['receiver_mobile'] ? format_mobile($info['receiver_mobile']) : '';
            $info['real_total'] = $info['pay_total'];
            $info['pay_total'] = moneyFormat($info['pay_total'] + $info['delivery_fee'], 2);
            $status = isset($info['status']) ? $info['status'] : 0;
            $info['status_text'] = '待支付';
            if ($status) {
                $info['status_text'] = isset($statusArr[$status]) ? $statusArr[$status] : '';
            }
        }

        return $info;
    }


    /**
     * 创建订单
     * @param $userId 用户
     * @param $params 参数
     * @return array|false
     */
    public function createOrder($userId, $params)
    {
        $type = isset($params['type']) && $params['type'] ? $params['type'] : 1;
        $submitType = isset($params['submit_type']) && $params['submit_type'] ? $params['submit_type'] : '';
        $addressId = isset($params['address_id']) && $params['address_id'] ? $params['address_id'] : 0;
        $goods = isset($params['goods']) && $params['goods'] ? $params['goods'] : [];
        $ids = $goods ? array_column($goods, 'id') : [];
        // 参数验证
        if (empty($goods) || empty($ids)) {
            $this->error = '商品参数不为空';
            return false;
        }

        if ($addressId <= 0) {
            $this->error = '请选择收货地址';
            return false;
        }

        // 缓存锁
        $cacheLockKey = "caches:orders:submit_lock:{$userId}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = '订单处理中～';
            return false;
        }

        // 用户信息
        RedisService::set($cacheLockKey, ['params' => $params, 'user_id' => $userId], rand(3, 5));
        $userInfo = MemberModel::where(['id' => $userId, 'mark' => 1])
            ->select(['id', 'openid','nickname','member_level','parent_id','point_id','points', 'buy_type','property','balance', 'bd_score', 'status'])
            ->first();
        $status = isset($userInfo['status']) ? $userInfo['status'] : 0;
        $openid = isset($userInfo['openid']) ? $userInfo['openid'] : 0;
        $buyType = isset($userInfo['buy_type']) ? $userInfo['buy_type'] : 0;
        $bdScore = isset($userInfo['bd_score']) ? $userInfo['bd_score'] : 0;
        $discountPoint = isset($userInfo['discount_point']) ? $userInfo['discount_point'] : 0; // 折扣
        if (empty($userInfo) || $status != 1) {
            $this->error = 1045;
            return false;
        }

        if (empty($openid)) {
            $this->error = 1042;
            return false;
        }

        // 商品数据
        $orderNo = get_order_num('JK');
        $result = GoodsService::make()->getOrderGoods($ids, $goods, $userId, $orderNo, $discountPoint);
        if (empty($result)) {
            RedisService::clear($cacheLockKey);
            $this->error = GoodsService::make()->getError();
            return false;
        }

        $orderGoods = isset($result['goods']) ? $result['goods'] : [];
        $goodsTotal = isset($result['goods_total']) ? $result['goods_total'] : 0; // 商品总价
        $orderTotal = isset($result['order_total']) ? $result['order_total'] : 0; // 订单结算金额（折后）
        $bdScoreTotal = isset($result['bd_score_total']) ? $result['bd_score_total'] : 0; // 报单积分
        $profitTotal = isset($result['profit_total']) ? $result['profit_total'] : 0; // 利润
        $discountTotal = isset($result['discount_total']) ? $result['discount_total'] : 0; // 折扣金额
        $orderCount = isset($result['count']) ? $result['count'] : 0;
        $deliveryFee = isset($result['delivery_fee']) ? $result['delivery_fee'] : 0; // 运费
        $storeId = isset($result['store_id']) ? $result['store_id'] : 0; // 企业/商家
        if (empty($orderGoods)) {
            RedisService::clear($cacheLockKey);
            $this->error = '获取订单商品错误～';
            return false;
        }

        if ($orderTotal <= 0) {
            RedisService::clear($cacheLockKey);
            $this->error = '订单金额错误～';
            return false;
        }

        if ($orderCount <= 0) {
            RedisService::clear($cacheLockKey);
            $this->error = '订单商品数量错误～';
            return false;
        }

        // 创业大礼包
        $mealId = 0;
        if ($type == 2) {
            $mealId = isset($ids[0]) ? $ids[0] : 0;
            if ($buyType != $mealId) {
                RedisService::clear($cacheLockKey);
                $this->error = '该礼包您暂时不满足购买条件';
                return false;
            }

            // 报单积分是否够
            if ($bdScore < $bdScoreTotal) {
                RedisService::clear($cacheLockKey);
                $this->error = '抱歉，您的报单积分不足';
                return false;
            }

            // 是否购买过
            $buyLimit = ConfigService::make()->getConfigByCode('business_buy_limit', 0);
            $buyLimit = $buyLimit>0?$buyLimit:0;
            if($buyLimit>0){
                $checkOrderCount = $this->checkBusinessOrder($userId, $mealId);
                if ($checkOrderCount >= $buyLimit) {
                    RedisService::clear($cacheLockKey);
                    $this->error = $buyLimit>1?"抱歉该创业礼包仅限购买{$buyLimit}次":'抱歉，您已经购买过该礼包';
                    return false;
                }
            }

        }

        // 收货地址信息
        $addressInfo = MemberAddressService::make()->getBindInfo($userId, $addressId);
        $realname = isset($addressInfo['realname']) ? $addressInfo['realname'] : '';
        $mobile = isset($addressInfo['mobile']) ? $addressInfo['mobile'] : '';
        $area = isset($addressInfo['area']) ? $addressInfo['area'] : '';
        $address = isset($addressInfo['address']) ? $addressInfo['address'] : '';
        if (empty($addressInfo) || empty($realname) || empty($mobile) || empty($area) || empty($address)) {
            RedisService::clear($cacheLockKey);
            $this->error = '收货地址信息错误，请核对后重试～';
            return false;
        }

        // 是否开启分账功能
        $payTotal = moneyFormat($orderTotal + $deliveryFee, 2); // 含运费支付金额
        if (env('PAY_DEBUG')) {
            $payTotal = 0.01;
        }

        // 订单数据
        $order = [
            'order_no' => $orderNo,
            'user_id' => $userId,
            'store_id' => $storeId,
            'meal_id' => $mealId,
            'type' => $type,
            'total' => $goodsTotal, // 商品总价
            'num' => $orderCount,
            'bd_score' => $bdScoreTotal, // 折扣后商品总价（不含运费）
            'profit_total' => $profitTotal, // 折扣后商品总价（不含运费）
            'pay_money' => $orderTotal, // 折扣后商品总价（不含运费）
            'pay_total' => $type==2 && $bdScoreTotal>0?moneyFormat($orderTotal + $bdScoreTotal,2):$orderTotal, // 折扣后商品总价（不含运费）
            'pay_status' => $type==2 && $bdScoreTotal>0? 30 : 10, // 折扣后商品总价（不含运费）
            'discount_point' => $discountPoint,
            'discount_total' => $discountTotal, // 折扣金额
            'delivery_fee' => $deliveryFee, // 运费
            'receiver_name' => $realname,
            'receiver_mobile' => $mobile,
            'receiver_area' => $area,
            'receiver_address' => $address,
            'create_time' => time(),
            'update_time' => time(),
            'status' => 1,
            'mark' => 1,
        ];

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

        // 订单商品
        if ($orderGoods && !OrderGoodsModel::insert($orderGoods)) {
            DB::rollBack();
            $this->error = '处理订单商品错误';
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 创业礼包分单
        if ($type == 2) {
            $data = $order;
            $data['total'] = moneyFormat($data['total'] / 6);
            $data['bd_score'] = moneyFormat($bdScoreTotal / 6, 2);
            $data['profit_total'] = moneyFormat($profitTotal / 6, 2);
            $data['pay_total'] = moneyFormat($orderTotal / 6, 2);
            $data['pay_money'] = moneyFormat($order['pay_money'] / 6, 2);

            $subOrders = [];
            for ($i = 1; $i <= 6; $i++) {
                $data['order_no'] = get_order_num('BS');
                $data['main_no'] = $orderNo;
                if ($i == 6) {
                    $data['total'] = round($order['total'] / 6, 2);
                    $data['bd_score'] = round($bdScoreTotal / 6, 2);
                    $data['profit_total'] = round($profitTotal / 6, 2);
                    $data['pay_total'] = round($orderTotal / 6, 2);
                    $data['pay_money'] = round($order['pay_money'] / 6, 2);
                }

                $subOrders[] = $data;
            }

            //
            if ($subOrders && !$this->model->insert($subOrders)) {
                DB::rollBack();
                $this->error = '处理商品订单失败';
                RedisService::clear($cacheLockKey);
                return false;
            }

            // 扣除报单积分
            if($bdScoreTotal>0){
                if(!MemberModel::where(['id'=>$userId])->update(['bd_score'=>DB::raw("bd_score - {$bdScoreTotal}"),'update_time'=>time()])){
                    DB::rollBack();
                    $this->error = '报单积分扣除失败';
                    RedisService::clear($cacheLockKey);
                    return false;
                }

                $data = [
                    'user_id'=>$userId,
                    'source_order_no'=>$orderNo,
                    'user_type'=> 1,
                    'account_type'=> 3, // 报单积分
                    'type'=> 1,
                    'money'=> -$bdScoreTotal,
                    'after_money'=>moneyFormat($bdScore - $bdScoreTotal,2),
                    'date'=>date('Y-m-d'),
                    'create_time'=>time(),
                    'remark'=> '创业礼包支付',
                    'status'=>1,
                    'mark'=>1
                ];
                if(!AccountLogModel::insertGetId($data)){
                    Db::rollBack();
                    $this->error = '付款处理失败';
                    return false;
                }
            }
        }

        // 佣金数据
        $order['id'] = $orderId;
        if(!$commission = SettleService::make()->commissionCount($order,$orderGoods,$userInfo, $type)){
            Db::rollBack();
            $this->error = '订单处理失败';
            return false;
        }

        // 获取支付参数
        /* TODO 支付处理 */
        $payOrder = [
            'type' => 1,
            'order_no' => $orderNo,
            'is_revenue' => isset($order['is_revenue'])?$order['is_revenue']:2,
            'pay_money' => $payTotal,
            'body' => '订单付款',
            'openid' => $openid
        ];

        // 调起支付
        $payment = PaymentService::make()->minPay($userInfo, $payOrder, 'store');
        if (empty($payment)) {
            //DB::rollBack();
            RedisService::clear($cacheLockKey);
            $this->error = PaymentService::make()->getError();
            return false;
        }

        // 商品库存扣除
        if ($orderGoods) {
            foreach ($orderGoods as $item) {
                $id = isset($item['goods_id']) ? $item['goods_id'] : 0;
                $num = isset($item['num']) ? $item['num'] : 0;
                $skuId = isset($item['sku_id']) ? $item['sku_id'] : 0;
                if ($id && !GoodsModel::where(['id' => $id])->update(['stock' => DB::raw("stock - {$num}"), 'update_time' => time()])) {
                    DB::rollBack();
                    RedisService::clear($cacheLockKey);
                    $this->error = '商品库存处理失败';
                    return false;
                }

                if ($skuId && !GoodsSkuModel::where(['id' => $skuId])->update(['stock' => DB::raw("stock - {$num}"), 'update_time' => time()])) {
                    DB::rollBack();
                    RedisService::clear($cacheLockKey);
                    $this->error = '商品库存处理失败';
                    return false;
                }
            }

            // 清空购物车结算商品
            if($submitType == 'cart'){
                $skuIds = $goods ? array_column($goods, 'sku_id') : [];
                CartModel::whereIn('goods_id',$ids)->whereIn('sku_id',$skuIds)->where(['user_id'=>$userId,'mark'=>1])->update(['mark'=>0,'num'=>0,'update_time'=>time()]);
                RedisService::clear("caches:goods:cartCount:{$userId}");
            }
        }

        // 用户操作记录
        DB::commit();
        $this->error = '订单创建成功，请前往支付～';
        RedisService::clear($cacheLockKey);
        return [
            'order_id' => $orderId,
            'payment' => $payment,
            'total' => $payOrder['pay_money'],
            'pay_type' => 10,
        ];
    }

    /**
     * 自动复购
     * @param $userId 用户
     * @param $mealId 套餐ID
     * @return array|false
     */
    public function replyBuy($userId, $mealId)
    {
        $type = isset($params['type']) && $params['type'] ? $params['type'] : 1;
        $goods = ["id_{$mealId}"=>['id'=>$mealId,'sku_id'=>0,'num'=>1]];
        $ids = [$mealId];

        // 缓存锁
        $cacheLockKey = "caches:orders:submit_lock:{$userId}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = '订单处理中～';
            return false;
        }

        // 用户信息
        RedisService::set($cacheLockKey, ['params' => $params, 'user_id' => $userId], rand(3, 5));
        $userInfo = MemberModel::where(['id' => $userId, 'mark' => 1])
            ->select(['id', 'openid','nickname','member_level','parent_id','point_id','points', 'buy_type','property','balance', 'bd_score', 'status'])
            ->first();
        $status = isset($userInfo['status']) ? $userInfo['status'] : 0;
        $openid = isset($userInfo['openid']) ? $userInfo['openid'] : 0;
        $bdScore = isset($userInfo['bd_score']) ? $userInfo['bd_score'] : 0;
        $balance = isset($userInfo['balance']) ? $userInfo['balance'] : 0;
        $discountPoint = isset($userInfo['discount_point']) ? $userInfo['discount_point'] : 0; // 折扣
        if (empty($userInfo) || $status != 1) {
            $this->error = 1045;
            return false;
        }

        if (empty($openid)) {
            $this->error = 1042;
            return false;
        }

        // 商品数据
        $orderNo = get_order_num('JK');
        $result = GoodsService::make()->getOrderGoods($ids, $goods, $userId, $orderNo, $discountPoint);
        if (empty($result)) {
            RedisService::clear($cacheLockKey);
            $this->error = GoodsService::make()->getError();
            return false;
        }

        $orderGoods = isset($result['goods']) ? $result['goods'] : [];
        $goodsTotal = isset($result['goods_total']) ? $result['goods_total'] : 0; // 商品总价
        $orderTotal = isset($result['order_total']) ? $result['order_total'] : 0; // 订单结算金额（折后）
        $bdScoreTotal = isset($result['bd_score_total']) ? $result['bd_score_total'] : 0; // 报单积分
        $profitTotal = isset($result['profit_total']) ? $result['profit_total'] : 0; // 利润
        $discountTotal = isset($result['discount_total']) ? $result['discount_total'] : 0; // 折扣金额
        $orderCount = isset($result['count']) ? $result['count'] : 0;
        $deliveryFee = isset($result['delivery_fee']) ? $result['delivery_fee'] : 0; // 运费
        $storeId = isset($result['store_id']) ? $result['store_id'] : 0; // 企业/商家
        if (empty($orderGoods)) {
            RedisService::clear($cacheLockKey);
            $this->error = '获取订单商品错误～';
            return false;
        }

        if ($orderTotal <= 0) {
            RedisService::clear($cacheLockKey);
            $this->error = '订单金额错误～';
            return false;
        }

        if ($orderCount <= 0) {
            RedisService::clear($cacheLockKey);
            $this->error = '订单商品数量错误～';
            return false;
        }

        // 报单积分是否够
        if ($bdScore < $bdScoreTotal) {
            RedisService::clear($cacheLockKey);
            $this->error = '抱歉，您的报单积分不足';
            return false;
        }

        // 是否购买过
        $buyLimit = ConfigService::make()->getConfigByCode('business_buy_limit', 0);
        $buyLimit = $buyLimit>0?$buyLimit:0;
        if($buyLimit>0){
            $checkOrderCount = $this->checkBusinessOrder($userId, $mealId);
            if ($checkOrderCount >= $buyLimit) {
                RedisService::clear($cacheLockKey);
                $this->error = $buyLimit>1?"抱歉该创业礼包仅限购买{$buyLimit}次":'抱歉，您已经购买过该礼包';
                return false;
            }
        }

        // 收货地址信息
        $addressInfo = MemberAddressService::make()->getBindInfo($userId);
        $realname = isset($addressInfo['realname']) ? $addressInfo['realname'] : '';
        $mobile = isset($addressInfo['mobile']) ? $addressInfo['mobile'] : '';
        $area = isset($addressInfo['area']) ? $addressInfo['area'] : '';
        $address = isset($addressInfo['address']) ? $addressInfo['address'] : '';
        if (empty($addressInfo) || empty($realname) || empty($mobile) || empty($area) || empty($address)) {
            RedisService::clear($cacheLockKey);
            $this->error = '收货地址信息错误，请核对后重试～';
            return false;
        }

        // 是否开启分账功能
        $payTotal = moneyFormat($orderTotal + $deliveryFee, 2); // 含运费支付金额
        if($balance < $payTotal){
            RedisService::clear($cacheLockKey);
            $this->error = "自动复购失败，您的余额不足";
            return false;
        }

        // 订单数据
        $order = [
            'order_no' => $orderNo,
            'user_id' => $userId,
            'store_id' => $storeId,
            'meal_id' => $mealId,
            'type' => $type,
            'total' => $goodsTotal, // 商品总价
            'num' => $orderCount,
            'bd_score' => $bdScoreTotal, // 折扣后商品总价（不含运费）
            'profit_total' => $profitTotal, // 折扣后商品总价（不含运费）
            'pay_money' => $orderTotal, // 折扣后商品总价（不含运费）
            'pay_total' => $type==2 && $bdScoreTotal>0?moneyFormat($orderTotal + $bdScoreTotal,2):$orderTotal, // 折扣后商品总价（不含运费）
            'pay_status' => $type==2 && $bdScoreTotal>0? 30 : 10, // 折扣后商品总价（不含运费）
            'discount_point' => $discountPoint,
            'discount_total' => $discountTotal, // 折扣金额
            'delivery_fee' => $deliveryFee, // 运费
            'receiver_name' => $realname,
            'receiver_mobile' => $mobile,
            'receiver_area' => $area,
            'receiver_address' => $address,
            'create_time' => time(),
            'update_time' => time(),
            'status' => 1,
            'mark' => 1,
        ];

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

        // 订单商品
        if ($orderGoods && !OrderGoodsModel::insert($orderGoods)) {
            DB::rollBack();
            $this->error = '处理订单商品错误';
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 创业礼包分单
        $data = $order;
        $data['total'] = moneyFormat($data['total'] / 6);
        $data['bd_score'] = moneyFormat($bdScoreTotal / 6, 2);
        $data['profit_total'] = moneyFormat($profitTotal / 6, 2);
        $data['pay_total'] = moneyFormat($orderTotal / 6, 2);
        $data['pay_money'] = moneyFormat($order['pay_money'] / 6, 2);

        $subOrders = [];
        for ($i = 1; $i <= 6; $i++) {
            $data['order_no'] = get_order_num('BS');
            $data['main_no'] = $orderNo;
            if ($i == 6) {
                $data['total'] = round($order['total'] / 6, 2);
                $data['bd_score'] = round($bdScoreTotal / 6, 2);
                $data['profit_total'] = round($profitTotal / 6, 2);
                $data['pay_total'] = round($orderTotal / 6, 2);
                $data['pay_money'] = round($order['pay_money'] / 6, 2);
            }

            $subOrders[] = $data;
        }

        //
        if ($subOrders && !$this->model->insert($subOrders)) {
            DB::rollBack();
            $this->error = '处理商品订单失败';
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 扣除报单积分
        if($bdScoreTotal>0){
            if(!MemberModel::where(['id'=>$userId])->update(['bd_score'=>DB::raw("bd_score - {$bdScoreTotal}"),'update_time'=>time()])){
                DB::rollBack();
                $this->error = '报单积分扣除失败';
                RedisService::clear($cacheLockKey);
                return false;
            }

            $data = [
                'user_id'=>$userId,
                'source_order_no'=>$orderNo,
                'user_type'=> 1,
                'account_type'=> 3, // 报单积分
                'type'=> 1,
                'money'=> -$bdScoreTotal,
                'after_money'=>moneyFormat($bdScore - $bdScoreTotal,2),
                'date'=>date('Y-m-d'),
                'create_time'=>time(),
                'remark'=> '创业礼包支付',
                'status'=>1,
                'mark'=>1
            ];
            if(!AccountLogModel::insertGetId($data)){
                Db::rollBack();
                $this->error = '付款处理失败';
                return false;
            }
        }

        // 余额支付
        if(!MemberModel::where(['id'=>$userId])->update(['balance'=>DB::raw("balance - {$payTotal}"),'update_time'=>time()])){
            DB::rollBack();
            $this->error = '余额支付失败';
            RedisService::clear($cacheLockKey);
            return false;
        }

        $data = [
            'user_id'=>$userId,
            'source_order_no'=>$orderNo,
            'user_type'=> 1,
            'account_type'=> 1, // 余额支付
            'type'=> 1,
            'money'=> -$payTotal,
            'after_money'=>moneyFormat($balance - $payTotal,2),
            'date'=>date('Y-m-d'),
            'create_time'=>time(),
            'remark'=> '创业礼包自动复购支付',
            'status'=>1,
            'mark'=>1
        ];
        if(!AccountLogModel::insertGetId($data)){
            Db::rollBack();
            $this->error = '自动复购付款处理失败';
            return false;
        }


        // 佣金数据
        $order['id'] = $orderId;
        if(!$commission = SettleService::make()->commissionCount($order,$orderGoods,$userInfo, $type)){
            Db::rollBack();
            $this->error = '订单结算处理失败';
            return false;
        }

        // 结算
        if(!$settle = SettleService::make()->commissionSettle($orderId)){
            Db::rollBack();
            $this->error = '订单结算处理失败';
            return false;
        }

        // 商品库存扣除
        if ($orderGoods) {
            foreach ($orderGoods as $item) {
                $id = isset($item['goods_id']) ? $item['goods_id'] : 0;
                $num = isset($item['num']) ? $item['num'] : 0;
                $skuId = isset($item['sku_id']) ? $item['sku_id'] : 0;
                if ($id && !GoodsModel::where(['id' => $id])->update(['stock' => DB::raw("stock - {$num}"), 'update_time' => time()])) {
                    DB::rollBack();
                    RedisService::clear($cacheLockKey);
                    $this->error = '商品库存处理失败';
                    return false;
                }

                if ($skuId && !GoodsSkuModel::where(['id' => $skuId])->update(['stock' => DB::raw("stock - {$num}"), 'update_time' => time()])) {
                    DB::rollBack();
                    RedisService::clear($cacheLockKey);
                    $this->error = '商品库存处理失败';
                    return false;
                }
            }
        }

        // 用户操作记录
        DB::commit();
        $this->error = '自动复购成功～';
        RedisService::clear($cacheLockKey);
        return [
            'order_id' => $orderId,
            'total' => $payTotal,
            'pay_type' => 10,
        ];
    }

    /**
     * 创业大礼包验证
     * @param $userId
     * @param $goodsId
     * @return array|mixed
     */
    public function checkBusinessOrder($userId, $goodsId)
    {
        $cacheKey = "caches:orders:check_order:{$userId}_{$goodsId}";
        $data = RedisService::get($cacheKey);
        if ($data) {
            return $data;
        }

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

        return $data;
    }

    /**
     * 订单支付
     * @param $userId
     * @param $id
     * @return array|false
     */
    public function pay($userId, $id)
    {
        if ($id <= 0) {
            $this->error = '请选择支付订单';
            return false;
        }

        // 缓存锁
        $cacheLockKey = "caches:orders:pay_lock:{$userId}_{$id}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = '订单处理中～';
            return false;
        }

        // 商品数据
        RedisService::set($cacheLockKey, ['order_id' => $id, 'user_id' => $userId], rand(3, 5));

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

        if (empty($openid)) {
            $this->error = '用户微信未授权，请重新授权登录';
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 订单信息
        $info = $this->model->where(['id' => $id, 'mark' => 1])
            ->select(['id', 'order_no', 'pay_total', 'delivery_fee', 'status'])
            ->first();
        $orderTotal = isset($info['pay_total']) ? $info['pay_total'] : 0;
        $deliveryFee = isset($info['delivery_fee']) ? $info['delivery_fee'] : 0;
        $orderNo = isset($info['order_no']) ? $info['order_no'] : '';
        $status = isset($info['status']) ? $info['status'] : 0;
        if (empty($info) || empty($orderNo)) {
            $this->error = '订单信息不存在';
            RedisService::clear($cacheLockKey);
            return false;
        }

        if ($status != 1) {
            $this->error = '订单已支付';
            RedisService::clear($cacheLockKey);
            return false;
        }

        $payTotal = moneyFormat($orderTotal + $deliveryFee);
        if (env('PAY_DEBUG')) {
            $payTotal = 0.01;
        }

        // 获取支付参数
        /* TODO 支付处理 */
        $payOrder = [
            'type' => 1,
            'order_no' => $orderNo,
            'pay_money' => $payTotal,
            'body' => '购物消费',
            'openid' => $openid
        ];

        // 调起支付
        $payment = PaymentService::make()->minPay($userInfo, $payOrder, 'store');
        if (empty($payment)) {
            DB::rollBack();
            RedisService::clear($cacheLockKey);
            $this->error = PaymentService::make()->getError();
            return false;
        }

        // 用户操作记录
        DB::commit();
        $this->error = '支付请求成功，请前往支付～';
        RedisService::clear($cacheLockKey);
        return [
            'order_id' => $id,
            'payment' => $payment,
            'total' => $payOrder['pay_money'],
            'pay_type' => 10,
        ];
    }

    /**
     * 订单取消
     * @param $userId
     * @param $orderId
     * @return array|false
     */
    public function cancel($userId, $orderId)
    {
        if ($orderId <= 0) {
            $this->error = '请选择订单';
            return false;
        }

        // 缓存锁
        $cacheLockKey = "caches:orders:cancel_lock:{$userId}_{$orderId}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = '订单处理中～';
            return false;
        }

        RedisService::set($cacheLockKey, ['order_id' => $orderId, 'user_id' => $userId], rand(3, 5));

        // 用户信息
        $userInfo = MemberModel::where(['id' => $userId, 'mark' => 1])
            ->select(['id', 'openid', 'mobile', 'nickname', 'realname','bd_score', 'balance', 'status'])
            ->first();
        $status = isset($userInfo['status']) ? $userInfo['status'] : 0;
        $bdScore = isset($userInfo['bd_score']) ? $userInfo['bd_score'] : 0;
        if (empty($userInfo) || $status != 1) {
            $this->error = 1045;
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 订单信息
        $info = $this->model->where(['id' => $orderId, 'mark' => 1])
            ->select(['id', 'order_no', 'pay_total', 'status'])
            ->first();
        $orderNo = isset($info['order_no']) ? $info['order_no'] : '';
        $status = isset($info['status']) ? $info['status'] : 0;
        $bdScoreTotal = isset($info['bd_score']) ? $info['bd_score'] : 0;
        if (empty($info) || empty($orderNo)) {
            $this->error = '订单信息不存在';
            RedisService::clear($cacheLockKey);
            return false;
        }

        if ($status != 1) {
            $this->error = '订单已支付';
            RedisService::clear($cacheLockKey);
            return false;
        }
        $orderGoods = OrderGoodsModel::where(['order_no' => $orderNo, 'mark' => 1])
            ->select(['goods_id', 'num', 'sku_id'])
            ->get();
        DB::beginTransaction();
        if ($orderGoods) {
            foreach ($orderGoods as $goods) {
                $goodsId = isset($goods['goods_id']) ? $goods['goods_id'] : 0;
                $num = isset($goods['num']) ? $goods['num'] : 0;
                $skuId = isset($goods['sku_id']) ? $goods['sku_id'] : 0;
                if ($goodsId) {
                    GoodsModel::where(['id' => $goodsId])->update(['stock' => DB::raw("stock + {$num}"), 'update_time' => time()]);
                }

                if ($skuId) {
                    GoodsSkuModel::where(['id' => $skuId])->update(['stock' => DB::raw("stock + {$num}"), 'update_time' => time()]);
                }
            }
        }

        // 退还报单积分
        if($bdScoreTotal>0){
            if(!MemberModel::where(['id'=>$userId])->update(['bd_score'=>DB::raw("bd_score + {$bdScoreTotal}"),'update_time'=>time()])){
                DB::rollBack();
                $this->error = '报单积分退还失败';
                RedisService::clear($cacheLockKey);
                return false;
            }

            $data = [
                'user_id'=>$userId,
                'source_order_no'=>$orderNo,
                'user_type'=> 1,
                'account_type'=> 3, // 报单积分
                'type'=> 3,
                'money'=> $bdScoreTotal,
                'after_money'=>moneyFormat($bdScore + $bdScoreTotal,2),
                'date'=>date('Y-m-d'),
                'create_time'=>time(),
                'remark'=> '创业礼包订单取消',
                'status'=>1,
                'mark'=>1
            ];
            if(!AccountLogModel::insertGetId($data)){
                Db::rollBack();
                $this->error = '订单取消处理失败';
                return false;
            }
        }


        $this->error = '取消订单成功';
        $this->model->where(['user_id' => $userId, 'mark' => 0])->where('update_time', '<=', time() - 300)->delete();
        OrderGoodsModel::where(['order_no' => $orderNo, 'mark' => 0])->where('update_time', '<=', time() - 300)->delete();
        $this->model->where(['id' => $orderId])->update(['mark' => 0, 'update_time' => time()]);
        OrderGoodsModel::where(['order_no' => $orderNo])->update(['mark' => 0, 'update_time' => time()]);
        DB::commit();
        return ['id' => $orderId];
    }

    /**
     * 订单删除隐藏
     * @param $userId
     * @param $orderId
     * @return array|false
     */
    public function hide($userId, $orderId)
    {
        if ($orderId <= 0) {
            $this->error = '请选择订单';
            return false;
        }

        // 缓存锁
        $cacheLockKey = "caches:orders:hide_lock:{$userId}_{$orderId}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = '订单删除中～';
            return false;
        }

        RedisService::set($cacheLockKey, ['order_id' => $orderId, 'user_id' => $userId], rand(3, 5));

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

        // 订单信息
        $info = $this->model->where(['id' => $orderId, 'mark' => 1])
            ->select(['id', 'order_no', 'pay_total', 'status'])
            ->first();
        $orderNo = isset($info['order_no']) ? $info['order_no'] : '';
        $status = isset($info['status']) ? $info['status'] : 0;
        if (empty($info) || empty($orderNo)) {
            $this->error = '订单信息不存在';
            RedisService::clear($cacheLockKey);
            return false;
        }

        if ($status != 4) {
            $this->error = '订单未完成';
            RedisService::clear($cacheLockKey);
            return false;
        }

        $this->error = '删除订单成功';
        $this->model->where(['id' => $orderId])->update(['is_hide' => 1, 'update_time' => time()]);
        return ['id' => $orderId];
    }

    /**
     * 订单完成
     * @param $userId 订单用户ID
     * @param $id 订单ID
     * @return array|false
     */
    public function complete($userId, $id, $check = true)
    {
        if ($id <= 0) {
            $this->error = '请选择订单';
            return false;
        }

        // 缓存锁
        $cacheLockKey = "caches:orders:complete_lock:{$userId}_{$id}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = '订单处理中～';
            return false;
        }

        // 商品数据
        RedisService::set($cacheLockKey, ['order_id' => $id, 'user_id' => $userId], rand(3, 5));

        // 用户信息
        $userInfo = MemberModel::where(['id' => $userId, 'mark' => 1])
            ->select(['id', 'openid', 'mobile', 'parent_id', 'nickname', 'realname', 'balance', 'status'])
            ->first();
        $status = isset($userInfo['status']) ? $userInfo['status'] : 0;
        $parentId = isset($userInfo['parent_id']) ? $userInfo['parent_id'] : 0;
        if ($check && (empty($userInfo) || $status != 1)) {
            $this->error = 1045;
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 订单信息
        $info = $this->model->with(['orderGoods','commission'])->where(['id' => $id, 'mark' => 1])
            ->select(['id', 'order_no','type', 'user_id', 'store_id', 'total', 'pay_total', 'delivery_no', 'delivery_company', 'delivery_code', 'status'])
            ->first();
        $orderNo = isset($info['order_no']) ? $info['order_no'] : '';
        $deliveryNo = isset($info['delivery_no']) ? $info['delivery_no'] : '';
        $deliverCompany = isset($info['delivery_company']) ? $info['delivery_company'] : '';
        $orderUserId = isset($info['user_id']) ? $info['user_id'] : 0;
        $storeId = isset($info['store_id']) ? $info['store_id'] : 0;
        $orderType = isset($info['type']) ? $info['type'] : 0;
        $orderTotal = isset($info['total']) ? $info['total'] : 0;
        $status = isset($info['status']) ? $info['status'] : 0;
        $commission = isset($info['commission']) ? $info['commission'] : [];
        $bonus = isset($commission['bonus'])?$commission['bonus'] : 0;
        $orderGoods = isset($info['order_goods']) ? $info['order_goods'] : [];
        if (empty($info) || empty($orderNo)) {
            $this->error = '订单信息不存在';
            RedisService::clear($cacheLockKey);
            return false;
        }

        if ($status != 3) {
            $this->error = '订单未发货';
            RedisService::clear($cacheLockKey);
            return false;
        }


        if (empty($deliveryNo) || empty($deliverCompany)) {
            $this->error = '订单发货信息错误，请联系客服';
            $this->model->where(['id' => $id])->update(['is_complete' => 1, 'complete_remark' => $this->error]);
            RedisService::clear("caches:orders:completeList");
            RedisService::clear($cacheLockKey);
            return false;
        }

        DB::beginTransaction();
        $completeStatus = env('ORDER_COMPLETE_STATUS', 5);
        $updateData = ['status' => $completeStatus, 'complete_at' => date('Y-m-d H:i:s'), 'update_time' => time()];
        if (!$check) {
            $updateData['is_complete'] = 1;
            $updateData['complete_remark'] = '自动收货';
        }
        $this->model->where(['id' => $id])->update($updateData);

        // 商家订单数据统计
        $updateData = ['order_count' => DB::raw('order_count+1'), 'order_total' => DB::raw("order_total + {$orderTotal}")];
        StoreModel::where(['id' => $storeId])->update($updateData);

        // 商品销量数据
        if ($orderGoods) {
            $counts = [];
            foreach ($orderGoods as $item) {
                $counts[$item['goods_id']] = isset($counts[$item['goods_id']]) ? $counts[$item['goods_id']] : 0;
                $counts[$item['goods_id']] += $item['num'];
            }

            if ($counts) {
                foreach ($counts as $id => $v) {
                    GoodsModel::where(['id' => $id])->update(['sales' => DB::raw("sales + {$v}"), 'update_time' => time()]);
                }
            }
        }

        // 商城订单结算
        if($orderType == 1){
            SettleService::make()->commissionSettle($id);
        }

        DB::commit();
        $this->error = '确认收货成功';
        RedisService::clear("caches:orders:completeList");
        RedisService::clear("caches:orders:revenueList");
        return ['id' => $id, 'msg' => $this->error];
    }

    /**
     * 售后或退款
     * @param $userId
     * @param $params
     * @return array|false
     */
    public function after($userId, $params)
    {
        $id = isset($params['id']) ? $params['id'] : 0;
        $afterType = isset($params['after_type']) ? $params['after_type'] : 1;
        if ($id <= 0) {
            $this->error = '请选择订单';
            return false;
        }

        // 缓存锁
        $cacheLockKey = "caches:orders:after_lock:{$userId}_{$id}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = '订单处理中～';
            return false;
        }

        // 商品数据
        RedisService::set($cacheLockKey, ['params' => $params, 'user_id' => $userId], rand(3, 5));

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

        // 订单信息
        $info = $this->model->where(['id' => $id, 'mark' => 1])
            ->select(['id', 'order_no', 'after_type', 'refund_status', 'pay_total', 'status'])
            ->first();
        $orderNo = isset($info['order_no']) ? $info['order_no'] : '';
        $status = isset($info['status']) ? $info['status'] : 0;
        $refundStatus = isset($info['refund_status']) ? $info['refund_status'] : 0;
        if (empty($info) || empty($orderNo)) {
            $this->error = '订单信息不存在';
            RedisService::clear($cacheLockKey);
            return false;
        }

        if ($status == 1) {
            $this->error = '订单未支付';
            RedisService::clear($cacheLockKey);
            return false;
        }

        if ($status == 4 && $afterType == 2) {
            $this->error = '订单已完成';
            RedisService::clear($cacheLockKey);
            return false;
        }

        if ($refundStatus > 0 && $refundStatus != 4) {
            $this->error = '订单售后处理中';
            RedisService::clear($cacheLockKey);
            return false;
        }


        $afterRealname = isset($params['after_realname']) ? $params['after_realname'] : '';
        $afterPhone = isset($params['after_phone']) ? $params['after_phone'] : '';
        $afterRemark = isset($params['after_remark']) ? $params['after_remark'] : '';
        if ($afterType == 1) {
            if (empty($afterRealname) || empty($afterPhone) || empty($afterRemark)) {
                $this->error = '请填写售后信息';
                RedisService::clear($cacheLockKey);
                return false;
            }
        }

        $data = [
            'after_type' => $afterType,
            'after_realname' => $afterRealname,
            'after_phone' => $afterPhone,
            'after_remark' => $afterRemark,
            'refund_remark' => isset($params['refund_remark']) ? $params['refund_remark'] : '',
            'refund_status' => 3,
            'update_time' => time()
        ];
        $this->model->where(['id' => $id])->update($data);

        $this->error = '订单申请售后成功';
        return ['id' => $id];
    }

    /**
     * 物流查询
     * @param $id
     * @return array|false|mixed
     */
    public function getDelivery($id)
    {
        $info = $this->model->where(['id' => $id, 'mark' => 1])->first();
        $deliveryNo = isset($info['delivery_no']) ? $info['delivery_no'] : '';
        $deliveryCode = isset($info['delivery_code']) ? $info['delivery_code'] : '';
        $mobile = isset($info['receiver_mobile']) ? $info['receiver_mobile'] : '';
        $receiverArea = isset($info['receiver_area']) && $info['receiver_area'] ? $info['receiver_area'] : '';
        if (empty($info)) {
            $this->error = '请选择订单';
            return false;
        }

        $cacheKey = "caches:kd100:order_{$id}";
        $data = RedisService::get($cacheKey);
        if ($data) {
            return $data;
        }
        $result = Kd100Service::make()->query($deliveryNo, $mobile, $deliveryCode, $receiverArea);
        RedisService::set($cacheKey . '_result', $result, 300);
        $status = isset($result['status']) ? $result['status'] : 0;
        $data = isset($result['data']) ? $result['data'] : [];
        $courierInfo = isset($result['courierInfo']) ? $result['courierInfo'] : [];
        $arrivalTime = isset($result['arrivalTime']) ? $result['arrivalTime'] : '';
        $predictedRoute = isset($result['predictedRoute']) ? $result['predictedRoute'] : [];
        $predictedData = $predictedRoute ? end($predictedRoute) : [];
        $arrivalData = [];
        if ($arrivalTime) {
            $arrivalData['arrivalTime'] = dayFormat(strtotime($arrivalTime . ':00:00'));
            $arrivalData['predictedData'] = $predictedData;
        }

        if ($courierInfo && $courierInfo['deliveryManPhone']) {
            $courierInfo['deliveryManPhone'] = explode(',', $courierInfo['deliveryManPhone']);
            $courierInfo['deliveryPhone'] = $courierInfo['deliveryManPhone'][1] ? $courierInfo['deliveryManPhone'][1] : $courierInfo['deliveryManPhone'][0];
        }

        if ($data && $status == 200) {
            RedisService::set($cacheKey, ['info' => $courierInfo, 'arrivalData' => $arrivalData, 'list' => $data], 1200);
        }

        return $data ? ['info' => $courierInfo, 'arrivalData' => $arrivalData, 'list' => $data] : [];

    }

    /**
     * 已发货待完成订单
     * @return array|mixed
     */
    public function getCompleteOrders()
    {
        $cacheKey = "caches:orders:completeList";
        $datas = RedisService::get($cacheKey);
        if ($datas) {
            return $datas;
        }

        $completeDay = ConfigService::make()->getConfigByCode('order_complete_day', 7);
        $limitNum = ConfigService::make()->getConfigByCode('order_complete_batch_num', 300);
        $limitNum = $limitNum > 10 && $limitNum < 2000 ? $limitNum : 300;
        $completeDay = $completeDay >= 1 && $completeDay < 30 ? $completeDay : 7;
        $datas = $this->model->where(['status' => 3, 'is_complete' => 2, 'mark' => 1])
            ->whereNotNull('delivery_no')
            ->select(['id', 'user_id', 'order_no', 'status'])
            ->where('pay_at', '<=', date('Y-m-d H:i:s', time() - $completeDay * 86400))
            ->limit($limitNum)
            ->get();
        $datas = $datas ? $datas->toArray() : [];
        if ($datas) {
            RedisService::set($cacheKey, $datas, rand(300, 600));
        }

        return $datas;
    }

    /**
     * 已完成，待分账订单
     * @return array|mixed
     */
    public function getRevenueOrderList()
    {
        $cacheKey = "caches:orders:revenueList";
        $datas = RedisService::get($cacheKey);
        if ($datas) {
            return $datas;
        }

        $limitNum = ConfigService::make()->getConfigByCode('order_revenue_batch_num', 300);
        $limitNum = $limitNum > 10 && $limitNum < 2000 ? $limitNum : 300;
        $datas = $this->model->where(['status' => 4, 'is_revenue' => 1, 'revenue_status' => 2, 'mark' => 1])
            ->select(['id', 'user_id', 'pay_total', 'order_no', 'revenue_no', 'transaction_id', 'status'])
            ->limit($limitNum)
            ->get();
        $datas = $datas ? $datas->toArray() : [];
        if ($datas) {
            RedisService::set($cacheKey, $datas, rand(300, 600));
        }

        return $datas;
    }

    /**
     * 订单分账处理
     * @param $id
     * @return false
     * @throws \Yansongda\Pay\Exception\ContainerException
     * @throws \Yansongda\Pay\Exception\InvalidParamsException
     */
    public function revenue($id)
    {
        if ($id <= 0) {
            $this->error = '订单参数错误';
            return false;
        }

        // 缓存锁
        $cacheLockKey = "caches:orders:revenue_lock:{$id}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = '订单分账处理中～';
            return false;
        }

        // 是否设置分账账户
        $revenueOpenid = ConfigService::make()->getConfigByCode('order_revenue_openid', '');
        if (empty($revenueOpenid)) {
            $this->error = '订单分账账户未配置';
            return false;
        }

        // 订单信息
        RedisService::set($cacheLockKey, ['id' => $id, 'date' => date('Y-m-d H:i:s')], 20);
        $info = $this->model->where(['id' => $id, 'mark' => 1])
            ->select(['id', 'order_no', 'revenue_no', 'user_id', 'transaction_id', 'pay_total', 'is_revenue', 'revenue_status', 'revenue_amount', 'status'])
            ->first();
        $revenueOrderNo = isset($info['revenue_no']) ? $info['revenue_no'] : '';
        $revenueAmount = isset($info['revenue_amount']) ? $info['revenue_amount'] : 0;
        $status = isset($info['status']) ? $info['status'] : 0;
        $isRevenue = isset($info['is_revenue']) ? $info['is_revenue'] : 0;
        $revenueStatus = isset($info['revenue_status']) ? $info['revenue_status'] : 0;
        if ($status != 4) {
            RedisService::clear($cacheLockKey);
            $this->error = '订单状态错误，未完成收货的订单无法分账';
            return false;
        }

        if ($isRevenue != 1) {
            RedisService::clear($cacheLockKey);
            $this->error = '该订单不是分账订单';
            return false;
        }

        if ($revenueStatus != 2) {
            RedisService::clear($cacheLockKey);
            $this->error = '该订单分账已处理完成';
            return false;
        }

        if ($revenueAmount <= 0) {
            RedisService::clear($cacheLockKey);
            $this->error = '订单分账金额不足';
            return false;
        }
        $order = [
            'transaction_id' => $info['transaction_id'],
            'out_order_no' => $revenueOrderNo,
            'body' => '订单分账',
            'amount' => $revenueAmount,
            'unsplit' => true, // 只分一次
        ];
        $result = PaymentService::make()->profitsharing($revenueOpenid, $order);
        $state = isset($result->state) ? $result->state : 0;
        $message = isset($result->message) ? $result->message : '分账失败';
        $orderId = isset($result->order_id) ? $result->order_id : '';
        if ($state == 'FINISHED') {
            $this->model->where(['id' => $id])->update(['revenue_status' => 1, 'revenue_order_id' => $orderId, 'update_time' => time()]);
            RedisService::clear($cacheLockKey);
            RedisService::clear("caches:orders:revenueList");
            $this->error = '分账处理成功';
            return true;
        } else {
            RedisService::clear($cacheLockKey);
            $this->error = $message;
            return false;
        }
    }
}