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 {