[發(fā)明專利]業(yè)務(wù)數(shù)據(jù)處理方法、裝置、計(jì)算機(jī)設(shè)備和存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110205415.2
• 申請(qǐng)日: 2021-02-24
• 公開（公告）號(hào): CN113010306A
• 公開（公告）日: 2021-06-22
• 發(fā)明（設(shè)計(jì)）人: 胡世海;王鍇;趙宇;楊占琛
• 申請(qǐng)（專利權(quán)）人: 金蝶軟件（中國(guó)）有限公司
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50;G06F9/448
• 代理公司: 廣州華進(jìn)聯(lián)合專利商標(biāo)代理有限公司 44224
• 代理人: 鄧云鵬

1.一種業(yè)務(wù)數(shù)據(jù)處理方法，其特征在于，所述方法包括：

獲取不同業(yè)務(wù)類型的業(yè)務(wù)數(shù)據(jù)以及預(yù)配置的各所述業(yè)務(wù)類型對(duì)應(yīng)的業(yè)務(wù)操作邏輯；

根據(jù)所述業(yè)務(wù)數(shù)據(jù)，分別生成與所述業(yè)務(wù)類型對(duì)應(yīng)的各子事件任務(wù)；所述子事件任務(wù)用于基于所述業(yè)務(wù)類型對(duì)應(yīng)的業(yè)務(wù)操作邏輯組合成目標(biāo)事件任務(wù)；

針對(duì)每一個(gè)所述子事件任務(wù)，將所述子事件任務(wù)與對(duì)應(yīng)的服務(wù)進(jìn)行綁定；

分別將所述子事件任務(wù)分發(fā)至與所述服務(wù)對(duì)應(yīng)的各處理服務(wù)器，以指示各所述處理服務(wù)器異步處理所述子事件任務(wù)；

接收各所述處理服務(wù)器異步處理所述子事件任務(wù)后所反饋的子處理結(jié)果，并將各所述子處理結(jié)果進(jìn)行匯總處理，得到所述目標(biāo)事件任務(wù)的目標(biāo)處理結(jié)果。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述接收各所述處理服務(wù)器異步處理所述子事件任務(wù)后所反饋的子處理結(jié)果，并將各所述子處理結(jié)果進(jìn)行匯總處理，得到所述目標(biāo)事件任務(wù)的目標(biāo)處理結(jié)果，包括：

對(duì)所述子事件任務(wù)的處理狀態(tài)進(jìn)行實(shí)時(shí)監(jiān)控；

當(dāng)歸屬于同一個(gè)目標(biāo)事件任務(wù)的所有子事件任務(wù)全部處理結(jié)束后，獲取各所述子事件任務(wù)的子處理結(jié)果；

將各所述子事件任務(wù)的子處理結(jié)果進(jìn)行匯總處理，得到所述目標(biāo)事件任務(wù)的目標(biāo)處理結(jié)果。

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

當(dāng)歸屬于同一個(gè)目標(biāo)事件任務(wù)的任一個(gè)子事件任務(wù)處理結(jié)束后，生成對(duì)應(yīng)的中間態(tài)提示信息；

將所述中間態(tài)提示信息發(fā)送至所述目標(biāo)事件任務(wù)對(duì)應(yīng)的終端。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述分別將所述子事件任務(wù)分發(fā)至與所述服務(wù)對(duì)應(yīng)的各處理服務(wù)器之后，所述方法還包括：

查詢是否存在與所述子事件任務(wù)對(duì)應(yīng)的任務(wù)分發(fā)成功信息；

當(dāng)查詢到所述任務(wù)分發(fā)成功信息、且接收到與所述任務(wù)分發(fā)成功信息對(duì)應(yīng)的任務(wù)接收成功信息時(shí)，判定所述子事件任務(wù)分發(fā)成功；所述任務(wù)接收成功信息是所述處理服務(wù)器在接收到所述子事件任務(wù)后所生成的；

當(dāng)未查詢到所述任務(wù)分發(fā)成功信息，和/或未接收到與所述任務(wù)分發(fā)成功信息對(duì)應(yīng)的任務(wù)接收成功信息時(shí)，判定所述子事件任務(wù)分發(fā)失敗。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述方法還包括：

當(dāng)所述子事件任務(wù)分發(fā)失敗時(shí)，生成失敗告警信息；

根據(jù)所述失敗告警信息，返回所述分別將所述子事件任務(wù)分發(fā)至與所述服務(wù)對(duì)應(yīng)的各處理服務(wù)器的步驟以繼續(xù)執(zhí)行，直至所述子事件任務(wù)分發(fā)成功。

6.根據(jù)權(quán)利要求1至5中任一項(xiàng)所述的方法，其特征在于，所述方法還包括：

對(duì)所述處理服務(wù)器的服務(wù)狀態(tài)進(jìn)行實(shí)時(shí)監(jiān)控；

當(dāng)所述處理服務(wù)器的服務(wù)狀態(tài)異常時(shí)，從所述處理服務(wù)器所在的服務(wù)器集群中選擇一臺(tái)服務(wù)狀態(tài)正常的處理服務(wù)器；

將已分發(fā)至所述服務(wù)狀態(tài)異常的處理服務(wù)器的子事件任務(wù)，重新分發(fā)至所述服務(wù)狀態(tài)正常的處理服務(wù)器。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，所述方法還包括：

當(dāng)所述服務(wù)狀態(tài)異常的處理服務(wù)器恢復(fù)服務(wù)時(shí)，根據(jù)所述子事件任務(wù)的任務(wù)標(biāo)識(shí)，判斷所述子事件任務(wù)是否已被所述服務(wù)器集群中的其他處理服務(wù)器進(jìn)行處理；

當(dāng)所述子事件任務(wù)已被所述服務(wù)器集群中的其他處理服務(wù)器進(jìn)行處理時(shí)，通知恢復(fù)服務(wù)的所述處理服務(wù)器過濾所述任務(wù)標(biāo)識(shí)對(duì)應(yīng)的子事件任務(wù)；

當(dāng)所述子事件任務(wù)未被所述服務(wù)器集群中的其他處理服務(wù)器進(jìn)行處理時(shí)，通知恢復(fù)服務(wù)的所述處理服務(wù)器處理所述任務(wù)標(biāo)識(shí)對(duì)應(yīng)的子事件任務(wù)。