feat:萤石增加多人观看策略

@@ -92,6 +92,17 @@ public class TkVideoController extends BaseController {
     return getCameraURL(entityId, null);
   }
 
+  @GetMapping("outVideo/{entityId}")
+  @ApiOperation("退出视频流播放")
+  public void outVideo(
+          @PathVariable("entityId") String entityId) throws ThingsboardException {
+     videoService.outVideo(
+            getCurrentUser().isTenantAdmin(),
+            getCurrentUser().getCurrentUserId(),
+            getCurrentUser().getCurrentTenantId(),
+            entityId);
+  }
+
   @GetMapping("url/{entityId}/{protocolType}")
   @ApiOperation("获取平台视频流播放地址")
   public ResponseResult<Map<String, String>> getCameraPreviewURL(

@@ -9,6 +9,7 @@ import org.thingsboard.server.common.data.yunteng.utils.HttpClientUtils;
 import org.thingsboard.server.common.data.yunteng.utils.JacksonUtil;
 
 import java.io.IOException;
+import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
@@ -21,6 +22,11 @@ public class EzvizUtils {
     private static Long expireTime;
 
     public static String getCameraPreviewURL(String appKey, String appSecret, String sn) throws IOException {
+        //查询缓存中是否已有该设备的直播url
+        String videoUrl =  VideoNumbersUtils.getUrl(appKey+sn);
+        if(!StringUtils.isEmpty(videoUrl)){
+            return videoUrl;
+        }
         getAccessTokenByUrl(appKey,appSecret);
         String cameraPreviewURL  = url+"v2/live/address/get?accessToken="+accessToken+
                 "&deviceSerial="+sn+"&protocol=4&quality=1";
@@ -38,6 +44,8 @@ public class EzvizUtils {
                     }
                     throw new TkDataValidationException(message);
                 }
+                //将获取到的rul放入缓存
+                VideoNumbersUtils.putVideoUrl(appKey+sn,json.get("url").textValue());
                 return json.get("url").textValue();
             }else{
                 String errorCode = json.get("code").asText();
@@ -85,4 +93,11 @@ public class EzvizUtils {
         }
     }
 
+    public static void main(String[] args) {
+        Date date = new Date(1703235281);
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+        System.out.println(sdf.format(date));
+    }
+
 }

+package org.thingsboard.server.common.data.yunteng.utils.tools;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class VideoNumbersUtils {
+
+    private static  Map<String, Map<String,Object>> number = new HashMap<>();
+
+
+    public static void putVideoUrl(String key,String url)  {
+        Map<String,Object> newVideo = new HashMap<>();
+        newVideo.put("url",url);
+        newVideo.put("number",1);
+        number.put(key,newVideo);
+    }
+
+    public static String getUrl(String key)  {
+        //获取已有直播链接并加入人数
+        Map<String,Object> oldVideo = number.get(key);
+        if(oldVideo==null){
+            return null;
+        }
+        oldVideo.put("number",(int)oldVideo.get("number")+1);
+        return oldVideo.get("url").toString();
+    }
+
+    public static void deleteVideoNumber(String key)  {
+        //减少直播间人数
+        Map<String,Object> oldVideo = number.get(key);
+        int videoNumber = (int) oldVideo.get("number");
+        //只有一个人并且需要减少则直接删除
+        if(videoNumber==1){
+            number.remove(key);
+            return;
+        }
+        oldVideo.put("number",(int)oldVideo.get("number")-1);
+    }
+
+
+}

@@ -15,10 +15,7 @@ import org.thingsboard.server.common.data.yunteng.core.exception.TkDataValidatio
 import org.thingsboard.server.common.data.yunteng.core.message.ErrorMessage;
 import org.thingsboard.server.common.data.yunteng.dto.*;
 import org.thingsboard.server.common.data.yunteng.utils.JacksonUtil;
-import org.thingsboard.server.common.data.yunteng.utils.tools.EzvizUtils;
-import org.thingsboard.server.common.data.yunteng.utils.tools.HikVisionArtemisPostUtils;
-import org.thingsboard.server.common.data.yunteng.utils.tools.ProtocolType;
-import org.thingsboard.server.common.data.yunteng.utils.tools.TkPageData;
+import org.thingsboard.server.common.data.yunteng.utils.tools.*;
 import org.thingsboard.server.dao.yunteng.entities.TkVideoEntity;
 import org.thingsboard.server.dao.yunteng.mapper.OrganizationMapper;
 import org.thingsboard.server.dao.yunteng.mapper.TkVideoMapper;
@@ -175,6 +172,21 @@ public class TkVideoServiceImpl extends AbstractBaseService<TkVideoMapper, TkVid
         return null;
     }
 
+    @Override
+    public void outVideo(boolean isTenantAdmin, String customerUserId, String tenantId, String entityId) {
+        if (isTenantAdmin) {
+            customerUserId = null;
+        }
+        //通过流媒体方式获取视频流的列表
+        List<TkVideoDTO> videoDTOList = baseMapper.getVideoInfosByTenantIdOrAccessModeOrId(tenantId, entityId,
+                FastIotConstants.MagicNumber.ONE, customerUserId);
+        if (videoDTOList.size() == 0) {
+            throw new TkDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage());
+        }
+        TkVideoDTO videoDTO = videoDTOList.get(0);
+        VideoNumbersUtils.deleteVideoNumber(videoDTO.getVideoPlatformDTO().getAppKey()+videoDTO.getSn());
+    }
+
     private String  HikVisionArtemis(TkVideoDTO videoDTO, ProtocolType protocolType){
         if(protocolType!=null && protocolType.equals(ProtocolType.HLS)){
             protocolType = videoDTO.getPlayProtocol() == 0 ? ProtocolType.HLS : ProtocolType.HLSS;

@@ -104,4 +104,9 @@ public interface TkVideoService extends BaseService<TkVideoEntity> {
    * @return 视频列表
    */
   List<TkVideoDTO> getVideoList(String organizationId, String tenantId);
+
+  void outVideo( boolean isTenantAdmin,
+                 String customerUserId,
+                 String tenantId,
+                 String entityId);
 }