|
@@ -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);
|