[發明專利]一種組織機構數據實時查詢系統

有效

• 申請號: 201910788775.2
• 申請日: 2019-08-26
• 公開（公告）號: CN110597894B
• 公開（公告）日: 2022-03-04
• 發明（設計）人: 舒建輝;李順德;陳浩毅
• 申請（專利權）人: 重慶華醫康道科技有限公司
• 主分類號: G06F16/25
• 分類號: G06F16/25;G06F16/2458;G06F16/28;G06F16/21
• 代理公司: 重慶圖為律師事務所 50287
• 代理人: 雷宇

1.一種組織機構數據實時查詢系統，其特征在于，包括：至少一個組織機構的數據庫、kettle、數據分發器、Flink、OpenApi、外部系統；

每個組織機構的數據庫按照組織機構自身業務需求創建有視圖，所述視圖中的數據用于提供給所述外部系統進行查詢；

在接收到所述外部系統發來的查詢請求時，所述kettle從所述查詢請求對應的所述組織機構的數據庫視圖抽取數據，并將抽取的數據按照預設字段進行字段轉換；

所述數據分發器將進行字段轉換后的數據分發到所述Flink；

所述Flink按照預設格式將分發來的數據進行格式轉換，并將格式轉換后的數據作為查詢結果發送到所述OpenApi；

所述OpenApi將所述查詢結果輸出到所述外部系統；

所述kettle還用于進行輸出文本，在所述kettle用于進行輸出文本時，還包括容錯檢查系統，所述輸出文本用于為所述容錯檢查系統提供數據來源；所述容錯檢查系統發現有錯的數據時，推送到另外單獨配置路由KEY的Kafka，由所述Flink接受處理，所述OpenApi單獨提供對外的接口，包括緩存的更新同步；對于已經上鏈的情況，按照預設處理規則進行處理，并且所述外部系統實時調用所述OpenApi的接口來處理容錯。

2.根據權利要求1所述的組織機構數據實時查詢系統，其特征在于，所述OpenApi還用于對所述查詢結果進行脫敏處理、和/或加密處理后輸出到所述外部系統。

3.根據權利要求1所述的組織機構數據實時查詢系統，其特征在于，還包括區塊鏈云平臺，所述OpenApi將所述查詢結果發送到所述區塊鏈云平臺進行存儲。

4.根據權利要求3所述的組織機構數據實時查詢系統，其特征在于，所述OpenApi還用于對所述查詢結果進行壓縮處理，并發送到所述區塊鏈云平臺進行存儲。

5.根據權利要求3所述的組織機構數據實時查詢系統，其特征在于，所述區塊鏈云平臺中存儲有的查詢結果，支持在接收到所述外部系統發來的查詢請求時直接從所述區塊鏈云平臺輸出到所述外部系統。

6.根據權利要求1至5任一項所述的組織機構數據實時查詢系統，其特征在于，還包括數據倉庫，所述Flink還用于將所述查詢結果存入所述數據倉庫，所述數據倉庫用于供BI讀取后所述BI對數據進行挖掘、統計、分析中至少一種。

7.根據權利要求1至5任一項所述的組織機構數據實時查詢系統，其特征在于，所述kettle還用于進行日志監控、Job監控中至少一種。

8.根據權利要求1至5任一項所述的組織機構數據實時查詢系統，其特征在于，所述Flink還用于將格式轉換后的數據進行清洗、聚合操作中至少一種，將進行清洗、聚合操作中至少一種后的數據作為查詢結果發送到所述OpenApi進行輸出。

9.根據權利要求1至5任一項所述的組織機構數據實時查詢系統，其特征在于，所述kettle還用于整合kafka-provider插件的程序同步數據到所述數據分發器，所述數據分發器包括Kafka和Zookeer的集群。