[發(fā)明專利]基于規(guī)則引擎的分布式應(yīng)用系統(tǒng)交易狀態(tài)一致化方法和系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202111495551.6
• 申請日: 2021-12-08
• 公開（公告）號: CN114140247A
• 公開（公告）日: 2022-03-04
• 發(fā)明（設(shè)計）人: 趙世碩;鄭常熠
• 申請（專利權(quán)）人: 興業(yè)銀行股份有限公司;興業(yè)數(shù)字金融服務(wù)(上海)股份有限公司
• 主分類號: G06Q40/04
• 分類號: G06Q40/04;G06F16/23;G06F16/2458;G06F16/25
• 代理公司: 上海段和段律師事務(wù)所 31334
• 代理人: 祁春倪

本發(fā)明提供了一種基于規(guī)則引擎的分布式應(yīng)用系統(tǒng)交易狀態(tài)一致化方法和系統(tǒng)，包括：差錯管理步驟：根據(jù)預(yù)設(shè)規(guī)則確定交易狀態(tài)，當(dāng)交易狀態(tài)不一致時，通過補償交易調(diào)整為一致；流水處理步驟：通過異步的方式，將交易的信息以預(yù)設(shè)統(tǒng)一的規(guī)則進行登記，并通過流計算的方式將交易信息進行加工，生成統(tǒng)一的中間表，用于流水信息抽取和保存；接口管理步驟：管理實時交易接口和流水映射方式，通過映射形式將不同的流水映射為統(tǒng)一標準和字典。本發(fā)明將變更集中在本系統(tǒng)中，通過映射、異步等方式解耦，減少對于現(xiàn)有業(yè)務(wù)系統(tǒng)的代碼侵入和改造，降低了對于現(xiàn)有業(yè)務(wù)的影響。

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

本發(fā)明涉及數(shù)據(jù)同步技術(shù)領(lǐng)域，具體地，涉及一種基于規(guī)則引擎的分布式應(yīng)用系統(tǒng)交易狀態(tài)一致化方法和系統(tǒng)。

背景技術(shù)

現(xiàn)有平臺中，各個分散的外圍業(yè)務(wù)系統(tǒng)只能獲取到本系統(tǒng)相關(guān)的流水狀態(tài)等信息，當(dāng)出現(xiàn)異常造成交易中斷時，也是按照本系統(tǒng)的情況和對于交易的定義理解進行處理，保證本系統(tǒng)的最終一致。當(dāng)業(yè)務(wù)逐漸發(fā)展，業(yè)務(wù)系統(tǒng)逐漸增加，業(yè)務(wù)流程逐漸復(fù)雜，出現(xiàn)了單個業(yè)務(wù)系統(tǒng)無法僅憑本系統(tǒng)信息進行后續(xù)處理的場景，需要向其他系統(tǒng)獲取額外信息，而且當(dāng)多系統(tǒng)共用賬戶的賬務(wù)出現(xiàn)異常時，很難保證問題流水可以及時發(fā)現(xiàn)和處理。

專利文獻CN109271443A(申請?zhí)枺篊N201810870706.1)公開了一種分布式數(shù)據(jù)一致性處理方法、系統(tǒng)、裝置和存儲介質(zhì)，所述方法包括：在交易執(zhí)行過程中，記錄交易步驟和保存現(xiàn)場數(shù)據(jù)；在交易發(fā)生失敗時，通過所述現(xiàn)場數(shù)據(jù)進行逆向操作，還原交易初始狀態(tài)；通過同步方式和異步方式對所述現(xiàn)場數(shù)據(jù)進行恢復(fù)處理。然而該專利依舊采用現(xiàn)有的技術(shù)思路，各個系統(tǒng)自行處理，必然會導(dǎo)致子系統(tǒng)間耦合度增加，業(yè)務(wù)的新增、變更、擴展和后續(xù)維護難度大幅增加。

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

針對現(xiàn)有技術(shù)中的缺陷，本發(fā)明的目的是提供一種基于規(guī)則引擎的分布式應(yīng)用系統(tǒng)交易狀態(tài)一致化方法和系統(tǒng)。

根據(jù)本發(fā)明提供的基于規(guī)則引擎的分布式應(yīng)用系統(tǒng)交易狀態(tài)一致化方法，包括：

差錯管理步驟：根據(jù)預(yù)設(shè)規(guī)則確定交易狀態(tài)，當(dāng)交易狀態(tài)不一致時，通過補償交易調(diào)整為一致；

流水處理步驟：通過異步的方式，將交易的信息以預(yù)設(shè)統(tǒng)一的規(guī)則進行登記，并通過流計算的方式將交易信息進行加工，生成統(tǒng)一的中間表，用于流水信息抽取和保存；

接口管理步驟：管理實時交易接口和流水映射方式，通過映射形式將不同的流水映射為統(tǒng)一標準和字典。

優(yōu)選的，當(dāng)交易狀態(tài)更新時同步到中間表中，并根據(jù)更新后的交易狀態(tài)處理其他交易；

在分布式應(yīng)用系統(tǒng)使用的開發(fā)框架不同時，進行文件同步。

優(yōu)選的，所述接口管理步驟包括流水狀態(tài)映射配置、流水字段映射配置、補償交易接口配置和流水文件批量同步接口配置；

所述流水狀態(tài)映射配置包括各分布式應(yīng)用系統(tǒng)流水表與中間表的成功、失敗、待決狀態(tài)映射規(guī)則的配置；

所述流水字段映射配置包括各分布式系統(tǒng)流水表對應(yīng)狀態(tài)字段名稱的配置；

所述補償交易接口配置包括各分布式系統(tǒng)正向調(diào)賬、反向調(diào)賬、狀態(tài)查詢的交易及出入?yún)⒌呐渲茫?/p>

所述流水文件批量同步接口配置包括流水表與中間表字段的映射規(guī)則的配置。

優(yōu)選的，還包括對賬管理步驟：根據(jù)預(yù)設(shè)對賬規(guī)則展示各分布式應(yīng)用系統(tǒng)實時流水交易情況，并對比賬戶的出入賬流水。

優(yōu)選的，還包括預(yù)警監(jiān)控步驟：當(dāng)出現(xiàn)無法通過配置自動處理的情況，或者監(jiān)控參數(shù)超過預(yù)設(shè)閾值時，進行報警處理。

根據(jù)本發(fā)明提供的基于規(guī)則引擎的分布式應(yīng)用系統(tǒng)交易狀態(tài)一致化系統(tǒng)，包括：

差錯管理模塊：根據(jù)預(yù)設(shè)規(guī)則確定交易狀態(tài)，當(dāng)交易狀態(tài)不一致時，通過補償交易調(diào)整為一致；