実行中のプロセスインスタンスでタスクを手動で変更します

Question

カスタムBPMアプリケーションを開発するために、私たちが他のBPMエンジンプロバイダと一緒に使用されている機能が1つあり、Camundaで使用するのが好きです。 ターゲット機能は、実行中のプロセスインスタンスを現在のアクティブなもの以外の指定されたタスクに設定/リセットすることです。 e.gの場合に必要な私たちの展望から。：

• プロセスのオーサリングプロセス - プロセスバージョンの移行
• インシデントの解決
• 誤って誤った使用法をユーザーによる誤って解決する

最後に私はこれを行うための簡単な機能を見つけませんでしたが、いくつかの制限で働いたいくつかのカスタムコードを取り出しました。このコード内にいくつかの弱点と不安定性があり、私は次の質問をしています：

これを達成するための代替方法を見逃したか、または今後のアプローチであるか、またはその瞬間には完全にサポートされていませんか？

現在の弱点IMHO：

• 最初のもので最も重要： 履歴タスクインスタンスは保存されていません。この タスクがトリガー/アクティブ化/起動した場合でも、トレーサブルではないことを示します。 Camunda Googleグループの次の投稿を見つけました（ post ）それはそれが言っていると言います この時点では、プロセス定義の範囲からのタスクであるため修正されますが 基礎となるプロセス定義からタスク定義を使用することによって 「範囲内」になりますか？
• コードは内部実装に基づいており、公式インターフェース
ではありません。
• この時点で、多くの「ブートストラップ」/初期化を手動で行う必要があります。 しかし、ユーザーとして（カマンダの開発者ではありません）私は必要なものを十分に認識していません オプション
とは何ですか
• タスク定義からの式を解析するような一部の部分は失敗しました（コードコメントアウトを参照）。 しかしそれは間違った使い方によって引き起こされるかもしれません

これは私たちのCamunda Service Facadeのコード（実験的なスニペット）です：

@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;
     }
}

.

私はあらゆるヒントまたはアドバイスに感謝します： - ）

Answer 1

私はすでに気づいたように、そのレベルのプロセスインスタンスを台無しにしないでください、あなたはCamundasサービスを迂回しています。同様の問題に直面したとき、我々は次のようになりました：

1. 古いプロセスバージョン
のプロセスインスタンスをキャンセルします。
2. 拡張プロセスの新しいインスタンスを起動し、プログラム的に希望の状態に転送します...

もう1つのオプション：新しいプロセスバージョン内のエントリポイント（メッセージ開始イベント）をモデル化します。次に、プログラムでインスタンスを目的の状態に転送する代わりに、イベントを介して新しいインスタンスを起動し、古いインスタンスのすべてのプロセス変数を渡します。

Answer 2

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 ドキュメントのための