本文整理了Java中org.activiti.engine.task.TaskQuery.processInstanceId()方法的一些代码示例，展示了TaskQuery.processInstanceId()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TaskQuery.processInstanceId()方法的具体详情如下：
包路径：org.activiti.engine.task.TaskQuery
类名称：TaskQuery
方法名：processInstanceId

TaskQuery.processInstanceId介绍

[英]Only select tasks for the given process instance id.
[中]仅为给定流程实例id选择任务。

代码示例

代码示例来源：origin: hs-web/hsweb-framework

@Override
public List<Task> selectNowTask(String procInstId) {
  return taskService.createTaskQuery()
      .processInstanceId(procInstId)
      .active()
      .list();
}

代码示例来源：origin: hs-web/hsweb-framework

@Override
public List<Task> selectTaskByProcessId(String procInstId) {
  return taskService
      .createTaskQuery()
      .processInstanceId(procInstId)
      .active()
      .list();
}

代码示例来源：origin: Activiti/Activiti

@Override
  public Optional<TaskCancelledEvent> from(ActivitiActivityCancelledEvent internalEvent) {
    List<org.activiti.engine.task.Task> tasks = taskService.createTaskQuery()
        .processInstanceId(internalEvent.getProcessInstanceId())
        .taskDefinitionKey(internalEvent.getActivityId())
        .list();
    TaskCancelledEvent event = null;
    if (!tasks.isEmpty()) {
      Task task = taskConverter.from(tasks.get(0));
      ((TaskImpl) task).setStatus(Task.TaskStatus.CANCELLED);
      event = new TaskCancelledImpl(task);
    }
    return Optional.ofNullable(event);
  }
}

代码示例来源：origin: Activiti/Activiti

@Override
public Page<Task> tasks(Pageable pageable,
            GetTasksPayload getTasksPayload) {
  TaskQuery taskQuery = taskService.createTaskQuery();
  if (getTasksPayload.getProcessInstanceId() != null) {
    taskQuery = taskQuery.processInstanceId(getTasksPayload.getProcessInstanceId());
  }
  if (getTasksPayload.getParentTaskId() != null) {
    taskQuery = taskQuery.taskParentTaskId(getTasksPayload.getParentTaskId());
  }
  List<Task> tasks = taskConverter.from(taskQuery.listPage(pageable.getStartIndex(),
                               pageable.getMaxItems()));
  return new PageImpl<>(tasks,
             Math.toIntExact(taskQuery.count()));
}

代码示例来源：origin: Activiti/Activiti

taskQuery = taskQuery.processInstanceId(getTasksPayload.getProcessInstanceId());

代码示例来源：origin: hs-web/hsweb-framework

