qimall/addons/CircleDistribution/common/logic/reward/DistributionReward.php

<?php

namespace addons\CircleDistribution\common\logic\reward;

use addons\CircleDistribution\common\enums\DistributionEnum;
use addons\CircleDistribution\common\enums\ComputingEnum;
use addons\CircleDistribution\common\models\DistributionCommissionBasisLog;
use addons\CircleDistribution\common\models\DistributionCommissionItemSetting;
use common\enums\GoodsTypeEnum;
use common\enums\StatusEnum;
use common\models\goods\Goods;
use common\models\user\UserPartitionRelationship;

/**
 * @desc 分销商奖励
 * Class DistributionReward
 * @Copyright: copyright (c) 2022 广东七件事集团
 * @package addons\Agent\common\logic\reward
 */
class DistributionReward extends DistributionBase
{
    public $reward_config;//会员奖励配置
    public $goods_config;//商品独立设置
    public $extension;//扩展

    /**
     * @desc:等级配置
     * @Author: hua
     * @Date: 2021/10/28
     * @Time: 16:09
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @return array
     */
    public function getLevelConfig()
    {
        $mall_id = $this->mall_id;
        $name = $this->name;

        $where = [['item_id' => $this->order_detail['goods_id']], ['mall_id' => $mall_id], ['item_type' => 'goods'], ['commission_type' => $name], ['status' => StatusEnum::ENABLED]];
        $distribution_goods_setting = DistributionCommissionItemSetting::getOne($where, true);

        $config_arr = [];

        if (!empty($distribution_goods_setting)) {
            if ($distribution_goods_setting['commission_type'] == $name) {
                $config_arr = [
                    'is_percent' => $distribution_goods_setting['is_percent'],
                    'list' => json_decode($distribution_goods_setting['commission_value'],true),
                    'is_not_involved_distribution' => $distribution_goods_setting['is_not_involved_distribution'],
                    'is_enable' => $distribution_goods_setting['is_enable']
                ];

                $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($source_table)
    {
        //0支付价格1商品售价2商品利润
        $multiple = $this->order_detail['num'] ?? 1;
        $money = $this->order_detail['goods_price'];
        switch ($this->basic_conf['computing_method']) {
            case ComputingEnum::COMPUTING_METHOD_PAY_PRICE:
                $goods_price = $this->order_detail['goods_price'] ?? 0;
                $adjust_money = $this->order_detail['adjust_money'] ?? 0;
                $money = ($goods_price + $adjust_money) / $multiple;
                break;
            case ComputingEnum::COMPUTING_METHOD_GOODS_PRICE:
                $money = $this->order_detail['original_goods_price']/$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;
                if($money<0) $money= 0;
                break;
        }
        $extension = ['source_table' => 'order_detail', 'source_table_id' => $this->order_detail['id'], 'from_type' => DistributionEnum::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 广东七件事集团
     * @param $extension
     */
    public function addRewardConfigLog($extension)
    {
        //$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) : '';
        $add_data['reward_config'] = !empty($this->reward_config) ? json_encode($this->reward_config) : '';
        $add_data['sequence'] = !empty($this->reward_config) ?  $this->reward_config['sequence'] : 1;
        $add_data['need_repurchase'] = !empty($this->reward_config) ?  $this->reward_config['need_repurchase'] : 0;

        if (!empty($this->goods_config)) $add_data['goods_config'] = json_encode($this->goods_config);
        $distribution_arr = [];
        foreach ($this->distribution_list as $agent) {
            $distribution_arr[$agent['id']] = [
                'user_id' => $agent['user_id'],
                'level' => $agent['level'],
            ];
        }
        $add_data['relation_ship'] = !empty($distribution_arr) ? json_encode($distribution_arr) : '';
        $add_data['mall_id'] = $this->mall_id;
        $add_data['status'] = StatusEnum::ENABLED;
        $add_data['user_id'] = $extension['distribution_user_id'];
        $res = DistributionCommissionBasisLog::setData($add_data);
        if ($res == false){
            echo 'DistributionReward:addRewardConfigLog:err:' . DistributionCommissionBasisLog::getStaticError();
            \Yii::error('DistributionReward:addRewardConfigLog:err:' . DistributionCommissionBasisLog::getStaticError());

        }
    }

    /**
     * @desc:组装插入数据
     * @Author: hua
     * @Date: 2021/10/28
     * @Time: 16:34
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $prize_list
     * @param $extension
     * @return array
     */
    public function packagingData($prize_list, $extension)
    {
        //投递到资产队列
        $state = ComputingEnum::DISTRIBUTION_FROZEN;
        if ($this->basic_conf['compute_type'] == ComputingEnum::ORDER_PAY) $state = ComputingEnum::DISTRIBUTION_FROZEN;
        $insert_wallet = [];
        $is_frozen = false;
        $goods_id = $this->order_detail['goods_id'];
        $goods = Goods::findOne(['id'=>$goods_id]);
//        if($goods['goods_type']==GoodsTypeEnum::GoodsTypeVirtual){
//            //虚拟商品，支付后-直接订单完成，所以直接结算
//            $is_frozen = false;
//        }else{
//            //if ($this->basic_conf['compute_type'] == ComputingEnum::ORDER_PAY) $is_frozen = false;
//            //if ($this->basic_conf['compute_type'] == ComputingEnum::ORDER_FINISH) $is_frozen = true;
//            $is_frozen = false;
//        }


        $from_type = $extension['from_type'] ?? DistributionEnum::ADDONS_NAME;
        foreach ($prize_list as $user_id => $item) {
            if($item['price']>0){
                $item['price'] = bcmul($item['price'],1,2);
                $prize_name = self::PRICE_NAME_MAP[$item['deep']] ?? '未知资金类型';
                $desc = '用户('.$user_id.'),获得订单('.$this->order_detail['order_id'].')分销商循环奖励,奖励类型:'.$prize_name.',金额:'.$item['price'];

                if($item['need_repurchase'] > 0)  $is_frozen = true;

                $insert_wallet [] = ['mall_id' => $this->mall_id, 'user_id' => $user_id,
                    'is_frozen' => $is_frozen, 'wallet_type' => $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' => $item['deep'],
                    '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;
    }


    /**
     * 根据订单 计算循环分销配置中对应佣金比例
     * @param $user_id
     * @param $parent_id
     * @return array|void
     */
    public function getRewardConfig($user_id,$parent_id)
    {
        if( $this->goods_config){
            $setting = $this->goods_config;
            
            if($setting['is_not_involved_distribution'] == 1){
                return ;
            }

            //商品独立设置
            if(!empty($setting['is_enable'])){
                if(!$setting['list']){
                    return ;
                }
            }else{
                $setting = $this->basic_conf[$this->name] ?? [];
                if($setting){
                    $setting = json_decode($setting,true);
                }
                if(empty($setting) || !isset($setting['list'])){
                    return ;
                }
            }
        }else{
            $setting = $this->basic_conf[$this->name] ?? [];
            if($setting){
                $setting = json_decode($setting,true);
            }
            if(empty($setting) || !isset($setting['list'])){
                return ;
            }
        }
        $count = count($setting['list']);

        $is_circle_repurchase = $this->basic_conf['is_circle_repurchase'] ?? 0;




        //查询该商城下 最后一笔订单的顺序
        $last_order = DistributionCommissionBasisLog::find()->where(['mall_id' => $this->mall_id,'from_type' => $this->extension['from_type'],'type' => $this->name,'user_id' => $parent_id])->orderBy(' id desc')->one();

        $index =  $last_order->sequence ?? 0;
        $need_repurchase = $last_order->need_repurchase ?? 0;  //上一个是否需要复购


        $index =  $index < $count ? $index : 0;

        $index =  $index+1;
        $sequence = $index % $count;
        $sequence = $sequence > 0 ? $sequence : $count;

        if($sequence == 1 && $last_order && $is_circle_repurchase){
            //下一次循环开始，第一笔订单，打开了复购开关
            $need_repurchase = 1;
        }

        //查询该笔订单 排序
        /**
        $order_count = DistributionCommissionBasisLog::find()->where(['user_id' => $parent_id,'mall_id' => $this->mall_id,'from_type' => $this->extension['from_type'],'type' => $this->name])->count();

        $index = $order_count + 1;


        $sequence = $index % $count;
        $sequence = $sequence > 0 ? $sequence : $count;
        $commission = $setting['list'][$sequence - 1]['value'] ?? 0;  //todo 这里可能要修改

         */

        $commission = $setting['list'][$sequence - 1]['value'] ?? 0;  //todo 这里可能要修改


        $config_arr = ['first_prize' => $commission,'is_percent' => $setting['is_percent'],'index' => $index,'sequence' => $sequence,'total' => $count,'need_repurchase' => $need_repurchase];
        $this->reward_config = $config_arr;

        return $config_arr;

    }


    /**
     * 获取循环分销配置中对应佣金比例
     * @desc  以下是按照会员顺序去 循环计算 佣金比例，已废弃
     * @param $user_id
     * @param $parent_id
     * @return array|void
     */
    public function getRewardConfigBak($user_id,$parent_id)
    {
        if( $this->goods_config){
            $setting = $this->goods_config;

            if(empty($setting) || !$setting['list']){
                return ;
            }

        }else{
            $setting = $this->basic_conf[$this->name] ?? [];
            if($setting){
                $setting = json_decode($setting,true);
            }
            if(empty($setting) || !isset($setting['list'])){
                return ;
            }
        }

        $count = count($setting['list']);
        //查询用户是上级的第几个会员

        $child_ids = UserPartitionRelationship::getChildIdArrOrderBy($parent_id,1);
        if(!in_array($user_id,$child_ids)){
            //查询有误，不在数组内
        }
        $index = array_search($user_id,$child_ids);
        $index = $index + 1;

        $sequence = $index % $count;
        $sequence = $sequence > 0 ? $sequence : $count;
        $commission = $setting['list'][$sequence - 1]['value'] ?? 0;  //todo 这里可能要修改

        $config_arr = ['first_prize' => $commission,'is_percent' => $setting['is_percent'],'index' => $index,'sequence' => $sequence,'total' => $count];
        $this->reward_config = $config_arr;

        return $config_arr;

    }
}