From f41e29ab3a28678df873b7d7d0756374968d063e Mon Sep 17 00:00:00 2001 From: PengShuaixin Date: Wed, 14 Apr 2021 12:29:59 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BA=94=E7=94=A8=E4=B8=8B=E7=BA=BF=E5=8A=9F?= =?UTF-8?q?=E8=83=BD=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kafka/manager/bpm/order/impl/DeleteAppOrder.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/order/impl/DeleteAppOrder.java b/kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/order/impl/DeleteAppOrder.java index 44aa9a0e..92173945 100644 --- a/kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/order/impl/DeleteAppOrder.java +++ b/kafka-manager-extends/kafka-manager-bpm/src/main/java/com/xiaojukeji/kafka/manager/bpm/order/impl/DeleteAppOrder.java @@ -23,6 +23,7 @@ import org.springframework.stereotype.Component; import java.util.Date; import java.util.List; +import java.util.stream.Collectors; /** * @author zhongyuankai @@ -94,7 +95,11 @@ public class DeleteAppOrder extends AbstractAppOrder { } // 判断app是否对topic有权限 List authorityList = authorityService.getAuthority(orderAppExtension.getAppId()); - if (!ValidateUtils.isEmptyList(authorityList)) { + // 过滤权限列表中access=0的 + List newAuthorityList = authorityList.stream() + .filter(authorityDO -> authorityDO.getAccess() != 0) + .collect(Collectors.toList()); + if (!ValidateUtils.isEmptyList(newAuthorityList)) { return ResultStatus.OPERATION_FORBIDDEN; } if (appService.deleteApp(appDO, userName) > 0) { -- GitLab