合并开源主线

648540858

2023-04-04 b4048fbe80dba8e7756ae557a15ab60b4f80a44b

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

@@ -1,10 +1,10 @@
package com.genersoft.iot.vmp.gb28181.session;



import com.alibaba.fastjson2.JSON;

import com.genersoft.iot.vmp.common.VideoManagerConstants;

import com.genersoft.iot.vmp.conf.UserSetting;

import com.genersoft.iot.vmp.gb28181.bean.SipTransactionInfo;

import com.genersoft.iot.vmp.gb28181.bean.SsrcTransaction;

import com.genersoft.iot.vmp.utils.JsonUtil;

import com.genersoft.iot.vmp.utils.redis.RedisUtil;

import gov.nist.javax.sip.message.SIPResponse;

import org.springframework.beans.factory.annotation.Autowired;

@@ -14,7 +14,7 @@
import java.util.ArrayList;

import java.util.List;



/**    
/**

 * @description:视频流session管理器，管理视频预览、预览回放的通信句柄 

 * @author: swwheihei

 * @date:   2020年5月13日 下午4:03:02     

@@ -29,7 +29,8 @@
      play,

      playback,

      download,

      broadcast

      broadcast,

      talk

   }



   /**

@@ -52,8 +53,7 @@
      ssrcTransaction.setSsrc(ssrc);

      ssrcTransaction.setMediaServerId(mediaServerId);

      ssrcTransaction.setType(type);

      System.out.println(22222);

      System.out.println(JSON.toJSONString(ssrcTransaction));



      RedisUtil.set(VideoManagerConstants.MEDIA_TRANSACTION_USED_PREFIX + userSetting.getServerId()

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

   }

@@ -136,7 +136,7 @@
      List<SsrcTransaction> result= new ArrayList<>();

      for (int i = 0; i < ssrcTransactionKeys.size(); i++) {

         String key = (String)ssrcTransactionKeys.get(i);

         SsrcTransaction ssrcTransaction = (SsrcTransaction)RedisUtil.get(key);

         SsrcTransaction ssrcTransaction = JsonUtil.redisJsonToObject(key, SsrcTransaction.class);

         result.add(ssrcTransaction);

      }

      return result;