|
@@ -112,6 +112,8 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
|
|
|
case "AP03": // 连接(心跳) BP03#
|
|
|
normalReply(factory, channel, "BP03");
|
|
|
checkSwitchMap(factory, deviceId, channel);// 心跳校验 下发报文
|
|
|
+ sendMsg2Kafka((msg + deviceId + "," + DateUtil.formatDate2String(new Date())).getBytes(), deviceId, channel);// 心跳报文下发
|
|
|
+ logger.warn("心跳报文下发 msg+" + msg);
|
|
|
break;
|
|
|
case "AP01": // 位置信息
|
|
|
String gpsState = msg.substring(12, 13);
|