jbpm4

Service API
1，RepositoryService---流程资源服务接口，提供对流程定义的部署，查询，删除等操作。
2，ExecutionService---流程执行服务接口，提供启动流程实例，“执行”推进，设置流程变量等操作。
3，ManagementService---流程管理控制服务的接口，在jbpm4.3中只提供异步工作（job）相关的执行和查询操作
4，TaskService ---人工任务服务接口。提供对任务(Task)的创建，提交，查询，保存，删除等操作。
5，HistoryService --- 流程历史服务接口。提供对流程历史库(已完成的流程实例)中历史流程实例，历史活动实例等记录的查询操作。还提供诸如某个流程定义所有活动的平均持续时间，某个流程定义中某转移的经过次数等数据分析服务。
6，IdentifyService ---身份认证的服务接口。提供对流程用户，用户组，以及组成关系的相关服务


控制流程Activities活动
start (开始活动) ：整个流程的开始节点，所有的流程实例从这里开始。在一个流程定义里必须有一个start活动，start活动必须有一个流出转移（transition）
state(状态活动) ：State节点也叫手工节点，进入到这种节点，整个流程的执行就会中断。直到系统外参与者发起继续执行的命令，业务程序实例的执行才能够继续下去。
decision(判断活动) ：一个decision用以决定在多个执行路径中哪个才可以被执行。 Decision可以拥有多个流出转移，当流实例到达decision活动时会根据最先匹配成功的条件自动地通过相应的流出转移。
<decision name="evaluate document">
<transition to="submit document">
<condition expr="#{content=="good"}"/>
</transition>
<transition to="try again">
<condition expr="#{content=="not so good"}"/>
</transition>
</decision>
<decision name="evaluate document" expr="#{content}">
<transition name="good" to="submit document" />
<transition name="bad" to="try again" />
</decision>

Fork-join(分支-聚合活动)：当流程需要并发执行的时候，就需要用到fork-join活动的组合，fork活动可以使流程在一条主干上出现并行的分支，join活动则可以使流程并行分支聚合成一条主干
End（结束节点) ：对于每一个流程定义都会有一个或多个结束节点，与开始节点对应
Task(人工任务活动)：一般用来处理及人机交互的活动
任务分配者(assignee)：一个简单的任务会被分配给一个指定的用户
task候选人：任务可能被分配给一组用户，其中的一个用户应该接受这个任务并完成它。
任务分配处理器





ProcessDefinition/ProcessInstance/Execution/Task
ProcessDefinition：
流程的定义，这个id是{key}-{version}
ProcessInstance：
流程实例






开始了一个Process，需要完成任务，完成任务有以下几种方法：
1. ExecutionService来完成任务：
    如果得到了正在执行的Execution(可以通过好几种途径获取)，可以通过ExecutionService来完成这个Execution
    executionService.signalExecutionById(executionId [, 可以有其他参数] );
2.TaskService来完成任务：
   如果通过TaskService取到自己的任务（Task），完成任务可以通过TaskService来进行；
   taskService.completeTask( taskid[, 可以有其他参数] );



获取文件内容
RepositoryService().getResourceAsStream(deploymentId, resourceName);

获取某节点的坐标
RepositoryService().getActivityCoordinates(processDefinitionId, activityName);

获取个人任务列表：
方式1：TaskService().findPersonalTasks(userId);
方式2，TaskService().createTaskQuery()//
                            .assignee(userId)//
                            .page(0, 1000)//
                            .list();

获取流程变量
1，TaskService.getVariable(taskId, variableName);
2，ExecutionService.getVariable(executionId, variableName);

拾取任务
1，  TaskService.takeTask(taskId, userId)，如果任务有assignee，则会抛异常。
2，  processEngine.getTaskService().assignTask(taskId, userId)，转交任务





最新的流程实例（查找 key为ICL的最新版本的流程定义， 然后在最新的流程定义里启动流程实例，当部署了一个新版本， startProcessInstanceByKey方法会自动切换到 最新部署的版本）
ProcessInstance processInstance = executionService.startProcessInstanceByKey("ICL");

新启动的流程实例分配一个key（业务key）（建议定义一个key）
ProcessInstance processInstance = executionService.startProcessInstanceByKey("ICL", "CL92837");

如果没有提供用户定义的key，数据库就会把主键作为key。 这样可以使用如下方式获得id：（不建议使用搜索，太耗资源）
ProcessInstance processInstance = executionService.startProcessInstanceByKey("ICL");
String pid = processInstance.getId();

获得用户的任务列表
List<Task> taskList = taskService.findPersonalTasks("tension");

读取任务数据variables
Set<String> variableNames = taskService.getVariableNames(taskId);
variables = taskService.getVariables(taskId, variableNames);

写入任务数据variables
variables = new HashMap<String, Object>();
variables.put("category", "small");
variables.put("lires", 923874893);
taskService.setVariables(taskId, variables);


查找某一特定流程定义的所有流程实例
List<HistoryProcessInstance> historyProcessInstances = historyService
  .createHistoryProcessInstanceQuery()
  .processDefinitionId("ICL-1")
  .orderAsc(HistoryProcessInstanceQuery.PROPERTY_STARTTIME)
  .list();
或者单独的活动
List<HistoryActivityInstance> histActInsts = historyService
    .createHistoryActivityInstanceQuery()
    .processDefinitionId("ICL-1")
    .activityName("a")
    .list();

获得所有已经执行的节点列表
List<HistoryActivityInstance> histActInsts = historyService
    .createHistoryActivityInstanceQuery()
    .processInstanceId("ICL.12345")
    .list();
上面的查询与通过execution id查询有一些不同。有时execution id和流程实例id是不同的， 当一个节点中使用了定时器，execution id中就会使用额外的后缀， 这就会导致当我们通过execution id查询时， 这个节点不会出现在结果列表中。


返回指定流程定义的所有流程实例并分页
List<ProcessInstance> results = executionService.createProcessInstanceQuery()
                                       .processDefinitionId("my_process_definition")
                                       .notSuspended()
                                       .page(0, 50)
                                       .list();

获得所有查询任务并分页
List<Task> myTasks = taskService.createTaskQuery()
    .processInstanceId(piId)
    .assignee("tension")
    .page(100, 120)
    .orderDesc(TaskQuery.PROPERTY_DUEDATE)
    .list();