修改:data文件信息查询,增加getSlaveInfo字段,控制可不查tag和标签信息,默认查询

This commit is contained in:
2026-03-27 14:45:47 +08:00
parent 4d22f187c5
commit 0700ac1a7c
3 changed files with 14 additions and 6 deletions

View File

@@ -14,4 +14,8 @@ public class GetFileBaseInfoReq {
@Schema(description = "节点UUID") @Schema(description = "节点UUID")
private String uuid; private String uuid;
@Schema(description = "是否查询tag或者文件标签信息,默认都查")
private boolean getSlaveInfo = true;
} }

View File

@@ -1062,13 +1062,15 @@ public class MinioFileIDataFileServiceImpl implements IDataFileService {
fileMetadataInfoResp.setApprovalStatus("approved"); fileMetadataInfoResp.setApprovalStatus("approved");
} }
} }
// 查询附属信息的默认是true去查询hpc工作流不用查
if(req.isGetSlaveInfo()){
log.info("getFileBaseInfo start:{}",JSONObject.toJSONString(req));
// 填充文件ta1-tag10的信息 // 填充文件ta1-tag10的信息
hierarchyHelper.setTagReqFromFileMetadata(fileMetadataInfo,fileMetadataInfoResp); hierarchyHelper.setTagReqFromFileMetadata(fileMetadataInfo,fileMetadataInfoResp);
// 填充文件类型标签信息 // 填充文件类型标签信息
fileDictTagQueryService.fillFileTagsForRespList(List.of(fileMetadataInfoResp), FileMetadataInfoResp::getId); fileDictTagQueryService.fillFileTagsForRespList(List.of(fileMetadataInfoResp), FileMetadataInfoResp::getId);
}
return SdmResponse.success(fileMetadataInfoResp); return SdmResponse.success(fileMetadataInfoResp);
} }

View File

@@ -265,6 +265,8 @@ public class HpcHandler implements ExecutionHandler<Map<String, Object>,HPCExecu
// 查data表 // 查data表
GetFileBaseInfoReq getFileBaseInfoReq = new GetFileBaseInfoReq(); GetFileBaseInfoReq getFileBaseInfoReq = new GetFileBaseInfoReq();
getFileBaseInfoReq.setFileId(outputDirId); getFileBaseInfoReq.setFileId(outputDirId);
// 不需要查询文件的标签信息
getFileBaseInfoReq.setGetSlaveInfo(false);
SdmResponse<FileMetadataInfoResp> fileBaseInfoResp = dataFeignClient.getFileBaseInfo(getFileBaseInfoReq); SdmResponse<FileMetadataInfoResp> fileBaseInfoResp = dataFeignClient.getFileBaseInfo(getFileBaseInfoReq);
if(!fileBaseInfoResp.isSuccess()||fileBaseInfoResp.getData()==null){ if(!fileBaseInfoResp.isSuccess()||fileBaseInfoResp.getData()==null){
CoreLogger.warn("getFileBaseInfo failed,outputDirId:{}",outputDirId); CoreLogger.warn("getFileBaseInfo failed,outputDirId:{}",outputDirId);