D-Net

import eu.dnetlib.repo.manager.service.controllers.RepositoryApi;

import org.springframework.beans.factory.annotation.Autowired;

        if(repository.getContactEmail().equals("null"))

            repository.setContactEmail("");

        if(repository.getDescription().equals("null"))

            repository.setDescription("");

        if(repository.getEnglishName().equals("null"))

            repository.setEnglishName("");

        if(repository.getLogoUrl().equals("null"))

            repository.setLogoUrl("");

        if(repository.getOfficialName().equals("null"))

            repository.setOfficialName("");

        repository.setTypology(datasource.get("platform").toString());

        repository.setDatasourceClass(datasource.get("typology").toString());

        //TODO change organization to list

        repository.setOrganization( ((JSONArray)datasource.get("organizations")).getJSONObject(0).get("legalname").toString());

        String countryCode = ((JSONArray)datasource.get("organizations")).getJSONObject(0).get("country").toString();

        repository.setCountryCode(countryCode);

package eu.dnetlib.repo.manager.service.controllers;

import eu.dnetlib.domain.data.PiwikInfo;

import eu.dnetlib.utils.md5.MD5;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.jdbc.core.RowMapper;

import org.springframework.stereotype.Component;

import org.springframework.web.bind.annotation.PathVariable;

import javax.annotation.PostConstruct;

import javax.sql.DataSource;

import java.security.NoSuchAlgorithmException;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Types;

import java.util.List;

@Component

public class PiWikApiImpl implements PiWikApi{

    @Autowired

    @Qualifier("repomanager.dataSource")

    private DataSource dataSource;

    private static final org.apache.log4j.Logger LOGGER = org.apache.log4j.Logger

            .getLogger(PiWikApiImpl.class);

    private final static String GET_PIWIK_SITE = "select repositoryid, siteid, authenticationtoken, creationdate, requestorname, requestoremail, validated, validationdate, comment, repositoryname, country from piwik_site where repositoryid = ?;";

    private final static String INSERT_PIWIK_INFO = "insert into piwik_site (repositoryid, siteid, creationdate, requestorname, requestoremail, validated, repositoryname, country, authenticationtoken) values (?, ?, now(), ?, ?, ?, ?, ?, ?)";

    private final static String GET_PIWIK_SITES = "select repositoryid, siteid, authenticationtoken, creationdate, requestorname, requestoremail, validated, validationdate, comment, repositoryname, country from piwik_site order by repositoryname";

    private final static String APPROVE_PIWIK_SITE = "update piwik_site set approved=true, approvaldate=now() where repositoryid = ?;";

    private RowMapper<PiwikInfo> piwikRowMapper = (rs, i) -> new PiwikInfo(rs.getString("repositoryid"), getOpenaireId(rs.getString("repositoryid")), rs.getString("repositoryname"), rs.getString("country"),

            rs.getString("siteid"), rs.getString("authenticationtoken"), rs.getTimestamp("creationdate"), rs.getString("requestorname"), rs.getString("requestoremail"),

            rs.getBoolean("validated"), rs.getTimestamp("validationdate"), rs.getString("comment"));

    @Override

    public PiwikInfo getPiwikSiteForRepo(@PathVariable("repositoryId") String repositoryId) {

        return new JdbcTemplate(dataSource).queryForObject(GET_PIWIK_SITE, new String[]{repositoryId}, new int[]{Types.VARCHAR}, piwikRowMapper);

    }

    @Override

    public PiwikInfo savePiwikInfo(PiwikInfo piwikInfo) {

        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);

        jdbcTemplate.update(INSERT_PIWIK_INFO, new Object[]{piwikInfo.getRepositoryId(), piwikInfo.getSiteId(), piwikInfo.getRequestorName(),

                        piwikInfo.getRequestorEmail(), piwikInfo.isValidated(), piwikInfo.getRepositoryName(), piwikInfo.getCountry(), piwikInfo.getAuthenticationToken()},

                new int[]{Types.VARCHAR, Types.VARCHAR, Types.VARCHAR, Types.VARCHAR, Types.BOOLEAN, Types.VARCHAR, Types.VARCHAR, Types.VARCHAR});

