org.camunda.bpm.engine.task.Task.getProcessDefinitionId()方法的使用及代码示例

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

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

Task.getProcessDefinitionId介绍

[英]Reference to the process definition or null if it is not related to a process.
[中]对流程定义的引用,如果与流程无关,则为null。

代码示例

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

public Task build() {
 Task mockTask = mock(Task.class);
 when(mockTask.getId()).thenReturn(id);
 when(mockTask.getName()).thenReturn(name);
 when(mockTask.getAssignee()).thenReturn(assignee);
 when(mockTask.getCreateTime()).thenReturn(createTime);
 when(mockTask.getDueDate()).thenReturn(dueDate);
 when(mockTask.getFollowUpDate()).thenReturn(followUpDate);
 when(mockTask.getDelegationState()).thenReturn(delegationState);
 when(mockTask.getDescription()).thenReturn(description);
 when(mockTask.getExecutionId()).thenReturn(executionId);
 when(mockTask.getOwner()).thenReturn(owner);
 when(mockTask.getParentTaskId()).thenReturn(parentTaskId);
 when(mockTask.getPriority()).thenReturn(priority);
 when(mockTask.getProcessDefinitionId()).thenReturn(processDefinitionId);
 when(mockTask.getProcessInstanceId()).thenReturn(processInstanceId);
 when(mockTask.getTaskDefinitionKey()).thenReturn(taskDefinitionKey);
 when(mockTask.getCaseDefinitionId()).thenReturn(caseDefinitionId);
 when(mockTask.getCaseInstanceId()).thenReturn(caseInstanceId);
 when(mockTask.getCaseExecutionId()).thenReturn(caseExecutionId);
 when(mockTask.getFormKey()).thenReturn(formKey);
 when(mockTask.getTenantId()).thenReturn(tenantId);
 return mockTask;
}

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

/**
 * Assuming that the task belongs to no process definition
 */
@Test
public void getFormForIndependentTask() {
 when(mockTask.getProcessDefinitionId()).thenReturn(null);
 given().pathParam("id", EXAMPLE_TASK_ID)
  .header("accept", MediaType.APPLICATION_JSON)
  .then().expect().statusCode(Status.OK.getStatusCode())
  .body("key", equalTo(MockProvider.EXAMPLE_FORM_KEY))
  .body("contextPath", nullValue())
  .when().get(TASK_FORM_URL);
 verify(repositoryServiceMock, never()).getProcessDefinition(null);
}

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

@Test
public void testGetTaskFormKeyWithNoAuthenticatedTenant() {
 testRule.deployForTenant(TENANT_ONE,
  "org/camunda/bpm/engine/test/api/authorization/formKeyProcess.bpmn20.xml");
 
 runtimeService.startProcessInstanceByKey(PROCESS_DEFINITION_KEY);
 
 Task task = taskService.createTaskQuery().singleResult();
 
 identityService.setAuthentication("aUserId", null);
 // then
 thrown.expect(ProcessEngineException.class);
 thrown.expectMessage("Cannot get the process definition '" + task.getProcessDefinitionId()
  +"' because it belongs to no authenticated tenant.");
 // when
 formService.getTaskFormKey(task.getProcessDefinitionId(), task.getTaskDefinitionKey());
 
}

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

@Test
 public void testGetTaskFormKeyWithDisabledTenantCheck() {

  testRule.deployForTenant(TENANT_ONE,
   "org/camunda/bpm/engine/test/api/authorization/formKeyProcess.bpmn20.xml");
  
  runtimeService.startProcessInstanceByKey(PROCESS_DEFINITION_KEY);
  
  Task task = taskService.createTaskQuery().singleResult();
  
  identityService.setAuthentication("aUserId", null);
  processEngineConfiguration.setTenantCheckEnabled(false);

  formService.getTaskFormKey(task.getProcessDefinitionId(), task.getTaskDefinitionKey());
  // then
  assertEquals("aTaskFormKey", formService.getTaskFormKey(task.getProcessDefinitionId(), task.getTaskDefinitionKey()));
 }
}

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

@Test
public void testGetTaskFormKeyWithAuthenticatedTenant() {
 testRule.deployForTenant(TENANT_ONE,
  "org/camunda/bpm/engine/test/api/authorization/formKeyProcess.bpmn20.xml");
 
 runtimeService.startProcessInstanceByKey(PROCESS_DEFINITION_KEY);
 
 Task task = taskService.createTaskQuery().singleResult();
 
 identityService.setAuthentication("aUserId", null, Arrays.asList(TENANT_ONE));
 assertEquals("aTaskFormKey", formService.getTaskFormKey(task.getProcessDefinitionId(), task.getTaskDefinitionKey()));
 
}

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

