RepositoryService

管理流程定义

RuntimeService

执行管理，包括启动、推进、删除流程实例等操作

TaskService

任务管理

HistoryService

历史管理(执行完的数据的管理)

IdentityService

组织机构管理

FormService

一个可选服务，任务表单管理

ManagerService

<startEvent id="start" name="my start event" />

<startEvent id="theStart">
<timerEventDefinition>
<timeCycle>R4/2017-03-11T12:13/PT5M</timeCycle>
</timerEventDefinition>
</startEvent>

<endEvent id="end" name="my end event" />

<sequenceFlow id="flow1" sourceRef="theStart" targetRef="theTask" />

<exclusiveGateway id="exclusiveGw" name="Exclusive Gateway" />
<sequenceFlow id="flow2" sourceRef="exclusiveGw" targetRef="theTask1">
<conditionExpression xsi:type="tFormalExpression">${input == 1}</conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow3" sourceRef="exclusiveGw" targetRef="theTask2">
<conditionExpression xsi:type="tFormalExpression">${input == 2}</conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow4" sourceRef="exclusiveGw" targetRef="theTask3">
<conditionExpression xsi:type="tFormalExpression">${input == 3}</conditionExpression>
</sequenceFlow>

<parallelGateway id="myParallelGateway" />
<startEvent id="theStart" />
<sequenceFlow id="flow1" sourceRef="theStart" targetRef="fork" />
<parallelGateway id="fork" />
<sequenceFlow sourceRef="fork" targetRef="receivePayment" />
<sequenceFlow sourceRef="fork" targetRef="shipOrder" />
<userTask id="receivePayment" name="Receive Payment" />
<sequenceFlow sourceRef="receivePayment" targetRef="join" />
<userTask id="shipOrder" name="Ship Order" />
<sequenceFlow sourceRef="shipOrder" targetRef="join" />
<parallelGateway id="join" />
<sequenceFlow sourceRef="join" targetRef="archiveOrder" />
<userTask id="archiveOrder" name="Archive Order" />
<sequenceFlow sourceRef="archiveOrder" targetRef="theEnd" />
<endEvent id="theEnd" />
 

<userTask id="inspector_downpayment_approve_task" name="包卖付款审核" activiti:candidateGroups="inspector_downpayment_approve">
  <documentation>包卖付款审核</documentation>
</userTask>

@Autowired
private ProcessEngine processEngine;
/**部署流程定义*/
@Test
public void deploy(){
    String bpmnClassPath = "bpmn/test_process.bpmn20.xml";
    Deployment deployment = processEngine.getRepositoryService()
            .createDeployment()
            .addClasspathResource(bpmnClassPath)
            .deploy();
    System.out.println(deployment.getId()+"        "+deployment.getName());
}
/**查看流程定义*/
@Test
public void queryProcessDefinition() throwsException {
	//获取仓库服务对象,使用版本的升序排列，查询列表
	List<ProcessDefinition> pdList = processEngine.getRepositoryService().createProcessDefinitionQuery()
	//添加查询条件
	//.processDefinitionKey(processDefinitionKey)
	//排序
	.orderByProcessDefinitionVersion().asc().list();//查询的结果集
	//遍历集合，查看内容
	for(ProcessDefinition pd : pdList) {
		System.out.println("id:" + pd.getId());
		System.out.println("name:" + pd.getName());
		System.out.println("key:" + pd.getKey());
		System.out.println("version:" + pd.getVersion());
		System.out.println("resourceName:"+pd.getDiagramResourceName());
		System.out.println("***************************************");
	}
}
@Test
public void deleteDeployment() throws Exception {
	//删除发布信息
	String deploymentId = "1";
	//获取仓库服务对象
	RepositoryService repositoryService = processEngine.getRepositoryService();
	//普通删除，如果当前规则下有正在执行的流程，则抛异常
	//repositoryService.deleteDeployment(deploymentId);
	//级联删除,会删除和当前规则相关的所有信息，正在执行的信息，也包括历史信息
	//相当于：repositoryService.deleteDeploymentCascade(deploymentId);
	repositoryService.deleteDeployment(deploymentId,true);
}

/*启动流程实例*/
@Test
public void startProcess() throws Exception {
	//通过流程定义的key启动流程，会启动版本最高的流程
	ProcessInstance pi = processEngines.getRuntimeService()//获取正在执行的Service
	.startProcessInstanceByKey("myProcess");//按照流程定义的key启动流程实例，默认按照最新版本启动
	System.out.println("pid:" + pi.getId() +",activitiId:" + pi.getActivitiId()+",pdId:"+pi.getProcessDefinitionId());
}
/*查看个人任务*/
@Test
public void startProcess() throws Exception {
	//配置查询对象
	String assignee="张三";
	//创建任务查询对象，查询个人任务
	List<Task> list = processEngine.getTaskService().createTaskQuery().taskAssignee(assignee)//指定个人任务的办理人查询任务
	.orderByTaskCreateTime().desc()//按照任务创建时间升序排列
	.list();//查询任务的所有记录
	System.out.println("======================【"+assignee+"】的个人任务列表=================");
	for(Task task: list) {
		System.out.print("id:"+task.getId()+",");
		System.out.print("name:"+task.getName()+",");
		System.out.print("createTime:"+task.getCreateTime()+",");
		System.out.println("assignee:"+task.getAssignee());
	}
}
/*办理任务*/
@Test
public void complete() throws Exception {
	String taskId = "1102";
	//完成任务
	processEngine.getTaskService().complete(taskId);//指定任务ID，完成任务
}
 

/**设置流程变量*/
@Test
public void setVariables(){
	//获取执行的Service
	TaskService taskService = processEngine.getTaskService();
	//指定办理人
	String assigneeUser = "张三";
	//流程实例ID
	String processInstanceId = "1701";
	Task task = taskService.createTaskQuery().taskAssignee(assigneeUser)//指定办理人
	.processInstanceId(processInstanceId)//指定流程实例ID
	.singleResult();
	/**一：变量中存放基本数据类型*/
	//taskService.setVariable(task.getId(), "请假人","李四");//使用流程变量的名称和流程变量的值设置流程变量，一次只能设置一个值
	//taskService.setVariable(task.getId(), "请假天数",3);
	//taskService.setVariable(task.getId(), "请假日期",new Date());
	/**二：变量中存放javabean对象，前提：让javabean对象实现implements
	java.io.Serializable*/
	Person p = new Person();
	p.setId(1L);
	p.setName("王五");
	taskService.setVariable(task.getId(), "人员信息",p);
	/**三：也可设置多个参数
	taskService.setVariables(taskId, variablesMap);
}