fix:算例输入输出节点建立磁盘目录

This commit is contained in:
2026-04-16 15:46:30 +08:00
parent 911f2b9ef7
commit be2c74fbcd

View File

@@ -52,10 +52,7 @@ import com.sdm.common.feign.impl.system.SysUserFeignClientImpl;
import com.sdm.common.feign.inter.system.IWsPushToolFeignClient;
import com.sdm.common.service.DataFileService;
import com.sdm.common.service.FileBizTypeService;
import com.sdm.common.utils.CommonUtils;
import com.sdm.common.utils.DateUtils;
import com.sdm.common.utils.PageUtils;
import com.sdm.common.utils.RandomUtil;
import com.sdm.common.utils.*;
import com.sdm.project.common.*;
import com.sdm.project.dao.*;
import com.sdm.project.model.bo.ApprovalDeliverableContentsModel;
@@ -977,6 +974,9 @@ public class SimulationRunServiceImpl extends ServiceImpl<SimulationRunMapper, S
SdmResponse outputDir = createDir(null, flowNodeDto.getUuid(), "数据输出", DirTypeEnum.PROJECT_NODE_DIR.getValue(), null);
flowNodeDto.setInputDirId(Long.parseLong(inputDir.getData().toString()));
flowNodeDto.setOutputDirId(Long.parseLong(outputDir.getData().toString()));
// 输入输出节点建立磁盘目录
createDiskDir(flowNodeDto.getInputDirId());
createDiskDir(flowNodeDto.getOutputDirId());
}
FlowNodeDto addReq = new FlowNodeDto();
addReq.setFlowNodeDtoList(flowNodeDtoList);
@@ -1022,6 +1022,15 @@ public class SimulationRunServiceImpl extends ServiceImpl<SimulationRunMapper, S
}
}
private void createDiskDir(Long fileId) {
GetFileBaseInfoReq getFileBaseInfoReq = new GetFileBaseInfoReq();
getFileBaseInfoReq.setFileId(fileId);
SdmResponse<FileMetadataInfoResp> fileBaseInfoResp = dataFeignClient.getFileBaseInfo(getFileBaseInfoReq);
if (fileBaseInfoResp.getData() != null) {
FilesUtil.createRunLocalDir(fileBaseInfoResp.getData().getObjectKey());
}
}
private SdmResponse createDir(String uuid, String parentUuid, String dirName, Integer dirType, String uuidOwnType) {
CreateDirReq createDirReq = new CreateDirReq();
createDirReq.setUuId(uuid);