antonis.lempesis
/
dnet-hadoop
forked from D-Net/dnet-hadoop
1
1
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

modified to consider the topic information

This commit is contained in:
Miriam Baglioni 2020-09-24 15:20:56 +02:00
parent 609ff17cfc
commit 15af1f527e
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/project/PrepareProjects.java
View File

@ -97,10 +97,26 @@ public class PrepareProjects {
if (csvProject.isPresent()) {
String[] programme = csvProject.get().getProgramme().split(";");
String topic = csvProject.get().getTopics();
String topicdescription = Optional
.ofNullable(csvProject.get().getTopics())
.map(topics -> {
if (topic.equalsIgnoreCase(value._1().getTopiccode())) {
return value._1().getTopicdescription();
}
return null;
})
.orElse(null);
Arrays
.stream(programme)
.forEach(p -> {
CSVProject proj = new CSVProject();
proj.setTopics(topic);
if (topicdescription != null) {
proj.setTopicdescription(topicdescription);
}
proj.setProgramme(p);
proj.setId(csvProject.get().getId());
csvProjectList.add(proj);