博客 / 詳情

返回

Flowable 流程實例的掛起(暫停)與激活

今天來和小夥伴們聊一聊流程的掛起和激活。

這塊實際上涉及到兩部分內容:

  1. 流程定義的掛起和激活。
  2. 流程實例的掛起和激活。

一個定義好的流程,如果掛起了,那麼就無法據此創建新的流程。

一個流程實例如果掛起了,那麼就無法執行流程中的任務。

小夥伴們注意區分這兩個概念(看了前面幾篇文章的小夥伴,應該對於這兩個概念不在話下了)。

我們分別來看。

1. 流程定義的掛起與激活

1.1 查詢是否掛起

對於一個定義好的流程,我們可以通過如下方法來查看這個流程是否掛起:

@Test
void test05() {
    List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().list();
    for (ProcessDefinition processDefinition : list) {
        String id = processDefinition.getId();
        boolean suspended = repositoryService.isProcessDefinitionSuspended(id);
        if (suspended) {
            logger.info("流程定義 {} 已掛起",processDefinition.getName());
        }else{
            logger.info("流程定義 {} 未掛起",processDefinition.getName());
        }
    }
}

這個查詢 SQL 涉及到的表是 ACT_RE_PROCDEF,該表中有一個名為 SUSPENSION_STATE_ 的字段,該字段表示這個流程是否掛起。如下圖:

1 表示流程沒有掛起。

1.2 掛起

執行如下方法,可以掛起一個流程定義,如下:

@Test
void test06() {
    List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().list();
    for (ProcessDefinition pd : list) {
        repositoryService.suspendProcessDefinitionById(pd.getId());
    }
}

掛起的原理其實很簡單,就是去 ACT_RE_PROCDEF 表中,將 SUSPENSION_STATE_ 字段的值設置為 2,就表示這個流程定義掛起了,我們可以看下流程定義掛起時執行的 SQL:

從這個執行的 SQL 中我們可以清晰的看到,操作的表是 ACT_RE_PROCDEF,修改的字段就是 SUSPENSION_STATE_,將該字段的值修改為 2(樂觀鎖相關的 REV_ 字段不考慮)。

對於一個已經掛起的流程定義,如果我們想據此啓動一個流程,如下:

@Test
void test01() {
    identityService.setAuthenticatedUserId("wangwu");
    ProcessInstance pi = runtimeService.startProcessInstanceByKey("leave");
    logger.info("id:{},activityId:{}", pi.getId(), pi.getActivityId());
}

此時就會拋出如下異常:

這個異常説的很明白了,流程定義被掛起了,無法開啓一個新的流程實例。

1.3 激活

已經掛起的流程定義,還可以激活,方式如下:

@Test
void test07() {
    List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().list();
    for (ProcessDefinition pd : list) {
        repositoryService.activateProcessDefinitionById(pd.getId());
    }
}

激活的原理也很簡單,,就是去 ACT_RE_PROCDEF 表中,將 SUSPENSION_STATE_ 字段的值設置為 1,就表示這個流程定義激活了,我們可以看下流程定義激活時執行的 SQL:

大家注意看操作的表、字段以及對應的參數。

2. 流程實例的掛起與激活

第一小節搞懂了,第二小節就容易多了。

2.1 掛起

掛起一個流程實例的方式如下:

@Test
void test08() {
    List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().list();
    for (ProcessDefinition pd : list) {
        repositoryService.suspendProcessDefinitionById(pd.getId(), true, null);
    }
}

小夥伴們看到,其實還是剛才上面的那個方法,只不過這裏多了兩個參數:

  1. 第二個參數 true 表示是否要掛起這個流程定義對應的所有的流程實例,true 表示掛起。
  2. 第三個參數 null 表示流程掛起的具體時間,如果該參數為 null,則流程會被立馬掛起,如果該參數是一個具體的日期,則到期之後流程才會被掛起,但是這個需要 job executor 的支持,關於 job executor,鬆哥後面再單獨發文章和小夥伴們介紹。

執行完成之後,這個流程實例就被掛起了。流程實例被掛起,涉及到兩個地方:

  1. 流程的執行實例被掛起。
  2. 流程的 Task 被掛起。

也就是首先 ACT_RU_EXECUTION 表中對應的流程實例會被掛起:

最後一列兩個 2 就説明這兩個執行實例被掛起了。

同時,流程實例的 Task 其實也被掛起了,即 ACT_RU_TASK 表中與之對應的任務被掛起了,如下:

可以看到,SUSPENSION_STATE_ 字段的值為 2,表示這 Task 也被掛起了。

我們來看看掛起流程實例時執行的 SQL:

注意,流程定義本身也被掛起了

對於處於掛起狀態的流程實例,是無法繼續執行的,如果強行執行,如下:

@Test
void test03() {
    List<Task> list = taskService.createTaskQuery().taskAssignee("wangwu").list();
    for (Task task : list) {
        taskService.complete(task.getId());
    }
}

則會拋出異常,如下:

這個異常也説的很清楚了,無法完成一個處於掛起狀態的 Task。

2.2 激活

處於掛起狀態的流程實例,可以通過如下方式激活:

@Test
void test09() {
    List<ProcessDefinition> list = repositoryService.createProcessDefinitionQuery().list();
    for (ProcessDefinition pd : list) {
        repositoryService.activateProcessDefinitionById(pd.getId(), true, null);
    }
}

一共三個參數:

  1. 流程定義的 ID。
  2. 是否激活流程定義對應的流程實例。
  3. 激活流程實例的時間,null 表示立馬激活,如果是一個具體的時間,則到期激活,不過和之前的一樣,這裏也需要 job executor 的支持。

激活就是反向操作,將 ACT_RU_EXECUTIONACT_RU_TASK 以及 ACT_RE_PROCDEF 表中的 SUSPENSION_STATE_ 字段值再改為 1。對應的 SQL 如下:

好啦,掛起與激活就先聊這麼多,下篇文章繼續~

user avatar
0 位用戶收藏了這個故事!

發佈 評論

Some HTML is okay.