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

在審

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

本申請(qǐng)?zhí)峁┮环N工作業(yè)務(wù)流的流程數(shù)據(jù)同步方法、裝置及設(shè)備，應(yīng)用于業(yè)務(wù)流程建模符號(hào)(BPMN)工作流框架中，涉及計(jì)算機(jī)技術(shù)領(lǐng)域，用于解決流程數(shù)據(jù)查詢時(shí)產(chǎn)生的響應(yīng)延時(shí)高的問題。該方法包括：在流程任務(wù)的任一流程節(jié)點(diǎn)觸發(fā)時(shí)，調(diào)用流程任務(wù)對(duì)應(yīng)的任務(wù)收集對(duì)象收集任一流程節(jié)點(diǎn)的節(jié)點(diǎn)數(shù)據(jù)；根據(jù)節(jié)點(diǎn)數(shù)據(jù)中各個(gè)數(shù)據(jù)的類別，分別將節(jié)點(diǎn)數(shù)據(jù)中各個(gè)數(shù)據(jù)存儲(chǔ)至關(guān)系型數(shù)據(jù)庫(kù)中對(duì)應(yīng)類別的數(shù)據(jù)表中；在任一流程節(jié)點(diǎn)終止時(shí)，分別從各個(gè)類別的數(shù)據(jù)表中獲取任一流程節(jié)點(diǎn)的節(jié)點(diǎn)數(shù)據(jù)，并將獲取的節(jié)點(diǎn)數(shù)據(jù)發(fā)送至消息隊(duì)列；將從消息隊(duì)列獲取的節(jié)點(diǎn)數(shù)據(jù)同步至非關(guān)系型數(shù)據(jù)庫(kù)中。

技術(shù)領(lǐng)域

本申請(qǐng)涉及計(jì)算機(jī)技術(shù)領(lǐng)域，提供一種工作業(yè)務(wù)流的流程數(shù)據(jù)同步方法、裝置及設(shè)備。

背景技術(shù)

隨著各個(gè)企業(yè)的不斷發(fā)展，企業(yè)的各種事務(wù)對(duì)應(yīng)的流程審批所產(chǎn)生的流程數(shù)據(jù)也不斷增多，使得進(jìn)行流程審批的系統(tǒng)的性能不斷下降，進(jìn)而產(chǎn)生啟動(dòng)業(yè)務(wù)流程卡頓以及流程數(shù)據(jù)查詢速度變慢等問題，導(dǎo)致用戶對(duì)流程審批系統(tǒng)的體驗(yàn)感越來越差。一般而言，在業(yè)務(wù)流程建模符號(hào)(Business Process Modeling Notation，BPMN)工作流框架中，流程數(shù)據(jù)會(huì)按照其類型分別存儲(chǔ)至結(jié)構(gòu)化查詢語言(My Structured Query Language，MySQL)數(shù)據(jù)庫(kù)的多個(gè)數(shù)據(jù)表中，所以，在進(jìn)行流程數(shù)據(jù)查詢時(shí)，需要多次查表操作且需要對(duì)查表獲取的數(shù)據(jù)進(jìn)行連接，響應(yīng)延時(shí)高。

因此，如何提升流程數(shù)據(jù)查詢的響應(yīng)速度是一個(gè)亟待解決的問題。

發(fā)明內(nèi)容

本申請(qǐng)實(shí)施例提供一種工作業(yè)務(wù)流的流程業(yè)務(wù)數(shù)據(jù)同步方法、裝置及設(shè)備，用于解決流程數(shù)據(jù)查詢時(shí)產(chǎn)生的響應(yīng)延時(shí)高的問題。

一方面，提供一種工作業(yè)務(wù)流的流程數(shù)據(jù)同步方法，所述方法包括：

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

根據(jù)所述流程節(jié)點(diǎn)的節(jié)點(diǎn)數(shù)據(jù)中各個(gè)數(shù)據(jù)的類別，分別將所述節(jié)點(diǎn)數(shù)據(jù)中各個(gè)數(shù)據(jù)存儲(chǔ)至關(guān)系型數(shù)據(jù)庫(kù)中對(duì)應(yīng)類別的數(shù)據(jù)表中；

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

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

一方面，提供一種工作業(yè)務(wù)流的流程數(shù)據(jù)同步裝置，所述裝置包括：

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

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

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

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

可選的，所述數(shù)據(jù)收集單元還用于：

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

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

可選的，所述數(shù)據(jù)聚合單元，還用于：