Browse Source

update 自动恢复

dev
lucas 1 week ago
parent
commit
502521c6cd
  1. 4
      consumers/consumerAxySkAlarm.go

4
consumers/consumerAxySkAlarm.go

@ -243,7 +243,7 @@ func (the *consumerAxySkAlarm) judgeSK() string {
}
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.000"), level)
detail = "自动恢复"
payload := the.skAlarmElimination(alarmInfoTemplate, level, detail, trigger.StructName)
the.OutKafka.Publish(the.Info.IoConfig.Out.Kafka.AlarmTopic, payload)
delete(the.historyStationAlarmMap, hisK)
@ -267,7 +267,7 @@ func (the *consumerAxySkAlarm) judgeSK() string {
//恢复无告警的双控测点
log.Printf("无告警,待恢复的测点ids==%v", noAlarmStationIds)
for _, stationId := range noAlarmStationIds {
content := "测量值恢复正常和变化速率恢复正常"
content := "自动恢复"
payload := the.skAlarmAutoElimination(trigger.StructId, trigger.StructName, stationId, "", trigger.AlarmLevel, content)
the.OutKafka.Publish(the.Info.IoConfig.Out.Kafka.AlarmTopic, payload)
hisK := fmt.Sprintf("%s_%s", stationId, fmt.Sprintf("3077000%d", trigger.AlarmLevel))

Loading…
Cancel
Save