建站
咨詢
售后
建站咨詢
新聞中心
在之前的文章中松哥和小伙伴們聊過，正在執(zhí)行的流程信息是保存在以 ACT_RU_ 為前綴的表中，執(zhí)行完畢的流程信息則保存在以 ACT_HI_ 為前綴的表中，也就是流程歷史信息表，當(dāng)然這個(gè)歷史信息表繼續(xù)細(xì)分的話，還有好多種，今天我們就來聊一聊這個(gè)話題。
假設(shè)我有如下一個(gè)流程：
當(dāng)這個(gè)流程執(zhí)行完畢后，以 ACT_RU_ 為前綴的表中的數(shù)據(jù)均已清空，現(xiàn)在如果想查看剛剛執(zhí)行過的流程信息，我們就得去以 ACT_HI_ 為前綴的表中。
1. 歷史流程信息
歷史流程信息查看，方式如下：
@Test
void test05(){
Listlist = 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ì)保存在歷史表中）。
我們來看下這個(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í)行完畢，那么我們的查詢方法如下：
@Test
void test05(){
Listlist = 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 條件，也就是說，判斷一個(gè)流程是否執(zhí)行完畢，就看它的 END_TIME_ 是否為空，不為空就表示流程已經(jīng)執(zhí)行結(jié)束了，為空就表示流程尚在執(zhí)行中。
2. 歷史任務(wù)查詢
剛剛我們查詢的是歷史流程，接下來我們來看下歷史任務(wù)，也就是查詢一個(gè)流程中執(zhí)行過的 Task 信息，如下表示查詢所有的歷史流程任務(wù)：
@Test
void test06(){
Listlist = 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ù)，如下：
@Test
void test07(){
ListinstanceList = historyService.createHistoricProcessInstanceQuery().list();
for (HistoricProcessInstance hpi : instanceList) {
Listlist = 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
從這里也可以看出來，這個(gè) finish 方法的執(zhí)行邏輯跟我們前面講的是一樣的。
3. 歷史活動(dòng)查詢
歷史任務(wù)就是各種 Task，歷史活動(dòng)則包括跟多內(nèi)容，像開始/結(jié)束節(jié)點(diǎn)，連線等等這些信息都算是活動(dòng)，這個(gè)在之前的文章中松哥已經(jīng)和大家介紹過了。
查詢代碼如下：
@Test
void test08(){
Listlist = 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í)行的歷史變量，方式如下：
@Test
void test09(){
HistoricProcessInstance pi = historyService.createHistoricProcessInstanceQuery().singleResult();
Listlist = 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í)行還有日志嗎？沒聽說過呀！
其實(shí)歷史日志查詢就是前面那幾種的一個(gè)集大成者，用法如下：
@Test
void 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());
ListhistoricData = 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_ = ?
接下來我寫了三個(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)最終查詢出來的類型是 HistoricActivityInstance。
- includeTasks 方法對(duì)應(yīng)最終查詢出來的類型是 HistoricTaskInstance。
- includeVariables 方法對(duì)應(yīng)最終查詢出來的類型是 HistoricVariableInstance。
在遍歷的時(shí)候通過類型判斷去查看具體是哪一種變量類型。
綜上，這個(gè)歷史日志查詢其實(shí)就是一個(gè)集大成者。
6. 歷史權(quán)限查詢
這個(gè)是用來查詢流程或者任務(wù)的處理人，例如查詢流程的處理人，方式如下：
@Test
void test11(){
HistoricProcessInstance pi = historyService.createHistoricProcessInstanceQuery().singleResult();
Listlinks = 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)的方式如下：
@Test
void test12(){
String taskName = "提交請(qǐng)假申請(qǐng)";
HistoricTaskInstance hti = historyService.createHistoricTaskInstanceQuery().taskName(taskName).singleResult();
Listlinks = 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ù)：
@Test
void test13(){
ListinstanceList = historyService.createHistoricProcessInstanceQuery().list();
for (HistoricProcessInstance hpi : instanceList) {
Listlist = 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í)別用來描述這個(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ì)記錄下來流程信息以及活動(dòng)信息，但是像執(zhí)行的 Task 這些信息都是沒有的（ACT_HI_TASKINST），包括流程參與者的信息（ACT_HI_IDENTITYLINK）等都不會(huì)記錄下來。
如果我們將歷史日志記錄的級(jí)別改為 audit，則上面提到的這幾種日志就都會(huì)記錄下來。但是 ACT_HI_DETAIL 表還是空的，詳細(xì)一個(gè)流程變量的變化過程不會(huì)被記錄下來。
如果我們將日志記錄級(jí)別改為 full，那么將會(huì)記錄下更多的信息。ACT_HI_DETAIL 表中會(huì)記錄下流程變量的詳細(xì)信息。
整個(gè)過程我就不給小伙伴們演示了大家可以自行嘗試。
當(dāng)前文章：Flowable已經(jīng)執(zhí)行完畢的流程去哪找？
文章鏈接：http://www.dlmjj.cn/article/dpsheie.html
