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

x33g5p2x  于2022-01-29 转载在 其他  
字(13.1k)|赞(0)|评价(0)|浏览(135)

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

RepositoryService.activateProcessDefinitionByKey介绍

[英]Activates the process definition with the given key (=id in the bpmn20.xml file).

Note: for more complex activate commands use #updateProcessDefinitionSuspensionState().
[中]使用给定的密钥（=bpmn20.xml文件中的id）激活流程定义。
注意：对于更复杂的激活命令，请使用#UpdateProcessDefinitionSuspendionState（）。

代码示例

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

@Deployment(resources = PROCESS_PATH)
public void testActivateProcessDefinition() {
 // when
 repositoryService.activateProcessDefinitionByKey(PROCESS_KEY);
 // then
 verifyNoUserOperationLogged();
}

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

@Test
public void testActivateProcessDefinitionByKeyThrowsAuthorizationException() {
 Map<String, Object> params = new HashMap<String, Object>();
 params.put("suspended", false);
 params.put("processDefinitionKey", MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY);
 String message = "expected exception";
 doThrow(new AuthorizationException(message)).when(repositoryServiceMock).activateProcessDefinitionByKey(MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY, false, null);
 given()
  .contentType(ContentType.JSON)
  .body(params)
 .then()
  .expect()
   .statusCode(Status.FORBIDDEN.getStatusCode())
   .body("type", is(AuthorizationException.class.getSimpleName()))
   .body("message", is(message))
  .when()
   .put(PROCESS_DEFINITION_SUSPENDED_URL);
}

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

@Test
public void testActivateProcessDefinitionByKey() {
 Map<String, Object> params = new HashMap<String, Object>();
 params.put("suspended", false);
 params.put("processDefinitionKey", MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY);
 given()
  .contentType(ContentType.JSON)
  .body(params)
 .then()
  .expect()
   .statusCode(Status.NO_CONTENT.getStatusCode())
  .when()
   .put(PROCESS_DEFINITION_SUSPENDED_URL);
 verify(repositoryServiceMock).activateProcessDefinitionByKey(MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY, false, null);
}

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

@Test
public void testDelayedActivateProcessDefinitionByKeyIncludingInstaces() {
 Map<String, Object> params = new HashMap<String, Object>();
 params.put("suspended", false);
 params.put("includeProcessInstances", true);
 params.put("processDefinitionKey", MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY);
 params.put("executionDate", MockProvider.EXAMPLE_PROCESS_DEFINITION_DELAYED_EXECUTION);
 Date executionDate = DateTimeUtil.parseDate(MockProvider.EXAMPLE_PROCESS_DEFINITION_DELAYED_EXECUTION);
 given()
  .contentType(ContentType.JSON)
  .body(params)
 .then()
  .expect()
   .statusCode(Status.NO_CONTENT.getStatusCode())
  .when()
   .put(PROCESS_DEFINITION_SUSPENDED_URL);
 verify(repositoryServiceMock).activateProcessDefinitionByKey(MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY, true, executionDate);
}

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

@Test
public void testActivateProcessDefinitionByKeyIncludingInstaces() {
 Map<String, Object> params = new HashMap<String, Object>();
 params.put("suspended", false);
 params.put("includeProcessInstances", true);
 params.put("processDefinitionKey", MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY);
 given()
  .contentType(ContentType.JSON)
  .body(params)
 .then()
  .expect()
   .statusCode(Status.NO_CONTENT.getStatusCode())
  .when()
   .put(PROCESS_DEFINITION_SUSPENDED_URL);
 verify(repositoryServiceMock).activateProcessDefinitionByKey(MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY, true, null);
}

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

@Test
public void testDelayedActivateProcessDefinitionByKey() {
 Map<String, Object> params = new HashMap<String, Object>();
 params.put("suspended", false);
 params.put("processDefinitionKey", MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY);
 params.put("executionDate", MockProvider.EXAMPLE_PROCESS_DEFINITION_DELAYED_EXECUTION);
 Date executionDate = DateTimeUtil.parseDate(MockProvider.EXAMPLE_PROCESS_DEFINITION_DELAYED_EXECUTION);
 given()
  .contentType(ContentType.JSON)
  .body(params)
 .then()
  .expect()
   .statusCode(Status.NO_CONTENT.getStatusCode())
  .when()
   .put(PROCESS_DEFINITION_SUSPENDED_URL);
 verify(repositoryServiceMock).activateProcessDefinitionByKey(MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY, false, executionDate);
}

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

