qimall/addons/BossWeight/common/logic/RewardLogLogic.php

<?php

namespace addons\BossWeight\common\logic;

use addons\BossWeight\common\enums\BossEnum;
use addons\BossWeight\common\models\AddonsBoss;
use addons\BossWeight\common\models\AddonsBossCommissionItemSetting;
use addons\BossWeight\common\models\AddonsBossLevelSetting;
use addons\BossWeight\common\models\AddonsBossRewardLog;
use common\enums\StatusEnum;
use common\helpers\FormatHelper;
use common\models\mall\MallAddons;
use common\models\order\Order;
use yii\helpers\Json;
use common\models\order\OrderDetail;
use common\traits\ErrorTrait;
use Exception;
use yii;

/**
 * Class RewardLog
 * @Author: lun
 * @DateTime: 2021/10/25 9:39
 * @Copyright: copyright (c) 2021 广东七件事集团
 * @package addons\BossWeight\common\logic
 */
class RewardLogLogic
{
    use ErrorTrait;

    /**
     * @Author: hua
     * @DateTime: 2021/10/18 9:57
     * @Copyright: copyright (c) 2021 广东七件事集团
     * @param $data
     * @return bool
     */
    public function execute($data)
    {
        try {
            // 查询订单信息
            $order = Order::getOne([['id' => $data['id']]],true,['detail'],false,'id,mall_id,order_no,order_status');
            if (empty($order)) throw new \yii\db\Exception("data[id]={$data['id']};order_id={$order['id']},查无此订单");
            if (empty($order['detail'])) throw new \yii\db\Exception("order_id={$order['id']},此订单详情为空");

            // 初始化数据
            $order_list = $order['detail'];
            $mallId = $order_list[0]['mall_id'];
            $calculate = [];// 佣金计算
            $amounts = 0;// 订单总金额
            $order_price = 0;//实付金额
            $date = date('Ymd', time());
            $time = time();

            // 判断用户插件是否安装
            if (MallAddons::isInstall($mallId, BossEnum::ADDONS_NAME) == 0) return true;

            // 获取基础配置
            $config = Yii::$app->services->setting->addons->get($mallId, 'BossWeight', 'basic');

            // 判断是否开启插件分润
            if ($config['is_enable'] == StatusEnum::DISABLED) return true;

            // 判断结算方式,0=支付完成,1=订单完成
            $settlement_method = $config['settlement_method'] == 0 ? 1 : 4;
            if ($order['order_status'] != $settlement_method) return true;

            // 获取股东等级列表
            $field = 'level,prize,extra_prize,is_extra,extra_type,extra_is_limit,extra_limit_price,weight_turnover_ratio,weight_level_ratio';
            $level_arr = AddonsBossLevelSetting::getBossLevelSetting([['mall_id' => $mallId]],[],true, $field);
            if (empty($level_arr)) return true;
            $level_arr = array_column($level_arr, null, 'level');

            // 获取所有股东列表
            $boss_list = AddonsBoss::find()->where(['mall_id' => $mallId, 'status' => StatusEnum::ENABLED])->all();
            if (empty($boss_list)) return true;

            // 统计各个股东等级的总人数
            $level_count = AddonsBoss::find()
                ->select("count(id) num,level")
                ->where(['mall_id' => $mallId, 'status' => StatusEnum::ENABLED])
                ->groupBy("level")
                ->indexBy("level")
                ->asArray()
                ->all();

            //加权分红
            $level_list = array_unique(array_column($boss_list,'level'));
            $totalWeight_list = [];
            foreach($level_list as $level){
                $totalWeight_list[$level] = CommissionLogLogic::getLevelWeight($mallId,$level);
            }
            $settlement_data = [];
            // 循环订单详情，对不同商品进行对应的佣金结算
            foreach ($order_list as $index => $detail) {
                // 获取结算的金额
                /*if ($config['compute_type'] == 0) $order_money = $detail['goods_price'];// 支付金额
                if ($config['compute_type'] == 1) $order_money = $detail['goods_price'] - $detail['cost_price'] + $detail['adjust_money'];// 商品利润
                if ($config['compute_type'] == 2) $order_money = $detail['price'];// 商品售价*/
                if ($config['compute_type'] == 0) $order_money = $detail['goods_price']; // 支付金额
                if ($config['compute_type'] == 1) $order_money = $detail['goods_price'] - bcmul($detail['cost_price'], $detail['num'], 2) + $detail['adjust_money']; // 商品利润
                if ($config['compute_type'] == 2) $order_money = bcmul($detail['price'], $detail['num'], 2); // 商品售价
                $amounts = $amounts + $order_money;//订单总计算金额
                $order_price +=  $detail['goods_price'];//订单总计算金额

                // 获取商品的股东分红独立配置
                $goods_setting = AddonsBossCommissionItemSetting::getOne([['mall_id' => $mallId], ['item_id' => $detail['goods_id']]], true, ['detail']);

                // 商品没参与股东分红则直接退出
                if (!empty($goods_setting) && $goods_setting['is_enable'] == 0) continue;

                // 判断是否开启独立设置
                if (!empty($goods_setting['is_alone']) && $goods_setting['is_alone'] == 1) {
                    // 商品独立分佣配置
                    $level_calculate = $goods_setting['detail'];
                } else {
                    // 等级分佣配置
                    $level_calculate = $level_arr;
                }
                // 对应的等级的永久/额外佣金计算
                foreach ($level_calculate as $level) {
                    $level_num = $level_count[$level['level']]['num'];// 统计的人数
                    if ($level_num <= 0) {
                        $forever_commonisson = $extra_commonisson = 0;
                    } else {
                        $forever_commonisson = $level['prize'] ? bcdiv($order_money * $level['prize'] / $level_num, 100, 2) : 0;// 永久分红佣金,单位：元
                        $extra_commonisson = $level['extra_prize'] ? bcdiv($order_money * $level['extra_prize'] / $level_num, 100, 2) : 0;// 额外分红佣金,单位：元
                    }

                    // 单个商品的结算明细
                    $settlement_data[$level['level']][] = [
                        'detail_id' => $detail['id'],
                        'goods_id' => $detail['goods_id'],
                        'goods_name' => $detail['goods_name'],
                        'amounts' => $order_money,
                        'prize' => $level['prize'],
                        'commonisson' => $forever_commonisson,
                        'extra_prize' => $level['extra_prize'],
                        'extra_commonisson' => $extra_commonisson,
                    ];

                    // 分红佣金计算
                    $calculate[$level['level']] = [
                        'commission' => empty($calculate[$level['level']]['commission']) ? $forever_commonisson : $calculate[$level['level']]['commission'] + $forever_commonisson,
                        'extra_commission' => empty($calculate[$level['level']]['extra_commission']) ? $extra_commonisson : $calculate[$level['level']]['extra_commission'] + $extra_commonisson,
                        'average_count' => $level_num,
                        'settlement_data' => $settlement_data[$level['level']],
                    ];

                }

            }

            // 结算的配置
            $settlement_config = [
                'compute_type' => $config['compute_type'],// 佣金计算方式
                'settlement_method' => $config['settlement_method'],// 结算方式
            ];

            // 分红计算
            foreach ($boss_list as $boss) {
                if (empty($calculate[$boss->level])) continue;
                // 永久分红
                $rows[] = [
                    'mall_id' => $boss->mall_id,
                    'order_id' => $order['id'],
                    'order_no' => $order['order_no'],
                    'user_id' => $boss->user_id,
                    'type' => 1,
                    'level' => $boss->level,// 股东等级
                    'average_count' => $level_count[$boss->level]['num'],// 统计人数
                    'amounts' => $amounts,//计算总金额
                    'order_price' => $order_price,//订单总金额
                    'settle_price' => bcdiv($amounts*$calculate[$boss->level]['settlement_data'][0]['prize'],100,2),
                    'commission' => $calculate[$boss->level]['commission'],
                    'settlement_config' => Json::encode($settlement_config),
                    'settlement_data' => Json::encode($calculate[$boss->level]['settlement_data']),
                    'date' => $date,
                    'created_at' => $time,
                    'updated_at' => $time,
                ];

                // 判断该等级是否开启额外分红
                if ($level_arr[$boss->level]['is_extra'] == 0) continue;
                $extra_settlement_config = $settlement_config;
                // 判断用户是否符合额外分红条件
                if ($level[$boss->level]['extra_type'] == 1 && $boss->upgrade_status != 1) continue;
                if ($level[$boss->level]['extra_type'] == 2 && $boss->upgrade_status != 2) continue;

                $extra_commission = $calculate[$boss->level]['extra_commission'];
                // 判断是否设置额外分红上限并且用户是否达到额外分红上限
                if ($level_arr[$boss->level]['extra_is_limit'] == 1) {
                    // 已超额则直接退出
                    if ($boss->temp_extra_commission >= $level_arr[$boss->level]['extra_limit_price']) continue;

                    // 没超额，但是加上奖励金额则超额，额外分红 = 限制金额 - 已有额外金额；
                    if ($boss->temp_extra_commission + $calculate[$boss->level]['extra_commission'] >= $level_arr[$boss->level]['extra_limit_price']) {
                        $extra_commission = $level_arr[$boss->level]['extra_limit_price'] - $boss->temp_extra_commission;
                        $extra_settlement_config['extra_msg'] = '额外分红金额已达到上限，应得额外分红：￥' . $calculate[$boss->level]['extra_commission'] . '，实得额外分红：￥' . $extra_commission;
                    }
                }

                // 额外分红
                $rows[] = [
                    'mall_id' => $boss->mall_id,
                    'order_id' => $order['id'],
                    'order_no' => $order['order_no'],
                    'user_id' => $boss->user_id,
                    'type' => 2,
                    'level' => $boss->level,// 股东等级
                    'average_count' => $level_count[$boss->level]['num'],// 统计人数
                    'amounts' => $amounts,
                    'order_price' => $order_price,//订单总金额
                    'settle_price' => bcdiv($amounts*$calculate[$boss->level]['settlement_data'][0]['extra_prize'],100,2),
                    'commission' => $extra_commission,
                    'settlement_config' => Json::encode($extra_settlement_config),
                    'settlement_data' => Json::encode($calculate[$boss->level]['settlement_data']),
                    'date' => $date,
                    'created_at' => $time,
                    'updated_at' => $time,
                ];
                // 增加额外分红的临时额度
                $boss->temp_extra_commission += $calculate[$boss->level]['extra_commission'];
                $boss->save();
            }

            // 保存数据
            if (!empty($rows)) {
                $trans = Yii::$app->db->beginTransaction();
                try {
                    // 生成数据
                    $field = ['mall_id','order_id','order_no','user_id','type','level','average_count','amounts','order_price','settle_price','commission','settlement_config','settlement_data','date','created_at','updated_at'];
                    Yii::$app->db->createCommand()->batchInsert(AddonsBossRewardLog::tableName(), $field, $rows)->execute();
                    $trans->commit();
                } catch (Exception $e) {
                    $trans->rollBack();
                    $this->setError($e->getMessage());
                    return false;
                }
            }
            return true;
        } catch (Exception $e) {
            $exception = FormatHelper::exception($e, '订单触发股东分红计算错误');
            echo $exception;
            $this->setError($exception);
            return false;
        }
    }


}