소스 검색

feature: 针对808协议的补传信息也发送到kafka

vinson 5 년 전
부모
커밋
863087901f
1개의 변경된 파일2개의 추가작업 그리고 1개의 파일을 삭제
  1. 2 1
      src/main/java/com/tidecloud/dataacceptance/service/impl/BSJGpsServerHandler.java

+ 2 - 1
src/main/java/com/tidecloud/dataacceptance/service/impl/BSJGpsServerHandler.java

@@ -68,7 +68,8 @@ public class BSJGpsServerHandler extends HexBinaryAcceptanceHandlerAdapter {
 			packageData.setDeviceId(deviceId);
 			//发送数据到kafka
 			final MsgHeader header = packageData.getMsgHeader();
-			if (Constants.MSG_TERMINAL_LOCATION_INFO_UPLOAD == header.getMsgId()) {
+			if (Constants.MSG_TERMINAL_LOCATION_INFO_UPLOAD == header.getMsgId()
+					|| Constants.MSG_TERMINAL_LOCATION_INFO_BATCH_UPLOAD == header.getMsgId()) {
 				sendMsg2Kafka(dataByteArray, packageData.getDeviceId(), channel);
 			}
 			this.processPackageData(packageData);