Merge branch 'cherry-pick-45fed0b1' into 'master'

fix: tcp/udp设备接入更新产品和设备信息时,更新其session信息

See merge request yunteng/thingskit!400

@@ -13,6 +13,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.thingsboard.common.util.JacksonUtil;
 import org.thingsboard.server.common.adaptor.AdaptorException;
 import org.thingsboard.server.common.data.DataConstants;
+import org.thingsboard.server.common.data.Device;
 import org.thingsboard.server.common.data.DeviceProfile;
 import org.thingsboard.server.common.data.DeviceTransportType;
 import org.thingsboard.server.common.data.device.profile.TkTcpDeviceProfileTransportConfiguration;
@@ -138,7 +139,6 @@ public class TcpUdpDataHandler implements SessionMsgListener {
     }
     deviceSessionCtx.tryProcessQueuedMsgs(msg -> processDeviceSessionMsg(ctx, msg));
   }
-
   private void processAuthTokenConnect(ChannelHandlerContext ctx, TcpAuthEntry accessToken) {
 
     log.debug(
@@ -519,6 +519,20 @@ public class TcpUdpDataHandler implements SessionMsgListener {
   }
 
   @Override
+  public void onDeviceProfileUpdate(
+          TransportProtos.SessionInfoProto sessionInfo, DeviceProfile deviceProfile) {
+    deviceSessionCtx.onDeviceProfileUpdate(sessionInfo, deviceProfile);
+  }
+
+  @Override
+  public void onDeviceUpdate(
+          TransportProtos.SessionInfoProto sessionInfo,
+          Device device,
+          Optional<DeviceProfile> deviceProfileOpt) {
+    deviceSessionCtx.onDeviceUpdate(sessionInfo, device, deviceProfileOpt);
+    deviceSessionCtx.setDeviceCode(JacksonUtil.toString(device.getAdditionalInfo()));
+  }
+  @Override
   public void onDeviceDeleted(DeviceId deviceId) {
     context.onAuthFailure(address);
     if (isTcp) {