這篇文章主要講以下三個方面
- 工作流介紹
- 工作流執(zhí)行過程
- 工作流模擬執(zhí)行
工作流介紹
以我們公司的報銷流程為例：
小明--->提交申請--->人事審批-->經(jīng)理審批-->財務(wù)審批--->結(jié)束
我們先思考一下，需要實現(xiàn)這的一個需求我們需要怎么做？
????我們可能需要去維護一個變量，來不斷傳遞過去下一個處理者，或者是建相關(guān)的任務(wù)表之類的，如果需求不會變，沒有什么條件處理，這樣也好設(shè)計。
????但是，如果有條件【不同職位員工審批方式不一樣】，需求更改了【不需要人事審批了】，那么我們的代碼就會亂，不好維護。
????再來看這種問題就是一種流式的控制管理，基于這么一個原因，我們需要學習一個框架來幫我們完成并管理這樣的報銷流程，他可以在上級點擊同意后自動將提交記錄錄到電腦并流轉(zhuǎn)到下一節(jié)點，這就是我們這里要講的工作流技術(shù)。
工作流(Workflow)，就是“業(yè)務(wù)過程的部分或整體在計算機應(yīng)用環(huán)境下的自動化”，它主要解決的是“使在多個參與者之間按照某種預(yù)定義的規(guī)則傳遞文檔、信息或任務(wù)的過程自動進行，從而實現(xiàn)某個預(yù)期的業(yè)務(wù)目標，或者促使此目標的實現(xiàn)”
這里我們也可以比對出工作流的優(yōu)點：
- 提高系統(tǒng)的柔性，適應(yīng)業(yè)務(wù)流程的變化
- 實現(xiàn)更好的業(yè)務(wù)過程控制，提高顧客服務(wù)質(zhì)量
- 降低系統(tǒng)開發(fā)和維護成本
工作流執(zhí)行過程
我們以官網(wǎng)提供的示例包演示：
官網(wǎng)https://www.activiti.org/get-started下載對應(yīng)的jar包，解壓出來，在wars包目錄下有個activiti-app.war，把這個包放到tomgcat運行（運行之前我把數(shù)據(jù)庫配置改成我本地的mysql：WEB-INF\classes\META-INF\activiti-app\activiti-app.properties）
項目啟動成功進入到首頁
- Kickstart App：主要用于流程模型管理、表單管理及應(yīng)用（App）管理，一個應(yīng)用可以包含多個流程模型，應(yīng)用可發(fā)布給其他用戶使用。
- Task App：用于管理整個activiti-app的任務(wù)，在該功能里面也可以啟動流程
- Idenity management：身份信息管理，可以管理用戶、用戶組等數(shù)據(jù)
進入第三個菜單Identity management
新建用戶：這邊新建用戶小明假設(shè)他為員工，王五是經(jīng)理
定義流程
在主界面點擊Kickstart App，點擊create Process按鈕彈出新建流程模型界面
上圖中定義了一個開始事件、兩個用戶任務(wù)、一個結(jié)束事件。我們定義的請假業(yè)務(wù)，需要將該用戶任務(wù)分配給 小明。點擊第一個用戶任務(wù)，并修改“Assignment”屬性，將“提交申請”任務(wù)分配給“xiaoming”用戶。保存成功后，再使用同樣的方法將“部門經(jīng)理審批”任務(wù)分配給 王五用戶，保存流程模型后，就可以將流程發(fā)布。
發(fā)布流程
在 activiti-app 中，一個 App 可包含多個流程模型，因此在發(fā)布流程前，先新建一個 App并為其設(shè)置流程模型。點擊 Apps 菜單，再點擊“Creaea App”按鈕，新建一個 App，該App就包含我們前面所設(shè)計的請假流程模型
建好之后需要為其設(shè)置流程模型
點擊一下即可，在關(guān)閉
點擊進入到app中，點擊發(fā)布public進行發(fā)布
發(fā)布成功后使用小明賬戶登錄，進入到首頁可以看到
進入請假流程模型App并且點擊“Processes”菜單，在界面左上角，可以看到“Start a process”按鈕，點擊啟動請假流程后，可以看到界面如圖所示
點擊complete，完成，任務(wù)跳轉(zhuǎn)到下一個執(zhí)行人
直至整個流程審批完成，結(jié)束
工作流模擬執(zhí)行
在我們模擬工作流流程之前在介紹下工作流引擎
ProcessEngine對象，這是Activiti工作的核心。負責生成流程運行時的各種實例及數(shù)據(jù)、監(jiān)控和管理流程的運行，其主要有以下兩個職責
- 定義流程，也就是給我們提供某種規(guī)范來定義規(guī)則，以及如何定義一個流程的這種規(guī)范，同事我們可以根據(jù)工作流引擎提供的相關(guān)概念來定義更為復(fù)雜的流程，這就是工作流引擎做的第一件事叫做定義流程。
- 執(zhí)行流程，也就是工作流引擎需要解釋這個規(guī)則，還要負責流程，它相當于流程的調(diào)度者，監(jiān)控每個流程的執(zhí)行情況，并將流程操作發(fā)往下一步，或者根據(jù)條件休眠或終止流程的這么一個過程就叫做執(zhí)行流程。
????了解完工作流引擎的這兩個職責，我相信對于什么是工作流引擎一定已經(jīng)有了一定的認識了，我們在用一句稍微有點官方的話來總結(jié)一下工作流引擎：工作流引擎為我們提供相關(guān)規(guī)則概念的定義，給我們提供了相關(guān)的API來調(diào)用這個引擎去執(zhí)行流程。流程的操作實際上就是工作流引擎提供相關(guān)的api我們?nèi)フ{(diào)用它。
activiti.cfg.xml（activiti的配置文件）
Activiti核心配置文件，配置流程引擎創(chuàng)建工具的基本參數(shù)和數(shù)據(jù)庫連接池參數(shù)
定義數(shù)據(jù)庫配置參數(shù)
- jdbcUrl: 數(shù)據(jù)庫的JDBC URL。
- jdbcDriver: 對應(yīng)不同數(shù)據(jù)庫類型的驅(qū)動。
- jdbcUsername: 連接數(shù)據(jù)庫的用戶名。
- jdbcPassword: 連接數(shù)據(jù)庫的密碼。
基于JDBC參數(shù)配置的數(shù)據(jù)庫連接 會使用默認的MyBatis連接池。 下面的參數(shù)可以用來配置連接池（來自MyBatis參數(shù)）
- jdbcMaxActiveConnections: 連接池中處于被使用狀態(tài)的連接的最大值。默認為10。
- jdbcMaxIdleConnections: 連接池中處于空閑狀態(tài)的連接的最大值。
- jdbcMaxCheckoutTime: 連接被取出使用的最長時間，超過時間會被強制回收。 默認為20000（20秒）。
- jdbcMaxWaitTime: 這是一個底層配置，讓連接池可以在長時間無法獲得連接時， 打印一條日志，并重新嘗試獲取一個連接。（避免因為錯誤配置導致沉默的操作失?。?。 默認為20000（20秒）
下面所有的操作都需要用到工作流引擎對象，我們可以如下方式獲取：
ProcessEngine processEngine= ProcessEngines.getDefaultProcessEngine();
這里默認會去資源路徑下讀取配置文件activiti.cfg.xml
我們再來回顧下工作流執(zhí)行過程，首先需要畫好流程圖，然后部署到app上
這個步驟我們叫：部署流程定義
public void deploymentProcessDefinition(){
Deployment deploy = processEngine.getRepositoryService() //與流程定義和部署對象相關(guān)的Service
.createDeployment() //創(chuàng)建一個部署對象
.name("審批流程") //添加部署名稱
.addClasspathResource("diagrams/audit.xml") //從classPath資源中加載，一次只能加載一個文件
.addClasspathResource("diagrams/audit.png")
.deploy(); //完成部署
}
說明：
- 首先獲得默認的流程引擎，通過流程引擎獲取了一個RepositoryService對象（倉庫對象）
- 由倉庫的服務(wù)對象產(chǎn)生一個部署對象配置對象，用來封裝部署操作的相關(guān)配置。
- 這是一個鏈式編程，在部署配置對象中設(shè)置顯示名，上傳流程定義規(guī)則文件
- 向數(shù)據(jù)庫表中存放流程定義的規(guī)則信息。
這一步在數(shù)據(jù)庫中將操作三張表
- act_re_deployment（部署對象表）
存放流程定義的顯示名和部署時間，每部署一次增加一條記錄 - act_re_procdef（流程定義表）
存放流程定義的屬性信息，部署每個新的流程定義都會在這張表中增加一條記錄。
注意：當流程定義的key相同的情況下，使用的是版本升級 - act_ge_bytearray（資源文件表）
存儲流程定義相關(guān)的部署信息。即流程定義文檔的存放地。每部署一次就會增加兩條記錄，一條是關(guān)于bpmn規(guī)則文件的，一條是圖片的（如果部署時只指定了bpmn一個文件，activiti會在部署時解析bpmn文件內(nèi)容自動生成流程圖）。兩個文件不是很大，都是以二進制形式存儲在數(shù)據(jù)庫中
然后需要發(fā)布：啟動流程
public void startProcess(){
ProcessInstance process = processEngine.getRuntimeService().startProcessInstanceByKey("myProcess_1");
}
操作數(shù)據(jù)庫的act_ru_execution表,如果是用戶任務(wù)節(jié)點，同時也會在act_ru_task添加一條記錄，我們可以看到小明會有一條任務(wù)，查詢操作如下：
List<Task> taskList = processEngine.getTaskService()//與正在執(zhí)行的任務(wù)管理相關(guān)的Service
.createTaskQuery()//創(chuàng)建任務(wù)查詢對象
/**查詢條件（where部分）*/
.taskAssignee("小明")//指定個人任務(wù)查詢，指定辦理人
// .taskCandidateUser(candidateUser)//組任務(wù)的辦理人查詢
// .processDefinitionId(processDefinitionId)//使用流程定義ID查詢
// .processInstanceId(processInstanceId)//使用流程實例ID查詢
// .executionId(executionId)//使用執(zhí)行對象ID查詢
/**排序*/
.orderByTaskCreateTime().asc()//使用創(chuàng)建時間的升序排列
/**返回結(jié)果集*/
// .singleResult()//返回惟一結(jié)果集
// .count()//返回結(jié)果集的數(shù)量
// .listPage(firstResult, maxResults);//分頁查詢
.list();//返回列表
for (Task task:taskList){
System.out.println("任務(wù)ID:"+task.getId());
System.out.println("任務(wù)名稱:"+task.getName());
System.out.println("任務(wù)的創(chuàng)建時間:"+task.getCreateTime());
System.out.println("任務(wù)的辦理人:"+task.getAssignee());
System.out.println("流程實例ID："+task.getProcessInstanceId());
System.out.println("執(zhí)行對象ID:"+task.getExecutionId());
System.out.println("流程定義ID:"+task.getProcessDefinitionId());
}
說明
- 因為是任務(wù)查詢，所以從processEngine中應(yīng)該得到TaskService
- 使用TaskService獲取到任務(wù)查詢對象TaskQuery
- 為查詢對象添加查詢過濾條件，使用taskAssignee指定任務(wù)的辦理者（即查詢指定用戶的代辦任務(wù)），同時可以添加分頁排序等過濾條件
- 調(diào)用list方法執(zhí)行查詢，返回辦理者為指定用戶的任務(wù)列表
- 任務(wù)ID、名稱、辦理人、創(chuàng)建時間可以從act_ru_task表中查到。
- 一個Task節(jié)點和Execution節(jié)點是1對1的情況，在task對象中使用Execution_來表示他們之間的關(guān)系
- 任務(wù)ID在數(shù)據(jù)庫表act_ru_task中對應(yīng)“ID_”列
完成任務(wù)
public void completeMyPersonalTask(){
processEngine.getTaskService(). //正在執(zhí)行任務(wù)相關(guān)的Service
complete("104"); //根據(jù)taskid完成任務(wù)
}
說明
- 是辦理任務(wù)，所以從ProcessEngine得到的是TaskService。
- 當執(zhí)行完這段代碼，再以員工的身份去執(zhí)行查詢的時候，會發(fā)現(xiàn)這個時候已經(jīng)沒有數(shù)據(jù)了，因為正在執(zhí)行的任務(wù)中沒有數(shù)據(jù)。
- 對于執(zhí)行完的任務(wù)，activiti將從act_ru_task表中刪除該任務(wù)，下一個任務(wù)會被插入進來。
- 以”部門經(jīng)理”的身份進行查詢，可以查到結(jié)果。因為流程執(zhí)行到部門經(jīng)理審批這個節(jié)點了。
- 再執(zhí)行辦理任務(wù)代碼，執(zhí)行完以后以”部門經(jīng)理”身份進行查詢，沒有結(jié)果。
- 重復(fù)第4和5步直到流程執(zhí)行完。
綜上，我們可以總結(jié)出這個幾個Service
- RepositoryService
是Activiti的倉庫服務(wù)類。所謂的倉庫指流程定義文檔的兩個文件：bpmn文件和流程圖片。 - RuntimeService
是activiti的流程執(zhí)行服務(wù)類?？梢詮倪@個服務(wù)類中獲取很多關(guān)于流程執(zhí)行相關(guān)的信息。 - TaskService
是activiti的任務(wù)服務(wù)類?？梢詮倪@個類中獲取任務(wù)的信息。 - HistoryService
是activiti的查詢歷史信息的類。在一個流程執(zhí)行完成后，這個對象為我們提供查詢歷史信息。
亦可以總結(jié)所用到的表
- ACT_RE_*: 'RE'表示repository。 這個前綴的表包含了流程定義和流程靜態(tài)資源 （圖片，規(guī)則，等等）。
- ACT_RU_*: 'RU'表示runtime。 這些運行時的表，包含流程實例，任務(wù)，變量，異步任務(wù)，等運行中的數(shù)據(jù)。 Activiti只在流程實例執(zhí)行過程中保存這些數(shù)據(jù)， 在流程結(jié)束時就會刪除這些記錄。 這樣運行時表可以一直很小速度很快。
- ACT_ID_*: 'ID'表示identity。 這些表包含身份信息，比如用戶，組等等。
- ACT_HI_*: 'HI'表示history。 這些表包含歷史數(shù)據(jù)，比如歷史流程實例， 變量，任務(wù)等等。
- ACT_GE_*: 通用數(shù)據(jù)， 用于不同場景下，如存放資源文件。
資源庫流程規(guī)則表
- act_re_deployment 部署信息表
- act_re_model 流程設(shè)計模型部署表
- act_re_procdef 流程定義數(shù)據(jù)表
運行時數(shù)據(jù)庫表 - act_ru_execution 運行時流程執(zhí)行實例表
- act_ru_identitylink 運行時流程人員表，主要存儲任務(wù)節(jié)點與參與者的相關(guān)信息
- act_ru_task 運行時任務(wù)節(jié)點表
- act_ru_variable 運行時流程變量數(shù)據(jù)表
- act_ru_job 工作數(shù)據(jù)表
- act_ru_event_subscr 事件描述表
歷史數(shù)據(jù)庫表 - act_hi_actinst 歷史節(jié)點表
- act_hi_attachment 歷史附件表
- act_hi_comment 歷史意見表
- act_hi_identitylink 歷史流程人員表
- act_hi_detail 歷史詳情表，提供歷史變量的查詢
- act_hi_procinst 歷史流程實例表
- act_hi_taskinst 歷史任務(wù)實例表
- act_hi_varinst 歷史變量表
組織機構(gòu)表 - act_id_group 用戶組信息表
- act_id_info 用戶擴展信息表
- act_id_membership 用戶與用戶組對應(yīng)信息表
- act_id_user 用戶信息表
通用數(shù)據(jù)表 - act_ge_bytearray 二進制數(shù)據(jù)表
-
act_ge_property 屬性數(shù)據(jù)表存儲整個流程引擎級別的數(shù)據(jù),初始化表結(jié)構(gòu)時，會默認插入三條記錄，
27102725_uKzQ.jpg
企業(yè)中的應(yīng)用
未完
