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)) }