diff --git a/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/elasticsearch/BulkUpload.java b/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/elasticsearch/BulkUpload.java index 508b1dc..be7d918 100644 --- a/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/elasticsearch/BulkUpload.java +++ b/dnet-ariadneplus-graphdb-publisher/src/main/java/eu/dnetlib/ariadneplus/elasticsearch/BulkUpload.java @@ -70,6 +70,15 @@ public class BulkUpload { uri.setLabel(ace.getTypeLabel()); ace.setHas_type(uri); + String uniqueIsPartOf = ace.getUniqueIsPartOf(); + if (uniqueIsPartOf != null) { + ace.setIsPartOf(Arrays.asList(uniqueIsPartOf)); + } + if (ace.getContributor() != null) { + ace.getContributor().clear(); + ace.setContributor(ace.getCreator()); + } + if (ace.getSpatial()!=null) { ace.getSpatial() .stream() @@ -162,17 +171,6 @@ public class BulkUpload { } } - if (!isCollection) { - String uniqueIsPartOf = ace.getUniqueIsPartOf(); - if (uniqueIsPartOf != null) { - ace.setIsPartOf(Arrays.asList(uniqueIsPartOf)); - } - if (ace.getContributor() != null) { - ace.getContributor().clear(); - ace.setContributor(ace.getCreator()); - } - } - String[] splits = ace.getIdentifier().split("/"); log.debug("JSON >>>> "+ace.toJson());