From b52f56e2e9acc8528b80a5312f36b2044be1edfb Mon Sep 17 00:00:00 2001
From: gaoyutao <duguprogromer@163.com>
Date: Tue, 10 Mar 2026 17:51:35 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E4=B8=9A=E5=8A=A1=E6=B5=81?=
 =?UTF-8?q?=E9=87=8F=E4=B8=8A=E6=8A=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../tongran/agent/server/core/enums/MsgEnum.java |  2 ++
 .../server/netty/enpoint/AgentEndpoint.java      | 16 ++++++++++++++++
 2 files changed, 18 insertions(+)

diff --git a/src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java b/src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java
index 4093299..ab8446f 100644
--- a/src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java
+++ b/src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java
@@ -43,6 +43,8 @@ public enum MsgEnum {
 
     网络上报重试("NET_RECOVER"),
 
+    业务网络上报("BUSINESS_NET"),
+
     挂载上报("POINT"),
 
     系统其他上报("OTHER_SYSTEM"),
diff --git a/src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java b/src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java
index fc861d7..80f7c17 100644
--- a/src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java
+++ b/src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java
@@ -231,6 +231,22 @@ public class AgentEndpoint {
         }
     }
 
+    @AgentDispatcher(msgId = MsgEnum.业务网络上报)
+    public class BusinessNetHandler implements AgentHandler {
+        @Override
+        public UpMsgResponse upHandle(String data, String clientId) {
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("clientId", clientId);
+            jsonObject.put("dataType", MsgEnum.业务网络上报.getValue());
+            jsonObject.put("data", data);
+            MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
+            agentProducer.asyncSend(mqMsg);
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
+        }
+    }
     @AgentDispatcher(msgId = MsgEnum.挂载上报)
     public class PointHandler implements AgentHandler {
         @Override