[發明專利]基金交易清算方法、裝置、設備及計算機可讀存儲介質

有效

• 申請號: 201810045530.6
• 申請日: 2018-01-17
• 公開（公告）號: CN107993151B
• 公開（公告）日: 2020-12-29
• 發明（設計）人: 白雪峰;王斌;黃志文;安棟;宋先優;李強;郭錦玉;尹方敏
• 申請（專利權）人: 平安科技（深圳）有限公司
• 主分類號: G06Q40/04
• 分類號: G06Q40/04
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 林燕云

1.一種基金交易清算方法，其特征在于，包括：

向Hadoop平臺導入新增的若干基金交易數據；

根據所述若干基金交易數據的基金特性對所述若干基金交易數據進行劃分，將劃分后的所述若干基金交易數據分別保存在Hadoop平臺對應的數據分區內；

將所述數據分區內的所述基金交易數據導入Spark平臺的RDD分區，所述RDD分區與所述數據分區一一對應；

將所述RDD分區內的所述基金交易數據均勻分配至若干清算任務；

基于分布式計算對所述若干清算任務進行處理，以完成對所述基金交易數據的清算；

其中，所述基于分布式計算對所述若干清算任務進行處理，以完成對所述基金交易數據的清算，包括：

將所述若干清算任務動態均勻地分配到多個計算節點；

獲取清算邏輯程序；

利用所述多個計算節點根據所述清算邏輯程序對所述若干清算任務中的基金交易數據進行清算；

所述將所述若干清算任務動態均勻地分配到多個計算節點的步驟包括：

在處理所述清算任務的過程中，根據所述清算任務被處理的效率動態地改變所述計算節點的待處理清算任務的數量。

2.根據權利要求1所述的基金交易清算方法，其特征在于，所述基金交易數據包括基金賬號，所述基金特性為所述基金賬號；

所述根據所述若干基金交易數據的基金特性對所述若干基金交易數據進行劃分，將劃分后的所述若干基金交易數據分別保存在Hadoop平臺對應的數據分區內，包括：

分別對每個基金賬號進行哈希處理，得到每條基金交易數據對應的哈希值，所述哈希值為一串數字；

分別將每條基金交易數據的哈希值的所有數字各自相加得到和；

將所述和除以預設數得到余數，其中，所述預設數為數據分區的總數；

將所述每條基金交易數據保存在所述余數對應的Hadoop平臺的數據分區內。

3.根據權利要求1所述的基金交易清算方法，其特征在于，所述利用所述多個計算節點根據所述清算邏輯程序對所述若干清算任務中的基金交易數據進行清算，包括：

判斷所述基金交易數據的基金賬戶是否為合法賬戶；

若所述基金賬戶為合法賬戶，則判斷所述基金交易數據是否合法；

若所述基金交易數據合法，則計算所述基金賬戶的交易純份額；

根據所述基金交易純份額計算所述基金賬戶的收益；

將所述收益分配到所述基金賬戶。

4.根據權利要求1所述的基金交易清算方法，其特征在于，所述基于分布式計算對所述若干清算任務進行處理，以完成對所述基金交易數據的清算之后，還包括：

將清算結束后的清算結果保存在Hadoop平臺的所述基金交易數據對應的數據分區。

5.一種基金交易清算裝置，其特征在于，包括：

第一導入單元，用于向Hadoop平臺導入新增的若干基金交易數據；

數據分區單元，根據所述若干基金交易數據的基金特性對所述若干基金交易數據進行劃分，將劃分后的所述若干基金交易數據分別保存在Hadoop平臺對應的數據分區內；

第二導入單元，用于將所述數據分區內的所述基金交易數據導入Spark平臺的RDD分區，所述RDD分區與所述數據分區一一對應；

分配單元，用于將所述RDD分區內的所述基金交易數據均勻分配至若干清算任務；

清算單元，用于基于分布式計算對所述若干清算任務進行處理，以完成對所述基金交易數據的清算；

其中，所述清算單元，包括：

分配子單元，用于將所述若干清算任務動態均勻地分配到多個計算節點；

獲取子單元，用于獲取清算邏輯程序；

清算子單元，用于利用所述多個計算節點根據所述清算邏輯程序對所述若干清算任務中的基金交易數據進行清算；

所述分配子單元，具體用于在處理所述清算任務的過程中，根據所述清算任務被處理的效率動態地改變所述計算節點的待處理清算任務的數量。