Showing
1 changed file
with
3 additions
and
3 deletions
| @@ -157,7 +157,7 @@ public class TcpTransportHandler extends ChannelInboundHandlerAdapter implements | @@ -157,7 +157,7 @@ public class TcpTransportHandler extends ChannelInboundHandlerAdapter implements | ||
| 157 | ByteBuf message = (ByteBuf) msg; | 157 | ByteBuf message = (ByteBuf) msg; |
| 158 | byte[] byteMsg = ByteBufUtils.buf2Bytes(message); | 158 | byte[] byteMsg = ByteBufUtils.buf2Bytes(message); |
| 159 | String msgStr = ByteUtils.bytesToStr(byteMsg); | 159 | String msgStr = ByteUtils.bytesToStr(byteMsg); |
| 160 | - log.error("会话【{}】收到设备【{}】来自【{}】数据【{}】", sessionId, deviceSessionCtx.getDeviceId(), address, msgStr); | 160 | + log.debug("会话【{}】收到设备【{}】来自【{}】数据【{}】", sessionId, deviceSessionCtx.getDeviceId(), address, msgStr); |
| 161 | deviceSessionCtx.setChannel(ctx); | 161 | deviceSessionCtx.setChannel(ctx); |
| 162 | if (deviceSessionCtx.getDeviceInfo() == null || deviceSessionCtx.getDeviceProfile() == null) { | 162 | if (deviceSessionCtx.getDeviceInfo() == null || deviceSessionCtx.getDeviceProfile() == null) { |
| 163 | processConnect(ctx, msgStr); | 163 | processConnect(ctx, msgStr); |
| @@ -534,7 +534,7 @@ public class TcpTransportHandler extends ChannelInboundHandlerAdapter implements | @@ -534,7 +534,7 @@ public class TcpTransportHandler extends ChannelInboundHandlerAdapter implements | ||
| 534 | 534 | ||
| 535 | @Override | 535 | @Override |
| 536 | public void onToDeviceRpcRequest(UUID sessionId, TransportProtos.ToDeviceRpcRequestMsg rpcRequest) { | 536 | public void onToDeviceRpcRequest(UUID sessionId, TransportProtos.ToDeviceRpcRequestMsg rpcRequest) { |
| 537 | - log.error("【{}】下发RPC命令【{}】给设备【{}】", sessionId, rpcRequest.getParams(), deviceSessionCtx.getDeviceInfo().getDeviceName()); | 537 | + log.debug("【{}】下发RPC命令【{}】给设备【{}】", sessionId, rpcRequest.getParams(), deviceSessionCtx.getDeviceInfo().getDeviceName()); |
| 538 | TcpTransportAdaptor adaptor = deviceSessionCtx.getPayloadAdaptor(); | 538 | TcpTransportAdaptor adaptor = deviceSessionCtx.getPayloadAdaptor(); |
| 539 | try { | 539 | try { |
| 540 | adaptor.convertToPublish(deviceSessionCtx, rpcRequest).ifPresent(payload -> { | 540 | adaptor.convertToPublish(deviceSessionCtx, rpcRequest).ifPresent(payload -> { |
| @@ -572,7 +572,7 @@ public class TcpTransportHandler extends ChannelInboundHandlerAdapter implements | @@ -572,7 +572,7 @@ public class TcpTransportHandler extends ChannelInboundHandlerAdapter implements | ||
| 572 | 572 | ||
| 573 | @Override | 573 | @Override |
| 574 | public void onToServerRpcResponse(TransportProtos.ToServerRpcResponseMsg rpcResponse) { | 574 | public void onToServerRpcResponse(TransportProtos.ToServerRpcResponseMsg rpcResponse) { |
| 575 | - log.error("[{}] 服务端响应设备的RPC请求", sessionId); | 575 | + log.debug("[{}] 服务端响应设备的RPC请求", sessionId); |
| 576 | // String baseTopic = toServerRpcSubTopicType.getRpcResponseTopicBase(); | 576 | // String baseTopic = toServerRpcSubTopicType.getRpcResponseTopicBase(); |
| 577 | // TcpTransportAdaptor adaptor = deviceSessionCtx.getAdaptor(toServerRpcSubTopicType); | 577 | // TcpTransportAdaptor adaptor = deviceSessionCtx.getAdaptor(toServerRpcSubTopicType); |
| 578 | // try { | 578 | // try { |