D-Net

package eu.dnetlib.goldoa.service.dao;

import eu.dnetlib.goldoa.domain.*;

import eu.dnetlib.goldoa.service.PublicationManagerImpl;

import eu.dnetlib.goldoa.service.UserManagerImpl;

import org.apache.commons.codec.digest.DigestUtils;

import org.apache.log4j.Logger;

import org.hibernate.criterion.Restrictions;

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

import org.springframework.jdbc.core.BatchPreparedStatementSetter;

import org.springframework.stereotype.Repository;

import javax.sql.DataSource;

import java.math.BigInteger;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Types;

import java.util.ArrayList;

import java.util.List;

@Repository

public class PublicationDAO extends AbstractDao<String,Publication>{

	private static Logger logger = Logger.getLogger(PublicationDAO.class);

	@SuppressWarnings("unchecked")

	public Publication getPublication(final String publicationId) {

        List<Publication> ps = createEntityCriteria().add(Restrictions.eq("id",publicationId)).list();

        if(ps.size() > 0)

            return ps.get(0);

        return null;

	}

	public Publication savePublication(Publication publication) {

		for(Author a : publication.getAuthors())

			a.setId(DigestUtils.md5Hex(a.getFirstname()+ a.getLastname() + a.getEmail() +

					(a.getOrganization()!=null?a.getOrganization().getId():"") +

					(a.getDepartment()!=null?a.getDepartment():"")

			) + publication.getId());

		Publication p = getPublication(publication.getId());

		Publication pub_merged = null;

		if(p!=null)

			pub_merged = (Publication) getSession().merge(publication);

		else

			persist(publication);

		return publication;

	}

	public BigInteger generateIdentifierID() {

		return (BigInteger) getSession().createSQLQuery("select nextval('identifier_id_seq') as id").list().get(0);

	}

}