1、任务停止，收到告警信息不入库了。HEADhaskafka

2、指令状态记录，插入时间以查询到流量回传的当前时间为指令状态日志表的effective_time，而不是查到的流量的开始时间。因为后者有可能导致流量开始时间在上一个下发周期导致频繁往上一个下发周期插入。

2 files changed, 3 insertions, 3 deletions

diff --git a/src/main/java/com/realtime/protection/server/alertmessage/AlertMessageService.java b/src/main/java/com/realtime/protection/server/alertmessage/AlertMessageService.java
index b6d0cec..18a1859 100644
--- a/src/main/java/com/realtime/protection/server/alertmessage/AlertMessageService.java
+++ b/src/main/java/com/realtime/protection/server/alertmessage/AlertMessageService.java
@@ -88,7 +88,7 @@ public class AlertMessageService {
                 default://主要是stop
                     //command不入库
                     //alertmessage入库
-                    insertAlertMessageOnly(alertMessage);
+//                    insertAlertMessageOnly(alertMessage);
                     break;
             }
         else if (taskType == TaskTypeEnum.JUDGED.getTaskType())//研判后
@@ -111,7 +111,7 @@ public class AlertMessageService {
                 default://主要是stop
                     //command不入库
                     //alertmessage入库
-                    insertAlertMessageOnly(alertMessage);
+//                    insertAlertMessageOnly(alertMessage);
             }
     }
 
diff --git a/src/main/resources/mappers/CommandMapper.xml b/src/main/resources/mappers/CommandMapper.xml
index b065915..80c2e89 100644
--- a/src/main/resources/mappers/CommandMapper.xml
+++ b/src/main/resources/mappers/CommandMapper.xml
@@ -957,7 +957,7 @@
         )
         select
             #{log_id},
-            #{effective_time},
+            NOW(),
             NULL,
             TASK_ID,
             RULE_ID,