qimall/addons/DoubleCopy/common/logic/Reward.php

<?php

namespace addons\DoubleCopy\common\logic;

use addons\DoubleCopy\common\enums\DoubleCopyEnum;
use addons\DoubleCopy\common\models\DoubleCopyCommission;
use addons\DoubleCopy\common\models\DoubleCopyCommissionItemSetting;
use addons\DoubleCopy\common\models\DoubleCopyLevel;
use addons\DoubleCopy\common\models\DoubleCopyLevelSetting;
use addons\DoubleCopy\common\models\DoubleCopyUser;
use addons\PointUpperLimit\common\service\ScoreLogService;
use addons\PointUpperLimit\common\service\UserService;
use common\enums\GoodsTypeEnum;
use common\enums\OrderStatusEnum;
use common\enums\StatusEnum;
use common\models\common\CapitalLog;
use common\models\goods\Goods;
use common\models\user\User;
use common\models\user\UserPartitionRelationship;
use common\models\user\UserWallet;
use common\traits\ErrorTrait;
use services\common\UserWalletService;
use Yii;
use yii\db\Exception;
use yii\db\Expression;
use yii\helpers\Json;
use addons\DoubleCopy\common\models\DoubleCopyPoolUser;
use common\enums\AddonsEnum;
use common\models\mall\MallAddons;

class Reward
{
    use ErrorTrait;

    public static $reward = [];// 奖励

    public static $is_upgrade = false;
    public static $is_fracture = false;// 关系是否断层[false=否，true=是]
    public static $task_counter_arr = [];
    public static $commission_type = 'commission';// 奖励类型
    public static $upgrade_num = 2;// 推荐位数

    /**
     * 是否为额外积分
     * @var bool
     */
    public static $is_additional_score = false;

    /**
     * 额外积分与积分映射
     * @var string[]
     */
    protected static $commission_name_map = [
        'additional_score'  => 'score'
    ];

    /**
     * 计算奖励
     * @Author: lun
     * @DateTime: 2022/5/17 0017 14:44
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param array $basic_order 订单
     * @param bool $is_upgrade 是否是升级
     * @return bool
     */
    public static function compute($basic_order, $is_upgrade,$commission_type= 'commission')
    {
        $trans = Yii::$app->db->beginTransaction();
        try {
            $mall_id = $basic_order['mall_id'];// 商城
            self::$reward = [];// 初始化置空，防止重复发奖励
            self::$is_upgrade = $is_upgrade;
            self::$is_fracture = false;
            self::$task_counter_arr = [];

            //  如果是额外积分
            self::$is_additional_score = $commission_type == 'additional_score';

            self::$commission_type = $commission_type;
            self::getUpgradeNum($basic_order['mall_id']);

            $doubleCopyUser = DoubleCopyUser::getOne([['user_id' => $basic_order['user_id']], ['mall_id' => $basic_order['mall_id']],['status'=>StatusEnum::ENABLED]], true, [], 'updated_at desc');
           
            if($doubleCopyUser){
                $goods_info = json_encode(['goods_id'=>$basic_order['detail'][0]['goods_id'], 'goods_name'=>$basic_order['detail'][0]['goods_name'],'price'=>$basic_order['detail'][0]['price']]);
           
                DoubleCopyUser::setData(['id'=>$doubleCopyUser['id'],'mall_id' => $basic_order['mall_id'],'goods_info'=>$goods_info]);
            }


            // 检查商品是虚拟商品订单
            $is_virtual = false;
            $goods = Goods::find()->where(['id' => $basic_order['detail'][0]['goods_id']])->asArray()->one();
            if (!empty($goods) && $goods['goods_type'] == GoodsTypeEnum::GoodsTypeVirtual) {
                $is_virtual = true;
                // 虚拟商品直接退出
//                if ($basic_order['order_status'] == OrderStatusEnum::ACCOMPLISH) {
//                    $trans->commit();
//                    return true;
//                }
            }

            // 获取配置信息
            $config = Yii::$app->services->setting->addons->get($mall_id, DoubleCopyEnum::ADDONS_NAME, 'basic');
            unset($config['reward_name']);// 移除名称自定义配置
            // 订单已完成，但是结算方式为支付完成，则后续不再进行结算
//            if ($config['compute_type'] == 1 && $basic_order['order_status'] == OrderStatusEnum::ACCOMPLISH) {
//                $trans->commit();
//                return true;
//            }

            // 获取链动用户信息
            $user = DoubleCopyUser::find()->where(['user_id' => $basic_order['user_id'], 'status' => StatusEnum::ENABLED])->one();
            if (empty($user)) {
                $trans->commit();
                return true;
            }
            // 检查是否已经生成过订单分润数据
            $check_commission = DoubleCopyCommission::find()->where(['order_id' => $basic_order['id'], 'status' => StatusEnum::ENABLED,'reward_currency'=>$commission_type])->asArray()->all();
            if (empty($check_commission)) {
                // 获取代理等级设置的商品
                $level_good_ids = DoubleCopyLevel::find()->select('goods_ids')->where(['mall_id' => $basic_order['mall_id'], 'level' => DoubleCopyEnum::LEVEL_AGENT, 'status' => StatusEnum::ENABLED])->scalar();
                $level_good_ids = empty($level_good_ids) ? [] : Json::decode($level_good_ids, true);// json字符串

                // 获取独立设置商品
                $alone_good_ids = DoubleCopyCommissionItemSetting::find()->select('item_id')->where(['mall_id' => $basic_order['mall_id'], 'status' => StatusEnum::ENABLED,'commission_type' => $commission_type])->column();
                $good_ids = array_unique(array_merge($level_good_ids, $alone_good_ids));

                // 组合订单信息
                $order = [
                    'id' => $basic_order['id'],
                    'order_id' => $basic_order['id'],
                    'order_no' => $basic_order['order_no'],
                    'mall_id' => $basic_order['mall_id'],
                    'user_id' => $basic_order['user_id'],
                    'order_status' => $basic_order['order_status'],
                    'created_at' => $basic_order['created_at'],
                ];

                // 获取等级配置
                $level = DoubleCopyLevelSetting::find()->where(['mall_id' => $mall_id,'status' => StatusEnum::ENABLED,'commission_type' => $commission_type])
                    ->with(['levelInfo' => function($query){
                        $query->select('id,open_ladder,ladder_setting');
                    }])->indexBy('level')->asArray()->all();

                foreach ($level as &$item) {
                    $item['open_ladder'] = $item['levelInfo']['open_ladder'];
                    $item['ladder_setting'] = $item['levelInfo']['ladder_setting'];
                }

                foreach ($basic_order['detail'] as $key => $detail){

                    // 获取独立设置商品
                    $good = DoubleCopyCommissionItemSetting::find()
                        ->where(['mall_id' => $basic_order['mall_id'], 'item_id' => $detail['goods_id'], 'status' => StatusEnum::ENABLED,'commission_type' => $commission_type])
                        ->with('detail')
                        ->asArray()->one();
                    if (empty($good)) {
                        $level_setting = $level;
                        // 获取等级设置商品
                        $good = DoubleCopyLevel::find()->select('goods_ids')->where(['mall_id' => $basic_order['mall_id'], 'level' => DoubleCopyEnum::LEVEL_AGENT, 'status' => StatusEnum::ENABLED])->asArray()->one();
                    } else {
                        if ($good['is_partake'] == 0) {
                            Yii::$app->custom->logs("二二赠送：".json_encode($order['id']).'，结果：不参与分红直接退出');
                            continue;// 不参与分红直接退出
                        }
                        if ($good['is_enable'] == 0) {// 参与分红但是不独立设置，则去等级设置
                            $level_setting = $level;
                        } else {
                            $level_setting = $good['detail'];
                            foreach ($level_setting as &$setting) {// 设置等级
                                $setting['first_prize_type'] = $setting['indirect_prize_type'] = $setting['second_prize_type'] = $setting['equal_prize_type'] = $setting['equal_level_prize_type'] = $setting['repurchase_prize_type'] = $good['is_percent'];
                                $setting['freeze_fund_prize'] = $level[$setting['level']]['freeze_fund_prize'];
                                $setting['open_ladder'] = $level[$setting['level']]['levelInfo']['open_ladder'];
                                $setting['ladder_setting'] = $level[$setting['level']]['levelInfo']['ladder_setting'];
                            }
                        }
                    }
                    if (empty($good)){
                        Yii::$app->custom->logs("二二赠送：".json_encode($order['id']).'，结果：没有商品');
                        continue;
                    }

                    // 检测购买此商品是否有使用优惠或抵扣(随机减不算)
                    if (!empty($config['is_open_no_rewards']) && bcmul($detail['price'], $detail['num'], 2) != bcmul($detail['goods_price'],1,2)){
                        Yii::$app->custom->logs("二二赠送：".json_encode($order['id']).'，结果：检测购买此商品是否有使用优惠或抵扣(随机减不算)');
                        continue;
                    }
                    // 判断商品是否在商品列表中
                    if (!in_array($detail['goods_id'], $good_ids)) {
                        Yii::$app->custom->logs("二二赠送：".json_encode($order['id']).'，结果：判断商品是否在商品列表中');
                        continue;
                    }
                    $order['order_detail_id'] = $detail['id'];
                    $order['goods_name'] = $detail['goods_name'];
                    $order['pic_url'] = $detail['pic_url'];
                    $order['price'] = $detail['price'];
                    $order['cost_price'] = $detail['cost_price'];
                    $order['original_goods_price'] = $detail['original_goods_price'];
                    $order['goods_price'] = $detail['goods_price'];
                    $order['adjust_money'] = $detail['adjust_money'];
                    $order['num'] = $detail['num'];
                    $order['goods_id'] = $detail['goods_id'];
                    self::computeHandle($user, $order, $config, $level_setting, $is_upgrade, $is_virtual);
                }
            }
            

            // 订单完成操作
            if ($basic_order['order_status'] == OrderStatusEnum::ACCOMPLISH) {
                // 获取未结算的奖励
                $list = DoubleCopyCommission::find()->where(['order_id' => $basic_order['id'], 'settlement_type' => StatusEnum::DISABLED, 'reward_currency' => $commission_type, 'status' => StatusEnum::ENABLED])->asArray()->all();
                if (empty($list) || (count($list) == 1 && $list[0]['is_frozen'] == 1)) {
                    $trans->commit();
                    return true;
                }
                $res = self::settlement($list, $config, $basic_order['order_status'], true, $basic_order['mall_id'], $is_virtual);
                if ($res === false) throw new Exception(self::getStaticError());
            }

            $trans->commit();
            return true;
        } catch (\Exception $e) {
            $trans->rollBack();
            self::setStaticError($e->getMessage());
            return false;
        }
    }


