支持执行器通过XxlJobContext获取job的触发时间

Author: walter.tan

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 String getJobLogFileName() {
         return jobLogFileName;
     }
 
+    public long getLogDateTime() {
+        return logDateTime;
+    }
+
     public int getShardIndex() {
         return shardIndex;
     }

xxl-job-core/src/main/java/com/xxl/job/core/context/XxlJobHelper.java

@@ -64,6 +64,20 @@ public static String getJobLogFileName() {
         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 ----------------------
 
     /**

xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java

@@ -122,6 +122,7 @@ public void run() {
 							triggerParam.getJobId(),
 							triggerParam.getExecutorParams(),
 							logFileName,
+							triggerParam.getLogDateTime(),
 							triggerParam.getBroadcastIndex(),
 							triggerParam.getBroadcastTotal());
 

xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java

@@ -209,6 +209,7 @@ private void callbackLog(List<HandleCallbackRequest> callbackParamList, String l
                     null,
                     logFileName,
                     -1,
+                    -1,
                     -1));
             XxlJobHelper.log(logContent);
         }