diff --git a/src/main/java/com/tongran/agent/client/scheduler/service/BusinessTasks.java b/src/main/java/com/tongran/agent/client/scheduler/service/BusinessTasks.java index c0fa107..c472dce 100644 --- a/src/main/java/com/tongran/agent/client/scheduler/service/BusinessTasks.java +++ b/src/main/java/com/tongran/agent/client/scheduler/service/BusinessTasks.java @@ -258,11 +258,11 @@ public class BusinessTasks { // String data = JSONArray.toJSONString(list); // Message message = Message.builder().clientId(GlobalConfig.CLIENT_ID).dataType(MsgEnum.交换机上报.getValue()).data(data).build(); JSONObject jsonObject = new JSONObject(); - jsonObject.put("timestamp", timestamp); String data = switchBoardService.getSwitchDataByType(type); if(StringUtils.isNotBlank(data)){ jsonObject = JSONObject.parseObject(data); } + jsonObject.put("timestamp", timestamp); Message message = Message.builder().clientId(GlobalConfig.CLIENT_ID).dataType(MsgEnum.交换机上报.getValue()).data(jsonObject.toString()).build(); sessionManager.writeAndFlush(sessionManager.getSessionById(GlobalConfig.CLIENT_ID).getChannel(), message); AssertLog.info("发送交换机信息包={}",JSON.toJSONString(message));