EDIT

/**

* 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.taxeditor.bulkeditor.input;

import java.util.ArrayList;

import java.util.Collections;

import java.util.Comparator;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import java.util.UUID;

import eu.etaxonomy.cdm.api.conversation.ConversationHolder;

import eu.etaxonomy.cdm.api.service.config.DeleteConfiguratorBase;

import eu.etaxonomy.cdm.api.service.config.IIdentifiableEntityServiceConfigurator;

import eu.etaxonomy.cdm.api.service.exception.ReferencedObjectUndeletableException;

import eu.etaxonomy.cdm.hibernate.HibernateProxyHelper;

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

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

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

import eu.etaxonomy.cdm.strategy.merge.IMergable;

import eu.etaxonomy.cdm.strategy.merge.MergeException;

import eu.etaxonomy.taxeditor.annotatedlineeditor.IEntityCreator;

import eu.etaxonomy.taxeditor.annotatedlineeditor.IEntityPersistenceService;

import eu.etaxonomy.taxeditor.bulkeditor.BulkEditorQuery;

import eu.etaxonomy.taxeditor.bulkeditor.IBulkEditorSortProvider;

import eu.etaxonomy.taxeditor.bulkeditor.input.sortprovider.CdmBaseSortProvider;

import eu.etaxonomy.taxeditor.bulkeditor.input.sortprovider.TitleCacheComparator;

import eu.etaxonomy.taxeditor.bulkeditor.internal.TaxeditorBulkeditorPlugin;

import eu.etaxonomy.taxeditor.editor.CdmEntitySessionInput;

import eu.etaxonomy.taxeditor.model.MessagingUtils;

import eu.etaxonomy.taxeditor.store.CdmStore;

/**

 * @author p.ciardelli

 * @created 25.06.2009

 * @version 1.0

 * @param <T>

 */

