Merge branch 'dev'

# Conflicts:
#	app/common/repositories/shared/SharedProsperityUserRepository.php
#	app/middleware/SecurityMiddleware.php

app/common/dao/shared/SharedProsperityGroupDao.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace app\common\dao\shared;
+
+use app\common\dao\BaseDao;
+use app\common\model\BaseModel;
+use app\common\model\shared\SharedProsperityGroup;
+
+class SharedProsperityGroupDao extends BaseDao
+{
+
+    /**
+     * @return BaseModel
+     */
+    protected function getModel(): string
+    {
+        return SharedProsperityGroup::class;
+    }
+
+    /**
+     * 获取所有团队配置
+     * @return array
+     */
+    public function getAllGroups(): array
+    {
+        try {
+            return $this->getModel()::select()->toArray();
+        } catch (\Exception $e) {
+            return [];
+        }
+    }
+
+}

app/common/dao/shared/SharedProsperityGroupUserDao.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace app\common\dao\shared;
+
+use app\common\dao\BaseDao;
+use app\common\model\BaseModel;
+use app\common\model\shared\SharedProsperityGroupUser;
+use think\db\exception\DbException;
+
+class SharedProsperityGroupUserDao extends BaseDao
+{
+
+    /**
+     * @return BaseModel
+     */
+    protected function getModel(): string
+    {
+        return SharedProsperityGroupUser::class;
+    }
+
+    /**
+     * 获取按团队分组的有效用户ID列表
+     * @return array [group_id => [user_id1, user_id2, ...]]
+     */
+    public function getValidUsersGroupByGroup(): array
+    {
+        try {
+            $rows = $this->getModel()::where('status', 1)
+                ->field('group_id, user_id')
+                ->select()
+                ->toArray();
+            $grouped = [];
+            foreach ($rows as $row) {
+                $grouped[$row['group_id']][] = $row['user_id'];
+            }
+            return $grouped;
+        } catch (\Exception $e) {
+            return [];
+        }
+    }
+
+    /**
+     * @param $groupId
+     * @return array
+     * @author 史晨
+     * @date 2026/2/27 11:31
+     * 获取团队用户(分页)
+     */
+    public function getUserByLevel($groupId)
+    {
+        try {
+            return $this->getModel()::where('status', 1)
+                ->where(['group_id' => $groupId])
+                ->paginate(20)
+                ->toArray();
+        } catch (DbException $e) {
+            return [];
+        }
+    }
+}

app/common/dao/shared/SharedProsperityUserDao.php

@@ -7,6 +7,7 @@ use app\common\enum\CommonEnum;
 use app\common\model\BaseModel;
 use app\common\model\shared\SharedProsperityUser;
 use app\entity\data\shared\SharedProsperityUserEntity;
+use think\db\exception\DbException;
 
 class SharedProsperityUserDao extends BaseDao
 {
@@ -232,6 +233,17 @@ class SharedProsperityUserDao extends BaseDao
         }
     }
 
+    public function updateRewardByUserId($userId, $field, $value)
+    {
+        try {
+            /** @var SharedProsperityUser $model */
+            $model = $this->getModel();
+            return $model::getDB()->where('user_id', $userId)->inc($field,$value)->update();
+        } catch (\Exception $e) {
+            return 0;
+        }
+    }
+
     /**
      * 按合伙人等级分组获取用户
      * @return array [partner_level => [user_id1, user_id2, ...]]
@@ -259,4 +271,36 @@ class SharedProsperityUserDao extends BaseDao
             return [];
         }
     }
+
+    /**
+     * @return array|void
+     * @author 史晨
+     * @date 2026/2/27 09:32
+     * 后台用户列表
+     */
+    public function adminList($where,$page)
+    {
+        /** @var SharedProsperityUser $model */
+        $model = $this->getModel();
+        try {
+            $list = $model::getDB()
+                ->where($where)
+                ->with([
+                    'user' => function ($query) {
+                        $query->field('uid,avatar,nickname,account');
+                    },
+                    'parent' => function ($query) {
+                        $query->field('uid,avatar,nickname,account');
+                    },
+                    'group' => function ($query) {
+                        $query->field('group_id,user_id');
+                    }
+                ])
+                ->paginate(['page' => $page, 'list_rows' => 20])
+                ->toArray();
+            return $list;
+        } catch (DbException $e) {
+            return [];
+        }
+    }
 }

app/common/dao/user/UserDao.php

@@ -272,6 +272,11 @@ class UserDao extends BaseDao
         return User::getDB()->where('account', $account)->where('is_del', 0)->find();
     }
 
