[發(fā)明專利]一種訂單數(shù)據(jù)處理方法和裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202010574918.2
• 申請(qǐng)日: 2020-06-22
• 公開（公告）號(hào): CN113781133A
• 公開（公告）日: 2021-12-10
• 發(fā)明（設(shè)計(jì)）人: 王雄;任銀龍
• 申請(qǐng)（專利權(quán)）人: 北京沃東天駿信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): G06Q30/06
• 分類號(hào): G06Q30/06;G06F16/22;G06F16/2455
• 代理公司: 中原信達(dá)知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 張一軍;李陽

本發(fā)明公開了訂單數(shù)據(jù)處理方法和裝置，涉及計(jì)算機(jī)技術(shù)領(lǐng)域。該方法的一具體實(shí)施方式包括消費(fèi)訂單實(shí)時(shí)消息信息存入緩存中，并將根據(jù)訂單實(shí)時(shí)消息信息生成的標(biāo)識(shí)放入緩存中的隊(duì)列；根據(jù)緩存設(shè)定的預(yù)設(shè)時(shí)間間隔將內(nèi)存中的訂單實(shí)時(shí)消息信息數(shù)據(jù)批量寫入數(shù)據(jù)庫中；通過定時(shí)任務(wù)查詢緩存中的隊(duì)列，對(duì)入隊(duì)列最早的預(yù)設(shè)數(shù)量個(gè)標(biāo)識(shí)循環(huán)遍歷，進(jìn)而以預(yù)設(shè)最小時(shí)間粒度進(jìn)行統(tǒng)計(jì)處理并存儲(chǔ)至數(shù)據(jù)庫中。從而，本發(fā)明的實(shí)施方式能夠解決現(xiàn)有訂單數(shù)據(jù)處理時(shí)效性差、效率低的問題。

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

本發(fā)明涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及一種訂單數(shù)據(jù)處理方法和裝置。

背景技術(shù)

隨著互聯(lián)網(wǎng)技術(shù)的迅速發(fā)展，電子商務(wù)已經(jīng)浸入我們生活的方方面面，對(duì)社會(huì)帶來了深遠(yuǎn)的影響。人們的衣食住行都離不開電子商務(wù)，電子商務(wù)中的訂單占據(jù)了絕對(duì)核心的地位，他直接展現(xiàn)了整個(gè)公司的日常運(yùn)轉(zhuǎn)是否正常，營(yíng)收是否健康，對(duì)公司的戰(zhàn)略制定起到重要的指引作用，甚至決定了公司的存亡，因此對(duì)訂單單量的展示、監(jiān)控及告警成為了公司最為重要的事情。

在實(shí)現(xiàn)本發(fā)明過程中，發(fā)明人發(fā)現(xiàn)現(xiàn)有技術(shù)中至少存在如下問題：

對(duì)訂單單量數(shù)據(jù)的信息獲取、統(tǒng)計(jì)、展示及檢測(cè)一般直接通過腳本或命令獲取訂單數(shù)據(jù)信息，訂單數(shù)據(jù)最終會(huì)持久化保存到硬盤或數(shù)據(jù)庫。以及通過代碼程序查詢數(shù)據(jù)庫單量數(shù)據(jù)信息進(jìn)行統(tǒng)計(jì)，不能實(shí)時(shí)展示當(dāng)前訂單數(shù)據(jù)信息，需要按日或按月查詢，并以報(bào)表統(tǒng)計(jì)、曲線圖、柱狀圖、餅狀圖等不直觀方式展示。另外，告警部分一般缺失或者通過人工查看報(bào)告數(shù)據(jù)進(jìn)行檢測(cè)、判斷單量是否正常，費(fèi)時(shí)費(fèi)力，監(jiān)控效果差。

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

有鑒于此，本發(fā)明實(shí)施例提供一種訂單數(shù)據(jù)處理方法和裝置，能夠解決現(xiàn)有訂單數(shù)據(jù)處理時(shí)效性差、效率低的問題。

