在之前的文章中松哥和小伙伴們聊過，正在執(zhí)行的流程信息是保存在以ACT_RU_為前綴的表中，執(zhí)行完畢的流程信息則保存在以ACT_HI_為前綴的表中，也就是流程歷史信息表，當(dāng)然這個(gè)歷史信息表繼續(xù)細(xì)分的話，還有好多種，今天我們就來(lái)聊一聊這個(gè)話題。

假設(shè)我有如下一個(gè)流程：

當(dāng)這個(gè)流程執(zhí)行完畢后，以ACT_RU_為前綴的表中的數(shù)據(jù)均已清空，現(xiàn)在如果想查看剛剛執(zhí)行過的流程信息，我們就得去以ACT_HI_為前綴的表中。

(資料圖片僅供參考)

1. 歷史流程信息

歷史流程信息查看，方式如下：

@Testvoid test05(){    List list = historyService.createHistoricProcessInstanceQuery().finished().list();    for (HistoricProcessInstance hpi : list) {        logger.info("name:{},startTime:{},endTime:{}",hpi.getName(),hpi.getStartTime(),hpi.getEndTime());    }}

調(diào)用的時(shí)候執(zhí)行的finished()方法表示查詢已經(jīng)執(zhí)行完畢的流程信息（從這里也可以看出，對(duì)于未執(zhí)行完畢的流程信息也會(huì)保存在歷史表中）。

我們來(lái)看下這個(gè)查詢對(duì)應(yīng)的 SQL，如下：

SELECT RES.* , DEF.KEY_ as PROC_DEF_KEY_, DEF.NAME_ as PROC_DEF_NAME_, DEF.VERSION_ as PROC_DEF_VERSION_, DEF.DEPLOYMENT_ID_ as DEPLOYMENT_ID_ from ACT_HI_PROCINST RES left outer join ACT_RE_PROCDEF DEF on RES.PROC_DEF_ID_ = DEF.ID_ WHERE RES.END_TIME_ is not NULL order by RES.ID_ asc

從這個(gè) SQL 中可以看到，這個(gè)查詢本質(zhì)上就是查詢的ACT_HI_PROCINST表。如下圖：

如果我們?cè)诓樵兊臅r(shí)候不限制流程是否執(zhí)行完畢，那么我們的查詢方法如下：

@Testvoid test05(){    List list = historyService.createHistoricProcessInstanceQuery().list();    for (HistoricProcessInstance hpi : list) {        logger.info("name:{},startTime:{},endTime:{}",hpi.getName(),hpi.getStartTime(),hpi.getEndTime());    }}

對(duì)應(yīng)的查詢 SQL 如下：

SELECT RES.* , DEF.KEY_ as PROC_DEF_KEY_, DEF.NAME_ as PROC_DEF_NAME_, DEF.VERSION_ as PROC_DEF_VERSION_, DEF.DEPLOYMENT_ID_ as DEPLOYMENT_ID_ from ACT_HI_PROCINST RES left outer join ACT_RE_PROCDEF DEF on RES.PROC_DEF_ID_ = DEF.ID_ order by RES.ID_ asc

和前面的 SQL 相比，后面的 SQL 少了WHERE RES.END_TIME_ is not NULL條件，也就是說(shuō)，判斷一個(gè)流程是否執(zhí)行完畢，就看它的END_TIME_是否為空，不為空就表示流程已經(jīng)執(zhí)行結(jié)束了，為空就表示流程尚在執(zhí)行中。

2. 歷史任務(wù)查詢

剛剛我們查詢的是歷史流程，接下來(lái)我們來(lái)看下歷史任務(wù)，也就是查詢一個(gè)流程中執(zhí)行過的 Task 信息，如下表示查詢所有的歷史流程任務(wù)：

@Testvoid test06(){    List list = historyService.createHistoricTaskInstanceQuery().list();    for (HistoricTaskInstance hti : list) {        logger.info("name:{},assignee:{},createTime:{},endTime:{}",hti.getName(),hti.getAssignee(),hti.getCreateTime(),hti.getEndTime());    }}

這個(gè)查詢對(duì)應(yīng)的 SQL 如下：

