From cee381411e202fa782f77552c3bfecf19714aed5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=99=BD=E5=87=A4=E5=90=89?= <baifengji@163.com>
Date: Sun, 16 Mar 2025 12:17:01 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E5=88=9D=E5=A7=8B=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/qyft/ms/system/core/client/DeviceTcpClient.java     | 4 ++--
 .../java/com/qyft/ms/system/core/handler/DeviceMessageHandler.java    | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/qyft/ms/system/core/client/DeviceTcpClient.java b/src/main/java/com/qyft/ms/system/core/client/DeviceTcpClient.java
index d84990e..bdc8fc5 100644
--- a/src/main/java/com/qyft/ms/system/core/client/DeviceTcpClient.java
+++ b/src/main/java/com/qyft/ms/system/core/client/DeviceTcpClient.java
@@ -109,7 +109,7 @@ public class DeviceTcpClient {
      */
     public boolean send(String request) {
         if (channel != null && channel.isActive()) {
-            log.info("发送设备TCP指令：{}", request);
+            log.info("向设备发送TCP指令：{}", request);
             channel.writeAndFlush(Unpooled.copiedBuffer(request, CharsetUtil.UTF_8));
             return true;
         } else {
@@ -123,7 +123,7 @@ public class DeviceTcpClient {
      */
     @PreDestroy
     private void shutdown() {
-        log.info("正在关闭 TCP 客户端...");
+        log.info("正在关闭设备TCP客户端...");
         group.shutdownGracefully();
     }
 }
diff --git a/src/main/java/com/qyft/ms/system/core/handler/DeviceMessageHandler.java b/src/main/java/com/qyft/ms/system/core/handler/DeviceMessageHandler.java
index 32e5d1f..cd5a929 100644
--- a/src/main/java/com/qyft/ms/system/core/handler/DeviceMessageHandler.java
+++ b/src/main/java/com/qyft/ms/system/core/handler/DeviceMessageHandler.java
@@ -14,7 +14,7 @@ public class DeviceMessageHandler extends ChannelInboundHandlerAdapter {
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) {
         if (!(msg instanceof ByteBuf buf)) {
-            log.warn("收到未知类型的消息：{}", msg.getClass());
+            log.warn("设备TCP链接收到未知类型的消息：{}", msg.getClass());
             return;
         }
         try {
@@ -26,7 +26,7 @@ public class DeviceMessageHandler extends ChannelInboundHandlerAdapter {
             Integer cmdId = payload.getInt("cmdId");
 
         } catch (Exception e) {
-            log.error("TCP服务消息处理错误: {}, error: {}", buf.toString(CharsetUtil.UTF_8), e.getMessage(), e);
+            log.error("设备TCP链接消息处理错误: {}, error: {}", buf.toString(CharsetUtil.UTF_8), e.getMessage(), e);
         } finally {
             buf.release();
         }