[發明專利]一種將數據更新快速同步到業務系統的裝置及方法

有效

• 申請號: 201611078665.X
• 申請日: 2016-11-30
• 公開（公告）號: CN108121730B
• 公開（公告）日: 2021-01-26
• 發明（設計）人: 馬文軍
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27;G06Q30/04
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 張一軍;姜勁

本發明提供一種將數據更新快速同步到業務系統的裝置及方法，該裝置包括數據更新模塊和數據同步模塊，數據更新模塊在發生數據的更新時，向數據同步模塊發送數據更新消息，數據更新消息包括數據的標識和更新時間；數據同步模塊包括緩存，緩存保存數據的標識和對應的最后更新時間，其中，當接收到數據更新消息時，數據同步模塊根據接收的數據更新消息中的標識確定緩存中保存的標識對應的最后更新時間，如果數據更新消息中的更新時間晚于最后更新時間，則從數據更新模塊獲取對應的數據并作為數據消息發送至業務系統，并且把緩存中的最后變更時間替換為數據更新消息中的更新時間。本發明能夠有效實現實時數據更新，提高了數據更新的工作效率。

技術領域

本發明涉及計算機網絡及計算機軟件領域，具體涉及一種將數據更新快速同步到業務系統的裝置及方法。

背景技術

增值稅發票(以下簡稱增票)資質信息是開具增票的唯一且必需的憑證，其中資質信息包括資質稅號、單位名稱等。每個與增票相關的業務系統和用戶都有權對資質信息進行新增、修改等操作。因此，在開具增票的過程中，用戶在各個業務系統提交開具增票請求之后，還需要負責增票業務的相關人員進行逐級審核，最終統一由企業發票系統進行審核處理，在審核通過之后才能夠正式開具增票。如果各個業務系統各自的資質信息與企業發票系統數據庫一致，在各個業務系統提交開具增票請求之后，正式開具增票的效率必定大為增加。

為便于能夠提高開具增票的效率，各個業務系統各自保存有一份資質信息。然而，由于各個業務系統擁有各自的業務數據并且執行各自的業務流程，彼此之間不可避免會存在大量不同狀態、不同內容的資質信息。雖然資質狀態變更頻繁，并且采用定時任務查詢資質數據庫的方式，仍然不能實時保證資質信息的一致。

在現有技術中，為保證各個業務系統中的資質信息與企業發票系統中的資質信息保持一致，各個業務系統需要頻繁查詢企業發票系統的資質數據庫。但是，隨著業務量的增長，增票開具量也隨之越來越大，資質信息的數據量也同樣隨之陡增。在大量開具發票的情況下，各個業務系統的查詢請求對企業發票系統數據庫造成巨大的讀壓力，甚至在高峰時期可能會造成企業發票系統數據庫的宕機，嚴重影響了開具增票的工作效率，增加了開票的機器資源消耗，甚至導致客戶的投訴。

因此，如何快速準確地將最新的資質信息和資質狀態同步給上游的各個業務系統，并且避免頻繁的查詢發票系統的資質數據庫已成為當前急需解決的技術問題。

發明內容

有鑒于此，本發明的目的在于提供一種將數據更新快速同步到業務系統的裝置及方法，以達到快速準確地將數據更新同步到業務系統。

本發明的技術方案是提供一種將數據更新快速同步到業務系統的裝置，該裝置包括數據更新模塊和數據同步模塊，其中，

所述數據更新模塊在發生數據的更新時，向所述數據同步模塊發送數據更新消息，所述數據更新消息包括所述數據的標識和更新時間；

所述數據同步模塊包括緩存，所述緩存保存所述數據的標識和對應的最后更新時間，

其中，當接收到所述數據更新消息時，所述數據同步模塊根據接收的所述數據更新消息中的所述標識確定所述緩存中保存的所述標識對應的最后更新時間，如果所述數據更新消息中的所述更新時間晚于所述最后更新時間，則從所述數據更新模塊獲取對應的數據并作為數據消息發送至所述業務系統，并且把所述緩存中的所述最后變更時間替換為所述數據更新消息中的所述更新時間。

可選地，所述數據是增值稅發票資質信息。

可選地，所述數據同步模塊由多套MQ消息集群組成，并且還包括監控模塊，所述監控模塊用于定期檢測各所述MQ消息集群的可用率和發送時間，并將發送時間最快且可用的所述MQ消息集群的編號保存至所述緩存中，使得在接收和發送消息時利用發送時間最快且可用的所述MQ消息集群。

本發明還提供一種將數據更新快速同步到業務系統的方法，所述方法，其中，