qimall/addons/CloudStockTwo/common/logic/reward/LevelRewardLogic.php

<?php


namespace addons\CloudStockTwo\common\logic\reward;

use addons\CloudStockTwo\common\models\CloudStockTwoAgent;
use app\plugins\cloud_stock\helpers\BonusMessage;
use app\plugins\cloud_stock\helpers\SmsConfig;
use common\enums\UserWalletEnum;
use Overtrue\EasySms\EasySms;
use addons\CloudStockTwo\common\models\CloudStockTwoLevel;
use addons\CloudStockTwo\common\models\CloudStockTwoFillOrder;
use addons\CloudStockTwo\common\models\CloudStockTwoGoods;
use common\enums\StatusEnum;
use common\enums\AddonsEnum;
use common\models\user\UserPartitionRelationship;
use common\helpers\ArrayHelper;
use common\models\user\User;
use common\models\order\Order;
use common\models\order\OrderDetail;
use common\enums\OrderStatusEnum;
class LevelRewardLogic
{   
    public $user_id;
    public $mall_id;
    public $reward_unit_price;
    public $agent;
    public $parent_agent;
    public $desc;
    public $level_name;
    public $fill_order;
    public $order_price;
    public $goods_id;
    public $num;
    public $order_type;
    public $order_id;

    public function __construct($mall_id,$agent,$order_type,$order_id,$level_name = '',$price=0,$goods_id=0,$num=0){
        $this->agent = $agent;
        $this->user_id = $agent->user_id;
        $this->level_name = $level_name;
        $this->mall_id = $mall_id;
        $this->order_price = $price;
        $this->goods_id = $goods_id;
        $this->num = $num;
        $this->order_type = $order_type;
        $this->order_id = $order_id;
    }
    /**
     * 直推代理奖励
     */
    public function addRewardLog()
    {   
        $this->getRewardUnitPrice();
        //奖励金额，不记录
        if (empty($this->reward_unit_price)) return false;
        //投递到资产队列
        $insert_wallet = $this->getInsertWallet(UserWalletEnum::FIRST);
        if ($insert_wallet) CloudStockTwoAgent::sendUserWalletQueue($insert_wallet);
    }

    /**
     * 代理补货奖励
     */
    public function addFillRewardLog($order)
    {   
        if($order['is_first']){
            return false;
        }
        $this->fill_order = $order;
        $this->getFillRewardUnitPrice();
        //奖励金额，不记录
        if (empty($this->reward_unit_price)) return false;
        //投递到资产队列
        $insert_wallet = $this->getInsertWallet(UserWalletEnum::FIRST);
        if ($insert_wallet) CloudStockTwoAgent::sendUserWalletQueue($insert_wallet);
    }
    /**
     * 获取对应等级商品奖励金额单价
     */
    protected function getRewardUnitPrice()
    {   
        $user = User::findOne(['id'=>$this->user_id]);
        if(!$user || !$user['parent_id']){
            $this->reward_unit_price = 0;
            return false;
        }

        $parent_agent = CloudStockTwoAgent::findOne(['user_id' => $user['parent_id'], 'mall_id' => $this->mall_id,'status'=>StatusEnum::ENABLED]);
        $this->parent_agent = $parent_agent;
        if(!$parent_agent){
            $this->reward_unit_price = 0;
            return false;
        }

        $parent_agent_level = CloudStockTwoLevel::findOne(['mall_id' => $this->mall_id, 'level' => $parent_agent['level'], 'status' => StatusEnum::ENABLED]);

        if(!$parent_agent_level || empty($parent_agent_level['is_recommender_reward'])){
            $this->reward_unit_price = 0;
            return false;
        }
        $agent_setting_info = json_decode($parent_agent_level['agent_setting_info'],true);
        if(empty($agent_setting_info)){
            $this->reward_unit_price = 0;
            return true;
        }
        foreach($agent_setting_info as $info){
            if($this->agent['level'] == $info['value']){
                if(isset($info['type']) && $info['type'] == 1){
                    $this->reward_unit_price = $info['value1'];
                }else{
                    $agent_price = CloudStockTwoGoods::getReplenshPrice($this->mall_id,$this->parent_agent['level'],[$this->goods_id]) ?? 0;
                    $this->reward_unit_price = $this->order_price - $agent_price * $this->num;
                }

                $this->desc = '直推代理(ID:'.$this->user_id.')升级为【'.$this->level_name.'】奖励';
                return true;
            }
        }
        $this->reward_unit_price = 0;
        return true;
    }

