D-Net

package eu.dnetlib.goldoa.service.dao;

import eu.dnetlib.goldoa.domain.Author;

import eu.dnetlib.goldoa.domain.Publication;

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

import org.apache.log4j.Logger;

import org.hibernate.criterion.Restrictions;

import org.springframework.stereotype.Repository;

import java.math.BigInteger;

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);

	}

}