From 46fd9f6d92c9624e0bb68f2e74c542dbd4b4af26 Mon Sep 17 00:00:00 2001
From: byteblogs168 <598092184@qq.com>
Date: Mon, 29 Jan 2024 15:01:47 +0800
Subject: [PATCH] =?UTF-8?q?feat:=202.6.0=201.=20=E4=BF=AE=E5=A4=8D?=
 =?UTF-8?q?=E5=B8=B8=E9=A9=BB=E4=BB=BB=E5=8A=A1=E6=B2=A1=E6=9C=89=E6=A0=A1?=
 =?UTF-8?q?=E9=AA=8C=E7=BB=84=E7=8A=B6=E6=80=81=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../job/task/support/dispatch/JobExecutorActor.java  | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/dispatch/JobExecutorActor.java b/easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/dispatch/JobExecutorActor.java
index cddf39be..ee4dd5c7 100644
--- a/easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/dispatch/JobExecutorActor.java
+++ b/easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/dispatch/JobExecutorActor.java
@@ -28,8 +28,10 @@ import com.aizuda.easy.retry.server.job.task.support.executor.job.JobExecutorCon
 import com.aizuda.easy.retry.server.job.task.support.executor.job.JobExecutorFactory;
 import com.aizuda.easy.retry.server.job.task.support.timer.JobTimerWheel;
 import com.aizuda.easy.retry.server.job.task.support.timer.ResidentJobTimerTask;
+import com.aizuda.easy.retry.template.datasource.persistence.mapper.GroupConfigMapper;
 import com.aizuda.easy.retry.template.datasource.persistence.mapper.JobMapper;
 import com.aizuda.easy.retry.template.datasource.persistence.mapper.JobTaskBatchMapper;
+import com.aizuda.easy.retry.template.datasource.persistence.po.GroupConfig;
 import com.aizuda.easy.retry.template.datasource.persistence.po.Job;
 import com.aizuda.easy.retry.template.datasource.persistence.po.JobTaskBatch;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -64,6 +66,8 @@ public class JobExecutorActor extends AbstractActor {
     private JobTaskBatchMapper jobTaskBatchMapper;
     @Autowired
     private TransactionTemplate transactionTemplate;
+    @Autowired
+    private GroupConfigMapper groupConfigMapper;
 
     @Override
     public Receive createReceive() {
@@ -185,6 +189,14 @@ public class JobExecutorActor extends AbstractActor {
             return;
         }
 
+        long count = groupConfigMapper.selectCount(new LambdaQueryWrapper<GroupConfig>()
+            .eq(GroupConfig::getNamespaceId, job.getNamespaceId())
+            .eq(GroupConfig::getGroupName, job.getGroupName())
+            .eq(GroupConfig::getGroupStatus, StatusEnum.YES.getStatus()));
+        if (count == 0) {
+            return;
+        }
+
         JobTimerTaskDTO jobTimerTaskDTO = new JobTimerTaskDTO();
         jobTimerTaskDTO.setJobId(taskExecuteDTO.getJobId());
         jobTimerTaskDTO.setTaskBatchId(taskExecuteDTO.getTaskBatchId());