From 502521c6cd1bd70bd5e93c2f2fffbd3189ef890f Mon Sep 17 00:00:00 2001 From: lucas Date: Tue, 2 Sep 2025 19:11:48 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E8=87=AA=E5=8A=A8=E6=81=A2=E5=A4=8D?= 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 3bb748d..05ed5fd 100644 --- a/consumers/consumerAxySkAlarm.go +++ b/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))