/*
 * 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.commons.tools.exceptions.ApplicationServerException;
import com.megatim.fdxcommons.model.enumeration.CriteriaLogicConnector;
import com.megatim.fdxcommons.model.enumeration.Operateur;
import com.megatim.fdxcommons.model.integration.ColumnDefinition;
import com.megatim.fdxcommons.model.pojo.CriteriaEntityFromView;
import com.megatim.fdxcommons.model.pojo.PageData;
import com.megatim.fdxcommons.tools.database.connection.DBConnection;
import com.megatim.fdxcommons.tools.database.queries.metadata.QueryCriterion;
import com.megatim.fdxcommons.tools.database.queries.metadata.SelectQueryResult;
import com.megatim.fdxcommons.tools.database.tables.appcolumns.EnCoursProductionColumnDefinition;
import com.megatim.fdxcommons.tools.database.tables.FdxApiTable;
import com.megatim.fdxcommons.tools.exceptions.CommonApplicationServerException;
import com.megatim.fdxcommons.tools.utils.CriteriaEntityFromViewToQueryCriterion;
import com.megatim.fdxconsultation.core.ifaces.customtypefichier.CustomTypeFichierManager;
import com.megatim.fdxconsultation.core.ifaces.integration.ColumnDefinitionManager;
import com.megatim.fdxconsultation.core.ifaces.helper.DataConsumptionOperations;
import com.megatim.fdxconsultation.core.impl.utils.FdxTableUtils;
import com.megatim.fdxconsultation.model.administration.User;
import com.megatim.fdxconsultation.model.dtos.reporting.CustomTypeFichierReportConfiguration;
import com.megatim.fdxconsultation.model.dtos.reporting.CustomTypeFichierReportConfigurationFromView;
import com.megatim.fdxconsultation.model.mappers.MapStructMapper;
import com.megatim.fdxconsultation.tools.context.AppCommonContext;
import java.io.File;
import java.sql.Connection;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.Resource;
import javax.enterprise.context.Dependent;
import javax.inject.Inject;
import javax.sql.DataSource;

/**
 *
 * @author ASUS
 */
@Dependent
public class DataConsumptionOperationsImpl implements DataConsumptionOperations {

    @Resource(lookup = AppCommonContext.JNDI_NAME)
    private DataSource dataSource;

    @Inject
    MapStructMapper mapper;

    @Inject
    com.megatim.fdxcommons.model.mappers.MapStructMapper commonMapper;

    @Inject
    CustomTypeFichierManager customTypeFichierManager;

    @Inject
    ColumnDefinitionManager columnDefinitionManager;

    @Override
    public List<Map<String, Object>> findByCriteria(String referentielVersion, String codeTypeFichier, CriteriaEntityFromView criterion) {
        try ( Connection connection = new DBConnection(dataSource).connection()) {
            SelectQueryResult result = selectResult(connection, codeTypeFichier, referentielVersion, curentDataProductionCriterion(criterion));
            return FdxTableUtils.fdxTableRowToListMap(result.rows());

        } catch (Exception ex) {
            Logger.getLogger(DataConsumptionOperationsImpl.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
            throw new CommonApplicationServerException();
        }
    }

    @Override
    public Long count(String referentielVersion, String codeTypeFichier, CriteriaEntityFromView criterion) {
        try ( Connection connection = new DBConnection(dataSource).connection()) {
            return table(codeTypeFichier, referentielVersion)
                    .count(curentDataProductionCriterion(criterion), connection);
        } catch (Exception ex) {
            throw new ApplicationServerException(ex.getMessage());
        }
    }

    @Override
    public PageData findByCriteriaWithPagination(String referentielVersion, String codeTypeFichier, CriteriaEntityFromView criterion, int pageNumber, int pageSize) {
        try ( Connection connection = new DBConnection(dataSource).connection()) {
            return getPageData(connection, codeTypeFichier, referentielVersion, curentDataProductionCriterion(criterion), pageNumber, pageSize);
        } catch (Exception ex) {
            Logger.getLogger(DataConsumptionOperationsImpl.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
            throw new CommonApplicationServerException();
        }

    }

    @Override
    public File printAll(String referentielVersion, String codeTypeFichier, CustomTypeFichierReportConfigurationFromView reportConfigurationFromView, User userConnected) throws Exception {
        CustomTypeFichierReportConfiguration reportConfiguration = mapper.customTypeFichierReportConfigurationFromViewToCustomTypeFichierReportConfiguration(reportConfigurationFromView);
        return customTypeFichierManager.generatePdf(reportConfiguration, codeTypeFichier, userConnected, false);
    }

    @Override
    public List<ColumnDefinition> getPrintableColumns(String referentielVersion, String codeTypeFichier) {
        return columnDefinitionManager.findByReferentielAndTypeFichier(referentielVersion, codeTypeFichier);
    }

    private QueryCriterion curentDataProductionCriterion(CriteriaEntityFromView criterion) {
        QueryCriterion queryCriterion = new CriteriaEntityFromViewToQueryCriterion(criterion).queryCriterion();
        
        if (queryCriterion != null) {
            return new QueryCriterion(null,
                    null,
                    null,
                    CriteriaLogicConnector.AND,
                    Arrays.asList(queryCriterion,
                            new QueryCriterion(new EnCoursProductionColumnDefinition().name(), false, Operateur.EQUALS, null, Arrays.asList()))
            );
        } else {
            return new QueryCriterion(new EnCoursProductionColumnDefinition().name(), false, Operateur.EQUALS, null, Arrays.asList());
        }

    }

    private SelectQueryResult selectResult(Connection connection, String codeTypeFichier, String referentielVersion, QueryCriterion queryCriterion) {
        try {
            return table(codeTypeFichier, referentielVersion).selectResult(queryCriterion, connection);
        } catch (Exception ex) {
            throw new ApplicationServerException(ex.getMessage());
        }
    }

    private SelectQueryResult selectResult(Connection connection, String codeTypeFichier, String referentielVersion, QueryCriterion queryCriterion, int pageNumber, int pageSize) {
        try {
            int offset = (pageNumber - 1) * pageSize;
            return table(codeTypeFichier, referentielVersion).selectResult(queryCriterion, connection, pageSize, offset);
        } catch (Exception ex) {
            ex.printStackTrace();
            throw new ApplicationServerException(ex.getMessage());
        }
    }

    private FdxApiTable table(String codeTypeFichier, String referentielVersion) {
        return new FdxApiTable(codeTypeFichier, referentielVersion);
    }

    private PageData getPageData(Connection connection, String codeTypeFichier, String referentielVersion, QueryCriterion queryCriterion, int pageNumber, int pageSize) {

        try {

            SelectQueryResult result = selectResult(connection, codeTypeFichier, referentielVersion, queryCriterion, pageNumber, pageSize);

            List<Map<String, Object>> loadedData = FdxTableUtils.fdxTableRowToListMap(result.rows());
            long totalNumberOfElements = table(codeTypeFichier, referentielVersion).count(queryCriterion, connection);

            PageData pageData = new PageData();
            pageData.setLoadedData(loadedData);
            pageData.setPageNumber(pageNumber);
            pageData.setPageSize(pageSize);
            pageData.setTotalNumberOfElements(totalNumberOfElements);

            return pageData;

        } catch (Exception ex) {
            throw new ApplicationServerException(ex.getMessage());
        }
    }

}