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

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

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

TaskQuery.listPage介绍

暂无

代码示例

代码示例来源：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.taskParentTaskId(getTasksPayload.getParentTaskId());
List<Task> tasks = taskConverter.from(taskQuery.listPage(pageable.getStartIndex(),
                             pageable.getMaxItems()));
return new PageImpl<>(tasks,

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

taskList = query.orderByTaskCreateTime().desc().listPage((pageInfo.getPageNum() - 1) * pageInfo
    .getPageSize(), pageInfo.getPageSize());
pageInfo.setCount((int) count);

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

public List<Item> loadItems(int start, int count) {
 List<Task> tasks = getQuery().listPage(start, count);
 List<Item> items = new ArrayList<Item>();
 for (Task task : tasks) {
  items.add(new TaskListItem(task));
 }
 return items;
}

代码示例来源：origin: org.alfresco/alfresco-repository

private List<WorkflowTask> queryRuntimeTasks(WorkflowTaskQuery query)
{
 // Runtime-tasks only exist on process-instances that are active
 // so no use in querying runtime tasks if not active
 if (!Boolean.FALSE.equals(query.isActive()))
 {
   TaskQuery taskQuery = createRuntimeTaskQuery(query);
   List<Task> results;
   int limit = query.getLimit();
   if (limit > 0)
   {
     results = taskQuery.listPage(0, limit);
   }
   else
   {
     results = taskQuery.list();
   }
   return getValidWorkflowTasks(results);
 }
 return new ArrayList<WorkflowTask>();
}

代码示例来源：origin: Alfresco/alfresco-repository

private List<WorkflowTask> queryRuntimeTasks(WorkflowTaskQuery query)
{
 // Runtime-tasks only exist on process-instances that are active
 // so no use in querying runtime tasks if not active
 if (!Boolean.FALSE.equals(query.isActive()))
 {
   TaskQuery taskQuery = createRuntimeTaskQuery(query);
   List<Task> results;
   int limit = query.getLimit();
   if (limit > 0)
   {
     results = taskQuery.listPage(0, limit);
   }
   else
   {
     results = taskQuery.list();
   }
   return getValidWorkflowTasks(results);
 }
 return new ArrayList<WorkflowTask>();
}

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

@Override
public List<BpmTask> findProcessTasks(ProcessInstance pi,
                   String userLogin,
                   Set<String> taskNames,
                   ProcessToolContext ctx) {
  TaskQuery q = getProcessEngine().getTaskService().createTaskQuery().processInstanceId(pi.getInternalId());
  if (userLogin != null)
    q = q.taskAssignee(userLogin);
  if (taskNames != null && !taskNames.isEmpty())  //TODO what if more than 1 task name is supplied
    q = q.taskName(taskNames.iterator().next());
  List<Task> tasks = q.listPage(0, 1000);
  return collectTasks(tasks, pi, ctx);
}

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

@Override
public List<BpmTask> getTaskData(String taskExecutionId, String taskName, ProcessToolContext ctx) {
  List<Task> tasks = getProcessEngine().getTaskService().createTaskQuery()
      //.notSuspended()
    .taskName(taskName)
      .executionId(taskExecutionId)
      .taskAssignee(user.getLogin())
      .listPage(0, 1);
  if (tasks.isEmpty()) {
    log.warning("Task " + taskExecutionId + " not found");
    return null;
  }
  List<BpmTask> bpmTasks = findProcessInstancesForTasks(tasks, ctx);
  return bpmTasks;
}

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

@Override
public Collection<BpmTask> getAllTasks(ProcessToolContext ctx) {
  return findProcessInstancesForTasks(
      getProcessEngine().getTaskService().createTaskQuery().orderByTaskId().desc().listPage(0, 1000),
      ctx);
}

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

@Override
public List<BpmTask> findUserTasks(Integer offset, Integer limit, ProcessToolContext ctx) {
  List<Task> tasks = getProcessEngine().getTaskService().createTaskQuery()
      .taskAssignee(user.getLogin())
      .listPage(offset, limit);
  return findProcessInstancesForTasks(tasks, ctx);
}

代码示例来源：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: 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: Evolveum/midpoint

public SearchResultList<WorkItemType> searchWorkItems(ObjectQuery query, Collection<SelectorOptions<GetOperationOptions>> options, OperationResult result)
    throws SchemaException {
  TaskQuery taskQuery = createTaskQuery(query, true, options, result);
  if (taskQuery == null) {
    return new SearchResultList<>(Collections.emptyList());
  }
  Integer offset = query != null ? query.getOffset() : null;
  Integer maxSize = query != null ? query.getMaxSize() : null;
  List<Task> tasks;
  if (offset == null && maxSize == null) {
    tasks = taskQuery.list();
  } else {
    tasks = taskQuery.listPage(defaultIfNull(offset, 0), defaultIfNull(maxSize, Integer.MAX_VALUE));
  }
  boolean getAllVariables = true;				// TODO implement based on options
  // there's no need to fill-in assignee details ; but candidates are necessary to fill-in; TODO implement based on options (resolve)
  return tasksToWorkItems(tasks, null, false, false, true, getAllVariables, result);
}

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

代码示例来源：origin: martin-grofcik/activiti-crystalball

List<Task> execTaskList = taskService.createTaskQuery().taskCandidateUser( assignee).orderByTaskPriority().desc().listPage(0, 1);
if ( !execTaskList.isEmpty()) {
  TaskEntity execTask = (TaskEntity) execTaskList.get(0);

代码示例来源：origin: martin-grofcik/activiti-crystalball

List<Task> execTaskList = taskService.createTaskQuery().taskCandidateUser( user.getId()).orderByTaskPriority().desc().listPage(0, 1);
if ( !execTaskList.isEmpty()) {
  Task execTask = execTaskList.get(0);

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

@Override
    public BpmTask refreshTaskData(BpmTask task, ProcessToolContext ctx) {
      MutableBpmTask bpmTask = task instanceof MutableBpmTask ? (MutableBpmTask) task : new MutableBpmTask(task);
      bpmTask.setProcessInstance(getProcessData(task.getProcessInstance().getInternalId(), ctx));

      List<Task> tasks = getProcessEngine().getTaskService().createTaskQuery()
//                   .notSuspended()
          .taskName(task.getTaskName())
          .executionId(task.getExecutionId())
          .taskAssignee(user.getLogin())
          .listPage(0, 1);
      if (tasks.isEmpty()) {
        log.warning("Task " + task.getExecutionId() + " not found");
        bpmTask.setFinished(true);
      }
      return bpmTask;
    }

代码示例来源：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.aperteworkflow/activiti-context

public Collection<ProcessInstance> getUserProcesses(int offset, int limit, ProcessToolContext ctx) {
  List<Task> taskList = getProcessEngine().getTaskService().createTaskQuery()
      .taskAssignee(user.getLogin())
      .orderByExecutionId()
      .desc()
      .listPage(offset, limit);
  List<String> ids = keyFilter("processInstanceId", taskList);
  final Map<String, ProcessInstance> instances = ctx.getProcessInstanceDAO().getProcessInstanceByInternalIdMap(ids);
  return new Mapcar<Task, ProcessInstance>(taskList) {
    @Override
    public ProcessInstance lambda(Task task) {
      ProcessInstance pi = instances.get(task.getProcessInstanceId());
      if (pi == null) {
        log.warning("process " + task.getProcessInstanceId() + " not found");
        return null;
      }
      pi.setState(task.getName());
      pi.setTaskId(task.getId());
      return pi;
    }
  }.go();
}

内容来源于网络，如有侵权，请联系作者删除！

TaskQuery

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    TaskQuery类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com