feat(admin): 添加共富会员奖励更新功能

- 在路由文件中新增共享繁荣用户奖励更新接口
- 在控制器中实现 updateReward 方法处理奖励更新逻辑
- 在 DAO 层添加 updateRewardByUserId 和 updateBrokeragePriceByUid 方法
- 在仓库层实现 updateReward 方法支持不同类型奖励更新
- 修复代码中的语法错误和格式问题
- 完善用户信息显示格式和数据查询逻辑

app/common/dao/shared/SharedProsperityUserDao.php

@@ -233,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, ...]]

app/common/dao/user/UserDao.php

@@ -483,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/repositories/shared/SharedProsperityUserRepository.php

@@ -532,19 +532,19 @@ class SharedProsperityUserRepository extends BaseRepository
     {
         /** @var SharedProsperityUserDao $userDao */
         $userDao = app()->make(SharedProsperityUserDao::class);
-        
+
         // 获取所有下级用户ID（包括自己）
         $subordinateIds = $userDao->getAllSubordinateUserIds($userId, true);
         if (empty($subordinateIds)) {
             return [];
         }
-        
+
         // 获取这些共富用户的基本信息（包含parent_id）
         $sharedUsers = $userDao->getSharedProsperityUserEntityListByUserIdList($subordinateIds);
         if (empty($sharedUsers)) {
             return [];
         }
-        
+
         // 获取用户昵称映射
         $userIds = array_map(function ($entity) {
             return $entity->getUserId();
@@ -554,9 +554,9 @@ class SharedProsperityUserRepository extends BaseRepository
         $userInfos = $userDao->getUserEntityListByUidList($userIds);
         $idToName = [];
         foreach ($userInfos as $userInfo) {
-            $idToName[$userInfo->getUid()] = $userInfo->getNickname()  . '(' . $userInfo->account .')' ?? ('用户' . $userInfo->getUid());
+            $idToName[$userInfo->getUid()] = $userInfo->getNickname() . '(' . $userInfo->account . ')' ?? ('用户' . $userInfo->getUid());
         }
-        
+
         // 构建节点数组
         $nodes = [];
         foreach ($sharedUsers as $sharedUser) {
@@ -566,7 +566,7 @@ class SharedProsperityUserRepository extends BaseRepository
                 'name' => $idToName[$sharedUser->getUserId()] ?? ('用户' . $sharedUser->getUserId()),
             ];
         }
-        
+
         // 构建树，以传入的用户为根节点
         $rootNode = $this->findNode($nodes, $userId);
         if (!$rootNode) {
@@ -579,7 +579,7 @@ class SharedProsperityUserRepository extends BaseRepository
         ];
         return [$tree];
     }
-    
+
     /**
      * 递归构建共富用户树
      * @param array $nodes 节点数组，每个节点包含 user_id, parent_id, name
@@ -601,7 +601,7 @@ class SharedProsperityUserRepository extends BaseRepository
         }
         return $branch;
     }
-    
+
     /**
      * 根据user_id查找节点名称
      * @param array $nodes
@@ -617,7 +617,7 @@ class SharedProsperityUserRepository extends BaseRepository
         }
         return null;
     }
-    
+
     /**
      * 根据user_id查找节点
      * @param array $nodes
@@ -672,12 +672,12 @@ class SharedProsperityUserRepository extends BaseRepository
             /** @var SharedProsperityGroupUserDao $groupUserDao */
             $groupUserDao = app()->make(SharedProsperityGroupUserDao::class);
             $groupUserData = $groupUserDao->getUserByLevel($params['user_group']);
-            $uids = array_column($groupUserData['data'],'user_id');
+            $uids = array_column($groupUserData['data'], 'user_id');
             $where[] = ['user_id', 'in', $uids];
             $page = 1;
         }
 
-        $list = $this->dao->adminList($where,$page);
+        $list = $this->dao->adminList($where, $page);
         return $list;
     }
 
@@ -693,4 +693,30 @@ class SharedProsperityUserRepository extends BaseRepository
     {
         return $this->dao->updateByUserId($userId, ['partner_level' => $level]);
     }
+
+    /**
+     * @param $userId
+     * @param $type
+     * @param $number
+     * @return int|mixed
+     * @author 史晨
+     * @date 2026/2/27 15:16
+     * 更新用户奖励
+     */
+    public function updateReward($userId, $type, $number)
+    {
+        $map = [
+            1001 => 'consumer_stocks',
+            1002 => 'withdrawal_limit',
+            1003 => 'pv'
+        ];
+        if (isset($map[$type])) {
+            $res = $this->dao->updateRewardByUserId($userId, $map[$type], $number);
+        } else {
+            /** @var UserDao $userDao */
+            $userDao = app()->make(UserDao::class);
+            $res = $userDao->updateBrokeragePriceByUid($userId, $number);;
+        }
+        return $res;
+    }
 }

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

@@ -37,4 +37,22 @@ class SharedProsperityUser
         }
         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

@@ -122,6 +122,8 @@ Route::group(config('admin.api_admin_prefix') . '/', function () {
         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 () {