SELECT RES.* from ACT_HI_TASKINST RES order by RES.ID_ asc

可以看到，歷史任務(wù)表就是ACT_HI_TASKINST，如下圖：

當(dāng)然，這里還有很多其他的玩法，例如查詢某一個(gè)流程已經(jīng)執(zhí)行完畢的歷史任務(wù)，如下：

@Testvoid test07(){    List instanceList = historyService.createHistoricProcessInstanceQuery().list();    for (HistoricProcessInstance hpi : instanceList) {        List list = historyService.createHistoricTaskInstanceQuery().processInstanceId(hpi.getId()).finished().list();        for (HistoricTaskInstance hti : list) {            logger.info("name:{},assignee:{},createTime:{},endTime:{}", hti.getName(), hti.getAssignee(), hti.getCreateTime(), hti.getEndTime());        }    }}

這個(gè)里邊的查詢歷史任務(wù)的 SQL 如下：

SELECT RES.* from ACT_HI_TASKINST RES WHERE RES.PROC_INST_ID_ = ? and RES.END_TIME_ is not null order by RES.ID_ asc

可以看到，跟前面相比，多了兩個(gè)條件：

流程實(shí)例 ID流程結(jié)束時(shí)間不為 null

從這里也可以看出來(lái)，這個(gè) finish 方法的執(zhí)行邏輯跟我們前面講的是一樣的。

3. 歷史活動(dòng)查詢

歷史任務(wù)就是各種 Task，歷史活動(dòng)則包括跟多內(nèi)容，像開始/結(jié)束節(jié)點(diǎn)，連線等等這些信息都算是活動(dòng)，這個(gè)在之前的文章中松哥已經(jīng)和大家介紹過了。

查詢代碼如下：

@Testvoid test08(){    List list = historyService.createHistoricActivityInstanceQuery().list();    for (HistoricActivityInstance hai : list) {        logger.info("name:{},startTime:{},assignee:{},type:{}",hai.getActivityName(),hai.getStartTime(),hai.getAssignee(),hai.getActivityType());    }}

這個(gè)查詢對(duì)應(yīng)的 SQL 如下：

SELECT RES.* from ACT_HI_ACTINST RES order by RES.ID_ asc

可以看到，ACT_HI_ACTINST表中保存了歷史活動(dòng)信息。

4. 歷史變量查詢

查詢流程執(zhí)行的歷史變量，方式如下：

@Testvoid test09(){    HistoricProcessInstance pi = historyService.createHistoricProcessInstanceQuery().singleResult();    List list = historyService.createHistoricVariableInstanceQuery().processInstanceId(pi.getId()).list();    for (HistoricVariableInstance hvi : list) {        logger.info("name:{},type:{},value:{}", hvi.getVariableName(), hvi.getVariableTypeName(), hvi.getValue());    }}

這個(gè)查詢對(duì)應(yīng)的 SQL 如下：

SELECT RES.* from ACT_HI_VARINST RES WHERE RES.PROC_INST_ID_ = ? order by RES.ID_ asc

可以看到流程的歷史變量信息保存在ACT_HI_VARINST表中。

5. 歷史日志查詢

有的小伙伴看到日志這兩個(gè)字可能會(huì)覺得奇怪，咦？流程執(zhí)行還有日志嗎？沒聽說(shuō)過呀！

其實(shí)歷史日志查詢就是前面那幾種的一個(gè)集大成者，用法如下：

