#工作流任務(wù)數(shù)據(jù)一致性解決方案案例馮文化黎慶劍一、系統(tǒng)概述工作流系統(tǒng)和業(yè)務(wù)系統(tǒng)的部署關(guān)系核心征管系統(tǒng)包括納稅人管理、申報(bào)征收、發(fā)票管理、風(fēng)險(xiǎn)管理等4個(gè)業(yè)務(wù)子系統(tǒng)和1個(gè)工作流子系統(tǒng)。它們?cè)诓渴鹕戏殖汕岸撕秃蠖?，前端是一個(gè)統(tǒng)一Web應(yīng)用，工作流引擎在后端，與其他子系統(tǒng)分布部署。各子系統(tǒng)通過(guò)集成平臺(tái)聯(lián)合在一起。應(yīng)用部署邏輯架構(gòu)如下圖所示。集成半臺(tái)核心征管

前端系統(tǒng)核心征管后;端子系統(tǒng)核心征管工作流系統(tǒng)I工作流接口調(diào)用序列圖U曠

核心征管業(yè)務(wù)數(shù)據(jù)庫(kù)（示端）核心征管工作流數(shù)據(jù)庫(kù)前喘頁(yè)面前端■Ctr:.集成平臺(tái)...■業(yè)務(wù)系統(tǒng)（后喘）:.集成平臺(tái)...1I丄作流系統(tǒng)，出前喘頁(yè)面前端■Ctr:.集成平臺(tái)...■業(yè)務(wù)系統(tǒng)（后喘）:.集成平臺(tái)...1I丄作流系統(tǒng)，出點(diǎn)擊按鈕調(diào)用業(yè)務(wù)服務(wù)執(zhí)行業(yè)務(wù)服務(wù)調(diào)用推送任務(wù)服務(wù)返回消息?返回消息.執(zhí)行:推送■■-任務(wù):服務(wù)以推送任務(wù)為例，其序列圖如下：1）服務(wù)消費(fèi)方通過(guò)ESB調(diào)用業(yè)務(wù)子系統(tǒng)的業(yè)務(wù)服務(wù)，業(yè)務(wù)子系統(tǒng)執(zhí)行該業(yè)務(wù)服務(wù)；2）業(yè)務(wù)子系統(tǒng)業(yè)務(wù)處理結(jié)束后，再通過(guò)ESB調(diào)用工作流子系統(tǒng)的推送任務(wù)服務(wù)；3）工作流子系統(tǒng)的推送任務(wù)服務(wù)結(jié)束后返回消息到業(yè)務(wù)子系統(tǒng)，業(yè)務(wù)子系統(tǒng)把相關(guān)處理結(jié)果最終返回給服務(wù)消費(fèi)方。二、任務(wù)數(shù)據(jù)一致性方案設(shè)計(jì)方案概述本方案采取任務(wù)對(duì)賬機(jī)制，解決工作流異常時(shí)造成的業(yè)務(wù)系統(tǒng)和工作流系統(tǒng)任務(wù)數(shù)據(jù)不一致的問(wèn)題。這是一種事后的補(bǔ)救機(jī)制。這種機(jī)制的目的是，當(dāng)業(yè)務(wù)成功、流程失敗時(shí)（約定系統(tǒng)一般先處理業(yè)務(wù)，再處理工作流），系統(tǒng)允許任務(wù)重做，保證任務(wù)可以再次被正確辦理。方案思路在核心征管的后端子系統(tǒng)和工作流子系統(tǒng)中分別記錄任務(wù)的基本信息，用來(lái)進(jìn)行任務(wù)對(duì)賬。業(yè)務(wù)系統(tǒng)，對(duì)賬信息記錄在“任務(wù)對(duì)賬信息表（BIZ_WF）”里；工作流系統(tǒng)，記錄在“流轉(zhuǎn)歷史表”里，如下圖所示：任務(wù)的對(duì)賬機(jī)制保證任務(wù)重做時(shí)，業(yè)務(wù)表單的相關(guān)信息被自動(dòng)帶入，不必重新填寫，直接提交進(jìn)行工作流操作。