@Test
public void testActivateProcessDefinitionByKeyWithException() {
 Map<String, Object> params = new HashMap<String, Object>();
 params.put("suspended", false);
 params.put("processDefinitionKey", MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY);
 String expectedException = "expectedException";
 doThrow(new ProcessEngineException(expectedException))
  .when(repositoryServiceMock)
  .activateProcessDefinitionByKey(MockProvider.EXAMPLE_PROCESS_DEFINITION_KEY, false, null);
 given()
  .contentType(ContentType.JSON)
  .body(params)
 .then()
  .expect()
   .statusCode(Status.INTERNAL_SERVER_ERROR.getStatusCode())
   .body("type", is(ProcessEngineException.class.getSimpleName()))
   .body("message", is(expectedException))
  .when()
   .put(PROCESS_DEFINITION_SUSPENDED_URL);
}

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

public void updateSuspensionState(ProcessEngine engine) {
 if (processDefinitionId != null && processDefinitionKey != null) {
  String message = "Only one of processDefinitionId or processDefinitionKey should be set to update the suspension state.";
  throw new InvalidRequestException(Status.BAD_REQUEST, message);
 }
 RepositoryService repositoryService = engine.getRepositoryService();
 Date delayedExecutionDate = null;
 if (executionDate != null && !executionDate.equals("")) {
  delayedExecutionDate = DateTimeUtil.parseDate(executionDate);
 }
 if (processDefinitionId != null) {
  // activate/suspend process definition by id
  if (getSuspended()) {
   repositoryService.suspendProcessDefinitionById(processDefinitionId, includeProcessInstances, delayedExecutionDate);
  } else {
   repositoryService.activateProcessDefinitionById(processDefinitionId, includeProcessInstances, delayedExecutionDate);
  }
 } else
 if (processDefinitionKey != null) {
  // activate/suspend process definition by key
  if (getSuspended()) {
   repositoryService.suspendProcessDefinitionByKey(processDefinitionKey, includeProcessInstances, delayedExecutionDate);
  } else {
   repositoryService.activateProcessDefinitionByKey(processDefinitionKey, includeProcessInstances, delayedExecutionDate);
  }
 } else {
  String message = "Either processDefinitionId or processDefinitionKey should be set to update the suspension state.";
  throw new InvalidRequestException(Status.BAD_REQUEST, message);
 }
}

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

public void testActivateProcessDefinitionByKey() {
 // given
 suspendProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 createGrantAuthorization(PROCESS_DEFINITION, ONE_TASK_PROCESS_KEY, userId, UPDATE);
 // when
 repositoryService.activateProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 // then
 ProcessDefinition definition = selectProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 assertFalse(definition.isSuspended());
}

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

public void testActivateProcessDefinitionByKeyIncludingInstancesWithUpdateInstancePermissionOnProcessDefinition() {
 // given
 startProcessInstanceByKey(ONE_TASK_PROCESS_KEY);
 suspendProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 createGrantAuthorization(PROCESS_DEFINITION, ONE_TASK_PROCESS_KEY, userId, UPDATE, UPDATE_INSTANCE);
 // when
 repositoryService.activateProcessDefinitionByKey(ONE_TASK_PROCESS_KEY, true, null);
 // then
 ProcessDefinition definition = selectProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 assertFalse(definition.isSuspended());
 ProcessInstance instance = selectSingleProcessInstance();
 assertFalse(instance.isSuspended());
}

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

public void testActivateProcessDefinitionByKeyWithoutAuthorization() {
 // given
 suspendProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 try {
  // when
  repositoryService.activateProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
  fail("Exception expected: It should not be possible to activate the process definition");
 } catch (AuthorizationException e) {
  // then
  String message = e.getMessage();
  assertTextPresent(userId, message);
  assertTextPresent(UPDATE.getName(), message);
  assertTextPresent(ONE_TASK_PROCESS_KEY, message);
  assertTextPresent(PROCESS_DEFINITION.resourceName(), message);
 }
}

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

public void testActivateProcessDefinitionByKeyIncludingInstancesWithUpdatePermissionOnAnyProcessInstance() {
 // given
 startProcessInstanceByKey(ONE_TASK_PROCESS_KEY);
 createGrantAuthorization(PROCESS_INSTANCE, ANY, userId, UPDATE);
 suspendProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 createGrantAuthorization(PROCESS_DEFINITION, ONE_TASK_PROCESS_KEY, userId, UPDATE);
 // when
 repositoryService.activateProcessDefinitionByKey(ONE_TASK_PROCESS_KEY, true, null);
 // then
 ProcessDefinition definition = selectProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 assertFalse(definition.isSuspended());
 ProcessInstance instance = selectSingleProcessInstance();
 assertFalse(instance.isSuspended());
}

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

