gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(1.4.0-beta1): 1. 优化重试任务统计数据

Browse Source
This commit is contained in:
opensnail 2025-02-26 23:26:02 +08:00
parent 2c7e1f47a7
commit 5f242ddc28
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/RetryMapper.java
View File

@ -15,5 +15,5 @@ public interface RetryMapper extends BaseMapper<Retry> {
int updateBatchNextTriggerAtById(@Param("list") List<Retry> list);
List<DashboardRetryResponseDO> selectRetrySummaryList(@Param("ew") Wrapper<RetryTask> wrapper);
List<DashboardRetryResponseDO> selectRetrySummaryList(@Param("ew") Wrapper<Retry> wrapper);
}

7
snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/RetrySummarySchedule.java
View File

@ -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<RetryTask> wrapper = new LambdaQueryWrapper<RetryTask>()
.between(RetryTask::getCreateDt, todayFrom, todayTo)
.groupBy(RetryTask::getNamespaceId, RetryTask::getGroupName, RetryTask::getSceneName);
LambdaQueryWrapper<Retry> wrapper = new LambdaQueryWrapper<Retry>()
.between(Retry::getCreateDt, todayFrom, todayTo)
.groupBy(Retry::getNamespaceId, Retry::getGroupName, Retry::getSceneName);
List<DashboardRetryResponseDO> dashboardRetryResponseDOList = retryMapper.selectRetrySummaryList(wrapper);
if (CollUtil.isEmpty(dashboardRetryResponseDOList)) {
continue;