任務(wù)對(duì)賬信息表任務(wù)對(duì)賬信息表（BIZ_WF）、工作流的流轉(zhuǎn)歷史表里的任務(wù)對(duì)賬信息應(yīng)包含以下內(nèi)容:流程稅務(wù)事項(xiàng)代碼、業(yè)務(wù)實(shí)例號(hào)、流程實(shí)例號(hào)流程稅務(wù)事項(xiàng)代碼、業(yè)務(wù)實(shí)例號(hào)、流程實(shí)例號(hào)、活動(dòng)實(shí)例號(hào)、工作項(xiàng)代碼、多事件實(shí)例號(hào)、操作類型編碼、操作人員代碼、操作人員崗位代碼、操作人員機(jī)構(gòu)代碼、流程狀態(tài)//唯一確定一個(gè)業(yè)務(wù)實(shí)例，啟動(dòng)流程時(shí)類似流程實(shí)例號(hào)，推送任務(wù)是類似工作項(xiàng)代碼。//該標(biāo)記唯一確定工作流引擎的一個(gè)流程實(shí)例，也唯一對(duì)應(yīng)一個(gè)稅務(wù)事項(xiàng)實(shí)例//該標(biāo)記唯一確定工作流引擎的一個(gè)活動(dòng)實(shí)例，也唯一對(duì)應(yīng)一個(gè)業(yè)務(wù)功能實(shí)例//唯一標(biāo)識(shí)正在辦理的任務(wù)//一個(gè)多事件的唯一標(biāo)識(shí)//啟動(dòng)流程為1,推送任務(wù)為2,取回任務(wù)3,回退任務(wù)4,作廢流程5,作廢活動(dòng)6//當(dāng)前任務(wù)操作者代碼，唯一確定該操作者//當(dāng)前任務(wù)操作者崗位代碼//當(dāng)前任務(wù)操作者崗位代碼//0表示流程正常，1表示異常，2表示狀態(tài)不明，3表示已重新提交對(duì)賬信息的記錄1、業(yè)務(wù)系統(tǒng)的任務(wù)對(duì)賬信息表BIZ_WF：1）業(yè)務(wù)調(diào)工作流而工作流異常時(shí)，業(yè)務(wù)系統(tǒng)首先把異常任務(wù)對(duì)賬信息記錄到log日志中,然后再向“任務(wù)對(duì)賬信息表”里插入該對(duì)賬信息。2）異常任務(wù)被再次提交，成功處理后，業(yè)務(wù)系統(tǒng)首先把處理信息記錄到log日志中，然后再向“任務(wù)對(duì)賬信息表”里插入該信息。以上log日志比BIZ_WF表里的信息多個(gè)字段：記錄類型：【1（異常保存），2（重做刪除）】。2、工作流系統(tǒng)的流轉(zhuǎn)歷史表：工作流的每步流轉(zhuǎn)，工作流引擎向“流轉(zhuǎn)歷史表”中插入任務(wù)對(duì)賬信息。三、任務(wù)對(duì)賬過(guò)程說(shuō)明任務(wù)對(duì)賬，分任務(wù)辦理時(shí)系統(tǒng)自動(dòng)對(duì)賬和手工對(duì)賬兩種方式。手工對(duì)賬是指當(dāng)工作流異常但在業(yè)務(wù)系統(tǒng)里的“任務(wù)對(duì)賬信息表”里沒(méi)有寫入異常對(duì)賬信息時(shí)，系統(tǒng)管理員使用任務(wù)對(duì)賬用例工具通過(guò)對(duì)日志文件、工作流的流轉(zhuǎn)歷史表里的信息對(duì)比，在“任務(wù)對(duì)賬信息表BIZ_WF”中重新插入對(duì)賬信息的過(guò)程。任務(wù)辦理時(shí)系統(tǒng)自動(dòng)對(duì)賬是指在異常任務(wù)在重新辦理時(shí)，系統(tǒng)根據(jù)流程實(shí)例號(hào)、工作項(xiàng)項(xiàng)代碼等信息通過(guò)“任務(wù)對(duì)賬信息表”里的異常對(duì)賬信息進(jìn)行對(duì)賬而重新辦理任務(wù)的過(guò)程。下面描述一下手工對(duì)賬和自動(dòng)對(duì)賬的過(guò)程。手工對(duì)賬過(guò)程手工任務(wù)對(duì)賬，系統(tǒng)管理員通過(guò)一個(gè)獨(dú)立的對(duì)賬用例完成。手工對(duì)賬過(guò)程如下：1）根據(jù)時(shí)間段解析異常任務(wù)對(duì)賬信息日志文件（比如bizlog_20141010_01.log）,與BIZ_WF里的信息對(duì)比，如果BIZ_WF表里缺少記錄則自動(dòng)補(bǔ)錄異常對(duì)賬信息；2）如果log中的異常任務(wù)的對(duì)賬信息為“狀態(tài)不明（即為工作流超時(shí)異常）”，則根據(jù)流程實(shí)例號(hào)、工作項(xiàng)代碼再到工作流系統(tǒng)中的流轉(zhuǎn)歷史表里進(jìn)行信息對(duì)賬，矯正BIZ_WF表里的“狀態(tài)不明”為“正常”或者“異常”。對(duì)賬情況如下表所示。log文件任務(wù)對(duì)賬信息表BIZWF流轉(zhuǎn)歷史表BIZ_WF對(duì)賬后某段時(shí)間內(nèi)有m條異常任務(wù)該段時(shí)間內(nèi)有n（nvm）條（不參與對(duì)賬）自動(dòng)補(bǔ)錄m-n條某條為狀態(tài)不明該條為狀態(tài)不明該條任務(wù)狀態(tài)明確更改為實(shí)際狀態(tài)任務(wù)辦理自動(dòng)對(duì)賬過(guò)程通過(guò)待辦列表辦理任務(wù)的對(duì)賬過(guò)程如下圖所示待辦任務(wù)列表上圖中的“對(duì)賬”過(guò)程是系統(tǒng)根據(jù)“工作項(xiàng)代碼”到BIZ_WF表里查詢流程狀態(tài)的過(guò)程。系統(tǒng)列出待辦任務(wù)列表；用戶選擇待辦列表里的一條任務(wù)進(jìn)行辦理；系統(tǒng)根據(jù)流程實(shí)例號(hào)、工作項(xiàng)代碼到“任務(wù)對(duì)賬信息表”進(jìn)行對(duì)賬，如果