[發(fā)明專利]交易補(bǔ)償方法及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202010411824.3
• 申請(qǐng)日: 2020-05-15
• 公開(kāi)（公告）號(hào): CN111738728A
• 公開(kāi)（公告）日: 2020-10-02
• 發(fā)明（設(shè)計(jì)）人: 賀夕政;王原軍;包玉雪;陳旭;葛林峰
• 申請(qǐng)（專利權(quán)）人: 蘇寧金融科技（南京）有限公司
• 主分類號(hào): G06Q20/40
• 分類號(hào): G06Q20/40;G06Q40/02
• 代理公司: 北京市萬(wàn)慧達(dá)律師事務(wù)所 11111
• 代理人: 盛安平

1.一種交易補(bǔ)償方法，其特征在于，包括：

從業(yè)務(wù)系統(tǒng)中獲取狀態(tài)變更的交易訂單；

基于所述交易訂單的更新時(shí)間以及任務(wù)配置表中對(duì)應(yīng)交易訂單的補(bǔ)償時(shí)間，計(jì)算每個(gè)所述交易訂單的補(bǔ)償發(fā)起時(shí)間；

按照補(bǔ)償發(fā)起時(shí)間的先后順序?qū)⑺鼋灰子唵尉彺嬷羶?nèi)存隊(duì)列；

定時(shí)掃描內(nèi)存隊(duì)列中的訂單任務(wù)，并在達(dá)到補(bǔ)償發(fā)起時(shí)間時(shí)通知業(yè)務(wù)系統(tǒng)向?qū)?yīng)所述交易訂單發(fā)起補(bǔ)償動(dòng)作。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，從業(yè)務(wù)系統(tǒng)中獲取狀態(tài)變更的交易訂單的方法包括：

通過(guò)實(shí)時(shí)數(shù)據(jù)復(fù)制平臺(tái)從業(yè)務(wù)系統(tǒng)中訂閱數(shù)據(jù)庫(kù)日志，接收業(yè)務(wù)系統(tǒng)中狀態(tài)發(fā)生變更的交易訂單表；

所述交易訂單表包括多個(gè)交易訂單，所述交易訂單包括訂單號(hào)、交易金額、更新時(shí)間以及更新?tīng)顟B(tài)。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，在基于所述交易訂單的更新時(shí)間以及任務(wù)配置表中對(duì)應(yīng)交易訂單的補(bǔ)償時(shí)間，計(jì)算每個(gè)所述交易訂單的補(bǔ)償發(fā)起時(shí)間之前還包括：

在服務(wù)端中預(yù)先部署任務(wù)配置表，所述任務(wù)配置表中配置有多種交易訂單對(duì)應(yīng)的補(bǔ)償時(shí)間。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，基于所述交易訂單的更新時(shí)間以及任務(wù)配置表中對(duì)應(yīng)交易訂單的補(bǔ)償時(shí)間，計(jì)算每個(gè)所述交易訂單的補(bǔ)償發(fā)起時(shí)間的方法包括：

提取所述交易訂單表中各交易訂單的更新時(shí)間；

遍歷所述交易訂單，從任務(wù)配置表中查找與所述交易訂單對(duì)應(yīng)的補(bǔ)償時(shí)間；

基于所述交易訂單的更新時(shí)間以及對(duì)應(yīng)的補(bǔ)償時(shí)間，相加得到各個(gè)所述交易訂單的補(bǔ)償發(fā)起時(shí)間。

5.根據(jù)權(quán)利要求1-4任一項(xiàng)所述的方法，其特征在于，在按照補(bǔ)償發(fā)起時(shí)間的先后順序?qū)⑺鼋灰子唵尉彺嬷羶?nèi)存隊(duì)列之前還包括：

構(gòu)建階梯時(shí)效的多個(gè)補(bǔ)償隊(duì)列，每個(gè)補(bǔ)償隊(duì)列用于處理相應(yīng)時(shí)效的交易訂單補(bǔ)償動(dòng)作；

