package com.megatim.fdxcommons.core.impl.helper.referentiel;

import com.megatim.fdxcommons.core.ifaces.db.ImportZipValidatorIfaces;
import com.megatim.fdxcommons.core.ifaces.helper.referentiel.ReferentielToImportDataReader;
import com.megatim.fdxcommons.core.ifaces.helper.referentiel.ReferentielXmlDataReader;
import com.megatim.fdxcommons.tools.exceptions.ImportReferentielException;
import com.megatim.fdxcommons.model.enumeration.StatutReferentiel;
import com.megatim.fdxcommons.model.pojo.ReferentielToImportData;
import com.megatim.fdxcommons.model.integration.TableDefinition;
import com.megatim.fdxcommons.model.referentiel.Referentiel;
import com.megatim.fdxcommons.tools.CommonAppContext;
import com.megatim.fdxcommons.tools.AppFileUtils;
import java.io.File;
import java.util.List;
import java.util.stream.Collectors;
import javax.enterprise.context.Dependent;
import javax.inject.Inject;

/**
 *
 * @author lenovo
 */
@Dependent
public class ReferentielToImportDataReaderImpl implements ReferentielToImportDataReader {

    @Inject
    private ReferentielXmlDataReader referentielXmlDataReader;

    @Inject
    private ImportZipValidatorIfaces importValidator;

    @Override
    public ReferentielToImportData getData(File referentielFile) throws Exception {

        //On décompresse le fichier zip du référentiel dans le répertoire temporaire du serveur
        File unzipDirectory = AppFileUtils.unzipFileInDirectory(referentielFile.getAbsolutePath(), CommonAppContext.TEMP_DIR);

        //Dans le répertoire décompressé, on décompresse encore le fichier contenant les fichiers xml des entités du référentiel
        File unzipReferentielDirectory = AppFileUtils.unzipFileInDirectory((unzipDirectory + File.separator + CommonAppContext.REFERENTIEL_ZIP_FILE_NAME), unzipDirectory.getAbsolutePath());

        //Indique le répertoire des validateurs du référentiel
        File validateursDirectory = new File(unzipDirectory + File.separator + CommonAppContext.UNZIP_REFERENTIEL_VALIDATEUR_DIR_NAME);

        ReferentielToImportData referentielToImportData = new ReferentielToImportData();
        referentielToImportData.setFileName(referentielFile.getName());
        referentielXmlDataReader.readData(unzipReferentielDirectory, referentielToImportData);

        Referentiel referentielEncours = getReferentielEncours(referentielToImportData);
        referentielToImportData.setReferentielEnCours(referentielEncours);

        //On extrait la définition des tables associées aux validateur (structures lignes) du référentiel EN COURS
        List<TableDefinition> tableDefinitions = importValidator.getTableDefinitions(validateursDirectory, referentielToImportData);
        referentielToImportData.setTableDefinitions(tableDefinitions);

        return referentielToImportData;

    }

    private Referentiel getReferentielEncours(ReferentielToImportData referentielToImportData) throws Exception {
        List<Referentiel> referentiels = referentielToImportData.getReferentiels()
                .stream()
                .filter(p -> p.getStatutReferentiel().equals(StatutReferentiel.EN_COURS))
                .collect(Collectors.toList());

        if (referentiels == null || referentiels.isEmpty()) {
            throw new ImportReferentielException("Cette archive n'a pas de referentiel avec le statut EN COURS");
        }

        if (referentiels.size() > 1) {
            throw new ImportReferentielException(referentiels.size() + " réferentiels en cours trouvés");
        }

        return referentiels.get(0);
    }

}