@Testvoid test10(){    HistoricProcessInstance pi = historyService.createHistoricProcessInstanceQuery().singleResult();    ProcessInstanceHistoryLog historyLog = historyService.createProcessInstanceHistoryLogQuery(pi.getId())            //包括歷史活動(dòng)            .includeActivities()            //包括歷史任務(wù)            .includeTasks()            //包括歷史變量            .includeVariables()            .singleResult();    logger.info("id:{},startTime:{},endTime:{}", historyLog.getId(), historyLog.getStartTime(), historyLog.getEndTime());    List historicData = historyLog.getHistoricData();    for (HistoricData data : historicData) {        if (data instanceof HistoricActivityInstance) {            HistoricActivityInstance hai = (HistoricActivityInstance) data;            logger.info("name:{},type:{}", hai.getActivityName(), hai.getActivityType());        }        if (data instanceof HistoricTaskInstance) {            HistoricTaskInstance hti = (HistoricTaskInstance) data;            logger.info("name:{},assignee:{}", hti.getName(), hti.getAssignee());        }        if (data instanceof HistoricVariableInstance) {            HistoricVariableInstance hvi = (HistoricVariableInstance) data;            logger.info("name:{},type:{},value:{}", hvi.getVariableName(), hvi.getVariableTypeName(), hvi.getValue());        }    }}

這個(gè)里邊，首先是查詢基本的流程日志信息，這個(gè)本質(zhì)上就是查詢歷史流程實(shí)例信息，對(duì)應(yīng)的 SQL 如下：

select RES.*, DEF.KEY_ as PROC_DEF_KEY_, DEF.NAME_ as PROC_DEF_NAME_, DEF.VERSION_ as PROC_DEF_VERSION_, DEF.DEPLOYMENT_ID_ as DEPLOYMENT_ID_ from ACT_HI_PROCINST RES left outer join ACT_RE_PROCDEF DEF on RES.PROC_DEF_ID_ = DEF.ID_ where PROC_INST_ID_ = ?

接下來(lái)我寫了三個(gè) include，每一個(gè) include 都對(duì)應(yīng)一句 SQL：

includeActivities 對(duì)應(yīng)的 SQL 如下：

SELECT RES.* from ACT_HI_ACTINST RES WHERE RES.PROC_INST_ID_ = ? order by RES.ID_ asc

includeTasks 對(duì)應(yīng)的 SQL 如下：

SELECT RES.* from ACT_HI_TASKINST RES WHERE RES.PROC_INST_ID_ = ? order by RES.ID_ asc

includeVariables 對(duì)應(yīng)的 SQL 如下：

SELECT RES.* from ACT_HI_VARINST RES WHERE RES.PROC_INST_ID_ = ? order by RES.ID_ asc

最終查詢完成后，調(diào)用getHistoricData方法可以查看這些額外的數(shù)據(jù)，List 集合中存放的 HistoricData 也分為不同的類型：

includeActivities 方法對(duì)應(yīng)最終查詢出來(lái)的類型是 HistoricActivityInstance。includeTasks 方法對(duì)應(yīng)最終查詢出來(lái)的類型是 HistoricTaskInstance。includeVariables 方法對(duì)應(yīng)最終查詢出來(lái)的類型是 HistoricVariableInstance。

在遍歷的時(shí)候通過類型判斷去查看具體是哪一種變量類型。

綜上，這個(gè)歷史日志查詢其實(shí)就是一個(gè)集大成者。

6. 歷史權(quán)限查詢

這個(gè)是用來(lái)查詢流程或者任務(wù)的處理人，例如查詢流程的處理人，方式如下：

@Testvoid test11(){    HistoricProcessInstance pi = historyService.createHistoricProcessInstanceQuery().singleResult();    List links = historyService.getHistoricIdentityLinksForProcessInstance(pi.getId());    for (HistoricIdentityLink link : links) {        logger.info("userId:{}",link.getUserId());    }}

這個(gè)是查詢流程對(duì)應(yīng)的處理人，對(duì)應(yīng)的 SQL 如下：

select * from ACT_HI_IDENTITYLINK where PROC_INST_ID_ = ?

如果想查詢?nèi)蝿?wù)的處理人，對(duì)應(yīng)的方式如下：

@Testvoid test12(){    String taskName = "提交請(qǐng)假申請(qǐng)";    HistoricTaskInstance hti = historyService.createHistoricTaskInstanceQuery().taskName(taskName).singleResult();    List links = historyService.getHistoricIdentityLinksForTask(hti.getId());    for (HistoricIdentityLink link : links) {        logger.info("{} 任務(wù)的處理人是 {}",taskName,link.getUserId());    }}

這個(gè)查詢對(duì)應(yīng)的 SQL 如下：

select * from ACT_HI_IDENTITYLINK where TASK_ID_ = ?

和前面的相比，其實(shí)就多了一個(gè)查詢條件TASK_ID_。

7. 自定義查詢 SQL

