EDIT

/**

* Copyright (C) 2019 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.cdm.api.service.description;

import java.math.BigDecimal;

import java.math.MathContext;

import java.util.ArrayList;

import java.util.Comparator;

import java.util.HashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Optional;

import java.util.Set;

import java.util.stream.Collectors;

import eu.etaxonomy.cdm.common.BigDecimalUtil;

import eu.etaxonomy.cdm.common.CdmUtils;

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

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

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

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

import eu.etaxonomy.cdm.model.description.CategoricalData;

import eu.etaxonomy.cdm.model.description.DescriptionBase;

import eu.etaxonomy.cdm.model.description.DescriptionElementBase;

import eu.etaxonomy.cdm.model.description.DescriptionType;

import eu.etaxonomy.cdm.model.description.DescriptiveDataSet;

import eu.etaxonomy.cdm.model.description.Feature;

import eu.etaxonomy.cdm.model.description.IDescribable;

import eu.etaxonomy.cdm.model.description.IndividualsAssociation;

import eu.etaxonomy.cdm.model.description.QuantitativeData;

import eu.etaxonomy.cdm.model.description.SpecimenDescription;

import eu.etaxonomy.cdm.model.description.State;

import eu.etaxonomy.cdm.model.description.StateData;

import eu.etaxonomy.cdm.model.description.StatisticalMeasure;

import eu.etaxonomy.cdm.model.description.StatisticalMeasurementValue;

import eu.etaxonomy.cdm.model.description.TaxonDescription;

import eu.etaxonomy.cdm.model.occurrence.SpecimenOrObservationBase;

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

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

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

/**

 * Aggregates the character data for a given {@link DescriptiveDataSet}.<br>

 * <br>

 * For all {@link SpecimenDescription}s belonging to this data set a new

 * aggregated {@link TaxonDescription}s are created for every taxon the

 * specimens are directly associated with.<BR>

 * Also lower rank taxon descriptions are aggregated to upper rank taxa.

 *

 * @author a.mueller

 * @author p.plitzner

 * @since 03.11.2019

 */

