From 69de854fb1c03c671f791156728c457b9d079b18 Mon Sep 17 00:00:00 2001 From: byteblogs168 <598092184@qq.com> Date: Fri, 18 Aug 2023 07:46:34 +0800 Subject: [PATCH] =?UTF-8?q?feat:=202.2.0=201.=20=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E5=B9=82=E7=AD=89=E6=B2=A1=E6=9C=89=E8=BF=87=E6=BB=A4=E7=B1=BB?= =?UTF-8?q?=E5=9E=8B=E4=B8=BATaskTypeEnum.RETRY=E5=92=8C=E7=8A=B6=E6=80=81?= =?UTF-8?q?=EF=BC=9ARetryStatusEnum.RUNNING=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../retry/server/support/generator/task/AbstractGenerator.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/AbstractGenerator.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/AbstractGenerator.java index a58b73b21..982dd089d 100644 --- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/AbstractGenerator.java +++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/AbstractGenerator.java @@ -2,6 +2,7 @@ package com.aizuda.easy.retry.server.support.generator.task; import cn.hutool.core.lang.Assert; import cn.hutool.core.lang.Pair; +import com.aizuda.easy.retry.common.core.enums.RetryStatusEnum; import com.aizuda.easy.retry.common.core.log.LogUtils; import com.aizuda.easy.retry.common.core.util.JsonUtil; import com.aizuda.easy.retry.server.enums.DelayLevelEnum; @@ -66,6 +67,8 @@ public abstract class AbstractGenerator implements TaskGenerator { List retryTasks = retryTaskAccess.list(taskContext.getGroupName(), new LambdaQueryWrapper() .eq(RetryTask::getGroupName, taskContext.getGroupName()) .eq(RetryTask::getSceneName, taskContext.getSceneName()) + .eq(RetryTask::getRetryStatus, RetryStatusEnum.RUNNING.getStatus()) + .eq(RetryTask::getTaskType, TaskTypeEnum.RETRY.getType()) .in(RetryTask::getIdempotentId, idempotentIdSet)); Map> retryTaskMap = retryTasks.stream().collect(Collectors.groupingBy(RetryTask::getIdempotentId));