lucas 1 week ago
parent
commit
a91d87e13a
  1. 5
      consumers/consumerAxySkAlarm.go

5
consumers/consumerAxySkAlarm.go

@ -222,6 +222,11 @@ func (the *consumerAxySkAlarm) judgeSK() string {
payload := the.skAlarmInfo(alarmInfoTemplate, level, detail, alarmTime)
the.OutKafka.Publish(the.Info.IoConfig.Out.Kafka.AlarmTopic, payload)
} else {
if level == 0 {
if v, ok := the.historyStationAlarmMap[sid]; ok {
level = v.AlarmLevel
}
}
payload := the.skAlarmElimination(alarmInfoTemplate, level, detail)
the.OutKafka.Publish(the.Info.IoConfig.Out.Kafka.AlarmTopic, payload)
delete(the.historyStationAlarmMap, sid)

Loading…
Cancel
Save