        return piwikInfo;

    }

    @Override

    public List<PiwikInfo> getPiwikSitesForRepos() {

        LOGGER.debug("Getting piwik sites for repos! ");

        return new JdbcTemplate(dataSource).query(GET_PIWIK_SITES, piwikRowMapper);

    }

    @Override

    public void approvePiwikSite(@PathVariable("repositoryId") String repositoryId) {

        new JdbcTemplate(dataSource).update(APPROVE_PIWIK_SITE, new Object[] {repositoryId}, new int[] {Types.VARCHAR});

    }

    @Override

    public String getOpenaireId(@PathVariable("repositoryId") String repositoryid) {

        try {

            if (repositoryid != null && repositoryid.contains("::"))

                return repositoryid.split("::")[0] + "::" + MD5.encrypt2Hex(repositoryid.split("::")[1]);

            else

                return null;

        } catch (NoSuchAlgorithmException e) {

            e.printStackTrace();

        }

        return null;

    }

}

        int page = 0;

        int size = 50;

    @RequestMapping(value = "/getRepositoriesByCountry/{country}/{mode}", method = RequestMethod.GET,

    void addRepository(Repository repository) throws JSONException;

    @RequestMapping(value = "/updateTimezone", method = RequestMethod.POST,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    String updateTimezone(String id, String timezone);

    @RequestMapping(value = "/updateTypology", method = RequestMethod.POST,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    String updateTypology(String id, String typology);

    @RequestMapping(value = "/updateTypology", method = RequestMethod.POST,

            produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    String updateLogoUrl(String id, String logoUrl);

    String getCountryName(String countryCode);

    private Map<String,String> countriesMap = new HashMap<>();

    private Map<String,String> inverseCountriesMap = new HashMap<>();

        Country[] countries = getCountries();

        for(Country c: countries){

            countriesMap.put(c.getName(),c.getCode());

            inverseCountriesMap.put(c.getCode(),c.getName());

        }

                                                     @PathVariable("mode") String mode) throws JSONException {

        int page = 0;

        int size = 100;

        String countryCode = countriesMap.get(country);

            resultSet.addAll(repos);

        for(Repository r : resultSet)

            r.setCountryName(getCountryName(r.getCountryCode()));

        List<Repository> repos = Converter.jsonToRepositoryList(new JSONArray(rs));

        for(Repository r : repos)

            r.setCountryName(getCountryName(r.getCountryCode()));

        return repos;

        Repository repo = Converter.jsonToRepositoryObject(new JSONObject(rs));

        if (repo != null)

            repo.setCountryName(getCountryName(repo.getCountryCode()));

        return repo;

        List<Repository> repos = Converter.jsonToRepositoryList(new JSONArray(rs));

        for(Repository r : repos)

            r.setCountryName(getCountryName(r.getCountryCode()));

        return repos;

    public void addRepository(@RequestBody Repository repository) throws JSONException {

        LOGGER.debug("Adding repository with name : " + repository.getOfficialName());

        LOGGER.debug("Repository equals : " + Converter.repositoryObjectToJson(repository));

        restTemplate.postForObject(uriComponents.toUri(),Converter.repositoryObjectToJson(repository),String.class);

    public String updateTimezone(@RequestParam(value = "id")   String id,

                                 @RequestParam(value = "timezone")  String timezone) {

        UriComponents uriComponents = UriComponentsBuilder

                .fromHttpUrl(baseAddress + "/ds/update/timezone")

                .queryParam("dsId",id)

                .queryParam("timezone",timezone)

                .build().encode();

        return restTemplate.postForObject(uriComponents.toUri(), null,String.class);

    }

    @Override

    public String updateTypology(@RequestParam(value = "id")   String id,

                                 @RequestParam(value = "typology")  String typology) {

        UriComponents uriComponents = UriComponentsBuilder

                .fromHttpUrl(baseAddress + "/ds/update/typology")

                .queryParam("dsId",id)

                .queryParam("typology",typology)

                .build().encode();

        return restTemplate.postForObject(uriComponents.toUri(), null,String.class);

    }

    @Override

    public String updateLogoUrl(@RequestParam(value = "id")   String id,

                                @RequestParam(value = "logoUrl") String logoUrl) {

        UriComponents uriComponents = UriComponentsBuilder

                .fromHttpUrl(baseAddress + "/ds/update/logourl")

                .queryParam("dsId",id)

                .queryParam("logourl",logoUrl)

                .build().encode();

        return restTemplate.postForObject(uriComponents.toUri(), null,String.class);

    }

    @Override

    @Override

    public String getCountryName(String countryCode) {

        return inverseCountriesMap.get(countryCode);

    }

package eu.dnetlib.repo.manager.service.controllers;

import eu.dnetlib.domain.data.PiwikInfo;

import org.springframework.http.MediaType;

import org.springframework.web.bind.annotation.*;

import java.util.List;

@RestController

@RequestMapping(value = "/piwi")

public interface PiWikApi {

    @RequestMapping(value = "/getPiwikSiteForRepo/{repositoryId}" , method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    PiwikInfo getPiwikSiteForRepo(String repositoryId);

    @RequestMapping(value = "/savePiwikInfo" , method = RequestMethod.POST,produces = MediaType.APPLICATION_JSON_VALUE)

    PiwikInfo savePiwikInfo(@RequestBody PiwikInfo piwikInfo);

    @RequestMapping(value = "/getPiwikSitesForRepos" , method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_VALUE)

    List<PiwikInfo> getPiwikSitesForRepos();

    @RequestMapping(value = "/approvePiwikSite/{repositoryId}" , method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    void approvePiwikSite(String repositoryId);

    @RequestMapping(value = "/getOpenaireId/{repositoryid}" , method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_VALUE)

    @ResponseBody

    String getOpenaireId(String repositoryid);

}

       xmlns:task="http://www.springframework.org/schema/task" xmlns:tx="http://www.springframework.org/schema/tx"

	http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

    <import resource="classpath:META-INF/cxf/cxf.xml"/>

    <!-- <import resource="classpath:META-INF/cxf/cxf-extension-soap.xml"/>-->

    <import resource="classpath:META-INF/cxf/cxf-extension-jaxws.xml"/>

    <import resource="classpath:META-INF/cxf/cxf-servlet.xml"/>

    <import resource="classpath*:/cxf.xml"/>

    <import resource="classpath*:/eu/dnetlib/repos/ehcacher/springContext-repos-ehcacher.xml"/>

    <import resource="classpath*:/eu/dnetlib/soap/cxf/applicationContext-eprbuilders.xml"/>

    <import resource="classpath*:/eu/dnetlib/clients/ws/springContext-locatorFactory.xml"/>

    <import resource="classpath*:/eu/dnetlib/users/springContext-users-ldap.xml"/>

    <import resource="classpath*:/gr/uoa/di/driver/util/springContext-locators.xml"/>

    <import resource="classpath*:/gr/uoa/di/driver/app/springContext-lookupFactory.xml"/>

    <import resource="classpath*:/gr/uoa/di/driver/app/springContext-lookupClients.xml"/>

    <import resource="classpath*:/eu/dnetlib/enabling/hcm/springContext-hcmService.xml"/>

    <import resource="classpath*:/gr/uoa/di/driver/app/springContext-commons.xml"/>

    <import resource="classpath*:/gr/uoa/di/driver/app/springContext-registrator.xml"/>

    <import resource="classpath*:/eu/dnetlib/repos/springContext-repos-dms-cached.xml"/>

    <context:property-placeholder location="classpath*:/eu/**/application.properties" />

    <tx:annotation-driven transaction-manager="txManager"/>

    <bean class="eu.dnetlib.repo.manager.service.config.CascadingPropertyLoader" id="propertyLoader">

        <property name="order" value="2" />

        <property name="properties">

            <bean class="eu.dnetlib.conf.WebappContextProperyFactory">

                <property name="propertyFetcher">

                    <bean class="eu.dnetlib.conf.PropertyFetcher" />

                </property>

            </bean>

        </property>

        <property name="ignoreUnresolvablePlaceholders" value="true" />

        <property name="locations">

            <list>

                <value>classpath*:/gr/**/springContext-*.properties</value>

                <value>classpath*:/eu/**/springContext-*.properties</value>

                <value>classpath*:/eu/dnetlib/repo/manager/service/email-texts.properties</value>

                <value>classpath*:dnet-site-wizard.properties</value>

                <value>classpath*:dnet-site-override.properties</value>

                <value>classpath*:dnet-wizard.properties</value>

                <value>classpath*:dnet-override.properties</value>

                <value>classpath*:dnet-validator-wizard.properties</value>

                <value>classpath*:dnet-validator-override.properties</value>

                <value>classpath*:dnet-site-force-override.properties</value>

                <value>classpath*:dnet-force-override.properties</value>

            </list>

        </property>

    </bean>

    <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

        <property name="dataSource" ref="repomanager.dataSource"/>

    </bean>

       xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"

       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

    <bean id="repomanager.dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">

        <property name="driverClassName" value="${repomanager.db.driverClassName}" />

        <property name="url" value="${repomanager.db.url}" />

        <property name="username" value="${repomanager.db.username}" />

        <property name="password" value="${repomanager.db.password}" />

        <property name="maxIdle" value="10" />

        <property name="maxActive" value="100" />

        <property name="maxWait" value="10000" />

        <property name="validationQuery" value="SELECT 1;" />

        <property name="testOnBorrow" value="true" />

        <property name="testOnReturn" value="true" />

        <property name="testWhileIdle" value="true" />

        <property name="timeBetweenEvictionRunsMillis" value="1200000" />

        <property name="minEvictableIdleTimeMillis" value="1800000" />

        <property name="numTestsPerEvictionRun" value="5" />

        <property name="poolPreparedStatements" value="true" />

        <property name="defaultAutoCommit" value="true" />

    </bean>

    <tx:annotation-driven transaction-manager="txManager"/>

    <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

        <property name="dataSource" ref="repomanager.dataSource"/>

    </bean>