package com.megatim.apifdxweb.service.impl.camel.processors;

import com.megatim.apifdxweb.core.ifaces.dataproduction.DataProductionManager;
import com.megatim.apifdxweb.core.ifaces.helper.FileDataReader;
import com.megatim.apifdxweb.core.ifaces.integration.ColumnDefinitionManager;
import com.megatim.apifdxweb.core.ifaces.referentiel.TypeFichierManager;
import com.megatim.apifdxweb.core.ifaces.referentiel.natureproduction.NatureProductionFichierManager;
import com.megatim.fdxcommons.model.searchentities.ColumnDefinitionSearch;
import com.megatim.apifdxweb.service.impl.camel.exceptions.BadFileNamePatterException;
import com.megatim.apifdxweb.service.impl.camel.exceptions.TimestampException;
import com.megatim.fdxcommons.model.dataproduction.DataProduction;
import com.megatim.fdxcommons.tools.exceptions.FileTypeNotExistException;
import com.megatim.fdxcommons.model.integration.ColumnDefinition;
import com.megatim.fdxcommons.model.referentiel.TypeFichier;
import com.megatim.fdxcommons.model.referentiel.natureproduction.NatureProduction;
import com.megatim.fdxcommons.tools.exceptions.CommonRessourceNotFoundException;
import com.megatim.fdxcommons.tools.integration.ApiIntegrationData;
import java.io.File;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.LinkedHashMap;
import java.util.List;
import javax.enterprise.context.Dependent;
import javax.inject.Inject;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;

/**
 *
 * @author lenovo
 */
@Dependent
public class FichierIntegrationProcessor implements Processor {

    @Inject
    private TypeFichierManager typeFichierManager;

    @Inject
    private ColumnDefinitionManager columnDefinitionManager;

    @Inject
    private FileDataReader fileDataReader;

    @Inject
    private DataProductionManager dataProductionManager;

    @Inject
    private NatureProductionFichierManager natureProductionFichierManager;

    @Override
    public void process(Exchange exchange) throws Exception {
        System.out.println("***********************in FichierIntegrationProcessor");
        File file = exchange.getIn().getBody(File.class);
        final String fileName = file.getName();

        if (fileName.length() < 12) {
            throw new BadFileNamePatterException(fileName);
        }

        String referentielVersion = fileName.substring(0, 6);
        String codeTypeFichier = fileName.substring(6, 12);
        String date = fileName.substring(12, 26);
        LocalDateTime fileDate = LocalDateTime.parse(date, DateTimeFormatter.ofPattern("yyyyMMddHHmmss"));

        stopIfTypeFichierNotExists(codeTypeFichier, referentielVersion);
        stopIfFileTimestampBeforeLastPoduction(referentielVersion, codeTypeFichier, fileName, fileDate);

        List<LinkedHashMap<String, Object>> data = fileDataReader.getDatas(referentielVersion, codeTypeFichier, file);
        ApiIntegrationData integrationData = new ApiIntegrationData(data, codeTypeFichier, referentielVersion, fileName, fileDate);

        exchange.getIn().setBody(integrationData);
    }

    private void stopIfTypeFichierNotExists(String codeTypeFichier, String referentielVersion) throws FileTypeNotExistException {
        TypeFichier typeFich = typeFichierManager.getById(codeTypeFichier);

        if (typeFich == null) {
            throw new CommonRessourceNotFoundException("TypeFichier '" + codeTypeFichier + "' inexistant");
        }
        System.out.println("******************************");
        System.out.println("codeTypeFichier : " + codeTypeFichier + ", referentielVersion : " + referentielVersion);
        ColumnDefinitionSearch searchEntity = new ColumnDefinitionSearch();
        searchEntity.setCodeTypeFichier(codeTypeFichier);
        searchEntity.setReferentielVersion(referentielVersion);

        System.out.println("before call to getAll");
        List<ColumnDefinition> colDefs = columnDefinitionManager.getAll(searchEntity);
        System.out.println("after call to getAll");
        System.out.println("******************************");

        if (colDefs == null || colDefs.isEmpty()) {
            throw new CommonRessourceNotFoundException("La structure du typeFichier '" + codeTypeFichier + "' est introuvable");
        }
    }

    private void stopIfFileTimestampBeforeLastPoduction(String referentielVersion, String codeTypeFichier, String fileName, LocalDateTime dateTime) throws TimestampException {
        NatureProduction natureProd = natureProductionFichierManager.getNatureProduction(codeTypeFichier, referentielVersion);

        if (natureProd.equals(NatureProduction.REFERENTIELLE)) {
            DataProduction lastDataProduction = dataProductionManager.lastProduction(referentielVersion, codeTypeFichier);

            if (lastDataProduction != null
                    && (dateTime.equals(lastDataProduction.getFileDate()) || dateTime.isBefore(lastDataProduction.getFileDate()))) {
                throw new TimestampException(fileName);
            }
        }
    }
}