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