[發(fā)明專利]一種工作業(yè)務(wù)流的流程數(shù)據(jù)同步方法、裝置及設(shè)備

在審

• 申請?zhí)枺?/td>: 202011604434.4
• 申請日: 2020-12-30
• 公開（公告）號: CN112685499A
• 公開（公告）日: 2021-04-20
• 發(fā)明（設(shè)計）人: 廖坤賢;王平;龍富永;付喆平;胡松青
• 申請（專利權(quán)）人: 珠海格力電器股份有限公司;珠海聯(lián)云科技有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/28;G06F16/22
• 代理公司: 北京同達信恒知識產(chǎn)權(quán)代理有限公司 11291
• 代理人: 黃麗

1.一種工作業(yè)務(wù)流的流程數(shù)據(jù)同步方法，其特征在于，所述方法包括：

在流程任務(wù)的任一流程節(jié)點觸發(fā)時，調(diào)用所述流程任務(wù)對應(yīng)的任務(wù)收集對象收集所述任一流程節(jié)點的節(jié)點數(shù)據(jù)；其中，所述任務(wù)收集對象用于收集至少一個流程任務(wù)執(zhí)行過程中各個流程節(jié)點產(chǎn)生的節(jié)點數(shù)據(jù)，每個流程節(jié)點的節(jié)點數(shù)據(jù)包括多個類別的數(shù)據(jù)；

根據(jù)所述節(jié)點數(shù)據(jù)中各個數(shù)據(jù)的類別，分別將所述節(jié)點數(shù)據(jù)中各個數(shù)據(jù)存儲至關(guān)系型數(shù)據(jù)庫中對應(yīng)類別的數(shù)據(jù)表中；

在所述任一流程節(jié)點終止時，分別從各個類別的數(shù)據(jù)表中獲取所述任一流程節(jié)點的節(jié)點數(shù)據(jù)，并將獲取的所述節(jié)點數(shù)據(jù)發(fā)送至消息隊列；

將從所述消息隊列獲取的所述節(jié)點數(shù)據(jù)同步至非關(guān)系型數(shù)據(jù)庫中。

2.如權(quán)利要求1所述的方法，其特征在于，在流程任務(wù)的任一流程節(jié)點觸發(fā)時，調(diào)用所述流程任務(wù)對應(yīng)的任務(wù)收集對象收集所述任一流程節(jié)點的節(jié)點數(shù)據(jù)之前，所述方法還包括：

在流程任務(wù)的起始流程節(jié)點觸發(fā)時，從已創(chuàng)建的任務(wù)收集對象中為所述流程任務(wù)分配對應(yīng)的任務(wù)收集對象；或者，

在流程任務(wù)的起始流程節(jié)點觸發(fā)時，為所述流程任務(wù)創(chuàng)建對應(yīng)的任務(wù)收集對象。

3.如權(quán)利要求1所述的方法，其特征在于，在所述任一流程節(jié)點終止時，分別從各個類別的數(shù)據(jù)表中獲取所述任一流程節(jié)點的節(jié)點數(shù)據(jù)，并將獲取的所述節(jié)點數(shù)據(jù)發(fā)送至消息隊列，包括：

通過后置攔截器根據(jù)攔截配置信息攔截表征所述任一流程節(jié)點終止的處理請求，所述攔截配置信息用于指示所述任一流程節(jié)點終止對應(yīng)的處理請求；

在所述后置攔截器攔截到所述處理請求時，分別從各個類別的數(shù)據(jù)表中獲取所述任一流程節(jié)點的節(jié)點數(shù)據(jù)；

將獲取的所述任一流程節(jié)點的節(jié)點數(shù)據(jù)按照設(shè)定的數(shù)據(jù)結(jié)構(gòu)進行組裝，得到同步數(shù)據(jù)包；

將所述同步數(shù)據(jù)包發(fā)送至所述消息隊列。

4.如權(quán)利要求1所述的方法，其特征在于，在將獲取的所述任一流程節(jié)點的節(jié)點數(shù)據(jù)發(fā)送至消息隊列之后，所述方法還包括：

清空所述任務(wù)收集對象緩存的所述任一流程節(jié)點的節(jié)點數(shù)據(jù)。

5.如權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

調(diào)用監(jiān)聽器監(jiān)聽所述流程任務(wù)的流程節(jié)點；

則在流程任務(wù)的任一流程節(jié)點觸發(fā)時，調(diào)用所述流程任務(wù)對應(yīng)的任務(wù)收集對象收集所述任一流程節(jié)點的節(jié)點數(shù)據(jù)，包括：

在所述監(jiān)聽器監(jiān)聽到所述流程任務(wù)的任一流程節(jié)點觸發(fā)時，調(diào)用所述任務(wù)收集對象收集所述任一流程節(jié)點對應(yīng)的節(jié)點數(shù)據(jù)。

6.如權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

在設(shè)定的時間間隔到達時，調(diào)用全量同步插件根據(jù)設(shè)定的配置信息，從所述關(guān)系型數(shù)據(jù)庫獲取各個類別的數(shù)據(jù)表的所有數(shù)據(jù)；

針對每一流程任務(wù)，分別將所述每一流程任務(wù)各個流程節(jié)點對應(yīng)的節(jié)點數(shù)據(jù)按照設(shè)定的數(shù)據(jù)結(jié)構(gòu)進行組裝，得到各個流程節(jié)點對應(yīng)的同步數(shù)據(jù)包；

將所述每一流程任務(wù)的各個流程節(jié)點對應(yīng)的同步數(shù)據(jù)包同步至所述非關(guān)系型數(shù)據(jù)庫中。

7.一種工作業(yè)務(wù)流的流程數(shù)據(jù)同步裝置，其特征在于，所述裝置包括：

數(shù)據(jù)收集單元，用于在流程任務(wù)的任一流程節(jié)點觸發(fā)時，調(diào)用所述流程任務(wù)對應(yīng)的任務(wù)收集對象收集所述任一流程節(jié)點的節(jié)點數(shù)據(jù)；其中，所述任務(wù)收集對象用于收集至少一個流程任務(wù)執(zhí)行過程中各個流程節(jié)點產(chǎn)生的節(jié)點數(shù)據(jù)，每個流程節(jié)點的節(jié)點數(shù)據(jù)包括多個類別的數(shù)據(jù)；

存儲單元，用于根據(jù)所述節(jié)點數(shù)據(jù)中各個數(shù)據(jù)的類別，分別將所述節(jié)點數(shù)據(jù)中各個數(shù)據(jù)存儲至關(guān)系型數(shù)據(jù)庫中對應(yīng)類別的數(shù)據(jù)表中；

數(shù)據(jù)聚合單元，用于在所述任一流程節(jié)點終止時，分別從各個類別的數(shù)據(jù)表中獲取所述任一流程節(jié)點的節(jié)點數(shù)據(jù)，并將獲取的所述節(jié)點數(shù)據(jù)發(fā)送至消息隊列；

同步單元，用于將從所述消息隊列獲取的所述節(jié)點數(shù)據(jù)同步至非關(guān)系型數(shù)據(jù)庫中。