当前位置:   article > 正文

【工作流Activiti7】4、Activiti7 结束/终止流程_activiti终止流程

activiti终止流程

1.  结束/终止 正在运行的流程实例

思路:跟回退一样的思路一样,直接从当前节点跳到结束节点(EndEvent) 

  1. /**
  2. * 结束任务
  3. * @param taskId 当前任务ID
  4. */
  5. public void endTask(String taskId) {
  6. // 当前任务
  7. Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
  8. BpmnModel bpmnModel = repositoryService.getBpmnModel(task.getProcessDefinitionId());
  9. List endEventList = bpmnModel.getMainProcess().findFlowElementsOfType(EndEvent.class);
  10. FlowNode endFlowNode = endEventList.get(0);
  11. FlowNode currentFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(task.getTaskDefinitionKey());
  12. // 临时保存当前活动的原始方向
  13. List originalSequenceFlowList = new ArrayList<>();
  14. originalSequenceFlowList.addAll(currentFlowNode.getOutgoingFlows());
  15. // 清理活动方向
  16. currentFlowNode.getOutgoingFlows().clear();
  17. // 建立新方向
  18. SequenceFlow newSequenceFlow = new SequenceFlow();
  19. newSequenceFlow.setId("newSequenceFlowId");
  20. newSequenceFlow.setSourceFlowElement(currentFlowNode);
  21. newSequenceFlow.setTargetFlowElement(endFlowNode);
  22. List newSequenceFlowList = new ArrayList<>();
  23. newSequenceFlowList.add(newSequenceFlow);
  24. // 当前节点指向新的方向
  25. currentFlowNode.setOutgoingFlows(newSequenceFlowList);
  26. // 完成当前任务
  27. taskService.complete(task.getId());
  28. // 可以不用恢复原始方向,不影响其它的流程
  29. // currentFlowNode.setOutgoingFlows(originalSequenceFlowList);
  30. }

补充1:关于BUSINESS_KEY_

BUSINESS_KEY_ 字段是用于将业务系统与Actititi工作流关联的关键字段,通常我们用它来存放业务表的ID,比如:请假ID、报销ID等等。

但是,通常咱们系统不可能只有一个流程,假设我们做的是一个OA系统,那么公司的流程有请假、采购、报销等等流程,那这一个字段如何区分到底是哪个业务流程的ID呢,换言之,假设BUSINESS_KEY_这个字段现在是2,那么我怎么知道这个2是请假表的ID,还是采购表的ID呢?因此,要想通过这个一个字段区分不同的类型就要求这个字段是唯一的,比如我们可以加上业务标识,比如:holiday:2,purchase:3等等。还有一种方式,利用另外一个空闲字段TENANT_ID_,我们可以把业务类型存到TENANT_ID_字段中,这样TENANT_ID_和BUSINESS_KEY_两个字段就能唯一确定是哪个业务的那个ID。

  1. /**
  2. * 7.1.0.M6的act_ru_task表中有BUSINESS_KEY_字段,因此可以直接task.getBusinessKey()
  3. * 而7.1.0.M5中没有这个字段,因此要想获取BUSINESS_KEY_必须从act_ru_execution表中取
  4. */
  5. @Test
  6. public void testBusinessKey() {
  7. List<Task> taskList = taskService.createTaskQuery().taskCandidateOrAssigned("lisi").taskTenantId("11").list();
  8. Set<String> processInstanceIds = taskList.stream().map(Task::getProcessInstanceId).collect(Collectors.toSet());
  9. List<ProcessInstance> processInstances = runtimeService.createProcessInstanceQuery().processInstanceIds(processInstanceIds).list();
  10. List<String> businessKeyList = processInstances.stream().map(ProcessInstance::getBusinessKey).collect(Collectors.toList());
  11. System.out.println(businessKeyList);
  12. Pattern pattern = Pattern.compile("^(\\w+):(\\d+)$");
  13. List<Integer> businessIds = new ArrayList<>();
  14. businessKeyList.forEach(businessKey->{
  15. Matcher matcher = pattern.matcher(businessKey);
  16. if (matcher.find()) {
  17. String id = matcher.group(2);
  18. businessIds.add(Integer.valueOf(id));
  19. }
  20. });
  21. }

补充2:Activiti不同版本的Bug

首先,我发现不同版本的表结构不一样,当用 7.1.0.M5 版本时,启动就报错,缺少字段