public abstract class AbstractBulkEditorInput<T extends CdmBase> extends CdmEntitySessionInput implements

    IEntityPersistenceService<T> {

	private UUID entityUuid;

	private List<T> model = new ArrayList<>();

	private Map<T, DeleteConfiguratorBase> toDelete = new HashMap<>();

	private List<T> saveCandidates = new ArrayList<>();

	private List<T> mergeCandidates = new ArrayList<>();

	private T mergeTarget = null;

	private IEntityCreator<T> entityCreator;

	private final ConversationHolder conversation;

	public AbstractBulkEditorInput() {

	    super(true);

	    this.conversation = CdmStore.createConversation();

	}

	static public AbstractBulkEditorInput NewInstance(BulkEditorInputType inputType) {

		return BulkEditorInputType.getInput(inputType);

	}

	public static AbstractBulkEditorInput NewInstance(IdentifiableEntity entity) {

		BulkEditorInputType inputType = BulkEditorInputType.getByType(entity.getClass());

		AbstractBulkEditorInput editorInput = NewInstance(inputType);

		editorInput.setEntityUuid(entity.getUuid());

		return editorInput;

	}

    public abstract String getName();

	protected abstract List<T> listEntities(IIdentifiableEntityServiceConfigurator configurator);

	protected abstract T loadEntity(UUID entityUuid);

	public void setMergeTarget(T t){

	    mergeTarget = t;

	}

    public List<T> getMergeCandidates() {

        return mergeCandidates;

    }

    public T getMergeTarget() {

        return mergeTarget;

    }

	public void removeMergeTarget(){

	    mergeTarget = null;

	}

	public void addMergeCandidate(T t){

	    mergeCandidates.add(t);

	}

	public void removeMergeCandidate(T t){

	    mergeCandidates.remove(t);

	}

    public void addToDelete(T t, DeleteConfiguratorBase config) {

        toDelete.put(t, config);

    }

    public void addSaveCandidate(T t){

        saveCandidates.add(t);

    }

	private void setEntityUuid(UUID entityUuid){

		this.entityUuid = entityUuid;

	}

	public UUID getEntityUuid() {

		return entityUuid;

	}

	public void performSearch(final BulkEditorQuery bulkEditorQuery) {

		List<T> entityList = new ArrayList<T>();

		if(getEntityUuid() != null){

			T entity = loadEntity(getEntityUuid());

			entityList.add(entity);

			model = entityList;

		}

		else if(bulkEditorQuery != null){

			IIdentifiableEntityServiceConfigurator configurator = bulkEditorQuery.getSearchConfigurator();

			Comparator queryComparator = (bulkEditorQuery.getComparator() != null) ? bulkEditorQuery.getComparator() : new TitleCacheComparator();

			entityList = listEntities(configurator);

			Collections.sort(entityList, queryComparator);

		}

		model = entityList;

	}

	public boolean isMergingEnabled() {

		return false;

	}

	public boolean isConvertingEnabled() {

		return false;

	}

	public boolean isMarkerTypeEditingEnabled(MarkerType markerType) {

		return false;

	}

	/** {@inheritDoc} */

	@Override

    public boolean merge(T entity, T mergeTarget) {

		if (entity instanceof IMergable) {

			try {

				CdmStore.getCommonService().merge(mergeTarget.getUuid(), entity.getUuid(), (Class<? extends CdmBase>)entity.getClass());

			} catch (MergeException e) {

				MessagingUtils.errorDialog("Bulk Editor Merge Error",

						this,

						"Could not merge chosen objects of type " + entity.getClass().getName(),

						TaxeditorBulkeditorPlugin.PLUGIN_ID,

						e,

						true);

			}

		}

		return true;

	}

	public void saveModel(){

	    saveModel(true);

	}

	public void saveModel(boolean resetMerge){

	    //delete entities

	    for(Entry<T, DeleteConfiguratorBase> entry:toDelete.entrySet()){

	        try {

                delete(entry.getKey(), entry.getValue());

            } catch (ReferencedObjectUndeletableException e) {

                e.printStackTrace();

            }

	    }

	    toDelete.clear();

	    if(resetMerge){

	        //merge entities

	        for(T mergeCandidate:mergeCandidates){

	            merge(mergeCandidate, mergeTarget);

	        }

	        mergeCandidates.clear();

	        mergeTarget = null;

	    }

	}

	/** {@inheritDoc} */

	@Override

    public T create(T entity) {

		return save(entity);

	}

	public IEntityCreator<T> getEntityCreator(){

		if(entityCreator == null){

			entityCreator = createEntityCreator();

		}

		return entityCreator;

	}

	protected abstract IEntityCreator<T> createEntityCreator();

	/**

	 * The default implementation returns an empty list of sort providers.

	 * @return

	 */

	public List<IBulkEditorSortProvider<T>> getSortProviders(){

		List<IBulkEditorSortProvider<T>> sortProviders = new ArrayList<IBulkEditorSortProvider<T>>();

		sortProviders.add(new CdmBaseSortProvider<T>());

		return sortProviders;

	}

	/**

	 * Returns a textual representation given object. The default implementation

	 * in the abstract base class returns the simple name of the class, this may

	 * be overwritten to something more specific in subclasses.

	 *

	 * @param entity

	 * @return a textual representation given object.

	 */

	public String getTypeText(Object entity){

		return entity.getClass().getSimpleName();

	}

	public String getText(T entity) {

		if(entity instanceof IdentifiableEntity){

			IdentifiableEntity identifiableEntity = (IdentifiableEntity) HibernateProxyHelper.deproxy(entity);

			return identifiableEntity.getTitleCache();

		}

		return "No text. Implement in subclass";

	}

	public List<T> getModel() {

		return model;

	}

	protected boolean replaceInModel(T entity) {

	    int index = model.indexOf(entity);

	    if(index >= 0) {

	        model.set(index, entity);

	        return true;

	    } else {

	        return false;

	    }

	}

    @Override

    public   List<T> getRootEntities() {

        return getModel();

    }

    @Override

    public Map<Object, List<String>> getPropertyPathsMap() {

        // TODO Auto-generated method stub

        return null;

    }

	public ConversationHolder getConversation() {

		return conversation;

	}

	public List<T> getSaveCandidates() {

        return saveCandidates;

    }

    /**

     *

     */

    public void resetSaveCandidates() {

       this.saveCandidates.clear();

    }

}