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 158aeb4b..5189414b 100644 --- a/src/main/java/com/sqx/modules/job/task/SpinningTask3.java +++ b/src/main/java/com/sqx/modules/job/task/SpinningTask3.java @@ -41,9 +41,9 @@ public class SpinningTask3 implements ITask { recordQueryWrapper.isNull("target_id"); 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 list = recordService.list(recordQueryWrapper); for (DiscSpinningRecord record : list) { spinningController.receive1(record);