php/app/common/repositories/shared/SharedProsperityTaskRepository.php

<?php

namespace app\common\repositories\shared;

use app\common\dao\shared\SharedProsperityBalanceLogDao;
use app\common\dao\shared\SharedProsperityRecommendConfigDao;
use app\common\dao\shared\SharedProsperityUserDao;
use app\common\dao\store\order\StoreOrderDao;
use app\common\enum\CommonEnum;
use app\common\repositories\BaseRepository;
use think\facade\Db;

class SharedProsperityTaskRepository extends BaseRepository
{
    const PARTNER_RADIO = 1;

    /**
     * @param $data
     * @return void
     * @throws \Exception
     * @author 史晨
     * @date 2026/2/10 10:10
     * 合伙人分红
     */
    public function partner($data)
    {
        // 获取时间范围内订单
        $merId = CommonEnum::DESIGN_MERCHANT_ID['SharedProsperity']['code'];
        $start = $data['startTime'];
        $end = $data['endTime'];

        // 获取pv
        /** @var SharedProsperityRewardRecordRepository $rewardRecordRepository */
        $rewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
        $orderList = $rewardRecordRepository->getListByTime($start, $end);
        if (empty($orderList)) {
            throw new \Exception('没有订单');
        }
        // 计算可分配利润
        $totalConPri = array_sum(array_column($orderList, 'number'));
        $conPri = floor($totalConPri * self::PARTNER_RADIO * 100) / 100;

        // 获取合伙人分配规则
        /** @var SharedProsperityRecommendConfigDao $configDao */
        $configDao = app()->make(SharedProsperityRecommendConfigDao::class);
        $config = $configDao->getConfigList(false);
        $config = array_column($config, 'profit_ratio', 'level');
        if (empty($config)) {
            throw new \Exception('没有合伙人分配规则');
        }
        // 获取合伙人
        /** @var SharedProsperityUserDao $userDao */
        $userDao = app()->make(SharedProsperityUserDao::class);
        $users = $userDao->getUserGroupByPartnerLevel();

        /** @var SharedProsperityBalanceLogDao $balanceDao */
        $balanceDao = app()->make(SharedProsperityBalanceLogDao::class);

        Db::startTrans();
        try {
            foreach ($users as $key => $user) {
                if ($key == 0) {
                    continue;
                }
                $radio = $config[$key];
                $userNum = count($user);

                foreach ($user as $u) {
                    // 计算每个用户分配的利润
                    $userReward = floor(($conPri * ($radio / 100) / $userNum) * 100) / 100;
                    // 记录日志
                    $userData = $userDao->getWhere(['user_id' => $u])->toArray();
                    $balanceDao->create([
                        'user_id' => $u,
                        'level' => $userData['partner_level'],
                        'radio' => $radio,
                        'total_profit' => $conPri,
                        'old' => $userData['balance'],
                        'number' => $userReward,
                        'after' => $userData['balance'] + $userReward
                    ]);

                    $bill = [
                        'uid' => $u,
                        'link_id' => 0,//关联订单id
                        'pm' => 1,//0：支出，1：获得
                        'title' => '共富体系合伙人分佣',//账单标题
                        'category' => 'now_money',//明细种类
                        'type' => 'commission',//明细类型
                        'number' => $userReward,//明细数字
                        'balance' => 0,//剩余
                        'mark' => '共富体系合伙人分佣明细入账',//备注
                        'create_time' => date('Y-m-d H:i:s'),//添加时间
                        'status' => 1,//0待确定，1有效，-1无效
                        'commission_type' => CommonEnum::COMMISSION_TYPE['SHARED_PROSPERITY_PARTNER_COMMISSION']['code'],//佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费
                        //7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12代理区域收益√ 13消费循环佣金
                        //14-推荐代理收益√ 15邀请小区团长升级√ 16大v分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√’
                        'order_sn' => 0,//订单号
                        'tripartite' => 0,//
                        'type_shop' => 0,//0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上
                        'mer_id' => 0,//商户id
                        'source' => 0,//1线下 0线上
                        'order_type' => 1,//1自营  2 第三方  订单类型
                        'is_red_brokerage' => 0,//1红积分对冲佣金 0正常佣金
                        'gzc' => 3,//养老金是否已进入公证处log表0：未进入。1：已进入
                        'take_time' => time(),//结算时间
                        'district_id' => '',//
                        'street_id' => '',//
                        'month' => '',//月份


                    ];

                    Db::name('user_bill')->insert($bill);

                    // 发放佣金
                    $userDao->updateByUserId($u, ['balance' => ['inc', $userReward]]);
                }
            }
            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            throw new \Exception($e->getMessage());
        }
    }
}