import org.kie.api.task.model.Task; //导入依赖的package包/类
@Override
public Map<String, Object> getVariablesMapForTaskId(Long taskId) throws RemoteException {
    try
    {
        Task task = AppContext.getService(RemoteWfEngine.class).getRemoteEngine().getTaskService().getTaskById(taskId);
        Content contentById = AppContext.getService(RemoteWfEngine.class).getRemoteEngine().getTaskService().getContentById(task.getTaskData().getDocumentContentId());
        if (contentById == null)
        {
            log.error("Task {} is missing content!", task.getId());
            return new HashMap<String, Object>();
        }
        JaxbContent jaxbTaskContent = (JaxbContent) contentById;
        return jaxbTaskContent.getContentMap();
    }
    catch (RuntimeException e)
    {
        throw new RemoteException("Server error", e);
    }
}
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
public LocalTask(Task task, boolean fetchAttachments) throws RemoteException {
    this.id = task.getId();
    this.name = task.getNames().iterator().next().getText();
    this.status = task.getTaskData().getStatus();
    if (task.getTaskData().getActualOwner() != null) {
        this.owner = task.getTaskData().getActualOwner().getId();
    } else {
        this.owner = "";
    }

    if (fetchAttachments) {
        LocalWorkflowRuntimeEngineBI wfEngine = AppContext.getService(LocalWorkflowRuntimeEngineBI.class);
        Map<String, Object> vmap = wfEngine.getVariablesMapForTaskId(task.getId());
        this.componentId = (String) vmap.get("in_component_id");
        this.componentName = (String) vmap.get("in_component_name");
        this.name = (String) vmap.get("NodeName");
        this.setInputVariables(new HashMap<String, String>());
        for (String key : vmap.keySet()) {
            this.getInputVariables().put(key, vmap.get(key).toString());
        }
    }
}
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
public UserTask(Task task) {

    id = task.getId();
    name = task.getName();
    description = task.getDescription();
    priority = task.getPriority();
    status = task.getTaskData().getStatus().name();

    potentialOwners = task.getPeopleAssignments().getPotentialOwners()
      .stream().map(OrganizationalEntity::getId).collect(Collectors.toList());

  }
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
Task getTask(JBPMConfiguration configuration, Exchange exchange) {
    Task task = exchange.getIn().getHeader(JBPMConstants.TASK, Task.class);
    if (task == null) {
        task = configuration.getTask();
    }
    return task;
}
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
@Test
public void getContentForTasks() {
	TaskService taskService = getRuntimeEngine().getTaskService();

	for (TaskSummary summary : taskService.getTasksAssignedAsPotentialOwner("jboss", null)) {
		Task task = taskService.getTaskById(summary.getId());
		Content c = taskService.getContentById(task.getTaskData().getDocumentContentId());
		HashMap<String, Object> d = (HashMap<String, Object>) ContentMarshallerHelper.unmarshall(c.getContent(), null);
		System.out.println(d);
	}
}
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
public Task getTask() {
    return task;
}
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
/**
 * The task instance to use with task operations
 */