和前面講的很多查詢類似，當(dāng)我們弄懂了每一個(gè)歷史查詢的 API 操作的是哪一個(gè)數(shù)據(jù)表，就會(huì)發(fā)現(xiàn)，歷史數(shù)據(jù)的查詢，也可以自定義 SQL。

舉個(gè)例子和小伙伴們看下，例如查詢某一個(gè)流程已經(jīng)執(zhí)行完畢的歷史任務(wù)：

@Testvoid test13(){    List instanceList = historyService.createHistoricProcessInstanceQuery().list();    for (HistoricProcessInstance hpi : instanceList) {        List list = historyService.createNativeHistoricTaskInstanceQuery()                .sql("SELECT RES.* from ACT_HI_TASKINST RES WHERE RES.PROC_INST_ID_ = #{pid} and RES.END_TIME_ is not null order by RES.ID_ asc")                .parameter("pid",hpi.getId()).list();        for (HistoricTaskInstance hti : list) {            logger.info("name:{},assignee:{},createTime:{},endTime:{}", hti.getName(), hti.getAssignee(), hti.getCreateTime(), hti.getEndTime());        }    }}

flowable 底層是 MyBatis，所有 SQL 中參數(shù)的傳遞形式和 MyBatis 一致。

8. 歷史數(shù)據(jù)記錄級(jí)別

Flowable 需要記錄哪些歷史數(shù)據(jù)，有一個(gè)日志級(jí)別用來(lái)描述這個(gè)事情，默認(rèn)有四種級(jí)別：

None: 這個(gè)表示不存儲(chǔ)任何歷史信息，好處是流程執(zhí)行的時(shí)候效率會(huì)比較快，壞處是流程執(zhí)行結(jié)束后，看不到曾經(jīng)執(zhí)行過的流程信息了。

Activity: 這個(gè)會(huì)存儲(chǔ)所有流程實(shí)例和活動(dòng)實(shí)例，在流程實(shí)例結(jié)束時(shí)，頂級(jí)流程實(shí)例變量的最新值將復(fù)制到歷史變量實(shí)例中，不會(huì)存儲(chǔ)詳細(xì)信息。

Audit: 在 Activity 的基礎(chǔ)上，還會(huì)存儲(chǔ)歷史詳細(xì)信息，包括權(quán)限信息等。默認(rèn)的日志記錄級(jí)別即次。

Full: 這個(gè)是在 Audit 的基礎(chǔ)上，還會(huì)存儲(chǔ)變量的變化信息，這會(huì)記錄大量的數(shù)據(jù)，也會(huì)導(dǎo)致流程執(zhí)行變慢。

一共就這四種級(jí)別，在 Spring Boot 項(xiàng)目中，如果我們想要配置這個(gè)日志記錄的級(jí)別，其實(shí)非常方便，直接在 application.properties 中進(jìn)行配置即可，如下：

flowable.history-level=none

配置加了這個(gè)配置，我們隨便啟動(dòng)一個(gè)流程，然后去查詢ACT_HI_系列的表，發(fā)現(xiàn)都是空的，沒有數(shù)據(jù)。

如果我們將歷史日志記錄的級(jí)別改為 activity，那么就會(huì)記錄下來(lái)流程信息以及活動(dòng)信息，但是像執(zhí)行的 Task 這些信息都是沒有的（ACT_HI_TASKINST），包括流程參與者的信息（ACT_HI_IDENTITYLINK）等都不會(huì)記錄下來(lái)。

如果我們將歷史日志記錄的級(jí)別改為 audit，則上面提到的這幾種日志就都會(huì)記錄下來(lái)。但是ACT_HI_DETAIL表還是空的，詳細(xì)一個(gè)流程變量的變化過程不會(huì)被記錄下來(lái)。

如果我們將日志記錄級(jí)別改為 full，那么將會(huì)記錄下更多的信息。ACT_HI_DETAIL表中會(huì)記錄下流程變量的詳細(xì)信息。

整個(gè)過程我就不給小伙伴們演示了大家可以自行嘗試。

關(guān)鍵詞： 執(zhí)行完畢 歷史任務(wù) 歷史變量 詳細(xì)信息 歷史信息