EDIT

package eu.etaxonomy.cdm.io.pesi.indexFungorum;

import java.sql.ResultSet;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.UUID;

import org.apache.log4j.Logger;

import org.springframework.stereotype.Component;

import org.springframework.transaction.TransactionStatus;

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

import eu.etaxonomy.cdm.hibernate.HibernateProxyHelper;

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

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

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

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

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

/**

 * @author k.luther

 * @since 19.08.2014

 */

@Component

public class IndexFungorumSubSpeciesImport extends IndexFungorumImportBase {

    private static final long serialVersionUID = -2877755674188760685L;

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

	private static final String pluralString = "subSpecies";

	public IndexFungorumSubSpeciesImport(){

		super(pluralString, null);

	}

	@Override

	public Map<Object, Map<String, ? extends CdmBase>> getRelatedObjectsForPartition(

			ResultSet rs, IndexFungorumImportState state) {

		return null;  //not used here

	}

	@Override

	protected String getRecordQuery(IndexFungorumImportConfigurator config) {

		return null;  //not used here

	}

	@Override

    protected void doInvoke(IndexFungorumImportState state){

		 logger.info("create infraspecific - specific relationship: " + state.getInfraspecificTaxaUUIDs().size() + " taxa");

		 List<String> propertyPaths = new ArrayList<>();

         propertyPaths.add("taxonNodes.*");

         propertyPaths.add("taxonNodes.classification");

         propertyPaths.add("taxonNodes.childNodes.*");

         propertyPaths.add("taxonNodes.childNodes.taxon.*");

         propertyPaths.add("taxonNodes.parent.*");

         propertyPaths.add("taxonNodes.parent.taxon.*");

         Classification classification = getClassification(state);

        for (UUID infraspecificTaxonUUID: state.getInfraspecificTaxaUUIDs().keySet()){

        	TransactionStatus txStatus = startTransaction();

        	Taxon infraspecificTaxon = (Taxon)getTaxonService().load(infraspecificTaxonUUID, propertyPaths);

            TaxonName name = infraspecificTaxon.getName();

//            getNameService().saveOrUpdate(name);

            String parentNameString = getParentNameInfraSpecific(name);

//            System.out.println("Parent name string: " + parentNameString);

            MatchingTaxonConfigurator matchingConfig = new MatchingTaxonConfigurator();

            matchingConfig.setTaxonNameTitle(parentNameString);

            matchingConfig.setPropertyPath(propertyPaths);

            @SuppressWarnings("rawtypes")

            List<TaxonBase> potentialParents = getTaxonService().findTaxaByName(matchingConfig);

                    //Taxon.class, parentNameString + "sec. ", MatchMode.BEGINNING, , pageSize, pageNumber, orderHints, propertyPaths)

                    //.searchNames(String uninomial,String infraGenericEpithet, String specificEpithet, String infraspecificEpithet, Rank rank, Integer pageSize, Integer pageNumber, List<OrderHint> orderHints,

            boolean matched = false;

            if (potentialParents.size()>1){

                for (@SuppressWarnings("rawtypes") TaxonBase potentialParent : potentialParents){

                    if (potentialParent.getTitleCache().equals(parentNameString + " sec*")){

                        classification.addParentChild((Taxon)potentialParent, infraspecificTaxon, null, null);

                        matched = true;

                        break;

                    }

                }

                if (matched == false){

                    logger.warn("Multiple match candidates but no match for " + name.getTitleCache());

                }

            }else if (!potentialParents.isEmpty()){

                Taxon parent = HibernateProxyHelper.deproxy(potentialParents.get(0), Taxon.class);

                classification.addParentChild(parent, infraspecificTaxon, null, null);

                matched = true;

            } else{

                Integer genusId = state.getInfraspecificTaxaUUIDs().get(infraspecificTaxonUUID);

                Taxon genusParent = getParentGenus(state, genusId);

//                Taxon genusParent = state.getRelatedObject(NAMESPACE_GENERA, String.valueOf(genusId), Taxon.class);

                classification.addParentChild(genusParent, infraspecificTaxon, null, null);

                logger.warn("Added infraspecific taxon to genus because species does not exist: " + infraspecificTaxon.getTitleCache());

                matched = true;

            }

            if (!matched){

                System.out.println("No parent for: " + name.getTitleCache());

            }

            getTaxonService().saveOrUpdate(infraspecificTaxon);

            commitTransaction(txStatus);

        }

	}

    private Taxon getParentGenus(IndexFungorumImportState state, Integer genusId) {

        Taxon result = getCommonService().getSourcedObjectByIdInSource(Taxon.class, String.valueOf(genusId), NAMESPACE_GENERA);

        return result;

    }

    private String getParentNameInfraSpecific(TaxonName taxonName){

        String parentName = taxonName.getGenusOrUninomial() + " " + taxonName.getSpecificEpithet();

        return parentName;

    }

    @Override

    protected boolean doCheck(IndexFungorumImportState state) {

        return false;

    }

    @Override

    protected boolean isIgnore(IndexFungorumImportState state) {

        return false;

    }

}