2018-06-27 12:29:21 +02:00
|
|
|
package eu.eudat.logic.managers;
|
2018-02-07 10:56:30 +01:00
|
|
|
|
2018-06-27 12:29:21 +02:00
|
|
|
import eu.eudat.logic.builders.model.models.ResearcherBuilder;
|
2018-03-21 11:57:56 +01:00
|
|
|
import eu.eudat.data.entities.Researcher;
|
2019-10-03 13:06:44 +02:00
|
|
|
import eu.eudat.logic.proxy.config.ExternalUrlCriteria;
|
2018-06-27 12:29:21 +02:00
|
|
|
import eu.eudat.models.data.external.ExternalSourcesItemModel;
|
|
|
|
import eu.eudat.models.data.external.ResearchersExternalSourcesModel;
|
2018-03-21 13:11:02 +01:00
|
|
|
import eu.eudat.data.query.items.item.researcher.ResearcherCriteriaRequest;
|
2018-06-27 12:29:21 +02:00
|
|
|
import eu.eudat.logic.proxy.config.exceptions.HugeResultSet;
|
|
|
|
import eu.eudat.logic.proxy.config.exceptions.NoURLFound;
|
|
|
|
import eu.eudat.logic.proxy.fetching.RemoteFetcher;
|
2019-09-30 16:42:01 +02:00
|
|
|
import eu.eudat.models.data.security.Principal;
|
2018-03-08 11:54:56 +01:00
|
|
|
import eu.eudat.queryable.QueryableList;
|
2018-06-27 12:29:21 +02:00
|
|
|
import eu.eudat.logic.services.ApiContext;
|
2019-03-05 16:33:59 +01:00
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
2019-02-01 17:56:55 +01:00
|
|
|
import org.springframework.stereotype.Component;
|
2018-02-07 10:56:30 +01:00
|
|
|
|
2018-03-08 11:54:56 +01:00
|
|
|
import java.util.List;
|
|
|
|
import java.util.Map;
|
2019-09-30 16:42:01 +02:00
|
|
|
import java.util.UUID;
|
2019-02-15 12:03:59 +01:00
|
|
|
import java.util.stream.Collectors;
|
2018-03-08 11:54:56 +01:00
|
|
|
|
2018-02-07 10:56:30 +01:00
|
|
|
/**
|
|
|
|
* Created by ikalyvas on 2/5/2018.
|
|
|
|
*/
|
2019-02-01 17:56:55 +01:00
|
|
|
@Component
|
2018-02-07 10:56:30 +01:00
|
|
|
public class ResearcherManager {
|
|
|
|
|
2019-03-05 16:33:59 +01:00
|
|
|
private ApiContext apiContext;
|
|
|
|
private RemoteFetcher remoteFetcher;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
public ResearcherManager(ApiContext apiContext) {
|
|
|
|
this.apiContext = apiContext;
|
|
|
|
this.remoteFetcher = apiContext.getOperationsContext().getRemoteFetcher();
|
|
|
|
}
|
|
|
|
|
2019-09-30 16:42:01 +02:00
|
|
|
public Researcher create(eu.eudat.models.data.researcher.Researcher researcher, Principal principal) throws Exception {
|
2018-02-16 08:45:18 +01:00
|
|
|
Researcher researcherEntity = researcher.toDataModel();
|
2019-09-30 16:42:01 +02:00
|
|
|
researcherEntity.setCreationUser(apiContext.getOperationsContext().getDatabaseRepository().getUserInfoDao().find(principal.getId()));
|
2018-03-05 17:18:45 +01:00
|
|
|
return apiContext.getOperationsContext().getDatabaseRepository().getResearcherDao().createOrUpdate(researcherEntity);
|
2018-02-07 10:56:30 +01:00
|
|
|
}
|
2018-03-08 11:54:56 +01:00
|
|
|
|
2019-09-30 16:42:01 +02:00
|
|
|
public List<eu.eudat.models.data.dmp.Researcher> getCriteriaWithExternal(ResearcherCriteriaRequest researcherCriteriaRequest, Principal principal) throws HugeResultSet, NoURLFound {
|
2018-03-08 11:54:56 +01:00
|
|
|
|
2018-03-21 11:57:56 +01:00
|
|
|
QueryableList<eu.eudat.data.entities.Researcher> items = apiContext.getOperationsContext().getDatabaseRepository().getResearcherDao().getWithCriteria(researcherCriteriaRequest.getCriteria());
|
2019-09-30 16:42:01 +02:00
|
|
|
items.where((builder, root) -> builder.equal(root.get("creationUser").get("id"), principal.getId()));
|
2018-06-27 12:29:21 +02:00
|
|
|
List<eu.eudat.models.data.dmp.Researcher> researchers = items.select(item -> new eu.eudat.models.data.dmp.Researcher().fromDataModel(item));
|
2019-10-03 13:06:44 +02:00
|
|
|
ExternalUrlCriteria externalUrlCriteria = new ExternalUrlCriteria(researcherCriteriaRequest.getCriteria().getName());
|
|
|
|
List<Map<String, String>> remoteRepos = remoteFetcher.getResearchers(externalUrlCriteria,null);
|
2018-03-08 11:54:56 +01:00
|
|
|
ResearchersExternalSourcesModel researchersExternalSourcesModel = new ResearchersExternalSourcesModel().fromExternalItem(remoteRepos);
|
|
|
|
for (ExternalSourcesItemModel externalListingItem : researchersExternalSourcesModel) {
|
2018-06-27 12:29:21 +02:00
|
|
|
eu.eudat.models.data.dmp.Researcher researcher = apiContext.getOperationsContext().getBuilderFactory().getBuilder(ResearcherBuilder.class)
|
2019-02-11 14:46:29 +01:00
|
|
|
.label(externalListingItem.getAbbreviation())
|
|
|
|
.id(externalListingItem.getId())
|
2018-03-08 11:54:56 +01:00
|
|
|
.name(externalListingItem.getName())
|
2019-07-29 11:04:19 +02:00
|
|
|
.tag(externalListingItem.getTag())
|
2018-03-08 11:54:56 +01:00
|
|
|
.build();
|
|
|
|
researchers.add(researcher);
|
|
|
|
}
|
2019-02-15 12:03:59 +01:00
|
|
|
return researchers.stream().distinct().collect(Collectors.toList());
|
2018-03-08 11:54:56 +01:00
|
|
|
}
|
2018-02-07 10:56:30 +01:00
|
|
|
}
|