public class StructuredDescriptionAggregation

        extends DescriptionAggregationBase<StructuredDescriptionAggregation, StructuredDescriptionAggregationConfiguration>{

    private DescriptiveDataSet dataSet;

    @Override

    protected String pluralDataType(){

        return "structured descriptive data";

    }

    @Override

    protected void preAggregate(IProgressMonitor monitor) {

        monitor.subTask("preAccumulate - nothing to do");

        // take start time for performance testing

        double start = System.currentTimeMillis();

        getResult().setCdmEntity(getDescriptiveDatasetService().load(getConfig().getDatasetUuid()));

        double end1 = System.currentTimeMillis();

        logger.info("Time elapsed for pre-accumulate() : " + (end1 - start) / (1000) + "s");

    }

    @Override

    protected void verifyConfiguration(IProgressMonitor monitor){

        if (!AggregationSourceMode.list(AggregationMode.ToParent, AggregationType.StructuredDescription)

            .contains(getConfig().getToParentSourceMode())){

            throw new AggregationException("Unsupported source mode for to-parent aggregation: " + getConfig().getToParentSourceMode());

        }

        if (!AggregationSourceMode.list(AggregationMode.WithinTaxon, AggregationType.StructuredDescription)

                .contains(getConfig().getWithinTaxonSourceMode())){

                throw new AggregationException("Unsupported source mode for within-taxon aggregation: " + getConfig().getWithinTaxonSourceMode());

        }

    }

    private boolean hasCharacterData(DescriptionElementBase element) {

        return hasCategoricalData(element) || hasQuantitativeData(element);

    }

    private boolean hasQuantitativeData(DescriptionElementBase element) {

        if(element instanceof QuantitativeData

                && !((QuantitativeData) element).getStatisticalValues().isEmpty()){

            QuantitativeData quantitativeData = (QuantitativeData)element;

            return !getExactValues(quantitativeData).isEmpty()

                    || quantitativeData.getMin()!=null

                    || quantitativeData.getMax()!=null;

        }

        return false;

    }

    private boolean hasCategoricalData(DescriptionElementBase element) {

        return element instanceof CategoricalData && !((CategoricalData) element).getStatesOnly().isEmpty();

    }

    @Override

    protected void setDescriptionTitle(TaxonDescription description, Taxon taxon) {

        String title = taxon.getName() != null? taxon.getName().getTitleCache() : taxon.getTitleCache();

        description.setTitleCache("Aggregated description for " + title, true);

        return;

    }

    @Override

    protected TaxonDescription createNewDescription(Taxon taxon) {

        String title = taxon.getTitleCache();

        if (logger.isDebugEnabled()){logger.debug("creating new description for " + title);}

        TaxonDescription description = TaxonDescription.NewInstance(taxon);

        description.addType(DescriptionType.AGGREGATED_STRUC_DESC);

        setDescriptionTitle(description, taxon);

        return description;

    }

    @Override

    protected boolean hasDescriptionType(TaxonDescription description) {

        return dataSet.getDescriptions().contains(description) && description.isAggregatedStructuredDescription();

    }

    @Override

    protected List<String> descriptionInitStrategy() {

        return new ArrayList<>();

    }

    @Override

    protected boolean mergeAggregationResultIntoTargetDescription(TaxonDescription targetDescription,

            ResultHolder resultHolder) {

        StructuredDescriptionResultHolder structuredResultHolder = (StructuredDescriptionResultHolder)resultHolder;

        boolean updated = mergeDescriptionElements(targetDescription, structuredResultHolder.categoricalMap, CategoricalData.class);

        updated |= mergeDescriptionElements(targetDescription, structuredResultHolder.quantitativeMap, QuantitativeData.class);

        updated |= mergeDescriptionSources(targetDescription, structuredResultHolder);

        if(!targetDescription.getElements().isEmpty()){

            dataSet.addDescription(targetDescription);

        }else{

            dataSet.removeDescription(targetDescription);

        }

        return updated;

    }

    @Override

    protected boolean isRelevantDescriptionElement(DescriptionElementBase deb){

        return deb.isInstanceOf(CategoricalData.class) || deb.isInstanceOf(QuantitativeData.class);

    }

    private <T extends DescriptionBase<?>> boolean mergeDescriptionSources(TaxonDescription targetDescription,

                StructuredDescriptionResultHolder structuredResultHolder) {

        boolean updated = false;

        //Remove sources from description

        Set<IdentifiableSource> sourcesToRemove = targetDescription.getSources().stream()

                .filter(source->source.getType().equals(OriginalSourceType.Aggregation))

                .collect(Collectors.toSet());

        Set<IdentifiableSource> newSources = structuredResultHolder.sources;

        for (IdentifiableSource newSource : newSources) {

            IdentifiableSource mergeSourceCandidate = findSourceCandidate(targetDescription, newSource);

            if (mergeSourceCandidate == null){

                addNewSource(targetDescription, newSource);

                updated = true;

            }else{

                updated |= mergeSource(mergeSourceCandidate, newSource);

                sourcesToRemove.remove(mergeSourceCandidate);

            }

        }

        //remove remaining sources-to-be-removed

        for (IdentifiableSource sourceToRemove : sourcesToRemove) {

            targetDescription.removeSource(sourceToRemove);

            updated |= sourceToRemove.isPersited();

            ICdmBase target = CdmBase.deproxy(sourceToRemove.getCdmSource());

            if (target != null){

                sourceToRemove.setCdmSource(null); //workaround for missing orphan removal #9801

                if (target instanceof DescriptionBase){

                    @SuppressWarnings("unchecked")

                    T descriptionToDelete = (T)target;

                    if (descriptionToDelete.isCloneForSource()){

                        //TODO maybe this is not really needed as it is later done anyway with .deltedDescription

                        //but currently this still leads to a re-saved by cascade exception

                        ((IDescribable<T>)descriptionToDelete.describedEntity()).removeDescription(descriptionToDelete);

                        structuredResultHolder.descriptionsToDelete.add(descriptionToDelete);

                    }

                } else if (target.isInstanceOf(Taxon.class)){

                    //nothing to do for now

                } else {

                    throw new AggregationException("CdmLink target type not yet supported: " + target.getClass().getSimpleName());

                }

            }

        }

        return updated;

    }

    private <T extends DescriptionBase<?>> void addNewSource(TaxonDescription targetDescription,

            IdentifiableSource newSource) {

        //add source

        targetDescription.addSource(newSource);

        //if it is a description add it to the described entity (specimen, taxon)

        ICdmBase target = newSource.getCdmSource();

        if (target != null){

            if (target.isInstanceOf(DescriptionBase.class)){

                @SuppressWarnings("unchecked")

                T description = (T)CdmBase.deproxy(target);

                ((IDescribable<T>)description.describedEntity()).addDescription(description);

            }

        }

    }

    //mergeablity has been checked before

    private <T extends DescriptionBase<?>> boolean mergeSource(IdentifiableSource mergeCandidate, IdentifiableSource newSource) {

        boolean updated = false;

        ICdmBase newTarget = newSource.getCdmSource();

        if (newTarget != null){

            newTarget = CdmBase.deproxy(newTarget);

            if (newTarget instanceof DescriptionBase){

                @SuppressWarnings("unchecked")

                T newTargetDesc = (T)newTarget;

                @SuppressWarnings("unchecked")

                T existingTargetDesc = CdmBase.deproxy((T)mergeCandidate.getCdmSource());

                updated |= mergeSourceDescription(existingTargetDesc, newTargetDesc);

                ((IDescribable<T>)existingTargetDesc.describedEntity()).addDescription(existingTargetDesc);

                if (!existingTargetDesc.equals(newTargetDesc)){

                    ((IDescribable<T>)newTargetDesc.describedEntity()).removeDescription(newTargetDesc);

                }

            }else if (newTarget instanceof Taxon){

                //nothing to do for now (we do not support reuse of sources linking to different taxa yet)

            }else{

                throw new AggregationException("Sources not linking to a description or a taxon instance currently not yet supported.");

            }

        }else{

            throw new AggregationException("Sources not linking to another CdmBase instance currently not yet supported.");

        }

        return updated;

    }

    private <T extends DescriptionBase<?>> boolean mergeSourceDescription(T existingSourceDescription, T newSourceDescription) {

        boolean updated = false;

        Set<DescriptionElementBase> elementsToRemove = new HashSet<>(existingSourceDescription.getElements());

        Set<DescriptionElementBase> newElements = new HashSet<>(newSourceDescription.getElements());

        for (DescriptionElementBase newElement : newElements){

            DescriptionElementBase newElementClone = newElement.clone();

            Optional<DescriptionElementBase> matchingElement = elementsToRemove.stream()

                    .filter(e->e.getFeature()!= null

                        && e.getFeature().equals(newElementClone.getFeature()))

                    .findFirst();

            if (matchingElement.isPresent()){

                updated |= mergeDescriptionElement(matchingElement.get(), newElementClone);

                elementsToRemove.remove(matchingElement.get());

            }else{

                existingSourceDescription.addElement(newElementClone);

                updated = true;

            }

        }

        updated |= addSourceDescriptionToDescribedEntity(newSourceDescription);

        existingSourceDescription.setTitleCache(newSourceDescription.getTitleCache(), true);

        for (DescriptionElementBase debToRemove : elementsToRemove){

            existingSourceDescription.removeElement(debToRemove);

            updated |= debToRemove.isPersited();

        }

        return updated;

    }

    @SuppressWarnings("unchecked")

    private <T extends DescriptionBase<?>> boolean addSourceDescriptionToDescribedEntity(T sourceDescription) {

        boolean updated = false;

        IDescribable<T> describedEntity = ((IDescribable<T>)sourceDescription.describedEntity());

        if (describedEntity.getDescriptions().contains(sourceDescription)){

            describedEntity.addDescription(sourceDescription);

            updated = true;

        }

        return updated;

    }

    private IdentifiableSource findSourceCandidate(TaxonDescription targetDescription, IdentifiableSource newSource) {

        for (IdentifiableSource existingSource : targetDescription.getSources()){

            boolean isCandidate = isCandidateForSourceReuse(existingSource, newSource);

            if (isCandidate){

                return existingSource;

            }

        }

        return null;

    }

    private boolean isCandidateForSourceReuse(IdentifiableSource existingSource, IdentifiableSource newSource) {

        if (newSource.getCdmSource()!= null){

            if (existingSource.getCdmSource() == null){

                return false;

            }else {

                ICdmBase newTarget = CdmBase.deproxy(newSource.getCdmSource());

                ICdmBase existingTarget = CdmBase.deproxy((CdmBase)existingSource.getCdmSource());

                if (!newTarget.getClass().equals(existingTarget.getClass())){

                    return false;

                }else{

                    if (newTarget instanceof SpecimenDescription){

                        SpecimenOrObservationBase<?> newSob = ((SpecimenDescription)newTarget).getDescribedSpecimenOrObservation();

                        SpecimenOrObservationBase<?> existingSob = ((SpecimenDescription)existingTarget).getDescribedSpecimenOrObservation();

                        //for now reuse is possible if both are descriptions for the same specimen

                        return newSob != null && newSob.equals(existingSob);

                    }else if (newTarget instanceof TaxonDescription){

                        Taxon newTaxon = ((TaxonDescription)newTarget).getTaxon();

                        Taxon existingTaxon = ((TaxonDescription)existingTarget).getTaxon();

                        //for now reuse is possible if both are descriptions for the same taxon

                        return newTaxon != null && newTaxon.equals(existingTaxon);

                    }else if (newTarget instanceof Taxon){

                        return newTarget.equals(existingTarget);

                    }else{

                        throw new AggregationException("Other classes then SpecimenDescription and TaxonDescription are not yet supported. But was: " + newTarget.getClass());

                    }

                }

            }

        }

        return false;

    }

    private <T extends DescriptionBase<?>> T cloneNewSourceDescription(T newSourceDescription) {

        if (!getConfig().isCloneAggregatedSourceDescriptions() && newSourceDescription.isAggregatedStructuredDescription()){

            return newSourceDescription;

        }

        @SuppressWarnings("unchecked")

        T clonedDescription = (T)newSourceDescription.clone();

//        clonedDescription.removeSources();

        clonedDescription.removeDescriptiveDataSet(dataSet);

        clonedDescription.getTypes().add(DescriptionType.CLONE_FOR_SOURCE);

        clonedDescription.setTitleCache("Clone: " + clonedDescription.getTitleCache(), true);

        return clonedDescription;

    }

    @Override

    protected <S extends DescriptionElementBase> boolean mergeDescriptionElement(S targetElement,

            S newElement) {

        boolean updated = false;

        targetElement = CdmBase.deproxy(targetElement);

        newElement = CdmBase.deproxy(newElement);

        if (targetElement instanceof CategoricalData){

            updated |= mergeDescriptionElement((CategoricalData)targetElement, (CategoricalData)newElement);

        }else if (targetElement.isInstanceOf(QuantitativeData.class)){

            updated |= mergeDescriptionElement((QuantitativeData)targetElement, (QuantitativeData)newElement);

        }else{

            throw new AggregationException("Class not supported: " + targetElement.getClass().getName());

        }

        return updated;

    }

    private boolean mergeDescriptionElement(CategoricalData elementToStay,

            CategoricalData newElement) {

        boolean updated = false;

        List<StateData> dataToRemove = new ArrayList<>(elementToStay.getStateData());

        List<StateData> newData = new ArrayList<>(newElement.getStateData());

        for (StateData newStateData : newData){

            State state = newStateData.getState();

            StateData oldStateData = firstByState(state, dataToRemove);

            if (oldStateData != null){

                //for now only state and count is used for aggregation, below code needs to be adapted if this changes

                if (!CdmUtils.nullSafeEqual(oldStateData.getCount(), newStateData.getCount())){

                    oldStateData.setCount(newStateData.getCount());

//                    getResult().addUpdatedObject(oldStateData);

                    updated = true;

                }

                dataToRemove.remove(oldStateData);

            }else{

                elementToStay.addStateData(newStateData);

                updated = true;

            }

        }

        for (StateData stateDataToRemove : dataToRemove){

            elementToStay.removeStateData(stateDataToRemove);

            updated |= stateDataToRemove.isPersited();

        }

        return updated;

    }

    private StateData firstByState(State state, List<StateData> oldData) {

        if (state == null){

            return null;

        }

        for (StateData sd : oldData){

            if (state.equals(sd.getState())){

                return sd;

            }

        }

        return null;

    }

    private boolean mergeDescriptionElement(QuantitativeData elementToStay,

            QuantitativeData newElement) {

        boolean updated = false;

        Set<StatisticalMeasurementValue> oldValues = new HashSet<>(elementToStay.getStatisticalValues());

        Set<StatisticalMeasurementValue> newValues = new HashSet<>(newElement.getStatisticalValues());

        for (StatisticalMeasurementValue newValue : newValues){

            StatisticalMeasure type = newValue.getType();

            StatisticalMeasurementValue oldValue = firstValueByType(type, oldValues);

            if (oldValue != null){

                //for now only state and count is used for aggregation, below code needs to be adapted if this changes

                if (!CdmUtils.nullSafeEqual(oldValue.getValue(), newValue.getValue())){

                    oldValue.setValue(newValue.getValue());

                    updated = true;

                }

                oldValues.remove(oldValue);

            }else{

                elementToStay.addStatisticalValue(newValue);

                updated = true;

            }

        }

        for (StatisticalMeasurementValue valueToRemove : oldValues){

            elementToStay.removeStatisticalValue(valueToRemove);

            updated |= valueToRemove.isPersited();

        }

        return updated;

    }

    private StatisticalMeasurementValue firstValueByType(StatisticalMeasure type, Set<StatisticalMeasurementValue> oldValues) {

        if (type == null){

            return null;

        }

        for (StatisticalMeasurementValue value : oldValues){

            if (type.equals(value.getType())){

                return value;

            }

        }

        return null;

    }

    @Override

    protected void initTransaction() {

        dataSet = getDescriptiveDatasetService().load(getConfig().getDatasetUuid());

    }

    @Override

    protected void removeDescriptionIfEmpty(TaxonDescription description, ResultHolder resultHolder) {

        super.removeDescriptionIfEmpty(description, resultHolder);

        if (description.getElements().isEmpty()){

            dataSet.removeDescription(description);

        }

    }

    @Override

    protected void aggregateToParentTaxon(TaxonNode taxonNode,

            ResultHolder resultHolder,

            Set<TaxonDescription> excludedDescriptions) {

        StructuredDescriptionResultHolder descriptiveResultHolder = (StructuredDescriptionResultHolder)resultHolder;

        Set<TaxonDescription> childDescriptions = getChildTaxonDescriptions(taxonNode, dataSet);

        addDescriptionToResultHolder(descriptiveResultHolder, childDescriptions, AggregationMode.ToParent);

    }

    @Override

    protected void aggregateWithinSingleTaxon(Taxon taxon,

            ResultHolder resultHolder,

            Set<TaxonDescription> excludedDescriptions) {

        StructuredDescriptionResultHolder descriptiveResultHolder = (StructuredDescriptionResultHolder)resultHolder;

        //specimen descriptions

        Set<SpecimenDescription> specimenDescriptions = getSpecimenDescriptions(taxon, dataSet);

        addDescriptionToResultHolder(descriptiveResultHolder, specimenDescriptions, AggregationMode.WithinTaxon);

        //"literature" descriptions

        if (getConfig().isIncludeLiterature()){

            Set<TaxonDescription> literatureDescriptions = getLiteratureDescriptions(taxon, dataSet);

            addDescriptionToResultHolder(descriptiveResultHolder, literatureDescriptions, AggregationMode.WithinTaxon);

        }

        //"default" descriptions

        //TODO add default descriptions

        //xxx

    }

    private void addDescriptionToResultHolder(StructuredDescriptionResultHolder descriptiveResultHolder,

            Set<? extends DescriptionBase<?>> specimenLiteraturOrDefaultDescriptions,

            AggregationMode aggregationMode) {

        boolean descriptionWasUsed = false;

        for (DescriptionBase<?> desc: specimenLiteraturOrDefaultDescriptions){

            for (DescriptionElementBase deb: desc.getElements()){

                if (hasCharacterData(deb)){

                    if (deb.isInstanceOf(CategoricalData.class)){

                        addToCategorical(CdmBase.deproxy(deb, CategoricalData.class), descriptiveResultHolder);

                        descriptionWasUsed = true;

                    }else if (deb.isInstanceOf(QuantitativeData.class)){

                        addToQuantitativData(CdmBase.deproxy(deb, QuantitativeData.class), descriptiveResultHolder);

                        descriptionWasUsed = true;

                    }

                }

            }

            //sources

            AggregationSourceMode sourceMode = getConfig().getSourceMode(aggregationMode);

            if(descriptionWasUsed && sourceMode != AggregationSourceMode.NONE){

                IdentifiableSource source = IdentifiableSource.NewAggregationSourceInstance();

                desc = CdmBase.deproxy(desc);

                switch (sourceMode){

                    case DESCRIPTION:

                        DescriptionBase<?> clonedDesc = cloneNewSourceDescription(desc);

                        source.setCdmSource(clonedDesc);

                        break;

                    case TAXON:

                        if (desc instanceof TaxonDescription){

                            Taxon taxon = ((TaxonDescription) desc).getTaxon();

                            source.setCdmSource(taxon);

                        }else {

                            throw new AggregationException("Description type not yet supported for aggregation source mode TAXON: " + desc.getClass().getSimpleName() );

                        }

                        break;

                    case NONE:

                        source = null;

                        break;

                    case ALL: //not yet supported

                        throw new AggregationException("Source mode not yet supported: " + sourceMode);

                    case ALL_SAMEVALUE: //makes no sense

                        throw new AggregationException("Illegal source mode: " + sourceMode);

                    default:

                        throw new AggregationException("Source mode not supported: " + sourceMode);

                }

                if (source != null){

                    descriptiveResultHolder.sources.add(source);

                }

            }

        }

    }

    private void addToQuantitativData(QuantitativeData qd, StructuredDescriptionResultHolder resultHolder) {

        QuantitativeData aggregatedQuantitativeData = resultHolder.quantitativeMap.get(qd.getFeature());

        if(aggregatedQuantitativeData==null){

            // no QuantitativeData with this feature in aggregation

            aggregatedQuantitativeData = aggregateWithinQuantitativeData(qd);

        }

        else{

            aggregatedQuantitativeData = addToExistingQuantitativeData(aggregatedQuantitativeData, qd);

        }

        if (aggregatedQuantitativeData != null){

            resultHolder.quantitativeMap.put(qd.getFeature(), aggregatedQuantitativeData);

        }

    }

    private void addToCategorical(CategoricalData cd, StructuredDescriptionResultHolder resultHolder) {

        CategoricalData aggregatedCategoricalData = resultHolder.categoricalMap.get(cd.getFeature());

        if(aggregatedCategoricalData == null){

            // no CategoricalData with this feature in aggregation

            aggregatedCategoricalData = cd.clone();

            // set count to 1 if not set

            if (!aggregatedCategoricalData.getStatesOnly().isEmpty()){

                aggregatedCategoricalData.getStateData().stream().filter(sd->sd.getCount()==null).forEach(sd->sd.incrementCount());

                resultHolder.categoricalMap.put(aggregatedCategoricalData.getFeature(), aggregatedCategoricalData);

            }

        }

        else{

            // split all StateData into those where the state already exists and those where it doesn't

            List<State> statesOnly = aggregatedCategoricalData.getStatesOnly();

            List<StateData> sdWithExistingStateInAggregation = cd.getStateData().stream().filter(sd->statesOnly.contains(sd.getState())).collect(Collectors.toList());

            List<StateData> sdWithNoExistingStateInAggregation = cd.getStateData().stream().filter(sd->!statesOnly.contains(sd.getState())).collect(Collectors.toList());

            for (StateData sd : sdWithNoExistingStateInAggregation) {

                StateData clone = sd.clone();

                // set count to 1 if not set

                if(clone.getCount()==null){

                    clone.incrementCount();

                }

                aggregatedCategoricalData.addStateData(clone);

            }

            for (StateData sdExist : sdWithExistingStateInAggregation) {

                List<StateData> aggregatedSameStateData = aggregatedCategoricalData.getStateData().stream()

                        .filter(sd->hasSameState(sdExist, sd))

                        .collect(Collectors.toList());

                for (StateData stateData : aggregatedSameStateData) {

                    if(sdExist.getCount()==null){

                        stateData.incrementCount();

                    }

                    else{

                        stateData.setCount(stateData.getCount()+sdExist.getCount());

                    }

                }

            }

        }

    }

    @Override

    protected StructuredDescriptionResultHolder createResultHolder() {

        return new StructuredDescriptionResultHolder();

    }

    private class StructuredDescriptionResultHolder extends ResultHolder{

        private Map<Feature, CategoricalData> categoricalMap = new HashMap<>();

        private Map<Feature, QuantitativeData> quantitativeMap = new HashMap<>();

        private Set<IdentifiableSource> sources = new HashSet<>();

        @Override

        public String toString() {

            return "SDResultHolder [categoricals=" + categoricalMap.size()

                + ", quantitatives=" + quantitativeMap.size()

                + ", sources=" + sources.size()

                + ", descriptionsToDelete=" + this.descriptionsToDelete.size()

                + "]";

        }

    }

    private Set<TaxonDescription> getChildTaxonDescriptions(TaxonNode taxonNode, DescriptiveDataSet dataSet) {

        Set<TaxonDescription> result = new HashSet<>();

        List<TaxonNode> childNodes = taxonNode.getChildNodes();

        for (TaxonNode childNode : childNodes) {

            Set<TaxonDescription> childDescriptions = childNode.getTaxon().getDescriptions();

            result.addAll(childDescriptions.stream()

                .filter(desc->desc.getTypes().contains(DescriptionType.AGGREGATED_STRUC_DESC))

                .filter(desc->dataSet.getDescriptions().contains(desc))

                .collect(Collectors.toSet()));

        }

        return result;

    }

    /**

     * Computes all specimens attached to the given taxon within the given dataSet.

     * For these secimens it returns all attache

     * */

    private Set<SpecimenDescription> getSpecimenDescriptions(Taxon taxon, DescriptiveDataSet dataSet) {

        Set<SpecimenDescription> result = new HashSet<>();

        //TODO performance: use DTO service to retrieve specimen descriptions without initializing all taxon descriptions

        for (TaxonDescription taxonDesc: taxon.getDescriptions()){

            for (DescriptionElementBase taxonDeb : taxonDesc.getElements()){

                if (taxonDeb.isInstanceOf(IndividualsAssociation.class)){

                    IndividualsAssociation indAss = CdmBase.deproxy(taxonDeb, IndividualsAssociation.class);

                    SpecimenOrObservationBase<?> specimen = indAss.getAssociatedSpecimenOrObservation();

                    Set<SpecimenDescription> descriptions = specimen.getSpecimenDescriptions();

                    for(SpecimenDescription specimenDescription : descriptions){

                        if(dataSet.getDescriptions().contains(specimenDescription) &&

                                specimenDescription.getTypes().stream().noneMatch(type->type.equals(DescriptionType.CLONE_FOR_SOURCE))){

                            result.add(specimenDescription);

                        }

                    }

                }

            }

        }

        return result;

    }

    private Set<TaxonDescription> getLiteratureDescriptions(Taxon taxon, DescriptiveDataSet dataSet) {

        Set<TaxonDescription> result = new HashSet<>();

        //TODO performance: use DTO service to retrieve specimen descriptions without initializing all taxon descriptions

        for(TaxonDescription taxonDescription : taxon.getDescriptions()){

            if(dataSet.getDescriptions().contains(taxonDescription)

                    && taxonDescription.getTypes().stream().anyMatch(type->type.equals(DescriptionType.SECONDARY_DATA))

                    && taxonDescription.getTypes().stream().noneMatch(type->type.equals(DescriptionType.CLONE_FOR_SOURCE)) ){

                result.add(taxonDescription);

            }

        }

        return result;

    }

    /**

     * Evaluates statistics for exact values collection and handles missing min and max values

     */

    private QuantitativeData aggregateWithinQuantitativeData(QuantitativeData sourceQd){

        QuantitativeData aggQD = QuantitativeData.NewInstance(sourceQd.getFeature());

        aggQD.setUnit(sourceQd.getUnit());

        Set<BigDecimal> exactValues = sourceQd.getExactValues();

        if(!exactValues.isEmpty()){

            // qd is not already aggregated

            Comparator<BigDecimal> comp = Comparator.naturalOrder();

            int exactValueSampleSize = exactValues.size();

            BigDecimal exactValueMin = exactValues.stream().min(comp).get();

            BigDecimal exactValueMax = exactValues.stream().max(comp).get();

            BigDecimal exactValueAvg = BigDecimalUtil.average(exactValues);

            //TODO also check for typical boundary data

            if(sourceQd.getMin() == null && sourceQd.getMax() == null){

                aggQD.setSampleSize(new BigDecimal(exactValueSampleSize), null);

                aggQD.setAverage(exactValueAvg, null);

            }

            aggQD.setMinimum(sourceQd.getMin() == null ? exactValueMin: sourceQd.getMin().min(exactValueMin), null);

            aggQD.setMaximum(sourceQd.getMax() == null ? exactValueMax: sourceQd.getMax().max(exactValueMax), null);

        }

        else{

            // qd has only min, max, ... but no exact values

            aggQD = sourceQd.clone();

            aggQD = handleMissingValues(aggQD);

        }

        return aggQD;

    }

    private QuantitativeData handleMissingValues(QuantitativeData qd) {

        //min max

        qd = handleMissingMinOrMax(qd);

        //average

        if (qd != null && qd.getAverage() == null){

            BigDecimal n = qd.getSampleSize();

            if(n != null && !n.equals(0f)){

                BigDecimal average = (qd.getMax().add(qd.getMin())).divide(n);

                qd.setAverage(average, null);

            }

        }

        return qd;

    }

    private QuantitativeData handleMissingMinOrMax(QuantitativeData qd) {

        return handleMissingMinOrMax(qd, getConfig().getMissingMinimumMode(), getConfig().getMissingMaximumMode());

    }

    public static QuantitativeData handleMissingMinOrMax(QuantitativeData aggQD, MissingMinimumMode missingMinMode,

            MissingMaximumMode missingMaxMode) {

        if(aggQD.getMin() == null && aggQD.getMax() != null){

            if (missingMinMode == MissingMinimumMode.MinToZero) {

                aggQD.setMinimum(BigDecimal.valueOf(0f), null);

            }else if (missingMinMode == MissingMinimumMode.MinToMax){

                aggQD.setMinimum(aggQD.getMax(), null);

            }else if (missingMinMode == MissingMinimumMode.SkipRecord){

                return null;

            }

        }

        if(aggQD.getMax() == null && aggQD.getMin() != null){

            if (missingMaxMode == MissingMaximumMode.MaxToMin){

                aggQD.setMaximum(aggQD.getMin(), null);

            }else if (missingMaxMode == MissingMaximumMode.SkipRecord){

                return null;

            }

        }

        return aggQD;

    }

    private QuantitativeData addToExistingQuantitativeData(QuantitativeData aggQd, QuantitativeData newQd) {

        newQd = aggregateWithinQuantitativeData(newQd); //alternatively we could check, if newQd is already basically aggregated, but for this we need a clear definition what the minimum requirements are and how ExactValues and MinMax if existing in parallel should be handled.

        BigDecimal min = null;

        BigDecimal max = null;

        BigDecimal average = null;

        BigDecimal sampleSize = null;

        newQd = handleMissingValues(newQd);

        if (newQd == null){

            return aggQd;

        }

        min = aggQd.getMin().min(newQd.getMin());

        max = aggQd.getMax().max(newQd.getMax());

        if (newQd.getSampleSize() != null && aggQd.getSampleSize() != null){