[發(fā)明專利]業(yè)務(wù)數(shù)據(jù)、資金流水處理方法、裝置、設(shè)備和介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202111191536.2
• 申請(qǐng)日: 2021-10-13
• 公開（公告）號(hào): CN113918651A
• 公開（公告）日: 2022-01-11
• 發(fā)明（設(shè)計(jì)）人: 李從凡;羅燕忠;劉思琪;郭玉偉;楊智帆;陳展威;劉紅波;劉宇明
• 申請(qǐng)（專利權(quán)）人: 廣東利通科技投資有限公司
• 主分類號(hào): G06F16/27
• 分類號(hào): G06F16/27;G06F16/2457;G06F16/26;G06Q10/10;G06Q40/00
• 代理公司: 廣州華進(jìn)聯(lián)合專利商標(biāo)代理有限公司 44224
• 代理人: 萬仁彥

1.一種基于分布式數(shù)據(jù)庫的業(yè)務(wù)數(shù)據(jù)處理方法，其特征在于，所述方法包括：

接收各業(yè)務(wù)節(jié)點(diǎn)對(duì)業(yè)務(wù)數(shù)據(jù)進(jìn)行處理后得到的業(yè)務(wù)數(shù)據(jù)處理結(jié)果；

將所述業(yè)務(wù)數(shù)據(jù)處理結(jié)果作為業(yè)務(wù)處理狀態(tài)標(biāo)識(shí)數(shù)據(jù)寫入分布式數(shù)據(jù)庫中；

根據(jù)業(yè)務(wù)分析需求信息，將相應(yīng)的目標(biāo)業(yè)務(wù)數(shù)據(jù)進(jìn)行聚合并存儲(chǔ)至分析數(shù)據(jù)庫中；所述目標(biāo)業(yè)務(wù)數(shù)據(jù)為已在所述分布式數(shù)據(jù)庫中完成狀態(tài)標(biāo)識(shí)的業(yè)務(wù)數(shù)據(jù)；

根據(jù)數(shù)據(jù)展示需求信息，從所述分析數(shù)據(jù)庫中讀取相應(yīng)的分析數(shù)據(jù)進(jìn)行數(shù)據(jù)展示。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將所述業(yè)務(wù)數(shù)據(jù)處理結(jié)果作為業(yè)務(wù)處理狀態(tài)標(biāo)識(shí)數(shù)據(jù)寫入分布式數(shù)據(jù)庫中，包括：

通過消息隊(duì)列接收所述業(yè)務(wù)數(shù)據(jù)處理結(jié)果；所述消息隊(duì)列包括Kafka或RabbitMQ；

從所述消息隊(duì)列中獲取所述業(yè)務(wù)數(shù)據(jù)處理結(jié)果作為業(yè)務(wù)處理狀態(tài)標(biāo)識(shí)數(shù)據(jù)寫入分布式數(shù)據(jù)庫中。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，對(duì)所述相應(yīng)的分析數(shù)據(jù)的數(shù)據(jù)展示方式包括靜態(tài)報(bào)表和/或動(dòng)態(tài)熱力圖。

4.根據(jù)權(quán)利要求1至3任一項(xiàng)所述的方法，其特征在于，所述業(yè)務(wù)數(shù)據(jù)包括鐵路售票系統(tǒng)資金流水和/或高速公路通行費(fèi)結(jié)算系統(tǒng)資金流水；所述分布式數(shù)據(jù)庫包括Hbase或TiDB；所述分析數(shù)據(jù)庫包括關(guān)系型數(shù)據(jù)庫。

5.一種基于分布式數(shù)據(jù)庫的資金流水處理方法，其特征在于，所述方法包括：

接收各業(yè)務(wù)節(jié)點(diǎn)對(duì)資金流水進(jìn)行處理后得到的資金流水處理結(jié)果；

將所述資金流水處理結(jié)果作為資金流水狀態(tài)標(biāo)識(shí)數(shù)據(jù)寫入分布式數(shù)據(jù)庫中；

