feat: 提供获取视频列表接口

@@ -19,6 +19,7 @@ import org.thingsboard.server.dao.yunteng.entities.TkVideoEntity;
 import org.thingsboard.server.dao.yunteng.service.TkVideoService;
 
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.*;
@@ -89,5 +90,12 @@ public class TkVideoController extends BaseController {
         map.put("url",url);
         return ResponseResult.success(map);
     }
-
+    @GetMapping("list")
+    @ApiOperation("获取视频列表")
+    public ResponseResult<List<TkVideoDTO>> getVideoList(
+            @RequestParam(value = "organizationId", required = false) String organizationId) throws ThingsboardException
+    {
+        return ResponseResult.success(videoService.getVideoList(organizationId,getCurrentUser().getCurrentTenantId()));
+    }
 }
+

@@ -12,19 +12,24 @@ import org.thingsboard.server.common.data.StringUtils;
 import org.thingsboard.server.common.data.yunteng.constant.FastIotConstants;
 import org.thingsboard.server.common.data.yunteng.core.exception.TkDataValidationException;
 import org.thingsboard.server.common.data.yunteng.core.message.ErrorMessage;
+import org.thingsboard.server.common.data.yunteng.dto.BaseDTO;
 import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
+import org.thingsboard.server.common.data.yunteng.dto.OrganizationDTO;
 import org.thingsboard.server.common.data.yunteng.dto.TkVideoDTO;
 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.dao.yunteng.entities.TkVideoEntity;
+import org.thingsboard.server.dao.yunteng.mapper.OrganizationMapper;
 import org.thingsboard.server.dao.yunteng.mapper.TkVideoMapper;
 import org.thingsboard.server.dao.yunteng.service.AbstractBaseService;
 import org.thingsboard.server.dao.yunteng.service.UserOrganizationMappingService;
 import org.thingsboard.server.dao.yunteng.service.TkVideoService;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Set;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Service
@@ -33,7 +38,7 @@ public class TkVideoServiceImpl extends AbstractBaseService<TkVideoMapper, TkVid
         implements TkVideoService {
 
     private final UserOrganizationMappingService userOrganizationMappingService;
-
+    private final OrganizationMapper organizationMapper;
     @Override
     public TkPageData<TkVideoDTO> pageDatas(IPage<TkVideoEntity> pageInfrom,
                                             boolean isPtTenantAdmin, String tenantId, String currentUserId,
@@ -115,4 +120,25 @@ public class TkVideoServiceImpl extends AbstractBaseService<TkVideoMapper, TkVid
         return result;
     }
 
+    @Override
+    public List<TkVideoDTO> getVideoList(String organizationId, String tenantId) {
+        List<String> organizationIds = new ArrayList<>();
+        if(StringUtils.isNotEmpty(organizationId)){
+            List<OrganizationDTO> organizations = organizationMapper.findOrganizationTreeList(tenantId,List.of(organizationId));
+            if(!organizations.isEmpty()){
+                organizationIds.addAll(organizations.stream().map(BaseDTO::getId).collect(Collectors.toList()));
+            }else{
+                organizationIds.add(organizationId);
+            }
+        }
+        List<TkVideoEntity> list = baseMapper.selectList(new LambdaQueryWrapper<TkVideoEntity>()
+                .eq(TkVideoEntity::getTenantId, tenantId)
+                .in(!organizationIds.isEmpty(),
+                        TkVideoEntity::getOrganizationId,organizationIds));
+        if(!list.isEmpty()){
+            return list.stream().map(entity->entity.getDTO(TkVideoDTO.class)).collect(Collectors.toList());
+        }
+        return null;
+    }
+
 }

@@ -6,6 +6,7 @@ import org.thingsboard.server.common.data.yunteng.dto.TkVideoDTO;
 import org.thingsboard.server.common.data.yunteng.utils.tools.TkPageData;
 import org.thingsboard.server.dao.yunteng.entities.TkVideoEntity;
 
+import java.util.List;
 import java.util.Set;
 
 public interface TkVideoService extends BaseService<TkVideoEntity> {
@@ -59,4 +60,12 @@ public interface TkVideoService extends BaseService<TkVideoEntity> {
      */
     boolean checkConfigIdsIsUseForVideo(Set<String> ids);
 
+    /**
+     * 获取视频列表
+     * @param organizationId 组织ID
+     * @param tenantId 租户ID
+     * @return 视频列表
+     */
+    List<TkVideoDTO> getVideoList(String organizationId, String tenantId);
+
 }