+    public function nicknameByUser($nickname)
+    {
+        return User::getDB()->where('nickname', $nickname)->where('is_del', 0)->find();
+    }
+
     /**
      * @param $uid
      * @return array
@@ -478,4 +483,17 @@ class UserDao extends BaseDao
             return [];
         }
     }
+
+    /**
+     * @param $uid
+     * @param $number
+     * @return mixed
+     * @author 史晨
+     * @date 2026/2/27 15:15
+     * 更新用户佣金
+     */
+    public function updateBrokeragePriceByUid($uid,$number)
+    {
+        return $this->getModel()::getDB()->where('uid', '=', $uid)->inc('brokerage_price',$number)->update();
+    }
 }

app/common/model/shared/SharedProsperityGroup.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace app\common\model\shared;
+
+use app\common\model\BaseModel;
+
+class SharedProsperityGroup extends BaseModel
+{
+    public static function tablePk(): ?string
+    {
+        return 'id';
+    }
+
+    public static function tableName(): string
+    {
+        return 'shared_prosperity_group';
+    }
+}

app/common/model/shared/SharedProsperityGroupUser.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace app\common\model\shared;
+
+use app\common\model\BaseModel;
+
+class SharedProsperityGroupUser extends BaseModel
+{
+    public static function tablePk(): ?string
+    {
+        return 'id';
+    }
+
+    public static function tableName(): string
+    {
+        return 'shared_prosperity_group_user';
+    }
+}

app/common/model/shared/SharedProsperityUser.php

@@ -3,6 +3,7 @@
 namespace app\common\model\shared;
 
 use app\common\model\BaseModel;
+use app\common\model\user\User;
 
 class SharedProsperityUser extends BaseModel
 {
@@ -15,4 +16,19 @@ class SharedProsperityUser extends BaseModel
     {
         return 'shared_prosperity_user';
     }
+
+    public function user()
+    {
+        return $this->hasOne(User::class, 'uid', 'user_id');
+    }
+
+    public function parent()
+    {
+        return $this->hasOne(User::class, 'uid', 'parent_id');
+    }
+
+    public function group()
+    {
+        return $this->hasOne(SharedProsperityGroupUser::class, 'user_id', 'user_id');
+    }
 }

app/common/repositories/finance/FinanceRepository.php

@@ -11,6 +11,8 @@
 namespace app\common\repositories\finance;
 // use app\common\dao\article\ArticleDao;
 // use app\common\model\article\ArticleContent;
+use app\common\enum\CommonEnum;
+use app\common\enum\shared\SharedProsperityRewardRecordEnum;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\user\UserRepository;
 use think\Exception;
@@ -247,6 +249,14 @@ class FinanceRepository extends BaseRepository
             $todayCount = Db::name('order_merchant')->where($dayWhere)->count();
             $list6[] = ['count' => $weekCount, 'name' => '周订单总数'];
             $list6[] = ['count' => $todayCount, 'name' => '日订单总数'];
+
+            // 共富订单统计
+            $shared_mer_id = CommonEnum::DESIGN_MERCHANT_ID['SharedProsperity']['code'];
+            $sharedMoney = Db::name('store_order')->where($where)->where('mer_id', $shared_mer_id)->count();
+            $weekCount = Db::name('store_order')->where($weekWhere)->where('mer_id', $shared_mer_id)->count();
+            $todayCount = Db::name('store_order')->where($dayWhere)->where('mer_id', $shared_mer_id)->count();
+            $list7[] = ['count' => $weekCount, 'name' => '周订单总数'];
+            $list7[] = ['count' => $todayCount, 'name' => '日订单总数'];
     
     
             $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($chengjiaomoney), 'name' => '会员专区订单总数', 'mer_id' => $mer_idhy, 'list' => $list1];
@@ -255,6 +265,7 @@ class FinanceRepository extends BaseRepository
             $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($tuikuanmoney), 'name' => '复购区订单总数', 'mer_id' => $mer_idfg, 'list' => $list4];
             $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($tuikuancount), 'name' => '三方平台订单总数', 'list' => $list5];
             $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($tuikuanren), 'name' => '线下订单总数', 'list' => $list6];
+            $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($sharedMoney), 'name' => '共富订单总数', 'mer_id' => $shared_mer_id, 'list' => $list7];
             return $data;
         }
     }
@@ -375,6 +386,18 @@ class FinanceRepository extends BaseRepository
             $data['tow'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($maker[0]['count'] ?? 0), 'name' => '股权', 'user_group' => 0];
             $maker = Db::query("SELECT count(uid) as count FROM `rrx_merchant` where {$where}");
             $data['tow'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($maker[0]['count'] ?? 0), 'name' => '商户', 'user_group' => 0];
