jbpmAPI-7

7.6. Task Service and The Process Engine

jBPM引擎而言,人工任务类似于任何其他需要调用外部服务和被实现为一个特定领域的服务。(更多关于特定于域的服务,看到这一章了。)因为一个人工任务是这样一个领域特定服务的一个例子,这一过程本身只包含一个高层次、抽象的描述要执行的人工任务和工作项处理程序负责绑定这个(文摘)任务到一个特定的实现。
用户可以插入任何人工任务服务实现,例如由jBPM提供,或者他们可能注册自己的实现。在接下来的段落中,我们将描述jBPM提供的人工任务服务实现。

jBPM项目提供了一个默认实现基于ws - humantask人工任务服务的规范。如果你不需要集成与另一个现有的jBPM实现人工任务服务的,您可以使用该服务。jBPM实现管理任务的生命周期(创建、声称完成,等)和商店的所有任务,任务列表,和其他相关信息。它还支持功能,如国际化、日历集成不同类型的作业,代表团,升级和最后期限。实现本身的代码可以发现jbpm-human-task模块。
jBPM任务服务实现是基于ws - humantask(WS-HT)规范。这个规范定义了(详细)模型的任务,生命周期,以及许多其他功能。它非常全面和第一个版本可以在这里找到。

7.7. Task Service API

人工任务服务公开了一个Java API来管理任务的生命周期。这允许客户端集成(在低水平)与人工任务服务。注意,终端用户应该不会与这低级API直接交互,但使用一个更具用户友好性任务的客户(见下文)。这些客户提供一个图形用户界面请求任务列表,声明和完成任务,和管理任务。下面列出的任务客户内部使用Java API与人工任务交互服务。当然,低级API也可以,这样开发者就可以在自己的代码中使用它直接与人工任务服务交互。
任务服务(界面org.kie.api.task.TaskService)提供了以下方法(等)管理人工任务的生命周期:

    
              void start( long taskId, String userId );

              void stop( long taskId, String userId );

              void release( long taskId, String userId );

              void suspend( long taskId, String userId );

              void resume( long taskId, String userId );

              void skip( long taskId, String userId );

              void delegate(long taskId, String userId, String targetUserId);

              void complete( long taskId, String userId, Map<String, Object> results );
如果你看一下方法签名,你会发现几乎所有的这些方法采取以下参数:
taskId:任务的id,我们正在处理。这通常是提取用户任务列表中当前选中的任务的用户界面。
用户标识:用户的id执行行动。这通常是用户的id登录到应用程序中。
还有一个内部接口,您应该检查方法与任务服务交互,这个接口是内部,直到它得到测试。未来版本的外部(公共)接口可以包含一些方法提出了InternalTaskService接口。如果你想使用这个接口提供的方法你需要手动把InternalTaskService。一个方法,可以从这个接口有用getTaskContent():

     Map<String, Object> getTaskContent( long taskId );
这种方法可以节省你做所有的锅炉钢板ContentMarshallerContext解组的序列化版本任务内容。如果你只想用稳定/公共API的你可以复制什么这个方法:

    Task taskById = taskQueryService.getTaskInstanceById(taskId);
              Content contentById = taskContentService.getContentById(taskById.getTaskData().getDocumentContentId());
              ContentMarshallerContext context = getMarshallerContext(taskById);
              Object unmarshalledObject = ContentMarshallerHelper.unmarshall(contentById.getContent(), context.getEnvironment(), context.getClassloader());
              if (!(unmarshalledObject instanceof Map)) {
                  throw new IllegalStateException(" The Task Content Needs to be a Map in order to use this method and it was: "+unmarshalledObject.getClass());
      
              }
              Map<String, Object> content = (Map<String, Object>) unmarshalledObject;
              return content;
       因为任务的内容可以是任何对象,前面的方法假设你存储的地图对象的工作。如果你存储地图除了你应该做相应检查。

7.8. Interacting with the Task Service

为了获得任务服务API推荐让运行时管理器,以确保一切都是正确设置。看更多信息,运行时管理器部分。从API的角度来看,你应该做的是这样的:

       ...
              RuntimeEngine engine = runtimeManager.getRuntimeEngine(EmptyContext.get());
              KieSession kieSession = engine.getKieSession();
              // Start a process
              kieSession.startProcess("CustomersRelationship.customers", params);
              // Do Task Operations
              TaskService taskService = engine.getTaskService();
              List<TaskSummary> tasksAssignedAsPotentialOwner = taskService.getTasksAssignedAsPotentialOwner("mary", "en-UK");
              
              // Claim Task
              taskService.claim(taskSummary.getId(), "mary");
              // Start Task
              taskService.start(taskSummary.getId(), "mary");

 如果您使用这种方法,不需要注册流程引擎的任务服务。自动运行时经理会为你这样做。如果你不使用运行时经理,你将负责设置LocalHTWorkItemHandler在会话中为了得到任务服务通知流程引擎当任务完成时,或一个任务的流程引擎通知已创建。
jBPM 6。x任务服务在本地运行流程和规则引擎,因此可以创建多个光客户不同的流程和规则引擎的实例。所有客户端都将共享相同的数据库(后端存储的任务)。