為實(shí)現(xiàn)上述目的，根據(jù)本發(fā)明實(shí)施例的一個(gè)方面，提供了一種訂單數(shù)據(jù)處理方法，包括消費(fèi)訂單實(shí)時(shí)消息信息存入緩存中，并將根據(jù)訂單實(shí)時(shí)消息信息生成的標(biāo)識(shí)放入緩存中的隊(duì)列；根據(jù)緩存設(shè)定的預(yù)設(shè)時(shí)間間隔將內(nèi)存中的訂單實(shí)時(shí)消息信息數(shù)據(jù)批量寫入數(shù)據(jù)庫中；通過定時(shí)任務(wù)查詢緩存中的隊(duì)列，對(duì)入隊(duì)列最早的預(yù)設(shè)數(shù)量個(gè)標(biāo)識(shí)循環(huán)遍歷，進(jìn)而以預(yù)設(shè)最小時(shí)間粒度進(jìn)行統(tǒng)計(jì)處理并存儲(chǔ)至數(shù)據(jù)庫中。

可選地，根據(jù)訂單實(shí)時(shí)消息信息生成標(biāo)識(shí)，包括：

獲取訂單實(shí)時(shí)消息信息中各維度數(shù)據(jù)和時(shí)間，根據(jù)預(yù)設(shè)維度組合拼成秒級(jí)或分鐘級(jí)的標(biāo)識(shí)放入緩存中的隊(duì)列。

可選地，還包括：

接收查詢請(qǐng)求，獲取請(qǐng)求中的查詢時(shí)間段，判斷該查詢時(shí)間段是否與當(dāng)前緩存中設(shè)置的存儲(chǔ)時(shí)間段一致；

若是則返回緩存中的統(tǒng)計(jì)處理結(jié)果；若否則查詢數(shù)據(jù)庫并構(gòu)建對(duì)應(yīng)于該查詢時(shí)間段的緩存以進(jìn)行統(tǒng)計(jì)處理。

可選地，以預(yù)設(shè)最小時(shí)間粒度進(jìn)行統(tǒng)計(jì)處理之后，還包括：

通過當(dāng)前時(shí)間點(diǎn)的統(tǒng)計(jì)處理結(jié)果與預(yù)設(shè)某一天相同時(shí)間點(diǎn)的統(tǒng)計(jì)處理結(jié)果進(jìn)行對(duì)比，監(jiān)測(cè)到對(duì)比結(jié)果滿足預(yù)設(shè)閾值，則啟動(dòng)報(bào)警程序。

可選地，啟動(dòng)報(bào)警程序之后，包括：

通過預(yù)設(shè)的通知方式向目標(biāo)報(bào)警群組進(jìn)行告警。

可選地，以預(yù)設(shè)最小時(shí)間粒度進(jìn)行統(tǒng)計(jì)處理并存儲(chǔ)至數(shù)據(jù)庫中之后，包括：

根據(jù)業(yè)務(wù)請(qǐng)求得到相應(yīng)的統(tǒng)計(jì)處理結(jié)果，以在前端頁面中進(jìn)行展示。

另外，本發(fā)明還提供了一種訂單數(shù)據(jù)處理裝置，包括獲取模塊，用于消費(fèi)訂單實(shí)時(shí)消息信息存入緩存中，并將根據(jù)訂單實(shí)時(shí)消息信息生成的標(biāo)識(shí)放入緩存中的隊(duì)列；

處理模塊，用于根據(jù)緩存設(shè)定的預(yù)設(shè)時(shí)間間隔將內(nèi)存中的訂單實(shí)時(shí)消息信息數(shù)據(jù)批量寫入數(shù)據(jù)庫中；通過定時(shí)任務(wù)查詢緩存中的隊(duì)列，對(duì)入隊(duì)列最早的預(yù)設(shè)數(shù)量個(gè)標(biāo)識(shí)循環(huán)遍歷，進(jìn)而以預(yù)設(shè)最小時(shí)間粒度進(jìn)行統(tǒng)計(jì)處理并存儲(chǔ)至數(shù)據(jù)庫中。

可選地，所述處理模塊，還用于：