|
|
|
@@ -209,21 +209,6 @@ public class NewDatasetServiceImpl implements NewDatasetService { |
|
|
|
dvcUtils.moveFiles(sourcePath, datasetPath); |
|
|
|
} |
|
|
|
|
|
|
|
if (!StringUtils.equals(datasetVo.getDatasetSource(), Constant.Source_Add)){ |
|
|
|
// 准备数据 |
|
|
|
DatasetTempStorage queryDatasetTempStorage = new DatasetTempStorage(); |
|
|
|
queryDatasetTempStorage.setName(repositoryName); |
|
|
|
queryDatasetTempStorage.setVersion(branchName); |
|
|
|
DatasetTempStorage datasetTempStorage = datasetTempStorageService.queryByDatasetTempStorage(queryDatasetTempStorage); |
|
|
|
if (datasetTempStorage != null){ |
|
|
|
String source = datasetTempStorage.getSource(); |
|
|
|
Map<String, Object> sourceMap = JacksonUtil.parseJSONStr2Map(source); |
|
|
|
Map<String, Object> preprocessCode = (Map<String, Object>) sourceMap.get("preprocess_code"); |
|
|
|
datasetVo.setProcessingCode(JacksonUtil.toJSONString(preprocessCode)); |
|
|
|
sourceMap.remove("preprocess_code"); |
|
|
|
datasetVo.setTrainTask(JacksonUtil.toJSONString(sourceMap)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
// 拼接生产的元数据后写入yaml文件 |
|
|
|
datasetVo.setCreateBy(String.valueOf(StringUtils.isNotEmpty((String) userInfo.get("nickname")) ? userInfo.get("nickname") : userInfo.get("login"))); |
|
|
|
@@ -520,12 +505,12 @@ public class NewDatasetServiceImpl implements NewDatasetService { |
|
|
|
queryDatasetTempStorage.setVersion(datasetVo.getVersion()); |
|
|
|
DatasetTempStorage datasetTempStorage = datasetTempStorageService.queryByDatasetTempStorage(queryDatasetTempStorage); |
|
|
|
if (datasetTempStorage != null) { |
|
|
|
String datasetSourceString = datasetTempStorage.getSource(); |
|
|
|
Map<String, Object> datasetSourceMap = JacksonUtil.parseJSONStr2Map(datasetSourceString); |
|
|
|
String preprocessCode = (String) datasetSourceMap.get("preprocess_code"); |
|
|
|
datasetSourceMap.remove("preprocess_code"); |
|
|
|
String source = datasetTempStorage.getSource(); |
|
|
|
Map<String, Object> sourceMap = JacksonUtil.parseJSONStr2Map(source); |
|
|
|
Map<String, Object> preprocessCode = (Map<String, Object>) sourceMap.get("preprocess_code"); |
|
|
|
datasetVo.setProcessingCode(preprocessCode); |
|
|
|
datasetVo.setDatasetSource(JacksonUtil.toJSONString(datasetSourceMap)); |
|
|
|
sourceMap.remove("preprocess_code"); |
|
|
|
datasetVo.setTrainTask(sourceMap); |
|
|
|
datasetTempStorage.setState(0); |
|
|
|
datasetTempStorageService.update(datasetTempStorage); |
|
|
|
} |
|
|
|
|