手动更改正在运行的流程实例的任务

问题描述 投票：0回答：3

为了开发自定义 BPM 应用程序，我们与另一家 BPM 引擎提供商一起使用了一项功能，并且也喜欢将其与 camunda 一起使用。 目标功能是将正在运行的流程实例设置/重置为除当前活动任务之外的指定任务。从我们的角度来看，例如以下情况是必要的：

  • 由于流程版本迁移而创作流程实例
  • 解决事件
  • 解决用户意外错误使用的问题

最后，我并没有真正找到一个简单的函数来执行此操作，而是编写了一些具有一些限制的自定义代码。该代码中存在一些弱点和不确定性，因此我有以下问题：

我是否错过了实现此目的的替代方法，或者以下方法是否正确，或者目前是否完全不受支持？

目前的弱点恕我直言：

  • 首先也是最重要的：不存储历史任务实例。这 导致无法追踪谁触发/激活/启动任务，甚至无法追踪任务何时触发/激活/启动。 我在 camunda google group (post) 上找到了以下帖子，上面写着 此时正确，因为这是一个超出流程定义范围的任务，但是 通过使用底层流程定义中的任务定义，我应该 “在范围内”？！
  • 代码基于内部实现，而非官方接口
  • 此时很多“引导”/初始化必须手动完成 但作为用户（不是 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;
     }
}

我很感激任何提示或建议:-)

java task business-process-management camunda
3个回答
5
投票

从 Camunda 7.3 开始，您可以使用流程实例修改来启动流程中的任何活动并取消任何活动的活动实例。

示例：

runtimeService.createProcessInstanceModification(processInstanceId)
  .startBeforeActivity("someActivityId")
  .cancelActivityInstance("someActivityInstanceId")
  .execute();

请参阅 http://docs.camunda.org/7.3/guides/user-guide/#process-engine-process-instance-modification 了解文档。

2
投票

我不会弄乱该级别的流程实例，正如您已经注意到的那样，您正在绕过 camundas 服务。当遇到类似的问题时，我们采取了以下措施：

  1. 取消旧流程版本的流程实例
  2. 启动扩展进程的新实例并以编程方式将其转发到所需状态...

另一个选项：在新流程版本内建模入口点（消息开始事件）。然后，无需以编程方式将实例转发到所需状态，只需通过事件启动新实例并传递旧实例的所有流程变量...

0
投票

我希望使用此处描述的技术将另一个实例添加到顺序多实例子流程：修改多实例流程 4

我收到以下错误： SequentialUpdateSubProcess#multiInstanceBody 范围内的活动无法并发实例化

修改正在由脚本执行。相关行：

runtimeService.createProcessInstanceModification(execution.getProcessInstanceId()) .startBeforeActivity(“SequentialUpdateSubProcess”) .setVariableLocal(“事件”, eventJsonValue) .execute()

如果子流程是并行多实例，则成功。我怀疑它试图立即启动新实例，而不是在初始实例完成后启动。是否有不同的技术可以添加到顺序多实例活动中？我已附上模型。

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.