[發明專利]數據處理的方法及裝置

有效

• 申請號: 201710083493.3
• 申請日: 2017-02-16
• 公開（公告）號: CN107798614B
• 公開（公告）日: 2020-07-14
• 發明（設計）人: 趙莫*
• 申請（專利權）人: 平安科技（深圳）有限公司
• 主分類號: G06Q40/08
• 分類號: G06Q40/08
• 代理公司: 深圳中一專利商標事務所 44237
• 代理人: 陽開亮

1.一種數據處理的方法，其特征在于，所述方法包括：

在保單匯總數據庫中部署批處理腳本，所述批處理腳本根據PROPHET軟件的數據處理邏輯編寫得到；

在對保單匯總數據進行處理時，獲取用戶觸發的調度任務；

執行所述調度任務對應的批處理腳本，從所述保單匯總數據庫中讀取所述調度任務對應的源表數據，并模擬所述PROPHET的處理邏輯對所述源表數據進行轉換及分析；

所述獲取用戶觸發的調度任務包括：

當獲取到用戶輸入的運行指令時，對指定機構庫進行kettle同步；

若同步成功時，在計劃表Pala_batch_plan中插入指定數量的調度任務，以供存儲過程掃描執行；

若同步失敗時，彈出提示信息，以提示用戶未完成同步的機構庫并在確認所述機構庫完成同步后進行補執行。

2.如權利要求1所述的數據處理的方法，其特征在于，所述執行所述調度任務對應的批處理腳本，從所述保單匯總數據庫中讀取所述調度任務對應的源表數據，并模擬所述PROPHET的處理邏輯對所述源表數據進行轉換及分析包括：

按照預設的時間間隔掃描所述計劃表pala_batch_plan，獲取最先的調度任務；

根據所述調度任務執行對應的批處理腳本，從所述保單匯總數據庫中讀取所述調度任務對應的源表數據，并模擬所述PROPHET的處理邏輯對所述源表數據進行轉換及分析；

根據調度任務的執行結果，更新日志表pol_ben_log中調度任務對應的狀態信息。

3.如權利要求2所述的數據處理的方法，其特征在于，所述方法還包括：

若調度任務執行成功時，根據用戶輸入的查看指令，顯示所述日志表pol_ben_log中的更新結果。

4.如權利要求2所述的數據處理的方法，其特征在于，所述方法還包括：

若調度任務執行失敗時，進行補執行，對當前機構庫進行kettle同步；

若同步成功時，在所述計劃表Pala_batch_plan中插入1條調度任務，以供存儲過程掃描執行。

5.一種數據處理的裝置，其特征在于，所述裝置包括：

部署模塊，用于在保單匯總數據庫中部署批處理腳本，所述批處理腳本根據PROPHET軟件的數據處理邏輯編寫得到；

獲取模塊，用于在對保單匯總數據進行處理時，獲取用戶觸發的調度任務；

執行模塊，用于執行所述調度任務對應的批處理腳本，從所述保單匯總數據庫中讀取所述調度任務對應的源表數據，并模擬所述PROPHET的處理邏輯對所述源表數據進行轉換及分析；

所述獲取模塊包括：

同步單元，用于當獲取到用戶輸入的運行指令時，對指定機構庫進行kettle同步；

任務插入單元，用于若同步成功時，在計劃表Pala_batch_plan中插入指定數量的調度任務，以供存儲過程掃描執行；

提示單元，用于若同步失敗時，彈出提示信息，以提示用戶未完成同步的機構庫并在確認所述機構庫完成同步后進行補執行。

6.如權利要求5所述的數據處理的裝置，其特征在于，所述執行模塊包括：

掃描單元，用于按照預設的時間間隔掃描所述計劃表pala_batch_plan，獲取最先的調度任務；

執行單元，用于根據所述調度任務執行對應的批處理腳本，從所述保單匯總數據庫中讀取所述調度任務對應的源表數據，并模擬所述PROPHET的處理邏輯對所述源表數據進行轉換及分析；

更新單元，用于根據調度任務的執行結果，更新日志表pol_ben_log中調度任務對應的狀態信息。

7.如權利要求6所述的數據處理的裝置，其特征在于，所述執行模塊還包括：

查看單元，用于若調度任務執行成功時，根據用戶輸入的查看指令，顯示所述日志表pol_ben_log中的更新結果。

8.如權利要求6所述的數據處理的裝置，其特征在于，所述執行模塊還包括：

補執行單元，用于若調度任務執行失敗時，進行補執行，對當前機構庫進行kettle同步；若同步成功時，在所述計劃表Pala_batch_plan中插入1條調度任務，以供存儲過程掃描執行。