EDIT

package eu.etaxonomy.cdm.io.operation;

import java.util.Arrays;

import java.util.List;

import org.apache.log4j.Logger;

import org.springframework.stereotype.Component;

import eu.etaxonomy.cdm.io.common.CdmImportBase;

import eu.etaxonomy.cdm.io.common.DefaultImportState;

import eu.etaxonomy.cdm.io.operation.config.CacheUpdaterConfigurator;

import eu.etaxonomy.cdm.model.agent.AgentBase;

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

import eu.etaxonomy.cdm.model.description.DescriptionBase;

import eu.etaxonomy.cdm.model.description.DescriptiveDataSet;

import eu.etaxonomy.cdm.model.description.FeatureTree;

import eu.etaxonomy.cdm.model.description.PolytomousKey;

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

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

import eu.etaxonomy.cdm.model.molecular.Sequence;

import eu.etaxonomy.cdm.model.name.TaxonName;

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

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

import eu.etaxonomy.cdm.model.reference.Reference;

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

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

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

import eu.etaxonomy.cdm.model.term.TermBase;

import eu.etaxonomy.cdm.model.term.TermVocabulary;

@Component

public class CacheUpdater extends CdmImportBase<CacheUpdaterConfigurator, DefaultImportState<CacheUpdaterConfigurator>> {

    private static final long serialVersionUID = -1410600568024821771L;

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

	@Override

	protected void doInvoke(DefaultImportState<CacheUpdaterConfigurator> state) {

		CacheUpdaterConfigurator config = state.getConfig();

		if (config.getClassList() == null || config.getClassList().isEmpty()){

			//!! not yet implemented

			logger.warn("Create class list from boolean values is not yet implemented for cache updater");

			createClassListFromBoolean();

		}

		//handle class list

		handleClassList(config.getClassList());

		return;

	}

	private boolean handleClassList(List<Class<? extends IdentifiableEntity>> classList) {

		boolean result = true;

		for (Class<? extends IdentifiableEntity> clazz : classList){

			//WE need to separate classes , because hibernate

			//returns multiple values for service.count() for e.g. IdentifableEntity.class

			//which leads to an exception

			if (! handleMultiTableClasses(clazz)){

				result &= this.handleSingleTableClass(clazz);

			}

		}

		return result;

	}

	private boolean handleMultiTableClasses(Class<? extends IdentifiableEntity> clazz) {

		if (clazz.isAssignableFrom(IdentifiableEntity.class)){

            @SuppressWarnings("rawtypes")

            List list = Arrays.asList(new Class[]{

					DescriptionBase.class, IdentifiableMediaEntity.class,

					Media.class, Sequence.class,

					TaxonBase.class, TaxonName.class,

					Classification.class, TermBase.class

					});

			handleClassList(list);

		}else if (clazz.isAssignableFrom(IdentifiableMediaEntity.class)){

			@SuppressWarnings("rawtypes")

            List list = Arrays.asList(new Class[]{AgentBase.class, Collection.class, Reference.class, SpecimenOrObservationBase.class});

			handleClassList(list);

		}else if (clazz.isAssignableFrom(TermBase.class)){

			@SuppressWarnings("rawtypes")

            List list = Arrays.asList(new Class[]{DefinedTermBase.class, FeatureTree.class, TermVocabulary.class });

			handleClassList(list);

		}else{

			return false;

		}

		return true;

	}

	private boolean handleSingleTableClass(Class<? extends IdentifiableEntity> clazz) {

		if (clazz == null){

		    return true;

		}

	    logger.info("Updating class " + clazz.getSimpleName() + " ...");

		try {

			//TermBase

			if (DefinedTermBase.class.isAssignableFrom(clazz)){

				getTermService().updateCaches((Class) clazz, null, null, null);

			}else if (TermVocabulary.class.isAssignableFrom(clazz)){

				getVocabularyService().updateCaches((Class) clazz, null, null, null);

			}

			//DescriptionBase

			else if (DescriptionBase.class.isAssignableFrom(clazz)){

				getDescriptionService().updateCaches((Class) clazz, null, null, null);

			}

			//Media

			else if (Media.class.isAssignableFrom(clazz)){

				getMediaService().updateCaches((Class) clazz, null, null, null);

			}//TaxonBase

			else if (TaxonBase.class.isAssignableFrom(clazz)){

				getTaxonService().updateCaches((Class) clazz, null, null, null);

			}

			//IdentifiableMediaEntity

			else if (AgentBase.class.isAssignableFrom(clazz)){

				getAgentService().updateCaches((Class) clazz, null, null, null);

			}else if (Collection.class.isAssignableFrom(clazz)){

				getCollectionService().updateCaches((Class) clazz, null, null, null);

			}else if (Reference.class.isAssignableFrom(clazz)){

				getReferenceService().updateCaches((Class) clazz, null, null, null);

			//Occurrence

			}else if (SpecimenOrObservationBase.class.isAssignableFrom(clazz)){

				getOccurrenceService().updateCaches((Class) clazz, null, null, null);

			}

//			//Sequence  //currently not identifiable and therefore has not caches

//			else if (Sequence.class.isAssignableFrom(clazz)){

//				//TODO misuse TaxonService for sequence update, use sequence service when it exists

//				getTaxonService().updateTitleCache((Class) clazz, null, null, null);

//			}

			//TaxonName

			else if (TaxonName.class.isAssignableFrom(clazz)){

				getNameService().updateCaches((Class) clazz, null, null, null);

			}

			//Classification

			else if (Classification.class.isAssignableFrom(clazz)){

				getClassificationService().updateCaches((Class) clazz, null, null, null);

			}

			//Polytomous Key

            else if (PolytomousKey.class.isAssignableFrom(clazz)){

                getPolytomousKeyService().updateCaches((Class) clazz, null, null, null);

            }

            //DescriptiveDataSet

            else if (DescriptiveDataSet.class.isAssignableFrom(clazz)){

                getDescriptiveDataSetService().updateCaches((Class) clazz, null, null, null);

            }

            //FeatureTree

            else if (FeatureTree.class.isAssignableFrom(clazz)){

                getFeatureTreeService().updateCaches((Class) clazz, null, null, null);

            }

			//unknown class

			else {

				String warning = "Unknown identifable entity subclass + " + clazz.getName();

				logger.error(warning);

				return false;

			}

			return true;

		} catch (Exception e) {

			String warning = "Exception occurred when trying to update class + " + clazz.getName();

			warning += " Exception was: " + e.getMessage();

			logger.error(warning);

			e.printStackTrace();

			return false;

		}

	}

	private void createClassListFromBoolean() {

		logger.warn("Create class list from boolean not yet implemented. Can't run cache updater");

	}

// ************* inherited form CdmIoBase but not needed here ********************/

	@Override

	protected boolean doCheck(DefaultImportState<CacheUpdaterConfigurator> state) {

		//not needed here

		return false;

	}

	@Override

	protected boolean isIgnore(DefaultImportState<CacheUpdaterConfigurator> state) {

		//not needed here

		return false;

	}

}