[發明專利]數據事件處理方法、裝置、設備和存儲介質

有效

• 申請號: 202010331024.0
• 申請日: 2020-04-24
• 公開（公告）號: CN111538491B
• 公開（公告）日: 2023-07-14
• 發明（設計）人: 郭瑋;王浩;肇文兵;周滋明;李新;金鑫;黎健
• 申請（專利權）人: 成都新致云服信息技術有限公司
• 主分類號: G06F8/30
• 分類號: G06F8/30;G06Q10/0631
• 代理公司: 北京超凡宏宇專利代理事務所(特殊普通合伙) 11463
• 代理人: 蔣姍

1.一種數據事件處理方法，其特征在于，包括：

獲取待處理的數據事件；

將所述數據事件進行數據解耦處理，生成多個原子數據模塊；

從數據庫中調用每個所述原子數據模塊對應的預設基類；其中，所述預設基類為多種數據事件的公共基類；

根據所述預設基類和每個所述原子數據模塊的數據內容，處理所述數據事件；

其中，所述根據所述預設基類和每個所述原子數據模塊的數據內容，處理所述數據事件，包括：

判斷是否存在原子集合屬于同一個所述預設基類，所述原子集合中包括超過預設數量的所述原子數據模塊；

若存在所述原子集合，為所述原子集合中的每個所述原子數據模塊分配一個線程；

分別執行每個所述原子數據模塊對應的線程，生成所述原子集合的處理結果信息。

2.根據權利要求1所述的方法，其特征在于，所述將所述數據事件進行數據解耦處理，生成多個原子數據模塊，包括：

將所述數據事件的處理流程分解成多個子流程；

將每個所述子流程拆分成多個表操作任務，每個所述表操作任務作為一個所述原子數據模塊。

3.根據權利要求1所述的方法，其特征在于，所述從數據庫中調用每個所述原子數據模塊對應的預設基類，包括：

根據所述數據事件的時間信息和業務屬性信息，將多個所述原子數據模塊進行分類，生成分類結果信息；

根據所述分類結果信息，于所述數據庫中，調用每個類別對應的所述預設基類。

4.根據權利要求1所述的方法，其特征在于，所述根據所述預設基類和每個所述原子數據模塊的數據內容，處理所述數據事件，包括：

根據每個所述原子數據模塊的所述數據內容，判斷所述預設基類中是否包含處理所述原子數據模塊的全部邏輯；

若所述預設基類中未包含處理所述原子數據模塊的所述全部邏輯，則根據所述預設基類和所述數據內容，為每個所述原子數據模塊建立派生類；

執行所述派生類，生成所述數據事件的處理結果信息。

5.根據權利要求4所述的方法，其特征在于，還包括：

若所述預設基類中包含處理所述原子數據模塊的所述全部邏輯，則執行每個所述原子數據模塊對應的所述預設基類，生成所述數據事件的處理結果信息。

6.根據權利要求1所述的方法，其特征在于，還包括：

判斷所述原子集合中是否存在未被成功處理的所述原子數據模塊；

若所述原子集合中存在未被成功處理的所述原子數據模塊，則根據已成功處理的所述原子數據模塊的處理結果信息，生成回滾數據。

7.根據權利要求6所述的方法，其特征在于，還包括：

若所述原子集合中的每個所述原子數據模塊已被全部成功處理，則根據成功處理的結果信息，調整每個所述原子數據模塊的處理參數。

8.一種數據事件處理裝置，其特征在于，包括：

獲取模塊，用于獲取待處理的數據事件；

解耦模塊，用于將所述數據事件進行數據解耦處理，生成多個原子數據模塊；

調用模塊，用于從數據庫中調用每個所述原子數據模塊對應的預設基類；其中，所述預設基類為多種數據事件的公共基類；

處理模塊，用于根據所述預設基類和每個所述原子數據模塊的數據內容，處理所述數據事件；

其中，所述根據所述預設基類和每個所述原子數據模塊的數據內容，處理所述數據事件，包括：

判斷是否存在原子集合屬于同一個所述預設基類，所述原子集合中包括超過預設數量的所述原子數據模塊；

若存在所述原子集合，為所述原子集合中的每個所述原子數據模塊分配一個線程；

分別執行每個所述原子數據模塊對應的線程，生成所述原子集合的處理結果信息。

9.根據權利要求8所述的裝置，其特征在于，所述解耦模塊用于：

將所述數據事件的處理流程分解成多個子流程；

將每個所述子流程拆分成多個表操作任務，每個所述表操作任務作為一個所述原子數據模塊。