@Deployment(resources = "org/camunda/bpm/engine/test/api/form/FormsProcess.bpmn20.xml")
@Test
public void testGetTaskFormKey() {
 String processDefinitionId = repositoryService.createProcessDefinitionQuery().singleResult().getId();
 runtimeService.startProcessInstanceById(processDefinitionId);
 Task task = taskService.createTaskQuery().singleResult();
 assertNotNull(task);
 String expectedFormKey = formService.getTaskFormData(task.getId()).getFormKey();
 String actualFormKey = formService.getTaskFormKey(task.getProcessDefinitionId(), task.getTaskDefinitionKey());
 assertEquals(expectedFormKey, actualFormKey);
}

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

dto.parentTaskId = task.getParentTaskId();
dto.priority = task.getPriority();
dto.processDefinitionId = task.getProcessDefinitionId();
dto.processInstanceId = task.getProcessInstanceId();
dto.taskDefinitionKey = task.getTaskDefinitionKey();

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

@Deployment
public void testTaskPropertiesNotNull() {
 ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("oneTaskProcess");
 List<String> activeActivityIds = runtimeService.getActiveActivityIds(processInstance.getId());
 Task task = taskService.createTaskQuery().singleResult();
 assertNotNull(task.getId());
 assertEquals("my task", task.getName());
 assertEquals("Very important", task.getDescription());
 assertTrue(task.getPriority() > 0);
 assertEquals("kermit", task.getAssignee());
 assertEquals(processInstance.getId(), task.getProcessInstanceId());
 assertEquals(processInstance.getId(), task.getExecutionId());
 assertNotNull(task.getProcessDefinitionId());
 assertNotNull(task.getTaskDefinitionKey());
 assertNotNull(task.getCreateTime());
 // the next test verifies that if an execution creates a task, that no events are created during creation of the task.
 if (processEngineConfiguration.getHistoryLevel().getId() >= ProcessEngineConfigurationImpl.HISTORYLEVEL_ACTIVITY) {
  assertEquals(0, taskService.getTaskEvents(task.getId()).size());
 }
}

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

@Test
public void testConcurrentUserTaskMigration() {
 // given
 ProcessDefinition sourceProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.PARALLEL_GATEWAY_PROCESS);
 ProcessDefinition targetProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.PARALLEL_GATEWAY_PROCESS);
 MigrationPlan migrationPlan = rule.getRuntimeService().createMigrationPlan(sourceProcessDefinition.getId(), targetProcessDefinition.getId())
  .mapEqualActivities()
  .build();
 // when
 testHelper.createProcessInstanceAndMigrate(migrationPlan);
 // then
 // the entities were migrated
 testHelper.assertExecutionTreeAfterMigration()
  .hasProcessDefinitionId(targetProcessDefinition.getId())
  .matches(
   describeExecutionTree(null).scope().id(testHelper.snapshotBeforeMigration.getProcessInstanceId())
    .child("userTask1").concurrent().noScope().up()
    .child("userTask2").concurrent().noScope()
    .done());
 List<Task> migratedTasks = testHelper.snapshotAfterMigration.getTasks();
 Assert.assertEquals(2, migratedTasks.size());
 for (Task migratedTask : migratedTasks) {
  Assert.assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());
 }
 // and it is possible to successfully complete the migrated instance
 for (Task migratedTask : migratedTasks) {
  rule.getTaskService().complete(migratedTask.getId());
 }
 testHelper.assertProcessEnded(testHelper.snapshotBeforeMigration.getProcessInstanceId());
}

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

@Deployment(resources = {TEST_PROCESS_USER_TASK_V1})
public void testSetProcessDefinitionVersionWithWithTask() {
 try {
 // start process instance
 ProcessInstance pi = runtimeService.startProcessInstanceByKey("userTask");
 // check that user task has been reached
 assertEquals(1, taskService.createTaskQuery().processInstanceId(pi.getId()).count());
 // deploy new version of the process definition
 org.camunda.bpm.engine.repository.Deployment deployment = repositoryService
  .createDeployment()
  .addClasspathResource(TEST_PROCESS_USER_TASK_V2)
  .deploy();
 assertEquals(2, repositoryService.createProcessDefinitionQuery().processDefinitionKey("userTask").count());
 ProcessDefinition newProcessDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionKey("userTask").processDefinitionVersion(2).singleResult();
 // migrate process instance to new process definition version
 processEngineConfiguration.getCommandExecutorTxRequired().execute(new SetProcessDefinitionVersionCmd(pi.getId(), 2));
 // check UserTask
 Task task = taskService.createTaskQuery().processInstanceId(pi.getId()).singleResult();
 assertEquals(newProcessDefinition.getId(), task.getProcessDefinitionId());
 assertEquals("testFormKey", formService.getTaskFormData(task.getId()).getFormKey());
 // continue
 taskService.complete(task.getId());
 assertProcessEnded(pi.getId());
 // undeploy "manually" deployed process definition
 repositoryService.deleteDeployment(deployment.getId(), true);
 }
 catch (Exception ex) {
  ex.printStackTrace();
 }
}

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

