[發(fā)明專利]數(shù)據(jù)處理方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110341398.5
• 申請(qǐng)日: 2021-03-30
• 公開（公告）號(hào): CN112905310A
• 公開（公告）日: 2021-06-04
• 發(fā)明（設(shè)計(jì)）人: 陳鑫;吳奔;史丹丹;陳立偉;王計(jì)春
• 申請(qǐng)（專利權(quán)）人: 中國(guó)建設(shè)銀行股份有限公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46;G06F9/50;G06F16/22;G06Q30/02
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種數(shù)據(jù)處理方法，其特征在于，包括：

獲取實(shí)時(shí)生成的紅包發(fā)放任務(wù)，并將所述紅包發(fā)放任務(wù)添加至待發(fā)放任務(wù)列表中；

響應(yīng)于批處理任務(wù)觸發(fā)操作，從所述待發(fā)放任務(wù)列表中獲取預(yù)設(shè)數(shù)量紅包發(fā)放任務(wù)，并確定與各所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶；

針對(duì)各所述紅包發(fā)放任務(wù)，利用事務(wù)消息在所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶和用戶賬戶之間進(jìn)行紅包轉(zhuǎn)賬。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，在獲取實(shí)時(shí)生成的紅包發(fā)放任務(wù)之前，還包括：

將對(duì)公總賬戶拆分成多個(gè)對(duì)公子賬戶，并將各所述對(duì)公子賬戶的賬戶金額分別存儲(chǔ)到對(duì)應(yīng)的Redis數(shù)據(jù)庫(kù)中進(jìn)行管理；

其中，各所述對(duì)公子賬戶設(shè)置統(tǒng)一的余額閾值，且各所述對(duì)公子賬戶的余額大于等于所述余額閾值。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，響應(yīng)于批處理任務(wù)觸發(fā)操作，從所述待發(fā)放任務(wù)列表中獲取預(yù)設(shè)數(shù)量紅包發(fā)放任務(wù)，并確定與各所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶，包括：

當(dāng)檢測(cè)到定時(shí)器的定時(shí)時(shí)間滿足觸發(fā)時(shí)間條件時(shí)，從所述待發(fā)放任務(wù)列表中獲取預(yù)設(shè)數(shù)量的紅包發(fā)放任務(wù)；

使用第一路由算法，將各所述紅包發(fā)放任務(wù)分發(fā)至對(duì)應(yīng)的服務(wù)器；

指示各所述服務(wù)器，使用第二路由算法，確定與各所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，指示各所述服務(wù)器，使用第二路由算法，確定與各所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶，包括：

針對(duì)各所述紅包發(fā)放任務(wù)，指示與所述紅包發(fā)放任務(wù)對(duì)應(yīng)的服務(wù)器，使用一致性哈希算法對(duì)所述紅包發(fā)放任務(wù)的序號(hào)以及子賬戶總數(shù)進(jìn)行取模運(yùn)算，并將運(yùn)算結(jié)果作為與所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶的序號(hào)。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，針對(duì)各所述紅包發(fā)放任務(wù)，利用事務(wù)消息，在所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶和用戶賬戶之間進(jìn)行紅包轉(zhuǎn)賬，包括：

針對(duì)各所述紅包發(fā)放任務(wù)，獲取所述紅包發(fā)放任務(wù)的紅包金額和用戶賬戶；

利用事務(wù)消息，在所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶中扣除所述紅包金額，同時(shí)在所述用戶賬戶中增加所述紅包金額。

6.根據(jù)權(quán)利要求2所述的方法，其特征在于，在利用事務(wù)消息，在所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶和用戶賬戶之間進(jìn)行紅包轉(zhuǎn)賬之后，還包括：

分別將各所述對(duì)公子賬戶的余額與所述余額閾值進(jìn)行比對(duì)；

如果存在余額小于所述余額閾值的目標(biāo)對(duì)公子賬戶，則回收所述目標(biāo)對(duì)公子賬戶，并將所述目標(biāo)對(duì)公子賬戶的余額分配給其他對(duì)公子賬戶。

7.根據(jù)權(quán)利要求1所述的方法，其特征在于，還包括：

計(jì)算預(yù)設(shè)時(shí)間長(zhǎng)度內(nèi)紅包發(fā)放任務(wù)的處理速度；

如果所述處理速度小于任務(wù)處理速度閾值，則提高紅包發(fā)放任務(wù)的處理優(yōu)先等級(jí)，或者增加對(duì)公子賬戶的數(shù)量。

8.根據(jù)權(quán)利要求5所述的方法，其特征在于，在針對(duì)各所述紅包發(fā)放任務(wù)，利用事務(wù)消息，在所述紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶和用戶賬戶之間進(jìn)行紅包轉(zhuǎn)賬之后，還包括：

將各所述對(duì)公子賬戶的扣除金額寫入已發(fā)放任務(wù)列表，并將所述待發(fā)放任務(wù)列表與所述已發(fā)放任務(wù)列表進(jìn)行比對(duì)；

如果兩者不一致，則觸發(fā)任務(wù)修正操作。

9.根據(jù)權(quán)利要求1所述的方法，其特征在于，還包括：

當(dāng)監(jiān)聽到各用戶賬戶開立的消息時(shí)，生成與各所述用戶賬戶對(duì)應(yīng)的初始紅包發(fā)放任務(wù)；

使用第一路由算法，將各所述初始紅包發(fā)放任務(wù)同步分發(fā)至對(duì)應(yīng)的服務(wù)器；

指示各所述服務(wù)器，使用第二路由算法，確定與各所述初始紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶；

針對(duì)各所述初始紅包發(fā)放任務(wù)，利用事務(wù)消息在所述初始紅包發(fā)放任務(wù)匹配的對(duì)公子賬戶和用戶賬戶之間進(jìn)行初始紅包轉(zhuǎn)賬。