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

update - 处理 Map 深拷贝

Browse Source
This commit is contained in:
wangli 2023-12-07 11:51:22 +08:00
parent 274b6117f2
commit 4f3c815631
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -29,6 +29,7 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;
import static cn.axzo.workflow.common.constant.BpmnConstants.BIZ_ORG_RELATION;
import static cn.axzo.workflow.common.constant.BpmnConstants.COUNTERSIGN_ORIGIN_ASSIGNER;
@ -158,7 +159,8 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis
Map<String, Object> variables = new HashMap<>();
BpmnProcessInstanceVO processInstance = getBpmnProcessInstanceVO(event);
Map<String, Object> originVariables = new HashMap<>(processInstance.getVariables());
Map<String, Object> originVariables = processInstance.getVariables().entrySet().stream()
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
BpmnTaskDelegateAssigner initiator = (BpmnTaskDelegateAssigner) originVariables.getOrDefault(INTERNAL_INITIATOR,
new BpmnTaskDelegateAssigner());