candidateUserSetter.accept(taskService
    .createTaskQuery()
    .processInstanceId(processInstance.getProcessInstanceId())
    .taskDefinitionKey(activityId)
    .active()

代码示例来源：origin: bluejoe2008/openwebflow

private TaskEntity getCurrentTask()
{
  return (TaskEntity) _processEngine.getTaskService().createTaskQuery().processInstanceId(_processInstanceId)
      .active().singleResult();
}

代码示例来源：origin: bill1012/AdminEAP

Task task = taskService.createTaskQuery().processInstanceId(processInstance.getProcessInstanceId()).taskAssignee(startUserId).singleResult();

代码示例来源：origin: bill1012/AdminEAP

/**
 * 流程撤回  TODO MESSAGE 流程撤回需要给相关人员发送消息提醒
 *
 * @param instanceId 历史流程实例ID
 * @param userId     用户ID
 * @return
 */
@Override
public Result withdrawTask(String instanceId, String userId) {
  HistoricProcessInstance processInstance = historyService.createHistoricProcessInstanceQuery().processInstanceId
      (instanceId).singleResult();
  Result result = this.canWithdraw(processInstance, userId);
  if (!result.isSuccess()) {
    return new Result(false, "不可撤回", "该任务已经被签收或者办理，无法撤回，请查看流程明细");
  } else {
    HistoricTaskInstance taskInstance = (HistoricTaskInstance) result.getData();
    final TaskEntity task = (TaskEntity) taskService.createTaskQuery().processInstanceId(instanceId).singleResult();
    try {
      this.jumpTask(task, taskInstance.getTaskDefinitionKey());
      //删除历史记录，填充签收人
      this.deleteCurrentTaskInstance(task.getId(), taskInstance);
      return new Result(true);
    } catch (Exception ex) {
      return new Result(false, "撤回异常", "任务撤回发生异常,异常原因：" + ex.getMessage());
    }
  }
}

代码示例来源：origin: com.bbossgroups.pdp/pdp-workflow

public List<Task> listTaskByProcessInstanceId(String processInstanceId) {
  return taskService.createTaskQuery()
      .processInstanceId(processInstanceId).list();
}

代码示例来源：origin: org.hswebframework.web/hsweb-system-workflow-local

@Override
public List<Task> selectTaskByProcessId(String procInstId) {
  return taskService
      .createTaskQuery()
      .processInstanceId(procInstId)
      .active()
      .list();
}

代码示例来源：origin: org.hswebframework.web/hsweb-system-workflow-local

@Override
public List<Task> selectNowTask(String procInstId) {
  return taskService.createTaskQuery()
      .processInstanceId(procInstId)
      .active()
      .list();
}

代码示例来源：origin: org.aperteworkflow/activiti-context

private List<Task> findProcessTasks(final ProcessInstance processInstance, ProcessToolContext ctx,
                  final boolean mustHaveAssignee) {
  List<Task> list = getProcessEngine().getTaskService().createTaskQuery()
      .processInstanceId(processInstance.getInternalId()).list();
  if (!mustHaveAssignee)
    return list;
  List<Task> res = new ArrayList<Task>();
  for (Task t : list) {
    if (t.getAssignee() != null) res.add(t);
  }
  return res;
}

代码示例来源：origin: com.bbossgroups.pdp/pdp-workflow

@Override
public Task getCurrentTask(String processInstanceId) {
  List<Task> taskList = taskService.createTaskQuery()
      .processInstanceId(processInstanceId).orderByTaskId().desc()
      .list();
  if (!CollectionUtils.isEmpty(taskList)) {
    return taskList.get(0);
  }
  return null;
}

代码示例来源：origin: org.toxos.process-assertions.activiti/activiti-6_0_0

@Override
public void taskIsUncompleted(final String processInstanceId, final String taskDefinitionKey) {
  // Assert the process is not completed
  getAssertFactory().getProcessInstanceAssertable(callback).processIsActive(processInstanceId);
  // Assert a task exists
  callback.trace(LogMessage.TASK_4, taskDefinitionKey, processInstanceId);
  final List<Task> tasks = getTaskService().createTaskQuery().processInstanceId(processInstanceId).taskDefinitionKey(taskDefinitionKey).active().list();
  Assert.assertThat(tasks, is(notNullValue()));
  Assert.assertThat(tasks.isEmpty(), is(false));
}

代码示例来源：origin: com.bbossgroups.pdp/pdp-workflow

public List<Task> getCurrentTaskList(String processInstanceId) {
  List<Task> taskList = taskService.createTaskQuery()
      .processInstanceId(processInstanceId).orderByTaskId().desc()
      .list();
  if (!CollectionUtils.isEmpty(taskList)) {
    return taskList;
  }
  return null;
}

代码示例来源：origin: org.aperteworkflow/activiti-context

@Override
public Collection<BpmTask> getProcessTaskInQueues(ProcessToolContext ctx, ProcessInstance processInstance) {
  List<Task> tasks = getProcessEngine()
      .getTaskService()
      .createTaskQuery()
      .processInstanceId(processInstance.getInternalId()).list();
  return findProcessInstancesForTasks(tasks, ctx);
}

代码示例来源：origin: Evolveum/midpoint

public SearchResultList<WorkItemType> getWorkItemsForProcessInstanceId(String processInstanceId, OperationResult result) {
  TaskService ts = activitiEngine.getTaskService();
  List<Task> tasks = ts.createTaskQuery()
      .processInstanceId(processInstanceId)
      .includeTaskLocalVariables()
      .includeProcessVariables()
      .list();
  return tasksToWorkItems(tasks, null, false, true, true, true, result);
}

代码示例来源：origin: org.aperteworkflow/activiti-context

@Override
public List<BpmTask> findProcessTasks(ProcessInstance pi, ProcessToolContext ctx) {
  List<Task> tasks = getProcessEngine().getTaskService().createTaskQuery()
      .processInstanceId(pi.getInternalId())
      .listPage(0, 1000);
  return collectTasks(tasks, pi, ctx);
}

代码示例来源：origin: org.aperteworkflow/activiti-context

@Override
public List<BpmTask> findUserTasks(ProcessInstance processInstance, ProcessToolContext ctx) {
  List<Task> tasks = getProcessEngine().getTaskService().createTaskQuery()
      .processInstanceId(processInstance.getInternalId())
      .taskAssignee(user.getLogin())
      .listPage(0, 1000);
  return collectTasks(tasks, processInstance, ctx);
}