activiti 中国式自由流任意节点的跳转

2022-11-11 15:58 81阅读 0赞

工作流目前只能支持按照预先设置好的线，判断线的预制条件才能按照模板进行跳转 。假设一个场景 a提交到 b b提交到c c提交到d d在一直提交下去。 但是退回如何控制呢。假如d-a一直退回。貌似要画很多的线进去，线上配置条件。这样流程才能运转下去。
在这里我们不想去画线，但是还期望流程能在制定的模板节点中运行。所以这个场景就是中国式流程。目前版本是5.14
1.实现的代码如如下：

  1. import java.util.Map;
  2. import org.activiti.engine.delegate.TaskListener;
  3. import org.activiti.engine.impl.context.Context;
  4. import org.activiti.engine.impl.interceptor.Command;
  5. import org.activiti.engine.impl.interceptor.CommandContext;
  6. import org.activiti.engine.impl.persistence.entity.ExecutionEntity;
  7. import org.activiti.engine.impl.persistence.entity.TaskEntity;
  8. import org.activiti.engine.impl.pvm.process.ActivityImpl;
  9. import org.activiti.engine.task.Comment;
  11. public class JumpTaskCmd implements Command<Comment> {
  12.  //完成
  13.  public  static String  EVENTNAME_COMPLETE="jump";
  14.  //退回
  15.  public  static String  EVENTNAME_TO_REVOKED="revoked";
  16.  //撤销
  17.  public  static String  EVENTNAME_TO_BE_RETURNED="returned";
  19.  protected String executionId;
  20.  protected ActivityImpl desActivity;
  21.  protected Map<String,Object> paramvar;
  22.  protected ActivityImpl currentActivity;
  23.  protected String JumpTaskReason;
  25.  public JumpTaskCmd(String executionId, ActivityImpl desActivity,Map<String,Object> paramvar,ActivityImpl currentActivity,String JumpTaskReason) {
  26.   super();
  27.   this.executionId = executionId;
  28.   this.desActivity = desActivity;
  29.   this.paramvar = paramvar;
  30.   this.currentActivity = currentActivity;
  31.   this.JumpTaskReason=JumpTaskReason;
  32.  }
  34.  @Override
  35.  public Comment execute(CommandContext commandContext) {
  36.   ExecutionEntity executionEntity = Context.getCommandContext()
  37.     .getExecutionEntityManager().findExecutionById(executionId);
  38.   executionEntity.setVariables(paramvar);
  39.   executionEntity.setEventSource(currentActivity);
  40.   executionEntity.setActivity(currentActivity);
  41.   for (TaskEntity taskEntity : Context.getCommandContext()
  42.     .getTaskEntityManager().findTasksByExecutionId(executionId)) {
  43.    taskEntity.fireEvent(TaskListener.EVENTNAME_COMPLETE);
  44.    Context.getCommandContext().getTaskEntityManager()
  45.      .deleteTask(taskEntity, JumpTaskReason, false);
  46.   }
  47.   executionEntity.executeActivity(desActivity);
  48.   return null;
  49.  }
  51. }

2、程序控制

  1. TaskServiceImpl taskServiceImpl = (TaskServiceImpl) processEngine
  2.       .getTaskService();
  3.     CommandExecutor commandExecutor = taskServiceImpl
  4.       .getCommandExecutor();
  5.     commandExecutor.execute(new JumpTaskCmd(task.getExecutionId(),
  6.       destinationActivity, param, currentActivity, jumpReason));