feat(shared-prosperity): 添加用户奖励记录功能并优化事务处理

- 引入 SharedProsperityRewardRecordDao 和相关枚举类
- 将更新用户奖励的方法返回值从 int 修改为 bool
- 添加数据库事务处理确保数据一致性
- 实现奖励变更记录日志功能，区分平台奖励和佣金奖励
- 增加正负数判断逻辑，自动生成相应备注信息
- 添加异常回滚机制保障数据安全

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -3,15 +3,18 @@
 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\user\UserDao;
 use app\common\enum\CommonEnum;
+use app\common\enum\shared\SharedProsperityRewardRecordEnum;
 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;
 use think\db\exception\DbException;
+use think\facade\Db;
 
 class SharedProsperityUserRepository extends BaseRepository
 {
@@ -698,7 +701,7 @@ class SharedProsperityUserRepository extends BaseRepository
      * @param $userId
      * @param $type
      * @param $number
-     * @return int|mixed
+     * @return bool
      * @author 史晨
      * @date 2026/2/27 15:16
      * 更新用户奖励
@@ -710,13 +713,77 @@ class SharedProsperityUserRepository extends BaseRepository
             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);;
+
+        try {
+            Db::startTrans();
+
+            $pm = 1;
+            $remark = '后台操作增加' . $number;
+            if ($number < 0) {
+                $pm = 0;
+                $remark = '后台操作减少' . abs($number);
+            }
+
+            if (isset($map[$type])) {
+                // 更新数据
+                $this->dao->updateRewardByUserId($userId, $map[$type], $number);
+                // 记录日志
+                $insertData = [
+                    'user_id' => $userId,
+                    'type' => $type,
+                    'pm' => $pm,
+                    'number' => abs($number),
+                    'balance' => 0,
+                    'status' => SharedProsperityRewardRecordEnum::STATUS['VALID']['code'],
+                    'type_shop' => SharedProsperityRewardRecordEnum::TYPE_SHOP['Platform']['code'],
+                    'order_sn' => 0,
+                    'take_time' => date('Y-m-d H:i:s', time()),
+                    'remark' => $remark,
+                    'create_time' => date('Y-m-d H:i:s', time()),
+                    'update_time' => date('Y-m-d H:i:s', time()),
+                ];
+                /** @var SharedProsperityRewardRecordDao $rewardRecordDao */
+                $rewardRecordDao = app()->make(SharedProsperityRewardRecordDao::class);
+                $rewardRecordDao->insertAll([$insertData]);
+            } else {
+                // 更新数据
+                /** @var UserDao $userDao */
+                $userDao = app()->make(UserDao::class);
+                $userDao->updateBrokeragePriceByUid($userId, $number);;
+                // 记录日志
+                $bill = [
+                    'uid' => $userId,
+                    'link_id' => 0,
+                    'pm' => $pm,
+                    'title' => $remark,
+                    'category' => 'now_money',
+                    'type' => 'commission',
+                    'number' => abs($number),
+                    'balance' => 0,
+                    'mark' => $remark,
+                    'create_time' => date('Y-m-d H:i:s'),
+                    'status' => 1,
+                    'commission_type' => CommonEnum::COMMISSION_TYPE['SHARED_PROSPERITY_PARTNER_COMMISSION']['code'],
+                    'order_sn' => 0,
+                    'tripartite' => 0,
+                    'type_shop' => 0,
+                    'mer_id' => 0,
+                    'source' => 0,
+                    'order_type' => 1,
+                    'is_red_brokerage' => 0,
+                    'gzc' => 3,
+                    'take_time' => time(),
+                    'district_id' => '',
+                    'street_id' => '',
+                    'month' => '',
+                ];
+                Db::name('user_bill')->insert($bill);
+            }
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            return false;
         }
-        return $res;
     }
 }