From 0313c0cd3ca5cf4c69f74288de6249ce94f378ee Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B0=B7=E6=88=90=E4=BC=9F?= Date: Fri, 27 Dec 2024 12:53:21 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E6=97=A5=E5=BF=97=E7=BA=A7?= =?UTF-8?q?=E5=88=AB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/das/modules/data/service/TDEngineService.java | 2 +- .../node/service/impl/NodeMessageServiceImpl.java | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/das/src/main/java/com/das/modules/data/service/TDEngineService.java b/das/src/main/java/com/das/modules/data/service/TDEngineService.java index 1e99ff2d..b0d66f3a 100644 --- a/das/src/main/java/com/das/modules/data/service/TDEngineService.java +++ b/das/src/main/java/com/das/modules/data/service/TDEngineService.java @@ -426,7 +426,7 @@ public class TDEngineService { } try { pstmt.executeUpdate(sb.toString()); - log.info("告警信息入库：{}",sb.toString()); + log.debug("告警信息入库：{}",sb.toString()); } catch (SQLException ex) { log.error("save deviceEvent error", ex); } diff --git a/das/src/main/java/com/das/modules/node/service/impl/NodeMessageServiceImpl.java b/das/src/main/java/com/das/modules/node/service/impl/NodeMessageServiceImpl.java index 285e7b52..e9e14da1 100644 --- a/das/src/main/java/com/das/modules/node/service/impl/NodeMessageServiceImpl.java +++ b/das/src/main/java/com/das/modules/node/service/impl/NodeMessageServiceImpl.java @@ -358,7 +358,7 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node // 使用 TypeReference 来指定转换目标类型 List list = objectMapper.convertValue(dataEvent, new TypeReference>() { }); - log.info("消息data转化deviceVo,{}", list); + log.debug("消息data转化deviceVo,{}", list); for (DeviceEventVo item : list) { DeviceInfoCache deviceInfoCache = cacheService.getEquipmentCache().getDeviceInfoCacheById(Long.valueOf(item.getDeviceId())); Integer firstTriggeredCode = adminRedisTemplate.get(String.format("RT:%s:%s", item.getDeviceId(), "FirstTriggeredCode".toLowerCase())); @@ -397,8 +397,8 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node deviceEventInfo.setEventText(item.getAttrCode() + fieldName + descList.get(1)); } Integer level = dataService.eventLevelMap.get(model).get(item.getAttrCode()); - log.info("level:{}", level); - log.info("fieldname{}", fieldName); + log.debug("level:{}", level); + log.debug("fieldname{}", fieldName); deviceEventInfo.setEventLevel(level == null ? 0 : level); } } else { @@ -448,7 +448,7 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node } ConcurrentWebSocketSessionDecorator concurrentWebSocketSessionDecorator = new ConcurrentWebSocketSessionDecorator(session, 5 * 1000, 2 * 1024 * 1024); onlineWSSessions.put(nodeId, concurrentWebSocketSessionDecorator); - + log.info("节点:{}已连接, IP: {}", nodeId, remoteIp); //如果采集程序的版本是0，则直接下发当前配置。 if (version == 0) { sendTerminalConfig(nodeId); @@ -485,7 +485,7 @@ public class NodeMessageServiceImpl extends TextWebSocketHandler implements Node @Override protected void handlePongMessage(WebSocketSession session, PongMessage message) throws Exception { Long nodeId = (Long) session.getAttributes().get(NodeConstant.NODE_ID); - log.info("收到 Node:{} Pong Message", nodeId); + log.debug("收到 Node:{} Pong Message", nodeId); session.getAttributes().put(NodeConstant.LAST_PONG_TIME, System.currentTimeMillis()); }