SpringBoot+flowable快速實(shí)現(xiàn)工作流，優(yōu)秀的工作流輪子

                                                                                                              這里先省略  

    org.springframework.boot    spring-boot-starter-parent    2.3.0.RELEASE     

    org.flowable    flowable-spring-boot-starter    6.6.0    mysql    mysql-connector-java    5.1.45

spring:  datasource:    url: jdbc:mysql://localhost:3306/flowable?useSSL=false&characterEncoding=UTF-8&serverTimezone=GMT%2B8    driver-class-name: com.mysql.jdbc.Driver    username: root    password: 123456

import lombok.extern.slf4j.Slf4j;import org.flowable.engine.HistoryService;import org.flowable.engine.RepositoryService;import org.flowable.engine.RuntimeService;import org.flowable.engine.history.HistoricProcessInstance;import org.flowable.engine.repository.Deployment;import org.flowable.engine.repository.ProcessDefinition;import org.flowable.engine.runtime.Execution;import org.flowable.engine.runtime.ProcessInstance;import org.flowable.idm.api.Group;import org.flowable.idm.api.User;import org.flowable.task.api.Task;import org.flowable.task.api.history.HistoricTaskInstance;import?org.springframework.beans.factory.annotation.Autowired;
import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.util.HashMap;import java.util.List;import java.util.Map;import?java.util.zip.ZipInputStream;
/** * TestFlowable * * @Author  * @Date: 2021/10/17 23:35 * @Version 1.0 */@Slf4jpublic?class?TestFlowable?{
    @Autowired????private?RepositoryService?repositoryService;
    @Autowired    private RuntimeService runtimeService;
    @Autowired    private HistoryService historyService;
    @Autowired    private org.flowable.engine.TaskService taskService;
    @Autowired    private org.flowable.engine.IdentityService identityService;
    public void createDeploymentZip() {        /*         * @Date: 2021/10/17 23:38         * Step 1: 部署xml（壓縮到zip形式，直接xml需要配置相對(duì)路徑，麻煩，暫不用）         */        try {            File zipTemp = new File("f:/leave_approval.bpmn20.zip");            ZipInputStream zipInputStream = new ZipInputStream(new FileInputStream(zipTemp));            Deployment deployment = repositoryService                    .createDeployment()                    .addZipInputStream(zipInputStream)                    .deploy();            log.info("部署成功:{}", deployment.getId());        } catch (FileNotFoundException e) {            e.printStackTrace();        }        /*         * @Date: 2021/10/17 23:40         * Step 2: 查詢(xún)部署的流程定義         */        List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().processDefinitionKey("leave_approval").list();????????List<ProcessDefinition>?pages?=?repositoryService.createProcessDefinitionQuery().processDefinitionKey("leave_approval").listPage(1,?30);
        /*         * @Date: 2021/10/17 23:40         * Step 3: 啟動(dòng)流程，創(chuàng)建實(shí)例         */        String processDefinitionKey = "leave_approval";//流程定義的key,對(duì)應(yīng)請(qǐng)假的流程圖        String businessKey = "schoolleave";//業(yè)務(wù)代碼，根據(jù)自己的業(yè)務(wù)用        Map<String, Object> variablesDefinition = new HashMap<>();//流程變量，可以自定義擴(kuò)充        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey, businessKey, variablesDefinition);        log.info("啟動(dòng)成功:{}", processInstance.getId());        /*         * @Date: 2021/10/17 23:40         * Step 4: 查詢(xún)指定流程所有啟動(dòng)的實(shí)例列表         * 列表，或 分頁(yè) 刪除         */        List<Execution> executions = runtimeService.createExecutionQuery().processDefinitionKey("leave_approval").list();        List<Execution> executionPages = runtimeService.createExecutionQuery().processDefinitionKey("leave_approval").listPage(1, 30);//????????runtimeService.deleteProcessInstance(processInstanceId,?deleteReason);?//刪除實(shí)例
        /*         * @Date: 2021/10/17 23:40         * Step 5: 學(xué)生查詢(xún)可以操作的任務(wù),并完成任務(wù)         */        String candidateGroup = "stu_group"; //候選組 xml文件里面的 flowable:candidateGroups="stu_group"        List<Task> taskList = taskService.createTaskQuery().taskCandidateGroup(candidateGroup).orderByTaskCreateTime().desc().list();        for (Task task : taskList) {            // 申領(lǐng)任務(wù)            taskService.claim(task.getId(), "my");            // 完成            taskService.complete(task.getId());????????}
        /*         * @Date: 2021/10/17 23:40         * Step 6: 老師查詢(xún)可以操作的任務(wù),并完成任務(wù)         */        String candidateGroupTe = "te_group"; //候選組 xml文件里面的 flowable:candidateGroups="te_group"        List<Task> taskListTe = taskService.createTaskQuery().taskCandidateGroup(candidateGroupTe).orderByTaskCreateTime().desc().list();        for (Task task : taskListTe) {            // 申領(lǐng)任務(wù)            taskService.claim(task.getId(), "myte");            // 完成            Map<String, Object> variables = new HashMap<>();            variables.put("command","agree"); //攜帶變量，用于網(wǎng)關(guān)流程的條件判定，這里的條件是同意            taskService.complete(task.getId(), variables);        }        /*         * @Date: 2021/10/18 0:17         * Step 7: 歷史查詢(xún)，因?yàn)橐坏┝鞒虉?zhí)行完畢，活動(dòng)的數(shù)據(jù)都會(huì)被清空，上面查詢(xún)的接口都查不到數(shù)據(jù)，但是提供歷史查詢(xún)接口         */        // 歷史流程實(shí)例        List<HistoricProcessInstance> historicProcessList = historyService.createHistoricProcessInstanceQuery().processDefinitionKey("leave_approval").list();        // 歷史任務(wù)        List<HistoricTaskInstance> historicTaskList = historyService.createHistoricTaskInstanceQuery().processDefinitionKey("leave_approval").list();        // 實(shí)例歷史變量 , 任務(wù)歷史變量        // historyService.createHistoricVariableInstanceQuery().processInstanceId(processInstanceId);        // historyService.createHistoricVariableInstanceQuery().taskId(taskId);        // *****************************************************分隔符********************************************************************        // *****************************************************分隔符********************************************************************        // 可能還需要的API        // 移動(dòng)任務(wù)，人為跳轉(zhuǎn)任務(wù)        // runtimeService.createChangeActivityStateBuilder().processInstanceId(processInstanceId)????????//???????.moveActivityIdTo(currentActivityTaskId,?newActivityTaskId).changeState();
        // 如果在數(shù)據(jù)庫(kù)配置了分組和用戶(hù)，還會(huì)用到        List<User> users = identityService.createUserQuery().list();    //用戶(hù)查詢(xún)，用戶(hù)id對(duì)應(yīng)xml 里面配置的用戶(hù)????????List<Group>?groups?=?identityService.createGroupQuery().list();?//分組查詢(xún)，分組id對(duì)應(yīng)xml?里面配置的分組?如?stu_group，te_group?在表里是id的值
        // 另外，每個(gè)查詢(xún)后面都可以拼條件，內(nèi)置恁多查詢(xún)，包括模糊查詢(xún)，大小比較都有    }}