y01000846/spdm-backend-yangyang
1
0
Fork 0
forked from toolchaintechnologycenter/spdm-backend
Code Pull Requests Activity

数据总览作业模式展示算力

Browse Source
This commit is contained in:
gulongcheng
2026-01-12 16:17:57 +08:00
parent 29c598fa9a
commit 1b6c045435
10 changed files with 134 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
data/src/main/java/com/sdm/data/service/impl/DimensionTemplateServiceImpl.java
View File

@@ -13,6 +13,7 @@ import com.sdm.common.entity.req.data.DelDirReq;
import com.sdm.common.entity.req.data.DelFileReq;
import com.sdm.common.entity.req.data.UploadFilesReq;
import com.sdm.common.entity.req.project.DelNodeReq;
import com.sdm.common.entity.req.project.SpdmQueryRunListReq;
import com.sdm.common.entity.req.system.UserQueryReq;
import com.sdm.common.entity.resp.AllNodeByProjectIdAndTypeResp;
import com.sdm.common.entity.resp.PageDataResp;
@@ -393,15 +394,24 @@ public class DimensionTemplateServiceImpl extends ServiceImpl<DimensionTemplateM
// 需要处理左侧聚合展示的目录
List<Long> fileIds = req.getFileIds();
List<String> nodeUUids = fileMetadataInfoService.lambdaQuery().in(FileMetadataInfo::getId, fileIds).list().stream().map(FileMetadataInfo::getRelatedResourceUuid).toList();
List<FileMetadataInfo> nodeFileInfos = fileMetadataInfoService.lambdaQuery().in(FileMetadataInfo::getId, fileIds).list();
List<String> nodeUUids = nodeFileInfos.stream().map(FileMetadataInfo::getRelatedResourceUuid).toList();
log.info("作业模式下：根据文件 fileIds：{}，获取到对应的节点uuid:{}", fileIds, nodeUUids);
if(CollectionUtils.isEmpty(nodeUUids)) {
log.error("作业模式下，未查询到对应的nodeUUids");
return SdmResponse.success();
}
// 从李东洋接口，基于 nodeUUids 获取 算列的run的uuids
// List<String> runUuids = projectMapper.queryRunUuidsByNodeUUids(nodeUUids);
List<String> runUuids = new ArrayList<>();
String nodeType = nodeFileInfos.get(0).getRelatedResourceUuidOwnType();
// 基于 nodeUUids 获取 算列的run的uuids
SpdmQueryRunListReq spdmQueryRunListReq = new SpdmQueryRunListReq();
spdmQueryRunListReq.setNodeIdList(nodeUUids);
spdmQueryRunListReq.setNodeType(nodeType);
SdmResponse<List<String>> resp = simuluationNodeFeignClient.getRunListByNodeId(spdmQueryRunListReq);
if(!resp.isSuccess()){
log.info("作业模式下，未查询到对应算列的runUuids");
return SdmResponse.success();
}
List<String> runUuids = resp.getData();
if(CollectionUtils.isEmpty(runUuids)){
log.info("作业模式下，未查询到对应算列的runUuids");