qimall/addons/Agent/common/logic/reward/AgentRewardByUpgrade.php

<?php

namespace addons\Agent\common\logic\reward;

use addons\Agent\common\enums\AgentEnum;
use addons\Agent\common\enums\ComputingEnum;
use addons\Agent\common\models\Agent;
use addons\Agent\common\models\AgentCommissionBasisLog;
use addons\Agent\common\models\AgentCommissionItemSetting;
use addons\Agent\common\models\AgentCommissionLevelSetting;
use addons\Agent\common\models\AgentLevel;
use addons\Agent\common\models\AgentTeamAchievement;
use addons\Agent\common\logic\reward\addons\area\AreaReward;
use addons\Area\common\enums\AreaEnum;
use common\enums\AddonsEnum;
use common\enums\GoodsTypeEnum;
use common\enums\RedisKeyEnum;
use common\enums\StatusEnum;
use common\enums\UserWalletEnum;
use common\helpers\LockHelper;
use common\models\goods\Goods;
use common\models\mall\Mall;
use services\common\UserWalletService;
use common\models\mall\MallAddons;
use common\models\order\Order;
use yii\db\Exception;

/**
 * @desc 渠道奖励
 * Class AgentReward
 * @Author: hua
 * @DateTime: 2021/10/27 15:24
 * @Copyright: copyright (c) 2021 广东七件事集团
 * @package addons\Agent\common\logic\reward
 */
class AgentRewardByUpgrade extends AgentBase
{
    public $level_config;//等级配置
    public $goods_config;//商品独立设置
    public $extension;//扩展
    public $order_detail = [];
    public $upgrade_agent;

