czg_team
/
video_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

大转盘补偿

This commit is contained in:
wangw 2025-01-14 18:49:56 +08:00
parent fa040a6529
commit 8aa4d6489a
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/com/sqx/modules/job/task/SpinningTask3.java
View File

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