[發(fā)明專利]一種信用卡賬戶管理數(shù)據(jù)的批處理方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 202011327117.2
• 申請日: 2020-11-24
• 公開（公告）號: CN112307126B
• 公開（公告）日: 2022-09-27
• 發(fā)明（設計）人: 李虎;曾毅峰;魏明麗;周高翔;程雪林;張磊
• 申請（專利權）人: 上海浦東發(fā)展銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F9/54
• 代理公司: 上海科盛知識產(chǎn)權代理有限公司 31225
• 代理人: 丁云

1.一種信用卡賬戶管理數(shù)據(jù)的批處理方法，其特征在于，包括：

S1：獲取批處理數(shù)據(jù)并集中儲存；

S2：將批處理數(shù)據(jù)進行數(shù)據(jù)切片處理，獲取多個數(shù)據(jù)分片；

S3：將數(shù)據(jù)分片送入決策調用節(jié)點，所述的決策調用節(jié)點根據(jù)數(shù)據(jù)分片中的數(shù)據(jù)獲取每個數(shù)據(jù)分片對應的數(shù)據(jù)組裝表；

S4：對數(shù)據(jù)組裝表進行決策處理，獲取決策響應報文；

S5：將決策響應報文送入Rabbit MQ消息隊列；

S6：決策處置節(jié)點從Rabbit MQ消息隊列異步獲取決策響應報文，獲取決策處理結果；

所述的S2具體步驟包括：根據(jù)預設的數(shù)據(jù)分片大小對批處理數(shù)據(jù)進行數(shù)據(jù)切片處理，獲取多個數(shù)據(jù)分片，并為數(shù)據(jù)分片中每個客戶數(shù)據(jù)建立唯一的客戶標識符；

所述的S3的具體步驟包括：

S31：確認當前決策調用節(jié)點隊列中計算任務最少的決策調用節(jié)點，將一個數(shù)據(jù)分片送入該計算任務最少的決策調用節(jié)點，重復步驟S31多次將所有數(shù)據(jù)分片送入決策調用節(jié)點；

S32：決策調用節(jié)點將每個數(shù)據(jù)切片中客戶標識符相同的數(shù)據(jù)組裝為該客戶標識符對應的客戶組裝數(shù)據(jù)，每個數(shù)據(jù)切片中的客戶組裝數(shù)據(jù)組成該數(shù)據(jù)切片的數(shù)據(jù)組裝表。

2.根據(jù)權利要求1所述的一種信用卡賬戶管理數(shù)據(jù)的批處理方法，其特征在于，所述的S32中以Oracle嵌套表方式將客戶標識符相同的數(shù)據(jù)組裝為客戶組裝數(shù)據(jù)。

3.根據(jù)權利要求1所述的一種信用卡賬戶管理數(shù)據(jù)的批處理方法，其特征在于，所述的方法還包括步驟S7：

獲取決策調用節(jié)點中的決策數(shù)量和決策處理節(jié)點的決策處理數(shù)量，若數(shù)量不相同，進行數(shù)據(jù)丟失報錯。

4.一種信用卡賬戶管理數(shù)據(jù)的批處理系統(tǒng)，其特征在于，所述的系統(tǒng)包括數(shù)據(jù)庫模塊、主任務模塊、多個決策調用節(jié)點、決策引擎模塊、Rabbit MQ消息隊列模塊和多個決策處置節(jié)點，

所述的數(shù)據(jù)庫模塊用于獲取并儲存批處理數(shù)據(jù)，

所述的主任務模塊用于將批處理數(shù)據(jù)進行數(shù)據(jù)切片處理，獲取多個數(shù)據(jù)分片，

所述的決策調用節(jié)點用于根據(jù)數(shù)據(jù)分片中的數(shù)據(jù)獲取每個數(shù)據(jù)分片對應的數(shù)據(jù)組裝表，

所述的決策引擎模塊用于對數(shù)據(jù)組裝表進行決策處理，獲取決策響應報文，

所述的Rabbit MQ消息隊列模塊接收決策響應報文，并供決策處置節(jié)點獲取決策響應報文，

所述的決策處置節(jié)點用于從Rabbit MQ消息隊列異步獲取決策響應報文，獲取決策處理結果；

所述的主任務模塊根據(jù)預設的數(shù)據(jù)分片大小對批處理數(shù)據(jù)進行數(shù)據(jù)切片處理，獲取多個數(shù)據(jù)分片，并為數(shù)據(jù)分片中每個客戶數(shù)據(jù)建立唯一的客戶標識符；

所述的決策調用節(jié)點對數(shù)據(jù)分片進行處理前，先確認當前決策調用節(jié)點隊列中計算任務最少的決策調用節(jié)點，將一個數(shù)據(jù)分片送入該計算任務最少的決策調用節(jié)點，然后重復多次將所有數(shù)據(jù)分片送入決策調用節(jié)點，

所述的決策調用節(jié)點對數(shù)據(jù)分片進行處理時，將每個數(shù)據(jù)切片中客戶標識符相同的數(shù)據(jù)組裝為該客戶標識符對應的客戶組裝數(shù)據(jù)，每個數(shù)據(jù)切片中的客戶組裝數(shù)據(jù)組成該數(shù)據(jù)切片的數(shù)據(jù)組裝表。

5.根據(jù)權利要求4所述的一種信用卡賬戶管理數(shù)據(jù)的批處理系統(tǒng)，其特征在于，所述的決策調用節(jié)點以Oracle嵌套表方式將客戶標識符相同的數(shù)據(jù)組裝為客戶組裝數(shù)據(jù)。

6.根據(jù)權利要求4所述的一種信用卡賬戶管理數(shù)據(jù)的批處理系統(tǒng)，其特征在于，所述的系統(tǒng)還包括計數(shù)報警模塊，所述的計數(shù)報警模塊獲取決策調用節(jié)點中的決策數(shù)量和決策處理節(jié)點的決策處理數(shù)量，若數(shù)量不相同，進行數(shù)據(jù)丟失報錯。