|
|
@@ -2,8 +2,6 @@ package com.tidecloud.dataacceptance.service.impl;
|
|
|
|
|
|
import com.tidecloud.dataacceptance.common.DateUtil;
|
|
|
import com.tidecloud.dataacceptance.entity.Advice;
|
|
|
-import com.tidecloud.dataacceptance.entity.Device;
|
|
|
-import com.tidecloud.dataacceptance.entity.LbsInfo;
|
|
|
import com.tidecloud.dataacceptance.service.HexBinaryAcceptanceHandlerAdapter;
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
import io.netty.buffer.Unpooled;
|
|
|
@@ -11,19 +9,12 @@ import io.netty.channel.Channel;
|
|
|
import io.netty.channel.ChannelFuture;
|
|
|
import io.netty.channel.ChannelHandler.Sharable;
|
|
|
import io.netty.channel.ChannelHandlerContext;
|
|
|
-import io.netty.util.concurrent.Future;
|
|
|
-import io.netty.util.concurrent.GenericFutureListener;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
-import org.slf4j.MDC;
|
|
|
import org.springframework.context.annotation.Scope;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
-import java.nio.charset.Charset;
|
|
|
-import java.text.SimpleDateFormat;
|
|
|
-import java.util.ArrayList;
|
|
|
import java.util.Date;
|
|
|
-import java.util.List;
|
|
|
|
|
|
/**
|
|
|
* 恒盛互通成人手表
|
|
|
@@ -38,7 +29,9 @@ public class WatchHenShengServerHandler extends HexBinaryAcceptanceHandlerAdapte
|
|
|
|
|
|
@Override
|
|
|
protected void handle(ByteBuf in, Channel channel) throws Exception {
|
|
|
- String msg = byteBufferToString(in.nioBuffer());
|
|
|
+ byte[] req = new byte[in.readableBytes()];
|
|
|
+ in.readBytes(req);
|
|
|
+ String msg = new String(req,"UTF-8");
|
|
|
logger.info("传入数据：》》》》》》》》》" + msg);
|
|
|
Advice advice = setAdvice(msg);
|
|
|
switch (advice.getAdviceType()) {
|
jianghouwei