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

TaskService.createTaskQuery介绍

[英]Returns a new TaskQuery that can be used to dynamically query tasks.
[中]返回可用于动态查询任务的新TaskQuery。

代码示例

代码示例来源：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: hs-web/hsweb-framework

@Override
public Task selectTaskByTaskId(String taskId) {
  return taskService
      .createTaskQuery()
      .taskId(taskId)
      .active()
      .singleResult();
}

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

public org.activiti.engine.task.Task getInternalTask(String taskId) {
  org.activiti.engine.task.Task internalTask = taskService.createTaskQuery().taskId(taskId).singleResult();
  if (internalTask == null) {
    throw new NotFoundException("Unable to find task for the given id: " + taskId);
  }
  return internalTask;
}

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

@GetMapping("/claims-and-todo")
@ApiOperation("获取待签收和待处理的任务")
@Authorize(merge = false)
public ResponseMessage<PagerResult<TaskInfo>> getClaimsAndTodo(QueryParamEntity query, Authentication authentication) {
  TaskQuery taskQuery = taskService.createTaskQuery();
  taskQuery.taskCandidateOrAssigned(authentication.getUser().getId());
  PagerResult<TaskInfo> result = QueryUtils.doQuery(taskQuery, query, TaskInfo::of);
  return ResponseMessage.ok(result);
}

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

@GetMapping("/claims")
@ApiOperation("获取待签收任务")
@Authorize(merge = false)
public ResponseMessage<PagerResult<TaskInfo>> getClaims(QueryParamEntity query, Authentication authentication) {
  TaskQuery taskQuery = taskService.createTaskQuery();
  taskQuery.taskCandidateUser(authentication.getUser().getId());
  PagerResult<TaskInfo> result = QueryUtils.doQuery(taskQuery, query, TaskInfo::of);
  return ResponseMessage.ok(result);
}

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

@Override
public ActivityImpl selectActivityImplByTask(String taskId) {
  if (StringUtils.isNullOrEmpty(taskId)) {
    return new ActivityImpl(null, null);
  }
  Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
  ProcessDefinitionEntity entity = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService).getDeployedProcessDefinition(task.getProcessDefinitionId());
  List<ActivityImpl> activities = entity.getActivities();
  return activities
      .stream()
      .filter(activity -> "userTask".equals(activity.getProperty("type")) && activity.getProperty("name").equals(task.getName()))
      .findFirst()
      .orElseThrow(() -> new NotFoundException("获取节点信息失败"));
}

代码示例来源：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

public org.activiti.engine.task.Task getInternalTaskWithChecks(String taskId) {
  String authenticatedUserId = getAuthenticatedUser();
  if (authenticatedUserId != null && !authenticatedUserId.isEmpty() && userGroupManager!=null) {
    
    List<String> userRoles = userGroupManager.getUserRoles(authenticatedUserId);
    List<String> userGroups = userGroupManager.getUserGroups(authenticatedUserId);
    org.activiti.engine.task.Task task = taskService.createTaskQuery().taskCandidateOrAssigned(authenticatedUserId,
                                                  userGroups).taskId(taskId).singleResult();
    if (task == null) {
      throw new NotFoundException("Unable to find task for the given id: " + taskId + " for user: " + authenticatedUserId + " (with groups: " + userGroups + " & with roles: " + userRoles + ")");
    }
    
    return task;
  }
  throw new IllegalStateException("There is no authenticated user, we need a user authenticated to find tasks");
}

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

private List<IdentityLink> getIdentityLinks(String taskId) {
  String authenticatedUserId = securityManager.getAuthenticatedUserId();
  if (authenticatedUserId != null && !authenticatedUserId.isEmpty()) {
    List<String> userRoles = userGroupManager.getUserRoles(authenticatedUserId);
    List<String> userGroups = userGroupManager.getUserGroups(authenticatedUserId);
    org.activiti.engine.task.Task internalTask = taskService.createTaskQuery().taskCandidateOrAssigned(authenticatedUserId,
                                                      userGroups).taskId(taskId).singleResult();
    if (internalTask == null) {
      throw new NotFoundException("Unable to find task for the given id: " + taskId + " for user: " + authenticatedUserId + " (with groups: " + userGroups + " & with roles: " + userRoles + ")");
    }   
    return taskService.getIdentityLinksForTask(taskId);
  }
  throw new IllegalStateException("There is no authenticated user, we need a user authenticated to find tasks");
}

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

@GetMapping("/todo")
@ApiOperation("获取待办任务")
@Authorize(merge = false)
public ResponseMessage<PagerResult<TaskInfo>> getTodoList(QueryParamEntity query, Authentication authentication) {
  TaskQuery taskQuery = taskService.createTaskQuery();
  taskQuery.taskAssignee(authentication.getUser().getId());
  PagerResult<TaskInfo> result = QueryUtils.doQuery(taskQuery, query, TaskInfo::of);
  return ResponseMessage.ok(result).exclude(query.getExcludes()).include(query.getIncludes());
}

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

Authentication authentication) {
Task task = taskService.createTaskQuery()
    .taskId(taskId)
    .singleResult();

代码示例来源：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

processEngine.getTaskService().createTaskQuery().count());
metrics.put("completedTaskCount",
      processEngine.getHistoryService().createHistoricTaskInstanceQuery().finished().count());

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

@Override
public void claim(String taskId, String userId) {
  Task task = taskService.createTaskQuery().
      taskId(taskId)
      .taskCandidateUser(userId)
      .active()
      .singleResult();
  if (task == null) {
    throw new NotFoundException("无法签收此任务");
  }
  if (!StringUtils.isNullOrEmpty(task.getAssignee())) {
    throw new BusinessException("任务已签售");
  } else {
    taskService.claim(taskId, userId);
  }
}

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

request.tryValidate();
Task task = taskService.createTaskQuery()
    .taskId(request.getTaskId())
    .singleResult();

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

@Override
public Page<Task> tasks(Pageable pageable,
            GetTasksPayload getTasksPayload) {
  TaskQuery taskQuery = taskService.createTaskQuery();
  if (getTasksPayload == null) {
    getTasksPayload = TaskPayloadBuilder.tasks().build();

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

request.tryValidate();
Task task = taskService.createTaskQuery()
    .taskId(request.getTaskId())
    .includeProcessVariables()

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

} else {
  candidateUserSetter.accept(taskService
      .createTaskQuery()
      .processInstanceId(processInstance.getProcessInstanceId())
      .taskDefinitionKey(activityId)

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

@Override
public String getStartUserId(String taskId) {
  Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
  HistoricProcessInstance historicProcessInstance =
      historyService.createHistoricProcessInstanceQuery()
          .processInstanceId(task.getProcessInstanceId())
          .singleResult();
  return historicProcessInstance.getStartUserId();
}