[發明專利]交易數據處理方法及裝置

在審

• 申請號: 202011016374.4
• 申請日: 2020-09-24
• 公開（公告）號: CN111932234A
• 公開（公告）日: 2020-11-13
• 發明（設計）人: 周晶;王帥;李慧超;鄭斌;孫博;劉坤
• 申請（專利權）人: 國網電子商務有限公司;國網電商科技有限公司
• 主分類號: G06Q20/12
• 分類號: G06Q20/12
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 李偉

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

響應于交易指令，獲取所述交易指令中的交易數據；

應用預先設置的執行引擎創建所述交易指令對應的交易處理管道；所述交易處理管道包含多個依次排序的業務節點閥；

將所述交易數據輸入至所述交易處理管道，使得所述交易處理管道中的每個所述業務節點閥依次對所述交易數據進行處理，得到所述交易指令對應的交易結果；其中，所述交易數據為所述交易處理管道中的首個業務節點閥的輸入，所述交易處理管道中的每個業務節點閥的輸出作為下一業務節點閥的輸入。

2.根據權利要求1所述的方法，其特征在于，所述應用預先設置的執行引擎創建所述交易指令對應的交易處理管道，包括：

調用所述執行引擎生成初始交易處理管道；

確定所述交易指令對應的交易流程；所述交易流程包含多個交易環節；

獲取每個所述交易環節各自對應的業務節點閥；

基于所述交易流程中的各個所述交易環節的執行順序將各個所述業務節點閥添加至所述初始交易處理管道；

將已添加各個所述業務節點閥的初始交易處理管道作為所述交易指令對應的交易處理管道。

3.根據權利要求1所述的方法，其特征在于，所述將所述交易數據輸入至所述交易處理管道，使得所述交易處理管道中的每個所述業務節點閥依次對所述交易數據進行處理，得到所述交易指令對應的交易結果，包括：

創建所述交易處理管道對應的管道上行文，并為所述交易數據分配處理標識符；

將攜帶處理標識的交易數據存放至所述管道上下文，觸發所述交易處理管道中的每個所述業務節點閥按其對應的執行順序執行數據處理操作，每個所述業務節點閥執行所述數據處理操作的過程，包括：在所述管道上下文中獲取該業務節點閥的輸入，并對該輸入進行處理，得到該業務節點閥對應的輸出，將該業務節點閥的輸出存放至所述管道上下文中；

其中，所述攜帶處理標識的交易數據為所述交易處理管道中的首個業務節點閥的輸入，將所述交易處理管道中的每個業務節點閥的輸出作為下一業務節點閥的輸入，直至獲取到所述交易處理管道中的最后一個業務節點閥的輸出；

將所述交易處理管道中的最后一個業務節點閥的輸出確定為所述交易指令對應的交易結果。

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

當檢測到任意一個所述業務節點閥對數據處理失敗時，執行數據回滾操作，以重新獲取該業務節點閥的輸入，使得該業務節點閥重新對該輸入進行處理。

5.根據權利要求1所述的方法，其特征在于，所述獲取所述交易指令中的交易數據，包括：

對所述交易指令進行解析，獲得所述交易指令中的指令信息；

在所述指令信息中獲取到所述交易數據。

6.一種交易數據處理裝置，其特征在于，包括：

獲取單元，用于響應于交易指令，獲取所述交易指令中的交易數據；

創建單元，用于應用預先設置的執行引擎創建所述交易指令對應的交易處理管道；所述交易處理管道包含多個依次排序的業務節點閥；

處理單元，用于將所述交易數據輸入至所述交易處理管道，使得所述交易處理管道中的每個所述業務節點閥依次對所述交易數據進行處理，得到所述交易指令對應的交易結果；其中，所述交易數據為所述交易處理管道中的首個業務節點閥的輸入，所述交易處理管道中的每個業務節點閥的輸出作為下一業務節點閥的輸入。

7.根據權利要求6所述的裝置，其特征在于，所述創建單元，包括：

生成子單元，用于調用所述執行引擎生成初始交易處理管道；

第一確定子單元，用于確定所述交易指令對應的交易流程；所述交易流程包含多個交易環節；

第一獲取子單元，用于獲取獲取每個所述交易環節各自對應的業務節點閥；

第一執行子單元，用于基于所述交易流程中的各個所述交易環節的執行順序將各個所述業務節點閥添加至所述初始交易處理管道；

第二執行子單元，用于將已添加各個所述業務節點閥的初始交易處理管道作為所述交易指令對應的交易處理管道。