[發(fā)明專利]一種參數(shù)同步方法和裝置

有效

• 申請?zhí)枺?/td>: 202110423699.2
• 申請日: 2021-04-20
• 公開（公告）號: CN113127564B
• 公開（公告）日: 2023-02-28
• 發(fā)明（設(shè)計(jì)）人: 劉建楠;安興朝;趙釗
• 申請（專利權(quán)）人: 建信金融科技有限責(zé)任公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 中原信達(dá)知識產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 張一軍;李陽

1.一種參數(shù)同步方法，其特征在于，包括：

接收業(yè)務(wù)參數(shù)同步請求，觸發(fā)參數(shù)同步進(jìn)程；

確定所述業(yè)務(wù)參數(shù)同步請求對應(yīng)的業(yè)務(wù)批次時間，調(diào)用參數(shù)同步引擎，獲取參數(shù)類型狀態(tài)表，以基于所述業(yè)務(wù)批次時間和所述參數(shù)類型狀態(tài)表，確定對應(yīng)該業(yè)務(wù)批次的參數(shù)分類記錄；其中，所述確定對應(yīng)該業(yè)務(wù)批次的參數(shù)分類記錄，包括：獲取所述業(yè)務(wù)參數(shù)同步請求對應(yīng)的業(yè)務(wù)批次所對應(yīng)的更新任務(wù)集合；確定所述參數(shù)類型狀態(tài)表的更新時間；基于所述業(yè)務(wù)批次時間、所述更新時間以及預(yù)設(shè)的超時時間閾值，確定所述更新任務(wù)集合中的超時更新任務(wù)；調(diào)用線程池，并發(fā)同步執(zhí)行各超時更新任務(wù)，確定各超時更新任務(wù)的執(zhí)行結(jié)果；基于所述各超時更新任務(wù)的執(zhí)行結(jié)果，更新參數(shù)類型狀態(tài)表，進(jìn)而確定更新的所述參數(shù)類型狀態(tài)表中的參數(shù)分類記錄；

將所述參數(shù)分類記錄傳輸至各個參數(shù)更新引擎以執(zhí)行更新任務(wù)，進(jìn)而從分布式緩存中提取與所述參數(shù)分類記錄對應(yīng)的參數(shù)變更數(shù)據(jù)，調(diào)用結(jié)構(gòu)化查詢語言，基于所述參數(shù)變更數(shù)據(jù)，更新各個參數(shù)更新引擎對應(yīng)的目標(biāo)數(shù)據(jù)庫；

響應(yīng)于確定更新任務(wù)的執(zhí)行結(jié)果為部分成功，獲取該業(yè)務(wù)批次中內(nèi)呼狀態(tài)為失敗和不確定的更新任務(wù)，進(jìn)而執(zhí)行參數(shù)同步失敗異步重發(fā)進(jìn)程。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述提取與所述參數(shù)分類記錄對應(yīng)的參數(shù)變更數(shù)據(jù)，包括：

響應(yīng)于確定分布式緩存中不存在與所述參數(shù)分類記錄對應(yīng)的參數(shù)變更數(shù)據(jù)，從源數(shù)據(jù)庫中查找并提取所述參數(shù)變更數(shù)據(jù)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述更新各個參數(shù)更新引擎對應(yīng)的目標(biāo)數(shù)據(jù)庫，包括：

確定所述參數(shù)變更數(shù)據(jù)的索引；

基于所述索引、所述參數(shù)變更數(shù)據(jù)和目標(biāo)數(shù)據(jù)庫，執(zhí)行結(jié)構(gòu)化查詢語言；

響應(yīng)于確定執(zhí)行結(jié)果異常，判斷執(zhí)行操作類型；

基于所述執(zhí)行操作類型，確定對應(yīng)的處理方式；

基于所述處理方式、所述索引、所述參數(shù)變更數(shù)據(jù)和目標(biāo)數(shù)據(jù)庫繼續(xù)執(zhí)行結(jié)構(gòu)化查詢語言，得到更新執(zhí)行結(jié)果，并基于所述更新執(zhí)行結(jié)果，更新各個參數(shù)更新引擎對應(yīng)的目標(biāo)數(shù)據(jù)庫。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述執(zhí)行參數(shù)同步失敗異步重發(fā)進(jìn)程，包括：

更新周期更新任務(wù)庫，確定所述周期更新任務(wù)庫中的各周期更新任務(wù)對應(yīng)的業(yè)務(wù)批次，并獲取業(yè)務(wù)批次流水表；

基于所述各周期更新任務(wù)對應(yīng)的業(yè)務(wù)批次、所述業(yè)務(wù)批次流水表以及業(yè)務(wù)批次時間，確定各周期更新任務(wù)的執(zhí)行順序；

基于所述執(zhí)行順序，確定目標(biāo)周期更新任務(wù)；

執(zhí)行所述目標(biāo)周期更新任務(wù)中內(nèi)呼狀態(tài)為失敗和不確定的更新任務(wù)，并獲取執(zhí)行結(jié)果；

進(jìn)而更新所述目標(biāo)周期更新任務(wù)對應(yīng)的業(yè)務(wù)批次對應(yīng)的參數(shù)類型狀態(tài)表，進(jìn)而更新所述目標(biāo)周期更新任務(wù)對應(yīng)的業(yè)務(wù)批次的參數(shù)分類記錄。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

接收參數(shù)同步狀態(tài)查詢請求，獲取所述參數(shù)同步狀態(tài)查詢請求中的批次標(biāo)識；

調(diào)用批次流水表，確定所述批次標(biāo)識對應(yīng)的業(yè)務(wù)批次中各任務(wù)的參數(shù)同步狀態(tài)，并輸出。

6.根據(jù)權(quán)利要求1～5中任一項(xiàng)所述的方法，其特征在于，所述參數(shù)同步請求包括：參數(shù)插入請求、參數(shù)更新請求和參數(shù)刪除請求。