[發明專利]一種異構柜臺并行運行方法和系統

在審

• 申請號: 202010548029.9
• 申請日: 2020-06-16
• 公開（公告）號: CN112116467A
• 公開（公告）日: 2020-12-22
• 發明（設計）人: 孫樂晨;覃劍;潘俊材;張萬華;郭林瑗;周超;王康貴;高劍;史光偉;劉英;劉小明
• 申請（專利權）人: 上海金融期貨信息技術有限公司
• 主分類號: G06Q40/04
• 分類號: G06Q40/04
• 代理公司: 上海專利商標事務所有限公司 31100
• 代理人: 施浩

1.一種異構柜臺并行運行方法，其特征在于，方法包括：資金同步和賬戶同步，本程序通過兩者的配合使得多柜臺實現異構并行，其中：

資金同步的處理流程包括：

步驟11：調用加載程序配置的功能實現本程序與其他柜臺的數據訪問；

步驟12：讀取日志系統中的數據，計算出本程序上次關閉時，資金同步進行的斷點處位置，并在上次的斷點處繼續處理后續步驟；

步驟13：使用資金事件驅動器設定資金數據的實時同步間隔和啟停資金同步；

步驟14：使用增量數據掃描器掃描各個柜臺的出入金數據的增量數據；

步驟15：使用數據適配器將各個柜臺的出入金數據的增量數據轉換成統一的中間格式，并添加輔助信息供后續日志系統使用；

步驟16：使用數據分發器將數據分發給合適的分發適配器，并進行數據二次篩選；

步驟17：使用分發適配器將出入金數據寫入目標柜臺；

步驟18：使用日志系統記錄已經同步的數據到源數據庫中，供篩選增量數據時使用；

賬戶同步的處理流程包括：

步驟21：調用加載程序配置的功能實現本程序與其他柜臺的數據訪問；

步驟22：使用賬戶事件驅動器來設定賬戶同步的同步間隔和啟停資金同步；

步驟23：使用監控中心XML文件監聽器檢測是否存在期貨市場下發的新的XML文件；

步驟24：按照本地保存的賬戶同步模板文件中的配置，將監控中心下發的XML文件讀取到內存中；

步驟25：調用數據補全的功能來補全讀取XML文件時未讀取到或不合法的數據；

步驟26：使用業務適配器處理XML文件中攜帶的業務；

步驟27：使用數據庫語句生成器根據接收到的數據，調用加載程序配置的功能中所加載的XML文件，生成數據庫語句并執行；

步驟28：使用日志系統來保存本程序執行時各個功能調用的輸出內容。

2.根據權利要求1所述的異構柜臺并行運行方法，其特征在于，加載程序配置的調用處理進一步包括：

讀取配置信息文件中的各個柜臺各自的配置信息，根據配置信息連接各自柜臺的數據庫系統，供后續功能的調用中訪問指定柜臺的數據；

讀取出入金功能配置文件來決定資金對應的源柜臺和目標柜臺。

3.根據權利要求1所述的異構柜臺并行運行方法，其特征在于，資金事件驅動器的設定處理進一步包括：

使用一個開關和一個定時器來管理資金同步功能，當開關關閉后，不再進行資金同步；

在開關開啟后，激活一個定時器，按照一定的時間間隔啟動資金同步功能。

4.根據權利要求1所述的異構柜臺并行運行方法，其特征在于，增量數據掃描器的處理進一步包括：

根據加載程序配置的步驟中所加載的出入金功能配置文件，決定掃描對應柜臺的出入金數據；

決定掃描的柜臺后，提取此柜臺的出入金數據，并使用日志系統去除那些已經被上次掃描到的數據，得到此柜臺的出入金數據的增量數據；

最后，保存源柜臺獲取的增量數據，以使后續的步驟中能夠調用數據適配器處理這些數據。

5.根據權利要求4所述的異構柜臺并行運行方法，其特征在于，在獲取柜臺的出入金數據的增量數據的過程中，首先將日志系統部署到目標柜臺的機器上；再對日志系統保存的數據進行格式化處理以使其可被數據庫語句識別，作為篩選條件；然后，在執行的數據庫語句中添加對日志系統格式化后數據的調用，以自動篩選出入金數據的增量數據。

6.根據權利要求1所述的異構柜臺并行運行方法，其特征在于，步驟14進一步包括：

先根據源柜臺的不同，使用原柜臺的對應方式處理增量數據，將增量數據轉化為中間格式的數據；

再將中間格式的數據發送給數據分發器。

7.根據權利要求1所述的異構柜臺并行運行方法，其特征在于，步驟15進一步包括：

根據目標柜臺選擇對應的分發適配器；

調用分發適配器前，判斷數據是否需要同步給目標柜臺；

調用分發適配器。