Вручную изменить задачу при запуске экземпляра процесса ⇐ JAVA

[Anonymous]

При разработке собственного приложения BPM есть одна функция, которую мы использовали с другим поставщиком механизма BPM и хотели бы использовать ее и с camunda.
Целевая функциональность заключается в настройке/сбросе запущенных экземпляров процесса для указанной задачи. кроме текущего активного. С нашей точки зрения, это необходимо, например:

• создание экземпляров процесса в связи с миграцией версий процесса
• разрешение инцидентов
• устранение случайно неправильного использования пользователем

Наконец, я действительно не нашел простая функция для этого, но был разработан специальный код, который работал с некоторыми ограничениями. В этом коде есть некоторые недостатки и неопределенности, поэтому У меня есть следующий вопрос:

Пропустил ли я альтернативный способ достижения это или следующий подход правильный, или он даже полностью не поддерживается на данный момент?

Текущие недостатки, имхо:

• первое и самое важное: ни один исторический экземпляр задачи не сохраняется. Это
  приводит к тому, что невозможно отследить, кто или даже когда задача была запущена/активирована/запущена.
  Я нашел следующее сообщение в группе Google 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 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 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 getAvailableTasks(String processInstanceId) {
Map taskDefs = null;
Collection taskDefObjects = null;
if (processInstanceId != null) {
ProcessInstanceQuery procInstQuery = runtimeService.
createProcessInstanceQuery().processInstanceId(
processInstanceId);
ProcessDefinitionEntity procDefEntity = getProcessDefinitionEager(
processInstanceId);
taskDefs = procDefEntity.getTaskDefinitions();
}
taskDefObjects = (Collection) (taskDefs != null ? taskDefs.
values() : new ArrayList());
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 getTasksByKey(String taskKey, String processInstanceId) {
List  tasks = taskService.createTaskQuery().processInstanceId(
processInstanceId).taskDefinitionKey(taskKey).list();
return tasks;
}

public class SaveTaskActivityInstanceCmd implements Command,
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;
}
}

Я ценю любой намек или совет

Подробнее здесь: https://stackoverflow.com/questions/250 ... s-instance