public void setTask(Task task) {
    this.task = task;
}
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
@Override
void execute(KieSession kieSession, TaskService taskService, JBPMConfiguration configuration, Exchange exchange) {
    Task task = taskService.getTaskByWorkItemId(safe(getWorkItemId(configuration, exchange)));
    setResult(exchange, task);
}
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
private void getTasks() {
	RemoteRuntimeEngine engine = remoteRestSessionFactory.newRuntimeEngine();
	// The TaskService class allows we to access the server tasks
	TaskService taskService = engine.getTaskService();
	String USER = "erics";
	List<TaskSummary> tasks = taskService.getTasksAssignedAsPotentialOwner(USER, "en-US");
	if (tasks.size() == 0) {
		System.out.printf("No tasks for user \"%s\" as owner...\n", USER);
	} else {
		System.out.printf("Tasks where user \"%s\" is a an owner...\n", USER);
		for (TaskSummary t : tasks) {
			System.out.printf("ID: %d\n", t.getId());
			System.out.printf("Name: %s\n", t.getName());
			System.out.printf("Actual Owner: %s\n", t.getActualOwner());
			System.out.printf("Created by: %s\n", t.getCreatedBy());
			System.out.printf("Created on: %s\n", t.getCreatedOn());
			System.out.printf("Status: %s\n", t.getStatus());
			System.out.printf("Description: %s\n", t.getDescription());
			// LoanApplication la = (LoanApplication)t.getClass();
			System.out.println("---------------");
			Task userTask = taskService.getTaskById(t.getId());
			TaskData taskData = userTask.getTaskData();

			Map<String, Object> m = taskService.getTaskContent(t.getId());

			StringBuilder sb = new StringBuilder();
			Iterator<Entry<String, Object>> iter = m.entrySet().iterator();
			while (iter.hasNext()) {
				Entry<String, Object> entry = iter.next();
				sb.append(entry.getKey());
				sb.append('=').append('"');
				sb.append(entry.getValue());
				sb.append('"');
				if (iter.hasNext()) {
					sb.append(',').append(' ');
				}
			}
			System.out.println(sb);
		}
	}

}
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
public Task getTask(Long taskId) {
	return userTaskService.getTask(taskId);
}
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
/**
  * Fetches a single task by its unique ID.
  * @param httpRequest
  * @param taskId
  * @throws Exception
  */
 @GET
 @Path("get/{taskId}")
 @Produces(MediaType.APPLICATION_XML)
 public TaskType getTask(@Context HttpServletRequest httpRequest, @PathParam("taskId") long taskId)
         throws Exception {
     assertCurrentUser(httpRequest);

     Task task = taskService.getTaskById(taskId);

     TaskType rval = new TaskType();

     List<I18NText> descriptions = task.getDescriptions();
     if (descriptions != null && !descriptions.isEmpty()) {
         rval.setDescription(descriptions.iterator().next().getText());
     }
     List<I18NText> names = task.getNames();
     if (names != null && !names.isEmpty()) {
         rval.setName(names.iterator().next().getText());
     }
     rval.setPriority(task.getPriority());
     rval.setId(String.valueOf(task.getId()));
     rval.setType(task.getTaskType());
     TaskData taskData = task.getTaskData();
     if (taskData != null) {
         User owner = taskData.getActualOwner();
         if (owner != null) {
             rval.setOwner(owner.getId());
         }
         Date expTime = taskData.getExpirationTime();
         if (expTime != null) {
             GregorianCalendar cal = new GregorianCalendar();
             cal.setTime(expTime);
             DatatypeFactory dtFactory = DatatypeFactory.newInstance();
             rval.setDueDate(dtFactory.newXMLGregorianCalendar(cal));
         }
         rval.setStatus(StatusType.fromValue(taskData.getStatus().toString()));
     }

     long docId = taskService.getTaskById(taskId).getTaskData().getDocumentContentId();

     if (docId > 0) {
      //Set the input params
      Content content = taskService.getContentById(docId);
      @SuppressWarnings("unchecked")
Map<String,Object> inputParams = (Map<String, Object>) ContentMarshallerHelper.unmarshall(content.getContent(), null);

      if (inputParams!=null && inputParams.size() > 0) {
      	if (rval.getTaskData()==null) rval.setTaskData(new TaskDataType());
      	for ( String key : inputParams.keySet()) {
      		Entry entry = new Entry();
      		entry.setKey(key);
      		entry.setValue(String.valueOf(inputParams.get(key)));
		rval.getTaskData().getEntry().add(entry);
	}
      }
     }

     return rval;
 }
 

import org.kie.api.task.model.Task; //导入依赖的package包/类
public void setTask(Task task) {
    this.task = task;
}