+
+            // 共富会员身份
+            $sharedUserDataQuery = Db::query("SELECT partner_level,count(user_id) count FROM `rrx_shared_prosperity_user` group by partner_level");
+            $sharedUserDataQuery = array_column($sharedUserDataQuery, 'count', 'partner_level');
+            $data['three'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($sharedUserDataQuery[0] ?? 0), 'name' => '普通用户', 'partner_level' => 0];
+            $data['three'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($sharedUserDataQuery[1] ?? 0), 'name' => '一星合伙人', 'partner_level' => 1];
+            $data['three'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($sharedUserDataQuery[2] ?? 0), 'name' => '二星合伙人', 'partner_level' => 2];
+            $data['three'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($sharedUserDataQuery[3] ?? 0), 'name' => '三星合伙人', 'partner_level' => 3];
+            $data['three'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($sharedUserDataQuery[4] ?? 0), 'name' => '钻石合伙人', 'partner_level' => 4];
+            $data['three'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($sharedUserDataQuery[5] ?? 0), 'name' => '总裁合伙人', 'partner_level' => 5];
+            $data['three'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($sharedUserDataQuery[6] ?? 0), 'name' => '联席主席团', 'partner_level' => 6];
+
             $res['left'] = $data;
         }
         return $res;
@@ -448,6 +471,31 @@ class FinanceRepository extends BaseRepository
         $data[] = ['className' => 'el-icon-s-goods', 'count' => $weekCount, 'name' => '会员专区本周总业绩'];
         $data[] = ['className' => 'el-icon-s-goods', 'count' => $todayCount, 'name' => '会员专区今日总业绩'];
 
+
+        // 共富会员概况
+        $sWeekWhere = " 1=1";
+        $weekWhere = " 1=1";
+        $dayWhere = " 1=1";
+        //上周时间条件
+        $sWeekWhere .= " and DATE(create_time) >= '" . $startDate . "' and DATE(create_time) <= '" . $endDate . "'";
+        //周时间条件
+        $weekWhere .= " and DATE(create_time) >= '" . $oneWeekAgoFormatted . "' and DATE(create_time) <= '" . $todayFormatted . "'";
+        //今日时间条件
+        $dayWhere .= " and DATE(create_time) = '" . $todayFormatted . "'";
+        $sharedUserCount = Db::name('shared_prosperity_user')->count(); //共富会员总人数
+        $sharedUserDayCount = Db::name('shared_prosperity_user')->where($dayWhere)->count(); //共富今日新增会员
+        $sharedUserPvCount = Db::name('shared_prosperity_reward_record')->where(['type'=>SharedProsperityRewardRecordEnum::TYPE['PV']['code']])->sum('number'); // 共富会员专区总业绩
+        $sharedUserLastWeekPv = Db::name('shared_prosperity_reward_record')->where($sWeekWhere)->where(['type'=>SharedProsperityRewardRecordEnum::TYPE['PV']['code']])->sum('number'); // 共富会员专区上周总业绩
+        $sharedUserWeekPv = Db::name('shared_prosperity_reward_record')->where($weekWhere)->where(['type'=>SharedProsperityRewardRecordEnum::TYPE['PV']['code']])->sum('number'); // 共富会员专区本周总业绩
+        $sharedUserTodayPv = Db::name('shared_prosperity_reward_record')->where($dayWhere)->where(['type'=>SharedProsperityRewardRecordEnum::TYPE['PV']['code']])->sum('number'); // 共富会员专区今日总业绩
+
+        $data[] = ['className' => 'el-icon-s-goods', 'count' => $sharedUserCount, 'name' => '共富会员总人数'];
+        $data[] = ['className' => 'el-icon-s-goods', 'count' => $sharedUserDayCount, 'name' => '共富今日新增会员'];
+        $data[] = ['className' => 'el-icon-s-goods', 'count' => $sharedUserPvCount, 'name' => '共富会员专区总业绩'];
+        $data[] = ['className' => 'el-icon-s-goods', 'count' => $sharedUserLastWeekPv, 'name' => '共富会员专区上周总业绩'];
+        $data[] = ['className' => 'el-icon-s-goods', 'count' => $sharedUserWeekPv, 'name' => '共富会员专区本周总业绩'];
+        $data[] = ['className' => 'el-icon-s-goods', 'count' => $sharedUserTodayPv, 'name' => '共富会员专区今日总业绩'];
+
         $res['left'][] = $data;
         return $res;
     }

app/common/repositories/shared/SharedProsperityTaskRepository.php

@@ -3,13 +3,18 @@
 namespace app\common\repositories\shared;
 
 use app\common\dao\shared\SharedProsperityBalanceLogDao;
