qimall/addons/Boss/common/logic/PoolPrizeLogic.php

<?php

namespace addons\Boss\common\logic;

use addons\Boss\common\enums\BossEnum;
use addons\Boss\common\models\AddonsBoss;
use addons\Boss\common\models\AddonsBossCommissionItemSetting;
use addons\Boss\common\models\BossPoolPrizeCommissionLog;
use addons\Boss\common\models\BossPoolPrizeJob;
use addons\Boss\common\models\BossPoolPrizeOrderLog;
use addons\Boss\common\models\BossPoolPrizePerformance;
use common\enums\StatusEnum;
use common\models\mall\MallAddons;
use common\models\user\UserPartitionRelationship;
use common\traits\ErrorTrait;
use services\common\UserWalletService;

/**
 * 奖金池逻辑层
 */
class PoolPrizeLogic
{
    use ErrorTrait;

    public function record($order, $order_status)
    {
        try {
            $mall_id = $order['mall_id'];
            // 判断用户插件是否安装
            if (MallAddons::isInstall($mall_id, BossEnum::ADDONS_NAME) == 0) return true;

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

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

            if ($config['is_prize_pool'] == StatusEnum::DISABLED) return true;

            if (($config['performance_settlement_method'] ?? 0) == $order_status) {
                $this->recordPerformance($order);
            }
            if ($config['prize_pool_time'] == $order_status) {
                $this->recordOrderLog($order, $config);
            }
        } catch (\Exception $e) {
            \Yii::error(__METHOD__ . ', err:' . $e->getMessage());
        }
    }

    public function send($mall_id, $config, $start_at, $end_at, $job_id)
    {
        try {
            $pool_prize_amount = 0;

            $prize_pool_source = $config['prize_pool_source'] ?? 1;
            if ($prize_pool_source == 1) {
                // 周期内奖金池总金额
                $pool_prize_amount = BossPoolPrizeOrderLog::find()->where([
                    'and',
                    ['mall_id' => $mall_id],
                    ['status' => StatusEnum::ENABLED],
                    ['settlement_status' => StatusEnum::DISABLED],
                    ['between', 'date', $start_at, $end_at]
                ])->sum('amount') ?? 0;
            } else if ($prize_pool_source == 2) {
                // 自定义奖金池金额
                $pool_prize_amount = $config['prize_pool_amount'] ?? 0;
            }
            if ($pool_prize_amount <= 0) return true;

            $boss_list = AddonsBoss::lists([
                'where' => [
                    ['mall_id' => $mall_id],
                    ['status' => StatusEnum::ENABLED]
                ],
                'select' => 'id,user_id'
            ]);
            $boss_uid = array_column($boss_list, 'user_id') ?? [];
            if (empty($boss_uid)) return true;

            // 周期内奖金池总业绩
            $all_performance = BossPoolPrizePerformance::find()->where([
                'and',
                ['mall_id' => $mall_id],
                ['user_id' => $boss_uid],
                ['status' => StatusEnum::ENABLED],
                ['between', 'date', $start_at, $end_at],
            ])->sum('performance') ?? 0;
            if ($all_performance <= 0) return true;

            // 周期内奖金池各个用户的业绩 
            $users_performance = BossPoolPrizePerformance::find()->where([
                'and',
                ['mall_id' => $mall_id],
                ['user_id' => $boss_uid],
                ['status' => StatusEnum::ENABLED],
                ['between', 'date', $start_at, $end_at],
            ])->select('SUM(performance) AS total_performance, user_id')
                ->groupBy('user_id')
                ->indexBy('user_id')
                ->asArray()
                ->all();
            $user_ids = array_column($users_performance, 'user_id') ?? [];

            if (empty($user_ids)) return true;
            $num = count($users_performance);
            $boss_uid_list = array_column($boss_list, 'id', 'user_id');
            $rows = [];
            $period_num = 0;
            $period_amount = 0;
            $period_performance = array_sum(array_column($users_performance, 'total_performance') ?? []);
            foreach ($users_performance as $user_id => $performance) {
                $amount = bcdiv(bcmul($performance['total_performance'], $pool_prize_amount, 4), $all_performance, 2);
                $rows[] = [
                    'boss_id' => $boss_uid_list[$user_id] ?? 0,
                    'mall_id' => $mall_id,
                    'user_id' => $user_id,
                    'num' => $num,
                    'total_amount' => $pool_prize_amount,
                    'total_performance' => $all_performance,
                    'personal_performance' => $performance['total_performance'],
                    'amount' => $amount,
                    'start_at' => $start_at,
                    'end_at' => $end_at,
                    'created_at' => time(),
                    'updated_at' => time(),
                    'billing_cycle' => $config['prize_pool_period'],
                    'job_id' => $job_id,
                ];
                $period_num += 1;
                $period_amount += $amount;
            }

            if (empty($rows)) throw new \Exception('奖金池佣金记录为空');
            $job = BossPoolPrizeJob::findOne($job_id);
            $t = \Yii::$app->db->beginTransaction();
            try {
                $insert_wallet = [];
                $columns = ['boss_id', 'mall_id', 'user_id', 'num', 'total_amount', 'total_performance', 'personal_performance', 'amount', 'start_at', 'end_at', 'created_at', 'updated_at', 'billing_cycle', 'job_id'];
                $res = \Yii::$app->db->createCommand()->batchInsert(BossPoolPrizeCommissionLog::tableName(), $columns, $rows)->execute();
                if (!$res) throw new \Exception('批量生成奖金池佣金记录失败');
                BossPoolPrizeOrderLog::updateAll(
                    ['settlement_status' => StatusEnum::ENABLED, 'updated_at' => time()],
                    ['and', ['mall_id' => $mall_id, 'settlement_status' => StatusEnum::DISABLED], ['between', 'date', $start_at, $end_at]]
                );
                $k = 1;
                $page_log = 1000;
                while ($log_list = BossPoolPrizeCommissionLog::find()->where(['mall_id' => $mall_id, 'start_at' => $start_at, 'end_at' => $end_at])
                    ->offset(($k - 1) * $page_log)->limit($page_log)->asArray()->all()
                ) {
                    foreach ($log_list as $log) {
                        $boss = AddonsBoss::findOne(['mall_id' => $log['mall_id'], 'user_id' => $log['user_id'], 'status' => StatusEnum::ENABLED]);
                        if (!$boss) continue;
                        $boss->bonus_pool_commission += $log['amount'];
                        $boss->total_commission += $log['amount'];
                        $boss->save();

                        $insert_wallet[] = [
                            'mall_id' => $log['mall_id'],
                            'user_id' => $log['user_id'],
                            'is_frozen' => false,
                            'wallet_type' => 'commission',
                            'money' => $log['amount'],
                            'desc' => '奖金池分红',
                            'source_table' => BossPoolPrizeCommissionLog::tableName(),
                            'source_table_id' => $log['id'],
                            'from_type' => BossEnum::ADDONS_NAME,
                            'capital_type' => BossEnum::ADDONS_NAME,
                        ];
                    }
                    $k++;
                }
                $job->num = $period_num;
                $job->total_amount = $period_amount;
                $job->total_performance = $period_performance;
                $job->period_total_amount = $pool_prize_amount;
                $job->save();
                $t->commit();
            } catch (\Exception $ex) {
                $t->rollback();
                throw $ex;
            }

            if ($insert_wallet) {
                UserWalletService::batchHandleByQueue($insert_wallet);
            }
        } catch (\Exception $e) {
            \Yii::error(__METHOD__ . ', err:' . $e->getMessage());
            return true;
        }
    }