    /**
     * 获取对应等级商品奖励金额单价
     */
    protected function getFillRewardUnitPrice()
    {   
        $user = User::findOne(['id'=>$this->user_id]);
        if(!$user || !$user['parent_id']){
            $this->reward_unit_price = 0;
            return false;
        }
        $parent_agent = CloudStockTwoAgent::findOne(['user_id' => $user['parent_id'], 'mall_id' => $this->mall_id,'status'=>StatusEnum::ENABLED]);
        $this->parent_agent = $parent_agent;
        // 存在上级代理 以及 与上级代理平级 拿直推利润
        if(!$parent_agent || $parent_agent['level'] != $this->agent['level']){
            $this->reward_unit_price = 0;
            return false;
        }
        $parent_agent_level = CloudStockTwoLevel::findOne(['mall_id' => $this->mall_id, 'level' => $parent_agent['level'], 'status' => StatusEnum::ENABLED]);



        if(!$parent_agent_level || empty($parent_agent_level['recommender_settle_rate'])){
            $this->reward_unit_price = 0;
            return false;
        }
        $this->reward_unit_price = $this->fill_order['pay_money'] *  $parent_agent_level['recommender_settle_rate'] / 100;
        $this->desc = '直推代理(ID:'.$this->user_id.')补货奖励';
        if($parent_agent_level['is_recommender_condition'] && $parent_agent_level['recommender_condition_prize']){
            $parent_fill_total = CloudStockTwoFillOrder::find()->where(['mall_id'=>$this->mall_id,'user_id'=>$parent_agent['user_id'],'status'=>StatusEnum::ENABLED,'is_pay'=>1])->sum('pay_money');
            if($parent_fill_total < $this->reward_unit_price * $parent_agent_level['recommender_condition_prize'] / 100){
                $this->reward_unit_price = 0;
                return false;
            }
        }

        return true;
    }

    public function getInsertWallet($capital_type)
    {
        $insert_wallet = [];
        $commission_num = $this->reward_unit_price;
        if(empty($commission_num)) return $insert_wallet;
        $is_frozen = false;
        if ($this->order_type == 'buying') {
            $source_table = OrderDetail::tableName();
            $order_detail = OrderDetail::findOne(['order_id'=>$this->order_id]);
            $source_table_id = $order_detail->id;
            $order = Order::findOne(['id'=>$this->order_id]);
            //订单完成后才结算货款
            if($order['order_status']!=OrderStatusEnum::ACCOMPLISH)$is_frozen = true;
        } else {
            $source_table = CloudStockTwoFillOrder::tableName();
        }
        $source_table_id = $this->order_id;
        $configs = \Yii::$app->services->setting->addons->get($this->mall_id, AddonsEnum::ADDONS_NAME_CLOUD_STOCK_TWO, 'basic');
        $service_charge = 0;
        if($configs['platform_fee']){
            $service_charge = $commission_num * $configs['platform_fee'] / 100;
            $service_charge  = bcmul($service_charge,1,2);
            $commission_num = bcsub($commission_num,$service_charge,2);
            if(empty($commission_num)) return $insert_wallet;
            $this->desc .= ',平台管理费扣除：'.$service_charge.'元';
        }
        $insert_wallet[] = [
            'mall_id' => $this->mall_id,
            'user_id' => $this->parent_agent->user_id,
            'is_frozen' => $is_frozen, 
            'wallet_type' => 'commission', 
            'money' => $commission_num,
            'desc' => $this->desc,
            'source_table' => $source_table,
            'source_table_id' => $source_table_id,
            'from_type' => AddonsEnum::ADDONS_NAME_CLOUD_STOCK_TWO,
            'capital_type' => $capital_type,
            'service_charge' => $service_charge,
        ];
        return $insert_wallet;
    }
}