|
@@ -68,7 +68,7 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
|
|
|
@Override
|
|
|
protected void handle(ByteBuf in, Channel channel) throws Exception {
|
|
|
|
|
|
- // String msg = byteBufferToString(in.nioBuffer());TODO (注意)
|
|
|
+ //String msg = byteBufferToString(in.nioBuffer());TODO (注意)
|
|
|
byte[] req = new byte[in.readableBytes()];
|
|
|
in.readBytes(req);
|
|
|
String msg = new String(req, "UTF-8");
|
|
@@ -84,7 +84,6 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
|
|
|
logger.info("该手表没有登录:且当前报文不是登录报文,不处理!,return" + msg);
|
|
|
channel.close();
|
|
|
return;
|
|
|
-
|
|
|
}
|
|
|
}
|
|
|
logger.info("传入数据为:" + msg);
|
|
@@ -119,9 +118,9 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
|
|
|
// 如果当前GPS 上报时间和当前服务器时间超过1小时直接断开连接重新连接
|
|
|
String gDay = msg.substring(6, 12);
|
|
|
String gTime = msg.substring(39, 45);
|
|
|
- if (checkGpsTime(gDay + gTime, time)) {
|
|
|
- channel.close();
|
|
|
- }
|
|
|
+// if (checkGpsTime(gDay + gTime, time)) {
|
|
|
+// channel.close();
|
|
|
+// }
|
|
|
setSwitchMap(deviceId, gpsState, msg, channel);// 采集数据
|
|
|
normalReply(factory, channel, "BP01");
|
|
|
break;
|