original id and AAT enrichment for RGK - DAI

dnet-ariadneplus-graphdb-publisher/src/main/resources/eu/dnetlib/ariadneplus/sparql/enrich/DAI/ordered_sparql_insert_afe_rgk.sparql

@@ -149,6 +149,20 @@ WHERE {
         }
 };
 
+PREFIX aocat: <https://www.ariadne-infrastructure.eu/resource/ao/cat/1.1/>
+INSERT {
+    GRAPH <https://ariadne-infrastructure.eu/api_________::ariadne_plus::afe_rgk::coins> {
+        ?record	aocat:has_original_id ?pid .
+    }
+}
+USING <https://ariadne-infrastructure.eu/api_________::ariadne_plus::afe_rgk::coins>
+WHERE {
+	?record aocat:has_landing_page ?pid .
+	MINUS {
+            ?record	aocat:has_original_id ?id .
+        }
+};
+
 PREFIX aocat: <https://www.ariadne-infrastructure.eu/resource/ao/cat/1.1/>
 PREFIX skos: <http://www.w3.org/2004/02/skos/core#>
 PREFIX ariadneplus: <https://ariadne-infrastructure.eu/aocat/>
@@ -206,4 +220,43 @@ PREFIX  skos: <http://www.w3.org/2004/02/skos/core#>
         ?temporal aocat:from ?from .
         ?temporal aocat:until ?until .
     }
-  };
+  };
+
+   PREFIX aocat: <https://www.ariadne-infrastructure.eu/resource/ao/cat/1.1/>
+   PREFIX skos: <http://www.w3.org/2004/02/skos/core#>
+
+   INSERT {
+    GRAPH <https://ariadne-infrastructure.eu/ariadneplus::afe_rgk::aatplus> {
+        ?record aocat:has_derived_subject ?aat_subject .
+    }
+   }
+  USING <https://ariadne-infrastructure.eu/api_________::ariadne_plus::afe_rgk::aat>
+  USING <https://ariadne-infrastructure.eu/api_________::ariadne_plus::afe_rgk::coins>
+   WHERE {
+        {
+            ?record aocat:has_native_subject ?native_subject .
+            bind (IRI(concat( "https://ariadne-infrastructure.eu/aocat/Concept/AFE/", ucase(strafter(str(?native_subject),"AFE_RGK/")))) as ?modified_native_subject)
+            ?modified_native_subject skos:exactMatch ?aat_subject	.
+        }
+        union
+        {
+            ?record aocat:has_native_subject ?native_subject .
+            bind (IRI(concat( "https://ariadne-infrastructure.eu/aocat/Concept/AFE/", ucase(strafter(str(?native_subject),"AFE_RGK/")))) as ?modified_native_subject)
+            ?modified_native_subject skos:broadMatch ?aat_subject	.
+
+        }
+        union
+        {
+            ?record aocat:has_native_subject ?native_subject .
+            bind (IRI(concat( "https://ariadne-infrastructure.eu/aocat/Concept/AFE/", ucase(strafter(str(?native_subject),"AFE_RGK/")))) as ?modified_native_subject)
+            ?modified_native_subject skos:closeMatch ?aat_subject	.
+
+        }
+        union
+        {
+            ?record aocat:has_native_subject ?native_subject .
+            bind (IRI(concat( "https://ariadne-infrastructure.eu/aocat/Concept/AFE/", ucase(strafter(str(?native_subject),"AFE_RGK/")))) as ?modified_native_subject)
+            ?modified_native_subject skos:narrowMatch ?aat_subject	.
+        }
+   };
+