fix[project]: 修改syncTodoPhaseForMes方法

This commit is contained in:
2026-03-18 20:13:36 +08:00
parent 41870d4121
commit 9bd917fca5

View File

@@ -3671,7 +3671,7 @@ public class LyricInternalServiceImpl implements ILyricInternalService {
}
private void syncTodoPhaseForMes(String curDateStr, Long projectId, String currentPhase, String projectNodeId, SpdmAddDemandReq req, String machineNum, String stationNum) {
private void syncTodoPhaseForMes(String curDateStr, Long projectId, String currentPhase, String projectNodeId, SpdmAddDemandReq req, String machineNum, String stationNum,SimulationNode projectNode) {
Long tenantId = req.getTenantId();
Long jobNumber = req.getCreator();
List<SpdmProjectNodeEditReq> currentNodeList;
@@ -3835,7 +3835,14 @@ public class LyricInternalServiceImpl implements ILyricInternalService {
}
// 批量创建文件夹
batchCreateNodeDir(addNodeList);
SpdmProjectNodeEditReq spdmProjectNodeEditReq = new SpdmProjectNodeEditReq();
BeanUtils.copyProperties(projectNode, spdmProjectNodeEditReq);
NodeServiceImpl.NodeTypeFilterResult filterResult = new NodeServiceImpl.NodeTypeFilterResult(spdmProjectNodeEditReq
, addNodeList.stream().filter(node -> NodeTypeEnum.PHASE.getValue().equals(node.getNodeType())).collect(Collectors.toList())
, addNodeList.stream().filter(node -> NodeTypeEnum.MACHINE.getValue().equals(node.getNodeType())).collect(Collectors.toList())
, addNodeList.stream().filter(node -> NodeTypeEnum.WORKSPACE.getValue().equals(node.getNodeType())).collect(Collectors.toList()));
BatchCreateDirReq batchCreateDirReq = buildBatchCreateDirReq(filterResult);
callBatchCreateDirApi(batchCreateDirReq);
}
@@ -3939,7 +3946,7 @@ public class LyricInternalServiceImpl implements ILyricInternalService {
if (ObjectUtils.isEmpty(phaseNode)) {
// 同步当前阶段
syncTodoPhaseForMes(curDateStr, Long.valueOf(projectNode.getProjectId()), currenPhase, projectNode.getUuid(), req,
machineNum, stationNum);
machineNum, stationNum, projectNode);
}
}