From 8bea537798e1b6232f5132907b027ee6b010f1b4 Mon Sep 17 00:00:00 2001
From: opensnail <598092184@qq.com>
Date: Wed, 26 Feb 2025 23:27:57 +0800
Subject: [PATCH] =?UTF-8?q?feat(1.4.0-beta1):=201.=20=E6=81=A2=E5=A4=8D?=
 =?UTF-8?q?=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../retry/task/support/schedule/CleanerSchedule.java   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java
index 190e00bbf..718473a91 100644
--- a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java
+++ b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java
@@ -86,13 +86,13 @@ public class CleanerSchedule extends AbstractSchedule implements Lifecycle {
     protected void doExecute() {
         try {
             // 清除日志默认保存天数大于零、最少保留最近一天的日志数据
-//            if (systemProperties.getLogStorage() <= 1) {
-//                SnailJobLog.LOCAL.error("retry clear log storage error", systemProperties.getLogStorage());
-//                return;
-//            }
+            if (systemProperties.getLogStorage() <= 1) {
+                SnailJobLog.LOCAL.error("retry clear log storage error", systemProperties.getLogStorage());
+                return;
+            }
 
             // clean retry log
-            LocalDateTime endTime = LocalDateTime.now();
+            LocalDateTime endTime = LocalDateTime.now().minusDays(systemProperties.getLogStorage());
             long total = PartitionTaskUtils.process(startId -> retryTaskBatchList(startId, endTime),
                     this::processRetryLogPartitionTasks, 0);