From 3ed38314aa9b0d976ad31c57f44e6a63afc487a5 Mon Sep 17 00:00:00 2001 From: opensnail <598092184@qq.com> Date: Wed, 26 Feb 2025 23:26:02 +0800 Subject: [PATCH] =?UTF-8?q?feat(1.4.0-beta1):=201.=20=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E9=87=8D=E8=AF=95=E4=BB=BB=E5=8A=A1=E7=BB=9F=E8=AE=A1=E6=95=B0?= =?UTF-8?q?=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datasource/persistence/mapper/RetryMapper.java | 2 +- .../retry/task/support/schedule/RetrySummarySchedule.java | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) 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;