|
|
@@ -42,7 +42,7 @@ public class SubscribedTask implements SchedulingConfigurer {
|
|
|
@Override
|
|
|
public void run() {
|
|
|
LocalDateTime startTime = LocalDateTime.now();
|
|
|
- LocalDateTime endTime = startTime.plusMinutes(10);
|
|
|
+ LocalDateTime endTime = startTime.plusMinutes(1);
|
|
|
List<Collection> collectionList = collectionRepo.selectStartTimeAfter(startTime, endTime);
|
|
|
collectionList.forEach(collection -> {
|
|
|
if (collection.getStartTime().isBefore(LocalDateTime.now()) && collection.getEndTime().isAfter(LocalDateTime.now())){
|
|
|
@@ -64,7 +64,7 @@ public class SubscribedTask implements SchedulingConfigurer {
|
|
|
}
|
|
|
}, triggerContext -> {
|
|
|
LocalDateTime startTime = LocalDateTime.now();
|
|
|
- LocalDateTime endTime = startTime.plusMinutes(2);
|
|
|
+ LocalDateTime endTime = startTime.plusMinutes(1);
|
|
|
List<Collection> collectionList = collectionRepo.selectStartTimeAfter(startTime, endTime);
|
|
|
if (Collections.isEmpty(collectionList)) {
|
|
|
// return new CronTrigger("0 0/10 * * * ?").nextExecutionTime(triggerContext);
|