@Deployment(resources = {"org/camunda/bpm/engine/test/api/repository/ProcessDefinitionSuspensionTest.testSuspendStartTimerOnProcessDefinitionSuspension.bpmn20.xml"})
public void testActivateStartTimerOnProcessDefinitionSuspensionByKey() {
 repositoryService.suspendProcessDefinitionByKey("process");
 Job startTimer = managementService.createJobQuery().timers().singleResult();
 assertTrue(startTimer.isSuspended());
 // when
 repositoryService.activateProcessDefinitionByKey("process");
 // then
 // refresh job
 startTimer = managementService.createJobQuery().timers().singleResult();
 assertFalse(startTimer.isSuspended());
}

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

@Deployment(resources={"org/camunda/bpm/engine/test/api/repository/processOne.bpmn20.xml"})
public void testSuspendActivateProcessDefinitionByKey() {
 ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertFalse(processDefinition.isSuspended());
 //suspend
 repositoryService.suspendProcessDefinitionByKey(processDefinition.getKey());
 processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertTrue(processDefinition.isSuspended());
 //activate
 repositoryService.activateProcessDefinitionByKey(processDefinition.getKey());
 processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
 assertFalse(processDefinition.isSuspended());
}

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

public void testActivateProcessDefinitionByKeyIncludingInstancesWithoutAuthorization() {
 // given
 startProcessInstanceByKey(ONE_TASK_PROCESS_KEY);
 suspendProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 createGrantAuthorization(PROCESS_DEFINITION, ONE_TASK_PROCESS_KEY, userId, UPDATE);
 try {
  // when
  repositoryService.activateProcessDefinitionByKey(ONE_TASK_PROCESS_KEY, true, null);
  fail("Exception expected: It should not be possible to activate the process definition");
 } catch (AuthorizationException e) {
  // then
  String message = e.getMessage();
  assertTextPresent(userId, message);
  assertTextPresent(UPDATE.getName(), message);
  assertTextPresent(PROCESS_INSTANCE.resourceName(), message);
  assertTextPresent(UPDATE_INSTANCE.getName(), message);
  assertTextPresent(ONE_TASK_PROCESS_KEY, message);
  assertTextPresent(PROCESS_DEFINITION.resourceName(), message);
 }
}

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

public void testActivateProcessDefinitionByKeyIncludingInstancesWithUpdatePermissionOnProcessInstance() {
 // given
 String processInstanceId = startProcessInstanceByKey(ONE_TASK_PROCESS_KEY).getId();
 createGrantAuthorization(PROCESS_INSTANCE, processInstanceId, userId, UPDATE);
 suspendProcessDefinitionByKey(ONE_TASK_PROCESS_KEY);
 createGrantAuthorization(PROCESS_DEFINITION, ONE_TASK_PROCESS_KEY, userId, UPDATE);
 try {
  // when
  repositoryService.activateProcessDefinitionByKey(ONE_TASK_PROCESS_KEY, true, null);
  fail("Exception expected: It should not be possible to activate the process definition");
 } catch (AuthorizationException e) {
  // then
  String message = e.getMessage();
  assertTextPresent(userId, message);
  assertTextPresent(UPDATE.getName(), message);
  assertTextPresent(PROCESS_INSTANCE.resourceName(), message);
  assertTextPresent(UPDATE_INSTANCE.getName(), message);
  assertTextPresent(ONE_TASK_PROCESS_KEY, message);
  assertTextPresent(PROCESS_DEFINITION.resourceName(), message);
 }
}

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

repositoryService.activateProcessDefinitionByKey(key, true, null);

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

repositoryService.activateProcessDefinitionByKey(processDefinition.getKey(), false, null);

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

repositoryService.activateProcessDefinitionByKey("oneTaskProcess", true, null);

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

repositoryService.activateProcessDefinitionByKey("oneTaskProcess");
assertEquals(nrOfProcessDefinitions, repositoryService.createProcessDefinitionQuery().count());
assertEquals(nrOfProcessDefinitions, repositoryService.createProcessDefinitionQuery().active().count());

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

RepositoryService

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    RepositoryService类方法

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