    /**
     * 计算处理等级商品与独立设置商品分润
     * @Author: lun
     * @DateTime: 2022/6/21 0021 15:25
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param object $user
     * @param array $order 订单信息
     * @param array $config 基础设置
     * @param array $level 等级设置
     * @param bool $is_upgrade 是否是升级
     * @return bool
     * @throws Exception
     */
    public static function computeHandle(DoubleCopyUser $user, $order, $config, $level, $is_upgrade, $is_virtual)
    {
        /*因为当订单为多个子订单循环是。之前订单佣金self::$reward 还会保存之前的数据。如果当下一个子订单没有self::$reward 中对应分佣类型数据
        那么之前的订单分佣数据不会被替换。还是会保留。所以此处需要每次都设置self::$reward = [];*/
        self::$reward = [];
        // 获取计算金额
        $computing_config = self::getComputingConfig($config, $order);
        if (empty($computing_config)) return true;

        // 初始化奖励参数
        $basic_params = [
            'mall_id' => $order['mall_id'],
            'buy_uid' => $order['user_id'],
            'order_id' => $order['id'],
            'order_no' => $order['order_no'],
            'pay_money' => $order['goods_price'],
            'goods_name' => $order['goods_name'],
            'pic_url' => $order['pic_url'],
            'price' => $order['price'],
            'source_table' => 'order_detail',
            'source_table_id' => $order['order_detail_id'],
            'setting' => $config,
            'created_at' => $order['created_at'],
            'updated_at' => time(),
        ];

        Yii::$app->custom->logs(json_encode(['user' => $user, 'computing_config' => $computing_config,'setting' => $config,'is_upgrade' => $is_upgrade, 'goods_id' => $order['goods_id']]));

        // 平台补贴(奖励topid)
        $second_prize = self::SecondPrize($user, $level, $computing_config, $basic_params, $is_upgrade,$order['goods_id']);
        Yii::$app->custom->logs("二二补贴：".json_encode($order['id']).'，结果：'.json_encode($second_prize));
        if ($second_prize === false) throw new Exception(self::getStaticError());
        //计算平台补贴贡献奖
        $contribution_price = self::contributionPrice($order, $basic_params, $user);
        if ($contribution_price === false) throw new Exception(self::getStaticError());

        // 直推奖(奖励pid)
        $first_prize = self::FirstPrize($user, $level, $computing_config, $basic_params, $is_upgrade,$order['goods_id']);
        Yii::$app->custom->logs("二二直推奖：".json_encode($order['id']).'，结果：'.json_encode($first_prize));
        if ($first_prize === false) throw new Exception(self::getStaticError());

        // 培育奖(平级奖[奖励pid的上级])，获取培育奖的计算依据：0=平台补贴计算，1=平台补贴+直推奖计算
        $equal_settle_basis = $config['equal_settle_basis'] ?? 0;

        $second_original_money = self::$reward[DoubleCopyEnum::SECOND_PRIZE]['original_money'] ?? 0;// 平台补贴金额
        

        if ($equal_settle_basis == 0) {// 平台补贴计算
            $computing_money = $second_original_money;// 平台补贴金额
        } else {// 平台补贴+直推奖计算
            // 判断当前用户是否平台补贴加直推一起获得
            $first_money = 0;
            if ($user['pid'] == $user['topid']) {// 如果平台补贴+直推奖获得者为同一个用户则计算培育收益需要按照两个收益和来做结算
                $first_money = self::$reward[DoubleCopyEnum::FIRST_PRIZE]['original_money'] ?? 0;
            }
            $computing_money = $second_original_money + $first_money;
        }
    
        // 培育奖计算
        if (!empty($computing_money)) {
            // 培育奖奖励人数
            $equal_prize = self::EqualPrize($user, $level, $computing_money, $basic_params, $computing_config['multiple'],$order['goods_id']);
            if ($equal_prize === false) throw new Exception(self::getStaticError());
            if ($equal_prize) {
                // 拿平台补贴收益支付处理
                if ($config['equal_settle_type'] == 1) {
                    self::$reward[DoubleCopyEnum::SECOND_PRIZE]['money'] = self::$reward[DoubleCopyEnum::SECOND_PRIZE]['money'] - self::$reward[DoubleCopyEnum::EQUAL_PRIZE]['money'];
                }
            }
        }
        
        //平级奖[奖励pid的上级]获取培育奖的计算依据：0=平台补贴计算，1=平台补贴+直推奖计算
        $equal_level_settle_basis = $config['equal_level_settle_basis'] ?? 0;

        $second_original_money = self::$reward[DoubleCopyEnum::SECOND_PRIZE]['original_money'] ?? 0;// 平台补贴金额


        if ($equal_level_settle_basis == 0) {// 平台补贴计算
            $computing_money = $second_original_money;// 平台补贴金额
        } else {// 平台补贴+直推奖计算
            // 判断当前用户是否平台补贴加直推一起获得
            $first_money = 0;
            if ($user['pid'] == $user['topid']) {// 如果平台补贴+直推奖获得者为同一个用户则计算培育收益需要按照两个收益和来做结算
                $first_money = self::$reward[DoubleCopyEnum::FIRST_PRIZE]['original_money'] ?? 0;
            }
            $computing_money = $second_original_money + $first_money;
        }

        // 平级奖计算
        if (!empty($computing_money)) {
            // 平级奖奖励人数
            $equal_level_prize = self::EqualLevelPrize($user, $level, $computing_money, $basic_params, $computing_config['multiple'],$order['goods_id']);
            if ($equal_level_prize === false) throw new Exception(self::getStaticError());
            if ($equal_level_prize) {
                // 拿平台补贴收益支付处理
                if ($config['equal_level_settle_type'] == 1) {
                    self::$reward[DoubleCopyEnum::SECOND_PRIZE]['money'] = self::$reward[DoubleCopyEnum::SECOND_PRIZE]['money'] - self::$reward[DoubleCopyEnum::EQUAL_LEVEL_PRIZE]['money'];
                }
            }
        }
        
        // 间推奖(依据主商城关系链，奖励下单用户的上上级)
        $indirect_prize = self::IndirectPrize($level, $computing_config, $basic_params,$order['goods_id']);
        if ($indirect_prize === false) throw new Exception(self::getStaticError());

        //津贴奖
        $allowance_prize = self::AllowancePrize($user, $level, $computing_money, $basic_params, $computing_config['multiple'],$order['goods_id']);
        if ($allowance_prize === false) throw new Exception(self::getStaticError());
// print_r(self::$reward);
        //复购奖
        $repurchase_prize = self::repurchasePrizeDiff($user, $level, $computing_config, $basic_params,$order['goods_id']);
        if ($repurchase_prize === false) throw new Exception(self::getStaticError());
        // 结算
        if (self::$reward) {
            $res = self::settlement(self::$reward, $config, $order['order_status'], false, $order['mall_id'], $is_virtual);
            if ($res === false) throw new Exception(self::getStaticError());
        }
    }


