[發明專利]一種單據數據分布式計算的方法和裝置

在審

• 申請號: 201810896522.2
• 申請日: 2018-08-08
• 公開（公告）號: CN110858199A
• 公開（公告）日: 2020-03-03
• 發明（設計）人: 孟令聞
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/242;G06F16/2455;G06F16/28
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 張一軍;李陽

本發明公開了一種單據數據分布式計算的方法和裝置，涉及計算機技術領域。該方法的一具體實施方式包括：確定待處理單據數據集合，以及將所述待處理單據數據集合裝載至緩存層；根據預設的分配規則從分布式計算機系統中確定出執行計算機；基于所述緩存層和所述緩存層裝載的待處理單據數據集合，所述執行計算機執行對應的業務邏輯，以得到處理結果；將所述處理結果寫回數據庫。該方法通過分布式計算機系統中的執行計算機與緩存層的交互，只將最后的處理結果寫回數據庫，避免了計算過程中與結構化數據庫的交互，進而大大提升了計算速度。

技術領域

本發明涉及計算機技術領域，尤其涉及一種單據數據分布式計算的方法和裝置。

背景技術

單據數據例如采銷運單據數據，具有結構復雜、關聯性強的特點。其中，采銷運單據數據是生產制造企業常見的采購單(purchase order,以下簡稱PO)、銷售單(salesorder,以下簡稱SO)和運輸單(delivery order,以下簡稱DO)，以及由它們附屬衍生出的子單據如制造單(manufacture order,以下簡稱MO)、發運追蹤狀態(shipment status,以下簡稱SPT)等數據。

現有技術中對該單據數據的計算，是將這些單據數據統一存放在一臺單機數據庫的關系型數據庫中，并以主外鍵的方式建立兩個單據數據之間的關聯關系。以及基于上述數據結構，單據數據在前臺展現給用戶或者后臺展現給管理者時，要進行一些邏輯加工和計算。具體的，對于待處理單據數據集合，例如新增數據，用關系型數據庫的存儲過程腳本遍歷新增數據集，對每一條數據執行業務邏輯子腳本，腳本執行期間會不斷地查詢關系型數據庫的歷史數據，以及期間會不斷的進行更新歷史數據、插入新數據的操作，無法批量執行相應操作，且當歷史數據量龐大時，效率低下。

發明內容

有鑒于此，本發明實施例提供一種單據數據分布式計算的方法和裝置，能夠通過分布式計算機系統中的執行計算機與緩存層的交互，只將最后的處理結果寫回數據庫，避免了計算過程中與結構化數據庫的交互，進而大大提升了計算速度。

為實現上述目的，根據本發明實施例的一個方面，提供了一種單據數據分布式計算的方法。

本發明實施例的單據數據分布式計算的方法包括：確定待處理單據數據集合，以及將所述待處理單據數據集合裝載至緩存層；根據預設的分配規則從分布式計算機系統中確定出執行計算機；基于所述緩存層和所述緩存層裝載的待處理單據數據集合，所述執行計算機執行對應的業務邏輯，以得到處理結果；將所述處理結果寫回數據庫。

可選地，確定待處理單據數據集合，以及將所述待處理單據數據集合裝載至緩存層的步驟包括：根據輸入的目標數據以及數據之間的關聯關系，在數據庫中查詢關聯數據，以獲取待處理單據數據集合；將所述待處理單據數據集合添加數據標識；根據所述數據標識和所述數據之間的關聯關系，將所述待處理單據數據集合裝載至緩存層。

可選地，根據預設的分配規則從分布式計算機系統中確定出執行計算機的步驟包括：獲取所述待處理單據數據集合的數據標識；根據所述數據標識與分布式計算機系統中計算機的對應關系，確定執行計算機。

可選地，基于所述緩存層和所述緩存層裝載的待處理單據數據集合，所述執行計算機執行對應的業務邏輯，以得到處理結果的步驟包括：所述執行計算機根據所述待處理單據數據集合確定對應的業務邏輯；所述執行計算機與所述緩存層交互，讀取緩存層裝載的待處理單據數據集合，執行所述對應的業務邏輯，并將計算的臨時結果或者中間狀態寫入所述緩存層；所述執行計算機確定所述對應的業務邏輯執行完畢，并將執行完畢的處理結果寫入所述緩存層。

可選地，所述緩存層為Redis數據庫。

為實現上述目的，根據本發明實施例的另一個方面，提供了一種單據數據分布式計算的裝置。

本發明實施例的單據數據分布式計算的裝置包括：