national_admin_functions #1
|
@ -29,6 +29,14 @@ public class OpenaireDuplicate implements Serializable {
|
||||||
@Column(name = "reltype")
|
@Column(name = "reltype")
|
||||||
private String relType;
|
private String relType;
|
||||||
|
|
||||||
|
public OpenaireDuplicate() {}
|
||||||
|
|
||||||
|
public OpenaireDuplicate(final String localId, final String oaOriginalId, final String relType) {
|
||||||
|
this.localId = localId;
|
||||||
|
this.oaOriginalId = oaOriginalId;
|
||||||
|
this.relType = relType;
|
||||||
|
}
|
||||||
|
|
||||||
public String getLocalId() {
|
public String getLocalId() {
|
||||||
return localId;
|
return localId;
|
||||||
}
|
}
|
||||||
|
|
|
@ -410,9 +410,10 @@ public class DatabaseUtils {
|
||||||
final List<OpenaireDuplicate> newDuplicates = ids.stream()
|
final List<OpenaireDuplicate> newDuplicates = ids.stream()
|
||||||
.map(openaireDuplicateRepository::findByLocalId)
|
.map(openaireDuplicateRepository::findByLocalId)
|
||||||
.flatMap(l -> l.stream())
|
.flatMap(l -> l.stream())
|
||||||
|
.filter(d -> d.getRelType().equals(SimilarityType.is_similar.toString()))
|
||||||
|
.map(d -> new OpenaireDuplicate(masterId, d.getOaOriginalId(), d.getRelType()))
|
||||||
.collect(Collectors.toList());
|
.collect(Collectors.toList());
|
||||||
newDuplicates.forEach(d -> d.setLocalId(masterId));
|
newDuplicates.forEach(d -> d.setLocalId(masterId));
|
||||||
saveDuplicates(newDuplicates, user);
|
|
||||||
|
|
||||||
final OffsetDateTime now = OffsetDateTime.now();
|
final OffsetDateTime now = OffsetDateTime.now();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue