Agent/tr-agent-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

交换机采集时间修正

Browse Source
This commit is contained in:
qiminbao
2025-09-23 11:44:26 +08:00
parent c139da0d91
commit 8bafa180d8
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/tongran/agent/client/scheduler/service/BusinessTasks.java
+2 -3
View File
@@ -248,8 +248,7 @@ public class BusinessTasks {
*/ */
@Async("taskExecutor") @Async("taskExecutor")
public void switchBoardTask(String type) { public void switchBoardTask(String type) {
long timestamp = System.currentTimeMillis(); long timestamp = AgentUtil.roundMinutes();
timestamp = Math.round(timestamp / 1000.0);
int count = task8Counter.incrementAndGet(); int count = task8Counter.incrementAndGet();
AssertLog.info("交换机信息采集定时任务执行 - 时间: {}，task #{}", LocalDateTime.now(), count); AssertLog.info("交换机信息采集定时任务执行 - 时间: {}，task #{}", LocalDateTime.now(), count);
// 判定客户端与服务端是否连接 // 判定客户端与服务端是否连接
@@ -259,11 +258,11 @@ public class BusinessTasks {
// String data = JSONArray.toJSONString(list); // String data = JSONArray.toJSONString(list);
// Message message = Message.builder().clientId(GlobalConfig.CLIENT_ID).dataType(MsgEnum.交换机上报.getValue()).data(data).build(); // Message message = Message.builder().clientId(GlobalConfig.CLIENT_ID).dataType(MsgEnum.交换机上报.getValue()).data(data).build();
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
jsonObject.put("timestamp", timestamp);
String data = switchBoardService.getSwitchDataByType(type); String data = switchBoardService.getSwitchDataByType(type);
if(StringUtils.isNotBlank(data)){ if(StringUtils.isNotBlank(data)){
jsonObject = JSONObject.parseObject(data); jsonObject = JSONObject.parseObject(data);
} }
jsonObject.put("timestamp", timestamp);
Message message = Message.builder().clientId(GlobalConfig.CLIENT_ID).dataType(MsgEnum.交换机上报.getValue()).data(jsonObject.toString()).build(); Message message = Message.builder().clientId(GlobalConfig.CLIENT_ID).dataType(MsgEnum.交换机上报.getValue()).data(jsonObject.toString()).build();
sessionManager.writeAndFlush(sessionManager.getSessionById(GlobalConfig.CLIENT_ID).getChannel(), message); sessionManager.writeAndFlush(sessionManager.getSessionById(GlobalConfig.CLIENT_ID).getChannel(), message);
AssertLog.info("发送交换机信息包={}",JSON.toJSONString(message)); AssertLog.info("发送交换机信息包={}",JSON.toJSONString(message));