wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - 移除流程变量源数据中的空 key 或空 value

Browse Source
This commit is contained in:
wangli 2023-12-07 19:18:40 +08:00
parent 575164d738
commit d3c23d72dd
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java
View File

@ -161,6 +161,7 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis
BpmnProcessInstanceVO processInstance = getBpmnProcessInstanceVO(event); BpmnProcessInstanceVO processInstance = getBpmnProcessInstanceVO(event);
Map<String, Object> originVariables = processInstance.getVariables().entrySet().stream() Map<String, Object> originVariables = processInstance.getVariables().entrySet().stream()
.filter(e -> Objects.nonNull(e.getKey()) && Objects.nonNull(e.getValue()))
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue)); .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
BpmnTaskDelegateAssigner initiator = (BpmnTaskDelegateAssigner) originVariables.getOrDefault(INTERNAL_INITIATOR, BpmnTaskDelegateAssigner initiator = (BpmnTaskDelegateAssigner) originVariables.getOrDefault(INTERNAL_INITIATOR,