【发布时间】：2014-07-31 12:19:15
【问题描述】：
为了开发自定义 BPM 应用程序，我们与另一个 BPM 引擎提供商一起使用了一项功能，并且也喜欢将其与 camunda 一起使用。 目标功能是关于将正在运行的流程实例设置/重置为除当前活动之外的指定任务。从我们的角度来看是必要的，例如：
- 由于流程版本迁移而创作流程实例
- 解决事件
- 解决用户意外错误使用的问题
最后，我并没有真正找到一个简单的函数来执行此操作，而是制定了一些自定义代码，但有一些限制。此代码中存在一些弱点和不确定性，因此我有以下问题：
我是否错过了实现此目的的替代方法，或者以下方法是否正确，或者目前甚至完全不受支持？
目前的弱点恕我直言：
- 首先也是最重要的： 不存储任何历史任务实例。这 导致无法追踪谁或什至何时触发/激活/启动了任务。 我在 camunda google group (post) 上找到了以下帖子，上面写着 在这一点上是正确的，因为这是一个超出流程定义范围的任务，但是 通过使用来自底层流程定义的任务定义，我应该 在“范围内”？！
- 代码基于内部实现而非官方接口
- 此时许多“引导”/初始化必须手动完成 但作为用户（不是 camunda 的开发人员），我并不完全了解需要什么和 什么是可选的
- 某些部分，例如从任务定义中解析表达式失败（请参阅注释掉的代码） 但这可能是由于使用不当造成的
这是代码（我们的 camunda 服务外观的实验性 sn-p）：
@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;
}
}
感谢任何提示或建议 :-)
【问题讨论】：
-
您能提供您的 bpmn 文件吗？在我看来，您正在做很多黑客行为，要么是因为 a）您的模型不符合您的需求，要么 b）您的项目不是 bpm 项目（也许是 acm？）
-
嗯，从我的角度来看，bpmn 的外观并不重要，因为我们想在任何 bpmn 上使用此功能。例如：给定简单的流程定义： Start -> Usertask A -> Usertask B -> End 如果有新的需求，我们需要一个新的服务任务： Start -> Usertask A -> Servicetask -> Usertask B -> End 现在我们必须将令牌已经在 usertask B 上的正在运行的流程实例重置为 usertask A，以便该实例可以通过新的 servicetask 运行。
-
好的，我明白了……您正在部署流程的扩展版本并且需要迁移正在运行的流程实例。根据我上面读到的内容，我假设您想更改正在运行的实例的行为。问题 1：您是否有运行时间过长以至于值得迁移的进程？为什么不让实例以旧版本结束？问题 2：你真的希望用户在任务 A 中重复他的工作吗？您不想在任务完成后立即重置实例吗？
标签： java task business-process-management camunda