NN2026041601/app/Services/Api/SettleService.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\CouponModel;
use App\Models\MemberCouponModel;
use App\Models\MemberModel;
use App\Models\OrderCommissionModel;
use App\Models\OrderModel;
use App\Models\PtAccountModel;
use App\Models\StoreModel;
use App\Services\BaseService;
use App\Services\Common\MemberLevelService;
use App\Services\ConfigService;
use App\Services\RedisService;
use Illuminate\Support\Facades\DB;

/**
 * 结算管理-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * @package App\Services\Api
 */
class SettleService extends BaseService
{
    /**
     * 构造函数
     * @author laravel开发员
     * @since 2020/11/11
     */
    public function __construct()
    {
        $this->model = new AccountLogModel();
    }

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

    /**
     * 商家收益结算
     * @param $storeId
     * @param $money 收益
     * @param $order 订单数据
     * @return array|false|int
     */
    public function storeBonus($storeId, $money, $order)
    {
        $orderNo = isset($order['order_no'])? $order['order_no'] : '';
        if($money<=0 && $storeId<=0){
            $this->error = '无企业佣金可结算';
            return false;
        }

        $storeInfo = StoreModel::where(['id'=> $storeId,'mark'=>1])->first();
        $balance = isset($storeInfo['bonus_total'])? $storeInfo['bonus_total'] : 0;
        $storeUserId = isset($storeInfo['user_id'])? $storeInfo['user_id'] : 0;
        if($storeUserId<=0){
            $this->error = '企业账号错误';
            return false;
        }

        if(!StoreModel::where(['id'=> $storeId])->update(['bonus_total'=>DB::raw("bonus_total + {$money}"),'update_time'=>time()])){
            $this->error = '收货错误，企业结算错误，请联系客服处理';
            return -1;
        }

        $log = [
            'user_id'=> $storeUserId,
            'store_id'=> $storeId,
            'source_order_no'=> isset($order['order_no'])? $order['order_no'] : '',
            'type'=> 7,
            'money'=> $money,
            'after_money'=> moneyFormat($balance+$money,2),
            'date'=>date('Y-m-d'),
            'create_time'=>time(),
            'remark'=> '收益',
            'status'=>1
        ];
        if(!$id = $this->model->insertGetId($log)){
            $this->error = '企业收益结算失败，请联系客服处理';
            return -1;
        }

        $result = ['id'=>$id,'store_id'=>$storeId,'bonus'=>$money];
        if(env('APP_DEBUG')){
            RedisService::set("caches:settle:{$orderNo}:store_{$storeId}", $result, 7200);
        }

        return $result;
    }