    /**
     * 结算
     * @Author: lun
     * @DateTime: 2022/5/17 0017 16:07
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $rewards
     * @param $config
     * @param $order_status
     * @param $has_commission
     * @param $is_virtual
     * @return bool
     * @throws \yii\db\Exception
     */
    public static function settlement($rewards, $config, $order_status, $has_commission, $mall_id, $is_virtual = false)
    {
        try {

            //奖励类型：佣金，积分
            $reward_currency = self::$commission_name_map[self::$commission_type] ?? self::$commission_type;


            $settlement_type = DoubleCopyEnum::NOT_SETTLEMENT;// 未结算
            $field = 'frozen_'.$reward_currency;
            $handle_unfrozen = false;// 是否执行解冻操作
            $has_freeze = false;// 是否已存在冻结佣金数据

            if ($config['compute_type'] == 1 && $order_status == OrderStatusEnum::PAY) {// 支付完成后
                $settlement_type = DoubleCopyEnum::SETTLED;// 已结算
                //$field = 'commission';
                $field = $reward_currency;
            }

            // 订单完成必须结算，即便中途配置改为支付完成结算
            if ($order_status == OrderStatusEnum::ACCOMPLISH) {// 订单完成后
                $settlement_type = DoubleCopyEnum::SETTLED;// 已结算
                //$field = 'commission';
                $field = $reward_currency;
                $handle_unfrozen = true;
            }

            // 虚拟商品直接改为已结算
//            if ($is_virtual == true) {
//                $settlement_type = DoubleCopyEnum::SETTLED;// 已结算
//                $field = 'commission';
//            }

            // 获取资金类型
            $capital_map = DoubleCopyEnum::getCapitalMap($mall_id);
            $lduser = $source_table_id = $commission_arr = [];
            $update_oids = 0;
            $user_total_reward = [];
            $point_upper_reward_insert = [];
            $height_commission_arr = [];
            foreach ($rewards as $key =>  $reward) {
                $reward['reward_currency'] = $reward_currency;
                if ($reward['money'] <= 0) continue;// 若平级奖由拿平台补贴用户给，有可能会导致平台补贴收益为空

                //奖励类型：佣金，积分
                $field = 'frozen_'.$reward_currency;
                if ($config['compute_type'] == 1 && $order_status == OrderStatusEnum::PAY) {// 支付完成后
                    $field = $reward_currency;
                }
                if ($order_status == OrderStatusEnum::ACCOMPLISH) {// 订单完成后
                    $field = $reward_currency;
                }

                $update_oids = $reward['order_id'];
                $source_table_id[] = $reward['source_table_id'];
                $reward['is_frozen'] = $reward['capital_type'] == DoubleCopyEnum::FREEZE_FUND ? 1 : 0;
                if ($reward['capital_type'] == DoubleCopyEnum::FREEZE_FUND) {
                    $reward['settlement_type'] = StatusEnum::DISABLED;
                } else {
                    $reward['settlement_type'] = $settlement_type;
                }
                if (!empty($reward['original_money'])) unset($reward['original_money']);
                //$reward['reward_currency'] = $reward_currency;

                //  如果是额外积分，那么就判断上限
                if (self::$is_additional_score && !$has_commission) {
                    if (!empty($user_total_reward[$reward['user_id']])) {
                        $user_total_reward[$reward['user_id']] = bcadd($user_total_reward[$reward['user_id']], $reward['money'], 2);
                    } else {
                        $user_total_reward[$reward['user_id']] = $reward['money'];
                    }
                    $quota = (new UserService())->getUserQuota($reward['mall_id'], $reward['user_id']);
                    if ($user_total_reward[$reward['user_id']] > $quota) {
                        $reward['money'] = bcsub($quota, bcsub($user_total_reward[$reward['user_id']], $reward['money'], 2), 2);
                    }
                    if ($reward['money'] <= 0) continue;
                }


                // 云库存计数器，云库存代理承担二二复制分佣开发，必须是支付成功并且未结算情况下计算
                if ($order_status == OrderStatusEnum::PAY && $reward_currency == 'commission') {
                    if(isset(self::$task_counter_arr[$reward['source_table_id']][DoubleCopyEnum::ADDONS_NAME]['commission'])){
                        self::$task_counter_arr[$reward['source_table_id']][DoubleCopyEnum::ADDONS_NAME]['commission'] += $reward['money'];
                    }else{
                        self::$task_counter_arr[$reward['source_table_id']][DoubleCopyEnum::ADDONS_NAME]['commission'] = $reward['money'];
                    }
                }
                 //判断用户佣金奖励是否设置上限,只在订单支付时判断
                $reward_amount = $reward['money'];
                if($reward_currency == 'commission' && $order_status == OrderStatusEnum::PAY){
                    $doubleCopyUser = DoubleCopyUser::find()->where(['user_id' => $reward['user_id'], 'status' => StatusEnum::ENABLED])->one();
                    if($doubleCopyUser && !empty($doubleCopyUser['is_height_commission'])){
                        CapitalLog::$capitalType = 'commission_frozen';
                        $frozen_commission = CapitalLog::find()->where(['user_id' => $reward['user_id'], 'from_type' => DoubleCopyEnum::ADDONS_NAME, 'status' => StatusEnum::DISABLED])->sum("change_num") ?? 0;
                        $frozen_fund = DoubleCopyCommission::find()->where(['user_id' => $reward['user_id'], 'capital_type' => DoubleCopyEnum::FREEZE_FUND, 'settlement_type' => [0,2],'reward_currency'=>'commission'])->sum('money') ?? 0;
                        $user_total_commission = $doubleCopyUser['commission'] + $frozen_commission + $frozen_fund; 
                        if(isset($height_commission_arr[$reward['user_id']]['amount'])){
                            $user_total_commission += $height_commission_arr[$reward['user_id']]['amount'];
                        }
                        $can_reward_amount = $doubleCopyUser['height_commission'] - $user_total_commission;
                        if($can_reward_amount <= 0){
                            $reward_amount = 0;
                            $reward['money'] = 0;
                            $rewards[$key]['money'] = 0;
                        }else{
                            if($can_reward_amount < $reward_amount){
                                $reward_amount = $can_reward_amount;
                                $reward['money'] = $can_reward_amount;
                                $rewards[$key]['money'] = $can_reward_amount;
                            }
                            if(isset($height_commission_arr[$reward['user_id']]['amount'])){
                                $height_commission_arr[$reward['user_id']]['amount'] += $reward['money'];
                            }else{
                                $height_commission_arr[$reward['user_id']]['amount'] = $reward['money'];
                            }
                        }
                    }
                }
                // 增加用户的资金累计额度 - 只有结算的时候才需要 所以这里会存在一个问题
                if ($reward['capital_type'] == DoubleCopyEnum::FREEZE_FUND) {
                    if($reward_currency == 'commission'){
                        $lduser[$reward['user_id']]['frozen_fund'] = $reward['money'];
                    }else{
                        $lduser[$reward['user_id']]['frozen_fund_score'] = $reward['money'];
                    }

                } else {
                    $lduser[$reward['user_id']][$field] = empty($lduser[$reward['user_id']][$field]) ? $reward_amount : $lduser[$reward['user_id']][$field] + $reward_amount;

                }

                $has_commission == false && $rows[] = $reward;// 支付完成生成数据
                
                $is_frozen = $settlement_type == DoubleCopyEnum::SETTLED ? false : true;

                //  用于额外积分记录
                if (self::$is_additional_score && !$has_commission) {
                    $point_upper_reward_insert[] = [
                        'mall_id' => $reward['mall_id'],
                        'user_id' => $reward['user_id'],
                        'is_frozen' => $is_frozen,
                        // 'wallet_type' => 'commission',
                        'wallet_type' => $reward_currency,
                        'money' => $reward['money'],
                        'desc' => $capital_map[$reward['capital_type']],
                        'source_table' => $reward['source_table'],
                        'source_table_id' => $reward['source_table_id'],
                        'from_type' => DoubleCopyEnum::ADDONS_NAME,
                        'capital_type' => $reward['capital_type'],
                        'order_no'  => $reward['order_no']
                    ];
                }

                // 已结算插入钱包队列中(冻结基金不算在内)
                if ($reward['capital_type'] != DoubleCopyEnum::FREEZE_FUND) {
                    // 如果订单已经完成，但是又未进行结算则不需要增加数据
                    if ($order_status == OrderStatusEnum::ACCOMPLISH && $settlement_type != DoubleCopyEnum::SETTLED) continue;

                    if (self::$is_upgrade == false && $handle_unfrozen == true) continue;// 执行解冻操作则不需要进行插入钱包队列
                    $insert_wallet[] = [
                        'mall_id' => $reward['mall_id'],
                        'user_id' => $reward['user_id'],
                        'is_frozen' => $is_frozen,
                        // 'wallet_type' => 'commission',
                        'wallet_type' => $reward_currency,
                        'money' => $reward['money'],
                        'desc' => $capital_map[$reward['capital_type']],
                        'source_table' => $reward['source_table'],
                        'source_table_id' => $reward['source_table_id'],
                        'from_type' => $reward['capital_type'] == DoubleCopyEnum::CONTRIBUTION_PRICE ? AddonsEnum::ADDONS_NAME_DOUBLE_COPY_COMMITMENT_AWARD : DoubleCopyEnum::ADDONS_NAME,
                        'capital_type' => $reward['capital_type'],
                        'order_no'  => $reward['order_no']
                    ];
                }
            }
            // 生成数据
            if (!empty($rows)) {
                $field = ['mall_id','buy_uid','order_id','order_no','pay_money','goods_name','pic_url','price','source_table','source_table_id','setting','created_at','updated_at','user_id','money','capital_type','reward_currency','is_frozen','settlement_type'];
                $res = Yii::$app->db->createCommand()->batchInsert(DoubleCopyCommission::tableName(), $field, $rows)->execute();
                if ($res == false) throw new Exception("批量插入奖励出错");
            }

            // 保存数据
            if (!empty($lduser) && $settlement_type == DoubleCopyEnum::SETTLED) {
                echo 'batchAddCommission：order_id='.$update_oids.','.json_encode($lduser).PHP_EOL;
                $res = DoubleCopyUser::batchAddCommission($lduser);
                if ($res === false) throw new Exception("批量更新用户佣金数据出错：" . DoubleCopyUser::getStaticError());
            }

            // 修改佣金列表状态
            if (!empty($update_oids) && $settlement_type == DoubleCopyEnum::SETTLED) {
                $res = DoubleCopyCommission::updateAll(['settlement_type' => StatusEnum::ENABLED, 'updated_at' => time()], "order_id in({$update_oids}) and reward_currency='{$reward_currency}' and capital_type!='".DoubleCopyEnum::FREEZE_FUND."'");
                if ($res === false) throw new Exception("批量修改佣金状态失败：" . DoubleCopyUser::getStaticError());
                $res = DoubleCopyCommission::updateAll(['frozen_status' => StatusEnum::ENABLED, 'updated_at' => time()], "order_id in({$update_oids}) and reward_currency='{$reward_currency}' and capital_type='".DoubleCopyEnum::FREEZE_FUND."'");
                if ($res === false) throw new Exception("修改冻结基金转入状态失败：" . DoubleCopyUser::getStaticError());
                // 将未结算金额移除
                if ($handle_unfrozen) {
                    $where = [
                        ['source_table' => 'order_detail'],
                        ['source_table_id' => $source_table_id],
                        [
                            'or',
                            ['from_type' => DoubleCopyEnum::ADDONS_NAME],
                            ['from_type' => AddonsEnum::ADDONS_NAME_DOUBLE_COPY_COMMITMENT_AWARD],
                        ],
                        ['status' => CapitalLog::STATUS_WAIT_SEND]
                    ];
                    $params['where'] = $where;
                    $wallet_type = 'commission';
                    CapitalLog::$capitalType = "{$wallet_type}_frozen";
                    $commission_list = CapitalLog::lists($params);
                    if ($commission_list) {
                        $has_freeze = true;
                        foreach ($commission_list as $item) {
                            $res = UserWalletService::unfrozen($item['id'], $wallet_type);
                            if ($res === false) throw new \Exception('解冻失败：'.UserWalletService::getStaticError());
                        }
                    }

                    $wallet_type = 'score';
                    CapitalLog::$capitalType = "{$wallet_type}_frozen";
                    $score_list = CapitalLog::lists($params);
                    if ($score_list) {
                        $has_freeze = true;
                        foreach ($score_list as $item) {
                            $res = UserWalletService::unfrozen($item['id'], $wallet_type);
                            if ($res === false) throw new \Exception('解冻失败：'.UserWalletService::getStaticError());
                        }
                    }


                }
            }

            //  如果是额外积分,那么就需要记录一下
            if (self::$is_additional_score && (!empty($point_upper_reward_insert) || $order_status == OrderStatusEnum::ACCOMPLISH)) {
                self::pointUpperLimit($order_status == OrderStatusEnum::ACCOMPLISH, $point_upper_reward_insert, $source_table_id);
            }
            // 插入钱包 - 放在最后预防中途报错
            if (!empty($insert_wallet) && $has_freeze == false) {
                $res = UserWalletService::batchHandleByQueue($insert_wallet);
                if (empty($res)) throw new \Exception('插入钱包队列：' . UserWalletService::getStaticError());
            }
            return true;
        } catch (\Exception $e) {
            self::setStaticError("奖励结算错误：第" . $e->getLine().'行，原因：'.$e->getMessage() . " 文件： " . $e->getFile());
            return false;
        }
    }

