Задача вручную изменить задачу при запуске процесса-экземпляра
-
21-12-2019 - |
Вопрос
В порядке разработки пользовательского приложения BPM Существует одна функция, которую мы использовали с другим провайдером двигателя BPM и хотелось бы использовать его с Camunda. Целевой функционал связан с настройкой / сбросом проработанных процессов в указанную задачу, отличную от текущей активной активности. Из нашей перспективы необходимо, когда E.g.:
- .
- Процесс авторства-экземпляров из-за миграции версии процесса
- разрешение инцидентов
- разрешение случайно неправильное использование пользователя
Наконец, я действительно не нашел простой функцию, чтобы сделать это, но разработал какой-то пользовательский код, который работал с некоторыми ограничениями. В этом коде есть некоторые недостатки и неуверенности в этом коде, так что у меня есть следующий вопрос :
Я пропустил альтернативный способ добиться этого или является следующим подходом или это даже полностью неподдерживается в данный момент?
Текущие слабости IMHO:
- .
- Первое и самое важное: Никакой исторический экземпляр задачи не сохраняется . Этот Причины, что он не прослеживается, кто или даже когда задача была вызвана / активирована / запущена. Я нашел следующий пост на Camunda Google Group ( post ) который говорит, что это исправить на данный момент, потому что это задача из облагания определения процесса, но Используя определение задачи из основного определения процесса, я должен Будь "по объему"?!
- Код основан на внутренней реализации, а не на официальном интерфейсе
- На данный момент много «Bootstrap» / инициализация должна быть сделана вручную но как пользователь (не разработчик Camunda), я не полностью осознаю, что требуется и Что опционально
- Некоторые запчасти, такие как экспрессирующие выражения из определения задач (см. Код комментирован) Но это может быть вызвано неправильным использованием
Вот код (экспериментальный фрагмент нашего фасада услуг Camunda):
@Inject
protected HistoryService histService;
@Inject
protected TaskService taskService;
@Inject
protected ManagementService managementService;
@Inject
protected RuntimeService runtimeService;
@Inject
protected IdentityService identityService;
@Inject
protected RepositoryService repositoryService;
@Inject
protected FormService formService;
@Inject
protected ProcessEngine processEngine;
public void startTask(String processInstanceId, String taskKey) {
Collection<TaskDefinition> taskDefs = getAvailableTasks(
processInstanceId);
TaskEntity newTask = null;
TaskDefinition taskDef = null;
for (TaskDefinition taskDefinition : taskDefs) {
if (taskDefinition.getKey().equals(taskKey)) {
taskDef = taskDefinition;
break;
}
}
boolean taskDefExists = taskDef != null;
List<Task> runningTasksByKey = getTasksByKey(taskKey, processInstanceId);
boolean taskIsAlreadyRunning = runningTasksByKey != null
&& runningTasksByKey.size() > 0;
if (taskDefExists && !taskIsAlreadyRunning) {
newTask = (TaskEntity) taskService.newTask();
ProcessInstance procInst = getProcessInstance(processInstanceId);
ExecutionEntity procInstEntity = (ExecutionEntity) procInst;
String taskName = (String) taskDef.getNameExpression().
getExpressionText();
// String taskAssigne = (String) taskDef.getAssigneeExpression().
// getValue(
// procInstEntity);
// newTask.setAssignee(taskAssigne);
newTask.setTaskDefinitionKey(taskDef.getKey());
newTask.setProcessInstance(procInstEntity);
newTask.setTaskDefinition(taskDef);
newTask.setName(taskName);
newTask.setProcessInstanceId(processInstanceId);
newTask.setProcessDefinitionId(procInstEntity.
getProcessDefinitionId());
taskService.saveTask(newTask);
TaskServiceImpl taskServiceImpl = (TaskServiceImpl) BpmPlatform.
getProcessEngineService().getDefaultProcessEngine().
getTaskService();
CommandExecutor commandExecutor = taskServiceImpl.
getCommandExecutor();
ExecutionEntity executionEntity = commandExecutor.execute(
new SaveTaskActivityInstanceCmd(newTask,
procInstEntity));
// commandExecutor.execute(new `SaveTaskHistoricActivityInstanceCmd(executionEntity, newTask));`
}
}
public Collection<TaskDefinition> getAvailableTasks(String processInstanceId) {
Map<String, TaskDefinition> taskDefs = null;
Collection<TaskDefinition> taskDefObjects = null;
if (processInstanceId != null) {
ProcessInstanceQuery procInstQuery = runtimeService.
createProcessInstanceQuery().processInstanceId(
processInstanceId);
ProcessDefinitionEntity procDefEntity = getProcessDefinitionEager(
processInstanceId);
taskDefs = procDefEntity.getTaskDefinitions();
}
taskDefObjects = (Collection<TaskDefinition>) (taskDefs != null ? taskDefs.
values() : new ArrayList<TaskDefinition>());
return taskDefObjects;
}
public ProcessDefinitionEntity getProcessDefinitionEager(
String processInstanceId) {
ProcessInstanceQuery procInstQuery = runtimeService.
createProcessInstanceQuery().processInstanceId(
processInstanceId);
ProcessInstance procInst = procInstQuery.singleResult();
String procDefId = procInst.getProcessDefinitionId();
return (ProcessDefinitionEntity) repositoryService.getProcessDefinition(
procDefId);
}
public List<Task> getTasksByKey(String taskKey, String processInstanceId) {
List<Task> tasks = taskService.createTaskQuery().processInstanceId(
processInstanceId).taskDefinitionKey(taskKey).list();
return tasks;
}
public class SaveTaskActivityInstanceCmd implements Command<ExecutionEntity>,
Serializable {
private TaskEntity newTask;
private ExecutionEntity procInstEntity;
public SaveTaskActivityInstanceCmd(TaskEntity newTaskInit,
ExecutionEntity procInstEntityInit) {
this.newTask = newTaskInit;
this.procInstEntity = procInstEntityInit;
}
public ExecutionEntity execute(CommandContext commandContext) {
ActivityImpl actImpl = new ActivityImpl(newTask.
getTaskDefinitionKey(),
procInstEntity.getProcessDefinition());
actImpl.setActivityBehavior(new UserTaskActivityBehavior(
new CdiExpressionManager(), newTask.getTaskDefinition()));
ExecutionEntity execEntity = new ExecutionEntity();
execEntity.setActivity(actImpl);
execEntity.setActivityInstanceId(newTask.getTaskDefinitionKey()
+ ":" + newTask.getId());
execEntity.setEventName(newTask.getEventName());
execEntity.setProcessDefinitionId(newTask.getProcessDefinitionId());
execEntity.setActive(true);
execEntity.setProcessInstance(procInstEntity);
commandContext.getExecutionManager().insert(execEntity);
return execEntity;
}
}
.
Я ценю любой намек или совет: -)
Решение
Я бы не связывался с экземпляром процесса на этом уровне, как вы уже заметили, вы обходили услуги Camundas.Когда столкнулся с подобной проблемой, мы пошли со следующими:
- Отмена экземпляра процесса старой версии процесса
- Начните новый экземпляр расширенного процесса и пересылайте его программно в желаемое состояние ...
Другой вариант: Модель точки входа (событие начала сообщения) внутри новой версии процесса.Затем, вместо того, чтобы программно пересылать экземпляр в желаемое состояние, просто запустите новый экземпляр через событие и пропустите все переменные процессы старого экземпляра ...
Другие советы
Начиная с Camunda 7.3, вы можете использовать модификацию экземпляра процесса, чтобы начать любую активность в процессе и отменить любой экземпляр активного активности.
Пример:
runtimeService.createProcessInstanceModification(processInstanceId)
.startBeforeActivity("someActivityId")
.cancelActivityInstance("someActivityInstanceId")
.execute();
.
см. см. http:// docs.Camunda.org/7.3/guide/user-guide/#process-gine-Process-instance-modification для документации.