    /**
     * @param $order
     * @param int $orderType
     */
    public function commissionCount($order, $orderGoods, $userInfo, $orderType=1)
    {
        $userId = isset($order['user_id'])?$order['user_id']:0;
        $storeId = isset($order['store_id'])?$order['store_id']:0;
        $mealId = isset($order['meal_id'])?$order['meal_id']:0;
        $orderId = isset($order['id'])?$order['id']:0;
        $orderNo = isset($order['order_no'])?$order['order_no']:'';
        $orderTotal = isset($order['pay_total'])?$order['pay_total']:0;
        $profitTotal = isset($order['profit_total'])?$order['profit_total']:0;
        $data = [
            'order_id'=> $orderId,
            'user_id'=> $userId,
            'order_no'=> $orderNo,
            'store_id'=> $storeId,
            'total'=> $orderTotal,
            'create_time'=>time(),
            'status'=>2,
            'mark'=>1,
        ];
        $errors = [];
        if($orderType==2){
            /*  TODO 计算直推奖  */
            $pointId = isset($userInfo['point_id'])? $userInfo['point_id']:0;
            $directBonus = ConfigService::make()->getConfigByCode('business_direct_bonus', 0);
            $directBonus = $directBonus>0 && $directBonus<$orderTotal?$directBonus:0;
            $pointInfo = MemberModel::where(['id' => $pointId,'mark'=>1])
                ->select(['id','nickname','buy_type','bonus_status','status','mark'])
                ->first();
            $bonusStatus = isset($pointInfo['bonus_status'])?$pointInfo['bonus_status']:0;
            $data['direct_uid'] = $pointId;
            if($pointInfo && $bonusStatus==1){
                $data['direct_bonus'] = json_encode(['uid'=>$pointId,'bonus'=>$directBonus],256);
            }else{
                $data['direct_bonus']= json_encode(['uid'=>$pointId,'direct_bonus'=>$directBonus,'meal_id'=>$mealId,'error'=>'节点推荐人不存在或收益已领完','point'=>$pointInfo],256);
            }

            /* TODO 计算见单奖和分红奖励  */
            $points = isset($userInfo['points'])?$userInfo['points']:'';
            $points = $points? explode(',',$points) : [];
            $points = array_filter($points);
            $points = array_reverse($points); // 由下到上1-6层
            $rewardLayer = ConfigService::make()->getConfigByCode('business_reward_layer', 6);
            $points = array_splice($points,0, $rewardLayer);
            $jdBonus = ConfigService::make()->getConfigByCode("business_jd_bonus_{$mealId}", 0);
            $jdBonus = $jdBonus>0 && $jdBonus< $orderTotal? $jdBonus : 0;

            // 计算当前平台下各个等级的会员数量
            $levelCounts = MemberService::make()->getCountsByLevel();
            $levelList = MemberLevelService::make()->getListByLevel();

            if($points){
                $pointList = MemberModel::with(['levelData'])->whereIn('id', $points)
                    ->select(['id','nickname','mobile','buy_type','member_level','bonus_status','status','mark'])
                    ->orderBy(DB::raw("FIELD(id, ".implode(',',$points).")"))
                    ->get();
                foreach ($pointList as $k => $point){
                    // 默认只分6层
                    $layer = $k+1;
                    if($layer>$rewardLayer){
                        continue;
                    }


                    // 处理见单奖
                    $pid = isset($point['id'])?$point['id']:0;
                    $pMark = isset($point['mark'])?$point['mark']:0;
                    $buyType = isset($point['buy_type'])?$point['buy_type']:0;
                    $bonusStatus = isset($point['bonus_status'])?$point['bonus_status']:0;
                    $pLevel = isset($point['member_level'])?$point['member_level']:0;
                    $levelWeightCountData = isset($levelCounts[$pLevel])? $levelCounts[$pLevel] : 0;
                    $levelData = isset($levelList[$pLevel])? $levelList[$pLevel] : 0;
                    $levelWeightCount = isset($levelWeightCountData['count'])? $levelWeightCountData['count']:0;
                    $levelBonus = isset($levelData['bonus'])? $levelData['bonus']:0;
                    $levelName = isset($levelData['name'])? $levelData['name']:'';
                    $data["bonus_{$layer}_uid"] = $pid;

                    $bonusData = [
                        'id'=> $pid,
                        'nickname'=> isset($point['nickname'])?$point['nickname']:'',
                        'mobile'=> isset($point['mobile'])?$point['mobile']:'',
                        'jd_bonus'=> 0,
                        'level'=> $pLevel,
                        'level_name'=> $levelName,
                        'weight'=> $levelWeightCount,
                        'weight_bonus'=> $levelBonus,
                        'level_bonus'=> 0,
                    ];
                    if($pMark==1 && $bonusStatus==1){
                        $bonusData['jd_bonus'] = $jdBonus;
                    }else{
                        $bonusData["error"]= "上{$layer}级节点推荐人不存在或收益已领完";
                    }

                    // 处理加权分红
                    if($pLevel>0 && $levelWeightCount>0 && $levelBonus>0 && $bonusStatus==1){
                        $bonusData['level_bonus'] = moneyFormat($levelBonus * 6/$levelWeightCount,2);
                    }

                    // 数据
                    $data["bonus_{$layer}_data"] = json_encode($bonusData,256);
                }
            }

        }else{
            /* TODO 计算商家佣金 */
            $storeInfo = StoreModel::where(['id' => $storeId])->first();
            $bonusRate = isset($storeInfo['bonus_rate']) ? floatval($storeInfo['bonus_rate']) : 0;
            $storeBonusRate = ConfigService::make()->getConfigByCode('store_bonus_rate', 0);
            $storeBonusRate = $storeBonusRate > 0 && $storeBonusRate <= 100 ? $storeBonusRate : 0;
            $bonusRate = $bonusRate > 0 && $bonusRate <= 100 ? $bonusRate : $storeBonusRate;
            $bonus = moneyFormat($orderTotal * $bonusRate / 100, 2);
            $data['bonus'] = $bonus;
            $data['bonus_rate'] = $bonusRate;


            /* TODO 计算绿色积分奖励 */
            $lsScoreTotal = 0;
            $data['ls_score_rates'] = [];
            $ptLsScoreRate = ConfigService::make()->getConfigByCode('ls_score_rate',0);
            $ptLsScoreRate = $ptLsScoreRate>0&&$ptLsScoreRate<=50?$ptLsScoreRate:0;
            if($orderGoods){
                foreach ($orderGoods as $goods){
                    $lsScoreRate = isset($goods['ls_score_rate'])?$goods['ls_score_rate']:0;
                    $lsScoreRate = $lsScoreRate>0 && $lsScoreRate<=50?$lsScoreRate : $ptLsScoreRate;
                    $profitTotal = isset($goods['profit_total'])?$goods['profit_total'] : 0;
                    if($profitTotal>0 && $lsScoreRate>0){
                        $lsScoreTotal += moneyFormat($profitTotal * $lsScoreRate/100,2);
                    }
                    $data['ls_score_rates'][$goods['goods_id']] = [
                        'goods_id'=> $goods['goods_id'],
                        'score'=>$lsScoreRate
                    ];
                }
            }
            $data['ls_score'] = $lsScoreTotal;
            $data['ls_score_rates'] = json_encode($data['ls_score_rates'], 256);


            /* TODO 计算数字资产+底池金额 */
            $ptPoolRate = ConfigService::make()->getConfigByCode('pt_pool_rate', 0);
            $ptPoolRate = $ptPoolRate>0 && $ptPoolRate<50?$ptPoolRate:0;
            $rewardPropertyRate = ConfigService::make()->getConfigByCode('reward_property_rate', 0);
            $rewardPropertyRate = $rewardPropertyRate > 0 && $rewardPropertyRate <= 50 ? $rewardPropertyRate : 0;
            $propertyTotal = moneyFormat($rewardPropertyRate * $profitTotal/100,2);
            $poolTotal = moneyFormat($ptPoolRate * $profitTotal/100,2);
            $data['pt_pool_rate'] = $ptPoolRate;
            $data['pt_pool'] = $poolTotal;
            $data['property'] = $propertyTotal;
            $data['property_rate'] = $rewardPropertyRate;
        }

        // 佣金数据入库
        if(!$cid = OrderCommissionModel::where(['order_no'=>$orderNo])->value('id')){
            $cid = OrderCommissionModel::insertGetId($data);
        }else{
            OrderCommissionModel::where(['id'=>$cid])->update($data);
        }

        $this->error = '佣金计算成功';
        $data['id'] = $cid;
        return $data;
    }

