From dea455d9e3880773180f08d3327fddc66323127e Mon Sep 17 00:00:00 2001 From: lucas Date: Mon, 1 Sep 2025 10:01:55 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E6=97=B6=E9=97=B4=E6=89=93=E5=8D=B0?= =?UTF-8?q?=E5=88=B0=E6=AF=AB=E7=A7=92?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consumers/consumerAxySkAlarm.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/consumers/consumerAxySkAlarm.go b/consumers/consumerAxySkAlarm.go index 55d22e1..9226f21 100644 --- a/consumers/consumerAxySkAlarm.go +++ b/consumers/consumerAxySkAlarm.go @@ -212,7 +212,7 @@ func (the *consumerAxySkAlarm) judgeSK() string { continue } //纪录历史告警 - log.Printf("trigger.Id=%d, 测点[%s]本次触发双控,%s,时刻[%s]level=%d", trigger.Id, sid, hisK, alarmTime.Format("2006-01-02 15:04:05"), level) + log.Printf("trigger.Id=%d, 测点[%s]本次触发双控,%s,时刻[%s]level=%d", trigger.Id, sid, hisK, alarmTime.Format("2006-01-02 15:04:05.000"), level) the.historyStationAlarmMap[hisK] = AXY_SK.HistoryAlarm{ SourceId: sid, AlarmLevel: level, @@ -227,7 +227,7 @@ func (the *consumerAxySkAlarm) judgeSK() string { level = trigger.AlarmLevel } if v, ok := the.historyStationAlarmMap[hisK]; ok { - log.Printf("trigger.Id=%d, 测点[%s]本次 恢复双控%s,时刻[%s]level=%d", trigger.Id, sid, hisK, v.Time.Format("2006-01-02 15:04:05"), level) + log.Printf("trigger.Id=%d, 测点[%s]本次 恢复双控%s,时刻[%s]level=%d", trigger.Id, sid, hisK, v.Time.Format("2006-01-02 15:04:05.000"), level) payload := the.skAlarmElimination(alarmInfoTemplate, level, detail) the.OutKafka.Publish(the.Info.IoConfig.Out.Kafka.AlarmTopic, payload) @@ -406,7 +406,7 @@ func (the *consumerAxySkAlarm) updateEsAlarmTriggerHistory(structId int) { Time: alarm.EndTime, AlarmLevel: alarm.CurrentLevel, } - log.Printf("加载双控历史告警 hisK=%s,time=%v", hisK, alarm.EndTime) + log.Printf("加载双控历史告警 hisK=%s,time=%v", hisK, alarm.EndTime.Format("2006-01-02T15:04:05.000+0800")) } log.Printf("双控历史告警 共 %d条", len(the.historyStationAlarmMap)) }