+use app\common\dao\shared\SharedProsperityGroupDao;
+use app\common\dao\shared\SharedProsperityGroupUserDao;
 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\enum\dividend\DividendLogEnum;
+use app\common\enum\shared\SharedProsperityBalanceLogEnum;
 use app\common\enum\shared\SharedProsperityRewardRecordEnum;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\user\UserBillRepository;
+use app\entity\data\dividend\DividendLogEntity;
 use think\facade\Db;
 use think\facade\Log;
 
@@ -19,9 +24,27 @@ class SharedProsperityTaskRepository extends BaseRepository
 
     const REWARD_TYPE_PV = SharedProsperityRewardRecordEnum::TYPE['PV']['code'];
 
+    // 临时分配规则
+    const CONFIG = [
+        // 用户
+        0 => "1.00",
+        // 一星合伙人
+        1 => "10.00",
+        // 二星合伙人
+        2 => "8.00",
+        // 三星合伙人
+        3 => "5.00",
+        // 钻石合伙人
+        4 => "3.00",
+        // 总裁合伙人
+        5 => "2.00",
+        // 联席主席团
+        6 => "1.00"
+    ];
+
     /**
      * @param $data
-     * @return void
+     * @return array 分配明细数据
      * @throws \Exception
      * @author 史晨
      * @date 2026/2/10 10:10
@@ -30,9 +53,9 @@ class SharedProsperityTaskRepository extends BaseRepository
     public function partner($data)
     {
         // 获取时间范围内订单
-        $merId = CommonEnum::DESIGN_MERCHANT_ID['SharedProsperity']['code'];
         $start = $data['startTime'];
         $end = $data['endTime'];
+        $isTest = $data['isTest'] ?? false; // 是否测试模式（不实际发放）
 
         // 获取pv
         /** @var SharedProsperityRewardRecordRepository $rewardRecordRepository */
@@ -46,10 +69,13 @@ class SharedProsperityTaskRepository extends BaseRepository
         $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');
+        $config = self::CONFIG;
+        if (empty($config)) {
+            /** @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('没有合伙人分配规则');
         }
@@ -61,7 +87,14 @@ class SharedProsperityTaskRepository extends BaseRepository
         /** @var SharedProsperityBalanceLogDao $balanceDao */
         $balanceDao = app()->make(SharedProsperityBalanceLogDao::class);
 
-        Db::startTrans();
+        // 分配明细数据收集
+        $distributionDetails = [];
+
+        // 如果是测试模式，不开启事务，只计算不实际发放
+        if (!$isTest) {
+            Db::startTrans();
+        }
+
         try {
             foreach ($users as $key => $userIds) {
                 if ($key == 0) {
@@ -69,7 +102,7 @@ class SharedProsperityTaskRepository extends BaseRepository
                 }
                 $radio = $config[$key];
                 // 该等级总分红
-                $levelTotal = floor(($conPri * ($radio / 100)) * 100) / 100;
+                $levelTotal = bcmul($conPri, bcdiv($radio, 100, 2), 2);
 
                 // 获取该等级所有用户的基本信息
                 $userInfos = $userDao->getSharedProsperityUserEntityListByUserIdList($userIds);
@@ -91,20 +124,58 @@ class SharedProsperityTaskRepository extends BaseRepository
                     $eachReward = floor(($levelTotal / $userNum) * 100) / 100;
                     foreach ($userInfos as $userInfo) {
                         $userReward = $eachReward;
-                        $this->distributeReward($userInfo, $userReward, $radio, $levelTotal, $balanceDao, $userDao);
+                        $weight = 1 / $userNum; // 平均分配的权重
+                        // 收集分配明细
+                        $distributionDetails[] = [
+                            'user_id' => $userInfo->getUserId(), //用户ID
+                            'level' => $key, //合伙人等级
+                            'total_allocation' => $levelTotal, //该等级总分配金额
+                            'team_pv' => $teamPvMap[$userInfo->getUserId()] ?? 0, //个人团队PV
+                            'current_level_team_pv' => $totalTeamPv, //当前等级所有用户的团队PV总和
+                            'ratio' => $weight, //占比（个人团队PV/当前等级团队PV）
+                            'actual_amount' => $userReward,//实际发放金额
+                        ];
+                        $this->distributeReward($userInfo, $userReward, $radio, $levelTotal, $balanceDao, $userDao, $isTest);
                     }
                 } else {
                     // 加权分配
                     foreach ($userInfos as $userInfo) {
                         $weight = $teamPvMap[$userInfo->getUserId()] / $totalTeamPv;
                         $userReward = floor($levelTotal * $weight * 100) / 100;
-                        $this->distributeReward($userInfo, $userReward, $radio, $levelTotal, $balanceDao, $userDao);
+                        // 收集分配明细
+                        $distributionDetails[] = [
+                            'user_id' => $userInfo->getUserId(),//用户ID
+                            'level' => $key,//合伙人等级
+                            'total_allocation' => $levelTotal,//该等级总分配金额
+                            'team_pv' => $teamPvMap[$userInfo->getUserId()] ?? 0,//个人团队PV
+                            'current_level_team_pv' => $totalTeamPv,//当前等级所有用户的团队PV总和
+                            'ratio' => $weight,//占比（个人团队PV/当前等级团队PV）
+                            'actual_amount' => $userReward,//实际发放金额
+                        ];
+                        $this->distributeReward($userInfo, $userReward, $radio, $levelTotal, $balanceDao, $userDao, $isTest);
                     }
                 }
             }
-            Db::commit();
+
+            if (!$isTest) {
+                // 记录分红日志
+                // $this->dividendLog($start, $end, $conPri, $conPri, $config, $isTest, '共富体系合伙人分红');
+                Db::commit();
+            }
+
+            // 返回分配明细数据
+            return [
+                'success' => true,
+                'is_test' => $isTest,
+                'total_pv' => $totalConPri,
+                'allocatable_profit' => $conPri,
+                'distribution_details' => $distributionDetails,
+                'config' => $config,
+            ];
         } catch (\Exception $e) {
-            Db::rollback();
+            if (!$isTest) {
+                Db::rollback();
+            }
             throw new \Exception($e->getMessage());
         }
     }