    /**
     * 订单结算
     * @param $orderId
     * @return array|false
     */
    public function commissionSettle($orderId)
    {
        $info = OrderModel::with(['commission'])
            ->where(['id'=>$orderId,'mark'=>1])
            ->select(['id','order_no','type','user_id','total','pay_total','bd_score','pay_status','status','refund_status'])
            ->first();
        $info = $info?$info->toArray() : [];
        if(empty($info)){
            $this->error = '结算订单不存在';
            return false;
        }

        if($info['status']<=1 || $info['pay_status'] == 10){
            $this->error = '订单未支付';
            return false;
        }

        if(in_array($info['refund_status'],[1,2,3])){
            $this->error = '订单已退款';
            return false;
        }

        $orderType = isset($info['type'])?$info['type'] : 1;
        $orderNo = isset($info['order_no'])?$info['order_no'] : '';
        $orderUserId = isset($info['user_id'])?$info['user_id'] : 0;
        $commission = isset($info['commission'])?$info['commission'] : [];
        $commissionId = isset($commission['id'])?$commission['id'] : 0;
        if(empty($commission) || $commissionId<=0){
            $this->error = '结算订单收益参数错误';
            return false;
        }

        if($commission['status'] == 1){
            $this->error = '订单收益已结算';
            return false;
        }

        $cacheKey = "caches:ordersCommission:{$orderNo}_{$orderUserId}:";
        if(RedisService::get("{$cacheKey}lock")){
            $this->error = '订单结算中';
//            return false;
        }

        //  创业订单
        $logs = [];
        $success = [];
        RedisService::set("{$cacheKey}lock", $info, 300);
        DB::beginTransaction();
        if($orderType == 2){
            // TODO 结算直推奖
            $directData = isset($commission['direct_bonus']) && $commission['direct_bonus']? json_decode($commission['direct_bonus'],true) : [];
            $directUserId = isset($commission['direct_uid'])? $commission['direct_uid'] : 0;
            $directBonus = isset($directData['bonus'])? $directData['bonus'] : 0;
            var_dump($directUserId);
            dump($directData);
            var_dump($directBonus);
            if($directUserId>0 && $directBonus>0){
                $directUser = isset($commission['direct_user'])? $commission['direct_user'] : [];
                $directUserBalance = isset($directUser['balance'])?$directUser['balance'] : 0;
                if($directUser){
                    $updateData = [
                        'balance'=>DB::raw("balance + {$directBonus}"),
                        'bonus_total'=>DB::raw("bonus_total + {$directBonus}"),
                        'update_time'=>time()
                    ];
                    if(!MemberModel::where(['id'=>$directUserId])->update($updateData)){
                        DB::rollBack();
                        RedisService::clear("{$cacheKey}lock");
                        $this->error = '直推奖励结算错误';
                        return false;
                    }

                    $data = [
                        'user_id'=> $directUserId,
                        'source_order_no'=> $orderNo,
                        'user_type'=> 1,
                        'account_type'=> 1, // 余额
                        'type'=> 8,
                        'bonus_type'=> 1,
                        'money'=> $directBonus,
                        'after_money'=>moneyFormat($directUserBalance + $directBonus,2),
                        'date'=>date('Y-m-d'),
                        'create_time'=>time(),
                        'remark'=> '直推奖',
                        'remark1'=> "用户ID:{$orderUserId}购买礼包直推奖励",
                        'status'=>1,
                        'mark'=>1
                    ];

                    $logs[] = $data;
                }
            }

            // TODO 结算见单奖+分红
            $bonusUids = [];
            for($i=1; $i<=6; $i++){
                $uid = isset($commission["bonus_{$i}_uid"])? $commission["bonus_{$i}_uid"]:0;
                if($uid){
                    $bonusUids[] = $uid;
                }
            }

            $bonusUsers = MemberModel::whereIn('id', $bonusUids)
                ->select(['id','openid','balance','mobile','nickname','property','ls_score','status'])
                ->get()
                ->keyBy('id');
            $bonusUsers = $bonusUsers? $bonusUsers->toArray() : [];
            dump($bonusUids);
            for($i=1; $i<=6; $i++){
               $uid = isset($commission["bonus_{$i}_uid"])? $commission["bonus_{$i}_uid"]:0;
               $bonusData = isset($commission["bonus_{$i}_data"])? $commission["bonus_{$i}_data"]:'';
               $bonusData = $bonusData?json_decode($bonusData,true):[];
               $jdBonus = isset($bonusData['jd_bonus'])?$bonusData['jd_bonus']:0;
               $levelName = isset($bonusData['level_name'])?$bonusData['level_name']:'';
               $levelBonus = isset($bonusData['level_bonus'])?$bonusData['level_bonus']:0;
               $bonusUser = isset($bonusUsers[$uid])?$bonusUsers[$uid] : [];
               $bonusUserBalance = isset($bonusUser['balance'])?$bonusUser['balance'] : 0;
               $bonusTotal = moneyFormat($jdBonus + $levelBonus,2);
               if($uid && $bonusUser && $bonusTotal>0){
                   $updateData = [
                       'balance'=>DB::raw("balance + {$bonusTotal}"),
                       'bonus_total'=>DB::raw("bonus_total + {$bonusTotal}"),
                       'update_time'=>time()
                   ];
                   if(!MemberModel::where(['id'=> $uid])->update($updateData)){
                       DB::rollBack();
                       $this->error = '见单和分红奖励结算错误';
                       RedisService::clear("{$cacheKey}lock");
                       return false;
                   }

                   if($jdBonus>0){
                       $bonusUserBalance = moneyFormat($bonusUserBalance + $jdBonus,2);
                       $data = [
                           'user_id'=> $uid,
                           'source_order_no'=> $orderNo,
                           'user_type'=> 1,
                           'account_type'=> 1, // 余额
                           'type'=> 8,
                           'bonus_type'=> 2,
                           'money'=> $jdBonus,
                           'after_money'=> $bonusUserBalance,
                           'date'=>date('Y-m-d'),
                           'create_time'=>time()+$i,
                           'remark'=> '见单奖',
                           'remark1'=> "下{$i}级用户ID:{$orderUserId}购买礼包见单奖",
                           'status'=>1,
                           'mark'=>1
                       ];

                       $logs[] = $data;
                   }

                   if($levelBonus>0){
                       $bonusUserBalance = moneyFormat($bonusUserBalance + $levelBonus,2);
                       $data = [
                           'user_id'=> $uid,
                           'source_order_no'=> $orderNo,
                           'user_type'=> 1,
                           'account_type'=> 1, // 余额
                           'type'=> 8,
                           'bonus_type'=> 3,
                           'money'=> $levelBonus,
                           'after_money'=> $bonusUserBalance,
                           'date'=>date('Y-m-d'),
                           'create_time'=>time()+$i,
                           'remark'=> '分红收益',
                           'remark1'=> "下{$i}级用户ID:{$orderUserId}购买礼包等级[{$levelName}]分红收益",
                           'status'=>1,
                           'mark'=>1
                       ];

                       $logs[] = $data;
                   }
               }
            }
        }
        // 商城订单
        else {
            // TODO 商家结算
            $storeInfo = isset($commission['store'])?$commission['store'] : [];
            $storeId = isset($commission['store_id'])?$commission['store_id'] : 0;
            $storeBonus = isset($commission['bonus'])?$commission['bonus'] : 0;
            $storeUserId = isset($storeInfo['user_id'])?$storeInfo['user_id'] : 0;
            $storeBalance = isset($storeInfo['balance'])?$storeInfo['balance'] : 0;
            if($storeId>0 && $storeInfo && $storeBonus>0){
                $updateData = [
                    'balance'=>DB::raw("balance + {$storeBonus}"),
                    'income'=>DB::raw("income + {$storeBonus}"),
                    'update_time'=>time()
                ];
                if(!StoreModel::where(['id'=> $storeId])->update($updateData)){
                    DB::rollBack();
                    $this->error = '商家提成结算失败';
                    RedisService::clear("{$cacheKey}lock");
                    return false;
                }

                $storeBalance = moneyFormat($storeBalance + $storeBonus,2);
                $data = [
                    'user_id'=> $storeUserId,
                    'store_id'=> $storeId,
                    'source_order_no'=> $orderNo,
                    'user_type'=> 2,
                    'account_type'=> 1, // 余额
                    'type'=> 7,
                    'bonus_type'=> 0,
                    'money'=> $storeBonus,
                    'after_money'=> $storeBalance,
                    'date'=>date('Y-m-d'),
                    'create_time'=>time(),
                    'remark'=> '商家提成结算',
                    'remark1'=> "用户ID:{$orderUserId}购买商品提成结算",
                    'status'=>1,
                    'mark'=>1
                ];

                $logs[] = $data;
            }

            // TODO 绿色积分结算
            $userInfo = isset($commission['user'])?$commission['user']:[];
            $userId = isset($commission['user_id'])?$commission['user_id']:0;
            $userLsScore = isset($userInfo['ls_score'])?$userInfo['ls_score']:0;
            $lsScore = isset($commission['ls_score'])?$commission['ls_score']:0;
            if($userId>0 && $userInfo && $lsScore>0){
                $updateData = [
                    'ls_score'=>DB::raw("ls_score + {$lsScore}"),
                    'ls_score_total'=>DB::raw("ls_score_total + {$lsScore}"),
                    'update_time'=>time()
                ];
                if(!MemberModel::where(['id'=>$userId])->update($updateData)){
                    DB::rollBack();
                    $this->error = '绿色积分奖励结算错误';
                    RedisService::clear("{$cacheKey}lock");
                    return false;
                }

                $data = [
                    'user_id'=> $userId,
                    'source_order_no'=> $orderNo,
                    'user_type'=> 1,
                    'account_type'=> 4, // 绿色积分
                    'type'=> 8,
                    'bonus_type'=> 4,
                    'money'=> $lsScore,
                    'after_money'=>moneyFormat($userLsScore + $lsScore,2),
                    'date'=>date('Y-m-d'),
                    'create_time'=>time(),
                    'remark'=> '绿色积分奖励',
                    'remark1'=> "用户ID:{$orderUserId}购买商品绿色积分奖励",
                    'status'=>1,
                    'mark'=>1
                ];

                $logs[] = $data;
            }


            // TODO 数字资产和底池
            $property = isset($commission['property'])?$commission['property']:0;
            $userProperty = isset($userInfo['property'])?$userInfo['property']:0;
            if($userId>0 && $userInfo && $property>0){
                $updateData = [
                    'property'=>DB::raw("property + {$property}"),
                    'property_total'=>DB::raw("property_total + {$property}"),
                    'update_time'=>time()
                ];
                if(!MemberModel::where(['id'=>$userId])->update($updateData)){
                    DB::rollBack();
                    $this->error = '数字资产奖励结算错误';
                    RedisService::clear("{$cacheKey}lock");
                    return false;
                }

                $data = [
                    'user_id'=> $userId,
                    'source_order_no'=> $orderNo,
                    'user_type'=> 1,
                    'account_type'=> 2, // 数字资产
                    'type'=> 8,
                    'bonus_type'=> 5,
                    'money'=> $property,
                    'after_money'=>moneyFormat($userProperty + $property,2),
                    'date'=>date('Y-m-d'),
                    'create_time'=>time(),
                    'remark'=> '数字资产奖励',
                    'remark1'=> "用户ID:{$orderUserId}购买商品数字资产奖励",
                    'status'=>1,
                    'mark'=>1
                ];

                $logs[] = $data;
            }

            // 平台底池结算
            $ptAccount = PtAccountModel::where(['mark'=>1])->first();
            $accountId = isset($ptAccount['id'])?$ptAccount['id'] : 0;
            $poolTotal = isset($ptAccount['pool_total'])?$ptAccount['pool_total'] : 0;
            $ptPool = isset($commission['pt_pool'])?$commission['pt_pool'] : 0;
            if($ptAccount && ($ptPool>0 || $property>0)){
                $updateData = [
                    'pool_total'=>DB::raw("pool_total + {$ptPool}"),
                    'today_pool'=>DB::raw("today_pool + {$ptPool}"),
                    'today_property'=>DB::raw("today_property + {$property}"),
                    'update_time'=>time()
                ];
                if(!PtAccountModel::where(['id'=>$accountId])->update($updateData)){
                    DB::rollBack();
                    $this->error = '平台底池和资产结算错误';
                    RedisService::clear("{$cacheKey}lock");
                    return false;
                }

                // 底池明细
                if($ptPool>0){
                    $data = [
                        'user_id'=> 0,
                        'source_order_no'=> $orderNo,
                        'user_type'=> 0,
                        'account_type'=> 5, // 平台账户
                        'type'=> 10,
                        'bonus_type'=> 6,
                        'money'=> $ptPool,
                        'after_money'=>moneyFormat($poolTotal + $ptPool,2),
                        'date'=>date('Y-m-d'),
                        'create_time'=>time(),
                        'remark'=> '返回底池',
                        'remark1'=> "用户ID:{$orderUserId}购买商品返回底池",
                        'status'=>1,
                        'mark'=>1
                    ];

                    $logs[] = $data;
                }
            }
        }

        // TODO 明细入表
        RedisService::set("{$cacheKey}logs", $logs, 3600);
        if($logs && !AccountLogModel::insert($logs)){
            DB::rollBack();
            $this->error = '奖励明细结算处理错误';
            RedisService::clear("{$cacheKey}lock");
            return false;
        }

        // 订单结算状态更新
//        if(!OrderCommissionModel::where(['id'=>$commissionId])->update(['status'=>1,'arrival_at'=>date('Y-m-d H:i:s'),'update_time'=>time()])){
//            DB::rollBack();
//            $this->error = '订单结算状态更新失败';
//            return false;
//        }

        DB::commit();
        $this->error = '订单结算完成';
        RedisService::clear("{$cacheKey}lock");
        RedisService::set("{$cacheKey}result", $info, 3600);
        return ['id'=>$orderId,'user_id'=>$orderUserId,'logs'=>$logs,'commission'=>$commission];
    }