@Test
public void testMigrateWithSubTask() {
 // given
 ProcessDefinition sourceProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.ONE_TASK_PROCESS);
 ProcessDefinition targetProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.ONE_TASK_PROCESS);
 MigrationPlan migrationPlan = rule.getRuntimeService().createMigrationPlan(sourceProcessDefinition.getId(), targetProcessDefinition.getId())
  .mapEqualActivities()
  .build();
 ProcessInstance processInstance = rule.getRuntimeService().startProcessInstanceById(sourceProcessDefinition.getId());
 Task task = rule.getTaskService().createTaskQuery().singleResult();
 Task subTask = rule.getTaskService().newTask();
 subTask.setParentTaskId(task.getId());
 rule.getTaskService().saveTask(subTask);
 // when
 testHelper.migrateProcessInstance(migrationPlan, processInstance);
 // then the sub task properties have not been updated (i.e. subtask should not reference the process instance/definition now)
 Task subTaskAfterMigration = rule.getTaskService().createTaskQuery().taskId(subTask.getId()).singleResult();
 Assert.assertNull(subTaskAfterMigration.getProcessDefinitionId());
 Assert.assertNull(subTaskAfterMigration.getProcessInstanceId());
 Assert.assertNull(subTaskAfterMigration.getTaskDefinitionKey());
 // the tasks can be completed and the process can be ended
 rule.getTaskService().complete(subTask.getId());
 rule.getTaskService().complete(task.getId());
 testHelper.assertProcessEnded(testHelper.snapshotBeforeMigration.getProcessInstanceId());
 if (!rule.getProcessEngineConfiguration().getHistoryLevel().equals(HistoryLevel.HISTORY_LEVEL_NONE)) {
  rule.getHistoryService().deleteHistoricTaskInstance(subTaskAfterMigration.getId());
 }
}

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

@Test
public void testUserTaskMigrationInSubProcessScope() {
 // given
 ProcessDefinition sourceProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.SUBPROCESS_PROCESS);
 ProcessDefinition targetProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.SUBPROCESS_PROCESS);
 MigrationPlan migrationPlan = rule.getRuntimeService().createMigrationPlan(sourceProcessDefinition.getId(), targetProcessDefinition.getId())
  .mapEqualActivities()
  .build();
 // when
 testHelper.createProcessInstanceAndMigrate(migrationPlan);
 // then
 // the entities were migrated
 testHelper.assertExecutionTreeAfterMigration()
  .hasProcessDefinitionId(targetProcessDefinition.getId())
  .matches(
   describeExecutionTree(null).scope().id(testHelper.snapshotBeforeMigration.getProcessInstanceId())
    .child("userTask").scope().id(testHelper.getSingleExecutionIdForActivityBeforeMigration("userTask"))
    .done());
 Task task = testHelper.snapshotBeforeMigration.getTaskForKey("userTask");
 Task migratedTask = testHelper.snapshotAfterMigration.getTaskForKey("userTask");
 Assert.assertEquals(task.getId(), migratedTask.getId());
 Assert.assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());
 // and it is possible to successfully complete the migrated instance
 rule.getTaskService().complete(migratedTask.getId());
 testHelper.assertProcessEnded(testHelper.snapshotBeforeMigration.getProcessInstanceId());
}

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

@Test
public void testRemoveScopeForNonScopeActivity() {
 // given
 ProcessDefinition sourceProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.SUBPROCESS_PROCESS);
 ProcessDefinition targetProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.ONE_TASK_PROCESS);
 MigrationPlan migrationPlan = rule.getRuntimeService()
  .createMigrationPlan(sourceProcessDefinition.getId(), targetProcessDefinition.getId())
  .mapActivities("userTask", "userTask")
  .build();
 // when
 testHelper.createProcessInstanceAndMigrate(migrationPlan);
 // then
 testHelper.assertExecutionTreeAfterMigration()
  .hasProcessDefinitionId(targetProcessDefinition.getId())
  .matches(
   describeExecutionTree("userTask").scope().id(testHelper.snapshotBeforeMigration.getProcessInstanceId())
    .done());
 testHelper.assertActivityTreeAfterMigration().hasStructure(
   describeActivityInstanceTree(targetProcessDefinition.getId())
    .activity("userTask", testHelper.getSingleActivityInstanceBeforeMigration("userTask").getId())
   .done());
 Task migratedTask = testHelper.snapshotAfterMigration.getTaskForKey("userTask");
 Assert.assertNotNull(migratedTask);
 assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());
 // and it is possible to successfully complete the migrated instance
 rule.getTaskService().complete(migratedTask.getId());
 testHelper.assertProcessEnded(testHelper.snapshotBeforeMigration.getProcessInstanceId());
}

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

