删除用户下的所有文件

src/main/java/cn/timer/api/controller/disk/DiskCatalogueController.java

@@ -40,6 +40,7 @@ import org.springframework.web.bind.annotation.*;
 
 
 import javax.transaction.Transactional;
 import javax.transaction.Transactional;
 import java.util.*;
 import java.util.*;
+import java.util.stream.Collectors;
 
 
 
 
 /**
 /**
@@ -406,26 +407,55 @@ public class DiskCatalogueController {
             }
             }
             /*查找ids第一个*/
             /*查找ids第一个*/
             diskCatalogueList.forEach(d->{
             diskCatalogueList.forEach(d->{
+                getSubCatalogueList(d.getId());
+                d.setDeleteFlag(1);
+                d.updateById();
+            });
+
+
+            return ResultUtil.success();
+    }
+    private void getSubCatalogueList(Integer id){
+        List<DiskCatalogue> subFileList =DiskCatalogue.builder().build().selectList(new QueryWrapper<DiskCatalogue>().lambda()
+                .like(DiskCatalogue::getParentId,id)
+                .eq(DiskCatalogue::getDeleteFlag,0));
+                subFileList.forEach(s->{
+                    if(subFileList.size()>0){
+                        getSubCatalogueList(s.getId());
+                    }
+                    List<DiskCatalogueFiles> diskCatalogueFilesList = DiskCatalogueFiles.builder().build().selectList(new QueryWrapper<DiskCatalogueFiles>().lambda()
+                    .eq(DiskCatalogueFiles::getCatalogueId,s.getId())
+                    .eq(DiskCatalogueFiles::getDeleteFlag,0));
+                    diskCatalogueFilesList.forEach(f->{
+                        DiskFiles.builder().deleteFlag(1).build().update(new QueryWrapper<DiskFiles>().lambda().eq(DiskFiles::getId,f.getFilesId()));
+                        f.setDeleteFlag(1);
+                        f.updateById();
+                    });
+                    s.setDeleteFlag(1);
+                    s.updateById();
+                });
+    }
+//    private void getSubCatalogueList2(Integer id){
 //        List<DiskCatalogue> subFileList =DiskCatalogue.builder().build().selectList(new QueryWrapper<DiskCatalogue>().lambda()
 //        List<DiskCatalogue> subFileList =DiskCatalogue.builder().build().selectList(new QueryWrapper<DiskCatalogue>().lambda()
-//                .like(DiskCatalogue::getParentIds,d.getId())
+//                .like(DiskCatalogue::getParentId,id)
 //                .eq(DiskCatalogue::getDeleteFlag,0));
 //                .eq(DiskCatalogue::getDeleteFlag,0));
-//                List<DiskCatalogue> subFileList =diskCatalogueService.getSubCatalogueList(d.getId().toString(),diskCatalogueParam.getUserId());
 //        subFileList.forEach(s->{
 //        subFileList.forEach(s->{
+//            if(subFileList.size()>0){
+//                getSubCatalogueList(s.getId());
+//            }
 //            List<DiskCatalogueFiles> diskCatalogueFilesList = DiskCatalogueFiles.builder().build().selectList(new QueryWrapper<DiskCatalogueFiles>().lambda()
 //            List<DiskCatalogueFiles> diskCatalogueFilesList = DiskCatalogueFiles.builder().build().selectList(new QueryWrapper<DiskCatalogueFiles>().lambda()
 //                    .eq(DiskCatalogueFiles::getCatalogueId,s.getId())
 //                    .eq(DiskCatalogueFiles::getCatalogueId,s.getId())
 //                    .eq(DiskCatalogueFiles::getDeleteFlag,0));
 //                    .eq(DiskCatalogueFiles::getDeleteFlag,0));
-//                    diskCatalogueFilesList.forEach(f->{
-//                        DiskFiles.builder().deleteFlag(1).build().update(new QueryWrapper<DiskFiles>().lambda().eq(DiskFiles::getId,f.getFilesId()));
-//                    });
+//            if(diskCatalogueFilesList!=null) {
+//                if(diskCatalogueFilesList.size()>0) {
+//                    diskFilesService.deleteDiskFile(diskCatalogueFilesList.stream().map(DiskCatalogueFiles::getFilesId).collect(Collectors.toList()));
+//                }
+//            }
+////            diskCatalogueFilesList.forEach(f->{
+////                DiskFiles.builder().deleteFlag(1).build().update(new QueryWrapper<DiskFiles>().lambda().eq(DiskFiles::getId,f.getFilesId()));
+////            });
 //            s.setDeleteFlag(1);
 //            s.setDeleteFlag(1);
 //            s.updateById();
 //            s.updateById();
 //        });
 //        });
-                d.setDeleteFlag(1);
-                d.updateById();
-            });
-
-
-            return ResultUtil.success();
-
-    }
+//    }
 }
 }