所述補(bǔ)償隊(duì)列包括秒級(jí)內(nèi)存補(bǔ)償隊(duì)列和分級(jí)內(nèi)存補(bǔ)償隊(duì)列。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，定時(shí)掃描內(nèi)存隊(duì)列中的訂單任務(wù)，并在達(dá)到補(bǔ)償發(fā)起時(shí)間時(shí)通知業(yè)務(wù)系統(tǒng)向?qū)?yīng)所述交易訂單發(fā)起補(bǔ)償動(dòng)作的方法包括：

將所述交易訂單全部緩存至秒級(jí)內(nèi)存補(bǔ)償隊(duì)列；

每秒執(zhí)行一次秒級(jí)補(bǔ)償任務(wù)，從秒級(jí)補(bǔ)償隊(duì)列中掃描出補(bǔ)償發(fā)起時(shí)間達(dá)到當(dāng)前時(shí)間的訂單任務(wù)，并將該訂單任務(wù)通知業(yè)務(wù)系統(tǒng)向?qū)?yīng)所述交易訂單發(fā)起補(bǔ)償動(dòng)作。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，定時(shí)掃描內(nèi)存隊(duì)列中的訂單任務(wù)，并在達(dá)到補(bǔ)償發(fā)起時(shí)間時(shí)通知業(yè)務(wù)系統(tǒng)向?qū)?yīng)所述交易訂單發(fā)起補(bǔ)償動(dòng)作的方法還包括：

待上一次秒級(jí)補(bǔ)償任務(wù)執(zhí)行完畢后，匯總補(bǔ)償失敗的所述交易訂單并清空秒級(jí)內(nèi)存補(bǔ)償隊(duì)列的緩存；

將補(bǔ)償失敗的所述交易訂單按照補(bǔ)償發(fā)起時(shí)間的先后順序緩存至分級(jí)內(nèi)存補(bǔ)償隊(duì)列；

每分鐘執(zhí)行一次分級(jí)補(bǔ)償任務(wù)，從分級(jí)內(nèi)存補(bǔ)償隊(duì)列中掃描出補(bǔ)償發(fā)起時(shí)間達(dá)到當(dāng)前時(shí)間的訂單任務(wù)，并將該訂單任務(wù)通知業(yè)務(wù)系統(tǒng)向?qū)?yīng)所述交易訂單發(fā)起補(bǔ)償動(dòng)作。

8.根據(jù)權(quán)利要求7所述的方法，其特征在于，定時(shí)掃描內(nèi)存隊(duì)列中的訂單任務(wù)，并在達(dá)到補(bǔ)償發(fā)起時(shí)間時(shí)通知業(yè)務(wù)系統(tǒng)向?qū)?yīng)所述交易訂單發(fā)起補(bǔ)償動(dòng)作的方法還包括：

待上一次分級(jí)補(bǔ)償任務(wù)執(zhí)行完畢后，匯總再次補(bǔ)償失敗的所述交易訂單并清空分級(jí)內(nèi)存補(bǔ)償隊(duì)列的緩存；

將再次補(bǔ)償失敗的所述交易訂單添加至異常任務(wù)表，并通知人工介入處理。

9.一種交易補(bǔ)償裝置，其特征在于，包括：

實(shí)時(shí)數(shù)據(jù)復(fù)制單元，用于從業(yè)務(wù)系統(tǒng)中獲取狀態(tài)變更的交易訂單；

流式消息處理單元，用于基于所述交易訂單的更新時(shí)間以及任務(wù)配置表中對(duì)應(yīng)交易訂單的補(bǔ)償時(shí)間，計(jì)算每個(gè)所述交易訂單的補(bǔ)償發(fā)起時(shí)間；

隊(duì)列緩存單元，用于按照補(bǔ)償發(fā)起時(shí)間的先后順序?qū)⑺鼋灰子唵尉彺嬷羶?nèi)存隊(duì)列；

任務(wù)處理單元，用于定時(shí)掃描內(nèi)存隊(duì)列中的訂單任務(wù)，并在達(dá)到補(bǔ)償發(fā)起時(shí)間時(shí)通知業(yè)務(wù)系統(tǒng)向?qū)?yīng)所述交易訂單發(fā)起補(bǔ)償動(dòng)作。

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