feat(admin): 添加共富团队等级修改功能

- 在路由文件中新增 updateGroup 接口路由
- 在控制器中实现 updateGroup 方法处理团队等级修改
- 新增 SharedProsperityUserGroupLog 模型用于记录团队变更日志
- 新增 SharedProsperityUserGroupLogDao 数据访问对象
- 在仓库类中添加 updateGroup 方法实现团队等级更新逻辑
- 添加团队变更记录日志功能并完善事务处理机制

app/common/dao/shared/SharedProsperityUserGroupLogDao.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace app\common\dao\shared;
+
+use app\common\dao\BaseDao;
+use app\common\model\shared\SharedProsperityUserGroupLog;
+use app\common\model\shared\SharedProsperityUserLevelLog;
+
+class SharedProsperityUserGroupLogDao extends BaseDao
+{
+    protected function getModel(): string
+    {
+        return SharedProsperityUserGroupLog::class;
+    }
+}

app/common/model/shared/SharedProsperityUserGroupLog.php

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

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -5,6 +5,7 @@ namespace app\common\repositories\shared;
 use app\common\dao\shared\SharedProsperityGroupUserDao;
 use app\common\dao\shared\SharedProsperityRewardRecordDao;
 use app\common\dao\shared\SharedProsperityUserDao;
+use app\common\dao\shared\SharedProsperityUserGroupLogDao;
 use app\common\dao\shared\SharedProsperityUserLevelLogDao;
 use app\common\dao\shared\SharedProsperityUserParentLogDao;
 use app\common\dao\user\UserDao;
@@ -12,6 +13,8 @@ use app\common\dao\user\UserWithdrawalLimitRecordDao;
 use app\common\enum\CommonEnum;
 use app\common\enum\shared\SharedProsperityRewardRecordEnum;
 use app\common\enum\shared\SharedProsperityUserEnum;
+use app\common\model\shared\SharedProsperityGroupUser;
+use app\common\model\shared\SharedProsperityUserParentLog;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\store\order\StoreCartRepository;
 use app\common\repositories\store\order\StoreOrderRepository;
@@ -849,6 +852,54 @@ class SharedProsperityUserRepository extends BaseRepository
         }
     }
 
+    /**
+     * @param $userId
+     * @param $groupId
+     * @param $remark
+     * @param $operator
+     * @return string|void
+     * @author 史晨
+     * @date 2026/3/17 17:19
+     * 更新用户分组
+     */
+    public function updateGroup($userId, $groupId, $remark, $operator)
+    {
+        $userGroup = SharedProsperityGroupUser::where(['user_id' => $userId, 'status' => 1])->find();
+        $userGroupId = $userGroup->group_id??0;
+        Db::startTrans();
+        try {
+            // 变更等级
+            if ($userGroup) {
+                $update = [
+                    'group_id' => $groupId,
+                    'status' => 1
+                ];
+                SharedProsperityGroupUser::update($update, ['user_id' => $userId]);
+            }else{
+                $insert = [
+                    'user_id' => $userId,
+                    'group_id' => $groupId,
+                    'status' => 1
+                ];
+                SharedProsperityGroupUser::create($insert);
+            }
+            // 记录日志
+            /** @var SharedProsperityUserGroupLogDao $logDao */
+            $logDao = app()->make(SharedProsperityUserGroupLogDao::class);
+            $logDao->create([
+                'user_id' => $userId,
+                'old_group' => $userGroupId,
+                'new_group' => $groupId,
+                'operator' => $operator,
+                'remark' => $remark
+            ]);
+            Db::commit();
+        } catch (\Exception $e) {
+            Db::rollback();
+            return $e->getMessage();
+        }
+    }
+
 
     /**
      * @param $userId

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

@@ -82,4 +82,28 @@ class SharedProsperityUser
         }
         return app('json')->success('更新成功');
     }
+
+    /**
+     * @return mixed
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author 史晨
+     * @date 2026/3/17 17:18
+     * 更新用户分组
+     */
+    public function updateGroup()
+    {
+        /** @var SharedProsperityUserRepository $repository */
+        $repository = app()->make(SharedProsperityUserRepository::class);
+        $params = app('request')->params(['user_id', 'group_id', 'remark']);
+        if (empty($params['user_id']) || empty($params['group_id'] || empty($params['remark']))) {
+            return app('json')->fail('参数错误');
+        }
+        $res = $repository->updateGroup($params['user_id'], $params['group_id'], $params['remark'], request()->adminId());
+        if (is_string($res)) {
+            return app('json')->fail($res);
+        }
+        return app('json')->success('更新成功');
+    }
 }

route/admin.php

@@ -126,6 +126,8 @@ Route::group(config('admin.api_admin_prefix') . '/', function () {
         Route::get('sharedProsperity/user/updateReward', 'admin.system.sharedProsperity.SharedProsperityUser/updateReward');
         // 修改共富会员上级
         Route::get('sharedProsperity/user/updateParent', 'admin.system.sharedProsperity.SharedProsperityUser/updateParent');
+        // 修改共富团队等级
+        Route::get('sharedProsperity/user/updateGroup', 'admin.system.sharedProsperity.SharedProsperityUser/updateGroup');
 
         //组合数据
         Route::group('group', function () {