根據(jù)業(yè)務(wù)分析需求信息，將相應(yīng)的目標(biāo)資金流水進(jìn)行聚合并存儲(chǔ)至分析數(shù)據(jù)庫中；所述目標(biāo)資金流水為已在所述分布式數(shù)據(jù)庫中完成狀態(tài)標(biāo)識(shí)的資金流水；

根據(jù)數(shù)據(jù)展示需求信息，從所述分析數(shù)據(jù)庫中讀取相應(yīng)的分析數(shù)據(jù)進(jìn)行數(shù)據(jù)展示。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，

所述將所述資金流水處理結(jié)果作為資金流水狀態(tài)標(biāo)識(shí)數(shù)據(jù)寫入分布式數(shù)據(jù)庫中，包括：

通過Kafka或RabbitMQ接收所述資金流水處理結(jié)果；

從所述Kafka或RabbitMQ中獲取所述資金流水處理結(jié)果作為資金流水狀態(tài)標(biāo)識(shí)數(shù)據(jù)寫入分布式數(shù)據(jù)庫中；

所述從所述分析數(shù)據(jù)庫中讀取相應(yīng)的分析數(shù)據(jù)進(jìn)行數(shù)據(jù)展示，包括：

以靜態(tài)報(bào)表和/或動(dòng)態(tài)熱力圖的展示方式展示從關(guān)系型數(shù)據(jù)庫中讀取的所述相應(yīng)的分析數(shù)據(jù)。

7.一種基于分布式數(shù)據(jù)庫的業(yè)務(wù)數(shù)據(jù)處理裝置，其特征在于，所述裝置包括：

數(shù)據(jù)接收模塊，用于接收各業(yè)務(wù)節(jié)點(diǎn)對(duì)資金流水進(jìn)行處理后得到的資金流水處理結(jié)果；

數(shù)據(jù)寫入模塊，用于將所述資金流水處理結(jié)果作為資金流水狀態(tài)標(biāo)識(shí)數(shù)據(jù)寫入分布式數(shù)據(jù)庫中；

數(shù)據(jù)聚合模塊，用于根據(jù)業(yè)務(wù)分析需求信息，將相應(yīng)的目標(biāo)資金流水進(jìn)行聚合并存儲(chǔ)至分析數(shù)據(jù)庫中；所述目標(biāo)資金流水為已在所述分布式數(shù)據(jù)庫中完成狀態(tài)標(biāo)識(shí)的資金流水；

數(shù)據(jù)展示模塊，用于根據(jù)數(shù)據(jù)展示需求信息，從所述分析數(shù)據(jù)庫中讀取相應(yīng)的分析數(shù)據(jù)進(jìn)行數(shù)據(jù)展示。

8.一種基于分布式數(shù)據(jù)庫的資金流水處理裝置，其特征在于，所述裝置包括：

流水接收模塊，用于接收各業(yè)務(wù)節(jié)點(diǎn)對(duì)資金流水進(jìn)行處理后得到的資金流水處理結(jié)果；

流水寫入模塊，用于將所述資金流水處理結(jié)果作為資金流水狀態(tài)標(biāo)識(shí)數(shù)據(jù)寫入分布式數(shù)據(jù)庫中；

流水聚合模塊，用于根據(jù)業(yè)務(wù)分析需求信息，將相應(yīng)的目標(biāo)資金流水進(jìn)行聚合并存儲(chǔ)至分析數(shù)據(jù)庫中；所述目標(biāo)資金流水為已在所述分布式數(shù)據(jù)庫中完成狀態(tài)標(biāo)識(shí)的資金流水；

流水展示模塊，用于根據(jù)數(shù)據(jù)展示需求信息，從所述分析數(shù)據(jù)庫中讀取相應(yīng)的分析數(shù)據(jù)進(jìn)行數(shù)據(jù)展示。

9.一種計(jì)算機(jī)設(shè)備，包括存儲(chǔ)器和處理器，所述存儲(chǔ)器存儲(chǔ)有計(jì)算機(jī)程序，其特征在于，所述處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)權(quán)利要求1至6中任一項(xiàng)所述的方法的步驟。

10.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，其特征在于，所述計(jì)算機(jī)程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)權(quán)利要求1至6中任一項(xiàng)所述的方法的步驟。