[發(fā)明專(zhuān)利]交易積分的更新方法及其裝置、電子設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202211513970.2
• 申請(qǐng)日: 2022-11-29
• 公開(kāi)（公告）號(hào): CN115809896A
• 公開(kāi)（公告）日: 2023-03-17
• 發(fā)明（設(shè)計(jì)）人: 雷濤;毛培芳;薛煜峰;廖杰
• 申請(qǐng)（專(zhuān)利權(quán)）人: 中國(guó)工商銀行股份有限公司
• 主分類(lèi)號(hào): G06Q30/0208
• 分類(lèi)號(hào): G06Q30/0208;G06F16/23;G06Q40/04
• 代理公司: 北京康信知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11240
• 代理人: 黃海英

本發(fā)明公開(kāi)了一種交易積分的更新方法及其裝置、電子設(shè)備及存儲(chǔ)介質(zhì)，涉及大數(shù)據(jù)領(lǐng)域，其中，該更新方法包括：獲取目標(biāo)用戶(hù)的交易數(shù)據(jù)，將交易數(shù)據(jù)轉(zhuǎn)化為多個(gè)交易元組，基于機(jī)構(gòu)標(biāo)識(shí)以及交易類(lèi)型，確定與交易元組對(duì)應(yīng)的目標(biāo)交易規(guī)則，基于交易元組和目標(biāo)交易規(guī)則，更新目標(biāo)用戶(hù)的交易積分。本發(fā)明解決了相關(guān)技術(shù)中無(wú)法實(shí)時(shí)更新用戶(hù)交易積分的技術(shù)問(wèn)題。

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

本發(fā)明涉及大數(shù)據(jù)領(lǐng)域，具體而言，涉及一種交易積分的更新方法及其裝置、電子設(shè)備及存儲(chǔ)介質(zhì)。

背景技術(shù)

隨著大數(shù)據(jù)技術(shù)的蓬勃發(fā)展，各行各業(yè)都開(kāi)始應(yīng)用大數(shù)據(jù)技術(shù)到生產(chǎn)運(yùn)行中，特別是在金融、電商等行業(yè)的用戶(hù)增值服務(wù)中，例如，用戶(hù)綜合積分領(lǐng)域，但是該領(lǐng)域?qū)Υ髷?shù)據(jù)技術(shù)的運(yùn)用還不夠充分，大部分情況下，用戶(hù)購(gòu)物、刷卡消費(fèi)時(shí)贈(zèng)送給用戶(hù)的綜合積分或者用戶(hù)使用綜合積分時(shí)，積分的更新處于延時(shí)狀態(tài)，有的甚至是隔天才能更新，這種情況下用戶(hù)不能及時(shí)感受到的積分帶來(lái)的好處，用戶(hù)體驗(yàn)非常不佳，同時(shí)，也不能在當(dāng)下的第二筆交易或者訂單中立馬使用上一筆消費(fèi)或者交易獲得的積分獎(jiǎng)勵(lì)，從而使得用戶(hù)綜合積分在整個(gè)的業(yè)務(wù)流程中不能發(fā)揮應(yīng)有的價(jià)值。

相關(guān)技術(shù)中，積分的更新方式有以下兩種：(1)用戶(hù)交易的明細(xì)統(tǒng)一保存在交易系統(tǒng)的數(shù)據(jù)庫(kù)中，待日終匯總明細(xì)數(shù)據(jù)文件給用戶(hù)積分平臺(tái)，用戶(hù)積分平臺(tái)基于明細(xì)和積分采集規(guī)則模型計(jì)算用戶(hù)積分，并在當(dāng)天之后更新用戶(hù)積分，用戶(hù)積分最快也要在第二天發(fā)生變化；(2)通過(guò)使用大數(shù)據(jù)Hadoop架構(gòu)的MapReduce模型或者SparkStreaming框架，雖然不用等到第二天，但是MapReduce模型存在高延時(shí)低吞吐問(wèn)題，SparkStreaming框架需要等到事件積累到一定批量時(shí)才能進(jìn)行處理，都存在延時(shí)不能做到實(shí)時(shí)處理。

針對(duì)上述的問(wèn)題，目前尚未提出有效的解決方案。

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

本發(fā)明實(shí)施例提供了一種交易積分的更新方法及其裝置、電子設(shè)備及存儲(chǔ)介質(zhì)，以至少解決相關(guān)技術(shù)中無(wú)法實(shí)時(shí)更新用戶(hù)交易積分的技術(shù)問(wèn)題。

