一直在搞工作流(activiti)，總結一下關於工作流(activiti)中同時並發處理多個子流程的操作方法。
先說下我要實現的業務：
1、辦公室發通知（在系統申報頁面上，勾選科室，被選中的科室執行第二步）
2、科室科員填報數據
3、科室科長做審核（注意這里的科長審核是對應第二步的科室，本科科長去審核本單位填報完的任務）
4、辦公室編制立項書，匯總數據
好，需求就先這樣，這里主要是給講解一下關於子流程的使用，所以其他的需求就不往上寫了。
先看一眼畫好后的流程圖：
可以看到任務發起時（啟動流程實例時）就進入了子流程中，這里需要關心的是怎么才能生成多個子流程呢，請看：
接下來我們對這個子流程進行配置：
注：1、Collection:可以存放集合，集合中可以存任意值，工作流會根據你集合里的值個數，去生成對應的子流程，
例如：我這里存的是3個科室code，{0001，0002，0003}，那么就會生成出3個子流程，
其實這里我簡單說明一下，如果只傳入1個值會生成4個流程實例，
傳2個會生成出6個流程實例（多出的兩個，一個是子流程subprocess的，一個是流程中第一個任務的），以此類推。
2、Element variable：顧名思義就是節點流程變量，用於在流程圖中代替集合中表示當前子流程的變量（我這存的是科室code，所以表示的就是科室code）。
這個節點流程變量可以在當前子流程中任意的task中使用，例如 子流程中的任務我就用到了這個變量，稍后會有圖詳細說明
3、Completion condition：顧名思義就是完成條件，這里寫的表達式如果滿足即可到（第三步：立項書編制）這個任務，關於這里的配置，
給大家推薦一個網址介紹：http://my.oschina.net/winHerson/blog/139267?fromerr=ApnxMXj5
接下來繼續配置，我的業務需求是 選中的科室做填報，並且有這個科室的科長去審核，那么我們接着去配置具體的用戶任務（userTask）
這里簡單講一下我做的這個項目的權限控制，我這里是通過權限點去控制顯示每個任務的待辦的權限，假如張三 有PM10000101權限點，
他就能看到任務中配置了PM10000101的待辦，因為我的系統是三級樹權限控制，用戶--角色--權限點（功能點），
所以我在工作流Candiate groups中配置的是功能點，各位可以根據自己系統的需要去合理配置。
順便在講一下將${candiateUser}配置到Candidate users或者Candidate groups的后果，
它會根據你集合中存的變量個數生成出任務來比較惡心的是這種形式，例如：
candiateUserList中存了{001,002,003}，按照規則會生成出3個子流程(A、B、C)，
但是在生成任務的時候會生成出這種A(001)、A(002)、A(003)、B(001)、B(002)、B(003)、C(001)、C(002)、C(003)
問題是我這里不需要這么生成任務，只需要一個流程對應1個任務就OK，所以我將${candiateUser}配置到了userTask的描述信息中
配置到了這一步基本告一段落，下面我將我的查詢待辦sql貼出來，相信大家都懂了
SELECT T.SERIAL_NUMBER,
(SELECT Q.DO_USERNAME FROM ACT_HI_TASKREMARK Q WHERE Q.P_ID=T.PROC_INST_ID_ AND Q.TASK_ID IS NULL AND ROWNUM <2 ) AS CREAT_USER,
T.ID_ AS ID,
T.PROC_INST_ID_ AS PID,
T.EXECUTION_ID_ AS EID,
P.NAME_ AS TASKTYPE,
T.NAME_ AS FLOWNAME,
TO_CHAR(T.CREATE_TIME_, 'YYYY-MM-DD HH24:MI:SS') AS CREATE_TIME,
TIMEHEADER((REPLACE(SUBSTR(TO_CHAR(NUMTODSINTERVAL((SELECT CEIL((TO_DATE(TO_CHAR(SYSDATE, 'YYYY-MM-DD HH24:MI:SS'),'YYYY-MM-DD HH24:MI:SS') -
TO_DATE(TO_CHAR(T.CREATE_TIME_, 'YYYY-MM-DD HH24:MI:SS'),
'YYYY-MM-DD HH24:MI:SS')) * 24 * 60)
FROM DUAL),'MINUTE')),'12','5'),':','小時')||'分' )) STAY_TIME,
DECODE((SELECT V.TEXT_ FROM ACT_RU_VARIABLE V WHERE V.PROC_INST_ID_ = T.PROC_INST_ID_ AND V.NAME_ = 'IS_URGENCY'),'2','<FONT COLOR="RED">【緊急】</FONT>','3','<FONT COLOR="PURPLE">【特急】</FONT>','<FONT COLOR="GREEN">【常規】</FONT>')||(SELECT V.TEXT_ FROM ACT_RU_VARIABLE V WHERE V.PROC_INST_ID_ = T.PROC_INST_ID_ AND V.NAME_ = 'TASKNAME') TASKNAME,
(SELECT V.TEXT_ FROM ACT_RU_VARIABLE V WHERE V.PROC_INST_ID_ = T.PROC_INST_ID_ AND V.NAME_ = 'DEADLINE') DEADLINE,
(SELECT COUNT(1) FROM CT_PURSUE C WHERE C.TASKID = T.ID_) URGE_TIME
FROM ACT_RU_TASK T, ACT_RU_IDENTITYLINK F, ACT_RE_PROCDEF P
WHERE T.ID_ = F.TASK_ID_(+)
AND T.PROC_DEF_ID_ = P.ID_
AND ('當前登錄用戶名' IN (SELECT U.USERNAME FROM PERM_ROLE_FUNC R, PERM_USERS U WHERE U.ROLE LIKE '%' || R.ROLEID || '%' AND R.FUNCCODE IN (F.GROUP_ID_) GROUP BY U.USERNAME)
OR '科室code' IN (T.DESCRIPTION_))
AND 1=1
AND 1=1
AND (NVL(T.DESCRIPTION_,'1')='1' OR T.DESCRIPTION_ ='科室code')
再貼一張系統圖：
接下來將啟動流程時的代碼貼出來：
//工作流
String targetFilePath = ServletActionContext.getRequest().getSession().getServletContext()
.getRealPath("/") + IcmisModels.TEMP_FOLD+ "/";//獲取項目臨時文件目錄
//得到當前系統用戶對象
UserView u = (UserView) ServletActionContext.getRequest().getSession().getAttribute(FrameConstant.SESSION_USERVIEW);
Map<String, Object> map=new HashMap<String, Object>();//要在啟動流程中存的流程變量map
map.put(WorkFlowConstant.START_USER, u.getUsername());//設置發起人
List<String> candiateUserList=new ArrayList<String>();//創建多個子流程用的集合
//獲取從前台傳過來的科室code，並將其解析出來存入集合
if(result.getAddinfoDep()!=null&&!"".equals(result.getAddinfoDep())){
String strs[]=result.getAddinfoDep().split(",");//將1,2,3,4..拼接的科室code字符串解析到數組里
for (String s : strs) {
candiateUserList.add(s);//將科室code存入集合中
}
}else{
candiateUserList.add("流程錯誤，無效任務"); //純粹扯淡，這種情況根本不存在
}
map.put("candiateUserList", candiateUserList);//多個子流程集合
map.put(WorkFlowConstant.TASK_NAME, result.getProjectName()+"設備清單填報");//任務名稱
map.put(WorkFlowConstant.DEADLINE,IcmisUnit.date2str(result.getDepDeadline()));//任務截止時間
map.put(WorkFlowConstant.IS_URGENCY,result.getTaskUrgency());//任務緊急度
//發起流程
String piId=wfservice.getWorkflowBaseService().startProcess("bpApply", map,targetFilePath);
public String startProcess(String processDefinitionKey,
Map<String, Object> vMap,String targetFilePath) {
RuntimeService rs = this.processEngine.getRuntimeService(); //得到運行時的service
//設置發起人，這個方法是通過線程判斷是一個了流程實例的
this.processEngine.getIdentityService().setAuthenticatedUserId(vMap.get(WorkFlowConstant.START_USER).toString());
//根據傳入的用戶名得到工作流內置的用戶表對象
User user = this.processEngine.getIdentityService().createUserQuery()
.userId(vMap.get(WorkFlowConstant.START_USER).toString())
.singleResult();
vMap.put("ac", processDefinitionKey);//設置流程定義key，存到流程變量中
//根據流程定義key得到流程定義對象
ProcessDefinition processDefinition = this.getProcessDefinitionByKey(processDefinitionKey);
//vMap.put(WorkFlowConstant.VIEW_URL, processDefinition.getDescription());
Map<String,Object> map=getSeqFlowByBpmn(processDefinition.getDeploymentId(),targetFilePath);//得到所有連線駁回的任務節點的map
vMap.put(WorkFlowConstant.SEQUENCEFLOW, map);//將連線駁回的任務節點map存入流程變量中
// 保存日志
ProcessInstance instance = rs.startProcessInstanceByKey(
processDefinitionKey, vMap);
TaskMarkModel taskMarkModel = new TaskMarkModel();
taskMarkModel.setAuditRemark("發起任務");
//排序使用
taskMarkModel.setCreateDate(new Date(new Date().getTime()-100000));
taskMarkModel.setDoDate(new Date(new Date().getTime()-100000));
taskMarkModel.setDoResult("發起任務");
taskMarkModel.setDoUserName(user.getFirstName());
taskMarkModel.setPid(instance.getProcessInstanceId());
taskMarkModel.setpName(processDefinition.getName());
taskMarkModel.setTaskName("發起任務");
this.saveTaskMark(taskMarkModel);
// 保存日志結束
return instance.getProcessInstanceId();
}