From 55780c8bfdde7a1596b6a87d124cfcfdf2dca565 Mon Sep 17 00:00:00 2001
From: qiminbao <qaz001122>
Date: Fri, 26 Sep 2025 17:19:16 +0800
Subject: [PATCH] =?UTF-8?q?agent=E6=B3=A8=E5=86=8C=E4=BA=A4=E6=8D=A2?=
 =?UTF-8?q?=E6=9C=BA=E5=A2=9E=E5=8A=A0=E7=B4=A2=E5=BC=95=E8=BF=87=E6=BB=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../server/rockermq/listener/AgentConsumerDownListener.java  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
index 3c5f63e..527b18d 100644
--- a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
+++ b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
@@ -99,6 +99,7 @@ public class AgentConsumerDownListener implements RocketMQListener<String> {
                         String pwrOID = "";
                         String fanOID = "";
                         String otherOID = "";
+                        String filters = "";
                         JSONObject json = JSONObject.parseObject(switchBoard);
                         if(json.containsKey("community")){
                             community = json.getString("community");
@@ -127,6 +128,9 @@ public class AgentConsumerDownListener implements RocketMQListener<String> {
                         if(json.containsKey("otherOID")){
                             otherOID = json.getString("otherOID");
                         }
+                        if(json.containsKey("filters")){
+                            filters = json.getString("filters");
+                        }
                         JSONObject switchBoardJson = new JSONObject();
                         switchBoardJson.put("community",community);
                         switchBoardJson.put("ip",switchIp);
@@ -137,6 +141,7 @@ public class AgentConsumerDownListener implements RocketMQListener<String> {
                         switchBoardJson.put("pwrOID",pwrOID);
                         switchBoardJson.put("fanOID",fanOID);
                         switchBoardJson.put("otherOID",otherOID);
+                        switchBoardJson.put("filters",filters);
                         object.put("switchBoard",switchBoardJson.toString());
                         AssertLog.info("交换机配置信息={}",switchBoardJson.toString());
                     }