日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

流程引擎，也算是一個(gè)比較常見的工具了，我們在日常的很多開發(fā)中都會(huì)用到，當(dāng)然用的最多的就是 OA 系統(tǒng)了，但是在一些非 OA 系統(tǒng)中，我們也會(huì)涉及到，比如一個(gè) CRM 中，可能會(huì)有合同管理的需求，合同的審批，也是需要流程引擎的。

成都創(chuàng)新互聯(lián)服務(wù)項(xiàng)目包括渭城網(wǎng)站建設(shè)、渭城網(wǎng)站制作、渭城網(wǎng)頁制作以及渭城網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，渭城網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到渭城省份的部分城市，未來相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

所以今天我們來簡單聊聊流程引擎，順便寫一個(gè)簡單的例子，小伙伴們一起來感受下流程引擎到底是個(gè)啥。

1. 流程引擎介紹

Flowable 是一個(gè)使用 Java 編寫的輕量級業(yè)務(wù)流程引擎。Flowable 流程引擎可用于部署 BPMN2.0 流程定義(用于定義流程的行業(yè) XML 標(biāo)準(zhǔn))，創(chuàng)建這些流程定義的流程實(shí)例，進(jìn)行查詢，訪問運(yùn)行中或歷史的流程實(shí)例與相關(guān)數(shù)據(jù)，等等。

Java 領(lǐng)域另一個(gè)流程引擎是 Activiti，不過我覺得這兩個(gè)東西，只要你會(huì)使用其中一個(gè)，另一個(gè)就不在話下。

咱就不廢話了，上代碼吧。

2. 創(chuàng)建項(xiàng)目

首先我們創(chuàng)建一個(gè) Spring Boot 項(xiàng)目，引入 Web、和 MySQL 驅(qū)動(dòng)兩個(gè)依賴，如下圖：

項(xiàng)目創(chuàng)建成功之后，我們引入 flowable 依賴，如下：

    org.flowable
    flowable-spring-boot-starter
    6.7.2

這個(gè)會(huì)幫我們做一些自動(dòng)化配置，默認(rèn)情況下，所以位于 resources/processes 的流程都會(huì)被自動(dòng)部署。

接下來我們在 application.yaml 中配置一下數(shù)據(jù)庫連接信息，當(dāng)項(xiàng)目啟動(dòng)的時(shí)候會(huì)自動(dòng)初始化數(shù)據(jù)庫，將來流程引擎運(yùn)行時(shí)候的數(shù)據(jù)會(huì)被自動(dòng)持久化到數(shù)據(jù)庫中。

spring:
  datasource:
    username: root
    password: 123
    url: jdbc:mysql:///flowable?serverTimezone=Asia/Shanghai&useSSL=false

好啦，配置完成后，我們就可以啟動(dòng)項(xiàng)目了。項(xiàng)目啟動(dòng)成功之后，flowable 數(shù)據(jù)庫中就會(huì)自動(dòng)創(chuàng)建如下這些表，將來流程引擎相關(guān)的數(shù)據(jù)都會(huì)自動(dòng)保存到這些表中。

默認(rèn)的表比較多，截圖只是其中一部分。

3. 畫流程圖

畫流程圖算是比較有挑戰(zhàn)的一個(gè)步驟了，也是流程引擎使用的關(guān)鍵。官方提供了一些流程引擎繪制工具，這個(gè)我就不說了，感興趣的小伙伴可以自行去體驗(yàn);IDEA 也自帶了一個(gè)流程可視化的工具，但是特別難用，我這里也就 不說了。

這里說一下我常用的 IDEA 插件 Flowable BPMN visualizer，如下圖：

插件怎么安裝就不用我教了吧，小伙伴們自行安裝即可。

裝好插件之后，我們在 resources 目錄下新建 processes 目錄，這個(gè)目錄下的流程文件將來會(huì)被自動(dòng)部署。

接下來我們在 processes 目錄下，新建一個(gè) BPMN 文件(插件裝好了就有這個(gè)選項(xiàng)了)，如下：