    public function addFrozenCommission()
    {   
        // 验证
        $config = $this->getLevelConfig();
        ['money' => $money, 'multiple' => $multiple, 'extension' => $extension] = $this->getRules();
        //极差奖励代理
        $diff_agent = null;
        //平级奖励结束等级
        $last_agent_level = 0;
        if (empty($this->team_prize_agents)) {
            foreach ($this->agent_list as $key => $agent) {
                var_dump($agent->user_id);
                if($diff_agent && $agent->level >= $diff_agent->level){
                    $this->team_prize_agents[$key] = $agent;
                    if($agent->level > $diff_agent->level){
                        $last_agent_level = $agent->level;
                        break;
                    }
                }elseif ($agent->level > $this->upgrade_agent->level){
                    $diff_agent = $agent;

                }
            }
        }
        if(empty($diff_agent)) return true;
        //计算渠道奖励
        $equal_prize_start = 0;
        $equal_prize_end = 0;
        $team_prize_list = [];
        if (isset($config[$diff_agent->level])) {
            $equal_prize_start = $this->computing($config[$diff_agent->level], $money, 'team', $multiple);
            if($equal_prize_start > 0){
                $team_prize_list[$diff_agent->user_id] = ['price' => $equal_prize_start, 'agent_id' => $diff_agent->id, 'agent_level' => $diff_agent->level];
            }
        }
        if (isset($config[$last_agent_level])) {
            $equal_prize_end = $this->computing($config[$last_agent_level], $money, 'team', $multiple);
        }
        $equal_prize = $equal_prize_end - $equal_prize_start;
        if(!empty($this->team_prize_agents) && $equal_prize > 0 ){
            // 获得奖励经销商数量
            $all_agent_num = count($this->team_prize_agents);
            $equal_prize = $equal_prize / $all_agent_num;

            foreach ($this->team_prize_agents as $key => $team_agent) {
                // 批处理组装数据
                $team_prize_list[$team_agent->user_id] = ['price' => $equal_prize, 'agent_id' => $team_agent->id, 'agent_level' => $team_agent->level];
            }
        }
        $insert_wallet = $this->packData(ComputingEnum::EQUAL_UPGRADE, $this->basic_conf['compute_type'], $team_prize_list, $extension);
        // 批量插入数据
        $money = 0;
        try {
            //投递到资产队列
            if ($insert_wallet) {
                foreach ($insert_wallet as $k => $user) {
                    $agent = Agent::findOne(['user_id' => $user['user_id'],'status'=>[StatusEnum::DISABLED,StatusEnum::ENABLED], 'mall_id' => $this->mall_id]);
                    if(empty($agent)) continue;
                    $field = 'total_' . ($this->commission_name_map[$this->name] ?? $this->name);
                    $agent->$field += $user['money'];
                    if (!in_array($user['capital_type'], [ComputingEnum::DRAINAGE_SUBSIDY_PRIZE, ComputingEnum::TEAM_SUBSIDY_PRIZE])) {
                        $money += $user['money'];
                    }
                    $res = $agent->save();
                    if (empty($res)) throw new \Exception(Agent::getStaticError());
                }
            }
            //$this->addRewardConfigLog();
            return $money;
        } catch (\Exception $e) {
            echo 'AgentRewardByUpgrade:addFrozenCommission' . $e->getMessage();
            return 0;
        }

    }
    /**
     * @desc:等级配置
     * @Author: hua
     * @Date: 2021/10/28
     * @Time: 16:09
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return array
     */
    public function getLevelConfig()
    {
        $params['where'] = [['mall_id' => $this->mall_id], ['status' => StatusEnum::ENABLED]];
        $params['select'] = 'id,mall_id,level,name,is_auto_upgrade,upgrade_type_condition,checked_condition_values,checked_condition_keys,condition_type,
        upgrade_type_goods,buy_goods_type,goods_type,goods_ids,goods_list,explain,status';
        $name = $this->name;
        $mall_id = $this->mall_id;
        $params['with'] = ['commissionLevelSetting' => function ($query) use ($name, $mall_id) {
            $query->where(['commission_type' => $name, 'mall_id' => $mall_id, 'status' => StatusEnum::ENABLED])
                ->select('id,mall_id,level,commission_type,from_type,is_percent_team,is_percent_equal,
            is_percent_over,is_percent_extra,agent_team_prize,agent_equal_prize,agent_over_prize,agent_extra_prize,status,is_alone_agent_equal_prize,alone_agent_equal_prize_info');
        }];
        $agent_level_list = AgentLevel::lists($params);
        $config_arr = [];
        foreach ($agent_level_list as $item) {
            $item['commissionLevelSetting']['alone_agent_equal_prize_info'] = !empty($item['commissionLevelSetting']['alone_agent_equal_prize_info']) ? json_decode($item['commissionLevelSetting']['alone_agent_equal_prize_info'],true) : [];
            $config_arr[$item['level']] = $item['commissionLevelSetting'];
        }
        $this->level_config = $config_arr;

        $where = [['item_id' => $this->order_detail['goods_id']], ['item_type' => 'goods'], ['commission_type' => $name], ['mall_id' => $this->mall_id], ['status' => StatusEnum::ENABLED]];
        $select = 'id,mall_id,is_enable,item_id,item_type,commission_type,is_percent_team,is_percent_equal,is_percent_over,is_percent_extra,status,
        is_percent_drainage_subsidy,is_percent_team_subsidy,is_percent_recommend,is_enable_recommend,is_alone_agent_equal_prize,alone_agent_equal_prize_type';
        $with = ['detail' => function ($query) {
            $query->select('id,mall_id,agent_commission_item_setting_id,level,agent_team_prize,agent_equal_prize,agent_over_prize,agent_extra_prize,status,
            agent_drainage_subsidy_prize,agent_team_subsidy_prize,extra_equal_prize1,extra_equal_prize2,agent_recommend_prize,alone_agent_equal_prize_info');
        }];
        $agent_goods_setting = AgentCommissionItemSetting::getOne($where, true, $with, false, $select);

        if (!empty($agent_goods_setting)) {
            if ($agent_goods_setting['commission_type'] == $name && $agent_goods_setting['is_enable']) {
                $config_arr = [];
                foreach ($agent_goods_setting['detail'] as $val) {
                    $config_arr[$val['level']] = [
                        'is_percent_team' => $agent_goods_setting['is_percent_team'],
                        'is_percent_equal' => $agent_goods_setting['is_percent_equal'],
                        'is_percent_over' => $agent_goods_setting['is_percent_over'],
                        'is_percent_extra' => $agent_goods_setting['is_percent_extra'],
                        'is_percent_drainage_subsidy' => $agent_goods_setting['is_percent_drainage_subsidy'],
                        'is_percent_team_subsidy' => $agent_goods_setting['is_percent_team_subsidy'],
                        'agent_team_prize' => $val['agent_team_prize'],
                        'agent_equal_prize' => $val['agent_equal_prize'],
                        'agent_over_prize' => $val['agent_over_prize'],
                        'agent_extra_prize' => $val['agent_extra_prize'],
                        'agent_drainage_subsidy_prize' => $val['agent_drainage_subsidy_prize'],
                        'agent_team_subsidy_prize' => $val['agent_team_subsidy_prize'],
                        'extra_equal_prize1' => $val['extra_equal_prize1'],
                        'extra_equal_prize2' => $val['extra_equal_prize2'],
                        'is_percent_recommend' => $agent_goods_setting['is_percent_recommend'] ?? 0,
                        'is_enable_recommend' => $agent_goods_setting['is_enable_recommend'] ?? 0,
                        'agent_recommend_prize' => $val['agent_recommend_prize'] ?? 0,
                        'is_alone_agent_equal_prize' => $agent_goods_setting['is_alone_agent_equal_prize'] ?? 0,
                        'alone_agent_equal_prize_info' => $val['alone_agent_equal_prize_info'] ? json_decode($val['alone_agent_equal_prize_info'],true) : [],

                    ];
                    //开启独立平级奖 平级奖励类型改为独立平级奖的设置
                    if(!empty($agent_goods_setting['is_alone_agent_equal_prize'])){
                        $config_arr[$val['level']]['is_percent_equal'] = $agent_goods_setting['alone_agent_equal_prize_type'] ?? 0;
                    }
                }
                $this->goods_config = $config_arr;
            }
        }
        return $config_arr;
    }

    /**
     * @desc:奖励规则
     * @Author: hua
     * @Date: 2021/10/28
     * @Time: 16:08
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return array
     */
    public function getRules(int $method = null)
    {
        $method = isset($method) ? $method : $this->basic_conf['computing_method'];         // 不传则用默认的计算方式
        //0支付价格1商品售价2商品利润
        $money = $this->order_detail['goods_price']??0;
        $multiple = $this->order_detail['num'] ?? 1;
        switch ($method) {
            case ComputingEnum::COMPUTING_METHOD_PAY_PRICE:
                $adjust_money = $this->order_detail['adjust_money']??0;
                $money = $this->order_detail['goods_price']??0;
                $money = (($money+$adjust_money)/$multiple);
                break;
            case ComputingEnum::COMPUTING_METHOD_GOODS_PRICE:
                $money = $this->order_detail['original_goods_price']??0;
                $money = ($money/$multiple);
                break;
            case ComputingEnum::COMPUTING_METHOD_GOODS_PROFIT:
                $goods_price = $this->order_detail['goods_price']??0;
                $cost_price = $this->order_detail['cost_price']??0;
                $adjust_money = $this->order_detail['adjust_money']??0;
                $money = ($goods_price/$multiple) - $cost_price+$adjust_money/$multiple;
                if($money<0) $money= 0;
                break;
        }
        $extension = ['source_table' => 'order_detail', 'source_table_id' => $this->order_detail['id']??0, 'from_type' => AgentEnum::ADDONS_NAME];
        $this->extension = $extension;
        return ['money' => $money, 'multiple' => $multiple, 'extension' => $extension];
    }

    /**
     * @desc:记录每次触发奖励的相关配置
     * @Author: hua
     * @Date: 2021/11/18
     * @Time: 11:09
     * @Copyright: copyright (c) 2021 广东七件事集团
     */
    public function addRewardConfigLog()
    {
        $extension = $this->extension;
        $add_data['source_table'] = $extension['source_table'];
        $add_data['source_table_id'] = $extension['source_table_id'];
        $add_data['type'] = $this->name;
        $add_data['from_type'] = $extension['from_type'];
        $add_data['basic_config'] = !empty($this->basic_conf) ? json_encode($this->basic_conf) : '';
        $add_data['level_config'] = !empty($this->level_config) ? json_encode($this->level_config) : '';
        if (!empty($this->goods_config)) $add_data['goods_config'] = json_encode($this->goods_config);
        $agent_arr = [];
        foreach ($this->agent_list as $agent) {
            $agent_arr[$agent['id']] = [
                'user_id' => $agent['user_id'],
                'level' => $agent['level'],
            ];
        }
        $add_data['relation_ship'] = !empty($agent_arr) ? json_encode($agent_arr) : '';
        $add_data['mall_id'] = $this->mall_id;
        $add_data['status'] = StatusEnum::ENABLED;
        $res = AgentCommissionBasisLog::setData($add_data);
        if ($res == false) echo 'AgentReward:addRewardConfigLog:err:' . AgentCommissionBasisLog::getStaticError();
    }


    /**
     * @desc:组装数据
     * @Author: hua
     * @Date: 2021/11/18
     * @Time: 15:29
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $capital_type //奖励类型
     * @param $compute_type //支付完成/订单完成结算
     * @param $prize_list //奖励列表
     * @param $extension //扩展列表
     * @param $deduct_prize_list //扣减奖励
     * @return array
     */
    public function packData($capital_type, $compute_type, $prize_list, $extension, $deduct_prize_list = [])
    {
        $type_map = ComputingEnum::getTypeMap();
        $insert_wallet = [];
        $is_frozen = true;
        $goods_id = $this->order_detail['goods_id'];
        $goods = Goods::findOne(['id'=>$goods_id]);
        if($goods['goods_type']==GoodsTypeEnum::GoodsTypeVirtual){
            //虚拟商品，支付后-直接订单完成，所以直接结算
            $is_frozen = false;
        }else{
            if ($compute_type == ComputingEnum::ORDER_PAY) $is_frozen = false;
            if ($compute_type == ComputingEnum::ORDER_FINISH) $is_frozen = true;
        }
        $from_type = $extension['from_type'] ?? AgentEnum::ADDONS_NAME;
        foreach ($prize_list as $user_id => $item) {
            //渠道内购,商品抵扣
            if ($capital_type == ComputingEnum::TEAM_PRIZE && !empty($this->basic_conf['is_self_buy']) && !empty($this->basic_conf['enable_goods_deduct']) && $this->user_id == $user_id) {
                continue;
            }
            if (!empty($deduct_prize_list[$user_id]['deduct_money'])) $item['price'] -= $deduct_prize_list[$user_id]['deduct_money'];
            $item['price'] = bcmul($item['price'],1,2);
            if ($item['price'] > 0) {
                $prize_name = $type_map[$capital_type] ?? '未知资金类型';
                if($capital_type == ComputingEnum::TEAM_PRIZE){
                    $item_prize_type = $item['prize_type'] ?? '';
                    $prize_name = $item_prize_type == ComputingEnum::RECOMMEND_PRIZE ? $type_map[ComputingEnum::RECOMMEND_PRIZE] : $type_map[ComputingEnum::TEAM_PRIZE];
                }
                $order_desc = $this->order_detail['order_id'];
                if ($this->repurchase_reward && $user_id == $this->user_id) {
                    $order_desc = "复购订单[{$this->order_detail['order_id']}]";
                }
                $desc = '用户(' . $user_id . '),获得订单(' . $order_desc . ')奖励,奖励类型:' . $prize_name . ',金额:' . ($this->is_additional_score ? '{{money}}' : $item['price']);
                //    echo $desc.PHP_EOL;
                $insert_wallet [] = ['mall_id' => $this->mall_id, 'user_id' => $user_id,
                    'is_frozen' => $is_frozen,
                    'wallet_type' => $this->commission_name_map[$this->name] ?? $this->name,
                    'money' => $item['price'],
                    'desc' => $desc,
                    'source_table' => $extension['source_table'] ?? '',
                    'source_table_id' => $extension['source_table_id'] ?? '',
                    'from_type' => $from_type,
                    'capital_type' => $capital_type,
                    'order_no' =>$this->order_detail['order_no'],
                    'contributor_name' =>$this->order_detail['goods_name'],
                    'contributor_id' =>$this->user_id,
                    'contributor_money' =>$this->order_detail['goods_price'],
                ];
            }
        }
        return $insert_wallet;
    }

    /**
     * @desc:获取投入资金队列的数据
     * @Author: hua
     * @Date: 2021/11/18
     * @Time: 15:46
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $team_prize_list
     * @param $equal_prize_list
     * @param $extra_prize_list
     * @param $over_prize_list
     * @param $deduct_agent_prize_list
     * @return array
     */
    public function getInsertWalletData($team_prize_list, $equal_prize_list, $extra_prize_list, $over_prize_list, $deduct_agent_prize_list)
    {

    }
}