org.activiti.engine.task.TaskQuery.active()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(5.1k)|赞(0)|评价(0)|浏览(219)

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

TaskQuery.active介绍

[英]Only selects tasks which are active (ie. not suspended)
[中]仅选择处于活动状态(即未暂停)的任务

代码示例

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

.taskId(request.getTaskId())
.includeProcessVariables()
.active()
.singleResult();

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

.processInstanceId(processInstance.getProcessInstanceId())
.taskDefinitionKey(activityId)
.active()
.singleResult());

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

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

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

private void checkAndNotify() throws Exception
{
  //检查即将过期的task
  Date dueDate = DateTime.now().minus(_parsedPeriodInAdvance).toDate();
  for (Task task : _processEngine.getTaskService().createTaskQuery().active().dueAfter(dueDate).list())
  {
    //是否已经通知?
    if (!_taskNotificationManager.isNotified(task.getId()))
    {
      //没有通知则现在通知
      List<UserDetailsEntity> involvedUsers = IdentityUtils.getUserDetailsFromIds(
        IdentityUtils.getInvolvedUsers(_processEngine.getTaskService(), task, _membershipManager),
        _userDetailsManager);
      if (!involvedUsers.isEmpty())
      {
        _messageNotifier.notify(involvedUsers.toArray(new UserDetailsEntity[0]), task);
      }
      //设置标志
      _taskNotificationManager.setNotified(task.getId());
      Logger.getLogger(getClass()).debug(String.format("notified %s", involvedUsers));
    }
  }
}

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

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

代码示例来源: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.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: org.toxos.process-assertions.activiti/activiti-6_0_0

@Override
public void taskIsUncompleted(final String taskId) {
  // Assert a task exists
  callback.trace(LogMessage.TASK_3, taskId);
  final Task task = getTaskService().createTaskQuery().taskId(taskId).active().singleResult();
  Assert.assertThat(task, is(notNullValue()));
  // Assert the process is not completed
  getAssertFactory().getProcessInstanceAssertable(callback).processIsActive(task.getProcessInstanceId());
}

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

@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: org.ow2.petals/petals-se-activiti

taskQuery.suspended();
} else {
  taskQuery.active();

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

.taskId(request.getTaskId())
.includeProcessVariables()
.active()
.singleResult();

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

.processInstanceId(processInstance.getProcessInstanceId())
.taskDefinitionKey(activityId)
.active()
.singleResult());

代码示例来源:origin: org.activiti/activiti-rest

taskQuery.active();
} else {
 taskQuery.suspended();

相关文章

微信公众号

最新文章

更多