我們來畫個(gè)請假的流程，就叫做 ask_for_leave.bpmn20.xml，注意最后面的 .bpmn20.xml 是固定后綴。

文件創(chuàng)建出來之后，右鍵單擊，選擇 View BPMN(Flowable) Diagram,就打開了可視化頁面了，我們就可以來繪制自己的流程圖了。

我的請假流程畫出來是這樣：

員工發(fā)起一個(gè)請假流程，首先是組長審核，組長審核通過了，就進(jìn)入到經(jīng)理審核，經(jīng)理審核通過了，這個(gè)流程就結(jié)束了，如果組長審核未通過或者經(jīng)理審核未通過，則流程給員工發(fā)送一個(gè)請假失敗的通知，流程結(jié)束。

我們來看下這個(gè)流程對應(yīng)的 XML 文件，一些流程細(xì)節(jié)會(huì)在 XML 文件中體現(xiàn)出來，如下：

結(jié)合 XML 文件我來和大家解釋一下這里涉及到的 Flowable 中的組件，我們來看下：

• ：表示一個(gè)完整的工作流程。
• ：工作流中起點(diǎn)位置，也就是圖中的綠色按鈕。
• ：工作流中結(jié)束位置，也就是圖中的紅色按鈕。
• ：代表一個(gè)任務(wù)審核節(jié)點(diǎn)（組長、經(jīng)理等角色），這個(gè)節(jié)點(diǎn)上有一個(gè) flowable:assignee 屬性，這表示這個(gè)節(jié)點(diǎn)該由誰來處理，將來在 Java 代碼中調(diào)用的時(shí)候，我們需要指定對應(yīng)的處理人的 ID 或者其他唯一標(biāo)記。
• ：這是服務(wù)任務(wù)，在具體的實(shí)現(xiàn)中，這個(gè)任務(wù)可以做任何事情。
• ：邏輯判斷節(jié)點(diǎn)，相當(dāng)于流程圖中的菱形框。
• ：鏈接各個(gè)節(jié)點(diǎn)的線條，sourceRef 屬性表示線的起始節(jié)點(diǎn)，targetRef 屬性表示線指向的節(jié)點(diǎn)，我們圖中的線條都屬于這種。

流程圖這塊松哥和大家稍微說一下，咋一看這個(gè)圖挺復(fù)雜很難畫，但是實(shí)際上只要你認(rèn)認(rèn)真真去捋一捋這里邊的各個(gè)屬性，基本上很快就明白到底是怎么一回事，我也相信各位小伙伴都有這樣的悟性。

4. 開發(fā)接口

接下來我們寫幾個(gè)接口，來體驗(yàn)一把流程引擎。

在正式體驗(yàn)之前，我們先來熟悉幾個(gè)類，這幾個(gè)類我們一會(huì)寫代碼會(huì)用到。

4.1 Java 類梳理

• ProcessDefinition

這個(gè)最好理解，就是流程的定義，也就相當(dāng)于規(guī)范，每個(gè) ProcessDefinition 都會(huì)有一個(gè) id。

• ProcessInstance

這個(gè)就是流程的一個(gè)實(shí)例。簡單來說，ProcessDefinition 相當(dāng)于是類，而 ProcessInstance 則相當(dāng)于是根據(jù)類 new 出來的對象。

• Activity

Activity 是流程標(biāo)準(zhǔn)規(guī)范 BPMN2.0 里面的規(guī)范，流程中的每一個(gè)步驟都是一個(gè) Activity。

• Execution

Execution 的含義是流程的執(zhí)行線路，通過 Execution 可以獲得當(dāng)前 ProcessInstance 當(dāng)前執(zhí)行到哪個(gè) Activity了。

• Task

Task 就是當(dāng)前要做的工作。

實(shí)際上這里涉及到的東西比較多，不過我們今天先整一個(gè)簡單的例子，所以上面這些知識(shí)點(diǎn)暫時(shí)夠用了。

4.2 查看流程圖

