fix: 解决审批节点表单无可编辑字段时,variables流程变量值为空,流程节点流转异常问题
This commit is contained in:
parent
149cab1dac
commit
575e7a38f3
|
@ -907,17 +907,9 @@ public class BpmnModelUtils {
|
||||||
* @return 符合条件的路径
|
* @return 符合条件的路径
|
||||||
*/
|
*/
|
||||||
private static SequenceFlow findMatchSequenceFlowByExclusiveGateway(Gateway gateway, Map<String, Object> variables) {
|
private static SequenceFlow findMatchSequenceFlowByExclusiveGateway(Gateway gateway, Map<String, Object> variables) {
|
||||||
// TODO 表单无可编辑字段时variables为空,流程走向会出现问题,比如流程审批过程中无需要修改的字段值,
|
SequenceFlow matchSequenceFlow = CollUtil.findOne(gateway.getOutgoingFlows(),
|
||||||
// TODO @小北:是不是还是保证,编辑的时候,如果计算下一个节点,还是 variables 是完整体?而不是空的!!!(可以微信讨论下)
|
|
||||||
SequenceFlow matchSequenceFlow;
|
|
||||||
if (CollUtil.isNotEmpty(variables)) {
|
|
||||||
matchSequenceFlow = CollUtil.findOne(gateway.getOutgoingFlows(),
|
|
||||||
flow -> ObjUtil.notEqual(gateway.getDefaultFlow(), flow.getId())
|
flow -> ObjUtil.notEqual(gateway.getDefaultFlow(), flow.getId())
|
||||||
&& (evalConditionExpress(variables, flow.getConditionExpression())));
|
&& (evalConditionExpress(variables, flow.getConditionExpression())));
|
||||||
} else {
|
|
||||||
matchSequenceFlow = CollUtil.findOne(gateway.getOutgoingFlows(),
|
|
||||||
flow -> ObjUtil.notEqual(gateway.getDefaultFlow(), flow.getId()));
|
|
||||||
}
|
|
||||||
if (matchSequenceFlow == null) {
|
if (matchSequenceFlow == null) {
|
||||||
matchSequenceFlow = CollUtil.findOne(gateway.getOutgoingFlows(),
|
matchSequenceFlow = CollUtil.findOne(gateway.getOutgoingFlows(),
|
||||||
flow -> ObjUtil.equal(gateway.getDefaultFlow(), flow.getId()));
|
flow -> ObjUtil.equal(gateway.getDefaultFlow(), flow.getId()));
|
||||||
|
|
|
@ -557,11 +557,24 @@ public class BpmTaskServiceImpl implements BpmTaskService {
|
||||||
// 2.2 添加评论
|
// 2.2 添加评论
|
||||||
taskService.addComment(task.getId(), task.getProcessInstanceId(), BpmCommentTypeEnum.APPROVE.getType(),
|
taskService.addComment(task.getId(), task.getProcessInstanceId(), BpmCommentTypeEnum.APPROVE.getType(),
|
||||||
BpmCommentTypeEnum.APPROVE.formatComment(reqVO.getReason()));
|
BpmCommentTypeEnum.APPROVE.formatComment(reqVO.getReason()));
|
||||||
// 2.3 校验并处理 APPROVE_USER_SELECT 当前审批人,选择下一节点审批人的逻辑
|
// 如果流程变量前端传空,需要从历史实例中获取,原因:前端表单如果在当前节点无可编辑的字段时variables一定会为空
|
||||||
Map<String, Object> variables = validateAndSetNextAssignees(task.getTaskDefinitionKey(), reqVO.getVariables(),
|
// 场景一:A节点发起,B节点表单无可编辑字段,审批通过时,C节点需要流程变量获取下一个执行节点,但因为B节点无可编辑的字段,variables为空,流程可能出现问题
|
||||||
|
// 场景二:A节点发起,B节点只有某一个字段可编辑(比如day),但C节点需要多个节点(比如workday,在发起时填写,因为B节点只有day的编辑权限,在审批后。variables会缺少work的值)
|
||||||
|
// 3.1 设置流程变量
|
||||||
|
Map<String, Object> processVariables = new HashMap<>();
|
||||||
|
// 3.2 获取历史中流程变量
|
||||||
|
if (CollUtil.isNotEmpty(instance.getProcessVariables())) {
|
||||||
|
processVariables.putAll(instance.getProcessVariables());
|
||||||
|
}
|
||||||
|
// 3.3 合并前端传递的流程变量,以前端为准
|
||||||
|
if (CollUtil.isNotEmpty(reqVO.getVariables())) {
|
||||||
|
processVariables.putAll(reqVO.getVariables());
|
||||||
|
}
|
||||||
|
// 3.4 校验并处理 APPROVE_USER_SELECT 当前审批人,选择下一节点审批人的逻辑
|
||||||
|
Map<String, Object> variables = validateAndSetNextAssignees(task.getTaskDefinitionKey(), processVariables,
|
||||||
bpmnModel, reqVO.getNextAssignees(), instance);
|
bpmnModel, reqVO.getNextAssignees(), instance);
|
||||||
runtimeService.setVariables(task.getProcessInstanceId(), variables);
|
runtimeService.setVariables(task.getProcessInstanceId(), variables);
|
||||||
// 2.4 调用 BPM complete 去完成任务
|
// 4 调用 BPM complete 去完成任务
|
||||||
taskService.complete(task.getId(), variables, true);
|
taskService.complete(task.getId(), variables, true);
|
||||||
|
|
||||||
// 【加签专属】处理加签任务
|
// 【加签专属】处理加签任务
|
||||||
|
@ -600,9 +613,7 @@ public class BpmTaskServiceImpl implements BpmTaskService {
|
||||||
}
|
}
|
||||||
processVariables = FlowableUtils.getStartUserSelectAssignees(processInstance.getProcessVariables());
|
processVariables = FlowableUtils.getStartUserSelectAssignees(processInstance.getProcessVariables());
|
||||||
// 特殊:如果当前节点已经存在审批人,则不允许覆盖
|
// 特殊:如果当前节点已经存在审批人,则不允许覆盖
|
||||||
// TODO @小北:【不用改】通过 if return,让逻辑更简洁一点;虽然会多判断一次 processVariables,但是 if else 层级更少。
|
if (processVariables != null && CollUtil.isNotEmpty(processVariables.get(nextFlowNode.getId()))) {
|
||||||
if (processVariables != null
|
|
||||||
&& CollUtil.isNotEmpty(processVariables.get(nextFlowNode.getId()))) {
|
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
// 设置 PROCESS_INSTANCE_VARIABLE_START_USER_SELECT_ASSIGNEES
|
// 设置 PROCESS_INSTANCE_VARIABLE_START_USER_SELECT_ASSIGNEES
|
||||||
|
@ -622,13 +633,6 @@ public class BpmTaskServiceImpl implements BpmTaskService {
|
||||||
processVariables = FlowableUtils.getApproveUserSelectAssignees(processInstance.getProcessVariables());
|
processVariables = FlowableUtils.getApproveUserSelectAssignees(processInstance.getProcessVariables());
|
||||||
if (processVariables == null) {
|
if (processVariables == null) {
|
||||||
processVariables = new HashMap<>();
|
processVariables = new HashMap<>();
|
||||||
} else {
|
|
||||||
List<Long> approveUserSelectAssignee = processVariables.get(nextFlowNode.getId());
|
|
||||||
// 特殊:如果当前节点已经存在审批人,则不允许覆盖
|
|
||||||
// TODO @小北:这种,应该可以覆盖呢。
|
|
||||||
if (CollUtil.isNotEmpty(approveUserSelectAssignee)) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
// 设置 PROCESS_INSTANCE_VARIABLE_APPROVE_USER_SELECT_ASSIGNEES
|
// 设置 PROCESS_INSTANCE_VARIABLE_APPROVE_USER_SELECT_ASSIGNEES
|
||||||
processVariables.put(nextFlowNode.getId(), assignees);
|
processVariables.put(nextFlowNode.getId(), assignees);
|
||||||
|
|
Loading…
Reference in New Issue