diff --git a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-common/src/main/java/com/schisandra/auth/common/utils/TreeUtils.java b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-common/src/main/java/com/schisandra/auth/common/utils/TreeUtils.java index 60d50b7..ade7df1 100644 --- a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-common/src/main/java/com/schisandra/auth/common/utils/TreeUtils.java +++ b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-common/src/main/java/com/schisandra/auth/common/utils/TreeUtils.java @@ -2,11 +2,33 @@ package com.schisandra.auth.common.utils; import java.lang.reflect.Field; import java.util.*; +import java.util.function.Function; import java.util.stream.Collectors; import java.util.stream.Stream; -import java.util.function.Function; + +/** + * @ClassName: Tree + * @Author: landaiqing + * @Description: + * @CreateTime: 2024/01/05 15:32 + */ + public class TreeUtils { + + /** + * @param nodesList 数据 + * @param pid 父ID + * @param idFieldName ID字段名称 + * @param parentIdFieldName 父ID字段名称 + * @param childrenFieldName 子集字段名称 + * @param function 操作子集函数 通常可以做排序 如:stream -> stream.sorted(Comparator.comparing(TreeNode::getId, Comparator.reverseOrder())) 根据ID倒序 + * 如果不想排序直接 stream -> stream + * @param + * @param + * @return + */ public static List buildTree(List nodesList, R pid, String idFieldName, String parentIdFieldName, String childrenFieldName, Function, Stream> function) { + Map> map = nodesList.stream().collect(Collectors.groupingBy(a -> { try { Field field = a.getClass().getDeclaredField(parentIdFieldName); @@ -18,6 +40,7 @@ public class TreeUtils { })); List roots = new ArrayList<>(); + // 逐层构建树结构 roots.addAll(function.apply(Optional.ofNullable(map.get(pid)).orElse(new ArrayList<>()).stream()).collect(Collectors.toList())); Queue queue = new LinkedList<>(roots); @@ -41,7 +64,8 @@ public class TreeUtils { throw new RuntimeException("Error reading id field: " + e.getMessage()); } } + return roots; } -} +} \ No newline at end of file diff --git a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-domain/src/main/java/com/schisandra/auth/domain/service/impl/SchisandraAuthPermissionDomainServiceImpl.java b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-domain/src/main/java/com/schisandra/auth/domain/service/impl/SchisandraAuthPermissionDomainServiceImpl.java index 8513c04..66b06a4 100644 --- a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-domain/src/main/java/com/schisandra/auth/domain/service/impl/SchisandraAuthPermissionDomainServiceImpl.java +++ b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-domain/src/main/java/com/schisandra/auth/domain/service/impl/SchisandraAuthPermissionDomainServiceImpl.java @@ -77,55 +77,58 @@ public class SchisandraAuthPermissionDomainServiceImpl implements SchisandraAuth /** * @description: 更新 - * @param: [schisandraAuthPermissionBO] - * @return: java.lang.Object + * @param: [schisandraAuthPermissionBO] + * @return: java.lang.Object * @author zhang * @date: 2024/4/17 17:06 - */ + */ @Override public int update(SchisandraAuthPermissionBO schisandraAuthPermissionBO) { SchisandraAuthPermission schisandraAuthPermission = SchisandraAuthPermissionBOConverter.INSTANCE.convertBOToEntity(schisandraAuthPermissionBO); return schisandraAuthPermissionService.update(schisandraAuthPermission); } -/** - * @description: 删除 - * @param: [schisandraAuthPermissionBO] - * @return: java.lang.Object - * @author zhang - * @date: 2024/4/17 17:06 - */ + + /** + * @description: 删除 + * @param: [schisandraAuthPermissionBO] + * @return: java.lang.Object + * @author zhang + * @date: 2024/4/17 17:06 + */ @Override public Object delete(SchisandraAuthPermissionBO schisandraAuthPermissionBO) { SchisandraAuthPermission schisandraAuthPermission = SchisandraAuthPermissionBOConverter.INSTANCE.convertBOToEntity(schisandraAuthPermissionBO); - boolean schisandraAuthPermission1 =schisandraAuthPermissionService.deleteById(schisandraAuthPermission.getId()); + boolean schisandraAuthPermission1 = schisandraAuthPermissionService.deleteById(schisandraAuthPermission.getId()); return schisandraAuthPermission1; } -/** - * @description: 插入 - * @param: [schisandraAuthPermissionBO] - * @return: java.lang.Object - * @author zhang - * @date: 2024/4/17 17:06 - */ + + /** + * @description: 插入 + * @param: [schisandraAuthPermissionBO] + * @return: java.lang.Object + * @author zhang + * @date: 2024/4/17 17:06 + */ @Override public Object insert(SchisandraAuthPermissionBO schisandraAuthPermissionBO) { SchisandraAuthPermission schisandraAuthPermission = SchisandraAuthPermissionBOConverter.INSTANCE.convertBOToEntity(schisandraAuthPermissionBO); - SchisandraAuthPermission schisandraAuthPermission1 =schisandraAuthPermissionService.insert(schisandraAuthPermission); + SchisandraAuthPermission schisandraAuthPermission1 = schisandraAuthPermissionService.insert(schisandraAuthPermission); return schisandraAuthPermission1; } -/** - * @description: 查询 - * @param: [schisandraAuthPermissionBO] - * @return: java.lang.Object - * @author zhang - * @date: 2024/4/17 17:07 - */ + + /** + * @description: 查询 + * @param: [schisandraAuthPermissionBO] + * @return: java.lang.Object + * @author zhang + * @date: 2024/4/17 17:07 + */ @Override public SchisandraAuthPermissionBO select(SchisandraAuthPermissionBO schisandraAuthPermissionBO) { SchisandraAuthPermission schisandraAuthPermission = SchisandraAuthPermissionBOConverter.INSTANCE.convertBOToEntity(schisandraAuthPermissionBO); - SchisandraAuthPermission schisandraAuthPermission1 =schisandraAuthPermissionService.queryById(schisandraAuthPermission.getId()); + SchisandraAuthPermission schisandraAuthPermission1 = schisandraAuthPermissionService.queryById(schisandraAuthPermission.getId()); SchisandraAuthPermissionBO schisandraAuthPermissionBO1 = SchisandraAuthPermissionBOConverter.INSTANCE.convertEntityToBO(schisandraAuthPermission1); return schisandraAuthPermissionBO1; } diff --git a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-infra/src/main/java/com/schisandra/auth/infra/basic/service/impl/SchisandraSocialUserServiceImpl.java b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-infra/src/main/java/com/schisandra/auth/infra/basic/service/impl/SchisandraSocialUserServiceImpl.java index 110c474..6228975 100644 --- a/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-infra/src/main/java/com/schisandra/auth/infra/basic/service/impl/SchisandraSocialUserServiceImpl.java +++ b/schisandra-cloud-storage-auth/schisandra-cloud-storage-auth-infra/src/main/java/com/schisandra/auth/infra/basic/service/impl/SchisandraSocialUserServiceImpl.java @@ -102,7 +102,7 @@ public class SchisandraSocialUserServiceImpl implements SchisandraSocialUserServ } /** - * @description: 根据appId和openId查询用户 + * @description: 根据openId查询用户 * @param: [appId, openId] * @return: com.schisandra.auth.infra.basic.entity.SchisandraSocialUser * @author: landaiqing diff --git a/schisandra-cloud-storage-oss/schisandra-cloud-storage-oss-application/schisandra-cloud-storage-oss-application-controller/src/main/java/com/schisandra/oss/application/controller/SchisandraOssMinioController.java b/schisandra-cloud-storage-oss/schisandra-cloud-storage-oss-application/schisandra-cloud-storage-oss-application-controller/src/main/java/com/schisandra/oss/application/controller/SchisandraOssMinioController.java index bdbb761..6c88421 100644 --- a/schisandra-cloud-storage-oss/schisandra-cloud-storage-oss-application/schisandra-cloud-storage-oss-application-controller/src/main/java/com/schisandra/oss/application/controller/SchisandraOssMinioController.java +++ b/schisandra-cloud-storage-oss/schisandra-cloud-storage-oss-application/schisandra-cloud-storage-oss-application-controller/src/main/java/com/schisandra/oss/application/controller/SchisandraOssMinioController.java @@ -29,7 +29,6 @@ import java.security.InvalidKeyException; import java.security.NoSuchAlgorithmException; import java.util.HashMap; import java.util.List; -import java.util.concurrent.atomic.AtomicInteger; /** * controller @@ -82,12 +81,12 @@ public class SchisandraOssMinioController { * @date: 2024/6/26 13:55 */ @GetMapping("listMinioDir") - public Result listMinioInfo(@RequestParam String target, @RequestParam String userId, @RequestParam String dirName,@RequestParam String bucket) throws Exception { - Preconditions.checkNotNull(target, "不能为空"); + public Result listMinioInfo( @RequestParam String userId, @RequestParam String dirName,@RequestParam String bucket) throws Exception { + Preconditions.checkNotNull(bucket, "不能为空"); Preconditions.checkNotNull(userId, "不能为空"); MinioOssClient bean = SpringUtil.getBean(userId); bean.getMinioOssConfig().setBucketName(bucket); - return Result.ok(bean.listDir(target, dirName)); + return Result.ok(bean.listDir(bucket, dirName)); } /**