[發(fā)明專利]批量文件分發(fā)處理方法及裝置

在審

• 申請?zhí)枺?/td>: 202011051946.2
• 申請日: 2020-09-29
• 公開（公告）號: CN112131188A
• 公開（公告）日: 2020-12-25
• 發(fā)明（設(shè)計）人: 韓彩
• 申請（專利權(quán)）人: 中國銀行股份有限公司
• 主分類號: G06F16/16
• 分類號: G06F16/16;G06F9/48
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 吳學(xué)鋒;呂俊剛

1.一種批量文件分發(fā)處理方法，其特征在于，包括：

獲取多個待處理文件的文件處理狀態(tài)信息，其中，所述文件處理狀態(tài)信息包括：每個待處理文件對應(yīng)文件處理步驟的執(zhí)行順序和執(zhí)行狀態(tài)；

根據(jù)每個待處理文件對應(yīng)文件處理步驟的執(zhí)行順序，讀取對每個待處理文件進(jìn)行處理的文件處理指令，其中，不同執(zhí)行順序的文件處理步驟對應(yīng)不同的文件處理指令；

將讀取到的對各個待處理文件進(jìn)行處理的文件處理指令，分發(fā)到多個批量處理服務(wù)器，由多個批量處理服務(wù)器根據(jù)接收到的文件處理指令，調(diào)用相應(yīng)的文件處理服務(wù)程序，對各個待處理文件進(jìn)行處理；

根據(jù)處理結(jié)果，更新每個待處理文件對應(yīng)文件處理步驟的執(zhí)行順序和執(zhí)行狀態(tài)。

2.如權(quán)利要求1所述的方法，其特征在于，每個待處理文件對應(yīng)文件處理步驟的執(zhí)行狀態(tài)包括：初始狀態(tài)、處理成功狀態(tài)和處理失敗狀態(tài)，其中，根據(jù)處理結(jié)果，更新每個待處理文件對應(yīng)文件處理步驟的執(zhí)行順序和執(zhí)行狀態(tài)，包括：

如果待處理文件當(dāng)前對應(yīng)的文件處理步驟被成功處理，則將待處理文件當(dāng)前對應(yīng)文件處理步驟的執(zhí)行狀態(tài)由初始狀態(tài)更新為處理成功狀態(tài)；

如果待處理文件當(dāng)前對應(yīng)的文件處理步驟未被成功處理，則將待處理文件當(dāng)前對應(yīng)文件處理步驟的執(zhí)行狀態(tài)更新由初始狀態(tài)更新為處理失敗狀態(tài)。

3.如權(quán)利要求2所述的方法，其特征在于，所述方法還包括：

當(dāng)待處理文件當(dāng)前文件處理步驟的執(zhí)行狀態(tài)為處理成功狀態(tài)的情況下，將待處理文件當(dāng)前文件處理步驟切換為當(dāng)前文件處理步驟的下一個步驟，并更新文件處理步驟的執(zhí)行狀態(tài)為初始狀態(tài)；

當(dāng)待處理文件當(dāng)前文件處理步驟的執(zhí)行狀態(tài)為處理失敗狀態(tài)的情況下，結(jié)束對待處理文件當(dāng)前文件處理步驟的處理。

4.如權(quán)利要求1所述的方法，其特征在于，基于Dubbo和Zookeeper分布式服務(wù)框架，將讀取到的對各個待處理文件進(jìn)行處理的文件處理指令，分發(fā)到多個批量處理服務(wù)器。

5.如權(quán)利要求1所述的方法，其特征在于，獲取多個待處理文件的文件處理狀態(tài)信息，包括：

獲取待處理文件列表，其中，所述待處理文件列表中包含：多個待處理文件的文件信息；

基于Quartz集群的定時任務(wù)，采用定時輪詢的方式，獲取所述待處理文件列表中每個待處理文件的文件處理狀態(tài)信息。

6.如權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

監(jiān)測每個待處理文件對應(yīng)各個文件處理步驟的執(zhí)行狀態(tài)和指令調(diào)用情況；

根據(jù)監(jiān)測結(jié)果，輸出預(yù)警信息，其中，所述預(yù)警信息用于提示執(zhí)行失敗或指令調(diào)用失敗的待處理文件。

7.一種批量文件分發(fā)處理裝置，其特征在于，包括：

文件狀態(tài)獲取模塊，用于獲取多個待處理文件的文件處理狀態(tài)信息，其中，所述文件處理狀態(tài)信息包括：每個待處理文件對應(yīng)文件處理步驟的執(zhí)行順序和執(zhí)行狀態(tài)；

指令讀取模塊，用于根據(jù)每個待處理文件對應(yīng)文件處理步驟的執(zhí)行順序，讀取對每個待處理文件進(jìn)行處理的文件處理指令，其中，不同執(zhí)行順序的文件處理步驟對應(yīng)不同的文件處理指令；

分發(fā)處理模塊，用于將讀取到的對各個待處理文件進(jìn)行處理的文件處理指令，分發(fā)到多個批量處理服務(wù)器，由多個批量處理服務(wù)器根據(jù)接收到的文件處理指令，調(diào)用相應(yīng)的文件處理服務(wù)程序，對各個待處理文件進(jìn)行處理；

文件狀態(tài)更新模塊，用于根據(jù)處理結(jié)果，更新每個待處理文件對應(yīng)文件處理步驟的執(zhí)行順序和執(zhí)行狀態(tài)。

8.如權(quán)利要求7所述的裝置，其特征在于，每個待處理文件對應(yīng)文件處理步驟的執(zhí)行狀態(tài)包括：初始狀態(tài)、處理成功狀態(tài)和處理失敗狀態(tài)，其中，所述文件狀態(tài)更新模塊包括：

第一狀態(tài)更新模塊，用于如果待處理文件當(dāng)前對應(yīng)的文件處理步驟被成功處理，則將待處理文件當(dāng)前對應(yīng)文件處理步驟的執(zhí)行狀態(tài)由初始狀態(tài)更新為處理成功狀態(tài)；

第二狀態(tài)更新模塊，用于如果待處理文件當(dāng)前對應(yīng)的文件處理步驟未被成功處理，則將待處理文件當(dāng)前對應(yīng)文件處理步驟的執(zhí)行狀態(tài)更新由初始狀態(tài)更新為處理失敗狀態(tài)。