<!-- pom.xml 依賴 -->  
<dependencies>  
    <!-- Flowable核心依賴 -->  
    <dependency>  
        <groupId>org.flowable</groupId>  
        <artifactId>flowable-spring-boot-starter-process</artifactId>  
        <version>6.8.0</version>  
    </dependency>  
    <!-- 數據庫依賴（以MySQL為例） -->  
    <dependency>  
        <groupId>mysql</groupId>  
        <artifactId>mysql-connector-java</artifactId>  
    </dependency>  
    <!-- Web模塊 -->  
    <dependency>  
        <groupId>org.springframework.boot</groupId>  
        <artifactId>spring-boot-starter-web</artifactId>  
    </dependency>  
</dependencies>  

# application.yml  
spring:  
  datasource:  
    url: jdbc:mysql://localhost:3306/flowable_demo?useSSL=false&serverTimezone=Asia/Shanghai  
    username: root  
    password: 123456  
  flowable:  
    database-schema-update: true  # 自動創(chuàng)建/更新數據庫表  
    check-process-definitions: true  # 啟動時檢查流程定義  
    async-executor-activate: false  # 禁用異步執(zhí)行器（簡化開發(fā)）  

<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL">  
  <process id="leaveProcess" name="請假流程">  
    <startEvent id="startEvent" />  
    <userTask id="managerApproval" name="部門經理審批">  
      <extensionElements>  
        <flowable:assignee>manager</flowable:assignee>  <!-- 辦理人變量 -->  
      </extensionElements>  
    </userTask>  
    <exclusiveGateway id="approvalGate" name="審批結果" />  
    <endEvent id="approveEnd" name="審批通過" />  
    <endEvent id="rejectEnd" name="審批拒絕" />  
    <!-- 流程連線定義 -->  
  </process>  
</definitions>  

import org.flowable.engine.*;  
import org.flowable.engine.runtime.ProcessInstance;  
import org.flowable.task.api.Task;  
import org.springframework.stereotype.Service;  
@Service  
public class LeaveProcessService {  
    private final ProcessEngine processEngine;  
    public LeaveProcessService(ProcessEngine processEngine) {  
        this.processEngine = processEngine;  
    }  
    // 1. 發(fā)起請假流程  
    public String startProcess(String applicant, String reason, int days) {  
        RuntimeService runtimeService = processEngine.getRuntimeService();  
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(  
            "leaveProcess",  // 流程定義Key  
            "process_" + UUID.randomUUID(),  // 流程實例ID  
            Map.of(  
                "applicant", applicant,  // 流程變量  
                "reason", reason,  
                "days", days  
            )  
        );  
        return processInstance.getId();  
    }  
    // 2. 處理審批任務  
    public void completeTask(String taskId, String assignee, boolean approved) {  
        TaskService taskService = processEngine.getTaskService();  
        Task task = taskService.createTaskQuery()  
            .taskId(taskId)  
            .singleResult();  
        taskService.claim(taskId, assignee);  // 認領任務  
        taskService.complete(taskId, Map.of("approved", approved));  // 提交審批結果  
    }  
    // 3. 查詢用戶待辦任務  
    public List<Task> getTasks(String assignee) {  
        return processEngine.getTaskService()  
            .createTaskQuery()  
            .taskAssignee(assignee)  
            .orderByTaskCreateTime()  
            .desc()  
            .list();  
    }  
}  

import org.springframework.web.bind.annotation.*;  
@RestController  
@RequestMapping("/process")  
public class LeaveProcessController {  
    private final LeaveProcessService processService;  
    // 發(fā)起流程  
    @PostMapping("/start")  
    public ResponseData startProcess(  
        @RequestParam String applicant,  
        @RequestParam String reason,  
        @RequestParam int days  
    ) {  
        String processId = processService.startProcess(applicant, reason, days);  
        return ResponseData.success("流程啟動成功", processId);  
    }  
    // 處理任務  
    @PostMapping("/complete")  
    public ResponseData completeTask(  
        @RequestParam String taskId,  
        @RequestParam String assignee,  
        @RequestParam boolean approved  
    ) {  
        processService.completeTask(taskId, assignee, approved);  
        return ResponseData.success("任務處理完成");  
    }  
    // 查詢待辦任務  
    @GetMapping("/tasks")  
    public ResponseData getTasks(@RequestParam String assignee) {  
        List<Task> tasks = processService.getTasks(assignee);  
        return ResponseData.success("獲取任務成功", tasks);  
    }  
}  

// 優(yōu)化查詢性能（添加索引）  
@PostConstruct  
public void createIndex() {  
    ManagementService managementService = processEngine.getManagementService();  
    managementService.createIndex("ACT_IDX_TASK_ASSIGNEE", "ACT_RU_TASK", "ASSIGNEE_");  
}  

// 部署新版本流程（保留歷史版本）  
RepositoryService repositoryService = processEngine.getRepositoryService();  
repositoryService.createDeployment()  
    .name("請假流程V2.0")  
    .addClasspathResource("processes/leave-process-v2.bpmn20.xml")  
    .deploy();  

// 查詢流程執(zhí)行歷史  
HistoryService historyService = processEngine.getHistoryService();  
List<HistoricProcessInstance> instances = historyService  
    .createHistoricProcessInstanceQuery()  
    .processInstanceBusinessKey("process_123")  
    .list();