update

src/main/java/com/tidecloud/dataacceptance/service/AcceptanceInboundHandlerAdapter.java

@@ -143,7 +143,7 @@ public  class AcceptanceInboundHandlerAdapter extends ChannelInboundHandlerAdapt
 			public void onSuccess(SendResult<Integer,  byte[]> result) {
 				MDC.put("strategyName", AcceptanceInboundHandlerAdapter.this.getPrefixName());
 				// 成功业务逻辑
-				logger.info("发送kafka成功.deviceId:{}, msg:{}", key, msg);
+				logger.info("发送kafka成功.deviceId:{}, msg:{}", deviceId, msg);
 			}
 		};
 		// 发送失败回调
@@ -152,7 +152,7 @@ public  class AcceptanceInboundHandlerAdapter extends ChannelInboundHandlerAdapt
 			public void onFailure(Throwable ex) {
 				MDC.put("strategyName", AcceptanceInboundHandlerAdapter.this.getPrefixName());
 				// 失败业务逻辑
-				logger.error("发送kafka失败.deviceId:{}, msg:{}", key, msg);
+				logger.error("发送kafka失败.deviceId:{}, msg:{}", deviceId, msg);
 				singleThreadPool.execute(() -> FileUtils.dataStorage(dataByteArray,dataPath,prefixName));
 			}
 		};

src/main/java/com/tidecloud/dataacceptance/service/impl/BSJGpsServerHandler.java

@@ -98,6 +98,7 @@ public class BSJGpsServerHandler extends HexBinaryAcceptanceHandlerAdapter {
 			try {
 				TerminalAuthenticationMsg authenticationMsg = new TerminalAuthenticationMsg(packageData);
 				this.msgProcessService.processAuthMsg(authenticationMsg);
+				manageChannel(packageData.getChannel(), header.getTerminalPhone());
 				logger.info("<<<<<[终端鉴权],phone={},flowid={}", header.getTerminalPhone(), header.getFlowId());
 			} catch (Exception e) {
 				logger.error("<<<<<[终端鉴权]处理错误,phone={},flowid={},err={}", header.getTerminalPhone(), header.getFlowId(),