    /**
     * 额外积分处理
     * @param bool $has_freeze
     * @param array $insert_wallet
     * @param array $source_table_id
     * @return array
     * @throws Exception
     */
    public static function pointUpperLimit(bool $has_freeze, array $insert_wallet, array $source_table_id)
    {
        $upperLimitService = new ScoreLogService();
        if ($has_freeze) {  //  是否已存在冻结佣金数据 如果存在那么就是解冻否则就是新增
            $upperLimitService->batchUnfrozen([   //  统一在渠道那边解冻
                ['source_table' => 'order_detail'],
                ['source_table_id' => $source_table_id],
                ['from_type' => DoubleCopyEnum::ADDONS_NAME],
                ['status' => CapitalLog::STATUS_WAIT_SEND]
            ]);
        } else {
            $upperLimitService->batchInsert($insert_wallet);
        }
        return $insert_wallet;
    }

    /**
     * 直推奖励
     * @Author: lun
     * @DateTime: 2022/5/17 0017 14:07
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $buy_user
     * @param $level
     * @param $computing_config
     * @param $basic_params
     * @return array|bool
     */
    public static function FirstPrize(&$buy_user, $level, $computing_config, $basic_params, $is_upgrade,$goods_id=0)
    {
        try {
            $computing_money = $computing_config['computing_money'];// 支付金额
            $multiple = $computing_config['multiple'];// 商品数量
            $config = $basic_params['setting'];         // 基础配置

            // 检查用户等级
            $first_user = DoubleCopyUser::find()->select('level,upgrade_level_at,user_id,mall_id,goods_info')->where(['user_id' => $buy_user['pid'], 'status' => StatusEnum::ENABLED])->asArray()->one();

            // 上级无身份的情况下，判断关系链断层是否继续找可获得直推奖的上级
            if (empty($first_user) && isset($config['first_fracture_reward']) && !empty($config['first_fracture_reward'])) {
                $parent_ids_arr = UserPartitionRelationship::getParentIdArr($buy_user['pid']);
                if (!empty($parent_ids_arr)) {
                    $parent_ids_arr = array_reverse($parent_ids_arr);
                    $parent_users = DoubleCopyUser::lists(['where' => [['mall_id' => $buy_user['mall_id']], ['user_id' => $parent_ids_arr], ['status' => StatusEnum::ENABLED]], 'select' => 'level,upgrade_level_at,user_id,mall_id,goods_info', 'index' => 'user_id']);
                    foreach ($parent_ids_arr as $parent_id) {
                        if (isset($parent_users[$parent_id])) {
                            $first_user = $parent_users[$parent_id];
                            break;
                        }
                    }
                }
            }

            // 判断用户等级是否存在，不存在代表该上级并非代理或老板级别
            if (empty($first_user)) return [];
            
            // 获取等级配置
            $level_config = $level[$first_user['level']];
          
            // 计算直推奖励金额
            if ($level_config['first_prize_type'] == 0) {
                // 按百分比计算
                $money = $computing_money * $level_config['first_prize'] / 100;
                $money = sprintf("%.2f",substr(sprintf("%.3f", $money), 0, -1));// 保留两位小数并不四舍五入
            } else {
                // 按固定金额计算
                $money = $level_config['first_prize'] * $multiple;
            }

            if ($money <= 0) return [];

            // 冻结基金
            $frozen_money = 0;
            // 必须要有平台补贴才能出现冻结基金，只有平台补贴用户跟直推用户为同一个人才可生效
            if (!empty(self::$reward[DoubleCopyEnum::FREEZE_FUND]) && $buy_user['topid'] == $first_user['user_id']) {
                $top_user = DoubleCopyUser::find()->where(['user_id' => $buy_user['topid'], 'status' => StatusEnum::ENABLED])->asArray()->one();
                $freeze_fund_prize = $level[$top_user['level']]['freeze_fund_prize'] ?? 0;// 该等级冻结基金比例
                if ($top_user['is_thaw'] != 1 && $freeze_fund_prize > 0 && !empty($config['frozen_settle_basis'])) {
                    // 计算冻结基金
                    if ($top_user['level'] >= DoubleCopyEnum::LEVEL_BOSS) {
                        // 判断该等级是否开启了解冻阶梯设置
                        if (!empty($level[$top_user['level']]['open_ladder'])) {
                            $freeze_fund_prize = $freeze_fund_prize * (100 - $top_user['thaw_percent']) / 100;
                        }
                        $frozen_money = sprintf("%.2f",substr(sprintf("%.3f", ($money * $freeze_fund_prize / 100)), 0, -1));// 保留两位小数并不四舍五入
                        if ($frozen_money > 0) {
                            // 生成冻结基金数据
                            self::$reward[DoubleCopyEnum::FREEZE_FUND]['money'] = empty(self::$reward[DoubleCopyEnum::FREEZE_FUND]['money']) ? $frozen_money : $frozen_money + self::$reward[DoubleCopyEnum::FREEZE_FUND]['money'];
                            
                        }
                    }
                }
            }

            // 生成奖励明细数据
            $basic_params['setting']['first_prize_type'] = $level_config['first_prize_type'];
            $basic_params['setting']['first_prize'] = $level_config['first_prize'];
            $basic_params['setting']['computing_money'] = $computing_money;
            $basic_params['setting']['frozen_money'] = $frozen_money;
            $basic_params['setting'] = Json::encode($basic_params['setting']);
            if(self::isLandaHealth($first_user['user_id'],$basic_params['price'],$goods_id,'first_prize')){
                self::$reward[DoubleCopyEnum::FIRST_PRIZE] = array_merge($basic_params, [
                    'user_id' => $first_user['user_id'],
                    'original_money' => $money,
                    'money' => $money - $frozen_money,
                    'capital_type' => DoubleCopyEnum::FIRST_PRIZE,
                ]);
            }
            

            return true;
        } catch (\Exception $e) {
            self::setStaticError("直推奖错误：第" . $e->getLine().'行，原因：'.$e->getMessage());
            return false;
        }
    }

