jbpm4.4 会签实例

<?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>

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);
}
}
}
}

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;
}

}

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());
}
}
}