public ConfigImportResult importData()

in shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/AppAuthServiceImpl.java [338:396]
52 lines of code
8 McCabe index (conditional complexity)

    public ConfigImportResult importData(final String namespace, final List<AppAuthDTO> authDataList) {
        if (CollectionUtils.isEmpty(authDataList)) {
            return ConfigImportResult.success();
        }
        StringBuilder errorMsgBuilder = new StringBuilder();
        int successCount = 0;
        // exist appKey set
        Set<String> existAppKeySet = Optional.of(
                        this.appAuthMapper.selectAllByNamespaceId(namespace)
                                .stream()
                                .filter(Objects::nonNull)
                                .map(AppAuthDO::getAppKey)
                                .collect(Collectors.toSet()))
                .orElseGet(Sets::newHashSet);
        
        for (AppAuthDTO appAuth : authDataList) {
            String appKey = appAuth.getAppKey();
            if (existAppKeySet.contains(appKey)) {
                // already exists, just record fail info, and continue
                LOG.info("import auth data, appKey: {} already exists", appKey);
                errorMsgBuilder
                        .append(appKey)
                        .append(",");
                continue;
            }
            AppAuthDO appAuthDO = AppAuthTransfer.INSTANCE.mapToEntity(appAuth);
            // create
            String authId = UUIDUtils.getInstance().generateShortUuid();
            appAuthDO.setId(authId);
            appAuthDO.setNamespaceId(namespace);
            int inserted = appAuthMapper.insertSelective(appAuthDO);
            if (inserted > 0) {
                successCount++;
                // auth path
                List<AuthPathDTO> authPathDTOList = appAuth.getAuthPathList();
                if (CollectionUtils.isNotEmpty(authPathDTOList)) {
                    List<AuthPathDO> authPathDOS = authPathDTOList
                            .stream()
                            .map(param -> AuthPathDO.create(param.getPath(), authId, param.getAppName()))
                            .collect(Collectors.toList());
                    authPathMapper.batchSave(authPathDOS);
                }
                
                // auth param
                List<AuthParamDTO> authParamVOList = appAuth.getAuthParamList();
                if (CollectionUtils.isNotEmpty(authParamVOList)) {
                    List<AuthParamDO> authParamDOS = authParamVOList
                            .stream()
                            .map(param -> AuthParamDO.create(authId, param.getAppName(), param.getAppParam()))
                            .collect(Collectors.toList());
                    authParamMapper.batchSave(authParamDOS);
                }
            }
        }
        if (StringUtils.isNotEmpty(errorMsgBuilder)) {
            return ConfigImportResult.fail(successCount, "import fail appKey: " + errorMsgBuilder);
        }
        return ConfigImportResult.success(successCount);
    }