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

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

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

TaskService.complete介绍

[英]Marks a task as done and continues process execution. This method is typically called by a task list user interface after a task form has been submitted by the Task#getAssignee().
[中]将任务标记为已完成并继续执行流程。此方法通常在任务#getAssignee（）提交任务表单后由任务列表用户界面调用。

代码示例

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

public void execute(ProcessEngine engine, String scenarioName) {
  engine
   .getRuntimeService()
   .startProcessInstanceByKey("ParallelMultiInstanceCompensationSubProcessHandlerScenario", scenarioName);
  // complete two out of three MI tasks
  List<Task> miTasks = engine.getTaskService().createTaskQuery()
    .processInstanceBusinessKey(scenarioName).list();
  engine.getTaskService().complete(miTasks.get(0).getId());
  engine.getTaskService().complete(miTasks.get(1).getId());
 }
};

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

private void completeTasks(String taskName, int times) {
 List<Task> tasks = taskService.createTaskQuery().taskName(taskName).list();
 assertTrue("Actual there are " + tasks.size() + " open tasks with name '" + taskName + "'. Expected at least " + times, times <= tasks.size());
 Iterator<Task> taskIterator = tasks.iterator();
 for (int i = 0; i < times; i++) {
  Task task = taskIterator.next();
  taskService.complete(task.getId());
 }
}

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

protected void completeTasksInOrder(String... taskNames) {
  for (String taskName : taskNames) {
   // complete any task with that name
   List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey(taskName).listPage(0, 1);
   assertTrue("task for activity " + taskName + " does not exist", !tasks.isEmpty());
   taskService.complete(tasks.get(0).getId());
  }
 }
}

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

public void execute(ProcessEngine engine, String scenarioName) {
  engine
   .getRuntimeService()
   .startProcessInstanceByKey("ParallelMultiInstanceCompensationSingleActivityHandlerScenario", scenarioName);
  // complete two out of three MI tasks
  List<Task> miTasks = engine.getTaskService().createTaskQuery()
    .processInstanceBusinessKey(scenarioName).list();
  engine.getTaskService().complete(miTasks.get(0).getId());
  engine.getTaskService().complete(miTasks.get(1).getId());
 }
};

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

protected void completeTasksInOrder(String... taskNames) {
  for (String taskName : taskNames) {
   // complete any task with that name
   List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey(taskName).listPage(0, 1);
   assertTrue("task for activity " + taskName + " does not exist", !tasks.isEmpty());
   taskService.complete(tasks.get(0).getId());
  }
 }
}

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

public void execute(ProcessEngine engine, String scenarioName) {
  engine
   .getRuntimeService()
   .startProcessInstanceByKey("ParallelMultiInstanceCompensationDefaultHandlerScenario", scenarioName);
  // complete two out of three MI tasks
  List<Task> miTasks = engine.getTaskService().createTaskQuery()
    .processInstanceBusinessKey(scenarioName).list();
  engine.getTaskService().complete(miTasks.get(0).getId());
  engine.getTaskService().complete(miTasks.get(1).getId());
 }
};

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

protected void completeTasksInOrder(String... taskNames) {
  for (String taskName : taskNames) {
   // complete any task with that name
   List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey(taskName).listPage(0, 1);
   assertTrue("task for activity " + taskName + " does not exist", !tasks.isEmpty());
   taskService.complete(tasks.get(0).getId());
  }
 }
}

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

protected void completeTasksInOrder(String... taskNames) {
  for (String taskName : taskNames) {
   // complete any task with that name
   List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey(taskName).listPage(0, 1);
   assertTrue("task for activity " + taskName + " does not exist", !tasks.isEmpty());
   taskService.complete(tasks.get(0).getId());
  }
 }
}

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

protected void completeTasksInOrder(String... taskNames) {
 for (String taskName : taskNames) {
  // complete any task with that name
  List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey(taskName).listPage(0, 1);
  assertTrue("task for activity " + taskName + " does not exist", !tasks.isEmpty());
  taskService.complete(tasks.get(0).getId());
 }
}

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

protected void completeTasksInOrder(String... taskNames) {
 for (String taskName : taskNames) {
  // complete any task with that name
  List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey(taskName).listPage(0, 1);
  assertTrue("task for activity " + taskName + " does not exist", !tasks.isEmpty());
  taskService.complete(tasks.get(0).getId());
 }
}

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

protected void completeTasksInOrder(String... taskNames) {
  for (String taskName : taskNames) {
   // complete any task with that name
   List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey(taskName).listPage(0, 1);
   assertTrue("task for activity " + taskName + " does not exist", !tasks.isEmpty());
   taskService.complete(tasks.get(0).getId());
  }
 }
}

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

@Test
@Deployment
public void testExecutionListenerOnTerminateEndEvent() {
 RecorderExecutionListener.clear();
 runtimeService.startProcessInstanceByKey("oneTaskProcess");
 Task task = taskService.createTaskQuery().singleResult();
 taskService.complete(task.getId());
 List<RecordedEvent> recordedEvents = RecorderExecutionListener.getRecordedEvents();
 assertEquals(2, recordedEvents.size());
 assertEquals("start", recordedEvents.get(0).getEventName());
 assertEquals("end", recordedEvents.get(1).getEventName());
}

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

protected void completeTasksInOrder(String... taskNames) {
 for (String taskName : taskNames) {
  // complete any task with that name
  List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey(taskName).listPage(0, 1);
  assertTrue("task for activity " + taskName + " does not exist", !tasks.isEmpty());
  taskService.complete(tasks.get(0).getId());
 }
}

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

@Test
public void testPriorityOnAsyncAfterUserTask() {
 // given
 processInstance = runtimeService.startProcessInstanceByKey("userTaskProcess");
 Task task = taskService.createTaskQuery().singleResult();
 // when
 taskService.complete(task.getId());
 // then
 Job asyncAfterJob = managementService.createJobQuery().singleResult();
 Assert.assertEquals(PriorityBean.PRIORITY, asyncAfterJob.getPriority());
}

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

protected void completeTasksInOrder(String... taskNames) {
  for (String taskName : taskNames) {
   // complete any task with that name
   List<Task> tasks = taskService.createTaskQuery().taskDefinitionKey(taskName).listPage(0, 1);
   assertTrue("task for activity " + taskName + " does not exist", !tasks.isEmpty());
   taskService.complete(tasks.get(0).getId());
  }
 }
}

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

@Test
public void testCompletionIsNotPossibleOnComplete () {
 // expect
 thrown.expect(ProcessEngineException.class);
 thrown.expectMessage(containsString("invalid task state"));
 //given
 createProcessWithListener(TaskListener.EVENTNAME_COMPLETE);
 //when
 runtimeService.startProcessInstanceByKey(TASK_LISTENER_PROCESS);
 Task task = taskService.createTaskQuery().singleResult();
 taskService.complete(task.getId());
}

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

TaskService

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    TaskService类方法

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