根據(jù)本發(fā)明實(shí)施例的一個(gè)方面，提供了一種交易積分的更新方法，包括：獲取目標(biāo)用戶(hù)的交易數(shù)據(jù)；將所述交易數(shù)據(jù)轉(zhuǎn)化為多個(gè)交易元組，其中，每個(gè)所述交易元組至少包括：機(jī)構(gòu)標(biāo)識(shí)、交易類(lèi)型；基于所述機(jī)構(gòu)標(biāo)識(shí)以及所述交易類(lèi)型，確定與所述交易元組對(duì)應(yīng)的目標(biāo)交易規(guī)則；基于所述交易元組和所述目標(biāo)交易規(guī)則，更新所述目標(biāo)用戶(hù)的交易積分。

可選地，將所述交易數(shù)據(jù)轉(zhuǎn)化為多個(gè)交易元組的步驟，包括：確定所述交易數(shù)據(jù)中的機(jī)構(gòu)標(biāo)識(shí)；將所述交易數(shù)據(jù)轉(zhuǎn)化為與所述機(jī)構(gòu)標(biāo)識(shí)關(guān)聯(lián)的多個(gè)所述交易元組，其中，所述交易元組還包括：用戶(hù)標(biāo)識(shí)、交易金額、交易渠道、交易時(shí)間。

可選地，在將所述交易數(shù)據(jù)轉(zhuǎn)化為多個(gè)交易元組之后，還包括：創(chuàng)建處理節(jié)點(diǎn)集群，其中，所述處理節(jié)點(diǎn)集群包括：第一處理節(jié)點(diǎn)、第二處理節(jié)點(diǎn)、第三處理節(jié)點(diǎn)；將所述多個(gè)交易元組發(fā)送至處理節(jié)點(diǎn)集群；對(duì)所述處理節(jié)點(diǎn)集群中的每個(gè)處理節(jié)點(diǎn)進(jìn)行序列化處理，得到每個(gè)所述處理節(jié)點(diǎn)的處理拓?fù)洌渲校總€(gè)所述處理拓?fù)浒ǎ憾鄠€(gè)子處理節(jié)點(diǎn)。

可選地，在將所述交易數(shù)據(jù)轉(zhuǎn)化為多個(gè)交易元組之后，還包括：調(diào)用所述第一處理節(jié)點(diǎn)，其中，所述第一處理節(jié)點(diǎn)設(shè)置有過(guò)濾算子函數(shù)；依據(jù)所述過(guò)濾算子函數(shù)，過(guò)濾所述交易元組中不符合預(yù)設(shè)采集條件的數(shù)據(jù)，得到目標(biāo)交易元組，其中，所述預(yù)設(shè)采集條件包括下述至少之一：交易成功數(shù)據(jù)、預(yù)設(shè)時(shí)間范圍內(nèi)的數(shù)據(jù)、與交易類(lèi)型匹配的數(shù)據(jù)、預(yù)設(shè)渠道的數(shù)據(jù)。

可選地，基于所述機(jī)構(gòu)標(biāo)識(shí)以及所述交易類(lèi)型，確定與所述交易元組對(duì)應(yīng)的目標(biāo)交易規(guī)則的步驟，包括：調(diào)用所述第二處理節(jié)點(diǎn)查詢(xún)預(yù)先建立的積分交易規(guī)則庫(kù)，得到查詢(xún)結(jié)果，其中，積分交易規(guī)則庫(kù)包括：N條交易規(guī)則，所述N為大于等于1的正整數(shù)，每個(gè)所述交易規(guī)則包括下述至少之一：依據(jù)機(jī)構(gòu)標(biāo)識(shí)維度和業(yè)務(wù)類(lèi)型維度確定的積分兌換比例、兌換渠道類(lèi)型、兌換時(shí)間范圍、每個(gè)用戶(hù)在第一預(yù)設(shè)時(shí)間段內(nèi)采集積分的次數(shù)上限閾值以及總積分上限閾值、機(jī)構(gòu)在第二預(yù)設(shè)時(shí)間段內(nèi)的每種業(yè)務(wù)類(lèi)型的積分總上限閾值；基于所述查詢(xún)結(jié)果，確定與所述機(jī)構(gòu)標(biāo)識(shí)以及所述交易類(lèi)型匹配的所述目標(biāo)交易規(guī)則。