springboot集成flowable創建請假流程實例

本文轉載自查看原文 2021-10-19 10:29 238 flowable

　　springboot如何集成flowable，如何部署flowable在線編輯器畫bpm圖以及bpm圖的畫法，我在上一篇博客中寫了，這里直接上代碼（源碼地址：晚安/flowable_holiday (gitee.com)）。　

　　這是我畫的請假流程bpm圖。

　　然會到代碼部分。

　　首先，先寫一個config類，避免生成的bpm圖中文亂碼。

package com.example.config;

import org.flowable.spring.SpringProcessEngineConfiguration;
import org.flowable.spring.boot.EngineConfigurationConfigurer;
import org.springframework.context.annotation.Configuration;


@Configuration
public class FlowableConfig implements EngineConfigurationConfigurer<SpringProcessEngineConfiguration> {
    @Override
    public void configure(SpringProcessEngineConfiguration springProcessEngineConfiguration) {
        springProcessEngineConfiguration.setActivityFontName("宋體");
        springProcessEngineConfiguration.setLabelFontName("宋體");
        springProcessEngineConfiguration.setAnnotationFontName("宋體");
    }
}

　　由於我在畫bpm圖的時候，給“經理審批”節點和“老板審批”節點設置了監聽器。所以接下來寫監聽器類

經理審批節點監聽器。指定任務受理人為“領導”。

package com.example.listen;

import org.flowable.engine.delegate.TaskListener;
import org.flowable.task.service.delegate.DelegateTask;

public class ManagerTaskHandler implements TaskListener {
    
    @Override
    public void notify(DelegateTask delegateTask) {
        delegateTask.setAssignee("領導");
        System.out.println("執行監聽器————————————————————————————————————");
    }
}

老板審批節點監聽器。指定任務受理人為“老板”。

package com.example.listen;

import org.flowable.engine.delegate.TaskListener;
import org.flowable.task.service.delegate.DelegateTask;

public class BossTaskHandler implements TaskListener {

    @Override
    public void notify(DelegateTask delegateTask) {
        delegateTask.setAssignee("老板");
    }
}

　　接下來到controller。

發起請假流程。這里要說明一下，只有在上一個節點完成任務后，流程才會執行到下一個節點。所以這里在發起流程后，就手動完成了任務，讓流程進行到下一個節點。

    /**
     * 發起請假
     *
     * @param userId    用戶Id
     * @param days     請假天數
     * @param descption 描述
     */ 
@RequestMapping(value = "/add")
    @ResponseBody
    public String addExpense(String userId, Integer money, String descption) {

        //啟動流程
        HashMap<String, Object> map = new HashMap<>();
        map.put("taskUser", userId);
        map.put("days", days);
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("leave-flow", map);
        Task task = taskService.createTaskQuery().processInstanceId(processInstance.getId()).singleResult();
        taskService.complete(task.getId());

        return "提交成功.流程Id為：" + processInstance.getId() + "任務id: " + task.getId() ;
    }

其他操作。

    /**
     * 獲取審批管理列表
     */
    @RequestMapping(value = "/list")
    @ResponseBody
    public Object list(String userId) {
        List<Task> tasks = taskService.createTaskQuery().taskAssignee(userId).orderByTaskCreateTime().desc().list();
        for (Task task : tasks) {
        }
        System.out.println(tasks.toString());

        return tasks.toString();
    }


    /**
     * 批准
     *
     * @param taskId 任務ID
     */
    @RequestMapping(value = "apply")
    @ResponseBody
    public String apply(String taskId) {
        List<Task> t = taskService.createTaskQuery().list();
        Task task = taskService.createTaskQuery().taskId(taskId).singleResult();

        //Task task = taskService.createTaskQuery().taskId(taskId).singleResult();

        if (task == null) {
            throw new RuntimeException("流程不存在");
        }
        //通過審核
        HashMap<String, Object> map = new HashMap<>();
        map.put("result", "同意");
        taskService.complete(taskId, map);
        return "processed ok!";
    }

    /**
     * 拒絕
     */
    @ResponseBody
    @RequestMapping(value = "reject")
    public String reject(String taskId) {
        HashMap<String, Object> map = new HashMap<>();
        map.put("result", "駁回");
        taskService.complete(taskId, map);
        return "reject";
    }

    /**
     * 生成流程圖
     *
     * @param processId 任務ID
     */
    @RequestMapping(value = "processDiagram")
    public void genProcessDiagram(HttpServletResponse httpServletResponse, String processId) throws Exception {
        List<ProcessInstance> t = runtimeService.createProcessInstanceQuery().list();
        ProcessInstance pi = runtimeService.createProcessInstanceQuery().processInstanceId(processId).singleResult();


        //流程走完的不顯示圖
        if (pi == null) {
            return;
        }
        Task task = taskService.createTaskQuery().processInstanceId(pi.getId()).singleResult();
        //使用流程實例ID，查詢正在執行的執行對象表，返回流程實例對象
        String InstanceId = task.getProcessInstanceId();
        List<Execution> executions = runtimeService
                .createExecutionQuery()
                .processInstanceId(InstanceId)
                .list();

        //得到正在執行的Activity的Id
        List<String> activityIds = new ArrayList<>();
        List<String> flows = new ArrayList<>();
        for (Execution exe : executions) {
            List<String> ids = runtimeService.getActiveActivityIds(exe.getId());
            activityIds.addAll(ids);
        }

        //獲取流程圖
        BpmnModel bpmnModel = repositoryService.getBpmnModel(pi.getProcessDefinitionId());
        ProcessEngineConfiguration engconf = processEngine.getProcessEngineConfiguration();
        ProcessDiagramGenerator diagramGenerator = engconf.getProcessDiagramGenerator();
//        InputStream in = diagramGenerator.generateDiagram(bpmnModel, "png", activityIds, flows, engconf.getActivityFontName(), engconf.getLabelFontName(), engconf.getAnnotationFontName(), engconf.getClassLoader(), 1.0);
        InputStream in = diagramGenerator.generateDiagram(bpmnModel, "png", activityIds, Collections.emptyList(), engconf.getActivityFontName(), engconf.getLabelFontName(), engconf.getAnnotationFontName(), null, 1.0, false);
        OutputStream out = null;
        byte[] buf = new byte[1024];
        int legth = 0;
        try {
            out = httpServletResponse.getOutputStream();
            while ((legth = in.read(buf)) != -1) {
                out.write(buf, 0, legth);
            }
        } finally {
            if (in != null) {
                in.close();
            }
            if (out != null) {
                out.close();
            }
        }
    }