From 518618f1a9b110a598cc9fdb44352cc215072195 Mon Sep 17 00:00:00 2001
From: Claudio Atzori <claudio.atzori@isti.cnr.it>
Date: Tue, 14 Mar 2023 15:22:47 +0100
Subject: [PATCH] [graph cleaning] avoid to overwrite the subject class to
 'keyword' for those with provenance 'subject:fos'

---
 .../java/eu/dnetlib/dhp/oa/graph/clean/CleaningRuleMap.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/clean/CleaningRuleMap.java b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/clean/CleaningRuleMap.java
index 3d501bb27..807055adb 100644
--- a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/clean/CleaningRuleMap.java
+++ b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/clean/CleaningRuleMap.java
@@ -9,6 +9,7 @@ import java.util.concurrent.atomic.AtomicReference;
 import org.apache.commons.lang3.SerializationUtils;
 import org.apache.commons.lang3.StringUtils;
 
+import eu.dnetlib.dhp.common.Constants;
 import eu.dnetlib.dhp.common.FunctionalInterfaceSupport.SerializableConsumer;
 import eu.dnetlib.dhp.common.vocabulary.VocabularyGroup;
 import eu.dnetlib.dhp.common.vocabulary.VocabularyTerm;
@@ -48,7 +49,9 @@ public class CleaningRuleMap extends HashMap<Class<?>, SerializableConsumer<Obje
 					subject.getQualifier().setClassid(vocabularyId);
 					subject.getQualifier().setClassname(vocabulary.getName());
 				}
-			} else if (vocabularyId.equals(subject.getQualifier().getClassid())) {
+			} else if (vocabularyId.equals(subject.getQualifier().getClassid()) &&
+				Objects.nonNull(subject.getDataInfo()) &&
+				!"subject:fos".equals(subject.getDataInfo().getProvenanceaction())) {
 				Qualifier syn = vocabulary.getSynonymAsQualifier(subject.getValue());
 				VocabularyTerm term = vocabulary.getTerm(subject.getValue());
 				if (Objects.isNull(syn) && Objects.isNull(term)) {