    /**
     * 间推奖励
     * @Author: lun
     * @DateTime: 2023/5/30 0030 14:05
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $level
     * @param $computing_config
     * @param $basic_params
     * @return array|bool
     */
    public static function IndirectPrize($level, $computing_config, $basic_params,$goods_id=0)
    {
        try {
            $multiple = $computing_config['multiple'];// 商品数量

            $indirect_arr = [];// 初始化间推奖励用户

            // 获取直推+平台补贴用户
            foreach (self::$reward as $key => $item) {
                // 目前间推奖只包括平台补贴、直推用户上级才可拥有
                if (in_array($item['capital_type'], [DoubleCopyEnum::FIRST_PRIZE, DoubleCopyEnum::SECOND_PRIZE, DoubleCopyEnum::FREEZE_FUND])) {
                    // 计算该用户总共得到的奖励
                    $indirect_arr[$item['user_id']] = empty($indirect_arr[$item['user_id']]) ? $item['money'] : $indirect_arr[$item['user_id']] + $item['money'];
                }
            }

            if ($indirect_arr) {
                foreach ($indirect_arr as $user_id => $computing_money) {
                    // 获取该用户的上级，因为间推奖励只给得到直推或平台补贴用户的上级，所以需要查询上级
                    $parent_id = User::find()->select('parent_id')->where(['id' => $user_id])->scalar();
                    if (empty($parent_id)) continue;

                    // 获取该上级的二二复制身份等级
                    $user = DoubleCopyUser::find()->select('level,upgrade_level_at,goods_info,mall_id')->where(['user_id' => $parent_id, 'status' => StatusEnum::ENABLED])->asArray()->one();
                    if (empty($user)) continue;

                    // 获取等级配置
                    $level_config = $level[$user['level']];
                    if (empty($level_config['indirect_prize'])) continue;// 奖励设置0直接退出

                    // 计算直推奖励金额
                    if ($level_config['indirect_prize_type'] == 0) {
                        $money = $computing_money * $level_config['indirect_prize'] / 100;
                        $money = sprintf("%.2f",substr(sprintf("%.3f", $money), 0, -1));// 保留两位小数并不四舍五入
                    } else {
                        // 按固定金额计算
                        $money = $level_config['indirect_prize'] * $multiple;
                    }

                    if ($money <= 0) continue;

                    // 生成奖励明细数据
                    $setting['indirect_prize_type'] = $level_config['indirect_prize_type'];// 奖励类型[百分比或金额]
                    $setting['indirect_prize'] = $level_config['indirect_prize'];// 奖励比例或金额
                    $setting['computing_money'] = $computing_money;// 奖励计算金额(只针对百分比奖励有用)
                    $setting['source_uid'] = $user_id;// 奖励来源于那个用户
                    $basic_params['setting'] = Json::encode($setting);
                    if(self::isLandaHealth($parent_id,$basic_params['price'],$goods_id,'indirect_prize')){
                        self::$reward[DoubleCopyEnum::INDIRECT_PRIZE.'_'.$parent_id] = array_merge($basic_params, [
                            'user_id' => $parent_id,
                            'original_money' => $money,
                            'money' => $money,
                            'capital_type' => DoubleCopyEnum::INDIRECT_PRIZE,
                        ]);
                    }
                }
            }
            return true;
        } catch (\Exception $e) {
            self::setStaticError("间推奖错误：第" . $e->getLine().'行，原因：'.$e->getMessage());
            return false;
        }
    }


    /**
     * 平台补贴
     * @Author: lun
     * @DateTime: 2022/5/17 0017 14:09
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $buy_user
     * @param $level
     * @param $computing_config
     * @param $basic_params
     * @param $is_upgrade
     * @return array|bool
     */
    public static function SecondPrize(DoubleCopyUser &$buy_user, $level, $computing_config, $basic_params, $is_upgrade,$goods_id=0)
    {
        try {
            if (empty($buy_user['pid'])) return [];

            $computing_money = $computing_config['computing_money'];// 支付金额
            $multiple = $computing_config['multiple'];// 商品数量
            $config = $basic_params['setting'];// 基础设置

            /** 平台补贴用户临时计算，如果跟原来的平台补贴用户有变化则需要改变平台补贴用户, 开始 **/
            if ($buy_user->pos <= self::$upgrade_num) {
                // 获取上级用户
                $parent_ids = UserPartitionRelationship::getParentIdArr($buy_user['user_id']);
                $parent_ids = array_reverse($parent_ids);// 倒序数组

                foreach ($parent_ids as $key => $pid) {
                    // 查询上级是否有身份
                    $pdc_user = DoubleCopyUser::find()->select('user_id,pos,pid')->where(['user_id' => $pid, 'status' => StatusEnum::ENABLED])->asArray()->one();
                    
                    if (empty($pdc_user)) {
                        $has_identity = false;
                        self::$is_fracture = true;
                        // 获取当前用户的上级uid
                        $ppuid = $parent_ids[$key + 1] ?? 0;
                        if ($ppuid) {
                            // 统计跟此用户同级人数，并且判断当前用户的平级数量是否大于或等于2号位
                            $equal_num = DoubleCopyUser::find()->where(['pid' => $ppuid, 'status' => StatusEnum::ENABLED])->count();
                            if ($equal_num >= self::$upgrade_num) {// 符合位置则表示当前用户的上级必定是拿平台补贴用户(拿平台补贴用户可以没有身份)
                                $topid = $ppuid;
                                break;
                            }
                        }
                    } else {
                        $has_identity = true;
                        // 如果当前位置是大于或等于3号位则表示此用户上级必定是老板
                        if ($pdc_user['pos'] > self::$upgrade_num) {
                            $topid = $pdc_user['pid'];
                            break;
                        }
                    }
                    $topid = $has_identity ? 0 : $pid;
                }

                // 临时检测的平台补贴用户id跟之前不同则需要修改平台补贴用户id
                if ($buy_user['topid'] != $topid) {
                    $buy_user->topid = $topid;
                    $buy_user->save();
                }
                // 二二复制关系链得平台补贴用户关系被中断后是否可得平台补贴
                if (self::$is_fracture == true && empty($config['fracture_reward'])) return [];
            } else {
                // 若本人位置大于2号位，则平台补贴必定是给到直推上级，但是上级却非二二复制用户，则不再给任何人平台补贴
                $puser = DoubleCopyUser::find()->select('user_id')->where(['user_id' => $buy_user['pid'], 'status' => StatusEnum::ENABLED])->asArray()->one();
                if (empty($puser)) return [];
            }
            /** 修改平台补贴用户， 结束 **/
            if (empty($buy_user->topid)) return [];

            // 获取拿平台补贴用户的等级
            $user = DoubleCopyUser::find()->where(['user_id' => $buy_user['topid'], 'status' => StatusEnum::ENABLED])->one();

            // 判断用户等级是否存在，不存在代表该上级并非代理或老板级别
            if (empty($user)) return [];
            if ($user['level'] < DoubleCopyEnum::LEVEL_BOSS) return [];// topid非老板直接退出

            // 获取等级配置
            $level_config = $level[$user['level']];

            // 直推上级跟平台补贴用户为同一人，并且是因为该用户下单导致上级升级的则不发奖励
            if ($buy_user['pid'] == $buy_user['topid']) {
                if ($buy_user['pos'] == self::$upgrade_num && $is_upgrade == true) return [];

                // 如果是1,2号位，并且平台补贴用户上级为平台，则无平台补贴获取
                if ($user['pid'] == 0 && $buy_user['pos'] <= self::$upgrade_num) return [];

                // 判断是否可以发送平台补贴，1=发送，2=不发送
                if (!empty($config['is_send_second']) && $config['is_send_second'] == 2) return [];
            } else {
                // 如果平台补贴用户的上级为平台则需要判断能否得到平台补贴
                if ($user['pos'] == 0) {
                    // 获取关系链从上往下第二个用户的位置，位置小于或等于2号位则表示用户平台补贴
                    $parent_arr = UserPartitionRelationship::getParentIdArr($buy_user['user_id']);
                    // 只需要判断topid的直推用户是否处于1、2号位即可，处于1、2号位则不给平台补贴
                    $pos_user = DoubleCopyUser::find()->select('user_id')->where(['pid' => $buy_user['topid'], 'status' => StatusEnum::ENABLED])->andWhere(['<=', 'pos', self::$upgrade_num])->column();
                    if (in_array($parent_arr[1], $pos_user)) return [];
                }
            }

            // 计算直推奖励金额
            if ($level_config['second_prize_type'] == 0) {
                // 按百分比计算
                $money = $computing_money * $level_config['second_prize'] / 100;
                $money = sprintf("%.2f",substr(sprintf("%.3f", $money), 0, -1));// 保留两位小数并不四舍五入
            } else {
                // 按固定金额计算
                $money = $level_config['second_prize'] * $multiple;
            }
            if ($money <= 0) return [];

            // 配置插入
            $setting = $basic_params['setting'];
            $setting['computing_money'] = $computing_money;

            // 查询是否开启了冻结基金
            $frozen_money = 0;
            if ($user['is_thaw'] != 1 && $level_config['freeze_fund_prize'] > 0) {
                // 判断该等级是否开启了解冻阶梯设置
                if (!empty($level[$user['level']]['open_ladder'])) {
                    $level_config['freeze_fund_prize'] = $level_config['freeze_fund_prize'] * (100 - $user['thaw_percent']) / 100;
                }
                // 计算冻结基金
                $frozen_money = $money * $level_config['freeze_fund_prize'] / 100;
                $frozen_money = sprintf("%.2f",substr(sprintf("%.3f", $frozen_money), 0, -1));// 保留两位小数并不四舍五入
                if ($frozen_money > 0) {
                    // 生成冻结基金数据
                    $setting['freeze_fund_prize'] = $level_config['freeze_fund_prize'];
                    $basic_params['setting'] = Json::encode($setting);
                    if(self::isLandaHealth($buy_user['topid'],$basic_params['price'],$goods_id,'freeze_fund')){
                        self::$reward[DoubleCopyEnum::FREEZE_FUND] = array_merge($basic_params, [
                            'user_id' => $buy_user['topid'],
                            'money' => $frozen_money,
                            'capital_type' => DoubleCopyEnum::FREEZE_FUND,
                        ]);
                    }
                }
            }

            // 生成奖励明细数据
            $setting['second_prize_type'] = $level_config['second_prize_type'];
            $setting['second_prize'] = $level_config['second_prize'];
            $basic_params['setting'] = Json::encode($setting);
            if(self::isLandaHealth($buy_user['topid'],$basic_params['price'],$goods_id,'second_prize')){
                self::$reward[DoubleCopyEnum::SECOND_PRIZE] = array_merge($basic_params, [
                    'user_id' => $buy_user['topid'],
                    'original_money' => $money,
                    'money' => $money - $frozen_money,// 可得平台补贴 = 总平台补贴 - 冻结基金
                    'capital_type' => DoubleCopyEnum::SECOND_PRIZE,
                ]);
            }
            //平台补贴极差
            if(!empty($config['second_prize_diff'])) self::secondPrizeDiff($user,$computing_config,$level,$basic_params,$goods_id);

            return true;
        } catch (\Exception $e) {
            self::setStaticError("平台补贴错误：第" . $e->getLine().'行，原因：'.$e->getMessage());
            return false;
        }
    }


