From d47b969e9691671816378a525e11619ae016c94a Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Mon, 29 Apr 2024 11:21:01 +0800
Subject: [PATCH] =?UTF-8?q?update=20-=20=E6=9C=AC=E5=9C=B0=E5=90=AF?=
 =?UTF-8?q?=E5=8A=A8=E6=97=B6,=E4=B8=8D=E5=8A=A0=E8=BD=BD=20xxljob?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/axzo/workflow/core/conf/FlowableConfiguration.java     | 4 ++++
 .../workflow/server/common/config/XxlJobConfiguration.java    | 2 ++
 2 files changed, 6 insertions(+)

diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/FlowableConfiguration.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/FlowableConfiguration.java
index 66c8995cb..d8d9a7131 100644
--- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/FlowableConfiguration.java
+++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/FlowableConfiguration.java
@@ -46,8 +46,12 @@ public class FlowableConfiguration {
             //            configuration.setCreateDiagramOnDeploy(false);
             configuration.setIdGenerator(new DistributedTimeBasedIdGenerator(stringRedisTemplate));
             configuration.setHistoricProcessInstanceDataManager(new CustomMybatisHistoricProcessInstanceDataManager(configuration));
+            // 自定义的异步任务处理器
             configuration.addCustomJobHandler(new AsyncApproveTaskJobHandler());
             configuration.addCustomJobHandler(new AsyncRejectTaskJobHandler(extAxHiTaskInstService));
+            // 异步任务异常重试时间间隔
+            configuration.setDefaultFailedJobWaitTime(30);
+            configuration.setAsyncFailedJobWaitTime(30);
             configuration.setCustomAsyncRunnableExecutionExceptionHandlers(Lists.newArrayList(new CustomAsyncRunnableExecutionExceptionHandler()));
         };
     }
diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/common/config/XxlJobConfiguration.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/common/config/XxlJobConfiguration.java
index 8f1f0452c..7d34b5eb4 100644
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/common/config/XxlJobConfiguration.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/common/config/XxlJobConfiguration.java
@@ -1,5 +1,6 @@
 package cn.axzo.workflow.server.common.config;
 
+import cn.azxo.framework.common.annotation.OnlyPodsEnvironment;
 import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -13,6 +14,7 @@ import org.springframework.context.annotation.Configuration;
  * @author wangli
  * @since 2024/4/28 14:02
  */
+@OnlyPodsEnvironment
 @Configuration
 public class XxlJobConfiguration {
     Logger logger = LoggerFactory.getLogger(XxlJobConfiguration.class);