[發(fā)明專利]函件批處理方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010182241.8
• 申請(qǐng)日: 2020-03-16
• 公開（公告）號(hào): CN111444013A
• 公開（公告）日: 2020-07-24
• 發(fā)明（設(shè)計(jì)）人: 丘健
• 申請(qǐng)（專利權(quán)）人: 中國(guó)平安人壽保險(xiǎn)股份有限公司
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50;G06F9/54;G06F9/448
• 代理公司: 北京市京大律師事務(wù)所 11321
• 代理人: 劉挽瀾

1.一種函件批處理方法，其特征在于，包括：

對(duì)目標(biāo)業(yè)務(wù)系統(tǒng)中的函件數(shù)據(jù)添加函件編碼，并按所述函件編碼對(duì)所述函件數(shù)據(jù)進(jìn)行排序，所述函件數(shù)據(jù)的狀態(tài)包括待生成函件狀態(tài)和已生成函件狀態(tài)；

根據(jù)所述函件數(shù)據(jù)的狀態(tài)，分頁查詢并獲取待生成函件狀態(tài)的函件數(shù)據(jù)，所述待生成函件狀態(tài)的函件數(shù)據(jù)為待生成推送函件的數(shù)據(jù)；

對(duì)所述待生成函件狀態(tài)的函件數(shù)據(jù)添加待轉(zhuǎn)換狀態(tài)標(biāo)識(shí)，對(duì)所述已生成函件狀態(tài)的函件數(shù)據(jù)添加已轉(zhuǎn)換狀態(tài)標(biāo)識(shí)；

根據(jù)所述待生成函件狀態(tài)的函件數(shù)據(jù)的數(shù)量級(jí)，實(shí)時(shí)配置線程池中的線程數(shù)目；根據(jù)所述待生成函件狀態(tài)的函件數(shù)據(jù)對(duì)應(yīng)的待生成函件任務(wù)生成任務(wù)隊(duì)列，所述待生成函件任務(wù)為處理所述待生成函件狀態(tài)的函件數(shù)據(jù)中正在生成推送函件的任務(wù)；

調(diào)用線程池中的線程，使用基于遠(yuǎn)程字典服務(wù)實(shí)現(xiàn)的分布式事物鎖并行處理所述任務(wù)隊(duì)列中的待生成函件任務(wù)，批量生成所述待生成函件狀態(tài)的函件數(shù)據(jù)對(duì)應(yīng)的推送函件。

2.根據(jù)權(quán)利要求1所述的函件批處理方法，其特征在于，所述使用基于遠(yuǎn)程字典服務(wù)實(shí)現(xiàn)的分布式事物鎖并行處理所述任務(wù)隊(duì)列中的待生成函件任務(wù)包括：

使用基于遠(yuǎn)程字典服務(wù)實(shí)現(xiàn)的分布式事物鎖鎖住所述待生成函件狀態(tài)的函件數(shù)據(jù)中正在生成推送函件的函件數(shù)據(jù)；

獲取對(duì)應(yīng)鎖定狀態(tài)的函件數(shù)據(jù)，并將所述鎖定狀態(tài)的函件數(shù)據(jù)的待轉(zhuǎn)換狀態(tài)標(biāo)識(shí)修改為鎖定狀態(tài)標(biāo)識(shí)；

使用輸入輸出字符流和預(yù)置工具包將所述鎖定狀態(tài)的函件數(shù)據(jù)和預(yù)置函件模板數(shù)據(jù)組裝成超文本標(biāo)記語言格式數(shù)據(jù)；

使用輸入輸出文件流將所述超文本標(biāo)記語言格式數(shù)據(jù)生成對(duì)應(yīng)的超文本標(biāo)記語言格式文件；

使用預(yù)置格式轉(zhuǎn)換插件將所述超文本標(biāo)記語言格式文件轉(zhuǎn)換為對(duì)應(yīng)的便攜式文檔格式的推送函件；

將所述便攜式文檔格式的推送函件對(duì)應(yīng)的函件數(shù)據(jù)的鎖定狀態(tài)標(biāo)識(shí)修改為已轉(zhuǎn)換狀態(tài)標(biāo)識(shí)；

將所述便攜式文檔格式的推送函件上傳至需要所述推送函件的業(yè)務(wù)系統(tǒng)；

釋放所述分布式事物鎖，并判定所述鎖定狀態(tài)的函件數(shù)據(jù)對(duì)應(yīng)的待生成函件任務(wù)處理完成。

3.根據(jù)權(quán)利要求1所述的函件批處理方法，其特征在于，所述調(diào)用線程池中的線程，使用基于遠(yuǎn)程字典服務(wù)實(shí)現(xiàn)的分布式事物鎖并行處理所述任務(wù)隊(duì)列中的待生成函件任務(wù)，批量生成所述待生成函件狀態(tài)的函件數(shù)據(jù)對(duì)應(yīng)的推送函件之后，包括：

接收用戶的函件下發(fā)請(qǐng)求；

根據(jù)所述函件下發(fā)請(qǐng)求查找對(duì)應(yīng)的已生成推送函件；

調(diào)用線程池中的線程將所述對(duì)應(yīng)的已生成推送函件發(fā)送至所述用戶。

4.根據(jù)權(quán)利要求2所述的函件批處理方法，其特征在于，所述使用輸入輸出文件流將所述超文本標(biāo)記語言格式數(shù)據(jù)生成對(duì)應(yīng)的超文本標(biāo)記語言格式文件之后，包括：

判斷所述將所述超文本標(biāo)記語言格式數(shù)據(jù)生成對(duì)應(yīng)的超文本標(biāo)記語言格式文件是否成功；

若判斷出生成不成功，則釋放所述分布式事物鎖，并判定所述鎖定狀態(tài)的函件數(shù)據(jù)對(duì)應(yīng)的待生成函件任務(wù)處理完成。

5.根據(jù)權(quán)利要求2所述的函件批處理方法，其特征在于，所述使用預(yù)置格式轉(zhuǎn)換插件將所述超文本標(biāo)記語言格式文件轉(zhuǎn)換為對(duì)應(yīng)的便攜式文檔格式的推送函件之后，包括：

判斷所述將所述超文本標(biāo)記語言格式文件轉(zhuǎn)換為對(duì)應(yīng)的便攜式文檔格式的推送函件是否成功；

若判斷出轉(zhuǎn)換不成功，則釋放所述分布式事物鎖，并判定所述鎖定狀態(tài)的函件數(shù)據(jù)對(duì)應(yīng)的待生成函件任務(wù)處理完成。

6.根據(jù)權(quán)利要求2所述的函件批處理方法，其特征在于，所述使用基于遠(yuǎn)程字典服務(wù)實(shí)現(xiàn)的分布式事物鎖鎖住待生成函件狀態(tài)的函件數(shù)據(jù)中正在生成推送函件的函件數(shù)據(jù)，包括：

使用基于遠(yuǎn)程字典服務(wù)獲取分布式事物鎖；

根據(jù)所述分布式事務(wù)鎖將所述正在生成推送函件的函件數(shù)據(jù)對(duì)應(yīng)的線程進(jìn)行加鎖，得到對(duì)應(yīng)鎖定狀態(tài)的函件數(shù)據(jù)。