Java8函数式编程应用小结

/**
     * 是否是标准或默认工作台
     * 理论上仅判断默认工作台即可（因为标准就是默认），此处是兜底一下历史逻辑
     *
     * @param context
     * @return
     */
    public boolean isStandardOrDefaultWorkbench(SchemaContext context) {
        Supplier<Boolean> isDefaultWorkbench = () -> StringUtils.isNotBlank(context.getDefaultAppUuid())
            && StringUtils.equals(context.getAppUuid(), context.getDefaultAppUuid());
        return WorkbenchType.WORKBENCH.equals(context.getWorkbenchType()) || isDefaultWorkbench.get();
    }

StringUtils.isNotBlank(context.getDefaultAppUuid())
    && StringUtils.equals(context.getAppUuid(), context.getDefaultAppUuid())

WorkbenchType.WORKBENCH.equals(context.getWorkbenchType())

isDefaultWorkbench.get()

 // 过滤隐藏应用
        return appDetails.stream().filter(app -> {
            AppModel appModel = new AppModel(app.getAppId(), app.getAppType());
            return !appDisplayModel.getHideApps().contains(appModel);
        }).collect(Collectors.toList());

    /**
     * 获取组织默认工作台appUuid
     * @param corpId
     * @param orgConfigTag
     * @return
     */
    public String getDefaultWorkbenchAppUuid(String corpId, OrgConfigTag orgConfigTag) {
        return Optional.ofNullable(orgConfigTag).map(OrgConfigTag::getDefaultAppUuid)
            .orElseGet(() -> OpenPageUtils.buildWorkbenchAppUuid(corpId));
    }

/**
     * 创建我的页面
     *
     * @param corpId
     * @param uid
     */
    protected void createMyPage(String corpId, Long uid, String appUuid, Method method) throws WorkbenchException {
            // 并发锁控制
            distributeLockSupport.lockAndDo(key,
                    () -> {
                        //创建页面方法
                        userCorpPageSupport.createMyPage(corpId, uid);
                        return null;
                    }
            );
    }

/**
     * 基于缓存的分布式锁操作
     *
     * @param key      资源key
     * @param callback 回调函数
     * @param <T>      返回结果类型
     * @return
     * @throws Exception
     */
    public <T> T lockAndDo(String key, Callback<T> callback) throws WorkbenchException {
        //取锁
        ...
        try {
            //加锁
            ...
            return callback.process();
        } catch (WorkbenchException ex) {
            throw ex;
        }  finally {
            try {
                //释放锁
                ...
            } catch (Exception ex) {
                //异常处理
            }
        }
    }
    //回调接口定义，供外部传入lambda
    @FunctionalInterface
    public interface Callback<T> {
        /**
         * 回调处理
         *
         * @return 处理结果
         * @throws WorkbenchException
         */
        T process() throws WorkbenchException, ServiceException;
    }

/**
     * 批量操作
     *
     * @param consumer 函数式写法，对批量对象操作
     */
    public void batchProccess(BiConsumer<Long, OrchardDTO> consumer) {
        if(orchardDTOMap!=null && orchardDTOMap.size()>0){
            for (Map.Entry<Long, OrchardDTO> entry : orchardDTOMap.entrySet()) {
                consumer.accept(entry.getKey(), entry.getValue());
            }
        }
    }

public void syncPush(MicroAppContext context, BatchOrchardDTO batchOrchardDTO) {
        //传入lambda来执行逻辑
        batchOrchardDTO.batchProccess((k, v) -> pushFacadeService.push(k, v));
    }