SpringBoot 集成 Camunda 流程引擎#

1
    <dependency>
2
            <groupId>org.camunda.bpm.springboot</groupId>
3
            <artifactId>camunda-bpm-spring-boot-starter</artifactId>
4
            <version>7.18.0</version>
5
        </dependency>
6
        <dependency>
7
            <groupId>org.camunda.bpm.springboot</groupId>
8
            <artifactId>camunda-bpm-spring-boot-starter-rest</artifactId>
9
            <version>7.18.0</version>
10
        </dependency>
11
        <dependency>
12
            <groupId>org.camunda.bpm.springboot</groupId>
13
            <artifactId>camunda-bpm-spring-boot-starter-webapp</artifactId>
14
            <version>7.18.0</version>
15
        </dependency>

1
server:
2
  port: 8080
3

4
# camunda登录信息配置
5
camunda.bpm:
6
  admin-user:
7
    id: admin  #用户名
8
    password: 123456  #密码
9
    firstName: yu
10
  filter:
11
    create: All tasks
12

13
# mysql连接信息
14
spring:
15
  datasource:
16
    driver-class-name: com.mysql.cj.jdbc.Driver
17
    url: jdbc:mysql://localhost:3306/camunda
18
    username: root
19
    password: root
20
    type: com.mysql.cj.jdbc.MysqlDataSource

1
@RestController
2
public class TaskController {
3

4
    @Autowired
5
    private TestTaskService testTaskService;
6

7
    /**
8
     * 开启流程
9
     */
10
    @PostMapping("/start/process")
11
    public void startProcess(){
12
        testTaskService.startProcess();
13
    }
14
    /**
15
     * 查询流程定义
16
     *
17
     * @return {@link List}<{@link ProcessDefinition}>
18
     */
19
    @PostMapping("/find/process")
20
    public List<ProcessDefinition> findProcess(){
21
        return testTaskService.findProcesses();
22
    }
23
    /**
24
     * 查询任务
25
     *
26
     * @return {@link List}<{@link Task}>
27
     */
28
    @PostMapping("/task")
29
    public List<Task> findTasks(){
30
        return testTaskService.findTasks();
31
    }
32
}

1
@Service
2
public class TestTaskService {
3

4
    @Autowired
5
    private TaskService taskService;
6
    @Autowired
7
    private RuntimeService runtimeService;
8
    @Autowired
9
    private RepositoryService repositoryService;
10

11
    /**
12
     * 启动过程
13
     */
14
    public void startProcess() {
15
        ProcessInstance instance = runtimeService.startProcessInstanceByKey("Process_1dcaeol");
16
        System.out.println(instance.toString());
17
    }
18

19
    public List<ProcessDefinition> findProcesses() {
20
        return repositoryService.createProcessDefinitionQuery().list();
21
    }
22

23
    public List<Task> findTasks() {
24
        return taskService.createTaskQuery().list();
25
    }