    /**
     * 培育奖
     * @Author: lun
     * @DateTime: 2022/5/17 0017 14:19
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $buy_user
     * @param $level
     * @param $computing_money
     * @param $basic_params
     * @return array|bool
     */
    public static function EqualPrize($buy_user, $level, $computing_money, $basic_params, $multiple,$goods_id=0)
    { 
        try {
            if (empty($computing_money) || empty($buy_user['topid'])) return [];
            $config = $basic_params['setting'];
            // 如果关系链断层则需要判断配置是否给奖励
            if (self::$is_fracture == true && empty($config['fracture_reward'])) return [];

            // 获取平台补贴用户等级
            $top_user = DoubleCopyUser::find()->select('level,pid')->where(['user_id' => $buy_user['topid'], 'status' => StatusEnum::ENABLED])->asArray()->one();
            if (empty($top_user) || empty($top_user['pid'])) return [];
            
            // 注意：2023-03-08需求更改，获取获得平台补贴用户的直推上级，培育奖只能由平台补贴获得者的直推上级所拥有
            $top_parent_user = DoubleCopyUser::find()->select('user_id,level,mall_id,goods_info')->where(['user_id' => $top_user['pid'], 'status' => StatusEnum::ENABLED])->asArray()->one(); 
            if (empty($top_parent_user) || $top_parent_user['level'] < DoubleCopyEnum::LEVEL_BOSS) return [];// 当前用户等级必须要大于或等于老板等级
           
            $reward_uid = $top_parent_user['user_id'];// 培育奖获得者
            // 获取等级配置
            $level_config = $level[$top_parent_user['level']];

            // 计算直推奖励金额
            if ($level_config['equal_prize_type'] == 0) {
                // 按百分比计算
                $money = $computing_money * $level_config['equal_prize'] / 100;
                $money = sprintf("%.2f",substr(sprintf("%.3f", $money), 0, -1));// 保留两位小数并不四舍五入
            } else {
                // 按固定金额计算
                $money = $level_config['equal_prize'] * $multiple;
            }
            
            if ($money <= 0) return [];

            // 生成奖励明细数据
            $basic_params['setting']['equal_prize_type'] = $level_config['equal_prize_type'];
            $basic_params['setting']['equal_prize'] = $level_config['equal_prize'];
            $basic_params['setting']['computing_money'] = $computing_money;
            $basic_params['setting'] = Json::encode($basic_params['setting']);
            if(self::isLandaHealth($reward_uid,$basic_params['price'],$goods_id,'equal_prize')){
                self::$reward[DoubleCopyEnum::EQUAL_PRIZE] = array_merge($basic_params, [
                    'user_id' => $reward_uid,
                    'money' => $money,
                    'capital_type' => DoubleCopyEnum::EQUAL_PRIZE,
                ]);
            }

            return true;
        } catch (\Exception $e) {
            self::setStaticError("平级奖错误：第" . $e->getLine().'行，原因：'.$e->getMessage());
            return false;
        }
    }

    /**
     * 津贴奖
     * @Author: mz
     * @DateTime: 2023/06/27 0017 14:19
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $buy_user
     * @param $level
     * @param $computing_config
     * @param $basic_params
     * @return array|bool
     * allowance_price
     */
    public static function AllowancePrize($buy_user, $level, $second_computing_money, $basic_params, $multiple,$goods_id=0)
    {
        try {
            $first_prize = self::$reward[DoubleCopyEnum::FIRST_PRIZE] ?? [];
            $second_prize = self::$reward[DoubleCopyEnum::SECOND_PRIZE] ?? [];

            if(empty($first_prize) && empty($second_prize)){
                Yii::error('直推奖与平台补贴都不存在，不发放津贴奖');
                return [];
            }

            // 可以获得津贴奖用户：0=平台补贴上级，1=直推奖上级，2=平台补贴或直推奖上级
            $allowance_compute = $basic_params['setting']['allowance_compute'] ?? 0;
            $first_prize_uid = $first_prize['user_id'] ?? 0;// 直推奖获得用户
            $second_prize_uid = $second_prize['user_id'] ?? 0;// 平台补贴获得用户
            $first_computing_money = $first_prize['money'] ?? 0;  // 直推奖金额
            if ($allowance_compute == 0) $first_prize_uid = 0;// 平台补贴上级可得奖励时，直推用户直接改为无上级
            if ($allowance_compute == 1) $second_prize_uid = 0;// 直推奖上级可得奖励时，平台补贴用户直接改为无上级
            if ($first_prize_uid == $second_prize_uid && $first_prize_uid == 0) return [];// 无奖励的用户直接退出
            $is_same = $first_prize_uid == $second_prize_uid ? true : false;// 直推奖与平台补贴是否同一个人

            // 获取平台补贴用户等级
            $first_second_users = DoubleCopyUser::find()->select('user_id,level,pid,pos')->where(['user_id' => [$first_prize_uid,$second_prize_uid], 'status' => StatusEnum::ENABLED])->asArray()->all();
            if (empty($first_second_users)) return [];

            $reward_users = [];// 津贴奖用户
            $reward_level = $basic_params['setting']['allowance_level'] ?? 2;// 可获得奖励的等级，没有设置默认等级2
            foreach ($first_second_users as $item) {
                // 不符合条件的直接跳过
                if (empty($item['pid']) || $item['pos'] > self::$upgrade_num) continue;

                // 检测奖励津贴奖的上级是否可以得到奖励
                $user = DoubleCopyUser::find()->select('user_id,level,goods_info,mall_id')->where(['user_id' => $item['pid'], 'status' => StatusEnum::ENABLED])->asArray()->one();
                if ($user) {
                    if ($user['level'] < $reward_level) continue;// 等级不符合直接跳过
                    $user['child_uid'] = $item['user_id'];
                    $reward_users[] = $user;
                }
            }
            if (empty($reward_users)) return [];// 无奖励用户直接跳过

            foreach ($reward_users as $item) {
                if ($is_same) {
                    // 直推奖与平台补贴都是同一个人的上级结算金额
                    $computing_money = $second_computing_money + $first_computing_money;
                } else {
                    // 直推奖的上级结算金额
                    if (!empty($first_prize_uid) && $item['child_uid'] == $first_prize_uid) $computing_money = $first_computing_money;
                    // 平台补贴的上级的结算金额
                    if (!empty($second_prize_uid) && $item['child_uid'] == $second_prize_uid) $computing_money = $second_computing_money;
                }
                if (empty($computing_money)) continue;

                // 获取等级配置
                $level_config = $level[$item['level']];

                // 计算直推奖励金额
                if ($level_config['allowance_price_type'] == 0) {
                    // 按百分比计算
                    $money = $computing_money * $level_config['allowance_price'] / 100;
                    $money = sprintf("%.2f",substr(sprintf("%.3f", $money), 0, -1));// 保留两位小数并不四舍五入
                } else {
                    // 按固定金额计算
                    $money = $level_config['allowance_price'] * $multiple;
                }

                if ($money <= 0) return [];
                // 生成奖励明细数据
                if (!is_array($basic_params['setting'])) $basic_params['setting'] = json_decode($basic_params['setting'], true);
                $basic_params['setting']['allowance_price_type'] = $level_config['allowance_price_type'];
                $basic_params['setting']['allowance_price'] = $level_config['allowance_price'];
                $basic_params['setting']['computing_money'] = $computing_money;
                $basic_params['setting'] = Json::encode($basic_params['setting']);
                if(self::isLandaHealth($item['user_id'],$basic_params['price'],$goods_id,'allowance_price')){
                    self::$reward[DoubleCopyEnum::ALLOWANCE_PRICE . '_' . $item['user_id']] = array_merge($basic_params, [
                        'user_id' => $item['user_id'],
                        'money' => $money,
                        'capital_type' => DoubleCopyEnum::ALLOWANCE_PRICE,
                    ]);
                }
            }

            return true;
        } catch (\Exception $e) {
            self::setStaticError("津贴奖错误：第" . $e->getLine().'行，原因：'.$e->getMessage());
            return false;
        }
    }

