From cec34fc2d4ac208bb854dbf0f33ff9b4d33717a3 Mon Sep 17 00:00:00 2001
From: zy_Java <654600784@qq.com>
Date: Thu, 27 May 2021 09:31:59 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=B7=E6=B1=82=E7=83=AD=E6=88=90=E5=83=8F?=
 =?UTF-8?q?=E6=94=B9=E6=88=9015=E7=A7=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/ccsens/logistics/Netty/NettyClient.java   | 2 +-
 .../com/ccsens/logistics/Netty/SimpleClientHandler.java     | 6 +++++-
 util/src/test/java/com/ccsens/util/OtherTest.java           | 6 +++---
 3 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java b/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java
index a3c7a8b1..66872579 100644
--- a/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java
+++ b/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java
@@ -72,7 +72,7 @@ public class NettyClient {
         ScheduledExecutorService service = Executors
                 .newSingleThreadScheduledExecutor();
         // 第二个参数为首次执行的延时时间，第三个参数为定时执行的间隔时间
-        service.scheduleAtFixedRate(runnable, 2, 5, TimeUnit.SECONDS);
+        service.scheduleAtFixedRate(runnable, 2, 15, TimeUnit.SECONDS);
 
 //        创建并执行在给定延迟后启用的 ScheduledFuture。
 //        参数：
diff --git a/logistics/src/main/java/com/ccsens/logistics/Netty/SimpleClientHandler.java b/logistics/src/main/java/com/ccsens/logistics/Netty/SimpleClientHandler.java
index 08cb5751..10e022c6 100644
--- a/logistics/src/main/java/com/ccsens/logistics/Netty/SimpleClientHandler.java
+++ b/logistics/src/main/java/com/ccsens/logistics/Netty/SimpleClientHandler.java
@@ -6,6 +6,7 @@ import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
@@ -14,6 +15,7 @@ import java.nio.charset.Charset;
 /**
  * @author 逗
  */
+@Slf4j
 @ChannelHandler.Sharable
 @Component
 public class SimpleClientHandler extends ChannelInboundHandlerAdapter{
@@ -24,7 +26,9 @@ public class SimpleClientHandler extends ChannelInboundHandlerAdapter{
     public void channelRead(ChannelHandlerContext ctx, Object msg) {
         if (msg instanceof ByteBuf) {
             String value = ((ByteBuf) msg).toString(Charset.defaultCharset());
-            System.out.println("服务器端返回的数据:" + value.substring(value.length()-3,value.length()));
+
+            log.info("服务器端返回的数据:{}",value.substring(value.length() > 500 ? value.length()-300 : 0));
+
             if(StrUtil.isNotEmpty(value) && value.lastIndexOf("not online") == -1) {
                 thermalImageryService.disposeMessage(value);
             }
diff --git a/util/src/test/java/com/ccsens/util/OtherTest.java b/util/src/test/java/com/ccsens/util/OtherTest.java
index 16cc0bcc..4d5d2c78 100644
--- a/util/src/test/java/com/ccsens/util/OtherTest.java
+++ b/util/src/test/java/com/ccsens/util/OtherTest.java
@@ -125,9 +125,9 @@ public class OtherTest {
     public void test9(){
         String s = "050005BD: The device is not online";
         String as = "55";
-
-        System.out.println(s.lastIndexOf("not online"));
-        System.out.println(as.lastIndexOf("not online"));
+        System.out.println(s.substring(s.length() > 200 ? s.length()-190 : 0));
+//        System.out.println(s.lastIndexOf("not online"));
+//        System.out.println(as.lastIndexOf("not online"));
     }
     @Test
     public void test10(){