toolchaintechnologycenter/spdm-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改：手动提交任务，节点判断信息优化

Browse Source
This commit is contained in:
yangyang01000846
2026-01-20 16:56:17 +08:00
parent 7c5567ccf7
commit 990eb0a47a
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
flowable/src/main/java/com/sdm/flowable/delegate/handler/HpcHandler.java
View File

@@ -166,9 +166,17 @@ public class HpcHandler implements ExecutionHandler<Map<String, Object>,HPCExecu
.collect(Collectors.groupingBy(ProcessNodeParam::getNodeId));
List<ProcessNodeParam> beforeNodeParams = nodeParamMap.get(beforeNodeId);
List<ProcessNodeParam> currentNodeParams = nodeParamMap.get(currentNodeId);
if(CollectionUtils.isEmpty(beforeNodeParams) || CollectionUtils.isEmpty(currentNodeParams)){
throw new RuntimeException("未获取到当前节点或者求解文件节点信息");
if(Objects.equals(executeMode,FlowableConfig.EXECUTE_MODE_AUTO)){
if(CollectionUtils.isEmpty(beforeNodeParams) || CollectionUtils.isEmpty(currentNodeParams)){
throw new RuntimeException("未获取到当前节点或者求解文件节点信息");
}
}
if(Objects.equals(executeMode,FlowableConfig.EXECUTE_MODE_MANUAL)){
if(CollectionUtils.isEmpty(currentNodeParams)){
throw new RuntimeException("未获取到当前节点信息");
}
}
// 自动,前一个节点
submitHpcTaskRemoteReq.setExecuteMode(executeMode);
if(Objects.equals(executeMode,FlowableConfig.EXECUTE_MODE_AUTO)){