    /**
     * 平级奖
     * @Author: lun
     * @DateTime: 2022/5/17 0017 14:19
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $buy_user
     * @param $level
     * @param $computing_money
     * @param $basic_params
     * @return array|bool
     */
    public static function EqualLevelPrize($buy_user, $level, $computing_money, $basic_params, $multiple,$goods_id=0)
    {
        try {
            if (empty($computing_money) || empty($buy_user['topid'])) return [];
            $config = $basic_params['setting'];
            // 如果关系链断层则需要判断配置是否给奖励
            if (self::$is_fracture == true && empty($config['fracture_reward'])) return [];

            // 获取平台补贴用户等级
            $top_user = DoubleCopyUser::find()->select('level,pid,topid')->where(['user_id' => $buy_user['topid'], 'status' => StatusEnum::ENABLED])->asArray()->one();
            if (empty($top_user) || empty($top_user['pid'])) return [];
            $equal_level_user = 0;
            //助力升级会员 获得平台补贴上级奖励平级奖
            if ($top_user['pos'] <= self::$upgrade_num) {
                $equal_level_user = $top_user['topid'];
            }else{
                $equal_level_user = $top_user['pid'];
            }
            if(empty($equal_level_user)) return [];
            $top_parent_user = DoubleCopyUser::find()->select('user_id,level')->where(['user_id' => $equal_level_user, 'status' => StatusEnum::ENABLED])->asArray()->one();
            if (empty($top_parent_user) || $top_parent_user['level'] < DoubleCopyEnum::LEVEL_BOSS) return [];// 当前用户等级必须要大于或等于老板等级
            $reward_uid = $top_parent_user['user_id'];// 平级奖获得者
            //与培育奖区别处：判断平级奖获得者的1、2号位是否大于或等于老板等级
            $cusers = DoubleCopyUser::find()
                ->where(['pid' => $reward_uid, 'status' => StatusEnum::ENABLED])
                ->andWhere(['<=','pos',self::$upgrade_num])
                ->select('user_id,level,goods_info,mall_id')
                ->asArray()
                ->all();
            foreach($cusers as $cuser){
                //平级奖获得者的1、2号位小于老板等级 不发放平级奖励
                if($cuser['level'] < DoubleCopyEnum::LEVEL_BOSS){
                    return [];
                }
            }
            // 获取等级配置
            $level_config = $level[$top_parent_user['level']];

            // 计算直推奖励金额
            if ($level_config['equal_level_prize_type'] == 0) {
                // 按百分比计算
                $money = $computing_money * $level_config['equal_level_prize'] / 100;
                $money = sprintf("%.2f",substr(sprintf("%.3f", $money), 0, -1));// 保留两位小数并不四舍五入
            } else {
                // 按固定金额计算
                $money = $level_config['equal_level_prize'] * $multiple;
            }

            if ($money <= 0) return [];
            if (!is_array($basic_params['setting'])) $basic_params['setting'] = json_decode($basic_params['setting'], true);
            // 生成奖励明细数据
            $basic_params['setting']['equal_level_prize_type'] = $level_config['equal_level_prize_type'];
            $basic_params['setting']['equal_level_prize'] = $level_config['equal_level_prize'];
            $basic_params['setting']['computing_money'] = $computing_money;
            $basic_params['setting'] = Json::encode($basic_params['setting']);
            if(self::isLandaHealth($reward_uid,$basic_params['price'],$goods_id,'equal_level_prize')){
                self::$reward[DoubleCopyEnum::EQUAL_LEVEL_PRIZE] = array_merge($basic_params, [
                    'user_id' => $reward_uid,
                    'money' => $money,
                    'capital_type' => DoubleCopyEnum::EQUAL_LEVEL_PRIZE,
                ]);
            }


            return true;
        } catch (\Exception $e) {
            self::setStaticError("平级奖错误：第" . $e->getLine().'行，原因：'.$e->getMessage());
            return false;
        }
    }

    /**
     * 获取订单计算金额
     * @Author: lun
     * @DateTime: 2022/5/17 0017 11:43
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $config
     * @param $order
     * @return mixed
     */
    private static function getComputingConfig($config, $order)
    {
        switch ($config['computing_method']) {
            case DoubleCopyEnum::COMPUTING_METHOD_PAY_PRICE:// 实际支付金额
                $computing_money = $order['goods_price'];
                break;
            case DoubleCopyEnum::COMPUTING_METHOD_GOODS_PRICE:// 商品售价
                $computing_money = $order['original_goods_price'];
                break;
            case DoubleCopyEnum::COMPUTING_METHOD_GOODS_PROFIT:// 商品利润
                $computing_money = $order['goods_price'] - $order['cost_price'] + $order['adjust_money'];;
                break;
        }
        return ['computing_money' => $computing_money, 'multiple' => $order['num']];
    }

    /**
     * 获取推荐的位数
     * @param $mall_id
     * @return void
     */
    public static function getUpgradeNum($mall_id)
    {
        $boss_level = DoubleCopyLevel::find()->select('upgrade_type_condition, checked_condition_values')->where(['mall_id' => $mall_id, 'level' => DoubleCopyEnum::LEVEL_BOSS, 'status' => StatusEnum::ENABLED])->asArray()->one();
        if ($boss_level['upgrade_type_condition'] == 1) {
            // json解析升级条件数量
            $json = Json::decode($boss_level['checked_condition_values'], true);
            self::$upgrade_num = $json[0]['value']['val0'] ?? 0;
        }
    }
    /**
     * 平台补贴极差
     * @param $mall_id
     * @return void
     */
    public static function secondPrizeDiff($user,$computing_config,$level,$basic_params,$goods_id=0){
        $topUser = DoubleCopyUser::find()->where(['user_id' => $user['topid'], 'status' => StatusEnum::ENABLED])->one();
        if(empty($topUser)) return true;
        
        if($topUser['level'] <= $user['level']){
            self::secondPrizeDiff($topUser,$computing_config,$level,$basic_params,$goods_id);
        }
        // 计算直推奖励金额
        $computing_money = $computing_config['computing_money'];// 支付金额
        $multiple = $computing_config['multiple'];// 商品数量
        $config = $basic_params['setting'];// 基础设置
        $level_config = $level[$topUser['level']];
        if ($level_config['second_prize_type'] == 0) {
            // 按百分比计算
            $money = $computing_money * $level_config['second_prize'] / 100;
            $money = sprintf("%.2f",substr(sprintf("%.3f", $money), 0, -1));// 保留两位小数并不四舍五入
        } else {
            // 按固定金额计算
            $money = $level_config['second_prize'] * $multiple;
        }

        //if ($money <= 0) return [];
        //已发放平级津贴
        $second_original_money = 0;
        foreach (self::$reward as $key =>  $reward) {
            if(strpos($key, DoubleCopyEnum::SECOND_PRIZE) !== false) {
                $second_original_money += $reward['money'];
            }
            if(strpos($key, DoubleCopyEnum::FREEZE_FUND) !== false) {
                $second_original_money += $reward['money'];
            }
        }
        $money = bcsub($money,$second_original_money,2);
        if ($money > 0){
            // 配置插入
            if (!is_array($basic_params['setting'])) $basic_params['setting'] = json_decode($basic_params['setting'], true);
            $setting = $basic_params['setting'];
            $setting['computing_money'] = $computing_money;

            // 查询是否开启了冻结基金
            $frozen_money = 0;
            if ($topUser['is_thaw'] != 1 && $level_config['freeze_fund_prize'] > 0) {
                // 判断该等级是否开启了解冻阶梯设置
                if (!empty($level[$topUser['level']]['open_ladder'])) {
                    $level_config['freeze_fund_prize'] = $level_config['freeze_fund_prize'] * (100 - $topUser['thaw_percent']) / 100;
                }
                // 计算冻结基金
                $frozen_money = $money * $level_config['freeze_fund_prize'] / 100;
                $frozen_money = sprintf("%.2f",substr(sprintf("%.3f", $frozen_money), 0, -1));// 保留两位小数并不四舍五入
                if ($frozen_money > 0) {
                    // 生成冻结基金数据
                    $setting['freeze_fund_prize'] = $level_config['freeze_fund_prize'];
                    $basic_params['setting'] = Json::encode($setting);
                    
                    if(self::isLandaHealth($user['topid'],$basic_params['price'],$goods_id,'freeze_fund')){
                        self::$reward[DoubleCopyEnum::FREEZE_FUND . '_' . $user['topid']] = array_merge($basic_params, [
                            'user_id' => $user['topid'],
                            'money' => $frozen_money,
                            'capital_type' => DoubleCopyEnum::FREEZE_FUND,
                        ]);
                    }
                }
            }

            // 生成奖励明细数据
            $setting['second_prize_type'] = $level_config['second_prize_type'];
            $setting['second_prize'] = $level_config['second_prize'];
            $basic_params['setting'] = Json::encode($setting);

            if(self::isLandaHealth($user['topid'],$basic_params['price'],$goods_id,'second_prize')){
                self::$reward[DoubleCopyEnum::SECOND_PRIZE . '_' . $user['topid']] = array_merge($basic_params, [
                    'user_id' => $user['topid'],
                    'original_money' => $money,
                    'money' => $money - $frozen_money,// 可得平台补贴 = 总平台补贴 - 冻结基金
                    'capital_type' => DoubleCopyEnum::SECOND_PRIZE,
                ]);  
            }
        }
        self::secondPrizeDiff($topUser,$computing_config,$level,$basic_params,$goods_id);
    }

