diff --git a/snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/RetryMapper.java b/snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/RetryMapper.java index a30eb7065..0fad28307 100644 --- a/snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/RetryMapper.java +++ b/snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/RetryMapper.java @@ -15,5 +15,5 @@ public interface RetryMapper extends BaseMapper { int updateBatchNextTriggerAtById(@Param("list") List list); - List selectRetrySummaryList(@Param("ew") Wrapper wrapper); + List selectRetrySummaryList(@Param("ew") Wrapper wrapper); } diff --git a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/RetrySummarySchedule.java b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/RetrySummarySchedule.java index 249696bfe..36ff548bf 100644 --- a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/RetrySummarySchedule.java +++ b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/RetrySummarySchedule.java @@ -10,6 +10,7 @@ import com.aizuda.snailjob.server.common.triple.Triple; import com.aizuda.snailjob.template.datasource.persistence.dataobject.DashboardRetryResponseDO; import com.aizuda.snailjob.template.datasource.persistence.mapper.RetryMapper; import com.aizuda.snailjob.template.datasource.persistence.mapper.RetrySummaryMapper; +import com.aizuda.snailjob.template.datasource.persistence.po.Retry; import com.aizuda.snailjob.template.datasource.persistence.po.RetrySummary; import com.aizuda.snailjob.template.datasource.persistence.po.RetryTask; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -61,9 +62,9 @@ public class RetrySummarySchedule extends AbstractSchedule implements Lifecycle // 重试按日实时查询统计数据(00:00:00 - 23:59:59) LocalDateTime todayFrom = LocalDateTime.of(LocalDate.now(), LocalTime.MIN).plusDays(-i); LocalDateTime todayTo = LocalDateTime.of(LocalDate.now(), LocalTime.MAX).plusDays(-i); - LambdaQueryWrapper wrapper = new LambdaQueryWrapper() - .between(RetryTask::getCreateDt, todayFrom, todayTo) - .groupBy(RetryTask::getNamespaceId, RetryTask::getGroupName, RetryTask::getSceneName); + LambdaQueryWrapper wrapper = new LambdaQueryWrapper() + .between(Retry::getCreateDt, todayFrom, todayTo) + .groupBy(Retry::getNamespaceId, Retry::getGroupName, Retry::getSceneName); List dashboardRetryResponseDOList = retryMapper.selectRetrySummaryList(wrapper); if (CollUtil.isEmpty(dashboardRetryResponseDOList)) { continue;