|
|
@ -261,7 +261,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)) |
|
|
|