Browse Source

v4转v3 v4场景置为删除状态

dsx 2 năm trước cách đây
mục cha
commit
12aa6154ea
1 tập tin đã thay đổi với 11 bổ sung11 xóa
  1. 11 11
      src/main/java/com/fdkankan/job/job/V4toV3Handler.java

+ 11 - 11
src/main/java/com/fdkankan/job/job/V4toV3Handler.java

@@ -77,18 +77,18 @@ public class V4toV3Handler {
             numList = Arrays.asList(nums.split(","));
         }
 
-        LambdaQueryWrapper<ScenePlus> queryWrapper = new LambdaQueryWrapper<>();
-        if(CollUtil.isNotEmpty(numList)){
-            queryWrapper.in(ScenePlus::getNum, numList);
-        }
-        List<ScenePlus> list = scenePlusService.list(queryWrapper);
+//        LambdaQueryWrapper<ScenePlus> queryWrapper = new LambdaQueryWrapper<>();
+//        if(CollUtil.isNotEmpty(numList)){
+//            queryWrapper.in(ScenePlus::getNum, numList);
+//        }
+//        List<ScenePlus> list = scenePlusService.list(queryWrapper);
 
-        if(CollUtil.isNotEmpty(list)){
-            list.parallelStream().forEach(plus->{
-                String num = plus.getNum();
+        if(CollUtil.isNotEmpty(numList)){
+            numList.parallelStream().forEach(num->{
+//                String num = plus.getNum();
                 try {
-                    ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(plus.getId());
-                    SceneEditInfo sceneEditInfo = sceneEditInfoService.getOne(new LambdaQueryWrapper<SceneEditInfo>().eq(SceneEditInfo::getScenePlusId, plus.getId()));
+//                    ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(plus.getId());
+//                    SceneEditInfo sceneEditInfo = sceneEditInfoService.getOne(new LambdaQueryWrapper<SceneEditInfo>().eq(SceneEditInfo::getScenePlusId, plus.getId()));
 
 //                    ScenePro scenePro = new ScenePro();
 //                    scenePro.setNum(plus.getNum());
@@ -177,7 +177,7 @@ public class V4toV3Handler {
 //                    scenePlusService.removeById(plus.getId());
 
                 }catch (Exception e){
-                    faildNumList.add(plus.getNum());
+                    faildNumList.add(num);
                     log.error("转换失败,num:" + num, e);
                 }
             });