|
@@ -1,6 +1,7 @@
|
|
|
package com.fdkankan.scene.service.impl;
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
+import cn.hutool.core.util.StrUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.fdkankan.common.constant.ErrorCode;
|
|
@@ -16,11 +17,14 @@ import com.fdkankan.platform.api.vo.Camera;
|
|
|
import com.fdkankan.platform.api.vo.User;
|
|
|
import com.fdkankan.scene.api.vo.SceneCnt;
|
|
|
import com.fdkankan.scene.entity.Folder;
|
|
|
+import com.fdkankan.scene.entity.FolderScene;
|
|
|
import com.fdkankan.scene.entity.Scene;
|
|
|
import com.fdkankan.scene.entity.SceneCooperation;
|
|
|
import com.fdkankan.scene.entity.ScenePro;
|
|
|
import com.fdkankan.scene.entity.SceneProExt;
|
|
|
import com.fdkankan.scene.entity.SceneProPO;
|
|
|
+import com.fdkankan.scene.service.IFolderSceneService;
|
|
|
+import com.fdkankan.scene.service.IFolderService;
|
|
|
import com.fdkankan.scene.service.ISceneCooperationService;
|
|
|
import com.fdkankan.scene.service.ISceneProExtService;
|
|
|
import com.fdkankan.scene.service.ISceneProService;
|
|
@@ -63,6 +67,10 @@ public class UserSceneServiceImpl implements IUserSceneService {
|
|
|
private ISceneProService sceneProService;
|
|
|
@Autowired
|
|
|
private ISceneProExtService sceneProExtService;
|
|
|
+ @Autowired
|
|
|
+ private IFolderService folderService;
|
|
|
+ @Autowired
|
|
|
+ private IFolderSceneService folderSceneService;
|
|
|
|
|
|
@Override
|
|
|
public Page<SceneVO> getScenes(String token, SceneParamVO param) {
|
|
@@ -251,8 +259,8 @@ public class UserSceneServiceImpl implements IUserSceneService {
|
|
|
|
|
|
public Map<String, Object> getNewScenesPagerByUserId(Long userId, SceneParamVO param) throws Exception {
|
|
|
|
|
|
- List<ScenePro> sceneEntityList = new ArrayList<>();
|
|
|
- List<Folder> folderEntityList = new ArrayList<>();
|
|
|
+ List<ScenePro> sceneList = new ArrayList<>();
|
|
|
+ List<Folder> folderList = new ArrayList<>();
|
|
|
|
|
|
boolean searchCamera = false;
|
|
|
List<Camera> cameraList = new ArrayList<>();
|
|
@@ -277,46 +285,41 @@ public class UserSceneServiceImpl implements IUserSceneService {
|
|
|
//根目录时,需要排除已经归类的场景
|
|
|
// if(param.getFolderId() == null){
|
|
|
// //查出所有已经归类的场景id
|
|
|
-// Condition condition = new Condition(FolderEntity.class);
|
|
|
-// condition.and().andEqualTo("userId", userId).andEqualTo("type", param.getFolderType());
|
|
|
-// List<FolderEntity> folderList = folderService.findAll(condition, "create_time desc");
|
|
|
+// List<Folder> folderList = folderService.list(
|
|
|
+// new LambdaQueryWrapper<Folder>()
|
|
|
+// .eq(Folder::getUserId, param.getUserId())
|
|
|
+// .eq(Folder::getFolderType, param.getFolderType()));
|
|
|
//
|
|
|
-// folderEntityList = folderList.parallelStream().filter(folder->ObjectUtils.isEmpty(folder.getParentId())).collect(Collectors.toList());
|
|
|
+// folderList = folderList.parallelStream().filter(folder->ObjectUtils.isEmpty(folder.getParentId())).collect(Collectors.toList());
|
|
|
// // 查找所有的文件夹
|
|
|
-// List<Long> folderIds = folderList.parallelStream().map(FolderEntity::getId).collect(Collectors.toList());
|
|
|
+// List<Long> folderIds = folderList.parallelStream().map(Folder::getId).collect(Collectors.toList());
|
|
|
// List<Long> sceneIdList = new ArrayList<>();
|
|
|
-// if(!ObjectUtils.isEmpty(folderIds)){
|
|
|
-// Condition folderSceneCondition = new Condition(FolderSceneEntity.class);
|
|
|
-// folderSceneCondition.and().andIn("folderId",folderIds);
|
|
|
-// List<FolderSceneEntity> folderSceneEntities = folderSceneService.findAll(folderSceneCondition);
|
|
|
-// sceneIdList = folderSceneEntities.parallelStream().map(FolderSceneEntity::getSceneId).collect(Collectors.toList());
|
|
|
+// if(CollUtil.isNotEmpty(folderIds)){
|
|
|
+// List<FolderScene> folderSceneList = folderSceneService.list(
|
|
|
+// new LambdaQueryWrapper<FolderScene>()
|
|
|
+// .select(FolderScene::getSceneId)
|
|
|
+// .in(FolderScene::getFolderId, folderIds));
|
|
|
+// sceneIdList = folderSceneList.parallelStream().map(FolderScene::getSceneId).collect(Collectors.toList());
|
|
|
// }
|
|
|
//
|
|
|
// Condition sceneCondition = new Condition(SceneProEntity.class);
|
|
|
// sceneCondition.and().andEqualTo("userId", userId).andNotEqualTo("sceneSource", "11");
|
|
|
// if(sceneIdList.size() > 0){
|
|
|
-// sceneCondition.and().andNotIn("id", sceneIdList);
|
|
|
+// param.setSceneIdList(sceneIdList);
|
|
|
// }
|
|
|
//
|
|
|
// //协作者 检索
|
|
|
-// if(param.getKeywordType().equals("userName") && StringUtils.isNotEmpty(param.getSearchKey()) ){
|
|
|
-// if( param.getSceneNumList()!=null && param.getSceneNumList().size()>0) {
|
|
|
-// sceneCondition.and().andIn("num", param.getSceneNumList());
|
|
|
-// }else{
|
|
|
-// sceneCondition.and().andEqualTo("num","");
|
|
|
+// if(param.getKeywordType().equals("userName") && StringUtils.isNotEmpty(param.getSearchKey())){
|
|
|
+// if(CollUtil.isEmpty(param.getNumList())){
|
|
|
+// param.setNum("");
|
|
|
// }
|
|
|
// }
|
|
|
//
|
|
|
-// if(!ObjectUtils.isEmpty(param.getSceneSource())){
|
|
|
-// if(param.getSceneSource().contains(",")){
|
|
|
-// sceneCondition.and().andIn("sceneSource", Arrays.asList(param.getSceneSource().split(",")));
|
|
|
-// }else{
|
|
|
-// sceneCondition.and().andEqualTo("sceneSource", param.getSceneSource());
|
|
|
-// }
|
|
|
-//
|
|
|
-// }
|
|
|
-// if(StringUtil.isNotEmpty(param.getSceneType())){
|
|
|
-// sceneCondition.and().andEqualTo("sceneType", param.getSceneType());
|
|
|
+// if(Objects.nonNull(param.getSceneSource())){
|
|
|
+// param.setSceneSourceList(
|
|
|
+// Arrays.stream(param.getSceneSource().split(","))
|
|
|
+// .map(source->Integer.parseInt(source))
|
|
|
+// .collect(Collectors.toList()));
|
|
|
// }
|
|
|
// if(StringUtils.isNotEmpty(sceneName)){
|
|
|
// sceneCondition.and().andLike("sceneName", "%" + sceneName + "%");
|