Spring Boot 2集成Activiti7

@Configuration
public class ActivitiConfig {
    private Logger logger = LoggerFactory.getLogger(ActivitiConfig.class);

    @Bean
    public UserDetailsService myUserDetailsService() {

        InMemoryUserDetailsManager inMemoryUserDetailsManager = new InMemoryUserDetailsManager();

        String[][] usersGroupsAndRoles = {
                {"salaboy", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"},
                {"wangwu", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"},
                {"lisi", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"},
                {"zhangsan", "password", "ROLE_ACTIVITI_USER", "GROUP_otherTeam"},
                {"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();
    }
}

package com.fang.demo.activitidemo;

import com.alibaba.fastjson.JSON;
import org.activiti.engine.*;
import org.activiti.engine.history.HistoricTaskInstance;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.HashMap;
import java.util.List;

@SpringBootTest
class ActivitiDemoApplicationTests {

    @Autowired
    private ProcessEngine processEngine;
    @Autowired
    private RepositoryService repositoryService;
    @Autowired
    private HistoryService historyService;
    @Autowired
    private TaskService taskService;
    @Autowired
    private RuntimeService runtimeService;

    /**
     * 启动审批流程
     */
    @Test
    public void startProcess() {
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myOutside");
        System.out.println("processInstance.getId() = " + processInstance.getId());
    }

    /**
     * 获取审批列表
     */
    @Test
    public void listProcess() {
        List<Task> list = taskService.createTaskQuery().processDefinitionKey("myOutside").taskCandidateOrAssigned("zhangsan").list();
        System.out.println("list = " + list);
    }

    /**
     * 完成审批
     */
    @Test
    public void completeTask() {
        Task task = taskService.createTaskQuery().processDefinitionKey("myOutside").taskCandidateOrAssigned("wangwu").singleResult();
//        taskService.claim(task.getId(), task.getAssignee());
        HashMap<String, Object> vars = new HashMap<>();
        vars.put("sign", "同意");
        taskService.complete(task.getId(), vars);
        System.out.println("task = " + task);
    }

    /**
     * 获取历史审批任务实例查询
     */
    @Test
    public void listHistoryTask() {
        List<HistoricTaskInstance> list = historyService.createHistoricTaskInstanceQuery().list();
        list.stream().forEach(item -> {
            System.out.println("item = " + JSON.toJSONString(item));
        });
    }

    /**
     * 获取历史流程实例
     */
    @Test
    public void listHistoryProcessInstance() {
        List<HistoricProcessInstance> list = historyService.createHistoricProcessInstanceQuery().list();
        list.stream().forEach(item -> {
            System.out.println("JSON.toJSONString(item) = " + JSON.toJSONString(item));
        });
    }
}