[發(fā)明專利]銀行數(shù)據(jù)處理的方法、裝置、電子設(shè)備和存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110342157.2
• 申請日: 2021-03-30
• 公開（公告）號: CN112905645A
• 公開（公告）日: 2021-06-04
• 發(fā)明（設(shè)計）人: 孫兵兵;王超;汪維;張小彪;李冉冉
• 申請（專利權(quán)）人: 中國建設(shè)銀行股份有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2458;G06Q40/02
• 代理公司: 中原信達(dá)知識產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 張春曉;張效榮

本發(fā)明公開了銀行數(shù)據(jù)處理的方法、裝置、電子設(shè)備和存儲介質(zhì)，涉及大數(shù)據(jù)技術(shù)領(lǐng)域。該方法的一具體實(shí)施方式包括：調(diào)用流計算處理引擎，接收采集的業(yè)務(wù)數(shù)據(jù)流；獲取業(yè)務(wù)數(shù)據(jù)中的類型參數(shù)，以判斷業(yè)務(wù)數(shù)據(jù)所屬類型是否為目標(biāo)類型；若是，則獲取業(yè)務(wù)數(shù)據(jù)中預(yù)設(shè)的關(guān)聯(lián)字段，將關(guān)聯(lián)字段相同的業(yè)務(wù)數(shù)據(jù)合并，生成關(guān)聯(lián)字段與合并后業(yè)務(wù)數(shù)據(jù)的對應(yīng)關(guān)系以更新至字段表中；若否，則獲取業(yè)務(wù)數(shù)據(jù)中預(yù)設(shè)的關(guān)鍵字段，調(diào)用字段表查詢與關(guān)鍵字段對應(yīng)的合并后業(yè)務(wù)數(shù)據(jù)，將業(yè)務(wù)數(shù)據(jù)與查詢的合并后業(yè)務(wù)數(shù)據(jù)拼接，生成站點(diǎn)數(shù)據(jù)。該實(shí)施方式能夠解決按批次處理業(yè)務(wù)數(shù)據(jù)，先接收到的業(yè)務(wù)數(shù)據(jù)無法及時處理，降低了業(yè)務(wù)數(shù)據(jù)處理的時效的問題。

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

本發(fā)明涉及大數(shù)據(jù)技術(shù)領(lǐng)域，尤其涉及一種銀行數(shù)據(jù)處理的方法、裝置、電子設(shè)備和存儲介質(zhì)。

背景技術(shù)

隨著銀行業(yè)務(wù)多樣化以及移動互聯(lián)網(wǎng)的發(fā)展，大量銀行業(yè)務(wù)可以通過移動終端辦理，隨之而來的是銀行業(yè)務(wù)數(shù)據(jù)的爆炸式增長，所以如何處理海量的業(yè)務(wù)數(shù)據(jù)成為一個重要問題。現(xiàn)有銀行業(yè)務(wù)數(shù)據(jù)通常采用按批次處理的方式，即先將業(yè)務(wù)數(shù)據(jù)按一些維度切分為多個批次，然后在同一批次的業(yè)務(wù)數(shù)據(jù)均接收完成后，對該批次的業(yè)務(wù)數(shù)據(jù)進(jìn)行處理。但是由于同一批次的業(yè)務(wù)數(shù)據(jù)并不會同時接收到，如此同一批次業(yè)務(wù)數(shù)據(jù)中先接收到的業(yè)務(wù)數(shù)據(jù)無法及時處理，從而降低了業(yè)務(wù)數(shù)據(jù)處理的時效。

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

有鑒于此，本發(fā)明實(shí)施例提供一種銀行數(shù)據(jù)處理的方法、裝置、電子設(shè)備和存儲介質(zhì)，能夠解決按批次處理業(yè)務(wù)數(shù)據(jù)，先接收到的業(yè)務(wù)數(shù)據(jù)無法及時處理，降低了業(yè)務(wù)數(shù)據(jù)處理的時效的問題。

為實(shí)現(xiàn)上述目的，根據(jù)本發(fā)明實(shí)施例的一個方面，提供了一種銀行數(shù)據(jù)處理的方法。

