fix 创建群
This commit is contained in:
@@ -190,7 +190,7 @@ public class GameJob {
|
||||
/**
|
||||
* 检查红包是否需要托领取(每3秒执行)
|
||||
*/
|
||||
@Scheduled(fixedDelay = 3000)
|
||||
// @Scheduled(fixedDelay = 3000)
|
||||
public void checkRedPacketForFakeReceive() {
|
||||
// 查找进行中的游戏红包
|
||||
List<RedPacket> ongoingRps = redPacketMapper.selectList(new LambdaQueryWrapper<RedPacket>()
|
||||
@@ -266,7 +266,7 @@ public class GameJob {
|
||||
/**
|
||||
* 检查局超时(每10秒执行)
|
||||
*/
|
||||
@Scheduled(fixedDelay = 10000)
|
||||
// @Scheduled(fixedDelay = 10000)
|
||||
public void checkRoundTimeout() {
|
||||
List<GameRound> ongoingRounds = gameRoundMapper.selectList(new LambdaQueryWrapper<GameRound>()
|
||||
.eq(GameRound::getStatus, 0));
|
||||
@@ -291,7 +291,7 @@ public class GameJob {
|
||||
/**
|
||||
* 每日凌晨重置活跃假人池
|
||||
*/
|
||||
@Scheduled(cron = "0 0 0 * * ?")
|
||||
// @Scheduled(cron = "0 0 0 * * ?")
|
||||
public void resetDailyFakeUsers() {
|
||||
fakeUserService.resetDailyActiveFakes();
|
||||
}
|
||||
@@ -636,7 +636,7 @@ public class GameJob {
|
||||
/**
|
||||
* 处理延迟任务队列(每秒执行)
|
||||
*/
|
||||
@Scheduled(fixedDelay = 1000)
|
||||
// @Scheduled(fixedDelay = 1000)
|
||||
public void processPendingTasks() {
|
||||
LocalDateTime now = LocalDateTime.now();
|
||||
pendingTasks.entrySet().removeIf(entry -> {
|
||||
|
||||
Reference in New Issue
Block a user