|
|
@@ -3,12 +3,10 @@ package com.ruoyi.platform.service.impl; |
|
|
import com.ruoyi.common.security.utils.SecurityUtils; |
|
|
import com.ruoyi.common.security.utils.SecurityUtils; |
|
|
import com.ruoyi.platform.domain.*; |
|
|
import com.ruoyi.platform.domain.*; |
|
|
import com.ruoyi.platform.mapper.ModelDependencyDao; |
|
|
import com.ruoyi.platform.mapper.ModelDependencyDao; |
|
|
import com.ruoyi.platform.service.ExperimentInsService; |
|
|
|
|
|
import com.ruoyi.platform.service.ExperimentService; |
|
|
|
|
|
import com.ruoyi.platform.service.ModelDependencyService; |
|
|
|
|
|
import com.ruoyi.platform.service.ModelsService; |
|
|
|
|
|
|
|
|
import com.ruoyi.platform.service.*; |
|
|
import com.ruoyi.platform.utils.JacksonUtil; |
|
|
import com.ruoyi.platform.utils.JacksonUtil; |
|
|
import com.ruoyi.platform.vo.ModelDependcyTreeVo; |
|
|
import com.ruoyi.platform.vo.ModelDependcyTreeVo; |
|
|
|
|
|
import com.ruoyi.platform.vo.ModelVersionDependcyVo; |
|
|
import com.ruoyi.system.api.model.LoginUser; |
|
|
import com.ruoyi.system.api.model.LoginUser; |
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
import org.springframework.context.annotation.Lazy; |
|
|
import org.springframework.context.annotation.Lazy; |
|
|
@@ -38,6 +36,8 @@ public class ModelDependencyServiceImpl implements ModelDependencyService { |
|
|
|
|
|
|
|
|
@Resource |
|
|
@Resource |
|
|
private ModelsService modelsService; |
|
|
private ModelsService modelsService; |
|
|
|
|
|
@Resource |
|
|
|
|
|
private ModelsVersionService modelsVersionService; |
|
|
@Lazy |
|
|
@Lazy |
|
|
@Resource |
|
|
@Resource |
|
|
private ExperimentService experimentService; |
|
|
private ExperimentService experimentService; |
|
|
@@ -77,21 +77,6 @@ public class ModelDependencyServiceImpl implements ModelDependencyService { |
|
|
@Override |
|
|
@Override |
|
|
public List<ModelDependency> queryByModelDependency(ModelDependency modelDependency) throws IOException { |
|
|
public List<ModelDependency> queryByModelDependency(ModelDependency modelDependency) throws IOException { |
|
|
List<ModelDependency> modelDependencyList = this.modelDependencyDao.queryByModelDependency(modelDependency); |
|
|
List<ModelDependency> modelDependencyList = this.modelDependencyDao.queryByModelDependency(modelDependency); |
|
|
/** |
|
|
|
|
|
* 补充workFlow_id + 是否共有 |
|
|
|
|
|
*/ |
|
|
|
|
|
if (modelDependencyList == null || modelDependencyList.size()==0){ |
|
|
|
|
|
return new ArrayList<>(); |
|
|
|
|
|
} |
|
|
|
|
|
for (ModelDependency md : modelDependencyList){ |
|
|
|
|
|
Integer currentModelId = md.getCurrentModelId(); |
|
|
|
|
|
Integer expInsId = md.getExpInsId(); |
|
|
|
|
|
Models models = modelsService.queryById(currentModelId); |
|
|
|
|
|
ExperimentIns experimentIns = experimentInsService.queryById(expInsId); |
|
|
|
|
|
Experiment experiment = experimentService.queryById(experimentIns.getExperimentId()); |
|
|
|
|
|
md.setWorkflowId(experiment.getWorkflowId()); |
|
|
|
|
|
md.setAvailableRange(models.getAvailableRange()); |
|
|
|
|
|
} |
|
|
|
|
|
return modelDependencyList; |
|
|
return modelDependencyList; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@@ -130,7 +115,6 @@ public class ModelDependencyServiceImpl implements ModelDependencyService { |
|
|
if (modelDependencyList!=null&&modelDependencyList.size()>=0){ |
|
|
if (modelDependencyList!=null&&modelDependencyList.size()>=0){ |
|
|
for (ModelDependency modelDependency:modelDependencyList){ |
|
|
for (ModelDependency modelDependency:modelDependencyList){ |
|
|
ModelDependcyTreeVo modelDependencyTreeVoIn = ModelDependencyConvertToTree(modelDependency); |
|
|
ModelDependcyTreeVo modelDependencyTreeVoIn = ModelDependencyConvertToTree(modelDependency); |
|
|
modelDependencyTreeVoIn.setCurrentModelName((String) parent.get("model_name")); |
|
|
|
|
|
processParentModel(modelDependencyTreeVoIn); |
|
|
processParentModel(modelDependencyTreeVoIn); |
|
|
ps.add(modelDependencyTreeVoIn); |
|
|
ps.add(modelDependencyTreeVoIn); |
|
|
} |
|
|
} |
|
|
@@ -142,7 +126,7 @@ public class ModelDependencyServiceImpl implements ModelDependencyService { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private void processChildrenModel(ModelDependcyTreeVo modelDependcyTreeVo){ |
|
|
|
|
|
|
|
|
private void processChildrenModel(ModelDependcyTreeVo modelDependcyTreeVo) throws IOException { |
|
|
String version = modelDependcyTreeVo.getVersion(); |
|
|
String version = modelDependcyTreeVo.getVersion(); |
|
|
Integer modelId = modelDependcyTreeVo.getCurrentModelId(); |
|
|
Integer modelId = modelDependcyTreeVo.getCurrentModelId(); |
|
|
List<ModelDependcyTreeVo> cs = new ArrayList<ModelDependcyTreeVo>(); |
|
|
List<ModelDependcyTreeVo> cs = new ArrayList<ModelDependcyTreeVo>(); |
|
|
@@ -159,7 +143,7 @@ public class ModelDependencyServiceImpl implements ModelDependencyService { |
|
|
modelDependcyTreeVo.setChildrenModels(cs); |
|
|
modelDependcyTreeVo.setChildrenModels(cs); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
private ModelDependcyTreeVo ModelDependencyConvertToTree(ModelDependency modelDependency){ |
|
|
|
|
|
|
|
|
private ModelDependcyTreeVo ModelDependencyConvertToTree(ModelDependency modelDependency) throws IOException { |
|
|
ModelDependcyTreeVo modelDependcyTreeVo = new ModelDependcyTreeVo(); |
|
|
ModelDependcyTreeVo modelDependcyTreeVo = new ModelDependcyTreeVo(); |
|
|
modelDependcyTreeVo.setCurrentModelId(modelDependency.getCurrentModelId()); |
|
|
modelDependcyTreeVo.setCurrentModelId(modelDependency.getCurrentModelId()); |
|
|
modelDependcyTreeVo.setExpInsId(modelDependency.getExpInsId()); |
|
|
modelDependcyTreeVo.setExpInsId(modelDependency.getExpInsId()); |
|
|
@@ -172,12 +156,33 @@ public class ModelDependencyServiceImpl implements ModelDependencyService { |
|
|
modelDependcyTreeVo.setTestDataset(JacksonUtil.parseJSONStr2MapList(modelDependency.getTestDataset())); |
|
|
modelDependcyTreeVo.setTestDataset(JacksonUtil.parseJSONStr2MapList(modelDependency.getTestDataset())); |
|
|
modelDependcyTreeVo.setProjectDependency(JacksonUtil.parseJSONStr2Map(modelDependency.getProjectDependency())); |
|
|
modelDependcyTreeVo.setProjectDependency(JacksonUtil.parseJSONStr2Map(modelDependency.getProjectDependency())); |
|
|
modelDependcyTreeVo.setParentModelsMap(JacksonUtil.parseJSONStr2MapList(modelDependency.getParentModels())); |
|
|
modelDependcyTreeVo.setParentModelsMap(JacksonUtil.parseJSONStr2MapList(modelDependency.getParentModels())); |
|
|
modelDependcyTreeVo.setWorkflowId(modelDependency.getWorkflowId()); |
|
|
|
|
|
modelDependcyTreeVo.setAvailableRange(modelDependcyTreeVo.getAvailableRange()); |
|
|
|
|
|
Models models = modelsService.queryById(modelDependency.getCurrentModelId()); |
|
|
|
|
|
if (models!=null) { |
|
|
|
|
|
modelDependcyTreeVo.setCurrentModelName(models.getName()); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* 补充workFlow_id + 是否共有 |
|
|
|
|
|
*/ |
|
|
|
|
|
Integer currentModelId = modelDependency.getCurrentModelId(); |
|
|
|
|
|
Integer expInsId = modelDependency.getExpInsId(); |
|
|
|
|
|
Models models = modelsService.queryById(currentModelId); |
|
|
|
|
|
ModelsVersion modelsVersionquery = new ModelsVersion(); |
|
|
|
|
|
modelsVersionquery.setModelsId(currentModelId); |
|
|
|
|
|
modelsVersionquery.setVersion(modelDependency.getVersion()); |
|
|
|
|
|
ModelsVersion modelsVersion = modelsVersionService.queryByModelsVersion(modelsVersionquery); |
|
|
|
|
|
ExperimentIns experimentIns = experimentInsService.queryById(expInsId); |
|
|
|
|
|
Experiment experiment = experimentService.queryById(experimentIns.getExperimentId()); |
|
|
|
|
|
ModelVersionDependcyVo modelVersionDependcyVo = new ModelVersionDependcyVo(); |
|
|
|
|
|
modelVersionDependcyVo.setName(models.getName()); |
|
|
|
|
|
modelVersionDependcyVo.setAvailableRange(models.getAvailableRange()); |
|
|
|
|
|
modelVersionDependcyVo.setDescription(models.getDescription()); |
|
|
|
|
|
modelVersionDependcyVo.setModelTag(models.getModelTag()); |
|
|
|
|
|
modelVersionDependcyVo.setModelType(models.getModelType()); |
|
|
|
|
|
modelVersionDependcyVo.setModelTagName(models.getModelTagName()); |
|
|
|
|
|
modelVersionDependcyVo.setModelTypeName(models.getModelTypeName()); |
|
|
|
|
|
modelVersionDependcyVo.setFileName(modelsVersion.getFileName()); |
|
|
|
|
|
modelVersionDependcyVo.setFileSize(modelsVersion.getFileSize()); |
|
|
|
|
|
modelVersionDependcyVo.setUrl(modelsVersion.getUrl()); |
|
|
|
|
|
modelDependcyTreeVo.setWorkflowId(experiment.getWorkflowId()); |
|
|
|
|
|
modelDependcyTreeVo.setModelVersionDependcyVo(modelVersionDependcyVo); |
|
|
|
|
|
|
|
|
return modelDependcyTreeVo; |
|
|
return modelDependcyTreeVo; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|