Revision 52305
Added by Alessia Bardi over 6 years ago
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/pom.xml | ||
|---|---|---|
| 1 |
<?xml version="1.0" ?> |
|
| 2 |
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> |
|
| 3 |
<parent> |
|
| 4 |
<groupId>eu.dnetlib</groupId> |
|
| 5 |
<artifactId>dnet45-parent</artifactId> |
|
| 6 |
<version>1.0.0</version> |
|
| 7 |
<relativePath /> |
|
| 8 |
</parent> |
|
| 9 |
<modelVersion>4.0.0</modelVersion> |
|
| 10 |
<groupId>eu.dnetlib</groupId> |
|
| 11 |
<artifactId>dnet-openaireplus-workflows</artifactId> |
|
| 12 |
<packaging>jar</packaging> |
|
| 13 |
<version>6.3.3</version> |
|
| 14 |
|
|
| 15 |
<scm> |
|
| 16 |
<developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3</developerConnection> |
|
| 17 |
</scm> |
|
| 18 |
<dependencies> |
|
| 19 |
<dependency> |
|
| 20 |
<groupId>eu.dnetlib</groupId> |
|
| 21 |
<artifactId>cnr-data-flow-monitoring-core</artifactId> |
|
| 22 |
<version>[2.0.0,3.0.0)</version> |
|
| 23 |
<exclusions> |
|
| 24 |
<exclusion> |
|
| 25 |
<artifactId>wstx-asl</artifactId> |
|
| 26 |
<groupId>org.codehaus.woodstox</groupId> |
|
| 27 |
</exclusion> |
|
| 28 |
</exclusions> |
|
| 29 |
</dependency> |
|
| 30 |
<dependency> |
|
| 31 |
<groupId>eu.dnetlib</groupId> |
|
| 32 |
<artifactId>cnr-enabling-database-api</artifactId> |
|
| 33 |
<version>[2.0.0,3.0.0)</version> |
|
| 34 |
</dependency> |
|
| 35 |
<dependency> |
|
| 36 |
<groupId>eu.dnetlib</groupId> |
|
| 37 |
<artifactId>cnr-enabling-database-service</artifactId> |
|
| 38 |
<version>[3.0.0,4.0.0)</version> |
|
| 39 |
</dependency> |
|
| 40 |
<dependency> |
|
| 41 |
<groupId>eu.dnetlib</groupId> |
|
| 42 |
<artifactId>dnet-msro-service</artifactId> |
|
| 43 |
<version>[3.0.0,4.0.0)</version> |
|
| 44 |
</dependency> |
|
| 45 |
<dependency> |
|
| 46 |
<groupId>eu.dnetlib</groupId> |
|
| 47 |
<artifactId>cnr-resultset-service</artifactId> |
|
| 48 |
<version>[2.0.0,3.0.0)</version> |
|
| 49 |
</dependency> |
|
| 50 |
<dependency> |
|
| 51 |
<groupId>eu.dnetlib</groupId> |
|
| 52 |
<artifactId>dnet-openaire-datasource-manager</artifactId> |
|
| 53 |
<version>[1.0.0-SNAPSHOT,2.0.0)</version> |
|
| 54 |
</dependency> |
|
| 55 |
<dependency> |
|
| 56 |
<groupId>eu.dnetlib</groupId> |
|
| 57 |
<artifactId>dnet-openaireplus-mapping-utils</artifactId> |
|
| 58 |
<version>[6.0.0,7.0.0)</version> |
|
| 59 |
</dependency> |
|
| 60 |
<dependency> |
|
| 61 |
<groupId>eu.dnetlib</groupId> |
|
| 62 |
<artifactId>dnet-hadoop-service-rmi</artifactId> |
|
| 63 |
<version>[1.0.0,2.0.0)</version> |
|
| 64 |
</dependency> |
|
| 65 |
<dependency> |
|
| 66 |
<groupId>eu.dnetlib</groupId> |
|
| 67 |
<artifactId>dnet-index-solr-common</artifactId> |
|
| 68 |
<version>[1.0.0,2.0.0)</version> |
|
| 69 |
</dependency> |
|
| 70 |
<dependency> |
|
| 71 |
<groupId>eu.dnetlib</groupId> |
|
| 72 |
<artifactId>dnet-collector-plugins</artifactId> |
|
| 73 |
<version>[1.0.0,2.0.0)</version> |
|
| 74 |
</dependency> |
|
| 75 |
|
|
| 76 |
<dependency> |
|
| 77 |
<groupId>eu.dnetlib</groupId> |
|
| 78 |
<artifactId>dnet-actionmanager-api</artifactId> |
|
| 79 |
<version>[4.0.0,5.0.0)</version> |
|
| 80 |
</dependency> |
|
| 81 |
|
|
| 82 |
<dependency> |
|
| 83 |
<groupId>eu.dnetlib</groupId> |
|
| 84 |
<artifactId>dnet-oai-common-workflows</artifactId> |
|
| 85 |
<version>[5.0.0,6.0.0)</version> |
|
| 86 |
</dependency> |
|
| 87 |
|
|
| 88 |
<dependency> |
|
| 89 |
<groupId>eu.dnetlib</groupId> |
|
| 90 |
<artifactId>dnet-index-solr-client</artifactId> |
|
| 91 |
<version>[2.0.0,2.9.9)</version> |
|
| 92 |
</dependency> |
|
| 93 |
|
|
| 94 |
<dependency> |
|
| 95 |
<groupId>eu.dnetlib</groupId> |
|
| 96 |
<artifactId>dnet-validator-workflows</artifactId> |
|
| 97 |
<version>[1.0.0,2.0.0)</version> |
|
| 98 |
</dependency> |
|
| 99 |
|
|
| 100 |
<dependency> |
|
| 101 |
<groupId>eu.dnetlib</groupId> |
|
| 102 |
<artifactId>dnet-deduplication</artifactId> |
|
| 103 |
<version>[1.0.0,2.0.0)</version> |
|
| 104 |
</dependency> |
|
| 105 |
|
|
| 106 |
<!-- modular ui and servlet api are here because of the stats controller --> |
|
| 107 |
<dependency> |
|
| 108 |
<groupId>eu.dnetlib</groupId> |
|
| 109 |
<artifactId>dnet-directindex-api</artifactId> |
|
| 110 |
<version>[1.0.0,2.0.0)</version> |
|
| 111 |
</dependency> |
|
| 112 |
|
|
| 113 |
<dependency> |
|
| 114 |
<groupId>org.apache.velocity</groupId> |
|
| 115 |
<artifactId>velocity</artifactId> |
|
| 116 |
<version>1.7</version> |
|
| 117 |
<exclusions> |
|
| 118 |
<exclusion> |
|
| 119 |
<artifactId>antlr</artifactId> |
|
| 120 |
<groupId>antlr</groupId> |
|
| 121 |
</exclusion> |
|
| 122 |
</exclusions> |
|
| 123 |
</dependency> |
|
| 124 |
<dependency> |
|
| 125 |
<groupId>org.apache.velocity</groupId> |
|
| 126 |
<artifactId>velocity-tools</artifactId> |
|
| 127 |
<version>2.0</version> |
|
| 128 |
<exclusions> |
|
| 129 |
<exclusion> |
|
| 130 |
<artifactId>antlr</artifactId> |
|
| 131 |
<groupId>antlr</groupId> |
|
| 132 |
</exclusion> |
|
| 133 |
</exclusions> |
|
| 134 |
</dependency> |
|
| 135 |
<dependency> |
|
| 136 |
<groupId>javax.servlet</groupId> |
|
| 137 |
<artifactId>javax.servlet-api</artifactId> |
|
| 138 |
<version>${javax.servlet.version}</version>
|
|
| 139 |
<scope>provided</scope> |
|
| 140 |
</dependency> |
|
| 141 |
<dependency> |
|
| 142 |
<groupId>junit</groupId> |
|
| 143 |
<artifactId>junit</artifactId> |
|
| 144 |
<version>${junit.version}</version>
|
|
| 145 |
<scope>test</scope> |
|
| 146 |
</dependency> |
|
| 147 |
<dependency> |
|
| 148 |
<groupId>eu.dnetlib</groupId> |
|
| 149 |
<artifactId>dnet-openaireplus-profiles</artifactId> |
|
| 150 |
<version>[1.0.0,2.0.0)</version> |
|
| 151 |
<scope>test</scope> |
|
| 152 |
</dependency> |
|
| 153 |
<dependency> |
|
| 154 |
<groupId>io.springfox</groupId> |
|
| 155 |
<artifactId>springfox-swagger2</artifactId> |
|
| 156 |
<version>${springfox-version}</version>
|
|
| 157 |
</dependency> |
|
| 158 |
<dependency> |
|
| 159 |
<groupId>org.mockito</groupId> |
|
| 160 |
<artifactId>mockito-core</artifactId> |
|
| 161 |
<version>1.9.5</version> |
|
| 162 |
</dependency> |
|
| 163 |
<dependency> |
|
| 164 |
<groupId>org.springframework</groupId> |
|
| 165 |
<artifactId>spring-jdbc</artifactId> |
|
| 166 |
<version>${spring.version}</version>
|
|
| 167 |
</dependency> |
|
| 168 |
|
|
| 169 |
<dependency> |
|
| 170 |
<groupId>eu.dnetlib</groupId> |
|
| 171 |
<artifactId>cnr-misc-utils</artifactId> |
|
| 172 |
<version>[1.0.5, 2.0.0)</version> |
|
| 173 |
</dependency> |
|
| 174 |
</dependencies> |
|
| 175 |
|
|
| 176 |
<properties> |
|
| 177 |
<springfox-version>2.5.0</springfox-version> |
|
| 178 |
</properties> |
|
| 179 |
</project> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg/updateDb.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="selectIncremental"/> |
|
| 10 |
</ARCS> |
|
| 11 |
</NODE> |
|
| 12 |
|
|
| 13 |
<NODE name="selectIncremental" type="IncrementalOperation"> |
|
| 14 |
<DESCRIPTION>Decide REFRESH/INCREMENTAL Update</DESCRIPTION> |
|
| 15 |
<PARAMETERS> |
|
| 16 |
<PARAM required="true" type="string" name="operationType" managedBy="user" function="validValues(['REFRESH','INCREMENTAL'])"></PARAM> |
|
| 17 |
</PARAMETERS> |
|
| 18 |
<ARCS> |
|
| 19 |
<ARC to="FETCH_RECORDS"/> |
|
| 20 |
</ARCS> |
|
| 21 |
</NODE> |
|
| 22 |
|
|
| 23 |
<NODE name="FETCH_RECORDS" type="FetchMDStoreRecords"> |
|
| 24 |
<DESCRIPTION>Fetch records from MDStore</DESCRIPTION> |
|
| 25 |
<PARAMETERS> |
|
| 26 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("row_id")$</PARAM>
|
|
| 27 |
<PARAM required="true" type="string" name="mdFormat" managedBy="system">$params.("row_format")$</PARAM>
|
|
| 28 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">rs_epr</PARAM> |
|
| 29 |
</PARAMETERS> |
|
| 30 |
<ARCS> |
|
| 31 |
<ARC to="UPDATE_DB"/> |
|
| 32 |
</ARCS> |
|
| 33 |
</NODE> |
|
| 34 |
|
|
| 35 |
|
|
| 36 |
<NODE name="UPDATE_DB" type="UpdateOpenaireDb"> |
|
| 37 |
<DESCRIPTION>Update Db</DESCRIPTION> |
|
| 38 |
<PARAMETERS> |
|
| 39 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">rs_epr</PARAM> |
|
| 40 |
</PARAMETERS> |
|
| 41 |
<ARCS> |
|
| 42 |
<ARC to="success"/> |
|
| 43 |
</ARCS> |
|
| 44 |
</NODE> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/datacite/repoBye.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="DeleteMetaWorkflow"/> |
|
| 10 |
</ARCS> |
|
| 11 |
</NODE> |
|
| 12 |
|
|
| 13 |
<NODE name="DeleteMetaWorkflow" type="DeleteOpenaireMetaWf"> |
|
| 14 |
<DESCRIPTION>Delete the MetaWorkflow</DESCRIPTION> |
|
| 15 |
<PARAMETERS> |
|
| 16 |
<PARAM required="true" type="string" name="metaWfId" managedBy="system">$params.("META_WORKFLOW_ID")$</PARAM>
|
|
| 17 |
</PARAMETERS> |
|
| 18 |
<ARCS> |
|
| 19 |
<ARC to="DeleteMDStoreNative"/> |
|
| 20 |
</ARCS> |
|
| 21 |
</NODE> |
|
| 22 |
|
|
| 23 |
<NODE name="DeleteMDStoreNative" type="DeleteMDStore"> |
|
| 24 |
<DESCRIPTION>Delete the native mdstore</DESCRIPTION> |
|
| 25 |
<PARAMETERS> |
|
| 26 |
<PARAM required="true" type="string" name="mdstoreId" managedBy="system" category="MDSTORE_ID">$params.("harv_id")$</PARAM>
|
|
| 27 |
</PARAMETERS> |
|
| 28 |
<ARCS> |
|
| 29 |
<ARC to="DeleteMDStoreDatacite"/> |
|
| 30 |
<ARC to="DeleteMDStorePublication"/> |
|
| 31 |
</ARCS> |
|
| 32 |
</NODE> |
|
| 33 |
|
|
| 34 |
<NODE name="DeleteMDStoreDatacite" type="DeleteMDStore"> |
|
| 35 |
<DESCRIPTION>Delete the IMEF mdstore</DESCRIPTION> |
|
| 36 |
<PARAMETERS> |
|
| 37 |
<PARAM required="true" type="string" name="mdstoreId" managedBy="system" category="MDSTORE_ID">$params.("tranODF_id")$</PARAM>
|
|
| 38 |
</PARAMETERS> |
|
| 39 |
<ARCS> |
|
| 40 |
<ARC to="RemoveApiExtraFields"/> |
|
| 41 |
</ARCS> |
|
| 42 |
</NODE> |
|
| 43 |
|
|
| 44 |
<NODE name="DeleteMDStorePublication" type="DeleteMDStore"> |
|
| 45 |
<DESCRIPTION>Delete the IMEF mdstore</DESCRIPTION> |
|
| 46 |
<PARAMETERS> |
|
| 47 |
<PARAM required="true" type="string" name="mdstoreId" managedBy="system" category="MDSTORE_ID">$params.("tranOAF_id")$</PARAM>
|
|
| 48 |
</PARAMETERS> |
|
| 49 |
<ARCS> |
|
| 50 |
<ARC to="RemoveApiExtraFields"/> |
|
| 51 |
</ARCS> |
|
| 52 |
</NODE> |
|
| 53 |
|
|
| 54 |
<NODE name="RemoveApiExtraFields" type="RemoveApiExtraFields" isJoin="true"> |
|
| 55 |
<DESCRIPTION>Reset the extrafields of the api</DESCRIPTION> |
|
| 56 |
<PARAMETERS> |
|
| 57 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 58 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 59 |
<PARAM required="true" type="string" name="fields" managedBy="system">last_collection_total, last_collection_date, last_collection_mdId, last_aggregation_total, last_aggregation_date, last_aggregation_mdId</PARAM> |
|
| 60 |
</PARAMETERS> |
|
| 61 |
<ARCS> |
|
| 62 |
<ARC to="success"/> |
|
| 63 |
</ARCS> |
|
| 64 |
</NODE> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg/transform.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="selectIncrementalTransformation"/> |
|
| 10 |
<ARC to="obtainParams" /> |
|
| 11 |
</ARCS> |
|
| 12 |
</NODE> |
|
| 13 |
|
|
| 14 |
<NODE name="selectIncrementalTransformation" type="IncrementalTransformation"> |
|
| 15 |
<DESCRIPTION>Decide REFRESH/INCREMENTAL transformation</DESCRIPTION> |
|
| 16 |
<PARAMETERS> |
|
| 17 |
<PARAM required="true" type="string" name="operationType" managedBy="user" function="validValues(['REFRESH','INCREMENTAL'])"></PARAM> |
|
| 18 |
</PARAMETERS> |
|
| 19 |
<ARCS> |
|
| 20 |
<ARC to="fetchOriginals"/> |
|
| 21 |
</ARCS> |
|
| 22 |
</NODE> |
|
| 23 |
|
|
| 24 |
<NODE name="fetchOriginals" type="FetchMDStoreRecords"> |
|
| 25 |
<DESCRIPTION>Fetch records from MDStore</DESCRIPTION> |
|
| 26 |
<PARAMETERS> |
|
| 27 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("orig_id")$</PARAM>
|
|
| 28 |
<PARAM required="true" type="string" name="mdFormat" managedBy="system">$params.("orig_format")$</PARAM>
|
|
| 29 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">orig_epr</PARAM> |
|
| 30 |
</PARAMETERS> |
|
| 31 |
<ARCS> |
|
| 32 |
<ARC to="setFunderAcronym"/> |
|
| 33 |
</ARCS> |
|
| 34 |
</NODE> |
|
| 35 |
|
|
| 36 |
<NODE name="obtainParams" type="ObtainOpenaireDataSourceParams"> |
|
| 37 |
<DESCRIPTION>Fetch records from MDStore</DESCRIPTION> |
|
| 38 |
<PARAMETERS> |
|
| 39 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 40 |
</PARAMETERS> |
|
| 41 |
<ARCS> |
|
| 42 |
<ARC to="setFunderAcronym"/> |
|
| 43 |
</ARCS> |
|
| 44 |
</NODE> |
|
| 45 |
|
|
| 46 |
<NODE name="setFunderAcronym" type="SetEnvParameter" isJoin="true"> |
|
| 47 |
<DESCRIPTION>Set funder acronym to use in transformation</DESCRIPTION> |
|
| 48 |
<PARAMETERS> |
|
| 49 |
<PARAM required="true" type="string" name="parameterName" managedBy="system">funderAcronym</PARAM> |
|
| 50 |
<PARAM required="false" type="string" name="parameterValue" managedBy="user"></PARAM> |
|
| 51 |
</PARAMETERS> |
|
| 52 |
<ARCS> |
|
| 53 |
<ARC to="generateRows"/> |
|
| 54 |
</ARCS> |
|
| 55 |
</NODE> |
|
| 56 |
|
|
| 57 |
<NODE name="generateRows" type="ApplyXslt"> |
|
| 58 |
<DESCRIPTION>Transform original records in DB rows</DESCRIPTION> |
|
| 59 |
<PARAMETERS> |
|
| 60 |
<PARAM required="true" type="string" name="xsltClasspath" managedBy="user" function="listFiles('/eu/dnetlib/msro/openaireplus/workflows/repo-hi/xslt','xsl')"></PARAM>
|
|
| 61 |
<PARAM required="true" type="string" name="inputEprParam" managedBy="system">orig_epr</PARAM> |
|
| 62 |
<PARAM required="true" type="string" name="outputEprParam" managedBy="system">packed_row_epr</PARAM> |
|
| 63 |
</PARAMETERS> |
|
| 64 |
<ARCS> |
|
| 65 |
<ARC to="cleanRows"/> |
|
| 66 |
</ARCS> |
|
| 67 |
</NODE> |
|
| 68 |
|
|
| 69 |
<NODE name="cleanRows" type="Clean"> |
|
| 70 |
<DESCRIPTION>Clean DB rows values according to defined vocabularies</DESCRIPTION> |
|
| 71 |
<PARAMETERS> |
|
| 72 |
<PARAM required="true" type="string" name="ruleId" managedBy="user" category="CLEANER_RULE_ID" function="listProfiles('CleanerDSResourceType', '//CLEANER_NAME')"></PARAM>
|
|
| 73 |
<PARAM required="true" type="string" name="inputEprParam" managedBy="system">packed_row_epr</PARAM> |
|
| 74 |
<PARAM required="true" type="string" name="outputEprParam" managedBy="system">cleaned_row_epr</PARAM> |
|
| 75 |
</PARAMETERS> |
|
| 76 |
<ARCS> |
|
| 77 |
<ARC to="filterManaged"/> |
|
| 78 |
</ARCS> |
|
| 79 |
</NODE> |
|
| 80 |
|
|
| 81 |
<NODE name="filterManaged" type="FilterManagedDatasources"> |
|
| 82 |
<DESCRIPTION>Filter DB rows according to the managed flag state</DESCRIPTION> |
|
| 83 |
<PARAMETERS> |
|
| 84 |
<PARAM managedBy="system" name="inputEprParam" required="true" type="string">cleaned_row_epr</PARAM> |
|
| 85 |
<PARAM managedBy="system" name="outputEprParam" required="true" type="string">filtered_row_epr</PARAM> |
|
| 86 |
</PARAMETERS> |
|
| 87 |
<ARCS> |
|
| 88 |
<ARC to="storeRowRecords"/> |
|
| 89 |
</ARCS> |
|
| 90 |
</NODE> |
|
| 91 |
|
|
| 92 |
<NODE name="storeRowRecords" type="StoreMDStoreRecords"> |
|
| 93 |
<DESCRIPTION>Store mdtore records</DESCRIPTION> |
|
| 94 |
<PARAMETERS> |
|
| 95 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("row_id")$</PARAM>
|
|
| 96 |
<PARAM required="true" type="string" name="storingType" managedBy="system">REFRESH</PARAM> |
|
| 97 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">filtered_row_epr</PARAM> |
|
| 98 |
</PARAMETERS> |
|
| 99 |
<ARCS> |
|
| 100 |
<ARC to="UPDATE_INFO"/> |
|
| 101 |
</ARCS> |
|
| 102 |
</NODE> |
|
| 103 |
|
|
| 104 |
<NODE name="UPDATE_INFO" type="MDStoreToApiExtraField"> |
|
| 105 |
<DESCRIPTION>Update datasouce API extra fields</DESCRIPTION> |
|
| 106 |
<PARAMETERS> |
|
| 107 |
<PARAM required="true" type="string" name="mdId" managedBy="system">$params.("row_id")$</PARAM>
|
|
| 108 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 109 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 110 |
<PARAM required="true" type="string" name="extraFieldForTotal" managedBy="system">last_aggregation_total</PARAM> |
|
| 111 |
<PARAM required="true" type="string" name="extraFieldForDate" managedBy="system">last_aggregation_date</PARAM> |
|
| 112 |
<PARAM required="true" type="string" name="extraFieldForMdId" managedBy="system">last_aggregation_mdId</PARAM> |
|
| 113 |
</PARAMETERS> |
|
| 114 |
<ARCS> |
|
| 115 |
<ARC to="success"/> |
|
| 116 |
</ARCS> |
|
| 117 |
</NODE> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg/collection.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="SELECT_MODE"/> |
|
| 10 |
</ARCS> |
|
| 11 |
</NODE> |
|
| 12 |
|
|
| 13 |
<NODE name="SELECT_MODE" type="Selection"> |
|
| 14 |
<DESCRIPTION>Choose collection mode</DESCRIPTION> |
|
| 15 |
<PARAMETERS> |
|
| 16 |
<PARAM required="true" type="string" name="selection" managedBy="user" function="validValues(['REFRESH','INCREMENTAL'])">REFRESH</PARAM> |
|
| 17 |
</PARAMETERS> |
|
| 18 |
<ARCS> |
|
| 19 |
<ARC to="COLLECT_REFRESH" name="REFRESH" /> |
|
| 20 |
<ARC to="PREPARE_INCREMENTAL" name="INCREMENTAL" /> |
|
| 21 |
</ARCS> |
|
| 22 |
</NODE> |
|
| 23 |
|
|
| 24 |
<NODE name="COLLECT_REFRESH" type="CollectRecords"> |
|
| 25 |
<DESCRIPTION>Start Harvesting</DESCRIPTION> |
|
| 26 |
<PARAMETERS> |
|
| 27 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 28 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 29 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">collected_epr</PARAM> |
|
| 30 |
</PARAMETERS> |
|
| 31 |
<ARCS> |
|
| 32 |
<ARC to="MD_BUILDER_REFRESH"/> |
|
| 33 |
</ARCS> |
|
| 34 |
</NODE> |
|
| 35 |
|
|
| 36 |
<NODE name="MD_BUILDER_REFRESH" type="MdBuilder"> |
|
| 37 |
<DESCRIPTION>Prepare mdstore records</DESCRIPTION> |
|
| 38 |
<PARAMETERS> |
|
| 39 |
<PARAM required="true" type="string" name="inputEprParam" managedBy="system">collected_epr</PARAM> |
|
| 40 |
<PARAM required="true" type="string" name="outputEprParam" managedBy="system">store_epr</PARAM> |
|
| 41 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 42 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 43 |
</PARAMETERS> |
|
| 44 |
<ARCS> |
|
| 45 |
<ARC to="STORE_REFRESH"/> |
|
| 46 |
</ARCS> |
|
| 47 |
</NODE> |
|
| 48 |
|
|
| 49 |
<NODE name="STORE_REFRESH" type="StoreMDStoreRecords"> |
|
| 50 |
<DESCRIPTION>Store mdtore records</DESCRIPTION> |
|
| 51 |
<PARAMETERS> |
|
| 52 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("orig_id")$</PARAM>
|
|
| 53 |
<PARAM managedBy="system" name="storingType" required="true" type="string">REFRESH</PARAM> |
|
| 54 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">store_epr</PARAM> |
|
| 55 |
</PARAMETERS> |
|
| 56 |
<ARCS> |
|
| 57 |
<ARC to="UPDATE_INFO"/> |
|
| 58 |
</ARCS> |
|
| 59 |
</NODE> |
|
| 60 |
|
|
| 61 |
<NODE name="PREPARE_INCREMENTAL" type="FindDateRangeForIncrementalHarvesting"> |
|
| 62 |
<DESCRIPTION>Find Date Range For Incremental Harvesting</DESCRIPTION> |
|
| 63 |
<PARAMETERS> |
|
| 64 |
<PARAM required="true" type="string" name="fromDateParam" managedBy="system">FROM_DATE</PARAM> |
|
| 65 |
<PARAM required="true" type="string" name="untilDateParam" managedBy="system">UNTIL_DATE</PARAM> |
|
| 66 |
</PARAMETERS> |
|
| 67 |
<ARCS> |
|
| 68 |
<ARC to="COLLECT_INCREMENTAL"/> |
|
| 69 |
</ARCS> |
|
| 70 |
</NODE> |
|
| 71 |
|
|
| 72 |
<NODE name="COLLECT_INCREMENTAL" type="DateRangeCollectRecords"> |
|
| 73 |
<DESCRIPTION>Start incremental harvesting</DESCRIPTION> |
|
| 74 |
<PARAMETERS> |
|
| 75 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 76 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 77 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">collected_epr</PARAM> |
|
| 78 |
<PARAM required="true" type="string" name="fromDateParam" managedBy="system">FROM_DATE</PARAM> |
|
| 79 |
<PARAM required="true" type="string" name="untilDateParam" managedBy="system">UNTIL_DATE</PARAM> |
|
| 80 |
</PARAMETERS> |
|
| 81 |
<ARCS> |
|
| 82 |
<ARC to="MD_BUILDER_INCREMENTAL"/> |
|
| 83 |
</ARCS> |
|
| 84 |
</NODE> |
|
| 85 |
|
|
| 86 |
<NODE name="MD_BUILDER_INCREMENTAL" type="MdBuilder"> |
|
| 87 |
<DESCRIPTION>Prepare mdstore records</DESCRIPTION> |
|
| 88 |
<PARAMETERS> |
|
| 89 |
<PARAM required="true" type="string" name="inputEprParam" managedBy="system">collected_epr</PARAM> |
|
| 90 |
<PARAM required="true" type="string" name="outputEprParam" managedBy="system">store_epr</PARAM> |
|
| 91 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 92 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 93 |
</PARAMETERS> |
|
| 94 |
<ARCS> |
|
| 95 |
<ARC to="STORE_INCREMENTAL"/> |
|
| 96 |
</ARCS> |
|
| 97 |
</NODE> |
|
| 98 |
|
|
| 99 |
<NODE name="STORE_INCREMENTAL" type="StoreMDStoreRecords"> |
|
| 100 |
<DESCRIPTION>Store mdstore records incrementally</DESCRIPTION> |
|
| 101 |
<PARAMETERS> |
|
| 102 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("orig_id")$</PARAM>
|
|
| 103 |
<PARAM required="true" type="string" name="storingType" managedBy="system">INCREMENTAL</PARAM> |
|
| 104 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">store_epr</PARAM> |
|
| 105 |
</PARAMETERS> |
|
| 106 |
<ARCS> |
|
| 107 |
<ARC to="UPDATE_INFO"/> |
|
| 108 |
</ARCS> |
|
| 109 |
</NODE> |
|
| 110 |
|
|
| 111 |
<NODE name="UPDATE_INFO" type="MDStoreToApiExtraField"> |
|
| 112 |
<DESCRIPTION>Update datasouce API extra fields</DESCRIPTION> |
|
| 113 |
<PARAMETERS> |
|
| 114 |
<PARAM required="true" type="string" name="mdId" managedBy="system">$params.("orig_id")$</PARAM>
|
|
| 115 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 116 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 117 |
<PARAM required="true" type="string" name="extraFieldForTotal" managedBy="system">last_collection_total</PARAM> |
|
| 118 |
<PARAM required="true" type="string" name="extraFieldForDate" managedBy="system">last_collection_date</PARAM> |
|
| 119 |
<PARAM required="true" type="string" name="extraFieldForMdId" managedBy="system">last_collection_mdId</PARAM> |
|
| 120 |
</PARAMETERS> |
|
| 121 |
<ARCS> |
|
| 122 |
<ARC to="success"/> |
|
| 123 |
</ARCS> |
|
| 124 |
</NODE> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg-contexts/xsl/dfg_context.xsl | ||
|---|---|---|
| 1 |
<?xml version="1.0" encoding="UTF-8"?> |
|
| 2 |
<xsl:stylesheet xmlns:xsl="http://www.w3.org/1999/XSL/Transform" |
|
| 3 |
xmlns:fn="http://www.w3.org/2005/xpath-functions" version="1.0" |
|
| 4 |
exclude-result-prefixes="fn" xmlns:utils="eu.dnetlib.data.transform.xml.AbstractDNetXsltFunctions"> |
|
| 5 |
|
|
| 6 |
<xsl:variable name="namespacePrefix" select="string('dfgf________')"/>
|
|
| 7 |
<xsl:variable name="funderID" select="concat($namespacePrefix, '::DFG')"/> |
|
| 8 |
|
|
| 9 |
<xsl:template match="/"> |
|
| 10 |
<fundings> |
|
| 11 |
<fundingtree> |
|
| 12 |
<funder> |
|
| 13 |
<id> |
|
| 14 |
<xsl:value-of select="$funderID"/> |
|
| 15 |
</id> |
|
| 16 |
<shortname>DFG</shortname> |
|
| 17 |
<name>Deutsche Forschungsgemeinschaft</name> |
|
| 18 |
<jurisdiction>DE</jurisdiction> |
|
| 19 |
</funder> |
|
| 20 |
<xsl:variable name="stream" select ="normalize-space(.//column[@name='Funding Programme'])" /> |
|
| 21 |
<xsl:variable name="stream_id" select="utils:md5($stream)"/> |
|
| 22 |
<xsl:if test="string-length($stream_id) > 0"> |
|
| 23 |
<funding_level_0> |
|
| 24 |
<id> |
|
| 25 |
<xsl:value-of select="concat($funderID, '::', $stream_id)"/> |
|
| 26 |
</id> |
|
| 27 |
|
|
| 28 |
<description> |
|
| 29 |
<xsl:value-of select="$stream"/> |
|
| 30 |
</description> |
|
| 31 |
<name> |
|
| 32 |
<xsl:value-of select="$stream"/> |
|
| 33 |
</name> |
|
| 34 |
<parent></parent> |
|
| 35 |
<class>dfg:fundingStream</class> |
|
| 36 |
</funding_level_0> |
|
| 37 |
</xsl:if> |
|
| 38 |
</fundingtree> |
|
| 39 |
</fundings> |
|
| 40 |
</xsl:template> |
|
| 41 |
|
|
| 42 |
</xsl:stylesheet> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg-contexts/xsl/wt_contexts.xsl | ||
|---|---|---|
| 1 |
<?xml version="1.0" encoding="UTF-8"?> |
|
| 2 |
<xsl:stylesheet xmlns:xsl="http://www.w3.org/1999/XSL/Transform" |
|
| 3 |
xmlns:fn="http://www.w3.org/2005/xpath-functions" version="1.0" |
|
| 4 |
exclude-result-prefixes="fn"> |
|
| 5 |
|
|
| 6 |
<xsl:variable name="namespacePrefix" select="string('wt__________')"/>
|
|
| 7 |
<xsl:variable name="funderID" select="concat($namespacePrefix, '::WT')"/> |
|
| 8 |
|
|
| 9 |
<xsl:template match="/"> |
|
| 10 |
<fundings> |
|
| 11 |
<fundingtree> |
|
| 12 |
<funder> |
|
| 13 |
<id> |
|
| 14 |
<xsl:value-of select="$funderID"/> |
|
| 15 |
</id> |
|
| 16 |
<shortname>WT</shortname> |
|
| 17 |
<name>Wellcome Trust</name> |
|
| 18 |
<jurisdiction></jurisdiction> |
|
| 19 |
</funder> |
|
| 20 |
<xsl:variable name="stream" select="normalize-space(.//Grant/Stream)"/> |
|
| 21 |
<xsl:if test="string-length($stream) > 0"> |
|
| 22 |
<funding_level_0> |
|
| 23 |
<id> |
|
| 24 |
<xsl:value-of select="concat($funderID, '::', $stream)"/> |
|
| 25 |
</id> |
|
| 26 |
<description> |
|
| 27 |
<xsl:value-of select="$stream"/> |
|
| 28 |
</description> |
|
| 29 |
<name> |
|
| 30 |
<xsl:value-of select="$stream"/> |
|
| 31 |
</name> |
|
| 32 |
<parent></parent> |
|
| 33 |
<class>wt:fundingStream</class> |
|
| 34 |
</funding_level_0> |
|
| 35 |
</xsl:if> |
|
| 36 |
</fundingtree> |
|
| 37 |
</fundings> |
|
| 38 |
</xsl:template> |
|
| 39 |
|
|
| 40 |
</xsl:stylesheet> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg/repoBye.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="DeleteMetaWorkflow"/> |
|
| 10 |
</ARCS> |
|
| 11 |
</NODE> |
|
| 12 |
|
|
| 13 |
<NODE name="DeleteMetaWorkflow" type="DeleteOpenaireMetaWf"> |
|
| 14 |
<DESCRIPTION>Delete the MetaWorkflow</DESCRIPTION> |
|
| 15 |
<PARAMETERS> |
|
| 16 |
<PARAM required="true" type="string" name="metaWfId" managedBy="system">$params.("META_WORKFLOW_ID")$</PARAM>
|
|
| 17 |
</PARAMETERS> |
|
| 18 |
<ARCS> |
|
| 19 |
<ARC to="DeleteMDStoreGMF"/> |
|
| 20 |
</ARCS> |
|
| 21 |
</NODE> |
|
| 22 |
|
|
| 23 |
<NODE name="DeleteMDStoreGMF" type="DeleteMDStore"> |
|
| 24 |
<DESCRIPTION>Delete the GMF mdstore</DESCRIPTION> |
|
| 25 |
<PARAMETERS> |
|
| 26 |
<PARAM required="true" type="string" name="mdstoreId" managedBy="system" category="MDSTORE_ID">$params.("orig_id")$</PARAM>
|
|
| 27 |
</PARAMETERS> |
|
| 28 |
<ARCS> |
|
| 29 |
<ARC to="DeleteMDStoreDBMF"/> |
|
| 30 |
</ARCS> |
|
| 31 |
</NODE> |
|
| 32 |
|
|
| 33 |
<NODE name="DeleteMDStoreDBMF" type="DeleteMDStore"> |
|
| 34 |
<DESCRIPTION>Delete the DBMF mdstore</DESCRIPTION> |
|
| 35 |
<PARAMETERS> |
|
| 36 |
<PARAM required="true" type="string" name="mdstoreId" managedBy="system" category="MDSTORE_ID">$params.("row_id")$</PARAM>
|
|
| 37 |
</PARAMETERS> |
|
| 38 |
<ARCS> |
|
| 39 |
<ARC to="RemoveApiExtraFields"/> |
|
| 40 |
</ARCS> |
|
| 41 |
</NODE> |
|
| 42 |
|
|
| 43 |
<NODE name="RemoveApiExtraFields" type="RemoveApiExtraFields"> |
|
| 44 |
<DESCRIPTION>Reset the extrafields of the api</DESCRIPTION> |
|
| 45 |
<PARAMETERS> |
|
| 46 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 47 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 48 |
<PARAM required="true" type="string" name="fields" managedBy="system">last_collection_total, last_collection_date, last_collection_mdId, last_aggregation_total, last_aggregation_date, last_aggregation_mdId</PARAM> |
|
| 49 |
</PARAMETERS> |
|
| 50 |
<ARCS> |
|
| 51 |
<ARC to="success"/> |
|
| 52 |
</ARCS> |
|
| 53 |
</NODE> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg-contexts/xsl/tubitak_contexts.xsl | ||
|---|---|---|
| 1 |
<?xml version="1.0" encoding="UTF-8"?> |
|
| 2 |
<xsl:stylesheet xmlns:xsl="http://www.w3.org/1999/XSL/Transform" |
|
| 3 |
xmlns:fn="http://www.w3.org/2005/xpath-functions" version="1.0" |
|
| 4 |
exclude-result-prefixes="fn"> |
|
| 5 |
|
|
| 6 |
<xsl:variable name="namespacePrefix" select="string('tubitakf____')"/>
|
|
| 7 |
<xsl:variable name="funderID" select="concat($namespacePrefix, '::tubitak')"/> |
|
| 8 |
|
|
| 9 |
<xsl:template match="/"> |
|
| 10 |
<fundings> |
|
| 11 |
<fundingtree> |
|
| 12 |
<funder> |
|
| 13 |
<id> |
|
| 14 |
<xsl:value-of select="$funderID"/> |
|
| 15 |
</id> |
|
| 16 |
<shortname>TUBITAK</shortname> |
|
| 17 |
<name>Türkiye Bilimsel ve Teknolojik Araştırma Kurumu</name> |
|
| 18 |
<jurisdiction>TR</jurisdiction> |
|
| 19 |
</funder> |
|
| 20 |
<xsl:variable name="stream" select="normalize-space(.//column[@name='FUNDING STREAM(S)'])"/> |
|
| 21 |
<xsl:if test="string-length($stream) > 0"> |
|
| 22 |
<funding_level_0> |
|
| 23 |
<id> |
|
| 24 |
<xsl:value-of select="concat($funderID, '::', $stream)"/> |
|
| 25 |
</id> |
|
| 26 |
|
|
| 27 |
<description> |
|
| 28 |
<xsl:value-of select="$stream"/> |
|
| 29 |
</description> |
|
| 30 |
<name> |
|
| 31 |
<xsl:value-of select="$stream"/> |
|
| 32 |
</name> |
|
| 33 |
<parent></parent> |
|
| 34 |
<class>tubitak:fundingStream</class> |
|
| 35 |
</funding_level_0> |
|
| 36 |
</xsl:if> |
|
| 37 |
</fundingtree> |
|
| 38 |
</fundings> |
|
| 39 |
</xsl:template> |
|
| 40 |
|
|
| 41 |
</xsl:stylesheet> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/aggrDatarepoOaiSets/transform.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="selectIncrementalTransformation"/> |
|
| 10 |
<ARC to="obtainParams" /> |
|
| 11 |
</ARCS> |
|
| 12 |
</NODE> |
|
| 13 |
|
|
| 14 |
<NODE name="selectIncrementalTransformation" type="IncrementalTransformation"> |
|
| 15 |
<DESCRIPTION>Decide REFRESH/INCREMENTAL transformation</DESCRIPTION> |
|
| 16 |
<PARAMETERS> |
|
| 17 |
<PARAM required="true" type="string" name="operationType" managedBy="user" function="validValues(['REFRESH','INCREMENTAL'])"></PARAM> |
|
| 18 |
</PARAMETERS> |
|
| 19 |
<ARCS> |
|
| 20 |
<ARC to="fetchOriginals"/> |
|
| 21 |
</ARCS> |
|
| 22 |
</NODE> |
|
| 23 |
|
|
| 24 |
<NODE name="fetchOriginals" type="FetchMDStoreRecords"> |
|
| 25 |
<DESCRIPTION>Fetch records from MDStore</DESCRIPTION> |
|
| 26 |
<PARAMETERS> |
|
| 27 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("orig_id")$</PARAM>
|
|
| 28 |
<PARAM required="true" type="string" name="mdFormat" managedBy="system">$params.("orig_format")$</PARAM>
|
|
| 29 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">orig_epr</PARAM> |
|
| 30 |
</PARAMETERS> |
|
| 31 |
<ARCS> |
|
| 32 |
<ARC to="generateRows"/> |
|
| 33 |
</ARCS> |
|
| 34 |
</NODE> |
|
| 35 |
|
|
| 36 |
<NODE name="obtainParams" type="ObtainOpenaireDataSourceParams"> |
|
| 37 |
<DESCRIPTION>Fetch records from MDStore</DESCRIPTION> |
|
| 38 |
<PARAMETERS> |
|
| 39 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 40 |
</PARAMETERS> |
|
| 41 |
<ARCS> |
|
| 42 |
<ARC to="generateRows"/> |
|
| 43 |
</ARCS> |
|
| 44 |
</NODE> |
|
| 45 |
|
|
| 46 |
<NODE name="generateRows" type="ApplyXslt" isJoin="true"> |
|
| 47 |
<DESCRIPTION>Transform original records in DB rows</DESCRIPTION> |
|
| 48 |
<PARAMETERS> |
|
| 49 |
<PARAM required="true" type="string" name="xsltClasspath" managedBy="system">/eu/dnetlib/msro/openaireplus/workflows/repo-hi/xslt-datacite/datacite_sets_2_db.xslt</PARAM> |
|
| 50 |
<PARAM required="true" type="string" name="inputEprParam" managedBy="system">orig_epr</PARAM> |
|
| 51 |
<PARAM required="true" type="string" name="outputEprParam" managedBy="system">packed_row_epr</PARAM> |
|
| 52 |
</PARAMETERS> |
|
| 53 |
<ARCS> |
|
| 54 |
<ARC to="storeRowRecords"/> |
|
| 55 |
</ARCS> |
|
| 56 |
</NODE> |
|
| 57 |
|
|
| 58 |
<NODE name="storeRowRecords" type="StoreMDStoreRecords"> |
|
| 59 |
<DESCRIPTION>Store mdtore records</DESCRIPTION> |
|
| 60 |
<PARAMETERS> |
|
| 61 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("row_id")$</PARAM>
|
|
| 62 |
<PARAM required="true" type="string" name="storingType" managedBy="system">REFRESH</PARAM> |
|
| 63 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">packed_row_epr</PARAM> |
|
| 64 |
</PARAMETERS> |
|
| 65 |
<ARCS> |
|
| 66 |
<ARC to="UPDATE_INFO"/> |
|
| 67 |
</ARCS> |
|
| 68 |
</NODE> |
|
| 69 |
|
|
| 70 |
<NODE name="UPDATE_INFO" type="MDStoreToApiExtraField"> |
|
| 71 |
<DESCRIPTION>Update datasouce API extra fields</DESCRIPTION> |
|
| 72 |
<PARAMETERS> |
|
| 73 |
<PARAM required="true" type="string" name="mdId" managedBy="system">$params.("row_id")$</PARAM>
|
|
| 74 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 75 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 76 |
<PARAM required="true" type="string" name="extraFieldForTotal" managedBy="system">last_aggregation_total</PARAM> |
|
| 77 |
<PARAM required="true" type="string" name="extraFieldForDate" managedBy="system">last_aggregation_date</PARAM> |
|
| 78 |
<PARAM required="true" type="string" name="extraFieldForMdId" managedBy="system">last_aggregation_mdId</PARAM> |
|
| 79 |
</PARAMETERS> |
|
| 80 |
<ARCS> |
|
| 81 |
<ARC to="success"/> |
|
| 82 |
</ARCS> |
|
| 83 |
</NODE> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg-contexts/xsl/arc_contexts.xsl | ||
|---|---|---|
| 1 |
<?xml version="1.0" encoding="UTF-8"?> |
|
| 2 |
<xsl:stylesheet version="1.0" |
|
| 3 |
xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:fn="http://www.w3.org/2005/xpath-functions" |
|
| 4 |
xmlns:ands="http://ands.org.au/standards/rif-cs/registryObjects" |
|
| 5 |
exclude-result-prefixes="fn"> |
|
| 6 |
|
|
| 7 |
<xsl:output indent="yes"/> |
|
| 8 |
|
|
| 9 |
<xsl:template match="/"> |
|
| 10 |
<fundings> |
|
| 11 |
<fundingtree> |
|
| 12 |
<funder> |
|
| 13 |
<id>arc_________::ARC</id> |
|
| 14 |
<shortname>ARC</shortname> |
|
| 15 |
<name>Australian Research Council (ARC)</name> |
|
| 16 |
<jurisdiction>AU</jurisdiction> |
|
| 17 |
</funder> |
|
| 18 |
</fundingtree> |
|
| 19 |
<xsl:for-each select="//ands:description[@type='fundingScheme']"> |
|
| 20 |
<fundingtree> |
|
| 21 |
<funder> |
|
| 22 |
<id>arc_________::ARC</id> |
|
| 23 |
<shortname>ARC</shortname> |
|
| 24 |
<name>Australian Research Council (ARC)</name> |
|
| 25 |
<jurisdiction>AU</jurisdiction> |
|
| 26 |
</funder> |
|
| 27 |
<funding_level_0> |
|
| 28 |
<id> |
|
| 29 |
<xsl:value-of select="concat('arc_________::ARC::', normalize-space(.))"/>
|
|
| 30 |
</id> |
|
| 31 |
<name> |
|
| 32 |
<xsl:value-of select="normalize-space(.)"/> |
|
| 33 |
</name> |
|
| 34 |
<description> |
|
| 35 |
<xsl:value-of select="normalize-space(.)"/> |
|
| 36 |
</description> |
|
| 37 |
<parent></parent> |
|
| 38 |
<class>arc:fundingStream</class> |
|
| 39 |
</funding_level_0> |
|
| 40 |
</fundingtree> |
|
| 41 |
</xsl:for-each> |
|
| 42 |
</fundings> |
|
| 43 |
</xsl:template> |
|
| 44 |
</xsl:stylesheet> |
|
| 45 |
|
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg-contexts/xsl/corda_contexts.xsl | ||
|---|---|---|
| 1 |
<?xml version="1.0" encoding="UTF-8"?> |
|
| 2 |
<xsl:stylesheet version="1.0" |
|
| 3 |
xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:fn="http://www.w3.org/2005/xpath-functions" |
|
| 4 |
exclude-result-prefixes="fn"> |
|
| 5 |
|
|
| 6 |
<xsl:variable name="namespacePrefix" select="string('ec__________')"/>
|
|
| 7 |
<xsl:variable name="funderID" select="concat($namespacePrefix, '::EC')"/> |
|
| 8 |
|
|
| 9 |
<xsl:template match="/"> |
|
| 10 |
<xsl:variable name="specificProgramName"> |
|
| 11 |
<xsl:choose> |
|
| 12 |
<xsl:when test="normalize-space(.//ProjectSpecificProgram)"> |
|
| 13 |
<xsl:value-of select="normalize-space(.//ProjectSpecificProgram)"/> |
|
| 14 |
</xsl:when> |
|
| 15 |
<xsl:otherwise> |
|
| 16 |
<xsl:value-of select="string('UNKNOWN')"/>
|
|
| 17 |
</xsl:otherwise> |
|
| 18 |
</xsl:choose> |
|
| 19 |
</xsl:variable> |
|
| 20 |
<xsl:variable name="programName"> |
|
| 21 |
<xsl:choose> |
|
| 22 |
<xsl:when test="normalize-space(.//ProjectProgram)"> |
|
| 23 |
<xsl:value-of select="normalize-space(.//ProjectProgram)"/> |
|
| 24 |
</xsl:when> |
|
| 25 |
<xsl:otherwise> |
|
| 26 |
<xsl:value-of select="string('UNKNOWN')"/>
|
|
| 27 |
</xsl:otherwise> |
|
| 28 |
</xsl:choose> |
|
| 29 |
</xsl:variable> |
|
| 30 |
<xsl:variable name="specificProgramDesc" select=".//ProjectSpecificProgramDescr"/> |
|
| 31 |
<xsl:variable name="specificProgramId" |
|
| 32 |
select="normalize-space(concat($funderID, '::FP7::', $specificProgramName))"/> |
|
| 33 |
<xsl:variable name="programDesc" select=".//ProjectProgramDescr"/> |
|
| 34 |
<xsl:variable name="programId" |
|
| 35 |
select="concat($funderID, '::FP7::', $specificProgramName, '::', $programName)"/> |
|
| 36 |
|
|
| 37 |
<fundingtree> |
|
| 38 |
<funder> |
|
| 39 |
<id> |
|
| 40 |
<xsl:value-of select="$funderID"/> |
|
| 41 |
</id> |
|
| 42 |
<shortname>EC</shortname> |
|
| 43 |
<name>European Commission</name> |
|
| 44 |
<jurisdiction>EU</jurisdiction> |
|
| 45 |
</funder> |
|
| 46 |
<funding_level_2> |
|
| 47 |
<id> |
|
| 48 |
<xsl:value-of select="$programId"/> |
|
| 49 |
</id> |
|
| 50 |
<description> |
|
| 51 |
<xsl:value-of select="$programDesc"/> |
|
| 52 |
</description> |
|
| 53 |
<name> |
|
| 54 |
<xsl:value-of select="$programName"/> |
|
| 55 |
</name> |
|
| 56 |
<class>ec:program</class> |
|
| 57 |
<parent> |
|
| 58 |
<funding_level_1> |
|
| 59 |
<id> |
|
| 60 |
<xsl:value-of select="$specificProgramId"/> |
|
| 61 |
</id> |
|
| 62 |
<description> |
|
| 63 |
<xsl:value-of select="$specificProgramDesc"/> |
|
| 64 |
</description> |
|
| 65 |
<name> |
|
| 66 |
<xsl:value-of select="$specificProgramName"/> |
|
| 67 |
</name> |
|
| 68 |
<class>ec:specificprogram</class> |
|
| 69 |
<parent> |
|
| 70 |
<funding_level_0> |
|
| 71 |
<id> |
|
| 72 |
<xsl:value-of select="concat($funderID, '::FP7')"/> |
|
| 73 |
</id> |
|
| 74 |
<description>SEVENTH FRAMEWORK PROGRAMME</description> |
|
| 75 |
<name>FP7</name> |
|
| 76 |
<parent/> |
|
| 77 |
<class>ec:frameworkprogram</class> |
|
| 78 |
</funding_level_0> |
|
| 79 |
</parent> |
|
| 80 |
</funding_level_1> |
|
| 81 |
</parent> |
|
| 82 |
</funding_level_2> |
|
| 83 |
</fundingtree> |
|
| 84 |
</xsl:template> |
|
| 85 |
|
|
| 86 |
</xsl:stylesheet> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg-contexts/xsl/nih_contexts.xsl | ||
|---|---|---|
| 1 |
<?xml version="1.0" encoding="UTF-8"?> |
|
| 2 |
<xsl:stylesheet version="1.0" |
|
| 3 |
xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:fn="http://www.w3.org/2005/xpath-functions" |
|
| 4 |
exclude-result-prefixes="fn"> |
|
| 5 |
|
|
| 6 |
<xsl:output indent="yes"/> |
|
| 7 |
|
|
| 8 |
<xsl:template match="/"> |
|
| 9 |
<fundings> |
|
| 10 |
<fundingtree> |
|
| 11 |
<funder> |
|
| 12 |
<id>nih_________::NIH</id> |
|
| 13 |
<shortname>NIH</shortname> |
|
| 14 |
<name>National Institutes of Health</name> |
|
| 15 |
<jurisdiction>US</jurisdiction> |
|
| 16 |
</funder> |
|
| 17 |
</fundingtree> |
|
| 18 |
<xsl:for-each select="//IC_NAME[./text() != '']"> |
|
| 19 |
<fundingtree> |
|
| 20 |
<funder> |
|
| 21 |
<id>nih_________::NIH</id> |
|
| 22 |
<shortname>NIH</shortname> |
|
| 23 |
<name>National Institutes of Health</name> |
|
| 24 |
<jurisdiction>US</jurisdiction> |
|
| 25 |
</funder> |
|
| 26 |
<xsl:variable name="fundingName" select="fn:upper-case(normalize-space(.))"/> |
|
| 27 |
<funding_level_0> |
|
| 28 |
<id> |
|
| 29 |
<xsl:value-of select="concat('nih_________::NIH::', $fundingName)"/>
|
|
| 30 |
</id> |
|
| 31 |
<name> |
|
| 32 |
<xsl:value-of select="$fundingName"/> |
|
| 33 |
</name> |
|
| 34 |
<description> |
|
| 35 |
<xsl:value-of select="$fundingName"/> |
|
| 36 |
</description> |
|
| 37 |
<parent></parent> |
|
| 38 |
<class>nih:fundingStream</class> |
|
| 39 |
</funding_level_0> |
|
| 40 |
</fundingtree> |
|
| 41 |
</xsl:for-each> |
|
| 42 |
</fundings> |
|
| 43 |
</xsl:template> |
|
| 44 |
</xsl:stylesheet> |
|
| 45 |
|
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg-contexts/xsl/corda_h2020_contexts.xsl | ||
|---|---|---|
| 1 |
<?xml version="1.0" encoding="UTF-8"?> |
|
| 2 |
<xsl:stylesheet version="1.0" xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:fn="http://www.w3.org/2005/xpath-functions" exclude-result-prefixes="fn"> |
|
| 3 |
|
|
| 4 |
<xsl:variable name="namespacePrefix" select="string('ec__________')"/>
|
|
| 5 |
<xsl:variable name="funderID" select="concat($namespacePrefix, '::EC')"/> |
|
| 6 |
|
|
| 7 |
<xsl:template match="/"> |
|
| 8 |
<fundingtree> |
|
| 9 |
<funder> |
|
| 10 |
<id> |
|
| 11 |
<xsl:value-of select="$funderID"/> |
|
| 12 |
</id> |
|
| 13 |
<shortname>EC</shortname> |
|
| 14 |
<name>European Commission</name> |
|
| 15 |
<jurisdiction>EU</jurisdiction> |
|
| 16 |
</funder> |
|
| 17 |
<funding_level_0> |
|
| 18 |
<id> |
|
| 19 |
<xsl:value-of select="concat($funderID, '::H2020')"/> |
|
| 20 |
</id> |
|
| 21 |
<name>H2020</name> |
|
| 22 |
<description>Horizon 2020 Framework Programme</description> |
|
| 23 |
<parent/> |
|
| 24 |
<class>ec:h2020fundings</class> |
|
| 25 |
</funding_level_0> |
|
| 26 |
</fundingtree> |
|
| 27 |
</xsl:template> |
|
| 28 |
|
|
| 29 |
</xsl:stylesheet> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/aggrDatarepoOaiSets/repoBye.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="DeleteMetaWorkflow"/> |
|
| 10 |
</ARCS> |
|
| 11 |
</NODE> |
|
| 12 |
|
|
| 13 |
<NODE name="DeleteMetaWorkflow" type="DeleteOpenaireMetaWf"> |
|
| 14 |
<DESCRIPTION>Delete the MetaWorkflow</DESCRIPTION> |
|
| 15 |
<PARAMETERS> |
|
| 16 |
<PARAM required="true" type="string" name="metaWfId" managedBy="system">$params.("META_WORKFLOW_ID")$</PARAM>
|
|
| 17 |
</PARAMETERS> |
|
| 18 |
<ARCS> |
|
| 19 |
<ARC to="DeleteMDStoreGMF"/> |
|
| 20 |
</ARCS> |
|
| 21 |
</NODE> |
|
| 22 |
|
|
| 23 |
<NODE name="DeleteMDStoreGMF" type="DeleteMDStore"> |
|
| 24 |
<DESCRIPTION>Delete the GMF mdstore</DESCRIPTION> |
|
| 25 |
<PARAMETERS> |
|
| 26 |
<PARAM required="true" type="string" name="mdstoreId" managedBy="system" category="MDSTORE_ID">$params.("orig_id")$</PARAM>
|
|
| 27 |
</PARAMETERS> |
|
| 28 |
<ARCS> |
|
| 29 |
<ARC to="DeleteMDStoreDBMF"/> |
|
| 30 |
</ARCS> |
|
| 31 |
</NODE> |
|
| 32 |
|
|
| 33 |
<NODE name="DeleteMDStoreDBMF" type="DeleteMDStore"> |
|
| 34 |
<DESCRIPTION>Delete the DBMF mdstore</DESCRIPTION> |
|
| 35 |
<PARAMETERS> |
|
| 36 |
<PARAM required="true" type="string" name="mdstoreId" managedBy="system" category="MDSTORE_ID">$params.("row_id")$</PARAM>
|
|
| 37 |
</PARAMETERS> |
|
| 38 |
<ARCS> |
|
| 39 |
<ARC to="RemoveApiExtraFields"/> |
|
| 40 |
</ARCS> |
|
| 41 |
</NODE> |
|
| 42 |
|
|
| 43 |
<NODE name="RemoveApiExtraFields" type="RemoveApiExtraFields"> |
|
| 44 |
<DESCRIPTION>Reset the extrafields of the api</DESCRIPTION> |
|
| 45 |
<PARAMETERS> |
|
| 46 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 47 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 48 |
<PARAM required="true" type="string" name="fields" managedBy="system">last_collection_total, last_collection_date, last_collection_mdId, last_aggregation_total, last_aggregation_date, last_aggregation_mdId</PARAM> |
|
| 49 |
</PARAMETERS> |
|
| 50 |
<ARCS> |
|
| 51 |
<ARC to="success"/> |
|
| 52 |
</ARCS> |
|
| 53 |
</NODE> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/aggrDatarepoOaiSets/updateDb.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="PREPARE_DB"/> |
|
| 10 |
</ARCS> |
|
| 11 |
</NODE> |
|
| 12 |
|
|
| 13 |
<NODE name="PREPARE_DB" type="ExecuteSql"> |
|
| 14 |
<DESCRIPTION>Create necessary tables</DESCRIPTION> |
|
| 15 |
<PARAMETERS> |
|
| 16 |
<PARAM name="dbProperty" type="string" managedBy="system" required="true">dnet.openaire.db.name</PARAM> |
|
| 17 |
<PARAM name="sql" type="string" managedBy="system" required="true">/eu/dnetlib/msro/openaireplus/workflows/repo-hi/sql-datacite/dataciteSets_prepareTables.sql</PARAM> |
|
| 18 |
</PARAMETERS> |
|
| 19 |
<ARCS> |
|
| 20 |
<ARC to="FETCH_SETS_FROM_MDSTORE"/> |
|
| 21 |
<ARC to="FETCH_DATAREPOS"/> |
|
| 22 |
</ARCS> |
|
| 23 |
</NODE> |
|
| 24 |
|
|
| 25 |
<NODE name="FETCH_SETS_FROM_MDSTORE" type="FetchMDStoreRecords"> |
|
| 26 |
<DESCRIPTION>Fetch records from MDStore</DESCRIPTION> |
|
| 27 |
<PARAMETERS> |
|
| 28 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("row_id")$</PARAM>
|
|
| 29 |
<PARAM required="true" type="string" name="mdFormat" managedBy="system">$params.("row_format")$</PARAM>
|
|
| 30 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">rs_epr</PARAM> |
|
| 31 |
</PARAMETERS> |
|
| 32 |
<ARCS> |
|
| 33 |
<ARC to="UPDATE_SETS_DB"/> |
|
| 34 |
</ARCS> |
|
| 35 |
</NODE> |
|
| 36 |
|
|
| 37 |
<NODE name="UPDATE_SETS_DB" type="UpdateOpenaireDb"> |
|
| 38 |
<DESCRIPTION>Update Db</DESCRIPTION> |
|
| 39 |
<PARAMETERS> |
|
| 40 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">rs_epr</PARAM> |
|
| 41 |
</PARAMETERS> |
|
| 42 |
<ARCS> |
|
| 43 |
<ARC to="FIND_MATCHES"/> |
|
| 44 |
</ARCS> |
|
| 45 |
</NODE> |
|
| 46 |
|
|
| 47 |
<NODE name="FETCH_DATAREPOS" type="QueryDb"> |
|
| 48 |
<DESCRIPTION>Fetch records by Query</DESCRIPTION> |
|
| 49 |
<PARAMETERS> |
|
| 50 |
<PARAM name="dbProperty" type="string" managedBy="system" required="true">dnet.openaire.db.name</PARAM> |
|
| 51 |
<PARAM name="sql" type="string" managedBy="system" required="true">/eu/dnetlib/msro/openaireplus/workflows/repo-hi/sql-datacite/dataciteSets_findDataRepos.sql</PARAM> |
|
| 52 |
<PARAM name="outputEprParam" type="string" managedBy="system" required="true">sql_epr</PARAM> |
|
| 53 |
</PARAMETERS> |
|
| 54 |
<ARCS> |
|
| 55 |
<ARC to="CLEAN_DATAREPOS" /> |
|
| 56 |
</ARCS> |
|
| 57 |
</NODE> |
|
| 58 |
|
|
| 59 |
<NODE name="CLEAN_DATAREPOS" type="ApplyXslt"> |
|
| 60 |
<DESCRIPTION>Transform original records in DB rows</DESCRIPTION> |
|
| 61 |
<PARAMETERS> |
|
| 62 |
<PARAM required="true" type="string" name="xsltClasspath" managedBy="system">/eu/dnetlib/msro/openaireplus/workflows/repo-hi/xslt-datacite/datacite_datarepos_2_db.xslt</PARAM> |
|
| 63 |
<PARAM required="true" type="string" name="inputEprParam" managedBy="system">sql_epr</PARAM> |
|
| 64 |
<PARAM required="true" type="string" name="outputEprParam" managedBy="system">clean_sql_epr</PARAM> |
|
| 65 |
</PARAMETERS> |
|
| 66 |
<ARCS> |
|
| 67 |
<ARC to="UPDATE_DATAREPOS_DB"/> |
|
| 68 |
</ARCS> |
|
| 69 |
</NODE> |
|
| 70 |
|
|
| 71 |
<NODE name="UPDATE_DATAREPOS_DB" type="UpdateOpenaireDb"> |
|
| 72 |
<DESCRIPTION>Update Db with cleaned datarepos</DESCRIPTION> |
|
| 73 |
<PARAMETERS> |
|
| 74 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">clean_sql_epr</PARAM> |
|
| 75 |
</PARAMETERS> |
|
| 76 |
<ARCS> |
|
| 77 |
<ARC to="FIND_MATCHES"/> |
|
| 78 |
</ARCS> |
|
| 79 |
</NODE> |
|
| 80 |
|
|
| 81 |
<NODE name="FIND_MATCHES" type="ExecuteSql" isJoin="true"> |
|
| 82 |
<DESCRIPTION>Create necessary tables</DESCRIPTION> |
|
| 83 |
<PARAMETERS> |
|
| 84 |
<PARAM name="dbProperty" type="string" managedBy="system" required="true">dnet.openaire.db.name</PARAM> |
|
| 85 |
<PARAM name="sql" type="string" managedBy="system" required="true">/eu/dnetlib/msro/openaireplus/workflows/repo-hi/sql-datacite/dataciteSets_findMatches.sql</PARAM> |
|
| 86 |
</PARAMETERS> |
|
| 87 |
<ARCS> |
|
| 88 |
<ARC to="success"/> |
|
| 89 |
</ARCS> |
|
| 90 |
</NODE> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg-contexts/xsl/croatian_csf_projects_contexts.xsl | ||
|---|---|---|
| 1 |
<?xml version="1.0" encoding="UTF-8"?> |
|
| 2 |
<xsl:stylesheet version="1.0" xmlns:xsl="http://www.w3.org/1999/XSL/Transform" |
|
| 3 |
xmlns:fn="http://www.w3.org/2005/xpath-functions" exclude-result-prefixes="fn"> |
|
| 4 |
|
|
| 5 |
<xsl:variable name="namespacePrefix" select="string('irb_hr______')"/>
|
|
| 6 |
|
|
| 7 |
<xsl:template match="/"> |
|
| 8 |
<xsl:choose> |
|
| 9 |
<xsl:when test="//csvRecord/column[@name = 'FUNDER_NAME']/text() = 'HRZZ'"> |
|
| 10 |
<fundingtree> |
|
| 11 |
<funder> |
|
| 12 |
<id> |
|
| 13 |
<xsl:value-of select="concat($namespacePrefix, '::HRZZ')"/> |
|
| 14 |
</id> |
|
| 15 |
<shortname>HRZZ</shortname> |
|
| 16 |
<name>Croatian Science Foundation (CSF)</name> |
|
| 17 |
<originalname>Hrvatska zaklada za znanost</originalname> |
|
| 18 |
<jurisdiction>HR</jurisdiction> |
|
| 19 |
</funder> |
|
| 20 |
</fundingtree> |
|
| 21 |
</xsl:when> |
|
| 22 |
<xsl:otherwise> |
|
| 23 |
<fundingtree/> |
|
| 24 |
</xsl:otherwise> |
|
| 25 |
</xsl:choose> |
|
| 26 |
</xsl:template> |
|
| 27 |
|
|
| 28 |
|
|
| 29 |
</xsl:stylesheet> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/aggrDatarepoOaiSets/collection.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="COLLECT"/> |
|
| 10 |
</ARCS> |
|
| 11 |
</NODE> |
|
| 12 |
|
|
| 13 |
<NODE name="COLLECT" type="CollectRecords"> |
|
| 14 |
<DESCRIPTION>Start Harvesting</DESCRIPTION> |
|
| 15 |
<PARAMETERS> |
|
| 16 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 17 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 18 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">collected_epr</PARAM> |
|
| 19 |
</PARAMETERS> |
|
| 20 |
<ARCS> |
|
| 21 |
<ARC to="MD_BUILDER"/> |
|
| 22 |
</ARCS> |
|
| 23 |
</NODE> |
|
| 24 |
|
|
| 25 |
<NODE name="MD_BUILDER" type="MdBuilder"> |
|
| 26 |
<DESCRIPTION>Prepare mdstore records</DESCRIPTION> |
|
| 27 |
<PARAMETERS> |
|
| 28 |
<PARAM required="true" type="string" name="inputEprParam" managedBy="system">collected_epr</PARAM> |
|
| 29 |
<PARAM required="true" type="string" name="outputEprParam" managedBy="system">store_epr</PARAM> |
|
| 30 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 31 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 32 |
</PARAMETERS> |
|
| 33 |
<ARCS> |
|
| 34 |
<ARC to="STORE"/> |
|
| 35 |
</ARCS> |
|
| 36 |
</NODE> |
|
| 37 |
|
|
| 38 |
<NODE name="STORE" type="StoreMDStoreRecords"> |
|
| 39 |
<DESCRIPTION>Store mdtore records</DESCRIPTION> |
|
| 40 |
<PARAMETERS> |
|
| 41 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("orig_id")$</PARAM>
|
|
| 42 |
<PARAM required="true" type="string" name="storingType" managedBy="system">REFRESH</PARAM> |
|
| 43 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">store_epr</PARAM> |
|
| 44 |
</PARAMETERS> |
|
| 45 |
<ARCS> |
|
| 46 |
<ARC to="UPDATE_INFO"/> |
|
| 47 |
</ARCS> |
|
| 48 |
</NODE> |
|
| 49 |
|
|
| 50 |
<NODE name="UPDATE_INFO" type="MDStoreToApiExtraField"> |
|
| 51 |
<DESCRIPTION>Update datasouce API extra fields</DESCRIPTION> |
|
| 52 |
<PARAMETERS> |
|
| 53 |
<PARAM required="true" type="string" name="mdId" managedBy="system">$params.("orig_id")$</PARAM>
|
|
| 54 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 55 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 56 |
<PARAM required="true" type="string" name="extraFieldForTotal" managedBy="system">last_collection_total</PARAM> |
|
| 57 |
<PARAM required="true" type="string" name="extraFieldForDate" managedBy="system">last_collection_date</PARAM> |
|
| 58 |
<PARAM required="true" type="string" name="extraFieldForMdId" managedBy="system">last_collection_mdId</PARAM> |
|
| 59 |
</PARAMETERS> |
|
| 60 |
<ARCS> |
|
| 61 |
<ARC to="success"/> |
|
| 62 |
</ARCS> |
|
| 63 |
</NODE> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/datacite/dataset_journal/sql/find_journal_intersection.sql | ||
|---|---|---|
| 1 |
SELECT |
|
| 2 |
h.entry AS id, |
|
| 3 |
h.datasourceid AS datasource, |
|
| 4 |
d.officialname AS name |
|
| 5 |
|
|
| 6 |
FROM hostedby_map h, datasources d |
|
| 7 |
WHERE |
|
| 8 |
h.oa_source_id = 're3data_____::r3d100010134' AND |
|
| 9 |
h.datasourceid = d.id |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/entityreg-contexts/xsl/fct_contexts.xsl | ||
|---|---|---|
| 1 |
<?xml version="1.0" encoding="UTF-8"?> |
|
| 2 |
|
|
| 3 |
<xsl:stylesheet version="1.0" |
|
| 4 |
xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:fn="http://www.w3.org/2005/xpath-functions" |
|
| 5 |
exclude-result-prefixes="fn"> |
|
| 6 |
|
|
| 7 |
<xsl:variable name="namespacePrefix" select="string('fct_________')"/>
|
|
| 8 |
<xsl:variable name="funderID" select="concat($namespacePrefix, '::FCT')"/> |
|
| 9 |
|
|
| 10 |
<xsl:template match="/"> |
|
| 11 |
<xsl:variable name="p1" select="normalize-space(.//funding/program)"/> |
|
| 12 |
<xsl:variable name="p2" select="normalize-space(.//funding/program2)"/> |
|
| 13 |
|
|
| 14 |
<fundingtree> |
|
| 15 |
<funder> |
|
| 16 |
<id> |
|
| 17 |
<xsl:value-of select="$funderID"/> |
|
| 18 |
</id> |
|
| 19 |
<shortname>FCT</shortname> |
|
| 20 |
<name>Fundação para a Ciência e a Tecnologia, I.P.</name> |
|
| 21 |
<jurisdiction>PT</jurisdiction> |
|
| 22 |
</funder> |
|
| 23 |
<xsl:if test="string-length($p1) > 0"> |
|
| 24 |
<xsl:choose> |
|
| 25 |
<xsl:when test="string-length($p2) > 0"> |
|
| 26 |
<xsl:variable name="level0" select="concat($funderID, '::', $p1)"/> |
|
| 27 |
<xsl:variable name="level1" select="concat($funderID, '::', $p1, '::', $p2)"/> |
|
| 28 |
<funding_level_1> |
|
| 29 |
<id> |
|
| 30 |
<xsl:value-of select="$level1"/> |
|
| 31 |
</id> |
|
| 32 |
<description> |
|
| 33 |
<xsl:value-of select="$p2"/> |
|
| 34 |
</description> |
|
| 35 |
<name> |
|
| 36 |
<xsl:value-of select="$p2"/> |
|
| 37 |
</name> |
|
| 38 |
<parent> |
|
| 39 |
<funding_level_0> |
|
| 40 |
<id> |
|
| 41 |
<xsl:value-of select="$level0"/> |
|
| 42 |
</id> |
|
| 43 |
<description> |
|
| 44 |
<xsl:value-of select="$p1"/> |
|
| 45 |
</description> |
|
| 46 |
<name> |
|
| 47 |
<xsl:value-of select="$p1"/> |
|
| 48 |
</name> |
|
| 49 |
<parent/> |
|
| 50 |
<class>fct:program</class> |
|
| 51 |
</funding_level_0> |
|
| 52 |
</parent> |
|
| 53 |
</funding_level_1> |
|
| 54 |
</xsl:when> |
|
| 55 |
<xsl:otherwise> |
|
| 56 |
<xsl:variable name="level0" select="concat($funderID, '::', $p1)"/> |
|
| 57 |
<funding_level_0> |
|
| 58 |
<id> |
|
| 59 |
<xsl:value-of select="$level0"/> |
|
| 60 |
</id> |
|
| 61 |
<description> |
|
| 62 |
<xsl:value-of select="$p1"/> |
|
| 63 |
</description> |
|
| 64 |
<name> |
|
| 65 |
<xsl:value-of select="$p1"/> |
|
| 66 |
</name> |
|
| 67 |
<parent/> |
|
| 68 |
<class>fct:program</class> |
|
| 69 |
</funding_level_0> |
|
| 70 |
</xsl:otherwise> |
|
| 71 |
</xsl:choose> |
|
| 72 |
</xsl:if> |
|
| 73 |
</fundingtree> |
|
| 74 |
</xsl:template> |
|
| 75 |
|
|
| 76 |
</xsl:stylesheet> |
|
| modules/dnet-openaireplus-workflows/tags/dnet-openaireplus-workflows-6.3.3/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/dataRepository/transform.wf.st | ||
|---|---|---|
| 1 |
<NODE name="SET_INFO" isStart="true" type="SetProviderInfo"> |
|
| 2 |
<DESCRIPTION>Set information about current provider</DESCRIPTION> |
|
| 3 |
<PARAMETERS> |
|
| 4 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 5 |
<PARAM required="true" type="string" name="providerName" managedBy="system">$params.("dataprovider:name")$</PARAM>
|
|
| 6 |
<PARAM required="true" type="string" name="api" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 7 |
</PARAMETERS> |
|
| 8 |
<ARCS> |
|
| 9 |
<ARC to="selectIncrementalTransformation"/> |
|
| 10 |
<ARC to="obtainParams" /> |
|
| 11 |
</ARCS> |
|
| 12 |
</NODE> |
|
| 13 |
|
|
| 14 |
<NODE name="selectIncrementalTransformation" type="IncrementalTransformation"> |
|
| 15 |
<DESCRIPTION>Decide REFRESH/INCREMENTAL transformation</DESCRIPTION> |
|
| 16 |
<PARAMETERS> |
|
| 17 |
<PARAM required="true" type="string" name="operationType" managedBy="user" function="validValues(['REFRESH','INCREMENTAL'])"></PARAM> |
|
| 18 |
</PARAMETERS> |
|
| 19 |
<ARCS> |
|
| 20 |
<ARC to="fetchOriginals"/> |
|
| 21 |
</ARCS> |
|
| 22 |
</NODE> |
|
| 23 |
|
|
| 24 |
<NODE name="fetchOriginals" type="FetchMDStoreRecords"> |
|
| 25 |
<DESCRIPTION>Fetch records from MDStore</DESCRIPTION> |
|
| 26 |
<PARAMETERS> |
|
| 27 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("harv_id")$</PARAM>
|
|
| 28 |
<PARAM required="true" type="string" name="mdFormat" managedBy="system">$params.("harv_format")$</PARAM>
|
|
| 29 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">orig_epr</PARAM> |
|
| 30 |
</PARAMETERS> |
|
| 31 |
<ARCS> |
|
| 32 |
<ARC to="transform"/> |
|
| 33 |
</ARCS> |
|
| 34 |
</NODE> |
|
| 35 |
|
|
| 36 |
<NODE name="obtainParams" type="ObtainOpenaireDataSourceParams"> |
|
| 37 |
<DESCRIPTION>Fetch records from MDStore</DESCRIPTION> |
|
| 38 |
<PARAMETERS> |
|
| 39 |
<PARAM required="true" type="string" name="providerId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 40 |
</PARAMETERS> |
|
| 41 |
<ARCS> |
|
| 42 |
<ARC to="transform"/> |
|
| 43 |
</ARCS> |
|
| 44 |
</NODE> |
|
| 45 |
|
|
| 46 |
<NODE name="transform" type="Transform" isJoin="true"> |
|
| 47 |
<DESCRIPTION>Transform original records</DESCRIPTION> |
|
| 48 |
<PARAMETERS> |
|
| 49 |
<PARAM required="true" type="string" name="ruleId" managedBy="user" category="TRANSFORMATION_RULE_ID" function="listProfiles('TransformationRuleDSResourceType', '//TITLE')"></PARAM>
|
|
| 50 |
<PARAM required="true" type="string" name="inputEprParam" managedBy="system">orig_epr</PARAM> |
|
| 51 |
<PARAM required="true" type="string" name="outputEprParam" managedBy="system">tran_epr</PARAM> |
|
| 52 |
</PARAMETERS> |
|
| 53 |
<ARCS> |
|
| 54 |
<ARC to="storeRecords"/> |
|
| 55 |
</ARCS> |
|
| 56 |
</NODE> |
|
| 57 |
|
|
| 58 |
<NODE name="storeRecords" type="StoreMDStoreRecords"> |
|
| 59 |
<DESCRIPTION>Store mdtore records</DESCRIPTION> |
|
| 60 |
<PARAMETERS> |
|
| 61 |
<PARAM required="true" type="string" name="mdId" managedBy="system" category="MDSTORE_ID">$params.("tran_id")$</PARAM>
|
|
| 62 |
<PARAM required="true" type="string" name="storingType" managedBy="system">REFRESH</PARAM> |
|
| 63 |
<PARAM required="true" type="string" name="eprParam" managedBy="system">tran_epr</PARAM> |
|
| 64 |
</PARAMETERS> |
|
| 65 |
<ARCS> |
|
| 66 |
<ARC to="UPDATE_INFO"/> |
|
| 67 |
</ARCS> |
|
| 68 |
</NODE> |
|
| 69 |
|
|
| 70 |
<NODE name="UPDATE_INFO" type="MDStoreToApiExtraField"> |
|
| 71 |
<DESCRIPTION>Update datasouce API extra fields</DESCRIPTION> |
|
| 72 |
<PARAMETERS> |
|
| 73 |
<PARAM required="true" type="string" name="mdId" managedBy="system">$params.("tran_id")$</PARAM>
|
|
| 74 |
<PARAM required="true" type="string" name="datasourceId" managedBy="system">$params.("dataprovider:id")$</PARAM>
|
|
| 75 |
<PARAM required="true" type="string" name="datasourceInterface" managedBy="system">$params.("dataprovider:interface")$</PARAM>
|
|
| 76 |
<PARAM required="true" type="string" name="extraFieldForTotal" managedBy="system">last_aggregation_total</PARAM> |
|
| 77 |
<PARAM required="true" type="string" name="extraFieldForDate" managedBy="system">last_aggregation_date</PARAM> |
|
| 78 |
<PARAM required="true" type="string" name="extraFieldForMdId" managedBy="system">last_aggregation_mdId</PARAM> |
|
Also available in: Unified diff
[maven-release-plugin] copy for tag dnet-openaireplus-workflows-6.3.3