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

<?php

namespace app\common\repositories\shared;

use app\common\dao\shared\SharedProsperityBalanceLogDao;
use app\common\dao\shared\SharedProsperityPointLogDao;
use app\common\dao\shared\SharedProsperityRecommendConfigDao;
use app\common\dao\shared\SharedProsperityUserDao;
use app\common\enum\CommonEnum;
use app\common\repositories\BaseRepository;
use think\Collection;
use think\facade\Db;
use think\facade\Log;

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());
        }
    }

    /**
     * @param $data
     * @return true
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     * @author 史晨
     * @date 2026/2/10 15:22
     * 感恩奖
     */
    public function thank($data)
    {
        // 获取时间范围内订单
        $start = $data['startTime'];
        $end = $data['endTime'];

        // 获取pv
        /** @var SharedProsperityRewardRecordRepository $rewardRecordRepository */
        $rewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
        $rewardList = $rewardRecordRepository->getListByTime($start, $end);
        if (empty($rewardList)) {
            throw new \Exception('没有订单');
        }

        // user_id分区求和 [id]=>[number]
        $groupedResult = array_reduce($rewardList, function ($carry, $item) {
            $userId = $item['user_id'];
            $number = floatval($item['number']);

            if (!isset($carry[$userId])) {
                $carry[$userId] = 0;
            }

            $carry[$userId] += $number;

            return $carry;
        }, []);

        if (empty($groupedResult)) {
            throw new \Exception('分组求和错误');
        }

        /** @var SharedProsperityUserRepository $userRepository */
        $userRepository = app()->make(SharedProsperityUserRepository::class);

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

        DB::startTrans();
        try {
            foreach ($groupedResult as $key => $value) {
                // 获取感恩奖比例
                $radio = CommonEnum::ORDER_EARNING_ALLOCATION['SharedProsperity']['Thank']['code'];
                // 计算积分
                $points = floor($value * $radio * 100) / 100;
                // 获取上级
                $userData = $userRepository->getSharedProsperityUserEntityByUserId($key);
                $parentId = $userData->getParentId();
                if ($parentId == 0) {
                    Log::info('共富感恩奖发放：' . $key . '的上级是0，不发放感恩奖');
                }
                // 给上级发积分，记录日志
                if ($parentId > 0) {
                    $parentData = $userRepository->getSharedProsperityUserEntityByUserId($parentId);
                    // 记录日志
                    $logDao->create([
                        'user_id' => $parentId,
                        'total' => $value,
                        'radio' => $radio,
                        'old' => $parentData->getPoints(),
                        'number' => $points,
                        'after' => $parentData->getPoints() + $points
                    ]);

                    // 发放积分
                    $userRepository->updateByUserId($parentId, ['points' => ['inc', $points]]);
                }
            }

            Db::commit();
            return true;
        } catch (\Exception $e) {
            DB::rollback();
            throw new \Exception($e->getMessage());
        }
    }
}