Browse Source

Merge remote-tracking branch 'origin/dev' into dev

dev-lhz
chenzhihang 1 year ago
parent
commit
5f8d6c3f24
1 changed files with 13 additions and 7 deletions
  1. +13
    -7
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentServiceImpl.java

+ 13
- 7
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentServiceImpl.java View File

@@ -470,20 +470,26 @@ public class ExperimentServiceImpl implements ExperimentService {
String sourceTaskId = (String) source.get("task_id"); String sourceTaskId = (String) source.get("task_id");
Map<String, Object> datasetPreprocessMap = (Map<String, Object>) datasetPreprocess.get(sourceTaskId); Map<String, Object> datasetPreprocessMap = (Map<String, Object>) datasetPreprocess.get(sourceTaskId);
//处理project数据 //处理project数据
Map<String, Object> projectMap = (Map<String, Object>) datasetPreprocessMap.get("project");
Map<String, Object> datasets = (Map<String, Object>) datasetPreprocessMap.get("datasets");
datasetTempStorage.setName((String) datasets.get("dataset_identifier"));
datasetTempStorage.setVersion((String) datasets.get("dataset_version"));
// 拼接需要的参数 // 拼接需要的参数
Map<String, Object> projectMap = (Map<String, Object>) datasetPreprocessMap.get("project");
Map<String, Object> sourceParams = new HashMap<>(); Map<String, Object> sourceParams = new HashMap<>();
sourceParams.put("experiment_name", experimentName); sourceParams.put("experiment_name", experimentName);
sourceParams.put("experiment_ins_id", experimentInsId); sourceParams.put("experiment_ins_id", experimentInsId);
sourceParams.put("experiment_id", experimentId); sourceParams.put("experiment_id", experimentId);
sourceParams.put("train_name", sourceTaskId); sourceParams.put("train_name", sourceTaskId);
sourceParams.put("preprocess_code", projectMap); sourceParams.put("preprocess_code", projectMap);
datasetTempStorage.setSource(JacksonUtil.toJSONString(sourceParams));
datasetTempStorage.setState(1);
datasetTempStorageService.insert(datasetTempStorage);
List<Map> datasets = (List<Map>) datasetPreprocessMap.get("datasets");
if (datasets != null) {
for (Map<String, Object> dataset : datasets) {
datasetTempStorage.setName((String) dataset.get("dataset_identifier"));
datasetTempStorage.setVersion((String) dataset.get("dataset_version"));
datasetTempStorage.setSource(JacksonUtil.toJSONString(sourceParams));
datasetTempStorage.setState(1);
datasetTempStorageService.insert(datasetTempStorage);
}
}


} }


} }


Loading…
Cancel
Save