org.camunda.bpm.engine.TaskService.createTaskQuery()方法的使用及代码示例

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

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

TaskService.createTaskQuery介绍

[英]Returns a new TaskQuery that can be used to dynamically query tasks.
[中]返回可用于动态查询任务的新TaskQuery。

代码示例

代码示例来源：origin: camunda/camunda-bpm-platform

public void execute(ProcessEngine engine, String scenarioName) {
  engine
   .getRuntimeService()
   .startProcessInstanceByKey("SubprocessParallelCreateCompensationScenario", scenarioName);
  // create the compensation event subscription for the first user task
  // execution continues from userTask1 to afterUserTask1
  Task userTask = engine.getTaskService().createTaskQuery()
    .processInstanceBusinessKey(scenarioName).taskDefinitionKey("userTask1").singleResult();
  engine.getTaskService().complete(userTask.getId());
 }
};

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment
public void testMultipleCandidateUsers() {
 runtimeService.startProcessInstanceByKey("multipleCandidateUsersExample");
 assertEquals(1, taskService.createTaskQuery().taskCandidateUser(GONZO).list().size());
 assertEquals(1, taskService.createTaskQuery().taskCandidateUser(KERMIT).list().size());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testQueryByName() {
 TaskQuery query = taskService.createTaskQuery().taskName("testTask");
 assertEquals(6, query.list().size());
 assertEquals(6, query.count());
 try {
  query.singleResult();
  fail("expected exception");
 } catch (ProcessEngineException e) {
  // OK
 }
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Override
 public void execute(ProcessEngine engine, String scenarioName) {
  ProcessInstance procInst = engine.getRuntimeService().startProcessInstanceByKey(PROCESS_DEF_KEY, scenarioName);
  List<Task> tasks = engine.getTaskService().createTaskQuery().processInstanceId(procInst.getId()).list();
  if (tasks.size() > 0) {
   engine.getTaskService().complete(tasks.get(0).getId());
  }
 }
};

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources={"org/camunda/bpm/engine/test/api/task/TaskQueryTest.testProcessDefinition.bpmn20.xml"})
public void testQueryByInvalidActivityInstanceId() throws Exception {
 runtimeService.startProcessInstanceByKey("oneTaskProcess");
 assertEquals(0, taskService.createTaskQuery().activityInstanceIdIn("anInvalidActivityInstanceId").list().size());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testQueryByNameLike() {
 TaskQuery query = taskService.createTaskQuery().taskNameLike("gonzo\\_%");
 assertNotNull(query.singleResult());
 assertEquals(1, query.list().size());
 assertEquals(1, query.count());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void execute(ProcessEngine engine, String scenarioName) {
  engine
   .getRuntimeService()
   .startProcessInstanceByKey("InterruptingEventSubprocessCompensationScenario", scenarioName);
  // enter the event subprocess
  engine.getRuntimeService().correlateMessage("Message", scenarioName);
  // create the compensation event subscription and wait before throwing compensation
  Task userTask = engine.getTaskService().createTaskQuery()
    .processInstanceBusinessKey(scenarioName).singleResult();
  engine.getTaskService().complete(userTask.getId());
 }
};

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment
public void testMixedCandidateUserAndGroup() {
 runtimeService.startProcessInstanceByKey("mixedCandidateUserAndGroupExample");
 assertEquals(1, taskService.createTaskQuery().taskCandidateUser(GONZO).list().size());
 assertEquals(1, taskService.createTaskQuery().taskCandidateUser(KERMIT).list().size());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void testQueryByDescriptionLike() {
 TaskQuery query = taskService.createTaskQuery().taskDescriptionLike("%gonzo\\_%");
 assertNotNull(query.singleResult());
 assertEquals(1, query.list().size());
 assertEquals(1, query.count());
}

代码示例来源：origin: camunda/camunda-bpm-platform

public void execute(ProcessEngine engine, String scenarioName) {
  engine
   .getRuntimeService()
   .startProcessInstanceByKey("InterruptingEventSubProcessNestedCompensationScenario", scenarioName);
  // trigger the event subprocess
  engine.getRuntimeService().correlateMessage("EventSubProcessMessage", scenarioName);
  // complete the task to compensate and then throw compensation
  Task innerSubProcessTask = engine.getTaskService().createTaskQuery()
    .processInstanceBusinessKey(scenarioName).singleResult();
  engine.getTaskService().complete(innerSubProcessTask.getId());
 }
};

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources={"org/camunda/bpm/engine/test/api/task/TaskQueryTest.testProcessDefinition.bpmn20.xml"})
public void testProcessInstanceBusinessKey() throws Exception {
 runtimeService.startProcessInstanceByKey("oneTaskProcess", "BUSINESS-KEY-1");
 assertEquals(1, taskService.createTaskQuery().processDefinitionName("The%One%Task%Process").processInstanceBusinessKey("BUSINESS-KEY-1").list().size());
 assertEquals(1, taskService.createTaskQuery().processInstanceBusinessKey("BUSINESS-KEY-1").list().size());
 assertEquals(0, taskService.createTaskQuery().processInstanceBusinessKey("NON-EXISTING").count());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void testServiceTaskTwoExecutionListenerCall() {
 testHelper.deploy(PROCESS_SERVICE_TASK_WITH_TWO_EXECUTION_START_LISTENER);
 runtimeService.startProcessInstanceByKey("Process");
 Task task = taskService.createTaskQuery().taskDefinitionKey("userTask1").singleResult();
 taskService.complete(task.getId());
 assertEquals(0, taskService.createTaskQuery().list().size());
 List<RecordedEvent> recordedEvents = RecorderExecutionListener.getRecordedEvents();
 assertEquals(2, recordedEvents.size());
 assertEquals("sendTask", recordedEvents.get(0).getActivityId());
 assertEquals("endEvent", recordedEvents.get(1).getActivityId());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment
public void testAssigneeExtension() {
 runtimeService.startProcessInstanceByKey("assigneeExtension");
 List<Task> tasks = taskService
  .createTaskQuery()
  .taskAssignee("kermit")
  .list();
 assertEquals(1, tasks.size());
 assertEquals("my task", tasks.get(0).getName());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
 @Deployment
 public void testCompactedExecutionTree() {
  //given process with concurrent execution and conditional events
  runtimeService.startProcessInstanceByKey(CONDITIONAL_EVENT_PROCESS_KEY);

  //when task before cancel is completed
  taskService.complete(taskService.createTaskQuery().taskName(TASK_BEFORE_CONDITION).singleResult().getId());

  //then conditional events are triggered
  tasksAfterVariableIsSet = taskService.createTaskQuery().list();
  assertEquals(1, tasksAfterVariableIsSet.size());
  assertEquals(TASK_AFTER_CONDITIONAL_START_EVENT, tasksAfterVariableIsSet.get(0).getName());
 }
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources={"org/camunda/bpm/engine/test/api/task/TaskQueryTest.testProcessDefinition.bpmn20.xml"})
public void testProcessDefinitionNameLike() throws Exception {
 ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("oneTaskProcess");
 List<Task> tasks = taskService.createTaskQuery().processDefinitionNameLike("The\\%One\\%Task%").list();
 assertEquals(1, tasks.size());
 assertEquals(processInstance.getId(), tasks.get(0).getProcessInstanceId());
 assertEquals(0, taskService.createTaskQuery().processDefinitionNameLike("The One Task").count());
 assertEquals(0, taskService.createTaskQuery().processDefinitionNameLike("The Other Task%").count());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
public void testServiceTaskExecutionListenerCall() {
 testHelper.deploy(PROCESS_SERVICE_TASK_WITH_EXECUTION_START_LISTENER);
 runtimeService.startProcessInstanceByKey("Process");
 Task task = taskService.createTaskQuery().taskDefinitionKey("userTask1").singleResult();
 taskService.complete(task.getId());
 assertEquals(0, taskService.createTaskQuery().list().size());
 List<RecordedEvent> recordedEvents = RecorderExecutionListener.getRecordedEvents();
 assertEquals(1, recordedEvents.size());
 assertEquals("endEvent", recordedEvents.get(0).getActivityId());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources={"org/camunda/bpm/engine/test/api/task/TaskQueryTest.testProcessDefinition.bpmn20.xml"})
public void testProcessDefinitionName() throws Exception {
 ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("oneTaskProcess");
 List<Task> tasks = taskService.createTaskQuery().processDefinitionName("The%One%Task%Process").list();
 assertEquals(1, tasks.size());
 assertEquals(processInstance.getId(), tasks.get(0).getProcessInstanceId());
 assertEquals(0, taskService.createTaskQuery().processDefinitionName("unexisting").count());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
@Deployment(resources = {"org/camunda/bpm/engine/test/bpmn/tasklistener/TaskListenerTest.bpmn20.xml"})
public void testTaskCreateListener() {
 runtimeService.startProcessInstanceByKey("taskListenerProcess");
 Task task = taskService.createTaskQuery().singleResult();
 assertEquals("Schedule meeting", task.getName());
 assertEquals("TaskCreateListener is listening!", task.getDescription());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Deployment(resources={"org/camunda/bpm/engine/test/api/task/TaskQueryTest.testProcessDefinition.bpmn20.xml"})
public void testProcessDefinitionId() throws Exception {
 ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("oneTaskProcess");
 List<Task> tasks = taskService.createTaskQuery().processDefinitionId(processInstance.getProcessDefinitionId()).list();
 assertEquals(1, tasks.size());
 assertEquals(processInstance.getId(), tasks.get(0).getProcessInstanceId());
 assertEquals(0, taskService.createTaskQuery().processDefinitionId("unexisting").count());
}

代码示例来源：origin: camunda/camunda-bpm-platform

@Test
@OperateOnDeployment("clientDeployment")
public void shouldEvaluateCondition() {
 // given
 runtimeService.startProcessInstanceByKey("callingProcessScriptConditionalFlow").getId();
 Task calledProcessTask = taskService.createTaskQuery().singleResult();
 // when the called process instance returns
 taskService.complete(calledProcessTask.getId());
 // then the conditional flow leaving the call activity has been taken
 Task afterCallActivityTask = taskService.createTaskQuery().singleResult();
 Assert.assertNotNull(afterCallActivityTask);
 Assert.assertEquals("afterCallActivityTask", afterCallActivityTask.getTaskDefinitionKey());
}

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

TaskService

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    TaskService类方法

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