feat(admin): 更新共享致富用户等级功能优化

- 添加备注参数并增加参数验证逻辑
- 实现等级变更日志记录功能
- 增加数据库事务处理确保数据一致性
- 新增 SharedProsperityUserLevelLog 模型和DAO层
- 添加操作员ID和备注信息存储
- 实现等级重复检查避免无效更新
- 完善错误处理和异常回滚机制

app/common/dao/shared/SharedProsperityUserLevelLogDao.php

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

app/common/model/shared/SharedProsperityUserLevelLog.php

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

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -4,6 +4,7 @@ namespace app\common\repositories\shared;
 
 use app\common\dao\shared\SharedProsperityGroupUserDao;
 use app\common\dao\shared\SharedProsperityUserDao;
+use app\common\dao\shared\SharedProsperityUserLevelLogDao;
 use app\common\dao\user\UserDao;
 use app\common\enum\CommonEnum;
 use app\common\enum\shared\SharedProsperityRewardRecordEnum;
@@ -14,6 +15,7 @@ use app\entity\data\shared\SharedProsperityGroupUserEntity;
 use app\entity\data\shared\SharedProsperityRecommendConfigEntity;
 use app\entity\data\shared\SharedProsperityUserEntity;
 use think\db\exception\DbException;
+use think\facade\Db;
 
 class SharedProsperityUserRepository extends BaseRepository
 {
@@ -752,9 +754,32 @@ class SharedProsperityUserRepository extends BaseRepository
      * @date 2026/2/27 14:23
      * 更新用户等级
      */
-    public function updateLevel($userId, $level)
+    public function updateLevel($userId, $level, $operator, $remark)
     {
-        return $this->dao->updateByUserId($userId, ['partner_level' => $level]);
+        $userInfo = $this->dao->getWhere(['user_id' => $userId]);
+        if ($level == $userInfo->partner_level) {
+            return '等级未发生变化';
+        }
+        Db::startTrans();
+        try {
+            // 变更等级
+            $this->dao->updateByUserId($userId, ['partner_level' => $level]);
+            // 记录日志
+            /** @var SharedProsperityUserLevelLogDao $logDao */
+            $logDao = app()->make(SharedProsperityUserLevelLogDao::class);
+            $logDao->create([
+                'user_id' => $userId,
+                'old_level' => $userInfo->partner_level,
+                'new_level' => $level,
+                'operator' => $operator,
+                'remark' => $remark
+            ]);
+            Db::commit();
+        } catch (\Exception $e) {
+            Db::rollback();
+            return $e->getMessage();
+        }
+
     }
 
     /**

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

@@ -30,10 +30,13 @@ class SharedProsperityUser
     {
         /** @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('更新失败');
+        $params = app('request')->params(['user_id', 'partner_level', 'remark']);
+        if (empty($params['user_id']) || empty($params['partner_level']) || empty($params['remark'])) {
+            return app('json')->fail('参数错误');
+        }
+        $res = $repository->updateLevel($params['user_id'], $params['partner_level'], request()->adminId(), $params['remark']);
+        if (is_string($res)) {
+            return app('json')->fail($res);
         }
         return app('json')->success('更新成功');
     }