Activiti——整合SpringBoot

桃扇骨 2023-10-15 22:49 213阅读 0赞

### 1、引入依赖 ###

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.0.RELEASE</version>
    </parent>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-spring-boot-starter</artifactId>
            <version>7.0.0.Beta2</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.29</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

### 2、 SpringBoot的application.yml文件配置 ###

注意：activiti7默认没有开启数据库历史记录，需要手动配置开启

spring:
      datasource:
        url: jdbc:mysql:///activiti7?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT
        username: root
        password: 123456
        driver-class-name: com.mysql.jdbc.Driver
      activiti:
        #1.flase：默认值。activiti在启动时，对比数据库表中保存的版本，如果没有表或者版本不匹配，将抛出异常
        #2.true： activiti会对数据库中所有表进行更新操作。如果表不存在，则自动创建
        #3.create_drop： 在activiti启动时创建表，在关闭时删除表（必须手动关闭引擎，才能删除表）
        #4.drop-create： 在activiti启动时删除原来的旧表，然后在创建新表（不需要手动关闭引擎）
        database-schema-update: true
        #检测历史表是否存在 activiti7默认没有开启数据库历史记录 启动数据库历史记录
        db-history-used: true
        #记录历史等级 可配置的历史级别有none, activity, audit, full
        #none：不保存任何的历史数据，因此，在流程执行过程中，这是最高效的。
        #activity：级别高于none，保存流程实例与流程行为，其他数据不保存。
        #audit：除activity级别会保存的数据外，还会保存全部的流程任务及其属性。audit为history的默认值。
        #full：保存历史数据的最高级别，除了会保存audit级别的数据外，还会保存其他全部流程相关的细节数据，包括一些流程参数等。
        history-level: full
        #校验流程文件，默认校验resources下的processes文件夹里的流程文件
        check-process-definitions: false

### 3、启动类 ###

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

### 4、 添加SpringSecurity安全框架整合配置 ###

因为Activiti7与SpringBoot整合后，默认情况下，集成了SpringSecurity安全框架，这样我们就要去准备SpringSecurity整合进来的相关用户权限配置信息。

SpringBoot的依赖包已经将SpringSecurity的依赖包也添加进项目中。

#### 4.1、\#\#\# 添加SecurityUtil类 ####

为了能够快速实现SpringSecurity安全框架的配置，所添加的一个组件。

@Component
    public class SecurityUtil {
        
        private Logger logger = LoggerFactory.getLogger(SecurityUtil.class);
    
        @Autowired
        @Qualifier("myUserDetailsService")
        private UserDetailsService userDetailsService;
    
    
        public void logInAs(String username) {
        
            UserDetails user = userDetailsService.loadUserByUsername(username);
            if (user == null) {
        
                throw new IllegalStateException("User " + username + " doesn't exist, please provide a valid user");
            }
            logger.info("> Logged in as: " + username);
            SecurityContextHolder.setContext(
                    new SecurityContextImpl(
                            new Authentication() {
        
                                @Override
                                public Collection<? extends GrantedAuthority> getAuthorities() {
        
                                    return user.getAuthorities();
                                }
    
                                @Override
                                public Object getCredentials() {
        
                                    return user.getPassword();
                                }
    
                                @Override
                                public Object getDetails() {
        
                                    return user;
                                }
    
                                @Override
                                public Object getPrincipal() {
        
                                    return user;
                                }
    
                                @Override
                                public boolean isAuthenticated() {
        
                                    return true;
                                }
    
                                @Override
                                public void setAuthenticated(boolean b) throws IllegalArgumentException {
        
                                    
                                }
    
                                @Override
                                public String getName() {
        
                                    return user.getUsername();
                                }
                            }
                    )
            );
            org.activiti.engine.impl.identity.Authentication.setAuthenticatedUserId(username);
        }
    }

#### 4.2、\#\#\# 添加DemoApplicationConfig类 ####

在Activiti7官方下载的Example中找到DemoApplicationConfig类，它的作用是为了实现SpringSecurity框架的用户权限的配置，这样我们就可以在系统中使用用户权限信息。

本次项目中基本是在文件中定义出来的用户信息，当然也可以是数据库中查询的用户权限信息。

后面处理流程时用到的任务负责人，需要添加在这里

