EDIT

/**

* Copyright (C) 2014 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.view.dataimport;

import java.io.IOException;

import java.io.InputStream;

import java.net.URI;

import java.util.ArrayList;

import java.util.Collection;

import org.apache.http.client.ClientProtocolException;

import org.w3c.dom.Element;

import org.w3c.dom.NodeList;

import eu.etaxonomy.cdm.ext.occurrence.bioCase.BioCaseQueryServiceWrapper;

import eu.etaxonomy.cdm.io.specimen.abcd206.in.Abcd206DataHolder;

import eu.etaxonomy.cdm.io.specimen.abcd206.in.Abcd206ImportConfigurator;

import eu.etaxonomy.cdm.io.specimen.abcd206.in.Abcd206ImportParser;

import eu.etaxonomy.cdm.io.specimen.abcd206.in.Abcd206ImportState;

import eu.etaxonomy.cdm.io.specimen.abcd206.in.Abcd206XMLFieldGetter;

import eu.etaxonomy.cdm.io.specimen.abcd206.in.AbcdParseUtility;

import eu.etaxonomy.cdm.io.specimen.abcd206.in.UnitAssociationWrapper;

/**

 * @author pplitzner

 * @date Sep 3, 2014

 *

 */

public class SpecimenImportView extends DataImportView<Abcd206DataHolder> {

    public static final String ID = "eu.etaxonomy.taxeditor.view.dataimport.SpecimenImportView"; //$NON-NLS-1$

    private URI endPoint;

    public SpecimenImportView() {

    }

    /**

     * @param endPoint

     */

    public void setEndpoint(URI endPoint) {

        this.endPoint = endPoint;

    }

    /* (non-Javadoc)

     * @see eu.etaxonomy.taxeditor.view.dataimport.DataImportView#getTextForTableItem(java.lang.Object)

     */

    @Override

    protected String getTextForTableItem(Abcd206DataHolder item) {

        //TODO: define a suitable toString method

        return item.toString();

    }

    /* (non-Javadoc)

     * @see eu.etaxonomy.taxeditor.view.dataimport.DataImportView#query()

     */

    @Override

    public void query() {

        String errorMessage = "Could not execute query " + query;

        Collection<Abcd206DataHolder> results = new ArrayList<Abcd206DataHolder>();

        try {

            //FIXME move ABCD import to cdmlib -> this will also get rid of the transient services

            InputStream resultStream;

            resultStream = new BioCaseQueryServiceWrapper().query(query, endPoint);

            Abcd206ImportConfigurator configurator = Abcd206ImportConfigurator.NewInstance(null, null);

            configurator.setSourceUri(endPoint);

            //            TransientCdmRepository repo =

//                    new TransientCdmRepository(CdmStore.getCurrentApplicationConfiguration());

            //configurator.setCdmAppController(repo);

            //TODO: do not query all data but with the selected triple IDs -> see GbifResponseImportView

            configurator.setAddMediaAsMediaSpecimen(true);

            configurator.setAllowReuseOtherClassifications(true);

            configurator.setMoveNewTaxaToDefaultClassification(false);

            UnitAssociationWrapper unitAssociationWrapper = AbcdParseUtility.parseUnitsNodeList(resultStream, null);

            NodeList unitsList = unitAssociationWrapper.getAssociatedUnits();

            Abcd206DataHolder dataHolder = new Abcd206DataHolder();

            Abcd206XMLFieldGetter abcdFieldGetter = new Abcd206XMLFieldGetter(dataHolder, unitAssociationWrapper.getPrefix());

            Abcd206ImportState state = new Abcd206ImportState(configurator);

            state.setDataHolder(dataHolder);

            for (int i = 0; i <unitsList.getLength(); i++){

                Element item = (Element) unitsList.item(i);

                //dataHolder = new Abcd206DataHolder();

                Abcd206ImportParser.setUnitPropertiesXML(item, abcdFieldGetter, state);

                results.add(dataHolder);

            }

//            Job job = CdmStore.getImportManager().createIOServiceJob(configurator, resultStream, SOURCE_TYPE.INPUTSTREAM);

//            CdmStore.getImportManager().run(job);

            setResults(results);

        } catch (ClientProtocolException e) {

            logger.error(errorMessage, e);

        } catch (IOException e) {

            logger.error(errorMessage, e);

        }

       // setResults(results);

    }

}