EDIT

// $Id$

/**

 * Copyright (C) 2007 EDIT

 * European Distributed Institute of Taxonomy 

 * http://www.e-taxonomy.eu

 * 

 * The contents of this file are subject to the Mozilla Public License Version 1.1

 * See LICENSE.TXT at the top of this package for the full license terms.

 */

package eu.etaxonomy.cdm.api.service;

import java.util.ArrayList;

import java.util.List;

import org.apache.log4j.Logger;

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

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Propagation;

import org.springframework.transaction.annotation.Transactional;

import eu.etaxonomy.cdm.api.service.pager.Pager;

import eu.etaxonomy.cdm.api.service.pager.impl.DefaultPagerImpl;

import eu.etaxonomy.cdm.model.common.DefinedTermBase;

import eu.etaxonomy.cdm.model.location.WaterbodyOrCountry;

import eu.etaxonomy.cdm.model.media.Media;

import eu.etaxonomy.cdm.model.taxon.TaxonBase;

import eu.etaxonomy.cdm.model.occurrence.DerivationEvent;

import eu.etaxonomy.cdm.model.occurrence.DeterminationEvent;

import eu.etaxonomy.cdm.model.occurrence.SpecimenOrObservationBase;

import eu.etaxonomy.cdm.persistence.dao.common.IDefinedTermDao;

import eu.etaxonomy.cdm.persistence.dao.occurrence.IOccurrenceDao;

import eu.etaxonomy.cdm.persistence.query.OrderHint;

/**

 * @author a.babadshanjan

 * @created 01.09.2008

 */

@Service

@Transactional(propagation = Propagation.SUPPORTS, readOnly = true)

public class OccurrenceServiceImpl extends IdentifiableServiceBase<SpecimenOrObservationBase,IOccurrenceDao> implements IOccurrenceService {

	static private final Logger logger = Logger.getLogger(OccurrenceServiceImpl.class);

	@Autowired

	private IDefinedTermDao definedTermDao;	

	public OccurrenceServiceImpl() {

		logger.debug("Load OccurrenceService Bean");

	}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.cdm.api.service.IIdentifiableEntityService#generateTitleCache()

	 */

	public void generateTitleCache() {

		// TODO Auto-generated method stub

		logger.warn("Not yet implemented");

	}

	/**

	 * FIXME Candidate for harmonization

	 * move to termService

	 */

	public WaterbodyOrCountry getCountryByIso(String iso639) {

		return this.definedTermDao.getCountryByIso(iso639);

	}

	/**

	 * FIXME Candidate for harmonization

	 * move to termService

	 */

	public List<WaterbodyOrCountry> getWaterbodyOrCountryByName(String name) {

		List<? extends DefinedTermBase> terms = this.definedTermDao.getDefinedTermByRepresentationText(name, WaterbodyOrCountry.class);

		List<WaterbodyOrCountry> countries = new ArrayList<WaterbodyOrCountry>();

		for (int i=0;i<terms.size();i++){

			countries.add((WaterbodyOrCountry)terms.get(i));

		}

		return countries;

	}

	@Autowired

	protected void setDao(IOccurrenceDao dao) {

		this.dao = dao;

	}

	public Pager<DerivationEvent> getDerivationEvents(SpecimenOrObservationBase occurence, Integer pageSize,Integer pageNumber, List<String> propertyPaths) {

        Integer numberOfResults = dao.countDerivationEvents(occurence);

		List<DerivationEvent> results = new ArrayList<DerivationEvent>();

		if(numberOfResults > 0) { // no point checking again

			results = dao.getDerivationEvents(occurence, pageSize, pageNumber,propertyPaths); 

		}

		return new DefaultPagerImpl<DerivationEvent>(pageNumber, numberOfResults, pageSize, results);

	}

	public Pager<DeterminationEvent> getDeterminations(SpecimenOrObservationBase occurrence, TaxonBase taxonBase, Integer pageSize,Integer pageNumber, List<String> propertyPaths) {

        Integer numberOfResults = dao.countDeterminations(occurrence, taxonBase);

		List<DeterminationEvent> results = new ArrayList<DeterminationEvent>();

		if(numberOfResults > 0) { // no point checking again

			results = dao.getDeterminations(occurrence,taxonBase, pageSize, pageNumber, propertyPaths); 

		}

		return new DefaultPagerImpl<DeterminationEvent>(pageNumber, numberOfResults, pageSize, results);

	}

	public Pager<Media> getMedia(SpecimenOrObservationBase occurence,Integer pageSize, Integer pageNumber, List<String> propertyPaths) {

        Integer numberOfResults = dao.countMedia(occurence);

		List<Media> results = new ArrayList<Media>();

		if(numberOfResults > 0) { // no point checking again

			results = dao.getMedia(occurence, pageSize, pageNumber, propertyPaths); 

		}

		return new DefaultPagerImpl<Media>(pageNumber, numberOfResults, pageSize, results);

	}

	public Pager<SpecimenOrObservationBase> list(Class<? extends SpecimenOrObservationBase> type, TaxonBase determinedAs, Integer pageSize, Integer pageNumber,	List<OrderHint> orderHints, List<String> propertyPaths) {

		Integer numberOfResults = dao.count(type,determinedAs);

		List<SpecimenOrObservationBase> results = new ArrayList<SpecimenOrObservationBase>();

		pageNumber = pageNumber == null ? 0 : pageNumber;

		if(numberOfResults > 0) { // no point checking again

			Integer start = pageSize == null ? 0 : pageSize * pageNumber;

			results = dao.list(type,determinedAs, pageSize, start, orderHints,propertyPaths);

		}

		return new DefaultPagerImpl<SpecimenOrObservationBase>(pageNumber, numberOfResults, pageSize, results);	}

}