本文整理了Java中org.activiti.engine.task.TaskQuery.active()
方法的一些代码示例,展示了TaskQuery.active()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。TaskQuery.active()
方法的具体详情如下:
包路径:org.activiti.engine.task.TaskQuery
类名称: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();
内容来源于网络,如有侵权,请联系作者删除!