From fa71295112af9a2ab0ad5b0148759bb8b44392a6 Mon Sep 17 00:00:00 2001 From: lucas Date: Mon, 1 Sep 2025 16:43:21 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E9=81=BF=E5=85=8D=E7=A9=BA=E5=BA=94?= =?UTF-8?q?=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consumers/consumerAxySkAlarm.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/consumers/consumerAxySkAlarm.go b/consumers/consumerAxySkAlarm.go index 8163b66..d42cb86 100644 --- a/consumers/consumerAxySkAlarm.go +++ b/consumers/consumerAxySkAlarm.go @@ -247,7 +247,7 @@ func (the *consumerAxySkAlarm) judgeSK() string { //无告警的测点,需要恢复 var noAlarmStationIds []string - var alarmStationIdMap map[string]string + alarmStationIdMap := map[string]string{} for _, alarm := range alarms { alarmStationIdMap[alarm.SourceId] = alarm.AlarmCode } @@ -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))