@@ -117,11 +188,19 @@ class SharedProsperityTaskRepository extends BaseRepository
      * @param $levelTotal
      * @param $balanceDao
      * @param $userDao
+     * @param bool $isTest 是否测试模式（不实际发放）
      * @return void
      */
-    private function distributeReward($userInfo, $userReward, $radio, $levelTotal, $balanceDao, $userDao)
+    private function distributeReward($userInfo, $userReward, $radio, $levelTotal, $balanceDao, $userDao, $isTest = false)
     {
         $userId = $userInfo->getUserId();
+
+        // 如果是测试模式，只记录日志不实际执行数据库操作
+        if ($isTest) {
+            Log::info("测试模式：用户 {$userId} 应发放奖励 {$userReward}，等级 {$userInfo->getPartnerLevel()}，比例 {$radio}，等级总分红 {$levelTotal}");
+            return;
+        }
+
         $balanceDao->create([
             'user_id' => $userId,
             'level' => $userInfo->getPartnerLevel(),
@@ -163,6 +242,23 @@ class SharedProsperityTaskRepository extends BaseRepository
         $userDao->updateByUserId($userId, ['balance' => ['inc', $userReward]]);
     }
 
+    // private function dividendLog($startTime, $endTime, $performance, $allocated, $starList, $isTest, $remark)
+    // {
+    //     // 组装日志信息
+    //     /** @var DividendLogEntity $dividendLogEntity */
+    //     $dividendLogEntity = DividendLogEntity::newInstance();
+    //     $dividendLogEntity->setType(DividendLogEnum::TYPE['SharedProsperityPartnerProfit']['code'])
+    //         ->setStartTime($startTime)
+    //         ->setEndTime($endTime)
+    //         ->setPerformance($performance)
+    //         ->setAbatement(json_encode([]))
+    //         ->setAllocated($allocated)
+    //         ->setRule(json_encode($starList))
+    //         ->setIsTest($isTest)
+    //         ->setRemark($remark)
+    //         ->setExpected();
+    // }
+
     /**
      * @param $data
      * @return true
@@ -264,4 +360,193 @@ class SharedProsperityTaskRepository extends BaseRepository
             throw new \Exception($e->getMessage());
         }
     }
+
+    /**
+     * @param $data
+     * @return array 分配明细数据
+     * @throws \Exception
+     * @author 史晨
+     * @date 2026/2/14 10:54
+     * 共富奖（团队平均分配）
+     */
+    public function group($data)
+    {
+        // 获取时间范围内订单
+        $start = $data['startTime'];
+        $end = $data['endTime'];
+        $isTest = $data['isTest'] ?? false; // 是否测试模式（不实际发放）
+
+        // 获取pv
+        /** @var SharedProsperityRewardRecordRepository $rewardRecordRepository */
+        $rewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
+        $orderList = $rewardRecordRepository->getListByTime($start, $end, self::REWARD_TYPE_PV);
+        if (empty($orderList)) {
+            throw new \Exception('没有订单');
+        }
+        // 计算总PV
+        $totalPv = array_sum(array_column($orderList, 'number'));
+        $totalPv = 100;
+        // 可分配总额 = 总PV * 15%
+        $totalAllocatable = floor($totalPv * 0.15 * 100) / 100;
+
+        // 获取团队配置
+        /** @var SharedProsperityGroupDao $groupDao */
+        $groupDao = app()->make(SharedProsperityGroupDao::class);
+        $groups = $groupDao->getAllGroups(); // 获取所有团队等级
+        if (empty($groups)) {
+            throw new \Exception('没有团队配置');
+        }
+
+        // 按 group_id 映射比例
+        $groupRatios = [];
+        foreach ($groups as $group) {
+            $groupRatios[$group['id']] = [
+                'name' => $group['name'],
+                'radio' => $group['radio'], // 百分比，例如 8.00
+                'max' => $group['max']
+            ];
+        }
+
+        // 获取团队成员
+        /** @var SharedProsperityGroupUserDao $groupUserDao */
+        $groupUserDao = app()->make(SharedProsperityGroupUserDao::class);
+        $groupUsers = $groupUserDao->getValidUsersGroupByGroup(); // 获取有效用户按团队分组
+        if (empty($groupUsers)) {
+            throw new \Exception('没有团队成员');
+        }
+
+        /** @var SharedProsperityBalanceLogDao $balanceDao */
+        $balanceDao = app()->make(SharedProsperityBalanceLogDao::class);
+        /** @var SharedProsperityUserDao $userDao */
+        $userDao = app()->make(SharedProsperityUserDao::class);
+
+        // 分配明细数据收集
+        $distributionDetails = [];
+
+        // 如果是测试模式，不开启事务，只计算不实际发放
+        if ($isTest === 'false') {
+            Db::startTrans();
+        }
+
+        try {
+            foreach ($groupRatios as $groupId => $groupInfo) {
+                $ratio = $groupInfo['radio']; // 百分比
+                // 该团队等级总分配金额 = 总PV * ratio / 100
+                $groupTotal = floor($totalPv * $ratio / 100 * 100) / 100;
+                // 获取该团队等级下的有效用户
+                $userIds = $groupUsers[$groupId] ?? [];
+                if (empty($userIds)) {
+                    // 没有成员，跳过分配
+                    continue;
+                }
+                $userCount = count($userIds);
+                // 平均分配
+                $eachReward = floor(($groupTotal / $userCount) * 100) / 100;
+                // 获取用户信息
+                $userInfos = $userDao->getSharedProsperityUserEntityListByUserIdList($userIds);
+
+                if (empty($userInfos)) {
+                    continue;
+                }
+                foreach ($userInfos as $userInfo) {
+                    $userReward = $eachReward;
+                    // 收集分配明细
+                    $distributionDetails[] = [
+                        'user_id' => $userInfo->getUserId(),
+                        'group_id' => $groupId,
+                        'group_name' => $groupInfo['name'],
+                        'total_allocation' => $groupTotal,
+                        'user_count' => $userCount,
+                        'ratio' => $ratio,
+                        'actual_amount' => $userReward,
+                    ];
+                    $this->distributeGroupReward($userInfo, $userReward, $ratio, $groupTotal, $balanceDao, $userDao, $groupId, $isTest);
+                }
+            }
+
+            if ($isTest === 'false') {
+                // 记录分红日志
+                // $this->dividendLog($start, $end, $totalPv, $totalAllocatable, $groupRatios, $isTest, '共富体系团队奖');
+                Db::commit();
+            }
+
+            // 返回分配明细数据
+            return [
+                'success' => true,
+                'is_test' => $isTest,
+                'total_pv' => $totalPv,
+                'allocatable_profit' => $totalAllocatable,
+                'distribution_details' => $distributionDetails,
+                'group_ratios' => $groupRatios,
+            ];
+        } catch (\Exception $e) {
+            if ($isTest === 'false') {
+                Db::rollback();
+            }
+            throw new \Exception($e->getMessage());
+        }
+    }
+
+    /**
+     * 分发团队奖励（记录日志和更新余额）
+     * @param $userInfo
+     * @param $userReward
+     * @param $radio
+     * @param $groupTotal
+     * @param $balanceDao
+     * @param $userDao
+     * @param $isTest
+     * @return void
+     */
+    private function distributeGroupReward($userInfo, $userReward, $radio, $groupTotal, $balanceDao, $userDao, $groupId, $isTest)
+    {
+        $userId = $userInfo->getUserId();
+
+        // 如果是测试模式，只记录日志不实际执行数据库操作
+        if ($isTest === 'true') {
+            Log::info("测试模式：用户 {$userId} 应发放团队奖励 {$userReward}，比例 {$radio}，团队总分红 {$groupTotal}");
+            return;
+        }
+
+        $balanceDao->create([
+            'user_id' => $userId,
+            'level' => $groupId, // 共富团队等级
+            'radio' => $radio,
+            'total_profit' => $groupTotal,
+            'old' => $userInfo->getBalance(),
+            'number' => $userReward,
+            'after' => $userInfo->getBalance() + $userReward,
+            'type' => SharedProsperityBalanceLogEnum::TYPE['GROUP']['code']
+        ]);
+
+        $bill = [
+            'uid' => $userId,
+            'link_id' => 0,
+            'pm' => 1,
+            'title' => '共富体系团队奖',
+            'category' => 'now_money',
+            'type' => 'commission',
+            'number' => $userReward,
+            'balance' => 0,
+            'mark' => '共富体系团队奖明细入账',
+            'create_time' => date('Y-m-d H:i:s'),
+            'status' => 1,
+            'commission_type' => CommonEnum::COMMISSION_TYPE['SHARED_PROSPERITY_GROUP_COMMISSION']['code'],
+            'order_sn' => 0,
+            'tripartite' => 0,
+            'type_shop' => 0,
+            'mer_id' => 0,
+            'source' => 0,
+            'order_type' => 1,
+            'is_red_brokerage' => 0,
+            'gzc' => 3,
+            'take_time' => time(),
+            'district_id' => '',
+            'street_id' => '',
+            'month' => '',
+        ];
+
+        Db::name('user_bill')->insert($bill);
+        $userDao->updateByUserId($userId, ['balance' => ['inc', $userReward]]);
+    }
 }

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -644,4 +644,154 @@ class SharedProsperityUserRepository extends BaseRepository
         }
         return null;
     }
