|
@ -9,6 +9,7 @@ import com.yihu.ehr.crawler.model.flow.CrawlerDataSetModel;
|
|
|
import com.yihu.ehr.crawler.model.flow.CrawlerFlowHeadModel;
|
|
|
import com.yihu.ehr.crawler.model.flow.CrawlerFlowModel;
|
|
|
import com.yihu.ehr.crawler.model.flow.resultModel.*;
|
|
|
import com.yihu.ehr.datacollect.model.DtoJobDataset;
|
|
|
import com.yihu.ehr.framework.constrant.Constants;
|
|
|
import com.yihu.ehr.framework.model.ActionResult;
|
|
|
import com.yihu.ehr.framework.model.DetailModelResult;
|
|
@ -17,6 +18,7 @@ import com.yihu.ehr.standard.model.adapter.AdapterDatasetModel;
|
|
|
import com.yihu.ehr.standard.model.adapter.AdapterMetadataModel;
|
|
|
import com.yihu.ehr.standard.model.adapter.AdapterSchemeVersionModel;
|
|
|
import com.yihu.ehr.standard.model.adapter.resultModel.AdapterSchemeResultModel;
|
|
|
import com.yihu.ehr.standard.model.adapter.resultModel.AdapterSchemeVersionResultDetailModel;
|
|
|
import com.yihu.ehr.standard.service.adapter.AdapterDatasetService;
|
|
|
import com.yihu.ehr.standard.service.adapter.AdapterMetadataService;
|
|
|
import com.yihu.ehr.standard.service.adapter.AdapterSchemeService;
|
|
@ -422,10 +424,34 @@ public class CrawlerService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public DetailModelResult getDataSetSavedResult() {
|
|
|
DetailModelResult checkedSchemeLs = getDataSetResult(null, null);
|
|
|
List<Map<String, Object>> list = checkedSchemeLs.getDetailModelList();
|
|
|
return null;
|
|
|
public DetailModelResult getDataSetSavedResult(Integer version) {
|
|
|
try {
|
|
|
DetailModelResult checkedSchemeLs = getDataSetResult(null, null);
|
|
|
List<Map<String, Object>> list = checkedSchemeLs.getDetailModelList();
|
|
|
for (Map<String, Object> objectMap : list) {
|
|
|
String versionID = objectMap.get("scheme_version_id").toString();
|
|
|
if (versionID.equals(version.toString())) {
|
|
|
String datasetIdStr = objectMap.get("dataSetId").toString();
|
|
|
|
|
|
List<MappingDataset> datasetList = getSchemeDatasetByChecked(version, datasetIdStr);
|
|
|
List<DtoJobDataset> rsJobDatasetList = new ArrayList<>();
|
|
|
for (MappingDataset dataset : datasetList) {
|
|
|
DtoJobDataset rsJobDataset = new DtoJobDataset();
|
|
|
rsJobDataset.setJobDatasetId(dataset.getId().toString());
|
|
|
rsJobDataset.setJobDatasetName(dataset.getName());
|
|
|
rsJobDataset.setJobDatasetCode(dataset.getCode());
|
|
|
rsJobDatasetList.add(rsJobDataset);
|
|
|
}
|
|
|
DetailModelResult result = new DetailModelResult();
|
|
|
result.setDetailModelList(rsJobDatasetList);
|
|
|
return result;
|
|
|
}
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return DetailModelResult.error("获取已存任务编排数据集错误");
|
|
|
}
|
|
|
return DetailModelResult.error("获取已存任务编排数据集错误");
|
|
|
|
|
|
}
|
|
|
|
|
@ -438,7 +464,7 @@ public class CrawlerService {
|
|
|
Set<String> schemeIdSets = new HashSet<>();
|
|
|
Set<String> versionSets = new HashSet<>();
|
|
|
DetailModelResult result = new DetailModelResult();
|
|
|
List<AdapterSchemeVersionModel> versionModelList = new ArrayList<>();
|
|
|
List<AdapterSchemeVersionResultDetailModel> versionModelList = new ArrayList<>();
|
|
|
if (list != null && list.size() > 0) {
|
|
|
for (Map<String, Object> objectMap : list) {
|
|
|
if (objectMap.get("scheme_id") != null && objectMap.get("scheme_version_id") != null) {
|
|
@ -451,11 +477,23 @@ public class CrawlerService {
|
|
|
for (AdapterSchemeResultModel schemeL : allSchemeLs) {
|
|
|
String schemeID = schemeL.getSchemeId().toString();
|
|
|
if (schemeIdSets.contains(schemeID)) {
|
|
|
String name = schemeL.getName();
|
|
|
List<AdapterSchemeVersionModel> versionModels = schemeL.getVersionList();
|
|
|
for (AdapterSchemeVersionModel versionModel : versionModels) {
|
|
|
String versionID = versionModel.getId().toString();
|
|
|
if (versionSets.contains(versionID)) {
|
|
|
versionModelList.add(versionModel);
|
|
|
AdapterSchemeVersionResultDetailModel model = new AdapterSchemeVersionResultDetailModel();
|
|
|
model.setSchemeName(name);
|
|
|
model.setId(versionModel.getId());
|
|
|
model.setName(versionModel.getName());
|
|
|
model.setSchemeId(versionModel.getSchemeId());
|
|
|
model.setBaseVersion(versionModel.getBaseVersion());
|
|
|
model.setPath(versionModel.getPath());
|
|
|
model.setPublishStatus(versionModel.getPublishStatus());
|
|
|
model.setPublishTime(versionModel.getPublishTime());
|
|
|
model.setPublishUser(versionModel.getPublishUser());
|
|
|
model.setVersion(versionModel.getVersion());
|
|
|
versionModelList.add(model);
|
|
|
}
|
|
|
}
|
|
|
}
|