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 44aa9a0e9bbdd3c16079e67e25fb036f5b86e7dc..92173945ae655d072b96205f40538d9d24a3d49c 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) {