fix: 视频流列表异常问题修复

 package org.thingsboard.server.dao.yunteng.impl;
 
 import com.baomidou.mybatisplus.core.conditions.Wrapper;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.jetbrains.annotations.Nullable;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 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.NoneTenantAssetException;
 import org.thingsboard.server.common.data.yunteng.core.exception.YtDataValidationException;
 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.enums.OrderTypeEnum;
-import org.thingsboard.server.common.data.yunteng.utils.ReflectUtils;
+import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
+import org.thingsboard.server.common.data.yunteng.dto.YtVideoDTO;
 import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
-import org.thingsboard.server.dao.yunteng.entities.AlarmProfile;
 import org.thingsboard.server.dao.yunteng.entities.YtVideoEntity;
-import org.thingsboard.server.dao.yunteng.mapper.AlarmProfileMapper;
-import org.thingsboard.server.dao.yunteng.mapper.OrganizationMapper;
 import org.thingsboard.server.dao.yunteng.mapper.YtVideoMapper;
-import org.thingsboard.server.dao.yunteng.service.*;
+import org.thingsboard.server.dao.yunteng.service.AbstractBaseService;
+import org.thingsboard.server.dao.yunteng.service.UserOrganizationMappingService;
+import org.thingsboard.server.dao.yunteng.service.YtVideoService;
 
-import java.util.HashSet;
 import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.stream.Collectors;
 
 @Slf4j
 @Service
 @RequiredArgsConstructor
 public class YtVideoServiceImpl extends AbstractBaseService<YtVideoMapper, YtVideoEntity>
-    implements YtVideoService {
+        implements YtVideoService {
 
-  private final UserOrganizationMappingService userOrganizationMappingService;
+    private final UserOrganizationMappingService userOrganizationMappingService;
 
-  @Override
-  public YtPageData<YtVideoDTO> pageDatas(IPage<YtVideoEntity> pageInfrom,
-                                          boolean isPtTenantAdmin, String tenantId, String currentUserId, String organizationId, String name, Boolean status) {
+    @Override
+    public YtPageData<YtVideoDTO> pageDatas(IPage<YtVideoEntity> pageInfrom,
+                                            boolean isPtTenantAdmin, String tenantId, String currentUserId, String organizationId, String name, Boolean status) {
 
-    List<String> organizationIds = userOrganizationMappingService.getEnableOrganizationIds(isPtTenantAdmin, tenantId, currentUserId,organizationId);
-    Wrapper pageFilter = new QueryWrapper<YtVideoEntity>()
-            .lambda()
-            .in(organizationIds!=null&& !organizationIds.isEmpty(),YtVideoEntity::getOrganizationId,organizationIds)
-            .eq(status!=null,YtVideoEntity::getStatus,status)
-            .like(StringUtils.isNotEmpty(name),YtVideoEntity::getName,name);
-    IPage<YtVideoDTO> page =
-        baseMapper.getVideoPage(pageInfrom, tenantId,name,status,organizationIds);
-    return getPageData(page, YtVideoDTO.class);
-  }
+        List<String> organizationIds = userOrganizationMappingService.getEnableOrganizationIds(isPtTenantAdmin, tenantId, currentUserId, organizationId);
+        Wrapper pageFilter = new QueryWrapper<YtVideoEntity>()
+                .lambda()
+                .in(organizationIds != null && !organizationIds.isEmpty(), YtVideoEntity::getOrganizationId, organizationIds)
+                .eq(status != null, YtVideoEntity::getStatus, status)
+                .like(StringUtils.isNotEmpty(name), YtVideoEntity::getName, name);
+        if (organizationIds == null || organizationIds.isEmpty()) {
+            organizationIds = null;
+        }
+        IPage<YtVideoDTO> page =
+                baseMapper.getVideoPage(pageInfrom, tenantId, name, status, organizationIds);
+        return getPageData(page, YtVideoDTO.class);
+    }
 
 
-  @Override
-  public YtVideoDTO detail(String tenantId, String entityId) {
-    Wrapper filter = new QueryWrapper<YtVideoEntity>().lambda()
-            .eq(YtVideoEntity::getTenantId,tenantId)
-            .eq(YtVideoEntity::getId,entityId);
-    YtVideoEntity self = baseMapper.selectOne(filter);
-    return     self.getDTO(YtVideoDTO.class);
-  }
+    @Override
+    public YtVideoDTO detail(String tenantId, String entityId) {
+        Wrapper filter = new QueryWrapper<YtVideoEntity>().lambda()
+                .eq(YtVideoEntity::getTenantId, tenantId)
+                .eq(YtVideoEntity::getId, entityId);
+        YtVideoEntity self = baseMapper.selectOne(filter);
+        return self.getDTO(YtVideoDTO.class);
+    }
 
 
-  @Override
-  @Transactional(rollbackFor=Exception.class)
-  public YtVideoDTO saveOrUpdate(YtVideoDTO videoDTO) {
-    if (StringUtils.isNotEmpty(videoDTO.getId())) {
-      Wrapper filter = new QueryWrapper<YtVideoEntity>().lambda()
-              .eq(YtVideoEntity::getTenantId,videoDTO.getTenantId())
-              .eq(YtVideoEntity::getId,videoDTO.getId());
-      YtVideoEntity oldVideo = baseMapper.selectOne(filter);
-      if (null == oldVideo) {
-        throw new YtDataValidationException(String.format(ErrorMessage.NOT_EXITED_OR_PERMISSION.getMessage(),videoDTO.getId()));
-      }
-      baseMapper.updateById(videoDTO.getEntity(YtVideoEntity.class));
-    } else {
-      baseMapper.insert(videoDTO.getEntity(YtVideoEntity.class));
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public YtVideoDTO saveOrUpdate(YtVideoDTO videoDTO) {
+        if (StringUtils.isNotEmpty(videoDTO.getId())) {
+            Wrapper filter = new QueryWrapper<YtVideoEntity>().lambda()
+                    .eq(YtVideoEntity::getTenantId, videoDTO.getTenantId())
+                    .eq(YtVideoEntity::getId, videoDTO.getId());
+            YtVideoEntity oldVideo = baseMapper.selectOne(filter);
+            if (null == oldVideo) {
+                throw new YtDataValidationException(String.format(ErrorMessage.NOT_EXITED_OR_PERMISSION.getMessage(), videoDTO.getId()));
+            }
+            baseMapper.updateById(videoDTO.getEntity(YtVideoEntity.class));
+        } else {
+            baseMapper.insert(videoDTO.getEntity(YtVideoEntity.class));
+        }
+        return videoDTO;
     }
-    return videoDTO;
-  }
 
 
-
-  @Override
-  @Transactional(rollbackFor=Exception.class)
-  public boolean deleteDataByIds(DeleteDTO deleteDTO) {
-    Wrapper filter = new QueryWrapper<YtVideoEntity>().lambda()
-            .eq(YtVideoEntity::getTenantId,deleteDTO.getTenantId())
-            .in(YtVideoEntity::getId,deleteDTO.getIds());
-    return baseMapper.delete(filter) > 0;
-  }
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public boolean deleteDataByIds(DeleteDTO deleteDTO) {
+        Wrapper filter = new QueryWrapper<YtVideoEntity>().lambda()
+                .eq(YtVideoEntity::getTenantId, deleteDTO.getTenantId())
+                .in(YtVideoEntity::getId, deleteDTO.getIds());
+        return baseMapper.delete(filter) > 0;
+    }
 
 }