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

补偿机制2

This commit is contained in:
wangw 2024-12-27 16:40:25 +08:00
parent fae9df231c
commit 9f4820f32f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -41,9 +41,9 @@ public class SpinningTask3 implements ITask {
recordQueryWrapper.isNull("target_id"); recordQueryWrapper.isNull("target_id");
recordQueryWrapper.eq("type",2); recordQueryWrapper.eq("type",2);
//大于 //大于
recordQueryWrapper.gt("create_time",fiveMinutesAgoStr); recordQueryWrapper.lt("create_time",fiveMinutesAgoStr);
//小于 //小于
recordQueryWrapper.lt("create_time", tenMinutesAgoStr); recordQueryWrapper.gt("create_time", tenMinutesAgoStr);
List<DiscSpinningRecord> list = recordService.list(recordQueryWrapper); List<DiscSpinningRecord> list = recordService.list(recordQueryWrapper);
for (DiscSpinningRecord record : list) { for (DiscSpinningRecord record : list) {
spinningController.receive1(record); spinningController.receive1(record);