TailReader 中设置 NginxLog#requestTimestamp 字段的值

agent/src/main/java/cn/reghao/bnt/agent/service/TailReader.java

@@ -1,6 +1,7 @@
 package cn.reghao.bnt.agent.service;
 
 import cn.reghao.bnt.agent.ws.WsClient;
+import cn.reghao.jutil.jdk.converter.DateTimeConverter;
 import cn.reghao.jutil.jdk.io.TextFile;
 import cn.reghao.jutil.jdk.serializer.JsonConverter;
 import cn.reghao.jutil.jdk.web.log.NginxLog;
@@ -10,6 +11,7 @@ import java.io.File;
 import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.io.RandomAccessFile;
+import java.time.LocalDateTime;
 import java.util.List;
 
 /**
@@ -87,6 +89,9 @@ public class TailReader implements Runnable {
     private void parseAndPersist(String line, File errLogFile) {
         try {
             NginxLog nginxLog = JsonConverter.jsonToObject(line, NginxLog.class);
+            LocalDateTime localDateTime = DateTimeConverter.localDateTime(nginxLog.getTimeIso8601());
+            long timestamp = DateTimeConverter.msTimestamp(localDateTime);
+            nginxLog.setRequestTimestamp(timestamp);
             wsClient.send("", nginxLog);
         } catch (Exception e) {
             e.printStackTrace();