    /**
     * 复购奖励极差
     * @param $mall_id
     * @return void
     */
    public static function repurchasePrizeDiff($user,$level, $computing_config, $basic_params,$goods_id=0){
        if ($user['pos'] <= self::$upgrade_num) {
            $user_id = $user['topid'];
        }else{
            $user_id = $user['pid'];
        }
        $pUser = DoubleCopyUser::find()->where(['user_id' => $user_id, 'status' => StatusEnum::ENABLED])->one();
        if(empty($pUser)) return true;

        // if($pUser['level'] <= $user['level']){
        //     self::repurchasePrizeDiff($pUser,$level, $computing_config, $basic_params);
        // }
        // 计算直推奖励金额
        $computing_money = $computing_config['computing_money'];// 支付金额
        $multiple = $computing_config['multiple'];// 商品数量
        $config = $basic_params['setting'];// 基础设置
        $level_config = $level[$pUser['level']];
        if ($level_config['repurchase_prize_type'] == 0) {
            // 按百分比计算
            $money = $computing_money * $level_config['repurchase_prize'] / 100;
            $money = sprintf("%.2f",substr(sprintf("%.3f", $money), 0, -1));// 保留两位小数并不四舍五入
        } else {
            // 按固定金额计算
            $money = $level_config['repurchase_prize'] * $multiple;
        }
        //if ($money <= 0) return [];
        //已发放复购奖励
        $repurchase_original_money = 0;
        foreach (self::$reward as $key =>  $reward) {
            if(strpos($key,DoubleCopyEnum::REPURCHASE_PRIZE) !== false) {
                $repurchase_original_money += $reward['money'];
            }
        }
        $money = bcsub($money,$repurchase_original_money,2);
        if ($money > 0){
            // 配置插入
            if (!is_array($basic_params['setting'])) $basic_params['setting'] = json_decode($basic_params['setting'], true);
            $setting = $basic_params['setting'];
            $setting['computing_money'] = $computing_money;
            $setting['repurchase_prize_type'] = $level_config['repurchase_prize_type'];
            $setting['repurchase_prize'] = $level_config['repurchase_prize'];
            $basic_params['setting'] = Json::encode($setting);
            if(self::isLandaHealth($user_id,$basic_params['price'],$goods_id,'repurchase_prize')){
                self::$reward[DoubleCopyEnum::REPURCHASE_PRIZE . '_' . $user_id] = array_merge($basic_params, [
                    'user_id' => $user_id,
                    'original_money' => $money,
                    'money' => $money,
                    'capital_type' => DoubleCopyEnum::REPURCHASE_PRIZE,
                ]);  
            }
        }
        self::repurchasePrizeDiff($pUser,$level, $computing_config, $basic_params,$goods_id);
    }

    public static function isLandaHealth($user_id,$price,$goods_id,$type){
        $res = true;
        $user = DoubleCopyUser::find()->where(['user_id' => $user_id, 'status' => StatusEnum::ENABLED])->one();
        $goods_info = Json::decode($user['goods_info'],true);
        $config = Yii::$app->services->setting->addons->get($user['mall_id'], AddonsEnum::ADDONS_LANDA_HEALTH, 'basic');
        $checkedName = [];
        if(isset($config['checkedName'])){
            $checkedName = Json::decode($config['checkedName'],true);
        }
        $goods_ids = [];
        if(isset($config['goods_ids'])){
            $goods_ids = Json::decode($config['goods_ids'],true);
        }
     
        if (MallAddons::isInstall($user['mall_id'], AddonsEnum::ADDONS_LANDA_HEALTH) == 1 && $goods_id>0 && isset($goods_info['goods_id']) && isset($goods_info['price']) && isset($config['is_enable']) && $config['is_enable']==1 && count($goods_ids)>=2 && in_array($goods_info['goods_id'],$goods_ids) && in_array($goods_id,$goods_ids) && (float)$goods_info['price'] < (float)$price && !in_array($type,$checkedName)) {
            $res = false;
        }

        return $res;
    }

    public static function contributionPrice($order, $basic_params, DoubleCopyUser &$buy_user)
    {
        try {
            if (self::$commission_type !== 'commission') {
                return [];
            }

            //topid 平台补贴计算过程中可能变化，重新获取
            $user = DoubleCopyUser::find()->where(['user_id' => $order['user_id'], 'status' => StatusEnum::ENABLED])->one();

            //需要安装二二复制贡献补贴奖插件
            if (!MallAddons::isInstall($user['mall_id'], AddonsEnum::ADDONS_NAME_DOUBLE_COPY_COMMITMENT_AWARD)) {
                return [];
            }
            $base_setting = Yii::$app->services->setting->addons->get($user['mall_id'], AddonsEnum::ADDONS_NAME_DOUBLE_COPY_COMMITMENT_AWARD, 'basic');

            if (empty($base_setting['is_enable'])) {
                return [];
            }

            $setting_goods_class = \addons\DoubleCopyCommitmentAward\common\models\DoubleCopyCommitmentAwardGoodsSetting::class;

            //获取商品贡献补贴奖设置
            $setting_goods_detail = $setting_goods_class::getOne([
                ['mall_id' => $order['mall_id']],
                ['goods_id' => $order['goods_id']],
                'status' => StatusEnum::ENABLED
            ], true);

            //商品需要存在于贡献补贴奖商品列表 且 商品需开启贡献补贴奖
            if (empty($setting_goods_detail) || empty($setting_goods_detail['is_reward'])) {
                return [];
            }

            //判断是否存在平台补贴
            if (self::$reward[DoubleCopyEnum::SECOND_PRIZE] && $user['topid']) {
                //商品是否存在独立设置

                if ($setting_goods_detail['is_alone'] == 1) {
                    //通过独立设置计算贡献补贴奖
                    $setting = $setting_goods_detail;

                    $platform_reward_value = $setting_goods_detail['user_reward_value'];
                } else {
                    //通过全局设置计算贡献补贴奖
                    $setting = $base_setting;

                    $platform_reward_value = $base_setting['user_reward_value'];
                }

                //按照获得的平台补贴奖百分比进行计算贡献补贴奖
                $money = bcmul($platform_reward_value / 100, self::$reward[DoubleCopyEnum::SECOND_PRIZE]['money'], 2);

                if ($user['pid'] == $user['topid']) {
                    $target_user_id = $order['user_id'];
                } else {
                    if ($buy_user->pos <= self::$upgrade_num) {
                        $parent_ids = UserPartitionRelationship::getParentIdArr($buy_user['user_id']);
                        $parent_ids = array_reverse($parent_ids);// 倒序数组

                        foreach ($parent_ids as $key => $pid) {
                            // 查询上级是否有身份
                            $pdc_user = DoubleCopyUser::find()->select('user_id,pos,pid')->where(['user_id' => $pid, 'status' => StatusEnum::ENABLED])->asArray()->one();

                            if (empty($pdc_user)) {
                                // 获取当前用户的上级uid
                                $ppuid = $parent_ids[$key + 1] ?? 0;
                                if ($ppuid) {
                                    // 统计跟此用户同级人数，并且判断当前用户的平级数量是否大于或等于2号位
                                    $equal_num = DoubleCopyUser::find()->where(['pid' => $ppuid, 'status' => StatusEnum::ENABLED])->count();
                                    if ($equal_num >= self::$upgrade_num) {// 符合位置则表示当前用户的上级必定是拿平台补贴用户(拿平台补贴用户可以没有身份)
                                        $target_user_id = $pid;
                                        break;
                                    }
                                }
                            } else {
                                // 如果当前位置是大于或等于3号位则表示此用户上级必定是老板
                                if ($pdc_user['pos'] > self::$upgrade_num) {
                                    $target_user_id = $pdc_user['user_id'];
                                    break;
                                }
                            }
                        }
                    } else {
                        $target_user_id = $user['pid'];
                    }
                }

            } else {
                if (!empty($user['topid'])) {
                    //见点奖用户不为平台，无需处理
                    return [];
                }

                if (empty($user['pid'])) {
                    $target_user_id = $order['user_id'];
                } else {
                    if ($buy_user->pos <= self::$upgrade_num) {
                        $parent_ids = UserPartitionRelationship::getParentIdArr($buy_user['user_id']);
                        $target_user_id = reset($parent_ids);
                    } else {
                        $target_user_id = $user['pid'];
                    }
                }


                if ($setting_goods_detail['is_alone'] == 1) {
                    $setting = $setting_goods_detail;
                    //通过独立设置计算贡献补贴奖
                    if ($setting_goods_detail['platform_reward_type'] == 1) {
                        //商品实付价百分比
                        $money = bcmul($setting_goods_detail['platform_reward_value'] / 100, $order['goods_price'], 2);
                    } else {
                        $money = $setting_goods_detail['platform_reward_value'];
                    }
                } else {
                    //通过全局设置计算贡献补贴奖
                    $setting = $base_setting;

                    //商品实付价百分比
                    $money = bcmul($base_setting['platform_reward_value'] / 100, $order['goods_price'], 2);
                }
            }

            if ($money <= 0) {
                return [];
            }

            $basic_params['setting'] = Json::encode($setting);

            self::$reward[DoubleCopyEnum::CONTRIBUTION_PRICE] = array_merge($basic_params, [
                'user_id' => $target_user_id,
                'original_money' => $money,
                'money' => $money * 1,// 可得平台补贴贡献奖
                'capital_type' => DoubleCopyEnum::CONTRIBUTION_PRICE,
            ]);

            return true;
        } catch (\Exception $e) {
            self::setStaticError("平台补贴贡献奖错误：第" . $e->getLine() . '行，原因：' . $e->getMessage());
            return false;
        }
    }
}