在正式開始之前，我們先準(zhǔn)備一個(gè)接口，用來查看流程圖的實(shí)時(shí)執(zhí)行情況，這樣方便我們查看流程到底執(zhí)行到哪一步了。

具體的代碼如下：

@RestController
public class HelloController {

    @Autowired
    RuntimeService runtimeService;

    @Autowired
    TaskService taskService;

    @Autowired
    RepositoryService repositoryService;

    @Autowired
    ProcessEngine processEngine;

    @GetMapping("/pic")
    public void showPic(HttpServletResponse resp, String processId) throws Exception {
        ProcessInstance pi = runtimeService.createProcessInstanceQuery().processInstanceId(processId).singleResult();
        if (pi == null) {
            return;
        }
        List executions = runtimeService
                .createExecutionQuery()
                .processInstanceId(processId)
                .list();

        List activityIds = new ArrayList<>();
        List flows = new ArrayList<>();
        for (Execution exe : executions) {
            List 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, false);
        OutputStream out = null;
        byte[] buf = new byte[1024];
        int legth = 0;
        try {
            out = resp.getOutputStream();
            while ((legth = in.read(buf)) != -1) {
                out.write(buf, 0, legth);
            }
        } finally {
            if (in != null) {
                in.close();
            }
            if (out != null) {
                out.close();
            }
        }
    }
}

這就一個(gè)工具，沒啥好說的，一會(huì)大家看完后面的代碼，再回過頭來看這個(gè)接口，很多地方就都懂了。

4.3 開啟一個(gè)流程

為了方便，接下來的代碼我們都在單元測試中完成。

首先我們來開啟一個(gè)流程，代碼如下：

String staffId = "1000";
/**
 * 開啟一個(gè)流程
 */
@Test
void askForLeave() {
    HashMap map = new HashMap<>();
    map.put("leaveTask", staffId);
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("ask_for_leave", map);
    runtimeService.setVariable(processInstance.getId(), "name", "javaboy");
    runtimeService.setVariable(processInstance.getId(), "reason", "休息一下");
    runtimeService.setVariable(processInstance.getId(), "days", 10);
    logger.info("創(chuàng)建請假流程 processId：{}", processInstance.getId());
}

首先由員工發(fā)起一個(gè)請假流程，map 中存放的 leaveTask 是我們在 XML 流程文件中提前定義好的，提前定義好當(dāng)前這個(gè)任務(wù)創(chuàng)建之后，該由誰來處理，這里我們是假設(shè)由工號(hào)為 1000 的員工來發(fā)起這樣一個(gè)請假流程。同時(shí)，我們還設(shè)置了一些額外信息。ask_for_leave 是我們在 XML 文件中定義的一個(gè) process 的名稱。

好啦，現(xiàn)在我們執(zhí)行這個(gè)單元測試方法，執(zhí)行完成后，控制臺(tái)會(huì)打印出當(dāng)前這個(gè)流程的 id，我們拿著這個(gè) id 去訪問 4.2 小節(jié)的接口，結(jié)果如下：

可以看到，請假用紅色的框框起來了，說明當(dāng)前流程走到了這一步。

4.4 將請求提交給組長

接下來，我們就需要將這個(gè)請假流程向后推進(jìn)一步，將請假事務(wù)提交給組長，代碼如下：

String zuzhangId = "90";
/**
 * 提交給組長審批
 */
@Test
void submitToZuzhang() {
    //員工查找到自己的任務(wù)，然后提交給組長審批
    List list = taskService.createTaskQuery().taskAssignee(staffId).orderByTaskId().desc().list();
    for (Task task : list) {
        logger.info("任務(wù) ID：{}；任務(wù)處理人：{}；任務(wù)是否掛起：{}", task.getId(), task.getAssignee(), task.isSuspended());
        Map map = new HashMap<>();
        //提交給組長的時(shí)候，需要指定組長的 id
        map.put("zuzhangTask", zuzhangId);
        taskService.complete(task.getId(), map);
    }
}

