/*
 * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
 * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
 */
package com.megatim.fdxconsultation.core.impl.helper;

import com.megatim.fdxcommons.model.dataproduction.CommonDataProduction;
import com.megatim.fdxcommons.model.enumeration.Operateur;
import com.megatim.fdxcommons.model.enumeration.StatutDataProduction;
import com.megatim.fdxcommons.tools.database.queries.CustomQueries;
import com.megatim.fdxcommons.tools.database.queries.DeleteTableDataQuery;
import com.megatim.fdxcommons.tools.database.queries.UpdateDataProductionQuery;
import com.megatim.fdxcommons.tools.database.queries.metadata.FdxTableDefinition;
import com.megatim.fdxcommons.tools.database.queries.metadata.QueryCriterion;
import com.megatim.fdxcommons.tools.database.tables.appcolumns.DataProductionIdColumnDefinition;
import com.megatim.fdxcommons.tools.database.tables.FdxConsultationTable;
import com.megatim.fdxcommons.tools.database.tables.FdxTableColumnData;
import com.megatim.fdxcommons.tools.database.tables.FdxTableRow;
import com.megatim.fdxcommons.tools.database.tables.appcolumns.IndexColumnDefinition;
import com.megatim.fdxconsultation.core.ifaces.helper.TableInsert;
import com.megatim.fdxconsultation.core.impl.factory.FdxConsultationTableFactory;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
import javax.enterprise.context.Dependent;
import javax.naming.NamingException;

/**
 *
 * @author ASUS
 */
@Dependent
public class FdxConsultationTableInsert implements TableInsert {

    @Override
    public Long insert(CommonDataProduction dataProduction, List<FdxTableRow> data, Connection connection) throws NamingException, SQLException, Exception {
        FdxConsultationTable fdxConsTable = FdxConsultationTableFactory.createTable(dataProduction.getCodeTypeFichier(),
                dataProduction.getReferentielVersion(),
                connection);
        FdxTableDefinition tableDefinition = fdxConsTable.tableDefinition(connection);
        final String tableName = fdxConsTable.getTableName().name(connection);

        if (dataProduction.getId() != null) {

            if (!data.isEmpty()) {
                Optional<FdxTableColumnData> optIndexData = data.get(0).getDataColumns().stream().filter(p -> p.getName().equals(new IndexColumnDefinition().name())).findFirst();

                //Si fdx_index est trouvé dans les données existantes, alors la nouvelle dataproduction est une modification et donc on doit supprimer les anciennes avant l'insertion
                if (optIndexData.isPresent() && new CustomQueries().fdxIndexExists((Long) optIndexData.get().getValue(), tableName, connection)) {
                    List<Long> indexes = data
                            .stream()
                            .flatMap(f -> f.getDataColumns().stream().filter(p -> p.getName().equals(new IndexColumnDefinition().name())))
                            .map(m -> (Long) m.getValue())
                            .collect(Collectors.toList());

                    //Supprimer les anciennes lignes de même index
                    new DeleteTableDataQuery(tableName, connection, deleteExistingIndexesCriterion(indexes)).execute();
                }
                fdxConsTable.insert(data, dataProduction.getId(), connection);
            }

            if (dataProduction.getStatutDataProduction().equals(StatutDataProduction.A_CONSOMMER)) {
                new UpdateDataProductionQuery(dataProduction, connection).execute();
                
                if (tableDefinition.isReferentiel()) {
                    new DeleteTableDataQuery(tableName, connection, whereDataProductionIsNotEqualCriterion(dataProduction.getId())).execute();
                }
            }
        }
        return dataProduction.getStatutDataProduction().equals(StatutDataProduction.A_CONSOMMER) ? dataProduction.getId() : null;
    }

    private QueryCriterion deleteExistingIndexesCriterion(List<Long> indexes) {
        return new QueryCriterion(new IndexColumnDefinition().name(), indexes, Operateur.IN, null, Arrays.asList());
    }

    private QueryCriterion whereDataProductionIsNotEqualCriterion(Long dataProductionId) {
        return new QueryCriterion(new DataProductionIdColumnDefinition().name(), dataProductionId, Operateur.NOT_EQUALS, null, Arrays.asList());
    }
}