[發(fā)明專利]訂單數(shù)據(jù)自動化對賬方法、裝置及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202210048990.0
• 申請日: 2022-01-17
• 公開（公告）號: CN114398359A
• 公開（公告）日: 2022-04-26
• 發(fā)明（設(shè)計）人: 萬梅;鄒鵬
• 申請（專利權(quán)）人: 深圳依時貨拉拉科技有限公司
• 主分類號: G06F16/215
• 分類號: G06F16/215;G06F16/23;G06F16/27
• 代理公司: 深圳瑞天謹(jǐn)誠知識產(chǎn)權(quán)代理有限公司 44340
• 代理人: 溫青玲

本發(fā)明公開了訂單數(shù)據(jù)自動化對賬方法、裝置及存儲介質(zhì)。所述方法包括將預(yù)設(shè)周期內(nèi)的訂單數(shù)據(jù)離線提交在大數(shù)據(jù)平臺庫全量表中；將所述預(yù)設(shè)周期內(nèi)的大數(shù)據(jù)平臺庫全量表中增量變化的訂單數(shù)據(jù)清洗出來，記錄在大數(shù)據(jù)平臺庫增量表中；將所述大數(shù)據(jù)平臺庫增量表的數(shù)據(jù)同步到業(yè)務(wù)數(shù)據(jù)庫MySQL庫增量表；通過定時任務(wù)，同步所述MySQL庫增量表的數(shù)據(jù)到所述業(yè)務(wù)數(shù)據(jù)庫。本發(fā)明使用大數(shù)據(jù)平臺IDP(Internet Datagram Protocol：數(shù)據(jù)報協(xié)議)代替原來的實時接口，對各方系統(tǒng)的壓力減小，也可以避免因為各系統(tǒng)的抖動帶來數(shù)據(jù)的不準(zhǔn)確性，企業(yè)對賬數(shù)據(jù)準(zhǔn)確度較高，根本上解決對賬真性數(shù)據(jù)錯誤，客觀上提升部分運營處理對賬問題的個人效率，也提升用戶對賬體驗。

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

本發(fā)明涉及計算機(jī)技術(shù)領(lǐng)域，特別是涉及訂單數(shù)據(jù)自動化對賬方法、裝置及存儲介質(zhì)。

背景技術(shù)

現(xiàn)有的對賬方案，是每天或每幾天某個時間通過接口的方式拿到企業(yè)訂單的所有數(shù)據(jù)，比如訂單基本信息、發(fā)票信息、賬期信息等。然后通過業(yè)務(wù)邏輯比對各方金額數(shù)據(jù)，核對訂單的對賬狀態(tài)為成功或則失敗。

上述方案通過接口的方式，對各方的系統(tǒng)壓力大，并且依賴關(guān)聯(lián)方系統(tǒng)的穩(wěn)定性，導(dǎo)致對賬數(shù)據(jù)經(jīng)常可能需要全量重跑。

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

本發(fā)明針對現(xiàn)有技術(shù)使用通過接口方式拿到企業(yè)訂單數(shù)據(jù)，對各方的系統(tǒng)壓力大，并且依賴關(guān)聯(lián)方系統(tǒng)的穩(wěn)定性，導(dǎo)致對賬數(shù)據(jù)經(jīng)常可能需要全量重跑的技術(shù)問題，提出以下技術(shù)方案。

為了解決上述技術(shù)問題，本發(fā)明采用的一種技術(shù)方案是：

訂單數(shù)據(jù)自動化對賬方法，包括：

將預(yù)設(shè)周期內(nèi)的訂單數(shù)據(jù)離線提交到大數(shù)據(jù)平臺庫全量表中；

將所述預(yù)設(shè)周期內(nèi)的大數(shù)據(jù)平臺庫全量表中增量變化的訂單數(shù)據(jù)清洗出來，記錄在大數(shù)據(jù)平臺庫增量表中；

將所述大數(shù)據(jù)平臺庫增量表的數(shù)據(jù)同步到業(yè)務(wù)數(shù)據(jù)庫MySQL庫增量表；

通過定時任務(wù)，同步所述MySQL庫增量表的數(shù)據(jù)到所述業(yè)務(wù)數(shù)據(jù)庫。

進(jìn)一步地，所述訂單數(shù)據(jù)包括訂單子數(shù)據(jù)、發(fā)票數(shù)據(jù)、賬期數(shù)據(jù)、支付數(shù)據(jù)；所述將預(yù)設(shè)周期內(nèi)的訂單數(shù)據(jù)全量聚合離線提交到大數(shù)據(jù)平臺庫全量表中包括：

將預(yù)設(shè)周期內(nèi)的訂單子數(shù)據(jù)、發(fā)票數(shù)據(jù)、賬期數(shù)據(jù)、支付數(shù)據(jù)全量聚合離線提交在大數(shù)據(jù)平臺庫全量表中。

進(jìn)一步地，所述大數(shù)據(jù)平臺庫全量表包括Hive庫全量表；所述增量表包括Hive庫增量表；所述將所述預(yù)設(shè)周期內(nèi)增量變化的訂單數(shù)據(jù)清洗出來，記錄在增量表中包括：

通過腳本任務(wù)，對比所述MySQL庫中對賬數(shù)據(jù)與Hive庫全量表的訂單數(shù)據(jù)，將所述預(yù)設(shè)周期內(nèi)增量數(shù)據(jù)同步到所述Hive庫增量表中。

進(jìn)一步地，所述將所述對賬增量表的數(shù)據(jù)同步到業(yè)務(wù)數(shù)據(jù)庫MySQL庫包括：

配置同步數(shù)據(jù)任務(wù)，將所述Hive庫增量表的增量數(shù)據(jù)同步到所述MySQL庫增量表。

進(jìn)一步地，所述通過定時任務(wù)，同步所述MySQL庫增量表的數(shù)據(jù)到所述業(yè)務(wù)數(shù)據(jù)庫包括：

在所述預(yù)設(shè)周期內(nèi)，通過定時任務(wù)，采用多線程并發(fā)處理所述MySQL庫增量表的增量數(shù)據(jù)，寫入所述業(yè)務(wù)數(shù)據(jù)庫。

進(jìn)一步地，所述方法還包括：

判斷所述MySQL庫增量表的數(shù)據(jù)的訂單唯一標(biāo)識是否存在于所述業(yè)務(wù)數(shù)據(jù)庫，若不存在則新增訂單數(shù)據(jù)，已存在則更新訂單數(shù)據(jù)。

進(jìn)一步地，所述方法還包括：