From 138e59ad6b2207dfeed97bbe91a9c5df86e576c1 Mon Sep 17 00:00:00 2001
From: zhangyuxiang <1323804152@qq.com>
Date: Mon, 29 Jun 2026 16:54:57 +0800
Subject: [PATCH] =?UTF-8?q?=E9=92=88=E5=AF=B9=E5=AE=89=E4=BF=A19=E6=A1=A59?=
 =?UTF-8?q?=E9=9A=A7=E9=A1=B9=E7=9B=AE=EF=BC=8C=E5=8F=AA=E6=8E=A8=E9=80=81?=
 =?UTF-8?q?=E5=B9=B3=E5=8F=B01=E7=BA=A7=E8=B6=85=E9=98=88=E5=80=BC?=
 =?UTF-8?q?=E5=91=8A=E8=AD=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 consumers/consumerZWYHBJCAS.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/consumers/consumerZWYHBJCAS.go b/consumers/consumerZWYHBJCAS.go
index 4960865..19fc622 100644
--- a/consumers/consumerZWYHBJCAS.go
+++ b/consumers/consumerZWYHBJCAS.go
@@ -670,7 +670,8 @@ func (the *consumerZWYHBJCAS) onData(topic string, msg string) bool {
 		if err != nil {
 			log.Printf("反序列化 异常 alarm数据=%s", msg)
 		} else {
-			if alarmData.AlarmTypeCode == "3007" && the.JudgeExist(alarmData.StructureId) {
+			//if alarmData.AlarmTypeCode == "3007" && the.JudgeExist(alarmData.StructureId) {
+			if alarmData.AlarmCode == "30070001" && the.JudgeExist(alarmData.StructureId) {
 				//收到配置结构物产生的超阈值告警
 				alarms := the.getAlarmInfo(alarmData)
 				if len(alarms) > 0 {