[發(fā)明專利]一種基于工作流平臺(tái)的數(shù)據(jù)同步方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202010688434.0
• 申請(qǐng)日: 2020-07-16
• 公開(kāi)（公告）號(hào): CN111930836A
• 公開(kāi)（公告）日: 2020-11-13
• 發(fā)明（設(shè)計(jì)）人: 敬巖;楊明;葉乃寶;谷冠飛
• 申請(qǐng)（專利權(quán)）人: 北京首汽智行科技有限公司
• 主分類號(hào): G06F16/27
• 分類號(hào): G06F16/27;G06F16/2455
• 代理公司: 北京世譽(yù)鑫誠(chéng)專利代理有限公司 11368
• 代理人: 李世端

本發(fā)明公開(kāi)的基于工作流平臺(tái)的數(shù)據(jù)同步方法，涉及數(shù)據(jù)存儲(chǔ)技術(shù)領(lǐng)域，利用工作流平臺(tái)的標(biāo)準(zhǔn)接口，處理各個(gè)業(yè)務(wù)系統(tǒng)發(fā)起的任務(wù)，當(dāng)任務(wù)的各個(gè)業(yè)務(wù)流程產(chǎn)生數(shù)據(jù)變更時(shí)，向各個(gè)業(yè)務(wù)系統(tǒng)發(fā)送基于消息隊(duì)列的異步消息，各個(gè)業(yè)務(wù)系統(tǒng)監(jiān)聽(tīng)異步消息，獲取工作流數(shù)據(jù)，各個(gè)業(yè)務(wù)系統(tǒng)利用自身的數(shù)據(jù)存儲(chǔ)接口，將工作流數(shù)據(jù)同步到自身的數(shù)據(jù)庫(kù)中，減少了業(yè)務(wù)系統(tǒng)查詢工作流平臺(tái)的次數(shù)，降低了工作流平臺(tái)數(shù)據(jù)庫(kù)的壓力，解決了由于歷史數(shù)據(jù)堆積導(dǎo)致的大表查詢慢的問(wèn)題。

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

本發(fā)明涉及數(shù)據(jù)存儲(chǔ)技術(shù)領(lǐng)域，具體涉及一種基于工作流平臺(tái)的數(shù)據(jù)同步方法。

背景技術(shù)

工作流平臺(tái)是一個(gè)公司必不可少的流程規(guī)范、實(shí)施工具，以前的工作流平臺(tái)的使用場(chǎng)景僅局限于公司的辦公自動(dòng)化審批，由于場(chǎng)景限制，所以通常不會(huì)存在因?yàn)閿?shù)據(jù)量太大引起的查詢、使用太慢的問(wèn)題，但是，現(xiàn)在的互聯(lián)網(wǎng)公司除了辦公自動(dòng)化審批外，工作流平臺(tái)更多的使用場(chǎng)景是業(yè)務(wù)工單，例如：客服投訴工單、用戶退款工單、訂單投訴工單等，這些不同種類的工單，每個(gè)都有一套標(biāo)準(zhǔn)的處理流程，非常適合接入工作流平臺(tái)辦理，而每個(gè)公司的工作流平臺(tái)一般也僅有一套，那么，眾多業(yè)務(wù)系統(tǒng)接入工作流平臺(tái)后，就會(huì)產(chǎn)生三個(gè)問(wèn)題：

(1)無(wú)關(guān)的業(yè)務(wù)系統(tǒng)之間共用工作流平臺(tái)數(shù)據(jù)庫(kù)，導(dǎo)致流程辦理的歷史數(shù)據(jù)太多，影響查詢和使用性能；

(2)業(yè)務(wù)系統(tǒng)篩選數(shù)據(jù)，一部分條件在業(yè)務(wù)系統(tǒng)，一部分條件在工作流平臺(tái)，按條件篩選數(shù)據(jù)、分頁(yè)麻煩；

(3)個(gè)別業(yè)務(wù)系統(tǒng)并發(fā)高時(shí)，工作流平臺(tái)數(shù)據(jù)庫(kù)壓力會(huì)隨之增大，由于共用工作流平臺(tái)，可能會(huì)導(dǎo)致少數(shù)業(yè)務(wù)影響全部業(yè)務(wù)。