@Test
public void testRemoveMultipleScopes() {
 // given
 ProcessDefinition sourceProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.DOUBLE_SUBPROCESS_PROCESS);
 ProcessDefinition targetProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.ONE_TASK_PROCESS);
 MigrationPlan migrationPlan = rule.getRuntimeService()
  .createMigrationPlan(sourceProcessDefinition.getId(), targetProcessDefinition.getId())
  .mapActivities("userTask", "userTask")
  .build();
 // when
 testHelper.createProcessInstanceAndMigrate(migrationPlan);
 // then
 testHelper.assertExecutionTreeAfterMigration()
  .hasProcessDefinitionId(targetProcessDefinition.getId())
  .matches(
   describeExecutionTree("userTask").scope().id(testHelper.snapshotBeforeMigration.getProcessInstanceId())
    .done());
 testHelper.assertActivityTreeAfterMigration().hasStructure(
   describeActivityInstanceTree(targetProcessDefinition.getId())
    .activity("userTask", testHelper.getSingleActivityInstanceBeforeMigration("userTask").getId())
   .done());
 Task migratedTask = testHelper.snapshotAfterMigration.getTaskForKey("userTask");
 Assert.assertNotNull(migratedTask);
 assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());
 // and it is possible to successfully complete the migrated instance
 rule.getTaskService().complete(migratedTask.getId());
 testHelper.assertProcessEnded(testHelper.snapshotBeforeMigration.getProcessInstanceId());
}

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

@Test
public void testRemoveScopeForScopeActivity() {
 // given
 ProcessDefinition sourceProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.SCOPE_TASK_SUBPROCESS_PROCESS);
 ProcessDefinition targetProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.SCOPE_TASK_PROCESS);
 MigrationPlan migrationPlan = rule.getRuntimeService()
  .createMigrationPlan(sourceProcessDefinition.getId(), targetProcessDefinition.getId())
  .mapActivities("userTask", "userTask")
  .build();
 // when
 testHelper.createProcessInstanceAndMigrate(migrationPlan);
 // then
 testHelper.assertExecutionTreeAfterMigration()
  .hasProcessDefinitionId(targetProcessDefinition.getId())
  .matches(
   describeExecutionTree(null).scope().id(testHelper.snapshotBeforeMigration.getProcessInstanceId())
    .child("userTask").scope().id(testHelper.getSingleExecutionIdForActivityBeforeMigration("userTask"))
    .done());
 testHelper.assertActivityTreeAfterMigration().hasStructure(
   describeActivityInstanceTree(targetProcessDefinition.getId())
    .activity("userTask", testHelper.getSingleActivityInstanceBeforeMigration("userTask").getId())
   .done());
 Task migratedTask = testHelper.snapshotAfterMigration.getTaskForKey("userTask");
 Assert.assertNotNull(migratedTask);
 assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());
 // and it is possible to successfully complete the migrated instance
 rule.getTaskService().complete(migratedTask.getId());
 testHelper.assertProcessEnded(testHelper.snapshotBeforeMigration.getProcessInstanceId());
}

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

@Test
public void testUserTaskMigration() {
 // given
 ProcessDefinition sourceProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.ONE_TASK_PROCESS);
 ProcessDefinition targetProcessDefinition = testHelper.deployAndGetDefinition(ProcessModels.SUBPROCESS_PROCESS);
 MigrationPlan migrationPlan = rule.getRuntimeService()
  .createMigrationPlan(sourceProcessDefinition.getId(), targetProcessDefinition.getId())
  .mapActivities("userTask", "userTask")
  .build();
 // when
 testHelper.createProcessInstanceAndMigrate(migrationPlan);
 // then
 testHelper.assertExecutionTreeAfterMigration()
  .hasProcessDefinitionId(targetProcessDefinition.getId())
  .matches(
   describeExecutionTree(null).scope().id(testHelper.snapshotBeforeMigration.getProcessInstanceId())
    .child("userTask").scope()
   .done());
 testHelper.assertActivityTreeAfterMigration().hasStructure(
   describeActivityInstanceTree(targetProcessDefinition.getId())
    .beginScope("subProcess")
     .activity("userTask", testHelper.getSingleActivityInstanceBeforeMigration("userTask").getId())
   .done());
 Task migratedTask = testHelper.snapshotAfterMigration.getTaskForKey("userTask");
 Assert.assertNotNull(migratedTask);
 assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());
 // and it is possible to successfully complete the migrated instance
 rule.getTaskService().complete(migratedTask.getId());
 testHelper.assertProcessEnded(testHelper.snapshotBeforeMigration.getProcessInstanceId());
}

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

assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());

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

assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());

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

assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());

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

assertEquals(targetProcessDefinition.getId(), migratedTask.getProcessDefinitionId());

相关文章