|
|
@@ -53,7 +53,7 @@ public class WorkNoticeFlowTask { |
|
|
|
//1. 定时取 工作通知暂存表的数据进行发送 |
|
|
|
List<WorkNoticeStaging> stagingList = workNoticeStagingService.list(Wrappers.lambdaQuery(WorkNoticeStaging.class) |
|
|
|
.eq(WorkNoticeStaging::getDead, Boolean.FALSE) |
|
|
|
.ge(WorkNoticeStaging::getNextTime, LocalDateTime.now()) |
|
|
|
.le(WorkNoticeStaging::getNextTime, LocalDateTime.now()) |
|
|
|
.le(WorkNoticeStaging::getRetryTimes, StagingContant.Retry.MAX_RETRY_TIMES) |
|
|
|
.orderByAsc(WorkNoticeStaging::getId)); |
|
|
|
|
|
|
|