org.apache.ibatis.exceptions.PersistenceException: 
### Error updating database.  Cause: java.sql.SQLSyntaxErrorException: Unknown column 'VERSION_' in 'field list'
### The error may exist in org/activiti/db/mapping/entity/Deployment.xml
### The error may involve org.activiti.engine.impl.persistence.entity.DeploymentEntityImpl.insertDeployment-Inline
### The error occurred while setting parameters
### SQL: insert into ACT_RE_DEPLOYMENT(ID_, NAME_, CATEGORY_, KEY_, TENANT_ID_, DEPLOY_TIME_, ENGINE_VERSION_, VERSION_, PROJECT_RELEASE_VERSION_)     values(?, ?, ?, ?, ?, ?, ?, ?, ?)
### Cause: java.sql.SQLSyntaxErrorException: Unknown column 'VERSION_' in 'field list'
    at org.apache.ibatis.exceptions.ExceptionFactory.wrapException(ExceptionFactory.java:30) ~[mybatis-3.5.0.jar:3.5.0]
    at org.apache.ibatis.session.defaults.DefaultSqlSession.update(DefaultSqlSession.java:200) ~[mybatis-3.5.0.jar:3.5.0]
    at org.apache.ibatis.session.defaults.DefaultSqlSession.insert(DefaultSqlSession.java:185) ~[mybatis-3.5.0.jar:3.5.0]
    at org.activiti.engine.impl.db.DbSqlSession.flushRegularInsert(DbSqlSession.java:787) ~[activiti-engine-7.1.0.M5.jar:na]
    at org.activiti.engine.impl.db.DbSqlSession.flushInsertEntities(DbSqlSession.java:662) ~[activiti-engine-7.1.0.M5.jar:na]
    at org.activiti.engine.impl.db.DbSqlSession.flushInserts(DbSqlSession.java:642) ~[activiti-engine-7.1.0.M5.jar:na]
    at org.activiti.engine.impl.db.DbSqlSession.flush(DbSqlSession.java:525) ~[activiti-engine-7.1.0.M5.jar:na]

解决办法也很简单,将缺失的字段加上即可:

  1. ALTER TABLE `act_re_deployment`
  2. ADD COLUMN `VERSION_` int(11) NULL DEFAULT NULL,
  3. ADD COLUMN `PROJECT_RELEASE_VERSION_` varchar(255) NULL DEFAULT NULL;

其次,我发现在启动流程实例查询流程定义时,7.1.0.M5是按版本升序取第一个,而7.1.0.M6是降序

同时,还发现7.1.0.M6有一个明显的Bug,这个Bug会导致当有多个部署的时候,即当act_re_deployment表中的记录多于1条时,就无法使用processRuntime.start()启动流程实例

本着用新不用旧的原则,还是建议用7.1.0.M6

还有一个bug,这个bug发生在当使用原生的taskService完成任务时,多次设置同一个流程变量的值后者不会覆盖前者。即,ACT_RU_VARIABLE表中变量的值没有更新。

为了说明这个问题,看下面这个图:

节点“1”完成任务时设置result==3,于是后面的流程永远是1->3->1->3->...  ,即使下一次执行时result==1,流程也不会走到2。经过分析,我猜测对同一个变量多次赋值,后者没有覆盖前者,也就是说第2次赋值没有生效,查看ACT_RU_VARIABLE表果然是这样,变量的值没有更新。经过反复试验,我发现用taskRuntime.complete()完成任务时就不会出现这个问题,流程变量的值会正常更新。

  1. Map<String, Object> variables = new HashMap<>();
  2. variables.put("result", 3);
  3. // 这样写的话,多次对同一个流程变量赋值时,流程变量的值不会更新,即后面的赋值永远是不生效的
  4. Task task = taskService.createTaskQuery().taskId("1234").singleResult();
  5. taskService.complete(task.getId(), variables);
  6. // 这样写的话,就很完美,ACT_RU_VARIABLE表的流程变量的值正常更新
  7. taskRuntime.complete(TaskPayloadBuilder.complete().withTaskId("1234").withVariables(variables).build());

补充3:任务监听器

  1. @Slf4j
  2. @Component
  3. public class TaskCreateListener implements TaskRuntimeEventListener<TaskCreatedEvent> {
  4. @Override
  5. public void onEvent(TaskCreatedEvent event) {
  6. System.out.println("任务被创建");
  7. }
  8. }
  9. @Slf4j
  10. @Component
  11. public class TaskAssignedListener implements TaskRuntimeEventListener<TaskAssignedEvent> {
  12. @Override
  13. public void onEvent(TaskAssignedEvent event) {
  14. System.out.println("任务被指派");
  15. }
  16. }
  17. @Slf4j
  18. @Component
  19. public class TaskCompletedListener implements TaskRuntimeEventListener<TaskCompletedEvent> {
  20. @Override
  21. public void onEvent(TaskCompletedEvent event) {
  22. System.out.println("任务被完成");
  23. }
  24. }

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/木道寻08/article/detail/784617
推荐阅读
相关标签
  

闽ICP备14008679号