xiu688/xiu_b
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix job

Browse Source
This commit is contained in:
wells
2026-08-08 20:51:50 +08:00
parent d8b2eb4bbb
commit 52061b9d59
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/tailbet/job/GameJob.java
+4 -4
View File
@@ -190,7 +190,7 @@ public class GameJob {
/** /**
* 检查红包是否需要托领取(每3秒执行) * 检查红包是否需要托领取(每3秒执行)
*/ */
// @Scheduled(fixedDelay = 3000) @Scheduled(fixedDelay = 3000)
public void checkRedPacketForFakeReceive() { public void checkRedPacketForFakeReceive() {
// 查找进行中的游戏红包 // 查找进行中的游戏红包
List<RedPacket> ongoingRps = redPacketMapper.selectList(new LambdaQueryWrapper<RedPacket>() List<RedPacket> ongoingRps = redPacketMapper.selectList(new LambdaQueryWrapper<RedPacket>()
@@ -266,7 +266,7 @@ public class GameJob {
/** /**
* 检查局超时(每10秒执行) * 检查局超时(每10秒执行)
*/ */
// @Scheduled(fixedDelay = 10000) @Scheduled(fixedDelay = 10000)
public void checkRoundTimeout() { public void checkRoundTimeout() {
List<GameRound> ongoingRounds = gameRoundMapper.selectList(new LambdaQueryWrapper<GameRound>() List<GameRound> ongoingRounds = gameRoundMapper.selectList(new LambdaQueryWrapper<GameRound>()
.eq(GameRound::getStatus, 0)); .eq(GameRound::getStatus, 0));
@@ -291,7 +291,7 @@ public class GameJob {
/** /**
* 每日凌晨重置活跃假人池 * 每日凌晨重置活跃假人池
*/ */
// @Scheduled(cron = "0 0 0 * * ?") @Scheduled(cron = "0 0 0 * * ?")
public void resetDailyFakeUsers() { public void resetDailyFakeUsers() {
fakeUserService.resetDailyActiveFakes(); fakeUserService.resetDailyActiveFakes();
} }
@@ -636,7 +636,7 @@ public class GameJob {
/** /**
* 处理延迟任务队列(每秒执行) * 处理延迟任务队列(每秒执行)
*/ */
// @Scheduled(fixedDelay = 1000) @Scheduled(fixedDelay = 1000)
public void processPendingTasks() { public void processPendingTasks() {
LocalDateTime now = LocalDateTime.now(); LocalDateTime now = LocalDateTime.now();
pendingTasks.entrySet().removeIf(entry -> { pendingTasks.entrySet().removeIf(entry -> {