From 820b713c95f3939cafbfdb76450c32d862c31222 Mon Sep 17 00:00:00 2001
From: Zhujx <Zhujx@Raytrontech.com>
Date: Tue, 30 Sep 2025 15:55:13 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E6=97=B6=E9=97=B4=E6=A0=A1?=
 =?UTF-8?q?=E9=AA=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../xiang/xservice/schedule/core/DynamicTaskScheduler.java | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/xservice-schedule-starter/src/main/java/com/xiang/xservice/schedule/core/DynamicTaskScheduler.java b/xservice-schedule-starter/src/main/java/com/xiang/xservice/schedule/core/DynamicTaskScheduler.java
index a5f7913..b67f93f 100644
--- a/xservice-schedule-starter/src/main/java/com/xiang/xservice/schedule/core/DynamicTaskScheduler.java
+++ b/xservice-schedule-starter/src/main/java/com/xiang/xservice/schedule/core/DynamicTaskScheduler.java
@@ -5,7 +5,6 @@ import lombok.RequiredArgsConstructor;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 import org.springframework.stereotype.Component;
 
-import javax.annotation.PostConstruct;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
 import java.util.Date;
@@ -21,8 +20,12 @@ public class DynamicTaskScheduler {
 
 
     public void schedule(TaskConfig config, Runnable task) {
+        schedule(config, task, LocalDateTime.now());
+    }
+
+    public void schedule(TaskConfig config, Runnable task, LocalDateTime serverTime) {
         LocalDateTime time = config.getExecutionTime();
-        if (time.isBefore(LocalDateTime.now())) return;
+        if (time.isBefore(serverTime)) return;
 
         ScheduledFuture<?> future = taskScheduler.schedule(() -> {
             try {