springboot集成flowable-modeler 实现免登

步骤

1. 搭建一个基础的spring boot框架

因为数据库使用MySQL，额外添加jdbc和mybatis依赖。

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>

        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.2</version>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

    </dependencies>

2. 添加flowable相关的依赖

包括flowable核心的flowable-spring-boot-starter以及flowable-UI需要的flowable-ui-modeler-rest flowable-ui-modeler-conf flowable-ui-modeler-logic，flowable版本选择当前最新的6.5.0

        <dependency>
            <groupId>org.flowable</groupId>
            <artifactId>flowable-spring-boot-starter</artifactId>
            <version>${flowable.version}</version>
        </dependency>

        <!-- flowable UI集成 -->
        <dependency>
            <groupId>org.flowable</groupId>
            <artifactId>flowable-ui-modeler-rest</artifactId>
            <version>${flowable.version}</version>
        </dependency>
        <dependency>
            <groupId>org.flowable</groupId>
            <artifactId>flowable-ui-modeler-conf</artifactId>
            <version>${flowable.version}</version>
        </dependency>
        <dependency>
            <groupId>org.flowable</groupId>
            <artifactId>flowable-ui-modeler-logic</artifactId>
            <version>${flowable.version}</version>
        </dependency>

3. 下载官方发布的war包

flowable-ui-modeler-app-6.5.0.war，把flowable-ui-modeler-app\src\main\resources\static下面的代码拷贝至自己的工程resources/static下

image.png

4. 重写两个配置类

package demo.workflow.config;

import org.flowable.ui.modeler.rest.app.EditorGroupsResource;
import org.flowable.ui.modeler.rest.app.EditorUsersResource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.autoconfigure.web.servlet.WebMvcRegistrations;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.FilterType;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.web.servlet.i18n.LocaleChangeInterceptor;
import org.springframework.web.servlet.i18n.SessionLocaleResolver;
import org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping;

@Configuration
@ComponentScan(value = {"org.flowable.ui.modeler.rest.app"},
        excludeFilters = {
                @ComponentScan.Filter(type = FilterType.ASSIGNABLE_TYPE, value = EditorUsersResource.class),
                @ComponentScan.Filter(type = FilterType.ASSIGNABLE_TYPE, value = EditorGroupsResource.class),
        })
@EnableAsync
public class AppDispatcherServletConfiguration implements WebMvcRegistrations {
        private static final Logger LOGGER = LoggerFactory.getLogger(AppDispatcherServletConfiguration.class);

        @Bean
        public SessionLocaleResolver localeResolver() {
                return new SessionLocaleResolver();
        }

        @Bean
        public LocaleChangeInterceptor localeChangeInterceptor() {
                LOGGER.debug("Configuring localeChangeInterceptor");
                LocaleChangeInterceptor localeChangeInterceptor = new LocaleChangeInterceptor();
                localeChangeInterceptor.setParamName("language");
                return localeChangeInterceptor;
        }

        @Override
        public RequestMappingHandlerMapping getRequestMappingHandlerMapping() {
                LOGGER.debug("Creating requestMappingHandlerMapping");
                RequestMappingHandlerMapping requestMappingHandlerMapping = new RequestMappingHandlerMapping();
                requestMappingHandlerMapping.setUseSuffixPatternMatch(false);
                requestMappingHandlerMapping.setRemoveSemicolonContent(false);
                Object[] interceptors = { localeChangeInterceptor() };
                requestMappingHandlerMapping.setInterceptors(interceptors);
                return requestMappingHandlerMapping;
        }
}

package demo.workflow.config;

import org.flowable.ui.modeler.rest.app.EditorGroupsResource;
import org.flowable.ui.modeler.rest.app.EditorUsersResource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.autoconfigure.web.servlet.WebMvcRegistrations;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.FilterType;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.web.servlet.i18n.LocaleChangeInterceptor;
import org.springframework.web.servlet.i18n.SessionLocaleResolver;
import org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping;

@Configuration
@ComponentScan(value = {"org.flowable.ui.modeler.rest.app"},
        excludeFilters = {
                @ComponentScan.Filter(type = FilterType.ASSIGNABLE_TYPE, value = EditorUsersResource.class),
                @ComponentScan.Filter(type = FilterType.ASSIGNABLE_TYPE, value = EditorGroupsResource.class),
        })
@EnableAsync
public class AppDispatcherServletConfiguration implements WebMvcRegistrations {
        private static final Logger LOGGER = LoggerFactory.getLogger(AppDispatcherServletConfiguration.class);

        @Bean
        public SessionLocaleResolver localeResolver() {
                return new SessionLocaleResolver();
        }

        @Bean
        public LocaleChangeInterceptor localeChangeInterceptor() {
                LOGGER.debug("Configuring localeChangeInterceptor");
                LocaleChangeInterceptor localeChangeInterceptor = new LocaleChangeInterceptor();
                localeChangeInterceptor.setParamName("language");
                return localeChangeInterceptor;
        }