    /**
     * @Description: 记录分红池业绩
     * @Author: zsan
     * @DateTime 2023-10-12 10:00:30
     * @param  array $order
     * @return bool
     */
    public function recordPerformance($order)
    {
        try {
            $mall_id = $order['mall_id'];
            $user_id =  $order['user_id'];
            $pid_arr = UserPartitionRelationship::getParentIdArr($user_id);
            $pid_arr[] = $user_id;
            $boss_list = AddonsBoss::find()
                ->where(['mall_id' => $mall_id, 'user_id' => $pid_arr, 'status' => StatusEnum::ENABLED])
                ->select('id, user_id, mall_id, status, level')
                ->asArray()->all();
            if (empty($boss_list)) return true;
            $config = \Yii::$app->services->setting->addons->get($mall_id, BossEnum::ADDONS_NAME, 'basic');
            if (!empty($config['boss_level'])) $config['boss_level'] = json_decode($config['boss_level'], true);
            foreach ($boss_list as $boss) {
                if (!empty($config['boss_level']) && !in_array($boss['level'], $config['boss_level'])) continue;
                if (BossPoolPrizePerformance::setData([
                    'user_id' => $boss['user_id'],
                    'mall_id' => $mall_id,
                    'date' => date('Ymd'),
                    'performance' => $order['pay_money']
                ]) === false) {
                    \Yii::error('err:,' . BossPoolPrizePerformance::getStaticError());
                }
            }
            return true;
        } catch (\Exception $e) {
            \Yii::error(__METHOD__ . ',err:' . $e->getMessage());
            return false;
        }
    }

    /**
     * @Description: 记录进入奖金池的订单
     * @Author: zsan
     * @DateTime 2023-10-12 10:37:38
     * @param  array $order
     * @param  array $config
     * @return bool
     */
    public function recordOrderLog($order, $config)
    {
        try {
            $user_id =  $order['user_id'];
            $mall_id = $order['mall_id'];
            $order_detail = $order['detail'];
            $goods_ids = array_column($order_detail, 'goods_id');
            $setting = AddonsBossCommissionItemSetting::lists([
                'where' => [
                    ['mall_id' => $mall_id],
                    ['item_id' => $goods_ids],
                    ['commission_type' => 'commission'],
                    ['status' => StatusEnum::ENABLED],
                    ['is_prize_pool' => StatusEnum::ENABLED],
                ],
                'select' => 'is_prize_pool,prize_pool_type,prize_pool_num,item_id',
                'index' => 'item_id',
            ]);
            if (empty($setting)) return true;
            $amount = 0;
            foreach ($order_detail as $detail) {
                if (isset($setting[$detail['goods_id']])) {
                    $prize_pool_type = $setting[$detail['goods_id']]['prize_pool_type']; //0百分比 1固定值
                    $prize_pool_num = $setting[$detail['goods_id']]['prize_pool_num'];
                    if ($prize_pool_type == 1) {
                        $amount += bcmul($prize_pool_num, $detail['num'], 2);
                    } else {
                        $order_money = 0;
                        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); // 商品售价
                        $amount += $order_money * $prize_pool_num / 100;
                    }
                }
            }
            if ($amount > 0) {
                if (BossPoolPrizeOrderLog::setData([
                    'mall_id' => $mall_id,
                    'user_id' => $user_id,
                    'date' => date('Ymd'),
                    'amount' => $amount,
                    'order_id' => $order['id'],
                    'order_no' => $order['order_no'],
                ]) === false) {
                    throw new \Exception(BossPoolPrizeOrderLog::getStaticError());
                }
            }
            return true;
        } catch (\Exception $e) {
            \Yii::error(__METHOD__ . ',err:' . $e->getMessage());
            return false;
        }
    }
}