目前主流的方案有兩種：一種是按業(yè)務(wù)分表，一種是按時(shí)間結(jié)轉(zhuǎn)。按業(yè)務(wù)分表，即每次接入一個(gè)業(yè)務(wù)線，就對(duì)應(yīng)生成、維護(hù)一套完整的工作流表結(jié)構(gòu)，類似沙盒的思想，每次對(duì)接業(yè)務(wù)線，都要做適配開(kāi)發(fā)，數(shù)據(jù)庫(kù)壓力沒(méi)解決，業(yè)務(wù)系統(tǒng)篩選數(shù)據(jù)依舊麻煩。按照時(shí)間結(jié)轉(zhuǎn)，即定期結(jié)轉(zhuǎn)工作流平臺(tái)的歷史數(shù)據(jù)，按時(shí)間段分表，不同時(shí)間段的數(shù)據(jù)查詢，走不同的表，條件跨時(shí)間段時(shí)，處理麻煩，數(shù)據(jù)庫(kù)壓力沒(méi)解決，業(yè)務(wù)系統(tǒng)篩選數(shù)據(jù)依舊麻煩。

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

為解決現(xiàn)有技術(shù)的不足，本發(fā)明實(shí)施例提供了一種基于工作流平臺(tái)的數(shù)據(jù)同步方法，該方法包括以下步驟：

利用工作流平臺(tái)的標(biāo)準(zhǔn)接口，處理各個(gè)業(yè)務(wù)系統(tǒng)發(fā)起的任務(wù)；

當(dāng)所述任務(wù)的各個(gè)業(yè)務(wù)流程產(chǎn)生數(shù)據(jù)變更時(shí)，向各個(gè)業(yè)務(wù)系統(tǒng)發(fā)送基于消息隊(duì)列的異步消息；

各個(gè)業(yè)務(wù)系統(tǒng)監(jiān)聽(tīng)所述異步消息，獲取工作流數(shù)據(jù)；

各個(gè)業(yè)務(wù)系統(tǒng)利用自身的數(shù)據(jù)存儲(chǔ)接口，將所述工作流數(shù)據(jù)同步到自身的數(shù)據(jù)庫(kù)中。

優(yōu)選地，各個(gè)業(yè)務(wù)系統(tǒng)監(jiān)聽(tīng)所述異步消息包括：

獲取所述異步消息的標(biāo)簽并將所述標(biāo)簽設(shè)置為自身任務(wù)的標(biāo)識(shí)，這樣設(shè)計(jì)的優(yōu)點(diǎn)在于：不同的業(yè)務(wù)系統(tǒng)，只需將異步消息的標(biāo)簽設(shè)置為自身業(yè)務(wù)流程的標(biāo)識(shí)即可實(shí)現(xiàn)只監(jiān)聽(tīng)自身流程數(shù)據(jù)的功能，避免了監(jiān)聽(tīng)到其他業(yè)務(wù)系統(tǒng)的數(shù)據(jù)，導(dǎo)致產(chǎn)生大表和臟數(shù)據(jù)的問(wèn)題。

優(yōu)選地，各個(gè)業(yè)務(wù)系統(tǒng)監(jiān)聽(tīng)所述異步消息還包括：

當(dāng)所述異步消息包含多個(gè)任務(wù)時(shí)，分別獲取所述異步消息的各個(gè)標(biāo)簽并分別將所述各個(gè)標(biāo)簽設(shè)置為自身各個(gè)任務(wù)的標(biāo)識(shí)，各個(gè)標(biāo)識(shí)之間用雙豎線隔開(kāi)。

優(yōu)選地，各個(gè)業(yè)務(wù)系統(tǒng)均內(nèi)置SDK工具包，所述SDK工具包用于監(jiān)聽(tīng)異步消息，具有消息隊(duì)列消費(fèi)者、數(shù)據(jù)庫(kù)表結(jié)構(gòu)及三個(gè)接口，其中，三個(gè)接口為數(shù)據(jù)查詢接口、數(shù)據(jù)保存接口及數(shù)據(jù)更新接口。

優(yōu)選地，所述異步消息的主題固定。

本發(fā)明實(shí)施例提供的基于工作流平臺(tái)的數(shù)據(jù)同步方法具有以下有益效果：