開發環境為MyEclipse8.5 jbpm4.4。 

根據會籤的一票否決制編寫。

流程的XML檔案 process.jpd.xml

<?xml version="1.0" encoding="UTF-8"?> <process name="會籤例項" xmlns="http://jbpm.org/4.3/jpdl" description="會籤中一個不同意，會籤就結束"> <start g="110,14,48,48" name="Start"> <transition g="-95,-17" name="to JointlySign" to="會籤"/> </start> <end g="110,264,48,48" name="End"/> <task g="88,96,92,52" name="會籤"> <assignment-handler class="test.join.AssignTask"> </assignment-handler> <transition g="-71,-17" name="to 執行" to="執行"/> <transition g="-41,-17" name="to 結束" to="End"/> </task> <state g="16,180,92,52" name="執行"> <transition g="-41,-17" name="to End" to="End"/> </state> </process>

AssignTask.java

package test.join; import java.util.List; import org.jbpm.api.Configuration; import org.jbpm.api.ProcessEngine; import org.jbpm.api.TaskService; import org.jbpm.api.model.OpenExecution; import org.jbpm.api.task.Assignable; import org.jbpm.api.task.AssignmentHandler; import org.jbpm.api.task.Participation; import org.jbpm.api.task.Task; import org.jbpm.pvm.internal.task.OpenTask; public class AssignTask implements AssignmentHandler{ private static final long serialVersionUID = 1L; List<String> participants; ProcessEngine processEngine=Configuration.getProcessEngine(); TaskService taskService=processEngine.getTaskService(); @SuppressWarnings("unchecked") public void assign(Assignable assignable, OpenExecution execution) throws Exception { //System.out.println("分配"); String pid=execution.getProcessInstance().getId(); //System.out.println("pid :"+pid); Task task=taskService.createTaskQuery().processInstanceId(pid).activityName(execution.getName()).uniqueResult(); //System.out.println(task.getName()); participants=(List<String>)taskService.getVariable(task.getId(), "participants"); if(participants!=null){ for(String participant:participants){ //System.out.println(participant); Task subTask=((OpenTask)task).createSubTask(); subTask.setAssignee(participant); taskService.addTaskParticipatingUser(task.getId(), participant, Participation.CLIENT); } } } }

Sign.java

package test.join; import org.jbpm.api.TaskService; import org.jbpm.api.cmd.Command; import org.jbpm.api.cmd.Environment; import org.jbpm.api.task.Task; public class Sign implements Command<Boolean>{ private static final long serialVersionUID = 1L; public static String VAR_SIGN="同意"; private String PASS; private String NOPASS; private String parentTaskId; private Task parentTask; private Task joinTask; String pid; public Sign(String parentTaskId,Task joinTask,String PASS,String NOPASS){ this.parentTaskId=parentTaskId; this.PASS=PASS; this.NOPASS=NOPASS; this.joinTask=joinTask; } public String getPid(){ return pid; } public Boolean execute(Environment environment) throws Exception { TaskService taskService=environment.get(TaskService.class); parentTask=taskService.getTask(parentTaskId); pid=parentTask.getExecutionId(); String sign=(String)taskService.getVariable(joinTask.getId(), VAR_SIGN); if(sign!=null&&sign.equals("不同意")){ taskService.completeTask(joinTask.getId()); taskService.completeTask(parentTask.getId(), NOPASS); return true; } taskService.completeTask(joinTask.getId()); if(taskService.getSubTasks(parentTaskId).size()==0){ taskService.completeTask(parentTaskId,PASS); return true; } return false; } }

test.java

package test.join; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import org.jbpm.api.Configuration; import org.jbpm.api.ExecutionService; import org.jbpm.api.HistoryService; import org.jbpm.api.ProcessEngine; import org.jbpm.api.ProcessInstance; import org.jbpm.api.RepositoryService; import org.jbpm.api.TaskService; import org.jbpm.api.history.HistoryProcessInstance; import org.jbpm.api.task.Task; public class Test { public static void main(String []args){ ProcessEngine processEngine=Configuration.getProcessEngine(); ExecutionService executionService=processEngine.getExecutionService(); TaskService taskService=processEngine.getTaskService(); RepositoryService repositoryService=processEngine.getRepositoryService(); repositoryService.createDeployment().addResourceFromClasspath("test/join/process.jpdl.xml").deploy(); Map<String,Object> variables=new HashMap<String,Object>(); List<String> pariticipants=new ArrayList<String>(); pariticipants.add("yunix"); pariticipants.add("snrqtdhuqf"); variables.put("participants", pariticipants); ProcessInstance processInstance=executionService.startProcessInstanceByKey("會籤例項",variables); Task task=taskService.createTaskQuery() .processInstanceId(processInstance.getId()) .activityName(processInstance.findActiveActivityNames().iterator().next()).uniqueResult(); //System.out.println(task.getId()); Task joinTask=taskService.findPersonalTasks("yunix").get(0); Sign sign=new Sign(task.getId(),joinTask,"to 執行","to 結束"); processEngine.execute(sign); joinTask=taskService.findPersonalTasks("snrqtdhuqf").get(0); sign=new Sign(task.getId(),joinTask,"to 執行","to 結束"); processEngine.execute(sign); processInstance=executionService.findProcessInstanceById(processInstance.getId()); System.out.println(processInstance.isActive("執行")); String executionId = processInstance.findActiveExecutionIn("執行").getId(); processInstance=executionService.signalExecutionById(executionId); System.out.println("流程是否結束："+processInstance.isEnded()); processInstance=executionService.startProcessInstanceByKey("會籤例項",variables); System.out.println("會籤不通過流程開始，流程ID為："+processInstance.getId()+" "); task=taskService.createTaskQuery() .processInstanceId(processInstance.getId()) .activityName(processInstance.findActiveActivityNames().iterator().next()) .uniqueResult(); joinTask=taskService.findPersonalTasks("yunix").get(0); Map<String,Object> v=new HashMap<String,Object>(); v.put(Sign.VAR_SIGN, "不同意"); taskService.setVariables(joinTask.getId(), v); sign=new Sign(task.getId(),joinTask,"to 執行","to 結束"); System.out.println(processEngine.execute(sign)); HistoryService historyService=processEngine.getHistoryService(); List<HistoryProcessInstance> hProcessInstances = historyService.createHistoryProcessInstanceQuery().processInstanceId(processInstance.getId()) .list(); for(HistoryProcessInstance h:hProcessInstances){ System.out.println("流程"+processInstance.getId()+"狀態："+h.getState()); } } }

測試結果：

true
流程是否結束：true
會籤不通過流程開始，流程ID為：會籤例項.17
true
流程會籤例項.17狀態：ended