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

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

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

TaskQuery.taskAssignee介绍

[英]Only select tasks which are assigned to the given user.
[中]仅选择分配给给定用户的任务。

代码示例

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

Task task = taskService.createTaskQuery().processInstanceId(processInstance.getProcessInstanceId()).taskAssignee(startUserId).singleResult();

代码示例来源：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: org.activiti/activiti-explorer

@Override
protected TaskQuery getQuery() {
 return taskService.createTaskQuery().taskAssignee(userId).orderByTaskId().asc();
}

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

@Override
public List<Task> listAssigneeTasks(String userIdentity) {
  return taskService.createTaskQuery().taskAssignee(userIdentity).orderByTaskCreateTime().asc().list();
}

代码示例来源：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.hswebframework.web/hsweb-system-workflow-local

@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: gem-team/gem

/**
 * @Description:流程列表
 * @param id 用户主键
 * @author: Ryan
 * @date 2018年11月18日
 */
public List<TaskDetails> findTaskList(String id) {
  List<TaskDetails> arrayList = new ArrayList<TaskDetails>();
  TaskQuery createTaskQuery = taskService.createTaskQuery();
  createTaskQuery.taskAssignee(id);
  List<Task> list = createTaskQuery.list();
  if(list!=null && list.size()>0) {
    for (Task task : list) {
      TaskDetails taskDetails = new TaskDetails();
      String id2 = task.getId();
      taskDetails.setId(id2);
      taskDetails.setName(task.getName());
      taskDetails.setVariables(taskService.getVariables(id2));
      arrayList.add(taskDetails);
    }
  }
  return arrayList;
}

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

private List<Task> findUserTask(final ProcessInstance processInstance, ProcessToolContext ctx) {
  return getProcessEngine().getTaskService().createTaskQuery().processInstanceId(processInstance.getInternalId())
      .taskAssignee(user.getLogin()).list();
}

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

for (User user : users) {
  if ( !isUserFree( user.getId() )) {
    for ( Task execTask : taskService.createTaskQuery().taskAssignee( user.getId() ).list()) {

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

.taskAssignee(authority);

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

public void buttonClick(ClickEvent event) {
 // Check if process-definition defines a start-form
 
 StartFormData startFormData = formService.getStartFormData(processDefinition.getId());
 if(startFormData != null && ((startFormData.getFormProperties() != null && !startFormData.getFormProperties().isEmpty()) || startFormData.getFormKey() != null)) {
  parentPage.showStartForm(processDefinition, startFormData);
 } else {
  // Just start the process-instance since it has no form.
  // TODO: Error handling
  ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());
  
  // Show notification of success
  notificationManager.showInformationNotification(Messages.PROCESS_STARTED_NOTIFICATION, getProcessDisplayName(processDefinition));
  
  // Switch to inbox page in case a task of this process was created
  List<Task> loggedInUsersTasks = taskService.createTaskQuery()
   .taskAssignee(ExplorerApp.get().getLoggedInUser().getId())
   .processInstanceId(processInstance.getId())
   .list();
  if (!loggedInUsersTasks.isEmpty()) {
   ExplorerApp.get().getViewManager().showInboxPage(loggedInUsersTasks.get(0).getId());
  }
 }
}

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

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

taskQuery.taskAssignee(query.getActorId());

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

taskQuery.taskAssignee(query.getActorId());

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

TaskQuery

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    TaskQuery类方法

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