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.e4.handler;

import java.util.HashSet;

import java.util.Set;

import javax.inject.Named;

import org.eclipse.core.runtime.NullProgressMonitor;

import org.eclipse.e4.core.di.annotations.CanExecute;

import org.eclipse.e4.core.di.annotations.Execute;

import org.eclipse.e4.ui.model.application.ui.basic.MPart;

import org.eclipse.e4.ui.model.application.ui.menu.MHandledMenuItem;

import org.eclipse.e4.ui.services.IServiceConstants;

import org.eclipse.jface.dialogs.MessageDialog;

import org.eclipse.swt.widgets.Shell;

import eu.etaxonomy.cdm.hibernate.HibernateProxyHelper;

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

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

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

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

import eu.etaxonomy.taxeditor.bulkeditor.BulkEditorQuery;

import eu.etaxonomy.taxeditor.bulkeditor.e4.BulkEditor;

import eu.etaxonomy.taxeditor.bulkeditor.input.AbstractBulkEditorInput;

import eu.etaxonomy.taxeditor.l10n.Messages;

import eu.etaxonomy.taxeditor.store.CdmStore;

/**

 * Note: This merging is persisted only when saved. This handler only checks

 * if merging is possible and removes only the list items but <b>not</b> the

 * CDM entitites

 * @author pplitzner

 * @date 11.09.2017

 *

 */

public class MergeGroupHandlerE4 {

    @Execute

    public void execute(

            @Named(IServiceConstants.ACTIVE_PART)MPart activePart,

            @Named(IServiceConstants.ACTIVE_SHELL)Shell shell) {

        BulkEditor editor = (BulkEditor) activePart.getObject();

        AbstractBulkEditorInput input = editor.getEditorInput();

        Set<CdmBase> mergedCandidates = new HashSet<>();

        if(editor.isDirty()){

            String[] labels = {Messages.MergeGroupHandler_save, Messages.MergeGroupHandler_continue, Messages.MergeGroupHandler_cancel};

            MessageDialog dialog = new MessageDialog(null, Messages.MergeGroupHandler_SaveChanges, null, Messages.MergeGroupHandler_description,

                    MessageDialog.QUESTION_WITH_CANCEL, 0, labels);

            dialog.open();

            int proceed = dialog.getReturnCode();

            boolean save = false;

            if (proceed == 0) {

                save = true;

            } else if (proceed == 2){

                return;

            }

            BulkEditorQuery lastQuery = editor.getLastQuery();

            editor.setLastQuery(null);

            editor.save(new NullProgressMonitor(), save);

            editor.setLastQuery(lastQuery);

        }

        // Check whether there are any group annotations

        Set<CdmBase> candidatesToMerge = input.getMergeCandidates();

        if (candidatesToMerge.size() == 0) {

            MessageDialog.openWarning(shell,

                    "No merge candidates", "No objects have been chosen for merging.");

            return;

        }

        // Check whether group merge target has been set

        CdmBase mergeTarget = input.getMergeTarget();

        if (mergeTarget == null) {

            MessageDialog.openWarning(shell,

                    "No group merge target set", "No group merge target has been set.");

            return;

        }

        TeamOrPersonBase<?> teamOrPerson = null;

        Reference ref = null;

        if (mergeTarget instanceof TeamOrPersonBase){

            teamOrPerson = HibernateProxyHelper.deproxy(mergeTarget, TeamOrPersonBase.class);

        } else if(mergeTarget instanceof Reference){

            ref = HibernateProxyHelper.deproxy(mergeTarget, Reference.class);

        }

        for (CdmBase item : candidatesToMerge) {

            //first check whether entities are mergeable

            try{

                if (ref != null){

                    Reference ref2 = HibernateProxyHelper.deproxy(item, Reference.class);

                    if (!CdmStore.getCommonService().isMergeable(ref, ref2, null)){

                        MessageDialog.openWarning(shell,

                                "No merge possible", "A merge of " + ref.getTitleCache() + " and " + ref2.getTitleCache() + " is not possible.");

                        return;

                    }

                    input.getModel().remove(item);

                    mergedCandidates.add(item);

                }

                if (teamOrPerson != null){

                    TeamOrPersonBase<?> teamOrPerson2 = HibernateProxyHelper.deproxy(item, TeamOrPersonBase.class);

                    if (!CdmStore.getCommonService().isMergeable(teamOrPerson, teamOrPerson2, null)){

                        MessageDialog.openWarning(shell,

                                "No merge possible", "A merge of " + teamOrPerson.getTitleCache() + " and " + teamOrPerson2.getTitleCache() + " is not possible.");

                        return;

                    }

                    input.getModel().remove(item);

                    mergedCandidates.add(item);

                }

            }catch(MergeException e){

                candidatesToMerge.clear();

                MessageDialog.openWarning(shell,

                        "No merge possible", "A merge is not possible." + e.getLocalizedMessage());

                return;

            }

        }

        if (!candidatesToMerge.isEmpty()){

            input.getMergedEntities().put(mergeTarget, mergedCandidates);

            input.getMergeCandidates().clear();

            input.setMergeTarget(null);

        }

        editor.setDirty();

        editor.refresh();

    }

    @CanExecute

    public boolean canExecute(@Named(IServiceConstants.ACTIVE_PART)MPart activePart,

            MHandledMenuItem menuItem) {

        boolean canExecute = false;

        BulkEditor editor = (BulkEditor) activePart.getObject();

        canExecute = !editor.getEditorInput().getMergeCandidates().isEmpty()

                && editor.getEditorInput().getMergeTarget()!=null;

        menuItem.setVisible(canExecute);

        return canExecute;

    }

}