feat(shareProsperity): 新增共富区部门功能

- 添加共富区路由配置和部门接口
- 实现团队用户数据访问层方法
- 添加递归获取下级用户ID和PV统计功能
- 创建团队管理控制器和业务逻辑处理

app/common/dao/shared/SharedProsperityUserDao.php

@@ -38,4 +38,186 @@ class SharedProsperityUserDao extends BaseDao
         }
         return $entityList;
     }
+
+    /**
+     * 获取所有直推用户（不分页）
+     * @param int $userId
+     * @return array
+     * @author 史晨
+     * @date 2026/2/9 09:35
+     */
+    public function getDirectByUserId(int $userId): array
+    {
+        $list = [];
+        try {
+            /** @var SharedProsperityUser $model */
+            $model = $this->getModel();
+            $list = $model::getDB()
+                ->where('parent_id', $userId)
+                ->select()
+                ->toArray();
+        } catch (\Exception $e) {
+
+        }
+        return $list;
+    }
+
+    /**
+     * 递归获取团队所有下级用户ID（可选择是否包含自己）
+     * @param int $userId
+     * @param bool $includeSelf 是否包含自己
+     * @return int[]
+     */
+    public function getAllSubordinateUserIds(int $userId, bool $includeSelf = false): array
+    {
+        $allIds = [];
+        try {
+            /** @var SharedProsperityUser $model */
+            $model = $this->getModel();
+            $getRecursiveChildren = function ($parentId) use (&$getRecursiveChildren, $model) {
+                $children = $model::getDB()
+                    ->where('parent_id', $parentId)
+                    ->column('user_id');
+                $allChildren = [];
+                foreach ($children as $childId) {
+                    $allChildren[] = $childId;
+                    $allChildren = array_merge($allChildren, $getRecursiveChildren($childId));
+                }
+                return $allChildren;
+            };
+            $allIds = $getRecursiveChildren($userId);
+            if ($includeSelf) {
+                array_unshift($allIds, $userId);
+            }
+        } catch (\Exception $e) {
+            // 记录日志或忽略
+        }
+        return $allIds;
+    }
+
+    /**
+     * 获取团队所有下级用户PV总和（不包括自己）
+     * @param int $userId
+     * @return float
+     */
+    public function getTeamPvSum(int $userId): float
+    {
+        $userIds = $this->getAllSubordinateUserIds($userId, false);
+        if (empty($userIds)) {
+            return 0.0;
+        }
+        try {
+            /** @var SharedProsperityUser $model */
+            $model = $this->getModel();
+            $sum = $model::getDB()
+                ->whereIn('user_id', $userIds)
+                ->sum('pv');
+            return (float)$sum;
+        } catch (\Exception $e) {
+            return 0.0;
+        }
+    }
+
+    /**
+     * 获取团队所有下级用户PV总和（包括自己）
+     * @param int $userId
+     * @return float
+     */
+    public function getTeamPvSumWithSelf(int $userId): float
+    {
+        $userIds = $this->getAllSubordinateUserIds($userId, true);
+        if (empty($userIds)) {
+            return 0.0;
+        }
+        try {
+            /** @var SharedProsperityUser $model */
+            $model = $this->getModel();
+            $sum = $model::getDB()
+                ->whereIn('user_id', $userIds)
+                ->sum('pv');
+            return (float)$sum;
+        } catch (\Exception $e) {
+            return 0.0;
+        }
+    }
+
+    /**
+     * 获取团队所有下级用户实体列表（不包括自己）
+     * @param int $userId
+     * @return SharedProsperityUserEntity[]
+     */
+    public function getTeamUserEntities(int $userId): array
+    {
+        $userIds = $this->getAllSubordinateUserIds($userId, false);
+        if (empty($userIds)) {
+            return [];
+        }
+        return $this->getSharedProsperityUserEntityListByUserIdList($userIds);
+    }
+
+    /**
+     * 获取团队所有下级用户实体列表（包括自己）
+     * @param int $userId
+     * @return SharedProsperityUserEntity[]
+     */
+    public function getTeamUserEntitiesWithSelf(int $userId): array
+    {
+        $userIds = $this->getAllSubordinateUserIds($userId, true);
+        if (empty($userIds)) {
+            return [];
+        }
+        return $this->getSharedProsperityUserEntityListByUserIdList($userIds);
+    }
+
+    /**
+     * 获取团队所有下级用户（包括分页，不包括自己）
+     * @param int $userId
+     * @param int $page
+     * @param int $pageSize
+     * @return array
+     */
+    public function getTeamUsers(int $userId, int $page = 1, int $pageSize = 10): array
+    {
+        $userIds = $this->getAllSubordinateUserIds($userId, false);
+        if (empty($userIds)) {
+            return ['data' => [], 'total' => 0, 'per_page' => $pageSize, 'current_page' => $page, 'last_page' => 1];
+        }
+        try {
+            /** @var SharedProsperityUser $model */
+            $model = $this->getModel();
+            $list = $model::getDB()
+                ->whereIn('user_id', $userIds)
+                ->paginate(['page' => $page, 'list_rows' => $pageSize])
+                ->toArray();
+            return $list;
+        } catch (\Exception $e) {
+            return ['data' => [], 'total' => 0, 'per_page' => $pageSize, 'current_page' => $page, 'last_page' => 1];
+        }
+    }
+
+    /**
+     * 获取团队所有下级用户（包括分页，包括自己）
+     * @param int $userId
+     * @param int $page
+     * @param int $pageSize
+     * @return array
+     */
+    public function getTeamUsersWithSelf(int $userId, int $page = 1, int $pageSize = 10): array
+    {
+        $userIds = $this->getAllSubordinateUserIds($userId, true);
+        if (empty($userIds)) {
+            return ['data' => [], 'total' => 0, 'per_page' => $pageSize, 'current_page' => $page, 'last_page' => 1];
+        }
+        try {
+            /** @var SharedProsperityUser $model */
+            $model = $this->getModel();
+            $list = $model::getDB()
+                ->whereIn('user_id', $userIds)
+                ->paginate(['page' => $page, 'list_rows' => $pageSize])
+                ->toArray();
+            return $list;
+        } catch (\Exception $e) {
+            return ['data' => [], 'total' => 0, 'per_page' => $pageSize, 'current_page' => $page, 'last_page' => 1];
+        }
+    }
 }

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -3,6 +3,7 @@
 namespace app\common\repositories\shared;
 
 use app\common\dao\shared\SharedProsperityUserDao;
