D-Net

package eu.dnetlib.goldoa.service.dao;

import eu.dnetlib.goldoa.domain.BankAccount;

import eu.dnetlib.goldoa.domain.Publisher;

import org.apache.log4j.Logger;

import org.hibernate.criterion.MatchMode;

import org.hibernate.criterion.Restrictions;

import org.springframework.stereotype.Repository;

import java.math.BigInteger;

import java.util.List;

/**

 * Created by antleb on 3/13/15.

 */

@Repository

public class PublisherDAO extends AbstractDao<String,Publisher>{

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

	@SuppressWarnings("unchecked")

	public List<Object> search(String term) {

		return createEntityCriteria().add(Restrictions.

				ilike("name",term, MatchMode.ANYWHERE)).list();

	}

	@SuppressWarnings("unchecked")

	public Publisher getPublisher(String id) {

		List<Publisher> rs =  createEntityCriteria()

				.add(Restrictions.ilike("id", id)).list();

		if(rs.size() == 0)

			return null;

		return rs.get(0);

	}

	public Publisher savePublisher(Publisher publisher) {

		if(publisher.getBankAccount() == null) {

			BigInteger id = getBankId();

			publisher.setBankAccount(new BankAccount(id,null, getBankAddress().toString(), null, null, null));

		}

		Publisher p = getPublisher(publisher.getId());

		Publisher publisher_merged = null;

		if(p!=null)

			publisher_merged = (Publisher) getSession().merge(publisher);

		else

			persist(publisher);

		return publisher;

	}

    public BigInteger getBankAddress() {

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

    }

	public BigInteger getBankId() {

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

	}

    @SuppressWarnings("unchecked")

    public Publisher getPublisherByName(String name) {

		List<Publisher> rs = (List<Publisher>) createEntityCriteria()

				.add(Restrictions.ilike("name", name)).list();

		if(rs.size() > 0 )

			return rs.get(0);

		return null;

    }

}