|
|
|
@ -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 { |
|
|
|
|