+
+    public function adminList($params)
+    {
+        $page = $params['page'] ?? 1;
+        $where = [];
+        /** @var UserDao $userDao */
+        $userDao = app()->make(UserDao::class);
+
+        // 手机号搜索
+        if (isset($params['account']) && $params['account']) {
+            $userData = $userDao->accountByUser($params['account']);
+            $uid = 0;
+            if ($userData) {
+                $uid = $userData->uid;
+            }
+
+            $where[] = ['user_id', '=', $uid];
+        }
+
+        // 昵称搜索
+        if (isset($params['nickname']) && $params['nickname']) {
+            $userData = $userDao->nicknameByUser($params['nickname']);
+            $uid = 0;
+            if ($userData) {
+                $uid = $userData->uid;
+            }
+            $where[] = ['user_id', '=', $uid];
+        }
+
+        // 合伙人等级搜索
+        if (isset($params['partner_level']) && $params['partner_level']) {
+            $where[] = ['partner_level', '=', $params['partner_level']];
+        }
+
+        // 共富团等级搜索
+        if (isset($params['user_group']) && $params['user_group']) {
+            /** @var SharedProsperityGroupUserDao $groupUserDao */
+            $groupUserDao = app()->make(SharedProsperityGroupUserDao::class);
+            $groupUserData = $groupUserDao->getUserByLevel($params['user_group']);
+            $uids = array_column($groupUserData['data'], 'user_id');
+            $where[] = ['user_id', 'in', $uids];
+            $page = 1;
+        }
+
+        $list = $this->dao->adminList($where, $page);
+        return $list;
+    }
+
+    /**
+     * @param $userId
+     * @param $level
+     * @return int
+     * @author 史晨
+     * @date 2026/2/27 14:23
+     * 更新用户等级
+     */
+    public function updateLevel($userId, $level)
+    {
+        return $this->dao->updateByUserId($userId, ['partner_level' => $level]);
+    }
+
+    /**
+     * @param $userId
+     * @param $type
+     * @param $number
+     * @return bool
+     * @author 史晨
+     * @date 2026/2/27 15:16
+     * 更新用户奖励
+     */
+    public function updateReward($userId, $type, $number)
+    {
+        $map = [
+            1001 => 'consumer_stocks',
+            1002 => 'withdrawal_limit',
+            1003 => 'pv'
+        ];
+
+        try {
+            Db::startTrans();
+
+            $pm = 1;
+            $remark = '后台操作增加' . $number;
+            if ($number < 0) {
+                $pm = 0;
+                $remark = '后台操作减少' . abs($number);
+            }
+
+            if (isset($map[$type])) {
+                // 更新数据
+                $this->dao->updateRewardByUserId($userId, $map[$type], $number);
+                // 记录日志
+                $insertData = [
+                    'user_id' => $userId,
+                    'type' => $type,
+                    'pm' => $pm,
+                    'number' => abs($number),
+                    'balance' => 0,
+                    'status' => SharedProsperityRewardRecordEnum::STATUS['VALID']['code'],
+                    'type_shop' => SharedProsperityRewardRecordEnum::TYPE_SHOP['Platform']['code'],
+                    'order_sn' => 0,
+                    'take_time' => date('Y-m-d H:i:s', time()),
+                    'remark' => $remark,
+                    'create_time' => date('Y-m-d H:i:s', time()),
+                    'update_time' => date('Y-m-d H:i:s', time()),
+                ];
+                /** @var SharedProsperityRewardRecordDao $rewardRecordDao */
+                $rewardRecordDao = app()->make(SharedProsperityRewardRecordDao::class);
+                $rewardRecordDao->insertAll([$insertData]);
+            } else {
+                // 更新数据
+                /** @var UserDao $userDao */
+                $userDao = app()->make(UserDao::class);
+                $userDao->updateBrokeragePriceByUid($userId, $number);;
+                // 记录日志
+                $bill = [
+                    'uid' => $userId,
+                    'link_id' => 0,
+                    'pm' => $pm,
+                    'title' => $remark,
+                    'category' => 'now_money',
+                    'type' => 'commission',
+                    'number' => abs($number),
+                    'balance' => 0,
+                    'mark' => $remark,
+                    'create_time' => date('Y-m-d H:i:s'),
+                    'status' => 1,
+                    'commission_type' => CommonEnum::COMMISSION_TYPE['SHARED_PROSPERITY_PARTNER_COMMISSION']['code'],
+                    'order_sn' => 0,
+                    'tripartite' => 0,
+                    'type_shop' => 0,
+                    'mer_id' => 0,
+                    'source' => 0,
+                    'order_type' => 1,
+                    'is_red_brokerage' => 0,
+                    'gzc' => 3,
+                    'take_time' => time(),
+                    'district_id' => '',
+                    'street_id' => '',
+                    'month' => '',
+                ];
+                Db::name('user_bill')->insert($bill);
+            }
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            return false;
+        }
+    }
 }

