[發明專利]業務數據、資金流水處理方法、裝置、設備和介質

在審

• 申請號: 202111191536.2
• 申請日: 2021-10-13
• 公開（公告）號: CN113918651A
• 公開（公告）日: 2022-01-11
• 發明（設計）人: 李從凡;羅燕忠;劉思琪;郭玉偉;楊智帆;陳展威;劉紅波;劉宇明
• 申請（專利權）人: 廣東利通科技投資有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/2457;G06F16/26;G06Q10/10;G06Q40/00
• 代理公司: 廣州華進聯合專利商標代理有限公司 44224
• 代理人: 萬仁彥

本申請涉及大數據技術領域，提供了一種業務數據、資金流水處理方法、裝置、計算機設備和存儲介質。本申請能夠實現在海量數據、高并發更新場景下高效、準確處理業務數據。該方法包括：接收各業務節點對業務數據進行處理后得到的業務數據處理結果，將業務數據處理結果作為業務處理狀態標識數據寫入分布式數據庫中，根據業務分析需求信息，將相應的目標業務數據進行聚合并存儲至分析數據庫中，該目標業務數據為已在分布式數據庫中完成狀態標識的業務數據，根據數據展示需求信息，從分析數據庫中讀取相應的分析數據進行數據展示。

技術領域

本申請涉及大數據技術領域，特別是涉及一種基于分布式數據庫的業務數據處理、資金流水處理方法、裝置、計算機設備和存儲介質。

背景技術

在財務資金結算系統中，準確、及時掌握資金流水全流程流轉狀態，既可為財務資金稽核工作提供強有力的數據統計支撐，也可進一步加強資金結算風險防控力度。目前，對于采用關系型數據庫作為單一數據存儲方式的財務資金系統，通過一張流水狀態標識表記錄資金流水全流程流轉狀態，以Oracle數據庫為例，其流水狀態標識表在高并發量更新場景下面臨如下問題：

(1)流水狀態標識表是基于明細流水級別的，其精確記錄每一條資金流水在系統的狀態及去向，以此支撐系統記錄資金流水全流程流轉狀態。在海量數據增改的業務場景下，大量施加行級排他性鎖將會升級為表鎖，從而引發大規模的鎖等待或鎖超時，這會嚴重影響正常業務流程；

(2)對于日均億級的數據量，可采用分表分區模式存儲，定期對冷表壓縮，有效降低單表數據量和存儲占用。但是在面對不同時間跨度的流水統計需求時，分表大大增加了統計難度，例如，需要根據記賬時間統計數據，而分表是根據流水上傳時間分表；

(3)為了加快查詢速度，一般需要創建索引，在系統升級時，需要對表增加字段就一定要修改表結構，為了進行這些操作，就需要對表施加排他鎖，則期間數據更新、插入、刪除等操作都是無法進行的。

因此，如何在海量數據、高并發更新場景下高效、準確處理業務數據是本領域技術人員目前需要解決的技術問題。

發明內容

基于此，有必要針對上述技術問題，提供一種基于分布式數據庫的業務數據處理、資金流水處理方法、裝置、計算機設備和存儲介質。

一種基于分布式數據庫的業務數據處理方法，所述方法包括：

接收各業務節點對業務數據進行處理后得到的業務數據處理結果；

將業務數據處理結果作為業務處理狀態標識數據寫入分布式數據庫中；

根據業務分析需求信息，將相應的目標業務數據進行聚合并存儲至分析數據庫中；該目標業務數據為已在分布式數據庫中完成狀態標識的業務數據；

根據數據展示需求信息，從分析數據庫中讀取相應的分析數據進行數據展示。

在其中一個實施例中，將業務數據處理結果作為業務處理狀態標識數據寫入分布式數據庫中，包括：

通過消息隊列接收業務數據處理結果；該消息隊列包括Kafka或RabbitMQ；

從消息隊列中獲取業務數據處理結果作為業務處理狀態標識數據寫入分布式數據庫中。

在其中一個實施例中，對相應的分析數據的數據展示方式包括靜態報表和/或動態熱力圖。

在其中一個實施例中，業務數據包括鐵路售票系統資金流水和/或高速公路通行費結算系統資金流水；分布式數據庫包括Hbase或TiDB；分析數據庫包括關系型數據庫。

一種基于分布式數據庫的資金流水處理方法，所述方法包括：

接收各業務節點對資金流水進行處理后得到的資金流水處理結果；