@Configuration
    public class ActivitiConfiguration {
        
        private Logger logger = LoggerFactory.getLogger(ActivitiConfiguration.class);
    
        @Bean
        public UserDetailsService myUserDetailsService() {
        
            InMemoryUserDetailsManager inMemoryUserDetailsManager = new InMemoryUserDetailsManager();
            //这里添加用户，后面处理流程时用到的任务负责人，需要添加在这里
            String[][] usersGroupsAndRoles = {
        
                    {
        "jack", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"},
                    {
        "rose", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"},
                    {
        "tom", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"},
                    {
        "other", "password", "ROLE_ACTIVITI_USER", "GROUP_otherTeam"},
                    {
        "system", "password", "ROLE_ACTIVITI_USER"},
                    {
        "admin", "password", "ROLE_ACTIVITI_ADMIN"},
            };
    
            for (String[] user : usersGroupsAndRoles) {
        
                List<String> authoritiesStrings = Arrays.asList(Arrays.copyOfRange(user, 2, user.length));
                logger.info("> Registering new user: " + user[0] + " with the following Authorities[" + authoritiesStrings + "]");
                inMemoryUserDetailsManager.createUser(new User(user[0], passwordEncoder().encode(user[1]),
                        authoritiesStrings.stream().map(s -> new SimpleGrantedAuthority(s)).collect(Collectors.toList())));
            }
    
            return inMemoryUserDetailsManager;
        }
    
        @Bean
        public PasswordEncoder passwordEncoder() {
        
            return new BCryptPasswordEncoder();
        }
    }

### 5、创建Bpmn文件 ###

Activiti7可以自动部署流程，前提是在resources目录下，创建一个新的目录processes，用来放置bpmn文件。

创建一个简单的Bpmn流程文件，并设置任务的用户组Candidate Groups。

Candidate Groups中的内容与上面DemoApplicationConfiguration类中出现的用户组名称要保持一致，可以填写：activitiTeam 或者 otherTeam。

这样填写的好处：当不确定到底由谁来负责当前任务的时候，只要是Groups内的用户都可以拾取这个任务

![在这里插入图片描述][d6ef2e7e6e5341daa4a20b89bf961aac.png]

### 6、测试 ###

@RunWith(SpringRunner.class)
    @SpringBootTest
    public class AppApplicationTests {
        
    
        @Autowired
        private ProcessRuntime processRuntime;
    
        @Autowired
        private TaskRuntime taskRuntime;
    
        @Autowired
        private SecurityUtil securityUtil;
    
    
        @Test
        public void testApp() {
        
            System.out.println(taskRuntime);
        }
    
    
        /**
         * 查看流程定义
         */
        @Test
        public void contextLoads() {
        
            securityUtil.logInAs("system");
            Page<ProcessDefinition> processDefinitionPage = processRuntime.processDefinitions(Pageable.of(0, 10));
            System.out.println("可用的流程定义数量：" + processDefinitionPage.getTotalItems());
    
            for (ProcessDefinition pd : processDefinitionPage.getContent()) {
        
                System.out.println("流程定义：" + pd);
            }
        }
    
        @Test
        public void testStartProcess() {
        
            securityUtil.logInAs("system");
            ProcessInstance pi = processRuntime.start(ProcessPayloadBuilder.start().withProcessDefinitionKey("myProcess").build());
            System.out.println("流程实例ID：" + pi.getId());
        }
    
        /**
         * 查询任务，并完成自己的任务
         */
        @Test
        public void testTask() {
        
            securityUtil.logInAs("jack");
            Page<Task> tasks = taskRuntime.tasks(Pageable.of(0, 10));
            if (tasks.getTotalItems() > 0) {
        
                for (Task task : tasks.getContent()) {
        
                    taskRuntime.claim(TaskPayloadBuilder.claim().withTaskId(task.getId()).build());
                    System.out.println("任务：" + task);
                    taskRuntime.complete(TaskPayloadBuilder.complete().withTaskId(task.getId()).build());
                }
            }
            Page<Task> taskPage = taskRuntime.tasks(Pageable.of(0, 10));
            if (taskPage.getTotalItems() > 0) {
        
                System.out.println("任务:" + taskPage.getContent());
            }
        }
    }

[d6ef2e7e6e5341daa4a20b89bf961aac.png]: https://img-blog.csdnimg.cn/d6ef2e7e6e5341daa4a20b89bf961aac.png