2个小bug

朱俊杰

2022-03-29 b0e494b842448568b6c20c9fbc7baa1df106b595

 src/main/java/com/genersoft/iot/vmp/gb28181/session/VideoStreamSessionManager.java

@@ -30,6 +30,12 @@
   @Autowired

   private UserSetup userSetup;



   public enum SessionType {

      play,

      playback,

      download

   }



   /**

    * 添加一个点播/回放的事务信息

    * 后续可以通过流Id/callID

@@ -40,7 +46,7 @@
    * @param mediaServerId 所使用的流媒体ID

    * @param transaction 事务

    */

   public void put(String deviceId, String channelId, String callId, String stream, String ssrc, String mediaServerId, ClientTransaction transaction){

   public void put(String deviceId, String channelId, String callId, String stream, String ssrc, String mediaServerId, ClientTransaction transaction, SessionType type){

      SsrcTransaction ssrcTransaction = new SsrcTransaction();

      ssrcTransaction.setDeviceId(deviceId);

      ssrcTransaction.setChannelId(channelId);

@@ -50,6 +56,7 @@
      ssrcTransaction.setCallId(callId);

      ssrcTransaction.setSsrc(ssrc);

      ssrcTransaction.setMediaServerId(mediaServerId);

      ssrcTransaction.setType(type);



      redisUtil.set(VideoManagerConstants.MEDIA_TRANSACTION_USED_PREFIX + userSetup.getServerId()

            + "_" +  deviceId + "_" + channelId + "_" + callId + "_" + stream, ssrcTransaction);

@@ -86,6 +93,15 @@
      return dialog;

   }



   public SIPDialog getDialogByCallId(String deviceId, String channelId, String callID){

      SsrcTransaction ssrcTransaction = getSsrcTransaction(deviceId, channelId, callID, null);

      if (ssrcTransaction == null) return null;

      byte[] dialogByteArray = ssrcTransaction.getDialog();

      if (dialogByteArray == null) return null;

      SIPDialog dialog = (SIPDialog)SerializeUtils.deSerialize(dialogByteArray);

      return dialog;

   }



   public SsrcTransaction getSsrcTransaction(String deviceId, String channelId, String callId, String stream){

      if (StringUtils.isEmpty(callId)) callId ="*";

      if (StringUtils.isEmpty(stream)) stream ="*";

@@ -95,6 +111,21 @@
      return (SsrcTransaction)redisUtil.get((String) scanResult.get(0));

   }



   public List<SsrcTransaction> getSsrcTransactionForAll(String deviceId, String channelId, String callId, String stream){

      if (StringUtils.isEmpty(deviceId)) deviceId ="*";

      if (StringUtils.isEmpty(channelId)) channelId ="*";

      if (StringUtils.isEmpty(callId)) callId ="*";

      if (StringUtils.isEmpty(stream)) stream ="*";

      String key = VideoManagerConstants.MEDIA_TRANSACTION_USED_PREFIX + userSetup.getServerId() + "_" + deviceId + "_" + channelId + "_" + callId+ "_" + stream;

      List<Object> scanResult = redisUtil.scan(key);

      if (scanResult.size() == 0) return null;

      List<SsrcTransaction> result = new ArrayList<>();

      for (Object keyObj : scanResult) {

         result.add((SsrcTransaction)redisUtil.get((String) keyObj));

      }

      return result;

   }



   public String getMediaServerId(String deviceId, String channelId, String stream){

      SsrcTransaction ssrcTransaction = getSsrcTransaction(deviceId, channelId, null, stream);

      if (ssrcTransaction == null) return null;