[發明專利]分筆成交的高效處理方法及系統

無效

• 申請號: 201010103947.7
• 申請日: 2010-01-26
• 公開（公告）號: CN101770632A
• 公開（公告）日: 2010-07-07
• 發明（設計）人: 鄧志國;何仲君;陳飛;王仁云;張國強
• 申請（專利權）人: 恒生電子股份有限公司
• 主分類號: G06Q40/00
• 分類號: G06Q40/00
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 趙景平;逯長明

1.一種分筆成交的高效處理方法，其特征在于，包括：

讀線程逐筆讀取成交記錄，根據所述成交記錄對應的申請編號將讀取的成交記錄存放到對應該申請編號的一個或多個節點，并將所述節點加入到已讀隊列中；

發送線程從所述已讀隊列中讀取所述節點，并將所述節點中的分筆成交數據加入到發送隊列中；

發送線程并行發送所述發送隊列中對應不同申請編號的多個節點中的分筆成交數據給交易后臺；

應答處理線程接收到所述交易后臺返回對應所述節點的分筆成交數據的處理結果后，將所述節點從所述發送隊列中刪除。

2.根據權利要求1所述的方法，其特征在于，所述讀線程讀取成交記錄包括：

讀線程從交易接口庫逐筆讀取成交記錄。

3.根據權利要求1所述的方法，其特征在于，所述根據所述成交記錄對應的申請編號將讀取的成交記錄存放到對應該申請編號的一個或多個節點，并將所述節點加入到已讀隊列中包括：

根據所述成交記錄對應的申請編號檢查當前讀取的成交記錄是否為讀取的上一筆成交記錄的分筆成交數據；

如果不是，則將所述當前讀取的成交記錄的分筆成交數據保存到對應該申請編號的節點，并將所述節點加入到已讀隊列中；

如果是，則將所述當前讀取的成交記錄的分筆成交數據與上一筆成交記錄的分筆成交數據合并保存到對應該申請編號的節點，并在所述節點存滿后，將所述節點加入到已讀隊列中。

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

根據合并保存的分筆成交記錄的分筆數確定所述節點是否存滿；

如果所述分筆數達到預設的最大值，則確定所述節點已存滿。

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

發送線程將一個節點中的分筆成交數據加入到發送隊列中后，將所述節點對應的申請編號設置為在途狀態；

所述發送線程從所述已讀隊列中讀取所述節點，并將所述節點中的分筆成交數據加入到發送隊列中包括：

發送線程從所述已讀隊列中讀取一個節點；

如果該節點對應的申請編號為在途狀態，則將該節點作為發送隊列中所述申請編號為在途狀態的節點的下一個節點。

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

所述應答處理線程將所述節點從所述發送隊列中刪除后，檢查所述發送隊列中是否還有與所述節點對應的申請編號相同的其他節點；

如果是，則所述應答處理線程依次發送所述其他節點；

如果否，則所述應答處理線程將所述節點對應的申請編號設置為非在途狀態。

7.一種分筆成交的高效處理系統，其特征在于，包括：

讀取單元，用于逐筆讀取成交記錄，根據所述成交記錄對應的申請編號將讀取的成交記錄存放到對應該申請編號的一個或多個節點，并將所述節點加入到已讀隊列中；

發送單元，用于從所述已讀隊列中讀取所述節點，并將所述節點中的分筆成交數據加入到發送隊列中；并且并行發送所述發送隊列中對應不同申請編號的多個節點中的分筆成交數據給交易后臺；

應答處理單元，用于接收所述交易后臺返回對應所述節點的分筆成交數據的處理結果，并在接收到所述處理結果后，將所述節點從所述發送隊列中刪除。

8.根據權利要求1所述的系統，其特征在于，所述讀取單元包括：

成交記錄讀取子單元，用于從交易接口庫逐筆讀取成交記錄；

緩存子單元，用于緩存所述讀取子單元讀取的成交記錄；

第一檢查子單元，用于根據所述成交記錄對應的申請編號檢查所述讀取子單元當前讀取的成交記錄是否為讀取的上一筆成交記錄的分筆成交數據；如果不是，則將所述當前讀取的成交記錄的分筆成交數據保存到對應該申請編號的節點，并將所述節點加入到已讀隊列中；如果是，則將所述當前讀取的成交記錄的分筆成交數據與上一筆成交記錄的分筆成交數據合并保存到對應該申請編號的節點，并在所述節點存滿后，將所述節點加入到已讀隊列中。

9.根據權利要求1所述的系統，其特征在于，所述發送單元包括：

節點讀取子單元，用于從所述已讀隊列中讀取所述節點，并將所述節點中的分筆成交數據加入到發送隊列中；

并行發送子單元，用于并行發送所述發送隊列中對應不同申請編號的多個節點中的分筆成交數據給交易后臺。