+use app\common\dao\user\UserDao;
 use app\common\repositories\BaseRepository;
 use app\entity\data\shared\SharedProsperityUserEntity;
 use think\db\exception\DbException;
@@ -115,4 +116,111 @@ class SharedProsperityUserRepository extends BaseRepository
         }
         return true;
     }
+
+    /**
+     * 获取直推用户列表，并计算每个直推用户的团队总人数和团队总业绩（包含自己）
+     * 返回三个列表：全部直推、大部门（团队业绩最大的直推用户）、小部门（其余直推用户）
+     * 同时返回统计数据：我的部门总人数、总业绩、小部门业绩总和、大部门业绩总和
+     * @param int $userId
+     * @return array
+     */
+    public function getTeam(int $userId): array
+    {
+        // 获取直推用户
+        $list = $this->dao->getDirectByUserId($userId);
+        if (empty($list)) {
+            // 没有直推用户，仍然返回统计数据（我的部门总人数和总业绩）
+            $myTeamUserIds = $this->dao->getAllSubordinateUserIds($userId, true);
+            $myTeamTotalCount = count($myTeamUserIds);
+            $myTeamPvSum = $this->dao->getTeamPvSumWithSelf($userId);
+            return [
+                'all_direct' => [],
+                'big_department' => [],
+                'small_department' => [],
+                'stats' => [
+                    'my_team_total_count' => $myTeamTotalCount,
+                    'my_team_pv_sum' => $myTeamPvSum,
+                    'small_department_pv_sum' => 0,
+                    'big_department_pv_sum' => 0,
+                ]
+            ];
+        }
+        // 收集所有直推用户ID
+        $userIds = array_column($list, 'user_id');
+        // 获取用户详细信息（昵称、头像、注册时间）
+        /** @var UserDao $userDao */
+        $userDao = app()->make(UserDao::class);
+        $userEntities = $userDao->getUserEntityListByUidList($userIds);
+        $userMap = [];
+        foreach ($userEntities as $userEntity) {
+            $userMap[$userEntity->getUid()] = [
+                'nickname' => $userEntity->getNickname(),
+                'avatar' => $userEntity->getAvatar(),
+                'create_time' => $userEntity->getCreateTime(),
+            ];
+        }
+        // 计算每个直推用户的团队总人数和团队总业绩
+        $maxPv = 0;
+        $maxPvIndex = -1;
+        foreach ($list as $index => &$item) {
+            $teamUserIds = $this->dao->getAllSubordinateUserIds($item['user_id'], true);
+            $teamTotalCount = count($teamUserIds);
+            $teamPvSum = $this->dao->getTeamPvSumWithSelf($item['user_id']);
+            $item['team_total_count'] = $teamTotalCount;
+            $item['team_pv_sum'] = $teamPvSum;
+            // 补充用户信息
+            if (isset($userMap[$item['user_id']])) {
+                $item['nickname'] = $userMap[$item['user_id']]['nickname'];
+                $item['avatar'] = $userMap[$item['user_id']]['avatar'];
+                $item['create_time'] = $userMap[$item['user_id']]['create_time'];
+            } else {
+                $item['nickname'] = '';
+                $item['avatar'] = '';
+                $item['create_time'] = '';
+            }
+            // 找出团队业绩最大的直推用户
+            if ($teamPvSum > $maxPv) {
+                $maxPv = $teamPvSum;
+                $maxPvIndex = $index;
+            }
+        }
+        unset($item);
+        // 分割大部门和小部门
+        $bigDepartment = [];
+        $smallDepartment = [];
+        if ($maxPvIndex >= 0) {
+            $bigDepartment[] = $list[$maxPvIndex];
+            foreach ($list as $index => $item) {
+                if ($index !== $maxPvIndex) {
+                    $smallDepartment[] = $item;
+                }
+            }
+        } else {
+            // 没有直推用户（理论上不会发生）
+            $smallDepartment = $list;
+        }
+        // 计算统计数据
+        $myTeamUserIds = $this->dao->getAllSubordinateUserIds($userId, true);
+        $myTeamTotalCount = count($myTeamUserIds);
+        $myTeamPvSum = $this->dao->getTeamPvSumWithSelf($userId);
+        $smallDepartmentPvSum = 0;
+        foreach ($smallDepartment as $item) {
+            $smallDepartmentPvSum += $item['team_pv_sum'];
+        }
+        $bigDepartmentPvSum = 0;
+        foreach ($bigDepartment as $item) {
+            $bigDepartmentPvSum += $item['team_pv_sum'];
+        }
+        return [
+            'all_direct' => $list,
+            'big_department' => $bigDepartment,
+            'small_department' => $smallDepartment,
+            'stats' => [
+                'my_team_total_count' => $myTeamTotalCount,
+                'my_team_pv_sum' => $myTeamPvSum,
+                'small_department_pv_sum' => $smallDepartmentPvSum,
+                'big_department_pv_sum' => $bigDepartmentPvSum,
+            ]
+        ];
+    }
 }

app/controller/api/shareProsperity/Team.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace app\controller\api\shareProsperity;
+
+use app\common\model\shared\SharedProsperityUser;
+use app\common\repositories\shared\SharedProsperityUserRepository;
+
+class Team extends BaseController
+{
+    public function list()
+    {
+        $userId = $this->request->uid();
+        /** @var SharedProsperityUserRepository $repository */
+        $repository = app()->make(SharedProsperityUserRepository::class);
+        $list = $repository->getTeam($userId);
+        return app('json')->success($list);
+    }
+}

route/api.php

@@ -350,6 +350,12 @@ Route::group('api/', function () {
 
         })->prefix('api.user.');
 
+        // 共富区
+        Route::group('shareProsperity', function () {
+            // 部门
+            Route::get('get_share_prosperity_team_list', 'Team/list');
+        })->prefix('api.shareProsperity.');
+
         //购物车
         Route::group('user/cart', function () {
             Route::get('/lst', 'StoreCart/lst');