From 7d90483cc90d8bc353be90a20391952b6b35f4ef Mon Sep 17 00:00:00 2001
From: qiminbao <qaz001122>
Date: Mon, 22 Sep 2025 22:39:07 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=B8=8A=E6=8A=A5=E5=BA=94?=
 =?UTF-8?q?=E7=AD=94?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../agent/server/core/enums/MsgEnum.java      |  2 +
 .../server/netty/enpoint/AgentEndpoint.java   | 40 +++++++++++++++----
 2 files changed, 34 insertions(+), 8 deletions(-)

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 3a338b4..ba39c1b 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
@@ -40,6 +40,8 @@ public enum MsgEnum {
 
     交换机上报("SWITCHBOARD"),
 
+    采集上报应答("COLLECT_RSP"),
+
     开启或更新系统采集("SYSTEM_COLLECT_START"),
 
     开启或更新系统采集应答("SYSTEM_COLLECT_START_RSP"),
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 d34138d..0ff9f79 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
@@ -97,7 +97,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -111,7 +114,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -125,7 +131,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -139,7 +148,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -153,7 +165,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -167,7 +182,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -181,7 +199,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }
 
@@ -195,7 +216,10 @@ public class AgentEndpoint {
             jsonObject.put("data", data);
             MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
             agentProducer.asyncSend(mqMsg);
-            return null;
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
         }
     }