diff --git a/src/main/java/com/sqx/modules/job/task/SpinningTask3.java b/src/main/java/com/sqx/modules/job/task/SpinningTask3.java index 27dfd3ee..ec94dbda 100644 --- a/src/main/java/com/sqx/modules/job/task/SpinningTask3.java +++ b/src/main/java/com/sqx/modules/job/task/SpinningTask3.java @@ -32,7 +32,7 @@ public class SpinningTask3 { private Logger logger = LoggerFactory.getLogger(getClass()); - @Scheduled(cron = "0 0/1 * * * ? ") + @Scheduled(cron = "0 0/5 * * * ? ") public void record() { record("1"); } @@ -45,8 +45,8 @@ public class SpinningTask3 { params = "1"; } // 获取五分钟前的时间 - Date fiveMinutesAgo = DateUtil.offsetMinute(now, Integer.valueOf(params) * -6); - Date tenMinutesAgo = DateUtil.offsetMinute(now, (Integer.valueOf(params) * -6) - 6); + Date fiveMinutesAgo = DateUtil.offsetMinute(now, Integer.valueOf(params) * -5); + Date tenMinutesAgo = DateUtil.offsetMinute(now, (Integer.valueOf(params) * -5) - 15); // 将五分钟前的时间转换为指定格式的时间字符串,这里采用常见的"yyyy-MM-dd HH:mm:ss"格式 String fiveMinutesAgoStr = DateUtil.format(fiveMinutesAgo, "yyyy-MM-dd HH:mm:ss"); String tenMinutesAgoStr = DateUtil.format(tenMinutesAgo, "yyyy-MM-dd HH:mm:ss"); @@ -55,10 +55,10 @@ public class SpinningTask3 { recordQueryWrapper.isNull("target"); recordQueryWrapper.isNull("target_id"); recordQueryWrapper.eq("type", 2); - //大于 - recordQueryWrapper.lt("create_time", fiveMinutesAgoStr); - //小于 - recordQueryWrapper.gt("create_time", tenMinutesAgoStr); + //大于等于 + recordQueryWrapper.le("create_time", fiveMinutesAgoStr); + //小于等于 + recordQueryWrapper.ge("create_time", tenMinutesAgoStr); logger.info("大转盘到账补偿时间范围:{}-----{}", tenMinutesAgoStr, fiveMinutesAgoStr); List list = recordService.list(recordQueryWrapper); ThreadUtil.execAsync(() -> {