|
|
@@ -9,6 +9,7 @@ import java.util.concurrent.Executors;
|
|
|
|
|
|
import com.accept.client.DeviceReplyClient;
|
|
|
import com.accept.model.DeviceReplyDto;
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
@@ -72,11 +73,12 @@ public class BingShuiGpsServerHandler extends HexBinaryAcceptanceHandlerAdapter
|
|
|
logger.error(e.getMessage(), e);
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
byte[] dataByteArray = new byte[in.readableBytes()];
|
|
|
in.readBytes(dataByteArray);
|
|
|
sendMsg2Kafka(dataByteArray, phone, channel);
|
|
|
+ logger.info("解析数据:"+ JSON.toJSONString(dataMap));
|
|
|
String serialStr = dataMap.get("S");
|
|
|
+ logger.info("S 数据值为:"+ JSON.toJSONString(dataMap));
|
|
|
Integer serialId = Integer.valueOf(serialStr) + 1;
|
|
|
Date now = new Date();
|
|
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMddHHmmss");
|
jianghouwei