交换机时间戳
This commit is contained in:
@@ -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));
|
||||
|
||||
Reference in New Issue
Block a user