EDIT

/**

* Copyright (C) 2007 EDIT

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

*/

package eu.etaxonomy.cdm.io.common;

import org.apache.log4j.Logger;

import org.springframework.beans.BeansException;

import org.springframework.context.ApplicationContext;

import org.springframework.context.ApplicationContextAware;

import org.springframework.stereotype.Component;

import eu.etaxonomy.cdm.api.service.IService;

import eu.etaxonomy.cdm.common.monitor.SubProgressMonitor;

/**

 * @created 20.06.2008

 */

@Component("defaultExport")

        implements ICdmExporter<T>, ApplicationContextAware {

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

	protected ApplicationContext applicationContext;

	@Override

    public void setApplicationContext(ApplicationContext applicationContext)

		this.applicationContext = applicationContext;

	}

	final static boolean FACULTATIVE = false;

	Map<String, MapWrapper<? extends CdmBase>> stores = new HashMap<String, MapWrapper<? extends CdmBase>>();

	public CdmApplicationAwareDefaultExport(){

		stores.put(ICdmIO.REFERENCE_STORE, new MapWrapper<>(service));

		stores.put(ICdmIO.NOMREF_STORE, new MapWrapper<>(service));

		stores.put(ICdmIO.TAXONNAME_STORE, new MapWrapper<>(service));

		stores.put(ICdmIO.TAXON_STORE, new MapWrapper<>(service));

		stores.put(ICdmIO.SPECIMEN_STORE, new MapWrapper<>(service));

	@Override

	    ExportResult result;

	    if (config.getCheck().equals(IExportConfigurator.CHECK.CHECK_ONLY)){

		    result = ExportResult.NewInstance(config.getResultType());

		    if (! success){

		        result.setAborted();

		    }

		    if (success){

		        result = doExport(config);

		    }else{

	            result.setAborted();

            logger.error(message);

            result.addError(message);

 		}

		return result;

            if (! success){

                result.setAborted();

            }

            if (success){

                result = doExport(config);

            }else{

                result.setAborted();

        } else if (config.getCheck().equals(IExportConfigurator.CHECK.EXPORT_WITHOUT_CHECK)){

            logger.error(message);

            result.addError(message);

	    return result;

	}

	protected <S extends IExportConfigurator> boolean doCheck(S  config){

	    boolean result = true;

		if (config == null){

			logger.warn("CdmExportConfiguration is null");

		}else if (! config.isValid()){

			logger.warn("CdmExportConfiguration is not valid");

            return false;

		state.initialize(config);

				String ioBeanName = getComponentBeanName(ioClass);

					logger.error(message);

					return false;

			} catch (Exception e) {

					logger.error(e);

					e.printStackTrace();

		}

		System.out.println("End checking Source ("+ config.getSourceNameString() + ") for export from Cdm");

		return result;

	}

		for (IIoObserver observer : config.getObservers()){

			io.addObserver(observer);

		}

	}

		for (IIoObserver observer : config.getObservers()){

	}

		if (config == null){

		    String message = "Configuration is null";

			logger.error(message);

			result.addError(message);

			return result;

		ExportResult result = ExportResult.NewInstance(config.getResultType());

		if (! config.isValid()){

			String message = "Configuration is not valid";

		    logger.error(message);

		    result.addError(message);

			return result;

		System.out.println("Start export from source '" + config.getSourceNameString()

		state.initialize(config);

		List<Integer> stepCounts = countSteps(state, ioList);

		Integer totalCount = stepCounts.get(stepCounts.size()-1);

		IProgressMonitor parentMonitor = SubProgressMonitor

		        .NewStarted(config.getProgressMonitor(), 99, "Process data", totalCount);

		    ICdmExport export = ioList.get(i);

		    Integer counts = stepCounts.get(i);

			    SubProgressMonitor ioMonitor = SubProgressMonitor

			            .NewStarted(parentMonitor, counts, ioName, counts );

				export.invoke(state);

				ioMonitor.done();

				logger.error(message);

				e.printStackTrace();

		        result.addException(e, message);

		}

		System.out.println("End export from source '" + config.getSourceNameString()

				+ "("+ result.toString() + ")"

				) ;

	}

     * @param state

     * @param ioList

     * @return

     */

    private List<Integer> countSteps(ExportStateBase state, List<ICdmExport> ioList) {

        //do invoke for each class

        List<Integer> result = new ArrayList<>();

        int sum = 0;

        for (ICdmExport export: ioList){

            int count = 1;

            try {

//                state.setCurrentIO(export);

                count = ((Long)export.countSteps(state)).intValue();

            } catch (Exception e) {

                String message = "Unexpected exception when count steps for progress monitoring " + export.getClass().getSimpleName()+ ": " + e.getMessage();

                logger.error(message);

                e.printStackTrace();

                state.getResult().addException(e, message);

            }

            result.add(count);

            sum += count;

        }

        result.add(sum);

        return result;

    }

    /**

     * @param state

     * @param config

     * @return

     */

    private <CONFIG extends T>  List<ICdmExport> makeIoList(ExportStateBase state, CONFIG config) {

        List<ICdmExport> result = new ArrayList<>();

        for (Class<ICdmExport> ioClass: config.getIoClassList()){

            try {

                String ioBeanName = getComponentBeanName(ioClass);

                ICdmExport cdmIo = applicationContext.getBean(ioBeanName, ICdmExport.class);

                if (cdmIo != null){

                    result.add(cdmIo);

                }else{

                    String message = "cdmIO was null: " + ioBeanName;

                    logger.error(message);

                    state.getResult().addError(message);

                }

            } catch (Exception e) {

                    String message = "Unexpected exception in " + ioClass.getSimpleName()+ ": " + e.getMessage();

                    logger.error(message);

                    e.printStackTrace();

                    state.getResult().addException(e, message);

            }

        }

        return result;

    }

    private String getComponentBeanName(Class<ICdmExport> ioClass){

		String ioBean = component.value();

		if ("".equals(ioBean)){

			ioBean = ioClass.getSimpleName();

			ioBean = ioBean.substring(0, 1).toLowerCase() + ioBean.substring(1); //make camelcase

		}

		return ioBean;

	}