1、aletmessage解析c_time为datetime并入库

src/main/java/com/realtime/protection/configuration/entity/alert/AlertMessage.java

@@ -5,7 +5,7 @@ import com.fasterxml.jackson.annotation.JsonProperty;
 import com.realtime.protection.configuration.entity.task.FiveTupleWithMask;
 import lombok.Data;
 
-import java.sql.Timestamp;
+import java.time.LocalDateTime;
 
 
 @Data
@@ -55,7 +55,9 @@ public class AlertMessage {
     @JsonProperty("c_priority")
     private Integer c_priority;
     @JsonProperty("c_time")
-    private Timestamp c_time;
+    private Long c_time;
+
+    private LocalDateTime ctime;
     @JsonProperty("c_flowid")
     private String c_flowid;
     @JsonProperty("c_src_ipv4")

src/main/java/com/realtime/protection/server/alertmessage/AlertMessageService.java

@@ -14,7 +14,9 @@ import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
+import java.time.Instant;
 import java.time.LocalDateTime;
+import java.time.ZoneId;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.List;
@@ -39,6 +41,11 @@ public class AlertMessageService {
 
     @DSTransactional
     public void processAlertMessage(AlertMessage alertMessage) {
+        //将告警信息中的c_time转换为LocalDateTime，并写入ctime
+        Instant instant = Instant.ofEpochSecond(alertMessage.getC_time());
+        LocalDateTime localDateTime = LocalDateTime.ofInstant(instant, ZoneId.systemDefault());
+        alertMessage.setCtime(localDateTime);
+
         //根据告警信息——>生成指令
         List<TaskCommandInfo> dynamicTaskCommandInfoList = generateDynamicCommand(alertMessage);
         //可能isProtectSrcOrDst和isProtectSrcOrDst都为FALSE，说明没有生成指令