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