yml配置

src/main/java/com/tailbet/controller/GameController.java

@@ -112,11 +112,7 @@ public class GameController {
     @PostMapping("/digit/set")
     public R<Void> setDigit(@RequestBody SetDigitDTO dto) {
         Long userId = UserContext.getUserId();
-
-        // 验证白名单权限
-        DigitWhite white = digitWhiteMapper.selectOne(new LambdaQueryWrapper<DigitWhite>()
-                .eq(DigitWhite::getUserId, userId));
-        if (white == null) {
+        if (!UserContext.isWhite()) {
             return R.fail("您不是白名单用户，无权设置尾数");
         }
 

src/main/java/com/tailbet/controller/OpsController.java

@@ -1,6 +1,7 @@
 package com.tailbet.controller;
 
 import com.tailbet.model.dto.CreateGroupDTO;
+import com.tailbet.model.dto.GroupMemberOperateDTO;
 import com.tailbet.model.dto.PointsDTO;
 import com.tailbet.model.dto.PullGroupDTO;
 import com.tailbet.model.entity.Group;
@@ -78,4 +79,45 @@ public class OpsController {
         return R.ok();
 
     }
+
+    /**
+     * 踢出群成员
+     * <p>
+     * 操作人需为该群群主或管理员；同时从本地数据库和 OpenIM 移除成员。
+     * </p>
+     */
+    @PostMapping("/group/kick")
+    public R<Void> kickGroup(@Valid @RequestBody GroupMemberOperateDTO dto) {
+        Long operatorId = UserContext.getUserId();
+        groupService.kickUser(dto.getGroupId(), dto.getUserId(), operatorId);
+        return R.ok();
+    }
+
+    /**
+     * 设置为管理员
+     * <p>
+     * 操作人需为该群群主；同时本地与 OpenIM 角色都会更新（OpenIM roleLevel=60=管理员），
+     * OpenIM 同步失败会抛异常回滚本地事务，保证本地与 IM 角色一致。
+     * </p>
+     */
+    @PostMapping("/group/set-admin")
+    public R<Void> setAdmin(@Valid @RequestBody GroupMemberOperateDTO dto) {
+        Long operatorId = UserContext.getUserId();
+        groupService.setAdmin(dto.getGroupId(), dto.getUserId(), operatorId);
+        return R.ok();
+    }
+
+    /**
+     * 取消管理员
+     * <p>
+     * 操作人需为该群群主；同时本地与 OpenIM 角色都会更新（OpenIM roleLevel=20=普通成员），
+     * OpenIM 同步失败会抛异常回滚本地事务，保证本地与 IM 角色一致。
+     * </p>
+     */
+    @PostMapping("/group/remove-admin")
+    public R<Void> removeAdmin(@Valid @RequestBody GroupMemberOperateDTO dto) {
+        Long operatorId = UserContext.getUserId();
+        groupService.removeAdmin(dto.getGroupId(), dto.getUserId(), operatorId);
+        return R.ok();
+    }
 }

src/main/java/com/tailbet/job/GameJob.java

@@ -139,20 +139,24 @@ public class GameJob {
 
     /**
      * 从数据库恢复延迟任务队列
+     * 注：包括已过期的任务，过期任务会在processPendingTasks中立即执行
      */
     private void recoverPendingTasks() {
         try {
-            List<PendingTask> dbTasks = pendingTaskMapper.selectList(
-                    new LambdaQueryWrapper<PendingTask>()
-                            .gt(PendingTask::getExecuteTime, LocalDateTime.now()));
+            // 数据库中残留的记录都是未执行的（执行成功后会立即删除），全部恢复
+            List<PendingTask> dbTasks = pendingTaskMapper.selectList(null);
 
             if (dbTasks == null || dbTasks.isEmpty()) {
                 log.info("无待执行的延迟任务，无需恢复");
                 return;
             }
 
+            LocalDateTime now = LocalDateTime.now();
+            int recovered = 0;
+            int expiredCount = 0;
             for (PendingTask dbTask : dbTasks) {
-                if (dbTask.getExecuteTime() == null || !dbTask.getExecuteTime().isAfter(LocalDateTime.now())) {
+                if (dbTask.getExecuteTime() == null) {
+                    log.warn("跳过executeTime为空的延迟任务: taskId={}", dbTask.getTaskId());
                     continue;
                 }
                 PendingTaskInfo info = new PendingTaskInfo();
@@ -163,9 +167,16 @@ public class GameJob {
                 info.setDigit(dbTask.getDigit());
                 info.setExecuteTime(dbTask.getExecuteTime());
                 pendingTasks.put(info.getTaskId(), info);
+                recovered++;
+                if (!dbTask.getExecuteTime().isAfter(now)) {
+                    expiredCount++;
+                    log.warn("恢复已过期任务，启动后立即执行: taskId={}, type={}, groupId={}, executeTime={}",
+                            dbTask.getTaskId(), dbTask.getType(), dbTask.getGroupId(), dbTask.getExecuteTime());
+                }
             }
 
-            log.info("延迟任务恢复完成，共恢复 {} 个待执行任务", pendingTasks.size());
+            log.info("延迟任务恢复完成，共恢复 {} 个待执行任务，其中 {} 个已过期将立即执行",
+                    recovered, expiredCount);
         } catch (Exception e) {
             log.error("恢复延迟任务失败: {}", e.getMessage(), e);
         }
@@ -229,8 +240,29 @@ public class GameJob {
      * 假人托领取剩余份额（循环领取直到红包领完）
      */
     private void fakeUserReceiveRemaining(RedPacket rp) {
-        List<User> fakes = fakeUserService.getFakeUsers();
+        if (rp.getGroupId() == null) {
+            log.warn("红包未关联群组，托跳过领取: rpId={}", rp.getId());
+            return;
+        }
+
+        // 仅允许群内假人领取，避免跨群领取红包
+        List<Long> groupMemberIds = groupMemberMapper.selectList(
+                        new LambdaQueryWrapper<GroupMember>()
+                                .eq(GroupMember::getGroupId, rp.getGroupId())
+                                .select(GroupMember::getUserId))
+                .stream()
+                .map(GroupMember::getUserId)
+                .collect(Collectors.toList());
+        if (groupMemberIds.isEmpty()) {
+            log.warn("红包所属群组无成员，托跳过领取: rpId={}, groupId={}", rp.getId(), rp.getGroupId());
+            return;
+        }
+
+        List<User> fakes = fakeUserService.getFakeUsers().stream()
+                .filter(fake -> groupMemberIds.contains(fake.getId()))
+                .toList();
         if (fakes.isEmpty()) {
+            log.info("红包所属群组无可用假人，托跳过领取: rpId={}, groupId={}", rp.getId(), rp.getGroupId());
             return;
         }
 
@@ -307,7 +339,75 @@ public class GameJob {
     public void resetDailyFakeUsers() {
         fakeUserService.resetDailyActiveFakes();
     }
+    /**
+     * 处理延迟任务队列(每秒执行)
+     */
+    @Scheduled(fixedDelay = 1000)
+    public void processPendingTasks() {
+        LocalDateTime now = LocalDateTime.now();
+        for (Map.Entry<String, PendingTaskInfo> entry : pendingTasks.entrySet()) {
+            PendingTaskInfo task = entry.getValue();
+            if (task.getExecuteTime() == null) {
+                pendingTasks.remove(entry.getKey());
+                deleteTaskFromDb(task.getTaskId());
+                continue;
+            }
+            if (task.getExecuteTime().isBefore(now) || task.getExecuteTime().isEqual(now)) {
+                boolean success = executeTask(task);
+                if (success) {
+                    pendingTasks.remove(entry.getKey());
+                    deleteTaskFromDb(task.getTaskId());
+                } else {
+                    // 失败时保留内存与数据库中的任务，5秒后再重试
+                    task.setExecuteTime(LocalDateTime.now().plusSeconds(5));
+                    updateTaskExecuteTimeInDb(task);
+                    log.warn("任务执行失败，保留任务待重试: taskId={}", task.getTaskId());
+                }
+            }
+        }
+    }
 
+    /**
+     * 更新延迟任务的执行时间(失败重试场景)
+     */
+    private void updateTaskExecuteTimeInDb(PendingTaskInfo task) {
+        try {
+            PendingTask dbTask = pendingTaskMapper.selectOne(
+                    new LambdaQueryWrapper<PendingTask>().eq(PendingTask::getTaskId, task.getTaskId()));
+            if (dbTask != null) {
+                dbTask.setExecuteTime(task.getExecuteTime());
+                pendingTaskMapper.updateById(dbTask);
+            }
+        } catch (Exception e) {
+            log.error("更新延迟任务执行时间失败: taskId={}, error={}", task.getTaskId(), e.getMessage());
+        }
+    }
+
+    /**
+     * 执行延迟任务
+     *
+     * @return true 表示执行成功(可清理)；false 表示执行失败(需保留以重试)
+     */
+    private boolean executeTask(PendingTaskInfo task) {
+        try {
+            switch (task.getType()) {
+                case "settle":
+                    return onSettle(task.getRoundId(), task.getGroupId(), task.getDigit());
+                case "auto_next":
+                    return onAutoNext(task.getGroupId());
+                case "start_rp":
+                    return onStartRp(task.getRoundId(), task.getGroupId());
+                case "bot_send_rp":
+                    return botSendRp(task.getRoundId(), task.getGroupId());
+                default:
+                    log.warn("未知任务类型: {}", task.getType());
+                    return false;
+            }
+        } catch (Exception e) {
+            log.error("执行任务失败: taskId={}, error={}", task.getTaskId(), e.getMessage());
+            return false;
+        }
+    }
     /**
      * 安排开始发红包
      */
@@ -458,50 +558,54 @@ public class GameJob {
     /**
      * 开始发红包
      */
-    public void onStartRp(Long roundId, Long groupId) {
-        GameRound round = gameRoundMapper.selectById(roundId);
-        if (round == null) {
-            return;
+    public boolean onStartRp(Long roundId, Long groupId) {
+        try {
+            GameRound round = gameRoundMapper.selectById(roundId);
+            if (round == null) {
+                return true;
+            }
+
+            // 更新局状态为开始发红包
+            round.setStatus(IGameService.STATUS_RP_SENDING);
+            round.setStartRpTime(LocalDateTime.now());
+            gameRoundMapper.updateById(round);
+
+            // 广播开始发红包
+            broadcastStartRp(groupId, round.getRoundNo());
+
+            // 安排超时后如果没人发包则机器人自动发
+            int autoRpTimeout = getConfigInt("auto_rp_timeout", 10);
+            scheduleBotSendRp(roundId, groupId, autoRpTimeout);
+            return true;
+        } catch (Exception e) {
+            log.error("开始发红包失败: roundId={}, error={}", roundId, e.getMessage());
+            return false;
         }
-
-        // 更新局状态为开始发红包
-        round.setStatus(IGameService.STATUS_RP_SENDING);
-        round.setStartRpTime(LocalDateTime.now());
-        gameRoundMapper.updateById(round);
-
-        // 广播开始发红包
-        broadcastStartRp(groupId, round.getRoundNo());
-
-        // 安排超时后如果没人发包则机器人自动发
-        int autoRpTimeout = getConfigInt("auto_rp_timeout", 10);
-        scheduleBotSendRp(roundId, groupId, autoRpTimeout);
     }
 
     /**
      * 机器人自动发包
      */
-    public void botSendRp(Long roundId, Long groupId) {
+    public boolean botSendRp(Long roundId, Long groupId) {
         GameRound round = gameRoundMapper.selectById(roundId);
         if (round == null) {
-            return;
+            return true;
         }
 
         // 仅在"开始发红包"状态下才执行,避免误触发
         if (round.getStatus() == null || round.getStatus() != IGameService.STATUS_RP_SENDING) {
             log.debug("本局{}当前状态非发红包中（status={}）,机器人跳过发包",
                     roundId, round.getStatus());
-            return;
+            return true;
         }
 
         // 已有用户先发包,机器人不再重复发包(让用户的红包触发开奖)
         if (round.getFirstRpId() != null) {
             log.info("本局{}已有用户先发包(firstRpId={}),机器人跳过发包",
                     roundId, round.getFirstRpId());
-            return;
+            return true;
         }
 
-        // 即使未设置目标尾数,机器人也会发包(由RedPacketService按随机金额处理)
-
         // 从本群成员中查找机器人账号
         List<Long> memberIds = groupMemberMapper.selectList(
                 new LambdaQueryWrapper<GroupMember>()
@@ -513,7 +617,7 @@ public class GameJob {
 
         if (memberIds.isEmpty()) {
             log.warn("群{}无成员,机器人跳过发包", groupId);
-            return;
+            return true;
         }
 
         User bot = userMapper.selectOne(new LambdaQueryWrapper<User>()
@@ -524,7 +628,7 @@ public class GameJob {
 
         if (bot == null) {
             log.warn("群{}成员中无可用机器人账号,跳过发包", groupId);
-            return;
+            return true;
         }
 
         try {
@@ -536,15 +640,17 @@ public class GameJob {
             RedPacket rp = redPacketService.sendRp(bot.getId(), groupId, amount, count, roundId);
             log.info("机器人自动发包: roundId={}, rpId={}, amount={}, count={}, targetDigit={}",
                     roundId, rp.getId(), amount, count, round.getTargetDigit());
+            return true;
         } catch (Exception e) {
             log.error("机器人发包失败: roundId={}, error={}", roundId, e.getMessage(), e);
+            return false;
         }
     }
 
     /**
      * 开奖结算
      */
-    public void onSettle(Long roundId, Long groupId, int digit) {
+    public boolean onSettle(Long roundId, Long groupId, int digit) {
         try {
             gameService.settle(roundId, digit);
 
@@ -565,8 +671,10 @@ public class GameJob {
             roundTasks.remove(roundId);
 
             log.info("局结算完成: roundId={}, digit={}", roundId, digit);
+            return true;
         } catch (Exception e) {
             log.error("结算失败: roundId={}, error={}", roundId, e.getMessage());
+            return false;
         }
     }
 
@@ -680,61 +788,25 @@ public class GameJob {
     }
 
 
-    /**
-     * 处理延迟任务队列(每秒执行)
-     */
-    @Scheduled(fixedDelay = 1000)
-    public void processPendingTasks() {
-        LocalDateTime now = LocalDateTime.now();
-        pendingTasks.entrySet().removeIf(entry -> {
-            PendingTaskInfo task = entry.getValue();
-            if (task.getExecuteTime() == null) {
-                deleteTaskFromDb(task.getTaskId());
-                return true;
-            }
-            if (task.getExecuteTime().isBefore(now) || task.getExecuteTime().isEqual(now)) {
-                executeTask(task);
-                deleteTaskFromDb(task.getTaskId());
-                return true;
-            }
-            return false;
-        });
-    }
 
-    /**
-     * 执行延迟任务
-     */
-    private void executeTask(PendingTaskInfo task) {
-        try {
-            switch (task.getType()) {
-                case "settle":
-                    onSettle(task.getRoundId(), task.getGroupId(), task.getDigit());
-                    break;
-                case "auto_next":
-                    onAutoNext(task.getGroupId());
-                    break;
-                case "start_rp":
-                    onStartRp(task.getRoundId(), task.getGroupId());
-                    break;
-                case "bot_send_rp":
-                    botSendRp(task.getRoundId(), task.getGroupId());
-                    break;
-                default:
-                    log.warn("未知任务类型: {}", task.getType());
-            }
-        } catch (Exception e) {
-            log.error("执行任务失败: taskId={}, error={}", task.getTaskId(), e.getMessage());
-        }
-    }
 
     /**
      * 自动开始下一期
      */
-    private void onAutoNext(Long groupId) {
+    private boolean onAutoNext(Long groupId) {
         try {
-            gameService.startGame(groupId, 0L); // 0L表示系统自动
+            GameRound round = gameService.startGame(groupId, 0L); // 0L表示系统自动
+            if (round == null || round.getId() == null) {
+                log.warn("自动开始下一期失败：startGame未返回局信息, groupId={}", groupId);
+                return false;
+            }
+            // 复用与手动流程一致的逻辑：注册roundTasks监控 + 广播开始下注
+            int betWindowSeconds = getConfigInt("bet_window_seconds", 60);
+            onGameStart(round.getId(), groupId, betWindowSeconds);
+            return true;
         } catch (Exception e) {
             log.error("自动开始下一期失败: groupId={}, error={}", groupId, e.getMessage());
+            return false;
         }
     }
 }

src/main/java/com/tailbet/mapper/UserMapper.java

@@ -6,6 +6,8 @@ import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Update;
 
+import java.math.BigDecimal;
+
 /**
  * 用户Mapper
  */
@@ -16,11 +18,11 @@ public interface UserMapper extends BaseMapper<User> {
      * 原子增加积分
      */
     @Update("UPDATE user SET points = points + #{amount} WHERE id = #{id}")
-    int addPoints(@Param("id") Long id, @Param("amount") Long amount);
+    int addPoints(@Param("id") Long id, @Param("amount") BigDecimal amount);
 
     /**
      * 原子扣除积分（积分不足时返回0）
      */
     @Update("UPDATE user SET points = points - #{amount} WHERE id = #{id} AND points >= #{amount}")
-    int subPoints(@Param("id") Long id, @Param("amount") Long amount);
+    int subPoints(@Param("id") Long id, @Param("amount") BigDecimal amount);
 }

src/main/java/com/tailbet/model/dto/BetDTO.java

@@ -2,6 +2,8 @@ package com.tailbet.model.dto;
 
 import lombok.Data;
 
+import java.math.BigDecimal;
+
 /**
  * 下注请求
  */
@@ -25,5 +27,5 @@ public class BetDTO {
     /**
      * 下注金额
      */
-    private Integer betAmount;
+    private BigDecimal betAmount;
 }

src/main/java/com/tailbet/model/dto/GroupMemberOperateDTO.java

@@ -0,0 +1,23 @@
+package com.tailbet.model.dto;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+/**
+ * 群成员角色操作请求（设置/取消管理员）
+ */
+@Data
+public class GroupMemberOperateDTO {
+
+    /**
+     * 群ID
+     */
+    @NotNull(message = "群ID不能为空")
+    private Long groupId;
+
+    /**
+     * 目标用户ID
+     */
+    @NotNull(message = "目标用户ID不能为空")
+    private Long userId;
+}

src/main/java/com/tailbet/model/dto/PointsDTO.java

@@ -2,6 +2,8 @@ package com.tailbet.model.dto;
 
 import lombok.Data;
 
+import java.math.BigDecimal;
+
 /**
  * 积分操作请求
  */
@@ -15,7 +17,7 @@ public class PointsDTO {
     /**
      * 积分数量
      */
-    private Long amount;
+    private BigDecimal amount;
 
     /**
      * 备注

src/main/java/com/tailbet/model/entity/BetOrder.java

@@ -45,7 +45,7 @@ public class BetOrder {
     /**
      * 下注金额
      */
-    private Integer betAmount;
+    private BigDecimal betAmount;
 
     /**
      * 赔率
@@ -65,7 +65,7 @@ public class BetOrder {
     /**
      * 中奖金额
      */
-    private Long winAmount;
+    private BigDecimal winAmount;
 
     /**
      * 创建时间

src/main/java/com/tailbet/model/entity/PointsFlow.java

@@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.Data;
+
+import java.math.BigDecimal;
 import java.time.LocalDateTime;
 
 /**
@@ -29,17 +31,17 @@ public class PointsFlow {
     /**
      * 变动数值(正负)
      */
-    private Long amount;
+    private BigDecimal amount;
 
     /**
      * 变动前余额
      */
-    private Long balanceBefore;
+    private BigDecimal balanceBefore;
 
     /**
      * 变动后余额
      */
-    private Long balanceAfter;
+    private BigDecimal balanceAfter;
 
     /**
      * 业务单号

src/main/java/com/tailbet/model/entity/RedPacket.java

@@ -78,14 +78,14 @@ public class RedPacket {
     private Integer status;
 
     /**
-     * 预分配金额列表(JSON数组)
+     * 预分配金额列表(JSON数组)，发红包时写入，领取时不再修改
      */
     private String shareAmounts;
 
     /**
-     * 已领取份额数
+     * 下一个待领取份额的索引（从0开始，已领取N个则值为N）
      */
-    private Integer shareTakenCount;
+    private Integer shareTakenIndex;
 
     /**
      * 创建时间

src/main/java/com/tailbet/model/entity/User.java

@@ -5,6 +5,8 @@ import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.Data;
 
+import java.math.BigDecimal;
+
 /**
  * 用户表
  */
@@ -36,9 +38,9 @@ public class User {
     private String avatarUrl;
 
     /**
-     * 积分余额
+     * 积分余额（与红包金额一致使用DECIMAL，避免浮点误差）
      */
-    private Long points;
+    private BigDecimal points;
 
     /**
      * 运营标记:0否 1是

src/main/java/com/tailbet/model/vo/DigitTrialVo.java

@@ -2,6 +2,8 @@ package com.tailbet.model.vo;
 
 import lombok.Data;
 
+import java.math.BigDecimal;
+
 /**
  * 尾数试算结果
  */
@@ -21,15 +23,20 @@ public class DigitTrialVo {
     /**
      * 总投注次数
      */
-    private int totalBet;
+    private int totalBetCount;
+
+    /**
+     * 总投注金额
+     */
+    private BigDecimal totalBet;
 
     /**
      * 总奖励/赔付金额
      */
-    private long totalAward;
+    private BigDecimal totalAward;
 
     /**
      * 净盈亏（totalAward - totalBet）
      */
-    private long profit;
+    private BigDecimal profit;
 }

src/main/java/com/tailbet/model/vo/LoginUserVo.java

@@ -3,6 +3,8 @@ package com.tailbet.model.vo;
 import com.tailbet.model.entity.User;
 import lombok.Data;
 
+import java.math.BigDecimal;
+
 /**
  * 登录用户信息
  */
@@ -31,7 +33,7 @@ public class LoginUserVo {
     /**
      * 积分
      */
-    private Long points;
+    private BigDecimal points;
 
     /**
      * 是否运营

src/main/java/com/tailbet/openim/OpenIMCallbackController.java

@@ -11,6 +11,8 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
 
+import java.math.BigDecimal;
+
 /**
  * OpenIM回调接口
  */
@@ -101,9 +103,9 @@ public class OpenIMCallbackController {
             }
 
             String playType = parts[0];
-            Integer betAmount;
+            BigDecimal betAmount;
             try {
-                betAmount = Integer.parseInt(parts[1]);
+                betAmount = new BigDecimal(parts[1]);
             } catch (NumberFormatException e) {
                 sendGroupMessage(groupId, "金额格式错误");
                 return;
@@ -127,7 +129,7 @@ public class OpenIMCallbackController {
             var bet = betService.placeBet(userId, bizGroupId, msgId, playType, betAmount);
 
             if (bet != null) {
-                sendGroupMessage(groupId, String.format("已记录: %s %d", playType, betAmount));
+                sendGroupMessage(groupId, String.format("已记录: %s %s", playType, betAmount.toPlainString()));
             }
 
         } catch (RuntimeException e) {

src/main/java/com/tailbet/service/IBetService.java

@@ -13,7 +13,7 @@ public interface IBetService {
      * 下注
      */
     BetOrder placeBet(Long userId, Long groupId, String clientMsgId,
-                      String playType, Integer betAmount);
+                      String playType, BigDecimal betAmount);
 
     /**
      * 获取赔率
@@ -23,5 +23,5 @@ public interface IBetService {
     /**
      * 获取用户本局下注总额
      */
-    Integer getUserRoundBetAmount(Long userId, Long roundId);
+    BigDecimal getUserRoundBetAmount(Long userId, Long roundId);
 }

src/main/java/com/tailbet/service/IFakeUserService.java

@@ -38,4 +38,9 @@ public interface IFakeUserService {
      * 获取假人列表
      */
     List<User> getFakeUsers();
+
+    /**
+     * 从现有假人中随机挑选指定数量
+     */
+    List<User> pickFakeUsers(int count);
 }

src/main/java/com/tailbet/service/IGameService.java

@@ -52,7 +52,10 @@ public interface IGameService {
      * 获取群当前可发红包的局（已封盘或正在发红包中）
      */
     GameRound getActiveSendRound(Long groupId);
-
+    /**
+     * 获取群当前结束下注的局
+     */
+    GameRound getBetEndRound(Long groupId);
     /**
      * 生成期号
      */

src/main/java/com/tailbet/service/IPointsService.java

@@ -3,6 +3,8 @@ package com.tailbet.service;
 import com.tailbet.model.entity.PointsFlow;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 
+import java.math.BigDecimal;
+
 /**
  * 积分Service接口
  */
@@ -19,17 +21,17 @@ public interface IPointsService {
     /**
      * 添加积分
      */
-    void addPoints(Long userId, Long amount, String type, String bizNo, Long operatorId, String remark);
+    void addPoints(Long userId, BigDecimal amount, String type, String bizNo, Long operatorId, String remark);
 
     /**
      * 扣除积分
      */
-    void subPoints(Long userId, Long amount, String type, String bizNo, Long operatorId, String remark);
+    void subPoints(Long userId, BigDecimal amount, String type, String bizNo, Long operatorId, String remark);
 
     /**
      * 获取用户积分
      */
-    Long getPoints(Long userId);
+    BigDecimal getPoints(Long userId);
 
     /**
      * 查询积分流水记录

src/main/java/com/tailbet/service/impl/BetServiceImpl.java

@@ -39,7 +39,7 @@ public class BetServiceImpl implements IBetService {
     @Override
     @Transactional
     public BetOrder placeBet(Long userId, Long groupId, String clientMsgId,
-                             String playType, Integer betAmount) {
+                             String playType, BigDecimal betAmount) {
         // 防重检查
         if (clientMsgId != null) {
             BetOrder existing = betOrderMapper.selectOne(new LambdaQueryWrapper<BetOrder>()
@@ -57,7 +57,7 @@ public class BetServiceImpl implements IBetService {
         if (user.getIsFake() != null && user.getIsFake() == 1) {
             // 假人下注只记录审计日志,不产生订单
             auditService.log(groupId, null, userId, "FAKE_BET",
-                    String.format("{\"playType\":\"%s\",\"amount\":%d}", playType, betAmount));
+                    String.format("{\"playType\":\"%s\",\"amount\":%s}", playType, betAmount.toPlainString()));
             return null;
         }
 
@@ -69,25 +69,28 @@ public class BetServiceImpl implements IBetService {
             throw new RuntimeException("当前不在下注阶段");
         }
 
-        // 检查余额
-        if (user.getPoints() < betAmount) {
-            throw new RuntimeException("余额不足");
-        }
-
-        // 检查限额
-        if (betAmount < 1 || betAmount > 2000) {
+        // 检查限额（必须为正整数，避免小数下注带来的精度问题）
+        if (betAmount == null || betAmount.signum() <= 0
+                || betAmount.compareTo(BigDecimal.valueOf(2000)) > 0) {
             throw new RuntimeException("单笔下注金额需在1-2000之间");
         }
 
+        // 检查余额
+        BigDecimal points = user.getPoints() == null ? BigDecimal.ZERO : user.getPoints();
+        if (points.compareTo(betAmount) < 0) {
+            throw new RuntimeException("余额不足");
+        }
+
         // 检查单局累计
-        Integer roundTotal = betOrderMapper.selectList(new LambdaQueryWrapper<BetOrder>()
+        BigDecimal roundTotal = betOrderMapper.selectList(new LambdaQueryWrapper<BetOrder>()
                 .eq(BetOrder::getUserId, userId)
                 .eq(BetOrder::getRoundId, round.getId())
                 .eq(BetOrder::getIsFake, 0))
                 .stream()
-                .mapToInt(BetOrder::getBetAmount)
-                .sum();
-        if (roundTotal + betAmount > 20000) {
+                .map(BetOrder::getBetAmount)
+                .filter(java.util.Objects::nonNull)
+                .reduce(BigDecimal.ZERO, BigDecimal::add);
+        if (roundTotal.add(betAmount).compareTo(BigDecimal.valueOf(20000)) > 0) {
             throw new RuntimeException("单局累计下注不能超过20000");
         }
 
@@ -95,7 +98,7 @@ public class BetServiceImpl implements IBetService {
         BigDecimal odds = getOdds(playType);
 
         // 扣减积分
-         pointsService.subPoints(userId, betAmount.longValue(),
+        pointsService.subPoints(userId, betAmount,
                 IPointsService.TYPE_BET, null, null, "游戏下注");
 
 
@@ -115,8 +118,8 @@ public class BetServiceImpl implements IBetService {
 
         // 审计日志
         auditService.log(groupId, round.getId(), userId, "BET_PLACE",
-                String.format("{\"betId\":%d,\"playType\":\"%s\",\"amount\":%d}",
-                        bet.getId(), playType, betAmount));
+                String.format("{\"betId\":%d,\"playType\":\"%s\",\"amount\":%s}",
+                        bet.getId(), playType, betAmount.toPlainString()));
 
         return bet;
     }
@@ -139,13 +142,14 @@ public class BetServiceImpl implements IBetService {
      * 获取用户本局下注总额
      */
     @Override
-    public Integer getUserRoundBetAmount(Long userId, Long roundId) {
+    public BigDecimal getUserRoundBetAmount(Long userId, Long roundId) {
         return betOrderMapper.selectList(new LambdaQueryWrapper<BetOrder>()
                 .eq(BetOrder::getUserId, userId)
                 .eq(BetOrder::getRoundId, roundId)
                 .eq(BetOrder::getIsFake, 0))
                 .stream()
-                .mapToInt(BetOrder::getBetAmount)
-                .sum();
+                .map(BetOrder::getBetAmount)
+                .filter(java.util.Objects::nonNull)
+                .reduce(BigDecimal.ZERO, BigDecimal::add);
     }
 }

src/main/java/com/tailbet/service/impl/FakeUserServiceImpl.java

@@ -13,6 +13,8 @@ import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
+import java.math.BigDecimal;
+
 import java.util.*;
 
 /**
@@ -56,7 +58,7 @@ public class FakeUserServiceImpl implements IFakeUserService {
         User fake = new User();
         fake.setUsername("fake_" + UUID.randomUUID().toString().replace("-", "").substring(0, 12));
         fake.setNickname(generateNickname());
-        fake.setPoints((long) (1000 + RANDOM.nextInt(49000)));
+        fake.setPoints(BigDecimal.valueOf(1000 + RANDOM.nextInt(49000)));
         fake.setIsFake(1);
         fake.setIsBot(0);
         fake.setIsOps(0);
@@ -155,11 +157,11 @@ public class FakeUserServiceImpl implements IFakeUserService {
         // 随机玩法和金额
         String[] playTypes = {"单", "双", "大", "小"};
         String playType = playTypes[RANDOM.nextInt(playTypes.length)];
-        int amount = (1 + RANDOM.nextInt(10)) * 10; // 10,20,30...100
+        BigDecimal amount = BigDecimal.valueOf((1 + RANDOM.nextInt(10)) * 10L); // 10,20,30...100
 
         try {
             betService.placeBet(fakeId, groupId, "fake_" + UUID.randomUUID(), playType, amount);
-            log.debug("假人{}下注: {} {}", fakeId, playType, amount);
+            log.debug("假人{}下注: {} {}", fakeId, playType, amount.toPlainString());
         } catch (Exception e) {
             log.debug("假人下注失败: {}", e.getMessage());
         }
@@ -174,4 +176,18 @@ public class FakeUserServiceImpl implements IFakeUserService {
                 .eq(User::getIsFake, 1)
                 .eq(User::getStatus, 1));
     }
+
+    /**
+     * 从现有假人中随机挑选指定数量
+     */
+    @Override
+    public List<User> pickFakeUsers(int count) {
+        List<User> fakes = getFakeUsers();
+        if (fakes.isEmpty()) {
+            return List.of();
+        }
+        Collections.shuffle(fakes, RANDOM);
+        int size = Math.min(count, fakes.size());
+        return new ArrayList<>(fakes.subList(0, size));
+    }
 }

src/main/java/com/tailbet/service/impl/GameServiceImpl.java

@@ -92,6 +92,14 @@ public class GameServiceImpl implements IGameService {
                 .last("LIMIT 1"));
     }
 
+    @Override
+    public GameRound getBetEndRound(Long groupId) {
+        return gameRoundMapper.selectOne(new LambdaQueryWrapper<GameRound>()
+                .eq(GameRound::getGroupId, groupId)
+                .eq(GameRound::getStatus, STATUS_BET_CLOSED)
+                .orderByDesc(GameRound::getCreateTime)
+                .last("LIMIT 1"));    }
+
     /**
      * 生成期号
      */
@@ -116,14 +124,18 @@ public class GameServiceImpl implements IGameService {
     }
 
     /**
-     * 开始游戏(群主操作)
+     * 开始游戏(群主操作或系统自动，userId=0L 表示系统)
      */
     @Override
     @Transactional
     public GameRound startGame(Long groupId, Long userId) {
-        // 校验群主权限
         Group group = groupMapper.selectById(groupId);
-        if (group == null || !group.getOwnerUserId().equals(userId)) {
+        if (group == null) {
+            throw new RuntimeException("群组不存在");
+        }
+
+        // 校验群主权限（系统调用时 userId=0L 跳过校验）
+        if (!Long.valueOf(0L).equals(userId) && !group.getOwnerUserId().equals(userId)) {
             throw new RuntimeException("只有群主可以开始游戏");
         }
 
@@ -180,13 +192,18 @@ public class GameServiceImpl implements IGameService {
 
     /**
      * 停止自动连开
+     * 直接修改最新一局（不限状态）——autoNext 是"本局结算后是否自动开下一期"的开关，
+     * 即使本局已结算但下一期还未自动开出的窗口期内也要能关掉
      */
     @Override
     @Transactional
     public void stopAutoNext(Long groupId, Long userId) {
-        GameRound round = getOngoingRound(groupId);
+        GameRound round = gameRoundMapper.selectOne(new LambdaQueryWrapper<GameRound>()
+                .eq(GameRound::getGroupId, groupId)
+                .orderByDesc(GameRound::getCreateTime)
+                .last("LIMIT 1"));
         if (round == null) {
-            throw new RuntimeException("没有进行中的局");
+            throw new RuntimeException("该群没有局");
         }
 
         Group group = groupMapper.selectById(groupId);
@@ -206,9 +223,9 @@ public class GameServiceImpl implements IGameService {
     @Override
     @Transactional
     public void setTargetDigit(Long groupId, Integer digit, Long userId) {
-        GameRound round = getBettingRound(groupId);
+        GameRound round = getBetEndRound(groupId);
         if (round == null) {
-            throw new RuntimeException("当前没有下注中的局");
+            throw new RuntimeException("当前没有下注结束的局");
         }
 
         round.setTargetDigit(digit);
@@ -247,19 +264,20 @@ public class GameServiceImpl implements IGameService {
             trial.setDigit(d);
             trial.setPlayWin(getPlayWinDesc(d));
 
-            int totalBet = 0;
-            long totalAward = 0;
+            BigDecimal totalBet = BigDecimal.ZERO;
+            BigDecimal totalAward = BigDecimal.ZERO;
 
             for (BetOrder bet : bets) {
-                totalBet += bet.getBetAmount();
+                totalBet = totalBet.add(nullToZero(bet.getBetAmount()));
                 if (isWin(bet, d)) {
-                    totalAward += bet.getBetAmount() * (1 + bet.getOdds().doubleValue());
+                    totalAward = totalAward.add(nullToZero(bet.getBetAmount())
+                            .multiply(BigDecimal.ONE.add(nullToZero(bet.getOdds()))));
                 }
             }
 
             trial.setTotalBet(totalBet);
             trial.setTotalAward(totalAward);
-            trial.setProfit(totalBet - totalAward);
+            trial.setProfit(totalBet.subtract(totalAward));
             result.add(trial);
         }
 
@@ -316,15 +334,16 @@ public class GameServiceImpl implements IGameService {
                 .eq(BetOrder::getRoundId, roundId)
                 .eq(BetOrder::getStatus, 0)); // 待结算
 
-        long totalBet = 0;
-        long totalAward = 0;
+        BigDecimal totalBet = BigDecimal.ZERO;
+        BigDecimal totalAward = BigDecimal.ZERO;
 
         for (BetOrder bet : bets) {
-            totalBet += bet.getBetAmount();
+            totalBet = totalBet.add(nullToZero(bet.getBetAmount()));
 
             if (isWin(bet, digit)) {
-                // 中奖,派奖
-                long winAmount = (long) (bet.getBetAmount() * (1 + bet.getOdds().doubleValue()));
+                // 中奖,派奖（用BigDecimal精确计算，避免double转换误差）
+                BigDecimal winAmount = nullToZero(bet.getBetAmount())
+                        .multiply(BigDecimal.ONE.add(nullToZero(bet.getOdds())));
                 bet.setStatus(1); // 已结算
                 bet.setWinAmount(winAmount);
                 betOrderMapper.updateById(bet);
@@ -333,7 +352,7 @@ public class GameServiceImpl implements IGameService {
                 pointsService.addPoints(bet.getUserId(), winAmount, IPointsService.TYPE_AWARD,
                         String.valueOf(bet.getId()), null, "游戏中奖");
 
-                totalAward += winAmount;
+                totalAward = totalAward.add(winAmount);
             } else {
                 // 未中奖
                 bet.setStatus(2); // 未中奖
@@ -348,9 +367,9 @@ public class GameServiceImpl implements IGameService {
         record.setRoundId(roundId);
         record.setDigit(digit);
         record.setPlayWins(getPlayWinDesc(digit));
-        record.setTotalBet((int) totalBet);
-        record.setTotalAward(totalAward);
-        record.setProfit(totalBet - totalAward);
+        record.setTotalBet(totalBet.intValue());
+        record.setTotalAward(totalAward.longValue());
+        record.setProfit(totalBet.subtract(totalAward).longValue());
         record.setCreateTime(LocalDateTime.now());
         drawRecordMapper.insert(record);
 
@@ -361,8 +380,9 @@ public class GameServiceImpl implements IGameService {
 
         // 审计日志
         auditService.log(round.getGroupId(), roundId, null, "SETTLE",
-                String.format("{\"digit\":%d,\"totalBet\":%d,\"totalAward\":%d,\"profit\":%d}",
-                        digit, totalBet, totalAward, totalBet - totalAward));
+                String.format("{\"digit\":%d,\"totalBet\":%s,\"totalAward\":%s,\"profit\":%s}",
+                        digit, totalBet.toPlainString(), totalAward.toPlainString(),
+                        totalBet.subtract(totalAward).toPlainString()));
     }
 
     /**
@@ -396,7 +416,7 @@ public class GameServiceImpl implements IGameService {
                 .eq(BetOrder::getGroupId, groupId)
                 .eq(BetOrder::getIsFake, 0));
         stat.setTotalBetCount(allBets.size());
-        stat.setTotalBetAmount(allBets.stream().mapToLong(BetOrder::getBetAmount).sum());
+        stat.setTotalBetAmount(allBets.stream().map(b -> b.getBetAmount() == null ? 0L : b.getBetAmount().longValue()).mapToLong(Long::longValue).sum());
 
         // 统计派奖
         List<DrawRecord> records = drawRecordMapper.selectList(new LambdaQueryWrapper<DrawRecord>()
@@ -406,4 +426,11 @@ public class GameServiceImpl implements IGameService {
 
         return stat;
     }
+
+    /**
+     * BigDecimal空值防御：null视为0
+     */
+    private static BigDecimal nullToZero(BigDecimal v) {
+        return v == null ? BigDecimal.ZERO : v;
+    }
 }

src/main/java/com/tailbet/service/impl/GroupServiceImpl.java

@@ -11,6 +11,7 @@ import com.tailbet.mapper.UserMapper;
 import com.tailbet.openim.OpenIMApiClient;
 import com.tailbet.service.IGroupService;
 import com.tailbet.service.IAuditService;
+import com.tailbet.service.IFakeUserService;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -38,6 +39,7 @@ public class GroupServiceImpl implements IGroupService {
     private final UserMapper userMapper;
     private final SysConfigMapper sysConfigMapper;
     private final IAuditService auditService;
+    private final IFakeUserService fakeUserService;
     private final OpenIMApiClient openIMApiClient;
 
     /**
@@ -132,16 +134,26 @@ public class GroupServiceImpl implements IGroupService {
             groupMemberMapper.insert(buildMember(groupId, botUserId, ROLE_NORMAL, now));
         }
 
-        // OpenIM 侧建群：群主为 owner，机器人作为初始成员
-        List<String> memberUserIDs = ownerIsBot
-                ? List.of()
-                : List.of(String.valueOf(botUserId));
+        // 从现有假人中挑选10个进群
+        List<User> fakeUsers = fakeUserService.pickFakeUsers(10);
+        for (User fake : fakeUsers) {
+            groupMemberMapper.insert(buildMember(groupId, fake.getId(), ROLE_NORMAL, now));
+        }
+
+        // OpenIM 侧建群：群主、机器人和假人作为初始成员
+        List<String> memberUserIDs = new java.util.ArrayList<>();
+        if (!ownerIsBot) {
+            memberUserIDs.add(String.valueOf(botUserId));
+        }
+        fakeUsers.stream()
+                .map(fake -> String.valueOf(fake.getId()))
+                .forEach(memberUserIDs::add);
         openIMApiClient.createGroup(String.valueOf(groupId), name, String.valueOf(ownerUserId), memberUserIDs);
 
         // 审计日志
         auditService.log(groupId, null, operatorId, "CREATE_GROUP",
-                String.format("{\"name\":\"%s\",\"ownerUserId\":%d,\"botUserId\":%d}",
-                        name.replace("\\", "\\\\").replace("\"", "\\\""), ownerUserId, botUserId));
+                String.format("{\"name\":\"%s\",\"ownerUserId\":%d,\"botUserId\":%d,\"fakeCount\":%d}",
+                        name.replace("\\", "\\\\").replace("\"", "\\\""), ownerUserId, botUserId, fakeUsers.size()));
 
         log.info("创建群成功: groupId={}, name={}, ownerUserId={}, botUserId={}, operatorId={}",
                 groupId, name, ownerUserId, botUserId, operatorId);
@@ -219,8 +231,11 @@ public class GroupServiceImpl implements IGroupService {
     @Transactional
     public void kickUser(Long groupId, Long targetUserId, Long operatorId) {
         Group group = groupMapper.selectById(groupId);
+        if (group == null) {
+            throw new RuntimeException("群组不存在");
+        }
 
-        // 检查权限
+        // 检查操作人权限
         GroupMember operator = groupMemberMapper.selectOne(new LambdaQueryWrapper<GroupMember>()
                 .eq(GroupMember::getGroupId, groupId)
                 .eq(GroupMember::getUserId, operatorId));
@@ -228,8 +243,6 @@ public class GroupServiceImpl implements IGroupService {
         if (operator == null) {
             throw new RuntimeException("你不是群成员");
         }
-
-        // 只有群主和管理员可以踢人
         if (operator.getRole() != ROLE_OWNER && operator.getRole() != ROLE_ADMIN) {
             throw new RuntimeException("只有群主和管理员可以踢人");
         }
@@ -239,10 +252,18 @@ public class GroupServiceImpl implements IGroupService {
             throw new RuntimeException("不能踢出群主");
         }
 
-        // 删除成员
-        groupMemberMapper.delete(new LambdaQueryWrapper<GroupMember>()
+        GroupMember target = groupMemberMapper.selectOne(new LambdaQueryWrapper<GroupMember>()
                 .eq(GroupMember::getGroupId, groupId)
                 .eq(GroupMember::getUserId, targetUserId));
+        if (target == null) {
+            throw new RuntimeException("目标用户不是群成员");
+        }
+
+        // 先同步 OpenIM，失败时事务回滚，避免本地与 IM 状态不一致
+        openIMApiClient.kickGroupMember(
+                String.valueOf(groupId), List.of(String.valueOf(targetUserId)));
+
+        groupMemberMapper.deleteById(target.getId());
 
         // 审计日志
         auditService.log(groupId, null, operatorId, "KICK_USER",
@@ -251,6 +272,10 @@ public class GroupServiceImpl implements IGroupService {
 
     /**
      * 设置管理员
+     * <p>
+     * 本地更新群成员角色后，调用 OpenIM 接口同步角色（roleLevel=60=管理员）。
+     * OpenIM 调用失败会抛异常回滚本地事务，保证本地与 IM 角色一致。
+     * </p>
      */
     @Override
     @Transactional
@@ -274,6 +299,10 @@ public class GroupServiceImpl implements IGroupService {
         member.setUpdateTime(LocalDateTime.now());
         groupMemberMapper.updateById(member);
 
+        // OpenIM 同步：roleLevel=60 表示管理员
+        openIMApiClient.setGroupMemberRole(
+                String.valueOf(groupId), String.valueOf(targetUserId), 60);
+
         // 审计日志
         auditService.log(groupId, null, operatorId, "SET_ADMIN",
                 String.format("{\"targetUserId\":%d}", targetUserId));
@@ -281,6 +310,10 @@ public class GroupServiceImpl implements IGroupService {
 
     /**
      * 取消管理员
+     * <p>
+     * 本地更新群成员角色后，调用 OpenIM 接口同步角色（roleLevel=20=普通成员）。
+     * OpenIM 调用失败会抛异常回滚本地事务，保证本地与 IM 角色一致。
+     * </p>
      */
     @Override
     @Transactional
@@ -303,6 +336,10 @@ public class GroupServiceImpl implements IGroupService {
         member.setUpdateTime(LocalDateTime.now());
         groupMemberMapper.updateById(member);
 
+        // OpenIM 同步：roleLevel=20 表示普通成员
+        openIMApiClient.setGroupMemberRole(
+                String.valueOf(groupId), String.valueOf(targetUserId), 20);
+
         // 审计日志
         auditService.log(groupId, null, operatorId, "REMOVE_ADMIN",
                 String.format("{\"targetUserId\":%d}", targetUserId));

src/main/java/com/tailbet/service/impl/PointsServiceImpl.java

@@ -12,6 +12,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.math.BigDecimal;
+
 /**
  * 积分Service实现
  */
@@ -28,13 +30,16 @@ public class PointsServiceImpl implements IPointsService {
      */
     @Override
     @Transactional
-    public void addPoints(Long userId, Long amount, String type, String bizNo, Long operatorId, String remark) {
+    public void addPoints(Long userId, BigDecimal amount, String type, String bizNo, Long operatorId, String remark) {
+        if (amount == null || amount.signum() == 0) {
+            throw new RuntimeException("变动数值必须为正数");
+        }
         User user = userMapper.selectById(userId);
         if (user == null) {
             throw new RuntimeException("用户不存在");
         }
 
-        Long before = user.getPoints();
+        BigDecimal before = user.getPoints() == null ? BigDecimal.ZERO : user.getPoints();
 
         // 原子增加积分
         int rows = userMapper.addPoints(userId, amount);
@@ -42,7 +47,7 @@ public class PointsServiceImpl implements IPointsService {
             throw new RuntimeException("积分增加失败");
         }
 
-        Long after = before + amount;
+        BigDecimal after = before.add(amount);
 
         // 记录流水
         PointsFlow flow = new PointsFlow();
@@ -62,16 +67,20 @@ public class PointsServiceImpl implements IPointsService {
      */
     @Override
     @Transactional
-    public void subPoints(Long userId, Long amount, String type, String bizNo, Long operatorId, String remark) {
+    public void subPoints(Long userId, BigDecimal amount, String type, String bizNo, Long operatorId, String remark) {
+        if (amount == null || amount.signum() <= 0) {
+            throw new RuntimeException("变动数值必须为正数");
+        }
         User user = userMapper.selectById(userId);
         if (user == null) {
             throw new RuntimeException("用户不存在");
         }
-        if (user.getPoints() < amount) {
+        BigDecimal current = user.getPoints() == null ? BigDecimal.ZERO : user.getPoints();
+        if (current.compareTo(amount) < 0) {
             throw new RuntimeException("余额不足");
         }
 
-        Long before = user.getPoints();
+        BigDecimal before = current;
 
         // 原子扣除积分（SQL层保证余额充足才扣）
         int rows = userMapper.subPoints(userId, amount);
@@ -79,13 +88,13 @@ public class PointsServiceImpl implements IPointsService {
             throw new RuntimeException("积分扣除失败");
         }
 
-        Long after = before - amount;
+        BigDecimal after = before.subtract(amount);
 
         // 记录流水
         PointsFlow flow = new PointsFlow();
         flow.setUserId(userId);
         flow.setType(type);
-        flow.setAmount(-amount);
+        flow.setAmount(amount.negate());
         flow.setBalanceBefore(before);
         flow.setBalanceAfter(after);
         flow.setBizNo(bizNo);
@@ -99,9 +108,9 @@ public class PointsServiceImpl implements IPointsService {
      * 获取用户积分
      */
     @Override
-    public Long getPoints(Long userId) {
+    public BigDecimal getPoints(Long userId) {
         User user = userMapper.selectById(userId);
-        return user != null ? user.getPoints() : 0L;
+        return user != null && user.getPoints() != null ? user.getPoints() : BigDecimal.ZERO;
     }
 
     /**

src/main/java/com/tailbet/service/impl/RedPacketServiceImpl.java

@@ -16,6 +16,7 @@ import com.tailbet.service.IAuditService;
 import com.tailbet.service.IPointsService;
 import com.tailbet.service.IRedPacketService;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -60,8 +61,15 @@ public class RedPacketServiceImpl implements IRedPacketService {
             throw new RuntimeException("用户不存在");
         }
 
+        // 前置校验：总金额必须够每个包至少 1 分，避免产生 0 元红包
+        BigDecimal minRequired = BigDecimal.valueOf(totalCount == null ? 0 : totalCount)
+                .multiply(new BigDecimal("0.01"));
+        if (totalAmount == null || totalAmount.compareTo(minRequired) < 0) {
+            throw new RuntimeException("红包总金额不能低于 " + minRequired.toPlainString() + " 元");
+        }
+
         // 扣积分
-        pointsService.subPoints(userId, totalAmount.longValue(),
+        pointsService.subPoints(userId, totalAmount,
                 IPointsService.TYPE_RP_SEND, null, null, "发送红包");
 
 
@@ -116,7 +124,7 @@ public class RedPacketServiceImpl implements IRedPacketService {
             log.error("序列化shareAmounts失败: {}", shareAmounts, e);
             throw new RuntimeException("系统错误");
         }
-        rp.setShareTakenCount(0);
+        rp.setShareTakenIndex(0);
         redPacketMapper.updateById(rp);
         log.info("预分配红包份额: rpId={}, type={}, targetDigit={}, amounts={}",
                 rp.getId(), rp.getType(), targetDigit, shareAmounts);
@@ -163,26 +171,34 @@ public class RedPacketServiceImpl implements IRedPacketService {
         }
 
         // 更新手气王信息（领取金额最大的用户为手气王）
-        Integer takenCount = rp.getShareTakenCount();
+        Integer takenIndex = rp.getShareTakenIndex();
         BigDecimal currentLucky = rp.getLuckyAmount();
         if (currentLucky == null || amount.compareTo(currentLucky) > 0) {
             rp.setLuckyAmount(amount);
             rp.setLuckyUserId(userId);
-            rp.setLuckyDigit(amount.remainder(BigDecimal.TEN).intValue());
+            rp.setLuckyDigit(digitOf(amount));
         }
-        rp.setShareTakenCount(takenCount != null ? takenCount + 1 : 1);
+        rp.setShareTakenIndex(takenIndex != null ? takenIndex + 1 : 1);
 
         redPacketMapper.updateById(rp);
 
-        // 如果是游戏红包且已领完，发布开奖事件
+        // 如果是游戏红包且已领完，标记手气王并发布开奖事件
         if (isFinished && TYPE_GAME.equals(rp.getType()) && rp.getRoundId() != null) {
+            // 标记手气王的领取记录 is_lucky=1
+            if (rp.getLuckyUserId() != null) {
+                redPacketRecvMapper.update(null, new LambdaUpdateWrapper<RedPacketRecv>()
+                        .eq(RedPacketRecv::getRpId, rpId)
+                        .eq(RedPacketRecv::getUserId, rp.getLuckyUserId())
+                        .set(RedPacketRecv::getIsLucky, 1));
+            }
             eventPublisher.publishEvent(new RedPacketFinishedEvent(
                     this, rp.getRoundId(), rp.getGroupId(), rp.getId(), rp.getLuckyDigit()));
-            log.info("游戏红包领完，发布开奖事件: roundId={}, luckyDigit={}", rp.getRoundId(), rp.getLuckyDigit());
+            log.info("游戏红包领完，标记手气王并发布开奖事件: roundId={}, luckyDigit={}, luckyUserId={}",
+                    rp.getRoundId(), rp.getLuckyDigit(), rp.getLuckyUserId());
         }
 
         // 加积分
-        pointsService.addPoints(userId, amount.longValue(),
+        pointsService.addPoints(userId, amount,
                 IPointsService.TYPE_RP_RECV, String.valueOf(rpId), null, "领取红包");
 
         // 记录领取
@@ -279,9 +295,9 @@ public class RedPacketServiceImpl implements IRedPacketService {
     }
 
     /**
-     * 从预分配金额中顺序取值
-     * 兼容旧数据：如果没有预分配金额，则走随机算法
-     */
+ * 从预分配金额中按索引顺序取值（不再修改 shareAmounts JSON）
+ * 兼容旧数据：如果没有预分配金额，则走随机算法
+ */
     private BigDecimal drawFromPreAllocatedAmounts(RedPacket rp) {
         if (rp.getShareAmounts() == null || rp.getShareAmounts().isEmpty()) {
             // 兼容旧数据fallback到随机
@@ -295,11 +311,13 @@ public class RedPacketServiceImpl implements IRedPacketService {
             if (amounts.isEmpty()) {
                 return calculateReceiveAmount(rp);
             }
-            // 取第一个
-            BigDecimal amount = amounts.remove(0);
-            // 更新JSON
-            rp.setShareAmounts(objectMapper.writeValueAsString(amounts));
-            return amount;
+            // 按 shareTakenIndex 索引取值，shareAmounts 不再被修改
+            Integer index = rp.getShareTakenIndex();
+            if (index == null || index >= amounts.size()) {
+                // 越界：兼容旧数据或异常情况，走随机
+                return calculateReceiveAmount(rp);
+            }
+            return amounts.get(index);
         } catch (Exception e) {
             log.error("解析shareAmounts失败: {}, error={}", rp.getShareAmounts(), e.getMessage());
             return calculateReceiveAmount(rp);
@@ -307,45 +325,76 @@ public class RedPacketServiceImpl implements IRedPacketService {
     }
 
     /**
-     * 预计算红包份额金额
-     * targetDigit 非空时确保手气王金额尾数=targetDigit
-     * targetDigit 为空时按纯随机份额处理
-     */
+ * 预计算红包份额金额
+ * targetDigit 非空时确保手气王金额尾数=targetDigit
+ * targetDigit 为空时按纯随机份额处理
+ */
     private List<BigDecimal> preCalculateShareAmounts(RedPacket rp, Integer targetDigit) {
         List<BigDecimal> amounts = new ArrayList<>();
         int count = rp.getTotalCount();
         BigDecimal total = rp.getTotalAmount();
+        BigDecimal minUnit = new BigDecimal("0.01"); // 最小份额：1 分
 
         if (count <= 1) {
-            // 只有1个，全部给手气王
             amounts.add(total);
             return amounts;
         }
 
         Random random = new Random();
 
-        // 计算手气王金额
-        BigDecimal luckyAmount = calculateLuckyAmount(total, targetDigit, random);
-        // 确保手气王金额不超过总额
-        if (luckyAmount.compareTo(total) > 0) {
-            luckyAmount = total;
+        // 1. 计算手气王金额（已保证不超过 luckyMax 且尾数=targetDigit）
+        BigDecimal luckyAmount = calculateLuckyAmount(total, targetDigit, count, random);
+
+        // 2. 计算其他人总额（保证每人至少 minUnit）
+        BigDecimal minForOthers = minUnit.multiply(BigDecimal.valueOf(count - 1));
+        BigDecimal remaining = total.subtract(luckyAmount);
+        if (remaining.compareTo(minForOthers) < 0) {
+            // 手气王挤占了他人最小份额，回收
+            luckyAmount = total.subtract(minForOthers);
+            if (targetDigit != null) {
+                luckyAmount = adjustToTargetDigit(luckyAmount, luckyAmount.add(minUnit), targetDigit);
+            }
+            remaining = minForOthers;
         }
 
-        // 剩余金额平均分配给其他人
-        BigDecimal remaining = total.subtract(luckyAmount);
+        // 3. 其他人金额（带小随机波动）
+        // 计算 avgAmount 后，确保 luckyAmount ≥ avgAmount × 1.2（maxFactor）
+        // 这样循环里的 amount 自然 ≤ luckyAmount，无需钳制，金额严格守恒
+        double maxFactor = 1.2;
         BigDecimal avgAmount = remaining.divide(BigDecimal.valueOf(count - 1), 2, RoundingMode.HALF_UP);
-
-        // 添加手气王金额
+        BigDecimal needed = avgAmount.multiply(BigDecimal.valueOf(maxFactor))
+                .setScale(2, RoundingMode.HALF_UP);
+        if (luckyAmount.compareTo(needed) < 0) {
+            // 手气王不够大，抬高到 needed（满足"分位尾数"=targetDigit 优先）
+            BigDecimal lifted = needed;
+            if (targetDigit != null) {
+                lifted = adjustToTargetDigit(lifted, total, targetDigit);
+            }
+            // 若抬高后超过 luckyMax（total - minForOthers），回退取 luckyMax 并再调尾数
+            BigDecimal cap = total.subtract(minForOthers);
+            if (lifted.compareTo(cap) > 0) {
+                lifted = cap;
+                if (targetDigit != null) {
+                    lifted = adjustToTargetDigit(lifted, cap, targetDigit);
+                }
+            }
+            luckyAmount = lifted;
+            remaining = total.subtract(luckyAmount);
+            // 重新计算 avgAmount，确保循环里的金额仍 ≥ minUnit
+            avgAmount = remaining.divide(BigDecimal.valueOf(count - 1), 2, RoundingMode.HALF_UP);
+        }
         amounts.add(luckyAmount);
 
-        // 添加其他金额（略有随机波动）
         BigDecimal remainingForOthers = remaining;
         for (int i = 1; i < count - 1; i++) {
-            // 允许小范围波动 0.8~1.2
             double factor = 0.8 + random.nextDouble() * 0.4;
             BigDecimal amount = avgAmount.multiply(BigDecimal.valueOf(factor))
                     .setScale(2, RoundingMode.HALF_UP);
-            // 确保不超过剩余
+            // 下限保护：每个份额至少 minUnit
+            if (amount.compareTo(minUnit) < 0) {
+                amount = minUnit;
+            }
+            // 累加上限：不超过 remainingForOthers
             if (amount.compareTo(remainingForOthers) > 0) {
                 amount = remainingForOthers;
             }
@@ -353,7 +402,12 @@ public class RedPacketServiceImpl implements IRedPacketService {
             remainingForOthers = remainingForOthers.subtract(amount);
         }
         // 最后一个拿剩余
-        amounts.add(remainingForOthers.setScale(2, RoundingMode.HALF_UP));
+        BigDecimal last = remainingForOthers;
+        // 下限保护：累减后可能 < minUnit
+        if (last.compareTo(minUnit) < 0) {
+            last = minUnit;
+        }
+        amounts.add(last.setScale(2, RoundingMode.HALF_UP));
 
         // 打乱顺序（让领取顺序随机）
         Collections.shuffle(amounts);
@@ -368,42 +422,88 @@ public class RedPacketServiceImpl implements IRedPacketService {
 
     /**
      * 计算手气王金额
-     * 比例为总额的30%~50%,有目标尾数时确保尾数=targetDigit
+     * - 比例为总额的 [1/count, 50%]，下限定为 1/count 以保证 luckyAmount ≥ avgAmount
+     *   （手气王必须 ≥ 其他人的平均金额，否则随机波动后有人会比手气王还大）
+     * - 有目标尾数时确保"分位尾数"=targetDigit
+     * - 不超过 luckyMax（total - minUnit * (count-1)），留出最小份额给其他人
      */
-    private BigDecimal calculateLuckyAmount(BigDecimal total, Integer targetDigit, Random random) {
-        // 手气王比例：总额的30%~50%
-        double ratio = 0.3 + random.nextDouble() * 0.2;
-        BigDecimal luckyAmountBase = total.multiply(BigDecimal.valueOf(ratio));
+    private BigDecimal calculateLuckyAmount(BigDecimal total, Integer targetDigit, int totalCount, Random random) {
+        BigDecimal minUnit = new BigDecimal("0.01");
+        BigDecimal minForOthers = minUnit.multiply(BigDecimal.valueOf(totalCount - 1));
+        BigDecimal luckyMax = total.subtract(minForOthers);
 
-        // 未指定目标尾数时按基础金额返回
-        if (targetDigit == null) {
-            return luckyAmountBase.setScale(2, RoundingMode.HALF_UP);
+        // 比例下限 1/count（保证 luckyAmount ≥ avgAmount），上限 50%
+        double minRatio = 1.0 / totalCount;
+        double ratio = minRatio + random.nextDouble() * (0.5 - minRatio);
+        BigDecimal luckyAmount = total.multiply(BigDecimal.valueOf(ratio))
+                .setScale(2, RoundingMode.HALF_UP);
+
+        // 调整尾数（如果指定）
+        if (targetDigit != null) {
+            luckyAmount = adjustToTargetDigit(luckyAmount, luckyMax, targetDigit);
         }
 
-        // 指定了目标尾数,调整金额使尾数=targetDigit
-        int lastDigit = luckyAmountBase.remainder(BigDecimal.TEN).intValue();
-        int diff = (targetDigit - lastDigit + 10) % 10;
-        return luckyAmountBase.add(BigDecimal.valueOf(diff))
-                .setScale(2, RoundingMode.HALF_UP);
+        // 上限保护：不超过 luckyMax
+        if (luckyAmount.compareTo(luckyMax) > 0) {
+            luckyAmount = luckyMax;
+            if (targetDigit != null) {
+                luckyAmount = adjustToTargetDigit(luckyAmount, luckyMax, targetDigit);
+            }
+        }
+
+        return luckyAmount;
     }
 
     /**
-     * 确保份额列表中至少有1个金额的尾数=targetDigit
-     * 若没有则从列表中找一个尾数匹配的金额,换到首位作为手气王
+     * 调整金额让"分位尾数"=targetDigit，且不超过 maxAllowed
+     * 优先向上调整（保持金额更大），如会超出则向下调整
      */
+    private BigDecimal adjustToTargetDigit(BigDecimal amount, BigDecimal maxAllowed, int targetDigit) {
+        BigDecimal minUnit = new BigDecimal("0.01");
+        int lastDigit = digitOf(amount);
+        if (lastDigit == targetDigit) {
+            return amount;
+        }
+        int upDiff = (targetDigit - lastDigit + 10) % 10;       // 向上调（单位：分）
+        int downDiff = (lastDigit - targetDigit + 10) % 10;     // 向下调
+        BigDecimal up = amount.add(BigDecimal.valueOf(upDiff).movePointLeft(2))
+                .setScale(2, RoundingMode.HALF_UP);
+        if (up.compareTo(maxAllowed) <= 0 && up.compareTo(minUnit) >= 0) {
+            return up;
+        }
+        BigDecimal down = amount.subtract(BigDecimal.valueOf(downDiff).movePointLeft(2))
+                .setScale(2, RoundingMode.HALF_UP);
+        if (down.compareTo(minUnit) >= 0) {
+            return down;
+        }
+        return amount; // 实在调不动，保持原值（兜底）
+    }
+
+    /**
+     * 取金额的"分位尾数"：金额×100 后取个位（如 0.45→5，1.05→5，0.40→0）
+     * BigDecimal.remainder(BigDecimal.TEN) 对小数返回自身+intValue 截断会丢精度，
+     * 这里按国内红包/微信红包标准按"分位"算尾数
+     */
+    private static int digitOf(BigDecimal amount) {
+        if (amount == null) return 0;
+        return amount.movePointRight(2).remainder(BigDecimal.TEN).intValue();
+    }
+
+    /**
+ * 确保 amounts[0] 的"分位尾数"=targetDigit（手气王必须在首位）
+ * 如果首位已经命中则不操作；否则找一个命中项 swap 到首位；都没有则兜底不动
+ */
     private void ensureLuckyDigit(List<BigDecimal> amounts, int targetDigit) {
-        for (BigDecimal amt : amounts) {
-            if (amt.remainder(BigDecimal.TEN).intValue() == targetDigit) {
-                return;
-            }
+        if (digitOf(amounts.get(0)) == targetDigit) {
+            return;
         }
-        // 没有尾数匹配的,找一个换到首位
+        // 首位不命中，找一个命中项 swap 到首位
         for (int i = 1; i < amounts.size(); i++) {
-            BigDecimal amt = amounts.get(i);
-            if (amt.remainder(BigDecimal.TEN).intValue() == targetDigit) {
-                Collections.swap(amounts, i, 0);
+            if (digitOf(amounts.get(i)) == targetDigit) {
+                Collections.swap(amounts, 0, i);
                 return;
             }
         }
+        // 没有任何命中项，无法保证（这种情况很罕见：total/count 太小无空间调整）
     }
 }

src/main/java/com/tailbet/service/impl/UserServiceImpl.java

@@ -14,6 +14,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.math.BigDecimal;
+
 import java.util.List;
 
 /**
@@ -53,7 +55,7 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IU
         user.setUsername(username);
         user.setPassword(passwordUtil.encode(password));
         user.setNickname(username);
-        user.setPoints(0L);
+        user.setPoints(BigDecimal.ZERO);
         user.setStatus(1);
         userMapper.insert(user);
 

src/main/resources/application-dev.yml

@@ -1,8 +1,6 @@
 spring:
   application:
     name: guess-game
-  profiles:
-    active: dev
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver
     url: jdbc:mysql://localhost:3306/guess_game?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&characterEncoding=utf8
@@ -32,6 +30,8 @@ mybatis-plus:
   configuration:
     map-underscore-to-camel-case: true
     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+#    log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl
+
   global-config:
     db-config:
       id-type: auto
@@ -39,13 +39,6 @@ mybatis-plus:
       logic-delete-value: 1
       logic-not-delete-value: 0
 
-#openim:
-##  api-url: ${OPENIM_API_URL:http://172.31.5.16:10002}
-#  api-url: ${OPENIM_API_URL:https://openim.xiu6688.com}
-#  ws-url: ${OPENIM_WS_URL:wss://im.xiu6688.com}
-#  admin-user: ${OPENIM_ADMIN_USER:imAdmin}
-#  admin-token: ${OPENIM_ADMIN_TOKEN:d71c0861267DM23adg}
-
 openim:
   # OpenIM REST API 外网地址（必填），下发给客户端 httpUrl
   apiUrl: https://openim.xiu6688.com
@@ -71,7 +64,7 @@ openim:
 
 
 jwt:
-  secret: ${JWT_SECRET:your-256-bit-secret-key-for-jwt-token-generation}
+  secret: ${JWT_SECRET:4d19a5c2984044848df9bed721512f9f}
   expiration: 604800000
 
 logging:

src/main/resources/application-test.yml

@@ -0,0 +1,72 @@
+spring:
+  application:
+    name: guess-game
+  datasource:
+    driver-class-name: com.mysql.cj.jdbc.Driver
+    url: jdbc:mysql://13.212.30.9:3306/guess_game?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&characterEncoding=utf8
+    username: app_user
+    password: ${DB_PASSWORD:dhOmjPJ2321wq!.}
+  data:
+    redis:
+      host: ${REDIS_HOST:127.0.0.1}
+      port: ${REDIS_PORT:6379}
+      password: ${REDIS_PASSWORD:ejgheyg2@eHSY2!.}
+      database: ${REDIS_DB:0}
+      timeout: 5000ms
+      lettuce:
+        pool:
+          max-active: 8
+          max-wait: -1ms
+          max-idle: 8
+          min-idle: 0
+
+server:
+  port: 9080
+
+mybatis-plus:
+  mapper-locations: classpath:mapper/**/*.xml
+  type-aliases-package: com.tailbet.entity
+  configuration:
+    map-underscore-to-camel-case: true
+    log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl
+
+  global-config:
+    db-config:
+      id-type: auto
+      logic-delete-field: deleted
+      logic-delete-value: 1
+      logic-not-delete-value: 0
+
+
+
+openim:
+  # OpenIM REST API 外网地址（必填），下发给客户端 httpUrl
+  apiUrl: https://openim.xiu6688.com
+  # OpenIM REST API 内网地址（可选），服务端调用，未配置则回落 apiUrl
+  internalApiUrl: http://172.31.5.16:10002
+  # OpenIM WebSocket 外网地址（必填），下发给客户端用于 IM SDK 初始化
+  wsUrl: wss://im.xiu6688.com
+  # OpenIM 管理员密钥（必填），用于获取 adminToken
+  secret: d71c0861267DM23adg
+  # OpenIM 管理员用户 ID（默认 imAdmin）
+  adminUserId: imAdmin
+  # 应用标识（默认 socialapp）
+  appId: socialapp
+  # adminToken 有效期秒数（默认 82800，即 23 小时）
+  tokenExpireSeconds: 82800
+  # 调用 OpenIM 接口的连接超时时间毫秒（默认 5000）
+  connectTimeoutMs: 5000
+  # 调用 OpenIM 接口的读取超时时间毫秒（默认 10000）
+  readTimeoutMs: 10000
+  # Webhook 签名密钥（可选），用于校验 OpenIM 回调请求
+  webhookSecret: your-webhook-secret
+
+
+
+jwt:
+  secret: ${JWT_SECRET:ecc6de473d6f4e0fbdaf5ea899fd2e26}
+  expiration: 604800000
+
+logging:
+  level:
+    com.tailbet: info

src/main/resources/sql/init.sql

@@ -10,7 +10,7 @@ CREATE TABLE IF NOT EXISTS user (
     password        VARCHAR(255) NOT NULL COMMENT '密码(BCrypt)',
     nickname        VARCHAR(50) DEFAULT '' COMMENT '昵称',
     avatar_url      VARCHAR(500) DEFAULT '' COMMENT '头像URL',
-    points          BIGINT DEFAULT 0 COMMENT '积分余额',
+    points          DECIMAL(20,2) DEFAULT 0 COMMENT '积分余额',
     is_ops          TINYINT DEFAULT 0 COMMENT '运营标记:0否 1是',
     is_bot          TINYINT DEFAULT 0 COMMENT '机器人标记:0否 1是',
     is_fake         TINYINT DEFAULT 0 COMMENT '假人托标记:0否 1是',
@@ -58,9 +58,9 @@ CREATE TABLE IF NOT EXISTS points_flow (
     id              BIGINT PRIMARY KEY AUTO_INCREMENT,
     user_id         BIGINT NOT NULL COMMENT '用户ID',
     type            VARCHAR(20) NOT NULL COMMENT '类型:ops_add/ops_sub/bet/award/rp_send/rp_recv',
-    amount          BIGINT NOT NULL COMMENT '变动数值(正负)',
-    balance_before  BIGINT NOT NULL COMMENT '变动前余额',
-    balance_after   BIGINT NOT NULL COMMENT '变动后余额',
+    amount          DECIMAL(20,2) NOT NULL COMMENT '变动数值(正负)',
+    balance_before  DECIMAL(20,2) NOT NULL COMMENT '变动前余额',
+    balance_after   DECIMAL(20,2) NOT NULL COMMENT '变动后余额',
     biz_no          VARCHAR(100) COMMENT '业务单号',
     operator_id     BIGINT COMMENT '操作人ID',
     remark          VARCHAR(255) DEFAULT '' COMMENT '备注',
@@ -100,11 +100,11 @@ CREATE TABLE IF NOT EXISTS bet_order (
     round_id        BIGINT NOT NULL COMMENT '局ID',
     client_msg_id   VARCHAR(100) COMMENT '客户端消息ID(防重)',
     play_type       VARCHAR(10) NOT NULL COMMENT '玩法:单/双/大/小/数字',
-    bet_amount      INT NOT NULL COMMENT '下注金额',
+    bet_amount      DECIMAL(20,2) NOT NULL COMMENT '下注金额',
     odds            DECIMAL(5,2) NOT NULL COMMENT '赔率',
     is_fake         TINYINT DEFAULT 0 COMMENT '是否假人下注',
     status          TINYINT DEFAULT 0 COMMENT '状态:0待结算 1已结算 2未中奖',
-    win_amount      BIGINT DEFAULT 0 COMMENT '中奖金额',
+    win_amount      DECIMAL(20,2) DEFAULT 0 COMMENT '中奖金额',
     deleted         TINYINT DEFAULT 0 COMMENT '逻辑删除',
     create_time     DATETIME DEFAULT CURRENT_TIMESTAMP,
     INDEX idx_user_round (user_id, round_id),
@@ -224,8 +224,8 @@ INSERT INTO sys_config (cfg_key, cfg_value, remark) VALUES
 INSERT INTO `guess_game`.`sys_config`(`id`, `cfg_key`, `cfg_value`, `remark`, `update_time`) VALUES (27, 'robot_id', '8', '机器人id', '2026-08-08 16:33:16');
 
 -- red_packet 表增加预分配金额字段
-ALTER TABLE red_packet ADD COLUMN share_amounts JSON COMMENT '预分配金额列表(JSON数组)';
-ALTER TABLE red_packet ADD COLUMN share_taken_count INT DEFAULT 0 COMMENT '已领取份额数';
+ALTER TABLE red_packet m COLUMN share_amounts JSON COMMENT '预分配金额列表(JSON数组，发红包时写入，领取时不再修改)';
+ALTER TABLE red_packet ADD COLUMN share_taken_index INT DEFAULT 0 COMMENT '下一个待领取份额的索引(从0开始)';
 
 -- game_round 表增加第一个红包ID字段
 ALTER TABLE game_round ADD COLUMN first_rp_id BIGINT COMMENT '第一个红包ID';
@@ -250,3 +250,14 @@ CREATE TABLE `pending_task` (
                                 INDEX `idx_execute_time` (`execute_time`),
                                 UNIQUE INDEX `idx_task_id` (`task_id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
+
+-- ====== 积分字段类型迁移：BIGINT → DECIMAL(20,2)，与红包金额统一精度 ======
+-- 历史BIGINT都是整数，DECIMAL(20,2)可无损容纳，无需特殊转换
+ALTER TABLE `user` MODIFY COLUMN `points` DECIMAL(20,2) DEFAULT 0 COMMENT '积分余额';
+ALTER TABLE `points_flow` MODIFY COLUMN `amount` DECIMAL(20,2) NOT NULL COMMENT '变动数值(正负)';
+ALTER TABLE `points_flow` MODIFY COLUMN `balance_before` DECIMAL(20,2) NOT NULL COMMENT '变动前余额';
+ALTER TABLE `points_flow` MODIFY COLUMN `balance_after` DECIMAL(20,2) NOT NULL COMMENT '变动后余额';
+
+-- ====== 注单金额字段类型迁移：INT/BIGINT → DECIMAL(20,2)，与积分/红包统一精度 ======
+ALTER TABLE `bet_order` MODIFY COLUMN `bet_amount` DECIMAL(20,2) NOT NULL COMMENT '下注金额';
+ALTER TABLE `bet_order` MODIFY COLUMN `win_amount` DECIMAL(20,2) DEFAULT 0 COMMENT '中奖金额';