From 07a1ed7150441d3053f900b520f8f61a50291022 Mon Sep 17 00:00:00 2001
From: "walter.tan" <Walter.Tan@moco.com>
Date: Tue, 4 Nov 2025 18:31:53 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81=E6=89=A7=E8=A1=8C=E5=99=A8?=
 =?UTF-8?q?=E9=80=9A=E8=BF=87XxlJobContext=E8=8E=B7=E5=8F=96job=E7=9A=84?=
 =?UTF-8?q?=E8=A7=A6=E5=8F=91=E6=97=B6=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/xxl/job/core/context/XxlJobContext.java    | 12 +++++++++++-
 .../com/xxl/job/core/context/XxlJobHelper.java     | 14 ++++++++++++++
 .../java/com/xxl/job/core/thread/JobThread.java    |  1 +
 .../xxl/job/core/thread/TriggerCallbackThread.java |  1 +
 4 files changed, 27 insertions(+), 1 deletion(-)

diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/context/XxlJobContext.java b/xxl-job-core/src/main/java/com/xxl/job/core/context/XxlJobContext.java
index 7e350129..2f4d4bf2 100644
--- a/xxl-job-core/src/main/java/com/xxl/job/core/context/XxlJobContext.java
+++ b/xxl-job-core/src/main/java/com/xxl/job/core/context/XxlJobContext.java
@@ -31,6 +31,11 @@ public class XxlJobContext {
      */
     private final String jobLogFileName;
 
+    /**
+     * log date time
+     */
+    private final long logDateTime;
+
     // ---------------------- for shard ----------------------
 
     /**
@@ -61,10 +66,11 @@ public class XxlJobContext {
     private String handleMsg;
 
 
-    public XxlJobContext(long jobId, String jobParam, String jobLogFileName, int shardIndex, int shardTotal) {
+    public XxlJobContext(long jobId, String jobParam, String jobLogFileName, long logDateTime, int shardIndex, int shardTotal) {
         this.jobId = jobId;
         this.jobParam = jobParam;
         this.jobLogFileName = jobLogFileName;
+        this.logDateTime = logDateTime;
         this.shardIndex = shardIndex;
         this.shardTotal = shardTotal;
 
@@ -83,6 +89,10 @@ public class XxlJobContext {
         return jobLogFileName;
     }
 
+    public long getLogDateTime() {
+        return logDateTime;
+    }
+
     public int getShardIndex() {
         return shardIndex;
     }
diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/context/XxlJobHelper.java b/xxl-job-core/src/main/java/com/xxl/job/core/context/XxlJobHelper.java
index 868b9fb3..6764c8ec 100644
--- a/xxl-job-core/src/main/java/com/xxl/job/core/context/XxlJobHelper.java
+++ b/xxl-job-core/src/main/java/com/xxl/job/core/context/XxlJobHelper.java
@@ -64,6 +64,20 @@ public class XxlJobHelper {
         return xxlJobContext.getJobLogFileName();
     }
 
+    /**
+     * current LogDateTime
+     *
+     * @return logDateTime
+     */
+    public static long getLogDateTime() {
+        XxlJobContext xxlJobContext = XxlJobContext.getXxlJobContext();
+        if (xxlJobContext == null) {
+            return -1;
+        }
+
+        return xxlJobContext.getLogDateTime();
+    }
+
     // ---------------------- for shard ----------------------
 
     /**
diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java
index 3cec9a25..f595e5f3 100644
--- a/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java
+++ b/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java
@@ -122,6 +122,7 @@ public class JobThread extends Thread{
 							triggerParam.getJobId(),
 							triggerParam.getExecutorParams(),
 							logFileName,
+							triggerParam.getLogDateTime(),
 							triggerParam.getBroadcastIndex(),
 							triggerParam.getBroadcastTotal());
 
diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java
index 434917ac..9f151f14 100644
--- a/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java
+++ b/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java
@@ -209,6 +209,7 @@ public class TriggerCallbackThread {
                     null,
                     logFileName,
                     -1,
+                    -1,
                     -1));
             XxlJobHelper.log(logContent);
         }