        @Override
        public RequestMappingHandlerMapping getRequestMappingHandlerMapping() {
                LOGGER.debug("Creating requestMappingHandlerMapping");
                RequestMappingHandlerMapping requestMappingHandlerMapping = new RequestMappingHandlerMapping();
                requestMappingHandlerMapping.setUseSuffixPatternMatch(false);
                requestMappingHandlerMapping.setRemoveSemicolonContent(false);
                Object[] interceptors = { localeChangeInterceptor() };
                requestMappingHandlerMapping.setInterceptors(interceptors);
                return requestMappingHandlerMapping;
        }
}

5. 排除Spring Security认证

@SpringBootApplication(exclude = {SecurityAutoConfiguration.class})
public class WorkflowApplication {

    public static void main(String[] args) {
        SpringApplication.run(WorkflowApplication.class, args);
    }
}

6. 添加配置

除了数据库连接外，还需要指定 flowable的mapper文件的classpath路径与相关的三个配置项。

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/flowable-spring-boot?&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false
spring.datasource.username=aa
spring.datasource.password=aa
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

mybatis.mapper-locations=classpath:/META-INF/modeler-mybatis-mappings/*.xml
mybatis.configuration-properties.boolValue=TRUE
mybatis.configuration-properties.blobType=BLOB
mybatis.configuration-properties.prefix=

7. 自定义用户认证

此时可以通过127.0.0.1:8080访问modeler-ui了，但是因为没有做用户配置所以无法登录，flowable获取用户是调用idm服务，可以通过修改前端将获取用户信息接口替换为自己的接口。

image.png

自己实现一个“/account”接口

    @RequestMapping(value = "/account", method = RequestMethod.GET, produces = "application/json")
    public UserRepresentation getAccount() {
        UserRepresentation userRepresentation = new UserRepresentation();
        userRepresentation.setId("admin");
        userRepresentation.setEmail("admin@flowable.org");
        userRepresentation.setFullName("Test Administrator");
        userRepresentation.setLastName("Administrator");
        userRepresentation.setFirstName("Test");
        List<String> privileges = new ArrayList<>();
        privileges.add(DefaultPrivileges.ACCESS_MODELER);
        privileges.add(DefaultPrivileges.ACCESS_IDM);
        privileges.add(DefaultPrivileges.ACCESS_ADMIN);
        privileges.add(DefaultPrivileges.ACCESS_TASK);
        privileges.add(DefaultPrivileges.ACCESS_REST_API);
        userRepresentation.setPrivileges(privileges);
        return userRepresentation;
    }

这样解决了登录的问题，但在添加流程的时候仍需要获取用户，因此还有额外重写SecurityUtils.getCurrentUserObject获取用户信息，在不同版本的flowable中SecurityUtils所在的位置可能不一样，可以去flowable-ui-common-6.5.0.jar包中查看，6.5.0版本中SecurityUtils在org.flowable.ui.common.security目录下，因此在自己的工程中新建同样的目录，在其中添加自己的SecurityUtils。

package org.flowable.ui.common.security;

import org.flowable.idm.api.User;
import org.flowable.ui.common.model.RemoteUser;
import org.springframework.security.core.GrantedAuthority;
import org.springframework.security.core.context.SecurityContext;
import org.springframework.security.core.context.SecurityContextHolder;

import java.util.ArrayList;
import java.util.List;

public class SecurityUtils {

    private static User assumeUser;

    private SecurityUtils() {
    }

    /**
     * Get the login of the current user.
     */
    public static String getCurrentUserId() {
        User user = getCurrentUserObject();
        if (user != null) {
            return user.getId();
        }
        return null;
    }

    /**
     * 添加流程时会用到用户id，这里重构SecurityUtils.getCurrentUserObject 获取用户信息
     */
    public static User getCurrentUserObject() {
        if (assumeUser != null) {
            return assumeUser;
        }

        RemoteUser user = new RemoteUser();
        user.setId("admin");
        user.setDisplayName("admin");
        user.setFirstName("admin");
        user.setLastName("admin");
        user.setEmail("admin@admin.com");
        user.setPassword("test");
        List<String> pris = new ArrayList<>();
        pris.add(DefaultPrivileges.ACCESS_MODELER);
        pris.add(DefaultPrivileges.ACCESS_IDM);
        pris.add(DefaultPrivileges.ACCESS_ADMIN);
        pris.add(DefaultPrivileges.ACCESS_TASK);
        pris.add(DefaultPrivileges.ACCESS_REST_API);
        user.setPrivileges(pris);
        return user;
    }

    public static FlowableAppUser getCurrentFlowableAppUser() {
        FlowableAppUser user = null;
        SecurityContext securityContext = SecurityContextHolder.getContext();
        if (securityContext != null && securityContext.getAuthentication() != null) {
            Object principal = securityContext.getAuthentication().getPrincipal();
            if (principal instanceof FlowableAppUser) {
                user = (FlowableAppUser) principal;
            }
        }
        return user;
    }

    public static boolean currentUserHasCapability(String capability) {
        FlowableAppUser user = getCurrentFlowableAppUser();
        for (GrantedAuthority grantedAuthority : user.getAuthorities()) {
            if (capability.equals(grantedAuthority.getAuthority())) {
                return true;
            }
        }
        return false;
    }

    public static void assumeUser(User user) {
        assumeUser = user;
    }

    public static void clearAssumeUser() {
        assumeUser = null;
    }

}