首先我們利用 staffId 查找到當(dāng)前員工的 id，進(jìn)而找到當(dāng)前員工需要執(zhí)行的任務(wù)，遍歷這個(gè)任務(wù)，調(diào)用 taskService.complete 方法將任務(wù)提交給組長，注意在 map 中指定組長的 id。

提交完成后，我們再去看流程圖片，如下：

可以看到，流程圖走到組長審批了。

4.5 組長審批

組長現(xiàn)在有兩種選擇，同意或者拒絕，同意的代碼如下：

/**
 * 組長審批-批準(zhǔn)
 */
@Test
void zuZhangApprove() {
    List list = taskService.createTaskQuery().taskAssignee(zuzhangId).orderByTaskId().desc().list();
    for (Task task : list) {
        logger.info("組長 {} 在審批 {} 任務(wù)", task.getAssignee(), task.getId());
        Map map = new HashMap<>();
        //組長審批的時(shí)候，如果是同意，需要指定經(jīng)理的 id
        map.put("managerTask", managerId);
        map.put("checkResult", "通過");
        taskService.complete(task.getId(), map);
    }
}

通過組長的 id 查詢組長的任務(wù)，同意的話，需要指定經(jīng)理，也就是這個(gè)流程下一步該由誰來處理。

拒絕的代碼如下：

/**
 * 組長審批-拒絕
 */
@Test
void zuZhangReject() {
    List list = taskService.createTaskQuery().taskAssignee(zuzhangId).orderByTaskId().desc().list();
    for (Task task : list) {
        logger.info("組長 {} 在審批 {} 任務(wù)", task.getAssignee(), task.getId());
        Map map = new HashMap<>();
        //組長審批的時(shí)候，如果是拒絕，就不需要指定經(jīng)理的 id
        map.put("checkResult", "拒絕");
        taskService.complete(task.getId(), map);
    }
}

拒絕的話，就沒那么多事了，直接設(shè)置 checkResult 為拒絕即可。

假設(shè)這里執(zhí)行了同意，那么流程圖如下：

4.6 經(jīng)理審批

經(jīng)理審批和組長審批差不多，只不過經(jīng)理這里是最后一步了，不需要再指定下一位處理人了，同意的代碼如下：

/**
 * 經(jīng)理審批自己的任務(wù)-批準(zhǔn)
 */
@Test
void managerApprove() {
    List list = taskService.createTaskQuery().taskAssignee(managerId).orderByTaskId().desc().list();
    for (Task task : list) {
        logger.info("經(jīng)理 {} 在審批 {} 任務(wù)", task.getAssignee(), task.getId());
        Map map = new HashMap<>();
        map.put("checkResult", "通過");
        taskService.complete(task.getId(), map);
    }
}

拒絕代碼如下：

/**
 * 經(jīng)理審批自己的任務(wù)-拒絕
 */
@Test
void managerReject() {
    List list = taskService.createTaskQuery().taskAssignee(managerId).orderByTaskId().desc().list();
    for (Task task : list) {
        logger.info("經(jīng)理 {} 在審批 {} 任務(wù)", task.getAssignee(), task.getId());
        Map map = new HashMap<>();
        map.put("checkResult", "拒絕");
        taskService.complete(task.getId(), map);
    }
}

4.7 拒絕流程

如果組長拒絕了或者經(jīng)理拒絕了，我們也有相應(yīng)的處理方案，首先在 XML 流程文件定義時(shí)，如下：

如果請假被拒絕，會(huì)進(jìn)入到這個(gè) serviceTask，serviceTask 對應(yīng)的處理類是 org.javaboy.flowable.AskForLeaveFail，該類的代碼如下：

public class AskForLeaveFail implements JavaDelegate {
    @Override
    public void execute(DelegateExecution execution) {
        System.out.println("請假失敗。。。");
    }
}

也就是請假失敗會(huì)進(jìn)入到這個(gè)方法中，現(xiàn)在我們就可以在這個(gè)方法中該干嘛干嘛了。

當(dāng)前標(biāo)題：SpringBoot整合流程引擎Flowable，SoEasy！
URL鏈接：http://www.dlmjj.cn/article/dhdcedo.html