得怡佳 手表接入 修改为jdk8

src/main/java/com/tidecloud/dataacceptance/service/impl/WatchDYJServerHandler.java

@@ -50,7 +50,7 @@ public class WatchDYJServerHandler extends HexBinaryAcceptanceHandlerAdapter {
                 byte[] dataByteArray = new byte[in.readableBytes()];
                 in.readBytes(dataByteArray);
                 sendMsg2Kafka(dataByteArray, advice.getDeviceId(), channel);
-                // logger.info("正常存储设备信息：" + getDevice(msg).toString());
+                logger.info("正常存储设备信息：" +advice.toString());
                 normalReply(advice, channel, "UD");
                 break;
             default: // 其他
@@ -92,12 +92,7 @@ public class WatchDYJServerHandler extends HexBinaryAcceptanceHandlerAdapter {
         ByteBuf buffer = Unpooled.buffer(replyCommandStr.getBytes().length);
         buffer.writeBytes(replyCommandStr.getBytes());
         ChannelFuture channelFuture = channel.writeAndFlush(buffer);
-        channelFuture.addListener(new GenericFutureListener<Future<? super Void>>() {
-            @Override
-            public void operationComplete(Future<? super Void> future) throws Exception {
-                logger.info("Normal reply :" + replyCommandStr);
-            }
-        });
+        channelFuture.addListener(future -> logger.info("Normal reply :" + replyCommandStr));
     }
 
     /**