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

添加仿真流程模版库

Browse Source
This commit is contained in:
daiqy88
2025-11-13 08:45:16 +08:00
parent 09992e1887
commit 2faf3a0985
34 changed files with 791 additions and 515 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pbs/src/main/java/com/sdm/pbs/schedule/SyncPbsTaskResult.java
View File

@@ -60,7 +60,7 @@ public class SyncPbsTaskResult {
if (!locked) {
continue;
}
String jobNumber = flowNode.getCreator().toString();
String jobNumber = String.valueOf(flowNode.getCreator());
List<PbsTask> pbsTasks = pbsMapper.getPbsTaskByFlowNodeId(flowNodeId);
boolean isSyncFinish = true;
for (PbsTask pbsTask : pbsTasks) {

2
pbs/src/main/java/com/sdm/pbs/thread/ExecuteFLowNodeThread.java
View File

@@ -157,7 +157,7 @@ public class ExecuteFLowNodeThread implements Runnable {
if (uploadSuccess) {
PbsService pbsService = (PbsService) SpringUtils.getBean("pbsServiceImpl");
log.info("flowNode：{}开始提交计算:{}", flowNode.getId(), JSONObject.toJSONString(submitJobReq));
SdmResponse response = pbsService.submitJob(submitJobReq, flowNode.getCreator().toString());
SdmResponse response = pbsService.submitJob(submitJobReq, String.valueOf(flowNode.getCreator()));
if (isBatch) {
// 批量
if (response.getCode() == 200) {