[發明專利]一種基于非關系型數據庫的訂單處理系統及方法

在審

• 申請號: 202010760066.6
• 申請日: 2020-07-31
• 公開（公告）號: CN111930801A
• 公開（公告）日: 2020-11-13
• 發明（設計）人: 逢逍遙
• 申請（專利權）人: 銀盛通信有限公司
• 主分類號: G06F16/2458
• 分類號: G06F16/2458;G06F16/27;G06Q30/06
• 代理公司: 深圳市深可信專利代理有限公司 44599
• 代理人: 萬永泉

本發明公開了一種基于非關系型數據庫的訂單處理系統，涉及數據庫技術領域；該系統包括訂單接收系統、回調接收系統、訂單處理系統以及非關系型數據庫集群；所述的訂單接收系統和回調接收系統均連接至非關系型數據庫集群上，所述訂單接收系統用于接收來自渠道商的充值訂單，并向非關系型數據庫集群寫入訂單記錄；所述的訂單處理系統與非關系型數據庫集群相連接，訂單處理系統包括回調渠道處理器和訂單處理器；所述的訂單處理系統上還連接有關系型數據庫；本發明的有益效果是：提升了系統處理的效率和健壯性，不影響用戶的體驗。

技術領域

本發明涉及到數據庫技術領域，更具體的說，本發明涉及一種基于非關系型數據庫的訂單處理系統及方法。

背景技術

渠道商進行話費充值，充值系統處理訂單經歷以下幾個步驟：1、充值系統接收充值訂單請求；2、充值系統向數據庫寫入訂單記錄；3、充值系統向話費供應商發送充值請求；4、充值系統接收供應商回調的充值結果；5、充值系統從數據庫讀取保存的訂單進行渠道商錢包賬戶操作后更新訂單狀態；6、充值系統回調渠道商充值結果；7、充值系統從數據庫讀取保存的訂單更新回調狀態。

如果大量用戶進行大批量話費充值，可能會有如下問題：1、系統既要接收訂單寫入訂單數據又要同時不斷查詢訂單數據處理訂單，系統的處理壓力大，系統如發生故障，除了無法繼續接收訂單，積壓的大量訂單也將不能得到及時處理；2、系統高頻率地對數據庫同時進行讀寫操作，數據庫的壓力大，在并發達到一定的數據量級之后可能會嚴重影響訂單的處理效率，也嚴重影響用戶體驗。

發明內容

為了克服現有技術的不足，本發明提供一種基于非關系型數據庫的訂單處理系統及方法，提升了系統處理的效率和健壯性，不影響用戶的體驗。

本發明解決其技術問題所采用的技術方案是：一種基于非關系型數據庫的訂單處理系統，其改進之處在于，該系統包括訂單接收系統、回調接收系統、訂單處理系統以及非關系型數據庫集群；

所述的訂單接收系統和回調接收系統均連接至非關系型數據庫集群上，所述訂單接收系統用于接收來自渠道商的充值訂單，并向非關系型數據庫集群寫入訂單記錄，所述回調接收系統用于接收來自供應商的充值結果，回調后向非關系型數據庫寫入訂單回調記錄；

所述的訂單處理系統與非關系型數據庫集群相連接，訂單處理系統包括回調渠道處理器和訂單處理器，所述訂單處理器用于從非關系型數據庫集群中查出訂單記錄，將訂單記錄加入第一消息隊列，并依據訂單記錄向供應商發起充值請求；所述回調渠道處理器用于從非關系型數據庫集群中查出訂單回調記錄，將訂單回調記錄加入第二消息隊列，并依據訂單回調記錄向渠道商發出通知回調；

所述的訂單處理系統上還連接有關系型數據庫。

在上述的結構中，所述的訂單處理器按照訂單記錄寫入時間的先后順序，從非關系型數據庫集群中查出訂單記錄。

在上述的結構中，所述的訂單處理器在查出訂單記錄后，更新非關系型數據庫集群中的訂單記錄為已處理。

在上述的結構中，在所述的訂單處理器在向供應商發出充值請求后，該訂單信息則存入關系型數據庫。

在上述的結構中，所述的回調渠道處理器按照訂單回調記錄寫入時間的先后順序，從非關系型數據庫集群中查出訂單回調記錄。

在上述的結構中，所述的回調渠道處理器在查出訂單回調記錄后，更新非關系型數據庫集群中的訂單回調記錄為已處理。

在上述的結構中，所述的回調渠道處理器在向渠道商發出通知回調前，依據訂單回調記錄解析在上述的結構中，所述的回調渠道處理器向渠道商發出通知，在收到渠道商響應收到通知或者預設回調次數用完前，持續地向渠道商發出通知；并在完成回調后更新關系型數據庫中的訂單回調狀態。

在上述的結構中，所述的訂單處理器包括移動訂單處理器、聯通訂單處理器以及電信訂單處理器。