From 8d68562486bccd4608623fc8b94a7250847d8471 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Mon, 22 Jan 2024 11:29:28 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../timer/impl/HutoolTimerExeServiceImpl.java      | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/impl/HutoolTimerExeServiceImpl.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/impl/HutoolTimerExeServiceImpl.java
index cad2e090d..0d5885015 100644
--- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/impl/HutoolTimerExeServiceImpl.java
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/impl/HutoolTimerExeServiceImpl.java
@@ -22,10 +22,10 @@ import org.springframework.stereotype.Service;
 public class HutoolTimerExeServiceImpl implements TimerExeService {
 
     private static final Log log = Log.get();
-//    @Value("${runTake.maxRetryCount}")
-//    private Integer maxRetryCount;
-//    @Value("${runTake.delayTime}")
-//    private Integer delayTime;
+    @Value("${runTake.maxRetryCount}")
+    private Integer maxRetryCount;
+    @Value("${runTake.delayTime}")
+    private Integer delayTime;
     @Override
     public void startTimer(String taskId, String cron, String className) {
 
@@ -63,7 +63,7 @@ public class HutoolTimerExeServiceImpl implements TimerExeService {
 
     public void runTaskWithRetryAndDelay(TimerTaskRunner timerTaskRunner) throws InterruptedException {
         int retryCount = 0; // 重试次数计数器
-        while (retryCount < 10) {
+        while (retryCount < maxRetryCount) {
             try {
                 System.out.println("重试机制："+(retryCount+1));
                 timerTaskRunner.action();
@@ -71,10 +71,10 @@ public class HutoolTimerExeServiceImpl implements TimerExeService {
             } catch (Exception e) {
                 // 处理异常
                 retryCount++; // 增加重试次数
-                Thread.sleep(25000); // 等待一段时间
+                Thread.sleep(delayTime); // 等待一段时间
             }
         }
-        if (retryCount >= 10) {
+        if (retryCount >= maxRetryCount) {
             // 达到最大重试次数，终止任务
             return;
         }