一直在搞工作流(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(); }
/** * 獲取每個任務的連線. * * @Title: getSeqFlowByBpmn * @author liufei12581@sinosoft.com.cn * @param deploymentid 部署id * @param targetFilePath 路徑 * @return */ public Map getSeqFlowByBpmn(String deploymentid,String targetFilePath){ Map<String,List<String>> map=new HashMap<String, List<String>>(); Map<String,String> taskmap=new HashMap<String, String>(); Map allmap=new HashMap(); try { InputStream in=null; List<String> list = getProcessEngine().getRepositoryService()// .getDeploymentResourceNames(deploymentid); //定義圖片資源的名稱 String resourceName = ""; if(list!=null && list.size()>0){ for(String name:list){ if(name.indexOf(".bpmn")>=0){ resourceName = name; } } } //獲取數據庫里部署的bpmn文件 in = getProcessEngine().getRepositoryService() .getResourceAsStream(deploymentid, resourceName); //將bpmn文件另存到本地並寫入xml文件 String fileName=resourceName.substring(0,resourceName.indexOf("."))+".xml"; File file = new File(targetFilePath+fileName); // if(file.exists()){//判斷文件是否存在 System.out.println(targetFilePath); file.delete();//如果存在則先刪除 file.createNewFile(); //創建文件 OutputStream output = new FileOutputStream(file); BufferedOutputStream bufferedOutput = new BufferedOutputStream(output); bufferedOutput.write(IcmisUnit.toByteArray(in)); bufferedOutput.flush(); // } //獲取dom工廠得到dom對象 DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();//步驟1 DocumentBuilder builder = factory.newDocumentBuilder();//步驟2 //將保存的xml解析成dom樹 Document doc = builder.parse(file);//步驟3 //獲取連線的所有node NodeList sequenceFlow = doc.getElementsByTagName("sequenceFlow"); //獲取網關的所有node NodeList exclusiveGateway = doc.getElementsByTagName("exclusiveGateway"); //獲取任務的所有node NodeList userTask = doc.getElementsByTagName("userTask"); //循環任務節點 for (int i = 0; i < userTask.getLength(); i++) { //獲取任務節點的id屬性 String id=userTask.item(i).getAttributes().getNamedItem("id").getNodeValue(); //獲取任務節點的name屬性 String name=userTask.item(i).getAttributes().getNamedItem("name").getNodeValue(); taskmap.put(id, name); } //循環連線節點 for (int i = 0; i < sequenceFlow.getLength(); i++) { //獲取連線的起始節點 String sourceTask=sequenceFlow.item(i).getAttributes().getNamedItem("sourceRef").getNodeValue(); //獲取連線的目標節點 String targetTask=sequenceFlow.item(i).getAttributes().getNamedItem("targetRef").getNodeValue(); boolean bool=true;//用來判斷是否是通過的連線，下面的操作是為了過濾描述通過的連線 //獲取連線節點下的配置信息節點，一個連線應該只有一個配置節點 NodeList nl= sequenceFlow.item(i).getChildNodes(); for (int j = 0; j <nl.getLength(); j++) { if(nl.item(j).getNodeType()==Node.ELEMENT_NODE){ //找到配置節點，並得到配置的值 if("conditionExpression".equals(nl.item(j).getNodeName())){ //這里要注意一下：配置通過的連線一定要寫成${flag=='1'}或"${flag==\"1\"} String flag=Util.nulltostr(nl.item(j).getFirstChild().getNodeValue()); if("${flag=='1'}".equals(flag)||"${flag==\"1\"}".equals(flag)){ //表示是通過的連線，如果是通過的連線則不做處理，這里用到了上面的boolean變量，通過變量來控制過濾節點 bool=false; } } } } //通過變量過濾已通過的連線節點 if(bool){ //存連線的開始任務 if(map.containsKey(sourceTask)){ //表示存在 map.get(sourceTask).add(targetTask); }else{ //表示不存在 List<String> targetlist=new ArrayList<String>(); targetlist.add(targetTask); map.put(sourceTask, targetlist); } } } //默認取出來的連線針對網關記錄的是網關的節點，但是實際操作中想要得到網關的節點id是不可能的，所以加了一步處理，獲取連接網關的上個節點 //這里要說明一下，連接到網關的連線 也就是targetRef肯定是只有一條連線，所以順藤摸瓜找到了連接網關的任務節點，這樣在實際項目中 //通過任務節點即可找到駁回連線的targetRef任務節點，即可展示到前台讓客戶去選擇駁回的連線啦 //循環網關node for (int i = 0; i < exclusiveGateway.getLength(); i++) { //得到網關id String exclusiveGatewayid=exclusiveGateway.item(i).getAttributes().getNamedItem("id").getNodeValue(); //通過循環所有的連線，比對得到那條唯一連接網關的連線將數據重新防止到map當中 for (String key : map.keySet()) { for (String target : map.get(key)) { if(exclusiveGatewayid.equals(target)){ map.put(key, map.get(exclusiveGatewayid)); } } } } } catch (Exception e) { e.printStackTrace(); } allmap.put(WorkFlowConstant.SEQ, map); allmap.put(WorkFlowConstant.USERTASK, taskmap); return allmap; }