本發(fā)明實(shí)施例的一種銀行數(shù)據(jù)處理的方法包括：調(diào)用流計算處理引擎，接收采集的業(yè)務(wù)數(shù)據(jù)流；獲取業(yè)務(wù)數(shù)據(jù)中的類型參數(shù)，以判斷所述業(yè)務(wù)數(shù)據(jù)所屬類型是否為目標(biāo)類型；若是，則獲取所述業(yè)務(wù)數(shù)據(jù)中預(yù)設(shè)的關(guān)聯(lián)字段，將所述關(guān)聯(lián)字段相同的業(yè)務(wù)數(shù)據(jù)合并，生成關(guān)聯(lián)字段與合并后業(yè)務(wù)數(shù)據(jù)的對應(yīng)關(guān)系以更新至字段表中；若否，則獲取所述業(yè)務(wù)數(shù)據(jù)中預(yù)設(shè)的關(guān)鍵字段，調(diào)用所述字段表查詢與所述關(guān)鍵字段對應(yīng)的合并后業(yè)務(wù)數(shù)據(jù)，將所述業(yè)務(wù)數(shù)據(jù)與查詢的合并后業(yè)務(wù)數(shù)據(jù)拼接，生成站點(diǎn)數(shù)據(jù)。

在一個實(shí)施例中，在所述將所述業(yè)務(wù)數(shù)據(jù)與查詢的合并后業(yè)務(wù)數(shù)據(jù)拼接得出站點(diǎn)數(shù)據(jù)之后，還包括：

獲取各站點(diǎn)數(shù)據(jù)的業(yè)務(wù)標(biāo)識，將所述業(yè)務(wù)標(biāo)識相同的站點(diǎn)數(shù)據(jù)關(guān)聯(lián)，生成與所述業(yè)務(wù)標(biāo)識對應(yīng)的業(yè)務(wù)流程數(shù)據(jù)。

在又一個實(shí)施例中，所述將所述業(yè)務(wù)標(biāo)識相同的站點(diǎn)數(shù)據(jù)關(guān)聯(lián)，得出與所述業(yè)務(wù)標(biāo)識對應(yīng)的業(yè)務(wù)流程數(shù)據(jù)，包括：

對所述業(yè)務(wù)標(biāo)識相同的站點(diǎn)數(shù)據(jù)，獲取對應(yīng)的執(zhí)行時間信息；

根據(jù)所述執(zhí)行時間信息確定所述業(yè)務(wù)標(biāo)識相同的站點(diǎn)數(shù)據(jù)所對應(yīng)的執(zhí)行順序，基于所述執(zhí)行順序依次串聯(lián)業(yè)務(wù)標(biāo)識相同的站點(diǎn)數(shù)據(jù)，得出與所述業(yè)務(wù)標(biāo)識對應(yīng)的業(yè)務(wù)流程數(shù)據(jù)。

在又一個實(shí)施例中，所述獲取各站點(diǎn)數(shù)據(jù)的業(yè)務(wù)標(biāo)識，包括：

對各站點(diǎn)數(shù)據(jù)，判斷所述各站點(diǎn)數(shù)據(jù)包括的業(yè)務(wù)數(shù)據(jù)中是否存在業(yè)務(wù)標(biāo)識字段；若是，則將所述業(yè)務(wù)標(biāo)識字段對應(yīng)的字段值確定為所述各站點(diǎn)數(shù)據(jù)的業(yè)務(wù)標(biāo)識；若否，則查詢各所述站點(diǎn)數(shù)據(jù)對應(yīng)的交易數(shù)據(jù)，從所述交易數(shù)據(jù)中獲取所述各站點(diǎn)數(shù)據(jù)的業(yè)務(wù)標(biāo)識。

在又一個實(shí)施例中，所述獲取所述業(yè)務(wù)數(shù)據(jù)中預(yù)設(shè)的關(guān)聯(lián)字段，將所述關(guān)聯(lián)字段相同的業(yè)務(wù)數(shù)據(jù)合并，包括：

對時間窗口內(nèi)的每個業(yè)務(wù)數(shù)據(jù)，獲取預(yù)設(shè)的關(guān)聯(lián)字段，判斷是否存在所述關(guān)聯(lián)字段相同的業(yè)務(wù)數(shù)據(jù)；

若是，則將所述關(guān)聯(lián)字段相同的業(yè)務(wù)數(shù)據(jù)合并；

若否，則存儲所述業(yè)務(wù)數(shù)據(jù)，將所述時間窗口向后滑動預(yù)設(shè)時長，以對滑動后的時間窗口中每個業(yè)務(wù)數(shù)據(jù)和存儲的業(yè)務(wù)數(shù)據(jù)，獲取預(yù)設(shè)的關(guān)聯(lián)字段，以判斷是否存在關(guān)聯(lián)字段相同的業(yè)務(wù)數(shù)據(jù)，其中，所述預(yù)設(shè)時長小于所述時間窗口的時長。