|
@@ -5,6 +5,7 @@ import cn.hutool.core.collection.ListUtil;
|
|
import cn.hutool.core.date.DateUtil;
|
|
import cn.hutool.core.date.DateUtil;
|
|
import cn.hutool.core.lang.Assert;
|
|
import cn.hutool.core.lang.Assert;
|
|
import cn.hutool.core.util.ArrayUtil;
|
|
import cn.hutool.core.util.ArrayUtil;
|
|
|
|
+import cn.hutool.core.util.ObjUtil;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
|
@@ -13,6 +14,7 @@ import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
|
|
import cn.iocoder.yudao.framework.common.util.object.ObjectUtils;
|
|
import cn.iocoder.yudao.framework.common.util.object.ObjectUtils;
|
|
import cn.iocoder.yudao.framework.common.util.object.PageUtils;
|
|
import cn.iocoder.yudao.framework.common.util.object.PageUtils;
|
|
import cn.iocoder.yudao.module.bpm.api.task.dto.BpmProcessInstanceCreateReqDTO;
|
|
import cn.iocoder.yudao.module.bpm.api.task.dto.BpmProcessInstanceCreateReqDTO;
|
|
|
|
+import cn.iocoder.yudao.module.bpm.controller.admin.base.user.UserSimpleBaseVO;
|
|
import cn.iocoder.yudao.module.bpm.controller.admin.definition.vo.model.BpmModelMetaInfoVO;
|
|
import cn.iocoder.yudao.module.bpm.controller.admin.definition.vo.model.BpmModelMetaInfoVO;
|
|
import cn.iocoder.yudao.module.bpm.controller.admin.definition.vo.model.simple.BpmSimpleModelNodeVO;
|
|
import cn.iocoder.yudao.module.bpm.controller.admin.definition.vo.model.simple.BpmSimpleModelNodeVO;
|
|
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.instance.*;
|
|
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.instance.*;
|
|
@@ -28,10 +30,11 @@ import cn.iocoder.yudao.module.bpm.enums.task.BpmProcessInstanceStatusEnum;
|
|
import cn.iocoder.yudao.module.bpm.enums.task.BpmReasonEnum;
|
|
import cn.iocoder.yudao.module.bpm.enums.task.BpmReasonEnum;
|
|
import cn.iocoder.yudao.module.bpm.enums.task.BpmTaskStatusEnum;
|
|
import cn.iocoder.yudao.module.bpm.enums.task.BpmTaskStatusEnum;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.candidate.BpmTaskCandidateInvoker;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.candidate.BpmTaskCandidateInvoker;
|
|
-import cn.iocoder.yudao.module.bpm.framework.flowable.core.candidate.strategy.dept.BpmTaskCandidateStartUserSelectStrategy;
|
|
|
|
|
|
+import cn.iocoder.yudao.module.bpm.framework.flowable.core.enums.BpmTaskCandidateStrategyEnum;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.enums.BpmnModelConstants;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.enums.BpmnModelConstants;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.enums.BpmnVariableConstants;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.enums.BpmnVariableConstants;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.event.BpmProcessInstanceEventPublisher;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.event.BpmProcessInstanceEventPublisher;
|
|
|
|
+import cn.iocoder.yudao.module.bpm.framework.flowable.core.util.BpmHttpRequestUtils;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.util.BpmnModelUtils;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.util.BpmnModelUtils;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.util.FlowableUtils;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.util.FlowableUtils;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.util.SimpleModelUtils;
|
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.util.SimpleModelUtils;
|
|
@@ -54,11 +57,13 @@ import org.flowable.engine.history.HistoricProcessInstanceQuery;
|
|
import org.flowable.engine.repository.ProcessDefinition;
|
|
import org.flowable.engine.repository.ProcessDefinition;
|
|
import org.flowable.engine.runtime.ProcessInstance;
|
|
import org.flowable.engine.runtime.ProcessInstance;
|
|
import org.flowable.engine.runtime.ProcessInstanceBuilder;
|
|
import org.flowable.engine.runtime.ProcessInstanceBuilder;
|
|
|
|
+import org.flowable.task.api.Task;
|
|
import org.flowable.task.api.history.HistoricTaskInstance;
|
|
import org.flowable.task.api.history.HistoricTaskInstance;
|
|
import org.springframework.context.annotation.Lazy;
|
|
import org.springframework.context.annotation.Lazy;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.validation.annotation.Validated;
|
|
import org.springframework.validation.annotation.Validated;
|
|
|
|
+import org.springframework.web.client.RestTemplate;
|
|
|
|
|
|
import java.util.*;
|
|
import java.util.*;
|
|
|
|
|
|
@@ -67,6 +72,7 @@ import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.
|
|
import static cn.iocoder.yudao.module.bpm.controller.admin.task.vo.instance.BpmApprovalDetailRespVO.ActivityNode;
|
|
import static cn.iocoder.yudao.module.bpm.controller.admin.task.vo.instance.BpmApprovalDetailRespVO.ActivityNode;
|
|
import static cn.iocoder.yudao.module.bpm.enums.ErrorCodeConstants.*;
|
|
import static cn.iocoder.yudao.module.bpm.enums.ErrorCodeConstants.*;
|
|
import static cn.iocoder.yudao.module.bpm.framework.flowable.core.enums.BpmnModelConstants.START_USER_NODE_ID;
|
|
import static cn.iocoder.yudao.module.bpm.framework.flowable.core.enums.BpmnModelConstants.START_USER_NODE_ID;
|
|
|
|
+import static cn.iocoder.yudao.module.bpm.framework.flowable.core.util.BpmnModelUtils.parseNodeType;
|
|
import static java.util.Arrays.asList;
|
|
import static java.util.Arrays.asList;
|
|
import static java.util.Collections.singletonList;
|
|
import static java.util.Collections.singletonList;
|
|
import static org.flowable.bpmn.constants.BpmnXMLConstants.*;
|
|
import static org.flowable.bpmn.constants.BpmnXMLConstants.*;
|
|
@@ -116,6 +122,9 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
@Resource
|
|
@Resource
|
|
private BpmProcessIdRedisDAO processIdRedisDAO;
|
|
private BpmProcessIdRedisDAO processIdRedisDAO;
|
|
|
|
|
|
|
|
+ @Resource
|
|
|
|
+ private RestTemplate restTemplate;
|
|
|
|
+
|
|
// ========== Query 查询相关方法 ==========
|
|
// ========== Query 查询相关方法 ==========
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -144,7 +153,7 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
}
|
|
}
|
|
|
|
|
|
private Map<String, String> getFormFieldsPermission(BpmnModel bpmnModel,
|
|
private Map<String, String> getFormFieldsPermission(BpmnModel bpmnModel,
|
|
- String activityId, String taskId) {
|
|
|
|
|
|
+ String activityId, String taskId) {
|
|
// 1. 获取流程活动编号。流程活动 Id 为空事,从流程任务中获取流程活动 Id
|
|
// 1. 获取流程活动编号。流程活动 Id 为空事,从流程任务中获取流程活动 Id
|
|
if (StrUtil.isEmpty(activityId) && StrUtil.isNotEmpty(taskId)) {
|
|
if (StrUtil.isEmpty(activityId) && StrUtil.isNotEmpty(taskId)) {
|
|
activityId = Optional.ofNullable(taskService.getHistoricTask(taskId))
|
|
activityId = Optional.ofNullable(taskService.getHistoricTask(taskId))
|
|
@@ -164,7 +173,7 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
Long startUserId = loginUserId; // 流程发起人
|
|
Long startUserId = loginUserId; // 流程发起人
|
|
HistoricProcessInstance historicProcessInstance = null; // 流程实例
|
|
HistoricProcessInstance historicProcessInstance = null; // 流程实例
|
|
Integer processInstanceStatus = BpmProcessInstanceStatusEnum.NOT_START.getStatus(); // 流程状态
|
|
Integer processInstanceStatus = BpmProcessInstanceStatusEnum.NOT_START.getStatus(); // 流程状态
|
|
- Map<String, Object> processVariables = reqVO.getProcessVariables(); // 流程变量
|
|
|
|
|
|
+ Map<String, Object> processVariables = new HashMap<>(); // 流程变量
|
|
// 1.2 如果是流程已发起的场景,则使用流程实例的数据
|
|
// 1.2 如果是流程已发起的场景,则使用流程实例的数据
|
|
if (reqVO.getProcessInstanceId() != null) {
|
|
if (reqVO.getProcessInstanceId() != null) {
|
|
historicProcessInstance = getHistoricProcessInstance(reqVO.getProcessInstanceId());
|
|
historicProcessInstance = getHistoricProcessInstance(reqVO.getProcessInstanceId());
|
|
@@ -173,7 +182,13 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
}
|
|
}
|
|
startUserId = Long.valueOf(historicProcessInstance.getStartUserId());
|
|
startUserId = Long.valueOf(historicProcessInstance.getStartUserId());
|
|
processInstanceStatus = FlowableUtils.getProcessInstanceStatus(historicProcessInstance);
|
|
processInstanceStatus = FlowableUtils.getProcessInstanceStatus(historicProcessInstance);
|
|
- processVariables = historicProcessInstance.getProcessVariables();
|
|
|
|
|
|
+ // 合并 DB 和前端传递的流量变量,以前端的为主
|
|
|
|
+ if (CollUtil.isNotEmpty(historicProcessInstance.getProcessVariables())) {
|
|
|
|
+ processVariables.putAll(historicProcessInstance.getProcessVariables());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if (CollUtil.isNotEmpty(reqVO.getProcessVariables())) {
|
|
|
|
+ processVariables.putAll(reqVO.getProcessVariables());
|
|
}
|
|
}
|
|
// 1.3 读取其它相关数据
|
|
// 1.3 读取其它相关数据
|
|
ProcessDefinition processDefinition = processDefinitionService.getProcessDefinition(
|
|
ProcessDefinition processDefinition = processDefinitionService.getProcessDefinition(
|
|
@@ -205,20 +220,78 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
}
|
|
}
|
|
|
|
|
|
// 3.1 计算当前登录用户的待办任务
|
|
// 3.1 计算当前登录用户的待办任务
|
|
- // TODO @jason:有一个极端情况,如果一个用户有 2 个 task A 和 B,A 已经通过,B 需要审核。这个时,通过 A 进来,todo 拿到
|
|
|
|
- // B,会不会表单权限不一致哈。
|
|
|
|
- BpmTaskRespVO todoTask = taskService.getFirstTodoTask(loginUserId, reqVO.getProcessInstanceId());
|
|
|
|
-
|
|
|
|
|
|
+ BpmTaskRespVO todoTask = taskService.getTodoTask(loginUserId, reqVO.getTaskId(), reqVO.getProcessInstanceId());
|
|
// 3.2 预测未运行节点的审批信息
|
|
// 3.2 预测未运行节点的审批信息
|
|
List<ActivityNode> simulateActivityNodes = getSimulateApproveNodeList(startUserId, bpmnModel,
|
|
List<ActivityNode> simulateActivityNodes = getSimulateApproveNodeList(startUserId, bpmnModel,
|
|
processDefinitionInfo,
|
|
processDefinitionInfo,
|
|
processVariables, activities);
|
|
processVariables, activities);
|
|
|
|
+ // 3.3 如果是发起动作,activityId 为开始节点,不校验审批人自选节点
|
|
|
|
+ if (ObjUtil.equals(reqVO.getActivityId(), BpmnModelConstants.START_USER_NODE_ID)) {
|
|
|
|
+ simulateActivityNodes.removeIf(node ->
|
|
|
|
+ BpmTaskCandidateStrategyEnum.APPROVE_USER_SELECT.getStrategy().equals(node.getCandidateStrategy()));
|
|
|
|
+ }
|
|
|
|
|
|
// 4. 拼接最终数据
|
|
// 4. 拼接最终数据
|
|
return buildApprovalDetail(reqVO, bpmnModel, processDefinition, processDefinitionInfo, historicProcessInstance,
|
|
return buildApprovalDetail(reqVO, bpmnModel, processDefinition, processDefinitionInfo, historicProcessInstance,
|
|
processInstanceStatus, endActivityNodes, runActivityNodes, simulateActivityNodes, todoTask);
|
|
processInstanceStatus, endActivityNodes, runActivityNodes, simulateActivityNodes, todoTask);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public List<ActivityNode> getNextApprovalNodes(Long loginUserId, BpmApprovalDetailReqVO reqVO) {
|
|
|
|
+ // 1.1 校验任务存在,且是当前用户的
|
|
|
|
+ Task task = taskService.validateTask(loginUserId, reqVO.getTaskId());
|
|
|
|
+ // 1.2 校验流程实例存在
|
|
|
|
+ ProcessInstance instance = getProcessInstance(task.getProcessInstanceId());
|
|
|
|
+ if (instance == null) {
|
|
|
|
+ throw exception(PROCESS_INSTANCE_NOT_EXISTS);
|
|
|
|
+ }
|
|
|
|
+ HistoricProcessInstance historicProcessInstance = getHistoricProcessInstance(task.getProcessInstanceId());
|
|
|
|
+ if (historicProcessInstance == null) {
|
|
|
|
+ throw exception(ErrorCodeConstants.PROCESS_INSTANCE_NOT_EXISTS);
|
|
|
|
+ }
|
|
|
|
+ // 1.3 校验BpmnModel
|
|
|
|
+ BpmnModel bpmnModel = processDefinitionService.getProcessDefinitionBpmnModel(task.getProcessDefinitionId());
|
|
|
|
+ if (bpmnModel == null) {
|
|
|
|
+ return null;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ // 2. 设置流程变量
|
|
|
|
+ Map<String, Object> processVariables = new HashMap<>();
|
|
|
|
+ // 2.1 获取历史中流程变量
|
|
|
|
+ if (CollUtil.isNotEmpty(historicProcessInstance.getProcessVariables())) {
|
|
|
|
+ processVariables.putAll(historicProcessInstance.getProcessVariables());
|
|
|
|
+ }
|
|
|
|
+ // 2.2 合并前端传递的流程变量,以前端为准
|
|
|
|
+ if (CollUtil.isNotEmpty(reqVO.getProcessVariables())) {
|
|
|
|
+ processVariables.putAll(reqVO.getProcessVariables());
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ // 3 获取当前任务节点的信息
|
|
|
|
+ // 3.1 获取下一个将要执行的节点集合
|
|
|
|
+ FlowElement flowElement = bpmnModel.getFlowElement(task.getTaskDefinitionKey());
|
|
|
|
+ List<FlowNode> nextFlowNodes = BpmnModelUtils.getNextFlowNodes(flowElement, bpmnModel, processVariables);
|
|
|
|
+ return convertList(nextFlowNodes, node -> {
|
|
|
|
+ List<Long> candidateUserIds = getTaskCandidateUserList(bpmnModel, node.getId(),
|
|
|
|
+ loginUserId, historicProcessInstance.getProcessDefinitionId(), processVariables);
|
|
|
|
+ // 3.2 获取节点的审批人信息
|
|
|
|
+ Map<Long, AdminUserRespDTO> userMap = adminUserApi.getUserMap(candidateUserIds);
|
|
|
|
+ // 3.3 获取节点的审批人部门信息
|
|
|
|
+ Map<Long, DeptRespDTO> deptMap = deptApi.getDeptMap(convertSet(userMap.values(), AdminUserRespDTO::getDeptId));
|
|
|
|
+ // 3.4 存在一个节点多人审批的情况,组装审批人信息
|
|
|
|
+ List<UserSimpleBaseVO> candidateUsers = new ArrayList<>();
|
|
|
|
+ userMap.forEach((key, value) -> candidateUsers.add(BpmProcessInstanceConvert.INSTANCE.buildUser(key, userMap, deptMap)));
|
|
|
|
+ return new ActivityNode().setNodeType(BpmSimpleModelNodeTypeEnum.APPROVE_NODE.getType())
|
|
|
|
+ .setId(node.getId())
|
|
|
|
+ .setName(node.getName())
|
|
|
|
+ .setStatus(BpmTaskStatusEnum.RUNNING.getStatus())
|
|
|
|
+ .setCandidateStrategy(BpmnModelUtils.parseCandidateStrategy(node))
|
|
|
|
+ // TODO @小北:先把 candidateUserIds 设置完,然后最后拼接 candidateUsers 信息。这样,如果有多个节点,就不用重复查询啦;类似 buildApprovalDetail 思路;
|
|
|
|
+ // TODO 先拼接处 List ActivityNode
|
|
|
|
+ // TODO 接着,再起一段,处理 adminUserApi.getUserMap(candidateUserIds)、deptApi.getDeptMap(convertSet(userMap.values(), AdminUserRespDTO::getDeptId))
|
|
|
|
+ .setCandidateUsers(candidateUsers);
|
|
|
|
+ });
|
|
|
|
+ }
|
|
|
|
+
|
|
@Override
|
|
@Override
|
|
@SuppressWarnings("unchecked")
|
|
@SuppressWarnings("unchecked")
|
|
public PageResult<HistoricProcessInstance> getProcessInstancePage(Long userId,
|
|
public PageResult<HistoricProcessInstance> getProcessInstancePage(Long userId,
|
|
@@ -283,15 +356,15 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
* 主要是,拼接审批人的用户信息、部门信息
|
|
* 主要是,拼接审批人的用户信息、部门信息
|
|
*/
|
|
*/
|
|
private BpmApprovalDetailRespVO buildApprovalDetail(BpmApprovalDetailReqVO reqVO,
|
|
private BpmApprovalDetailRespVO buildApprovalDetail(BpmApprovalDetailReqVO reqVO,
|
|
- BpmnModel bpmnModel,
|
|
|
|
- ProcessDefinition processDefinition,
|
|
|
|
- BpmProcessDefinitionInfoDO processDefinitionInfo,
|
|
|
|
- HistoricProcessInstance processInstance,
|
|
|
|
- Integer processInstanceStatus,
|
|
|
|
- List<ActivityNode> endApprovalNodeInfos,
|
|
|
|
- List<ActivityNode> runningApprovalNodeInfos,
|
|
|
|
- List<ActivityNode> simulateApprovalNodeInfos,
|
|
|
|
- BpmTaskRespVO todoTask) {
|
|
|
|
|
|
+ BpmnModel bpmnModel,
|
|
|
|
+ ProcessDefinition processDefinition,
|
|
|
|
+ BpmProcessDefinitionInfoDO processDefinitionInfo,
|
|
|
|
+ HistoricProcessInstance processInstance,
|
|
|
|
+ Integer processInstanceStatus,
|
|
|
|
+ List<ActivityNode> endApprovalNodeInfos,
|
|
|
|
+ List<ActivityNode> runningApprovalNodeInfos,
|
|
|
|
+ List<ActivityNode> simulateApprovalNodeInfos,
|
|
|
|
+ BpmTaskRespVO todoTask) {
|
|
// 1. 获取所有需要读取用户信息的 userIds
|
|
// 1. 获取所有需要读取用户信息的 userIds
|
|
List<ActivityNode> approveNodes = newArrayList(
|
|
List<ActivityNode> approveNodes = newArrayList(
|
|
asList(endApprovalNodeInfos, runningApprovalNodeInfos, simulateApprovalNodeInfos));
|
|
asList(endApprovalNodeInfos, runningApprovalNodeInfos, simulateApprovalNodeInfos));
|
|
@@ -313,19 +386,21 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
* 获得【已结束】的活动节点们
|
|
* 获得【已结束】的活动节点们
|
|
*/
|
|
*/
|
|
private List<ActivityNode> getEndActivityNodeList(Long startUserId, BpmnModel bpmnModel,
|
|
private List<ActivityNode> getEndActivityNodeList(Long startUserId, BpmnModel bpmnModel,
|
|
- BpmProcessDefinitionInfoDO processDefinitionInfo,
|
|
|
|
- HistoricProcessInstance historicProcessInstance, Integer processInstanceStatus,
|
|
|
|
- List<HistoricActivityInstance> activities, List<HistoricTaskInstance> tasks) {
|
|
|
|
|
|
+ BpmProcessDefinitionInfoDO processDefinitionInfo,
|
|
|
|
+ HistoricProcessInstance historicProcessInstance, Integer processInstanceStatus,
|
|
|
|
+ List<HistoricActivityInstance> activities, List<HistoricTaskInstance> tasks) {
|
|
// 遍历 tasks 列表,只处理已结束的 UserTask
|
|
// 遍历 tasks 列表,只处理已结束的 UserTask
|
|
- // 为什么不通过 activities 呢?因为,加签场景下,它只存在于 tasks,没有 activities,导致如果遍历 activities
|
|
|
|
- // 的话,它无法成为一个节点
|
|
|
|
|
|
+ // 为什么不通过 activities 呢?因为,加签场景下,它只存在于 tasks,没有 activities,导致如果遍历 activities 的话,它无法成为一个节点
|
|
|
|
+ // TODO @芋艿:子流程只有activity,这里获取不到已结束的子流程;
|
|
|
|
+ // TODO @lesan:【子流程】基于 activities 查询出 usertask、callactivity,然后拼接?如果是子流程,就是可以点击过去?
|
|
List<HistoricTaskInstance> endTasks = filterList(tasks, task -> task.getEndTime() != null);
|
|
List<HistoricTaskInstance> endTasks = filterList(tasks, task -> task.getEndTime() != null);
|
|
List<ActivityNode> approvalNodes = convertList(endTasks, task -> {
|
|
List<ActivityNode> approvalNodes = convertList(endTasks, task -> {
|
|
FlowElement flowNode = BpmnModelUtils.getFlowElementById(bpmnModel, task.getTaskDefinitionKey());
|
|
FlowElement flowNode = BpmnModelUtils.getFlowElementById(bpmnModel, task.getTaskDefinitionKey());
|
|
ActivityNode activityNode = new ActivityNode().setId(task.getTaskDefinitionKey()).setName(task.getName())
|
|
ActivityNode activityNode = new ActivityNode().setId(task.getTaskDefinitionKey()).setName(task.getName())
|
|
.setNodeType(START_USER_NODE_ID.equals(task.getTaskDefinitionKey())
|
|
.setNodeType(START_USER_NODE_ID.equals(task.getTaskDefinitionKey())
|
|
? BpmSimpleModelNodeTypeEnum.START_USER_NODE.getType()
|
|
? BpmSimpleModelNodeTypeEnum.START_USER_NODE.getType()
|
|
- : BpmSimpleModelNodeTypeEnum.APPROVE_NODE.getType())
|
|
|
|
|
|
+ : ObjUtil.defaultIfNull(parseNodeType(flowNode), // 目的:解决“办理节点”的识别
|
|
|
|
+ BpmSimpleModelNodeTypeEnum.APPROVE_NODE.getType()))
|
|
.setStatus(FlowableUtils.getTaskStatus(task))
|
|
.setStatus(FlowableUtils.getTaskStatus(task))
|
|
.setCandidateStrategy(BpmnModelUtils.parseCandidateStrategy(flowNode))
|
|
.setCandidateStrategy(BpmnModelUtils.parseCandidateStrategy(flowNode))
|
|
.setStartTime(DateUtils.of(task.getCreateTime())).setEndTime(DateUtils.of(task.getEndTime()))
|
|
.setStartTime(DateUtils.of(task.getCreateTime())).setEndTime(DateUtils.of(task.getEndTime()))
|
|
@@ -381,18 +456,19 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
* 获得【进行中】的活动节点们
|
|
* 获得【进行中】的活动节点们
|
|
*/
|
|
*/
|
|
private List<ActivityNode> getRunApproveNodeList(Long startUserId,
|
|
private List<ActivityNode> getRunApproveNodeList(Long startUserId,
|
|
- BpmnModel bpmnModel,
|
|
|
|
- ProcessDefinition processDefinition,
|
|
|
|
- Map<String, Object> processVariables,
|
|
|
|
- List<HistoricActivityInstance> activities,
|
|
|
|
- List<HistoricTaskInstance> tasks) {
|
|
|
|
- // 构建运行中的任务,基于 activityId 分组
|
|
|
|
|
|
+ BpmnModel bpmnModel,
|
|
|
|
+ ProcessDefinition processDefinition,
|
|
|
|
+ Map<String, Object> processVariables,
|
|
|
|
+ List<HistoricActivityInstance> activities,
|
|
|
|
+ List<HistoricTaskInstance> tasks) {
|
|
|
|
+ // 构建运行中的任务、子流程,基于 activityId 分组
|
|
List<HistoricActivityInstance> runActivities = filterList(activities, activity -> activity.getEndTime() == null
|
|
List<HistoricActivityInstance> runActivities = filterList(activities, activity -> activity.getEndTime() == null
|
|
- && (StrUtil.equalsAny(activity.getActivityType(), ELEMENT_TASK_USER)));
|
|
|
|
|
|
+ && (StrUtil.equalsAny(activity.getActivityType(), ELEMENT_TASK_USER, ELEMENT_CALL_ACTIVITY)));
|
|
Map<String, List<HistoricActivityInstance>> runningTaskMap = convertMultiMap(runActivities,
|
|
Map<String, List<HistoricActivityInstance>> runningTaskMap = convertMultiMap(runActivities,
|
|
HistoricActivityInstance::getActivityId);
|
|
HistoricActivityInstance::getActivityId);
|
|
|
|
|
|
// 按照 activityId 分组,构建 ApprovalNodeInfo 节点
|
|
// 按照 activityId 分组,构建 ApprovalNodeInfo 节点
|
|
|
|
+ // TODO @lesan:【子流程】在子流程进行审批的时候,HistoricActivityInstance 里面可以拿到 runActivities.get(0).getCalledProcessInstanceId()。要不要支持跳转???
|
|
Map<String, HistoricTaskInstance> taskMap = convertMap(tasks, HistoricTaskInstance::getId);
|
|
Map<String, HistoricTaskInstance> taskMap = convertMap(tasks, HistoricTaskInstance::getId);
|
|
return convertList(runningTaskMap.entrySet(), entry -> {
|
|
return convertList(runningTaskMap.entrySet(), entry -> {
|
|
String activityId = entry.getKey();
|
|
String activityId = entry.getKey();
|
|
@@ -402,7 +478,8 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
HistoricActivityInstance firstActivity = CollUtil.getFirst(taskActivities); // 取第一个任务,会签/或签的任务,开始时间相同
|
|
HistoricActivityInstance firstActivity = CollUtil.getFirst(taskActivities); // 取第一个任务,会签/或签的任务,开始时间相同
|
|
ActivityNode activityNode = new ActivityNode().setId(firstActivity.getActivityId())
|
|
ActivityNode activityNode = new ActivityNode().setId(firstActivity.getActivityId())
|
|
.setName(firstActivity.getActivityName())
|
|
.setName(firstActivity.getActivityName())
|
|
- .setNodeType(BpmSimpleModelNodeTypeEnum.APPROVE_NODE.getType())
|
|
|
|
|
|
+ .setNodeType(ObjUtil.defaultIfNull(parseNodeType(flowNode), // 目的:解决“办理节点”和"子流程"的识别
|
|
|
|
+ BpmSimpleModelNodeTypeEnum.APPROVE_NODE.getType()))
|
|
.setStatus(BpmTaskStatusEnum.RUNNING.getStatus())
|
|
.setStatus(BpmTaskStatusEnum.RUNNING.getStatus())
|
|
.setCandidateStrategy(BpmnModelUtils.parseCandidateStrategy(flowNode))
|
|
.setCandidateStrategy(BpmnModelUtils.parseCandidateStrategy(flowNode))
|
|
.setStartTime(DateUtils.of(CollUtil.getFirst(taskActivities).getStartTime()))
|
|
.setStartTime(DateUtils.of(CollUtil.getFirst(taskActivities).getStartTime()))
|
|
@@ -410,6 +487,11 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
// 处理每个任务的 tasks 属性
|
|
// 处理每个任务的 tasks 属性
|
|
for (HistoricActivityInstance activity : taskActivities) {
|
|
for (HistoricActivityInstance activity : taskActivities) {
|
|
HistoricTaskInstance task = taskMap.get(activity.getTaskId());
|
|
HistoricTaskInstance task = taskMap.get(activity.getTaskId());
|
|
|
|
+ // 特殊情况:子流程节点 ChildProcess 仅存在于 activity 中,并且没有自身的 task,需要跳过执行
|
|
|
|
+ // TODO @芋艿:后续看看怎么优化!
|
|
|
|
+ if (task == null) {
|
|
|
|
+ continue;
|
|
|
|
+ }
|
|
activityNode.getTasks().add(BpmProcessInstanceConvert.INSTANCE.buildApprovalTaskInfo(task));
|
|
activityNode.getTasks().add(BpmProcessInstanceConvert.INSTANCE.buildApprovalTaskInfo(task));
|
|
// 加签子任务,需要过滤掉已经完成的加签子任务
|
|
// 加签子任务,需要过滤掉已经完成的加签子任务
|
|
List<HistoricTaskInstance> childrenTasks = filterList(
|
|
List<HistoricTaskInstance> childrenTasks = filterList(
|
|
@@ -440,9 +522,9 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
* 获得【预测(未来)】的活动节点们
|
|
* 获得【预测(未来)】的活动节点们
|
|
*/
|
|
*/
|
|
private List<ActivityNode> getSimulateApproveNodeList(Long startUserId, BpmnModel bpmnModel,
|
|
private List<ActivityNode> getSimulateApproveNodeList(Long startUserId, BpmnModel bpmnModel,
|
|
- BpmProcessDefinitionInfoDO processDefinitionInfo,
|
|
|
|
- Map<String, Object> processVariables,
|
|
|
|
- List<HistoricActivityInstance> activities) {
|
|
|
|
|
|
+ BpmProcessDefinitionInfoDO processDefinitionInfo,
|
|
|
|
+ Map<String, Object> processVariables,
|
|
|
|
+ List<HistoricActivityInstance> activities) {
|
|
// TODO @芋艿:【可优化】在驳回场景下,未来的预测准确性不高。原因是,驳回后,HistoricActivityInstance
|
|
// TODO @芋艿:【可优化】在驳回场景下,未来的预测准确性不高。原因是,驳回后,HistoricActivityInstance
|
|
// 包括了历史的操作,不是只有 startEvent 到当前节点的记录
|
|
// 包括了历史的操作,不是只有 startEvent 到当前节点的记录
|
|
Set<String> runActivityIds = convertSet(activities, HistoricActivityInstance::getActivityId);
|
|
Set<String> runActivityIds = convertSet(activities, HistoricActivityInstance::getActivityId);
|
|
@@ -464,8 +546,8 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
}
|
|
}
|
|
|
|
|
|
private ActivityNode buildNotRunApproveNodeForSimple(Long startUserId, BpmnModel bpmnModel,
|
|
private ActivityNode buildNotRunApproveNodeForSimple(Long startUserId, BpmnModel bpmnModel,
|
|
- BpmProcessDefinitionInfoDO processDefinitionInfo, Map<String, Object> processVariables,
|
|
|
|
- BpmSimpleModelNodeVO node, Set<String> runActivityIds) {
|
|
|
|
|
|
+ BpmProcessDefinitionInfoDO processDefinitionInfo, Map<String, Object> processVariables,
|
|
|
|
+ BpmSimpleModelNodeVO node, Set<String> runActivityIds) {
|
|
// TODO @芋艿:【可优化】在驳回场景下,未来的预测准确性不高。原因是,驳回后,HistoricActivityInstance
|
|
// TODO @芋艿:【可优化】在驳回场景下,未来的预测准确性不高。原因是,驳回后,HistoricActivityInstance
|
|
// 包括了历史的操作,不是只有 startEvent 到当前节点的记录
|
|
// 包括了历史的操作,不是只有 startEvent 到当前节点的记录
|
|
if (runActivityIds.contains(node.getId())) {
|
|
if (runActivityIds.contains(node.getId())) {
|
|
@@ -479,7 +561,8 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
// 1. 开始节点/审批节点
|
|
// 1. 开始节点/审批节点
|
|
if (ObjectUtils.equalsAny(node.getType(),
|
|
if (ObjectUtils.equalsAny(node.getType(),
|
|
BpmSimpleModelNodeTypeEnum.START_USER_NODE.getType(),
|
|
BpmSimpleModelNodeTypeEnum.START_USER_NODE.getType(),
|
|
- BpmSimpleModelNodeTypeEnum.APPROVE_NODE.getType())) {
|
|
|
|
|
|
+ BpmSimpleModelNodeTypeEnum.APPROVE_NODE.getType(),
|
|
|
|
+ BpmSimpleModelNodeTypeEnum.TRANSACTOR_NODE.getType())) {
|
|
List<Long> candidateUserIds = getTaskCandidateUserList(bpmnModel, node.getId(),
|
|
List<Long> candidateUserIds = getTaskCandidateUserList(bpmnModel, node.getId(),
|
|
startUserId, processDefinitionInfo.getProcessDefinitionId(), processVariables);
|
|
startUserId, processDefinitionInfo.getProcessDefinitionId(), processVariables);
|
|
activityNode.setCandidateUserIds(candidateUserIds);
|
|
activityNode.setCandidateUserIds(candidateUserIds);
|
|
@@ -494,14 +577,22 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
// 3. 抄送节点
|
|
// 3. 抄送节点
|
|
if (CollUtil.isEmpty(runActivityIds) && // 流程发起时:需要展示抄送节点,用于选择抄送人
|
|
if (CollUtil.isEmpty(runActivityIds) && // 流程发起时:需要展示抄送节点,用于选择抄送人
|
|
BpmSimpleModelNodeTypeEnum.COPY_NODE.getType().equals(node.getType())) {
|
|
BpmSimpleModelNodeTypeEnum.COPY_NODE.getType().equals(node.getType())) {
|
|
|
|
+ List<Long> candidateUserIds = getTaskCandidateUserList(bpmnModel, node.getId(),
|
|
|
|
+ startUserId, processDefinitionInfo.getProcessDefinitionId(), processVariables);
|
|
|
|
+ activityNode.setCandidateUserIds(candidateUserIds);
|
|
|
|
+ return activityNode;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ // 4. 子流程节点
|
|
|
|
+ if (BpmSimpleModelNodeTypeEnum.CHILD_PROCESS.getType().equals(node.getType())) {
|
|
return activityNode;
|
|
return activityNode;
|
|
}
|
|
}
|
|
return null;
|
|
return null;
|
|
}
|
|
}
|
|
|
|
|
|
private ActivityNode buildNotRunApproveNodeForBpmn(Long startUserId, BpmnModel bpmnModel,
|
|
private ActivityNode buildNotRunApproveNodeForBpmn(Long startUserId, BpmnModel bpmnModel,
|
|
- BpmProcessDefinitionInfoDO processDefinitionInfo, Map<String, Object> processVariables,
|
|
|
|
- FlowElement node, Set<String> runActivityIds) {
|
|
|
|
|
|
+ BpmProcessDefinitionInfoDO processDefinitionInfo, Map<String, Object> processVariables,
|
|
|
|
+ FlowElement node, Set<String> runActivityIds) {
|
|
if (runActivityIds.contains(node.getId())) {
|
|
if (runActivityIds.contains(node.getId())) {
|
|
return null;
|
|
return null;
|
|
}
|
|
}
|
|
@@ -532,7 +623,7 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
}
|
|
}
|
|
|
|
|
|
private List<Long> getTaskCandidateUserList(BpmnModel bpmnModel, String activityId,
|
|
private List<Long> getTaskCandidateUserList(BpmnModel bpmnModel, String activityId,
|
|
- Long startUserId, String processDefinitionId, Map<String, Object> processVariables) {
|
|
|
|
|
|
+ Long startUserId, String processDefinitionId, Map<String, Object> processVariables) {
|
|
Set<Long> userIds = taskCandidateInvoker.calculateUsersByActivity(bpmnModel, activityId,
|
|
Set<Long> userIds = taskCandidateInvoker.calculateUsersByActivity(bpmnModel, activityId,
|
|
startUserId, processDefinitionId, processVariables);
|
|
startUserId, processDefinitionId, processVariables);
|
|
return new ArrayList<>(userIds);
|
|
return new ArrayList<>(userIds);
|
|
@@ -568,11 +659,11 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
Set<String> finishedTaskActivityIds = convertSet(activities, HistoricActivityInstance::getActivityId,
|
|
Set<String> finishedTaskActivityIds = convertSet(activities, HistoricActivityInstance::getActivityId,
|
|
activityInstance -> activityInstance.getEndTime() != null
|
|
activityInstance -> activityInstance.getEndTime() != null
|
|
&& ObjectUtil.notEqual(activityInstance.getActivityType(),
|
|
&& ObjectUtil.notEqual(activityInstance.getActivityType(),
|
|
- BpmnXMLConstants.ELEMENT_SEQUENCE_FLOW));
|
|
|
|
|
|
+ BpmnXMLConstants.ELEMENT_SEQUENCE_FLOW));
|
|
Set<String> finishedSequenceFlowActivityIds = convertSet(activities, HistoricActivityInstance::getActivityId,
|
|
Set<String> finishedSequenceFlowActivityIds = convertSet(activities, HistoricActivityInstance::getActivityId,
|
|
activityInstance -> activityInstance.getEndTime() != null
|
|
activityInstance -> activityInstance.getEndTime() != null
|
|
&& ObjectUtil.equals(activityInstance.getActivityType(),
|
|
&& ObjectUtil.equals(activityInstance.getActivityType(),
|
|
- BpmnXMLConstants.ELEMENT_SEQUENCE_FLOW));
|
|
|
|
|
|
+ BpmnXMLConstants.ELEMENT_SEQUENCE_FLOW));
|
|
// 特殊:会签情况下,会有部分已完成(审批)、部分未完成(待审批),此时需要 finishedTaskActivityIds 移除掉
|
|
// 特殊:会签情况下,会有部分已完成(审批)、部分未完成(待审批),此时需要 finishedTaskActivityIds 移除掉
|
|
finishedTaskActivityIds.removeAll(unfinishedTaskActivityIds);
|
|
finishedTaskActivityIds.removeAll(unfinishedTaskActivityIds);
|
|
// 特殊:如果流程实例被拒绝,则需要计算是哪个活动节点。
|
|
// 特殊:如果流程实例被拒绝,则需要计算是哪个活动节点。
|
|
@@ -624,8 +715,8 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
}
|
|
}
|
|
|
|
|
|
private String createProcessInstance0(Long userId, ProcessDefinition definition,
|
|
private String createProcessInstance0(Long userId, ProcessDefinition definition,
|
|
- Map<String, Object> variables, String businessKey,
|
|
|
|
- Map<String, List<Long>> startUserSelectAssignees) {
|
|
|
|
|
|
+ Map<String, Object> variables, String businessKey,
|
|
|
|
+ Map<String, List<Long>> startUserSelectAssignees) {
|
|
// 1.1 校验流程定义
|
|
// 1.1 校验流程定义
|
|
if (definition == null) {
|
|
if (definition == null) {
|
|
throw exception(PROCESS_DEFINITION_NOT_EXISTS);
|
|
throw exception(PROCESS_DEFINITION_NOT_EXISTS);
|
|
@@ -643,7 +734,7 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
throw exception(PROCESS_INSTANCE_START_USER_CAN_START);
|
|
throw exception(PROCESS_INSTANCE_START_USER_CAN_START);
|
|
}
|
|
}
|
|
// 1.3 校验发起人自选审批人
|
|
// 1.3 校验发起人自选审批人
|
|
- validateStartUserSelectAssignees(definition, startUserSelectAssignees);
|
|
|
|
|
|
+ validateStartUserSelectAssignees(userId, definition, startUserSelectAssignees, variables);
|
|
|
|
|
|
// 2. 创建流程实例
|
|
// 2. 创建流程实例
|
|
if (variables == null) {
|
|
if (variables == null) {
|
|
@@ -653,10 +744,9 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
variables.put(BpmnVariableConstants.PROCESS_INSTANCE_VARIABLE_START_USER_ID, userId); // 设置流程变量,发起人 ID
|
|
variables.put(BpmnVariableConstants.PROCESS_INSTANCE_VARIABLE_START_USER_ID, userId); // 设置流程变量,发起人 ID
|
|
variables.put(BpmnVariableConstants.PROCESS_INSTANCE_VARIABLE_STATUS, // 流程实例状态:审批中
|
|
variables.put(BpmnVariableConstants.PROCESS_INSTANCE_VARIABLE_STATUS, // 流程实例状态:审批中
|
|
BpmProcessInstanceStatusEnum.RUNNING.getStatus());
|
|
BpmProcessInstanceStatusEnum.RUNNING.getStatus());
|
|
- variables.put(BpmnVariableConstants.PROCESS_INSTANCE_SKIP_EXPRESSION_ENABLED, true); // 跳过表达式需要添加此变量为
|
|
|
|
- // true,不影响没配置
|
|
|
|
- // skipExpression 的节点
|
|
|
|
|
|
+ variables.put(BpmnVariableConstants.PROCESS_INSTANCE_SKIP_EXPRESSION_ENABLED, true); // 跳过表达式需要添加此变量为 true,不影响没配置 skipExpression 的节点
|
|
if (CollUtil.isNotEmpty(startUserSelectAssignees)) {
|
|
if (CollUtil.isNotEmpty(startUserSelectAssignees)) {
|
|
|
|
+ // 设置流程变量,发起人自选审批人
|
|
variables.put(BpmnVariableConstants.PROCESS_INSTANCE_VARIABLE_START_USER_SELECT_ASSIGNEES,
|
|
variables.put(BpmnVariableConstants.PROCESS_INSTANCE_VARIABLE_START_USER_SELECT_ASSIGNEES,
|
|
startUserSelectAssignees);
|
|
startUserSelectAssignees);
|
|
}
|
|
}
|
|
@@ -688,17 +778,23 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
return instance.getId();
|
|
return instance.getId();
|
|
}
|
|
}
|
|
|
|
|
|
- private void validateStartUserSelectAssignees(ProcessDefinition definition,
|
|
|
|
- Map<String, List<Long>> startUserSelectAssignees) {
|
|
|
|
- // 1. 获得发起人自选审批人的 UserTask/ServiceTask 列表
|
|
|
|
- BpmnModel bpmnModel = processDefinitionService.getProcessDefinitionBpmnModel(definition.getId());
|
|
|
|
- List<Task> tasks = BpmTaskCandidateStartUserSelectStrategy.getStartUserSelectTaskList(bpmnModel);
|
|
|
|
- if (CollUtil.isEmpty(tasks)) {
|
|
|
|
|
|
+ private void validateStartUserSelectAssignees(Long userId, ProcessDefinition definition,
|
|
|
|
+ Map<String, List<Long>> startUserSelectAssignees,
|
|
|
|
+ Map<String, Object> variables) {
|
|
|
|
+ // 1. 获取预测的节点信息
|
|
|
|
+ BpmApprovalDetailRespVO detailRespVO = getApprovalDetail(userId, new BpmApprovalDetailReqVO()
|
|
|
|
+ .setProcessDefinitionId(definition.getId())
|
|
|
|
+ .setProcessVariables(variables));
|
|
|
|
+ List<ActivityNode> activityNodes = detailRespVO.getActivityNodes();
|
|
|
|
+ if (CollUtil.isEmpty(activityNodes)) {
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
- // 2. 校验发起人自选审批人的审批人和抄送人是否都配置了
|
|
|
|
- tasks.forEach(task -> {
|
|
|
|
|
|
+ // 2.1 移除掉不是发起人自选审批人节点
|
|
|
|
+ activityNodes.removeIf(task ->
|
|
|
|
+ ObjectUtil.notEqual(BpmTaskCandidateStrategyEnum.START_USER_SELECT.getStrategy(), task.getCandidateStrategy()));
|
|
|
|
+ // 2.2 流程发起时要先获取当前流程的预测走向节点,发起时只校验预测的节点发起人自选审批人的审批人和抄送人是否都配置了
|
|
|
|
+ activityNodes.forEach(task -> {
|
|
List<Long> assignees = startUserSelectAssignees != null ? startUserSelectAssignees.get(task.getId()) : null;
|
|
List<Long> assignees = startUserSelectAssignees != null ? startUserSelectAssignees.get(task.getId()) : null;
|
|
if (CollUtil.isEmpty(assignees)) {
|
|
if (CollUtil.isEmpty(assignees)) {
|
|
throw exception(PROCESS_INSTANCE_START_USER_SELECT_ASSIGNEES_NOT_CONFIG, task.getName());
|
|
throw exception(PROCESS_INSTANCE_START_USER_SELECT_ASSIGNEES_NOT_CONFIG, task.getName());
|
|
@@ -771,6 +867,16 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
BpmReasonEnum.REJECT_TASK.format(reason));
|
|
BpmReasonEnum.REJECT_TASK.format(reason));
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public void updateProcessInstanceVariables(String id, Map<String, Object> variables) {
|
|
|
|
+ runtimeService.setVariables(id, variables);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void removeProcessInstanceVariables(String id, Collection<String> variableNames) {
|
|
|
|
+ runtimeService.removeVariables(id, variableNames);
|
|
|
|
+ }
|
|
|
|
+
|
|
// ========== Event 事件相关方法 ==========
|
|
// ========== Event 事件相关方法 ==========
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -802,12 +908,47 @@ public class BpmProcessInstanceServiceImpl implements BpmProcessInstanceService
|
|
// 3. 发送流程实例的状态事件
|
|
// 3. 发送流程实例的状态事件
|
|
processInstanceEventPublisher.sendProcessInstanceResultEvent(
|
|
processInstanceEventPublisher.sendProcessInstanceResultEvent(
|
|
BpmProcessInstanceConvert.INSTANCE.buildProcessInstanceStatusEvent(this, instance, status));
|
|
BpmProcessInstanceConvert.INSTANCE.buildProcessInstanceStatusEvent(this, instance, status));
|
|
|
|
+
|
|
|
|
+ // 4. 流程后置通知
|
|
|
|
+ if (Objects.equals(status, BpmProcessInstanceStatusEnum.APPROVE.getStatus())) {
|
|
|
|
+ BpmProcessDefinitionInfoDO processDefinitionInfo = processDefinitionService.
|
|
|
|
+ getProcessDefinitionInfo(instance.getProcessDefinitionId());
|
|
|
|
+ if (ObjUtil.isNotNull(processDefinitionInfo) &&
|
|
|
|
+ ObjUtil.isNotNull(processDefinitionInfo.getPostProcessNotifySetting())) {
|
|
|
|
+ BpmModelMetaInfoVO.HttpRequestSetting setting = processDefinitionInfo.getPostProcessNotifySetting();
|
|
|
|
+
|
|
|
|
+ BpmHttpRequestUtils.executeBpmHttpRequest(instance,
|
|
|
|
+ setting.getUrl(),
|
|
|
|
+ setting.getHeader(),
|
|
|
|
+ setting.getBody(),
|
|
|
|
+ true, setting.getResponse(),
|
|
|
|
+ restTemplate,
|
|
|
|
+ this);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public void updateProcessInstanceVariables(String id, Map<String, Object> variables) {
|
|
|
|
- runtimeService.setVariables(id, variables);
|
|
|
|
|
|
+ public void processProcessInstanceCreated(ProcessInstance instance) {
|
|
|
|
+ // 注意:需要基于 instance 设置租户编号,避免 Flowable 内部异步时,丢失租户编号
|
|
|
|
+ FlowableUtils.execute(instance.getTenantId(), () -> {
|
|
|
|
+ // 流程前置通知
|
|
|
|
+ BpmProcessDefinitionInfoDO processDefinitionInfo = processDefinitionService.
|
|
|
|
+ getProcessDefinitionInfo(instance.getProcessDefinitionId());
|
|
|
|
+ // TODO @lesan:if return 哈。减少括号。
|
|
|
|
+ if (ObjUtil.isNotNull(processDefinitionInfo) &&
|
|
|
|
+ ObjUtil.isNotNull(processDefinitionInfo.getPreProcessNotifySetting())) {
|
|
|
|
+ BpmModelMetaInfoVO.HttpRequestSetting setting = processDefinitionInfo.getPreProcessNotifySetting();
|
|
|
|
+ BpmHttpRequestUtils.executeBpmHttpRequest(instance,
|
|
|
|
+ setting.getUrl(),
|
|
|
|
+ setting.getHeader(),
|
|
|
|
+ setting.getBody(),
|
|
|
|
+ true, setting.getResponse(),
|
|
|
|
+ restTemplate,
|
|
|
|
+ this);
|
|
|
|
+ }
|
|
|
|
+ });
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
}
|