app/controller/admin/system/sharedProsperity/SharedProsperityUser.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace app\controller\admin\system\sharedProsperity;
+use app\common\repositories\shared\SharedProsperityUserRepository;
+
+class SharedProsperityUser
+{
+    /**
+     * @return mixed
+     * @author 史晨
+     * @date 2026/2/27 09:33
+     * 共富用户列表
+     */
+    public function list()
+    {
+        /** @var SharedProsperityUserRepository $repository */
+        $repository = app()->make(SharedProsperityUserRepository::class);
+        $params = app('request')->params(['account', 'nickname', 'partner_level', 'user_group', 'page']);
+        $list = $repository->adminList($params);
+        return app('json')->success($list);
+    }
+
+    /**
+     * @return mixed
+     * @author 史晨
+     * @date 2026/2/27 14:23
+     * 更新用户等级
+     */
+    public function updateLevel()
+    {
+        /** @var SharedProsperityUserRepository $repository */
+        $repository = app()->make(SharedProsperityUserRepository::class);
+        $params = app('request')->params(['user_id', 'partner_level']);
+        $res = $repository->updateLevel($params['user_id'], $params['partner_level']);
+        if (!$res) {
+            return app('json')->fail('更新失败');
+        }
+        return app('json')->success('更新成功');
+    }
+
+    /**
+     * @return mixed
+     * @author 史晨
+     * @date 2026/2/27 15:16
+     * 更新用户奖励
+     */
+    public function updateReward()
+    {
+        /** @var SharedProsperityUserRepository $repository */
+        $repository = app()->make(SharedProsperityUserRepository::class);
+        $params = app('request')->params(['user_id', 'type', 'number']);
+        $res = $repository->updateReward($params['user_id'], $params['type'], $params['number']);
+        if (!$res) {
+            return app('json')->fail('更新失败');
+        }
+        return app('json')->success('更新成功');
+    }
+}

route/admin.php

@@ -118,6 +118,13 @@ Route::group(config('admin.api_admin_prefix') . '/', function () {
         Route::get('sharedProsperity/detail', 'admin.system.sharedProsperity.SharedProsperityRecommend/detail');
         Route::post('sharedProsperity/update', 'admin.system.sharedProsperity.SharedProsperityRecommend/update');
 
+        // 共富会员
+        Route::get('sharedProsperity/user/list', 'admin.system.sharedProsperity.SharedProsperityUser/list');
+        // 修改共富会员等级
+        Route::get('sharedProsperity/user/updateLevel', 'admin.system.sharedProsperity.SharedProsperityUser/updateLevel');
+        // 修改共富会员奖励
+        Route::get('sharedProsperity/user/updateReward', 'admin.system.sharedProsperity.SharedProsperityUser/updateReward');
+
         //组合数据
         Route::group('group', function () {
             Route::get('lst', '/lst')->name('groupLst');