feat(admin): 添加共富会员管理功能

- 新增共富会员路由配置
- 创建SharedProsperityGroup模型和数据访问层
- 创建SharedProsperityGroupUser模型和数据访问层
- 扩展SharedProsperityUser模型关联用户和父级关系
- 实现后台共富用户列表查询接口
- 添加按团队分组的用户数据获取功能
- 实现多条件筛选查询包括手机号、昵称、合伙人等级等
- 集成用户昵称查询功能

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
 {
@@ -259,4 +260,33 @@ 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');
+                    }
+                ])
+                ->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

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,14 @@ 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');
+    }
 }

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -2,10 +2,12 @@
 
 namespace app\common\repositories\shared;
 
+use app\common\dao\shared\SharedProsperityGroupUserDao;
 use app\common\dao\shared\SharedProsperityUserDao;
 use app\common\dao\user\UserDao;
 use app\common\enum\CommonEnum;
 use app\common\enum\shared\SharedProsperityUserEnum;
+use app\common\model\user\User;
 use app\common\repositories\BaseRepository;
 use app\entity\data\shared\SharedProsperityRecommendConfigEntity;
 use app\entity\data\shared\SharedProsperityUserEntity;
@@ -631,4 +633,51 @@ 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;
+    }
 }

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

@@ -0,0 +1,22 @@
+<?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);
+    }
+}

route/admin.php

@@ -118,6 +118,9 @@ 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::group('group', function () {
             Route::get('lst', '/lst')->name('groupLst');