From 7ab87be6a207c3a3d99717cab23cd15c81ddb9bd Mon Sep 17 00:00:00 2001 From: lucas Date: Sat, 30 Aug 2025 14:19:49 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=20=E6=81=A2=E5=A4=8D?= =?UTF-8?q?=E5=91=8A=E8=AD=A6=E6=97=B6=20=20=E5=91=8A=E8=AD=A6=E7=AD=89?= =?UTF-8?q?=E7=BA=A7=E8=8E=B7=E5=8F=96=E4=B8=8D=E5=88=B0=E7=9A=84=E6=83=85?= =?UTF-8?q?=E5=86=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consumers/consumerAxySkAlarm.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/consumers/consumerAxySkAlarm.go b/consumers/consumerAxySkAlarm.go index 2213fb1..6ed4be3 100644 --- a/consumers/consumerAxySkAlarm.go +++ b/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)