    /**
     * 新人注册奖励
     * @param $userId
     * @return array|bool
     */
    public function registerReward($userId)
    {
        $rewardOpen = ConfigService::make()->getConfigByCode('register_award_coupon',0);
        $rewardCouponId = ConfigService::make()->getConfigByCode('register_reward_coupon_id',0);
        if($rewardCouponId<=0 || $rewardOpen!= 1){
            $this->error = '未开启或配置注册优惠券奖励';
            return true;
        }

        $couponInfo = CouponModel::where(['id'=>$rewardCouponId,'mark'=>1])
            ->first();
        $status = isset($couponInfo['status'])?$couponInfo['status']:0;
        if(empty($couponInfo) || $status != 1){
            $this->error = '配置的注册奖励优惠券不存在或无效';
            return true;
        }

        $data = [
            'coupon_id'=> $rewardCouponId,
            'user_id'=> $userId,
            'store_id'=> isset($couponInfo['store_id'])?$couponInfo['store_id']:0,
            'name'=> isset($couponInfo['name'])?$couponInfo['name']:'',
            'coupon_type'=> isset($couponInfo['coupon_type'])?$couponInfo['coupon_type']: 20,
            'reduce_price'=> isset($couponInfo['reduce_price'])?$couponInfo['reduce_price']:0,
            'discount'=> isset($couponInfo['discount'])?$couponInfo['discount']:0,
            'min_price'=> isset($couponInfo['min_price'])?$couponInfo['min_price']:0,
            'expire_day'=> isset($couponInfo['expire_day'])?$couponInfo['expire_day']:0,
            'start_time'=> isset($couponInfo['start_time'])?$couponInfo['start_time']:0,
            'end_time'=> isset($couponInfo['end_time'])?$couponInfo['end_time']:0,
            'goods_ids'=> isset($couponInfo['goods_ids'])&&$couponInfo['goods_ids']?$couponInfo['goods_ids']:'',
            'create_time'=> time(),
            'status'=> 1,
        ];

        if(!$id = MemberCouponModel::insertGetId($data)){
            $this->error = '奖励注册优惠券失败';
            return true;
        }

        $data['id'] = $id;
        $data['discount'] = floatval($data['discount']);
        $data['reduce_price'] = floatval($data['reduce_price']);
        unset($data['create_time']);
        unset($data['status']);
        unset($data['goods_ids']);
        $this->error = '奖励注册优惠券成功';
        return $data;
    }
}