fix: 修改设备凭证和删除设备时移除设备会话信息

@@ -17,6 +17,7 @@ import java.security.NoSuchAlgorithmException;
 import java.text.ParseException;
 import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.stream.Collectors;
 import javax.annotation.PostConstruct;
 import javax.sdp.SdpFactory;
 import javax.sdp.SdpParseException;
@@ -769,9 +770,11 @@ public class SIPProcessorObserver extends SIPRequestProcessorParent
       UUID sessionId, TransportProtos.SessionCloseNotificationProto sessionCloseNotification) {
     log.trace(
         "[{}] Received the remote command to close the session: {}",
-        sessionId,
+            sessionId,
         sessionCloseNotification.getMessage());
-    //        deviceSessionCtx.getChannel().close();
+    List<String> cameraCodes = deviceSessions.values().stream().filter(gbtDeviceSessionCtx ->gbtDeviceSessionCtx.getSessionId().equals(sessionId))
+                    .map(gbtDeviceSessionCtx -> gbtDeviceSessionCtx.getCameraCode()).collect(Collectors.toList());
+    removeDeviceSession(cameraCodes);
   }
 
   @Override
@@ -963,11 +966,16 @@ public class SIPProcessorObserver extends SIPRequestProcessorParent
 
   @Override
   public void onDeviceDeleted(DeviceId deviceId) {
-    //        context.onAuthFailure(address);
-    //        ChannelHandlerContext ctx = deviceSessionCtx.getChannel();
-    //        ctx.close();
+    List<String> cameraCodes = deviceSessions.values().stream().filter(gbtDeviceSessionCtx -> gbtDeviceSessionCtx.getDeviceId().equals(deviceId))
+            .map(gbtDeviceSessionCtx->gbtDeviceSessionCtx.getCameraCode()).collect(Collectors.toList());
+    removeDeviceSession(cameraCodes);
   }
 
+  private void removeDeviceSession(List<String> cameraCodes){
+    if(null != cameraCodes && !cameraCodes.isEmpty()){
+      deviceSessions.remove(cameraCodes.get(0));
+    }
+  }
   public void cameraInviteResponse(ResponseEvent evt) {
 
     try {