本文整理了Java中org.activiti.engine.task.TaskQuery.count()
方法的一些代码示例,展示了TaskQuery.count()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。TaskQuery.count()
方法的具体详情如下:
包路径:org.activiti.engine.task.TaskQuery
类名称:TaskQuery
方法名:count
暂无
代码示例来源: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: Activiti/Activiti
pageable.getMaxItems()));
return new PageImpl<>(tasks,
Math.toIntExact(taskQuery.count()));
代码示例来源:origin: bill1012/AdminEAP
query = query.processCategoryIn(categorys);
count = query.count();
taskList = query.orderByTaskCreateTime().desc().listPage((pageInfo.getPageNum() - 1) * pageInfo
.getPageSize(), pageInfo.getPageSize());
代码示例来源:origin: Evolveum/midpoint
public Integer countWorkItems(ObjectQuery query, Collection<SelectorOptions<GetOperationOptions>> options, OperationResult result) throws SchemaException {
TaskQuery taskQuery = createTaskQuery(query, false, options, result);
return taskQuery != null ? (int) taskQuery.count() : 0;
}
代码示例来源:origin: org.activiti/activiti-explorer
public int size() {
return (int) getQuery().count();
}
代码示例来源:origin: martin-grofcik/activiti-crystalball
/**
* isUser able to work on the new task?
*
* @param userId
* @return
*/
private boolean isUserFree(String userId) {
return taskService.createTaskQuery().taskAssignee( userId).count() == 0;
}
代码示例来源:origin: lcw2004/one
/**
* 统计工作流列表
*
* @param queryCondition
* @return
*/
public long countTaskList(TaskQueryCondition queryCondition) {
try {
TaskQuery taskQuery = queryCondition.createTaskQuery(taskService.createTaskQuery());
return taskQuery.count();
} catch (Exception e) {
logger.error(e.getMessage(), e);
throw new OneBaseException("查询失败:" + e.getMessage());
}
}
代码示例来源:origin: org.aperteworkflow/activiti-context
@Override
public Collection<ProcessQueue> getUserAvailableQueues(ProcessToolContext ctx) {
Collection<ProcessQueue> configs = getUserQueuesFromConfig(ctx);
final List<String> names = keyFilter("name", configs);
if (names.isEmpty()) {
return new ArrayList();
}
TaskService ts = getProcessEngine().getTaskService();
for (ProcessQueue q : configs) {
q.setProcessCount(ts.createTaskQuery().taskCandidateGroup(q.getName()).taskUnnassigned().count());
}
return configs;
}
代码示例来源:origin: henryyan/activiti-dry-cargo
long count = taskService.createTaskQuery().taskDefinitionKey(taskDefinitionKey).processInstanceId(processInstanceId).taskAssignee(userId).count();
if (count > 0) {
logger.warn("忽略重复加签,用户:{}, 任务:{}", userId, taskDefinitionKey);
代码示例来源:origin: lcw2004/one
/**
* 查询工作流列表
*
* @param queryCondition
* @return
*/
public PageInfo<TaskInfoBean> queryTaskList(TaskQueryCondition queryCondition) {
PageInfo<TaskInfoBean> page = queryCondition.getPageInfo();
List<TaskInfoBean> list = new ArrayList<>();
try {
TaskQuery taskQuery = queryCondition.createTaskQuery(taskService.createTaskQuery());
List<Task> taskList = taskQuery.orderByTaskCreateTime().desc().listPage((page.getPageNo() - 1) * page.getPageSize(), page.getPageSize());
page.setCount(taskQuery.count());
for (Task task : taskList) {
list.add(transToTaskInfoBean(task));
}
page.setList(list);
} catch (Exception e) {
logger.error(e.getMessage(), e);
throw new OneBaseException("查询失败:" + e.getMessage());
}
return page;
}
代码示例来源:origin: Alfresco/alfresco-repository
@Override
public long countTasks(WorkflowTaskQuery query) {
long totalCount = 0;
WorkflowTaskState taskState = query.getTaskState();
if(WorkflowTaskState.COMPLETED.equals(taskState) == false)
{
totalCount += createRuntimeTaskQuery(query).count();
}
// Depending on the state, history should be included/excluded as well
if(WorkflowTaskState.IN_PROGRESS.equals(taskState) == false)
{
totalCount += createHistoricTaskQuery(query).count();
}
return totalCount;
}
代码示例来源:origin: org.alfresco/alfresco-repository
@Override
public long countTasks(WorkflowTaskQuery query) {
long totalCount = 0;
WorkflowTaskState taskState = query.getTaskState();
if(WorkflowTaskState.COMPLETED.equals(taskState) == false)
{
totalCount += createRuntimeTaskQuery(query).count();
}
// Depending on the state, history should be included/excluded as well
if(WorkflowTaskState.IN_PROGRESS.equals(taskState) == false)
{
totalCount += createHistoricTaskQuery(query).count();
}
return totalCount;
}
代码示例来源:origin: org.activiti/activiti-explorer
protected boolean canUserClaimTask() {
return taskService.createTaskQuery()
.taskCandidateUser(ExplorerApp.get().getLoggedInUser().getId())
.taskId(task.getId())
.count() == 1;
}
代码示例来源:origin: org.activiti/activiti-spring-boot-starter
processEngine.getTaskService().createTaskQuery().count());
metrics.put("completedTaskCount",
processEngine.getHistoryService().createHistoricTaskInstanceQuery().finished().count());
代码示例来源:origin: com.quhaodian.discover/discover-workflow
@Override
public Page<TaskVo> page(Pageable page, FlowSo so) {
Page<TaskVo> result = null;
TaskQuery query = taskService.createTaskQuery();
if (so != null && so.getName() != null && so.getName().length() > 0) {
query = query.processVariableValueLike("name", "%" + so.getName() + "%");
}
query = query.orderByTaskCreateTime().desc();
Long total = query.count();
List<TaskVo> content = new ArrayList<TaskVo>();
result = new Page<TaskVo>(content, total, page);
int first = (result.getPageNumber() - 1) * page.getPageSize();
if (first < 0) {
first = 0;
}
List<Task> tasks = query.listPage(first, page.getPageSize());
Conver<TaskVo, Task> conver = new TaskVoConver(taskService);
content = ConverUtils.coverList(tasks, conver);
result = new Page<TaskVo>(content, total, page);
return result;
}
代码示例来源:origin: com.quhaodian.discover/discover-workflow
@Override
public Page<TaskVo> page(String username, Pageable page, FlowSo so) {
Page<TaskVo> result = null;
TaskQuery query = taskService.createTaskQuery().taskAssignee(username);
if (so != null && so.getName() != null && so.getName().length() > 0) {
//query=query.includeTaskLocalVariables();
//query=query.includeProcessVariables();
//query=query.taskVariableValueLike("name","%"+so.getName()+"%");
query = query.processVariableValueLike("name", "%" + so.getName() + "%");
}
query = query.orderByTaskCreateTime().desc();
Long total = query.count();
List<TaskVo> content = new ArrayList<TaskVo>();
result = new Page<TaskVo>(content, total, page);
int first = (result.getPageNumber() - 1) * page.getPageSize();
if (first < 0) {
first = 0;
}
List<Task> tasks = query.listPage(first, page.getPageSize());
Conver<TaskVo, Task> conver = new TaskVoConver(taskService);
content = ConverUtils.coverList(tasks, conver);
result = new Page<TaskVo>(content, total, page);
return result;
}
代码示例来源:origin: org.activiti/activiti-explorer
} else if (loggedInUserId.equals(task.getAssignee())) {
showInboxPage(taskId);
} else if (taskService.createTaskQuery().taskInvolvedUser(loggedInUserId).count() == 1) {
showInvolvedPage(taskId);
} else {
代码示例来源:origin: org.activiti/activiti-explorer
.taskId(task.getId())
.taskCandidateGroup(groupId)
.count() == 1;
boolean isUserInvolved = taskService.createTaskQuery()
.taskInvolvedUser(loggedInUserId)
.count() == 1;
内容来源于网络,如有侵权,请联系作者删除!