package com.megatim.apifdxweb.core.impl.helper;

import com.megatim.apifdxweb.core.ifaces.helper.DataProductionOperations;
import com.megatim.apifdxweb.core.ifaces.helper.RoutingChecker;
import com.megatim.apifdxweb.model.request.UpdateRequest;
import com.megatim.apifdxweb.tools.AppContext;
import com.megatim.commons.tools.exceptions.ApplicationServerException;
import com.megatim.fdxcommons.core.ifaces.helper.DataInMemoryHandler;
import com.megatim.fdxcommons.model.dataproduction.DataProduction;
import com.megatim.fdxcommons.model.dataproduction.DataProductionSource;
import com.megatim.fdxcommons.model.pojo.CriteriaEntityFromView;
import com.megatim.fdxcommons.tools.database.connection.DBConnection;
import com.megatim.fdxcommons.tools.database.queries.metadata.QueryCriterion;
import com.megatim.fdxcommons.tools.database.tables.FdxApiTable;
import com.megatim.fdxcommons.tools.exceptions.CommonRessourceNotFoundException;
import com.megatim.fdxcommons.tools.utils.CriteriaEntityFromViewToQueryCriterion;
import java.sql.Connection;
import java.time.LocalDateTime;
import java.util.LinkedHashMap;
import java.util.List;
import javax.annotation.Resource;
import javax.enterprise.context.Dependent;
import javax.inject.Inject;
import javax.sql.DataSource;

/**
 *
 * @author Gabuntu
 */
@Dependent
public class DataProductionOperationsImpl implements DataProductionOperations {

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

    @Inject
    private DataInMemoryHandler dataInMemoryHandler;

    @Inject
    private RoutingChecker routingChecker;

    @Override
    public void saveAll(String codeTypeFichier, List<LinkedHashMap<String, Object>> datas, String connectedParticipant) {

        stopIfProductionNotPermitted(codeTypeFichier, connectedParticipant);

        try ( Connection connection = new DBConnection(dataSource).connection()) {
            connection.setAutoCommit(false);

            DataProduction dataProduction = newDataProduction(codeTypeFichier, connectedParticipant);
            table(connection, codeTypeFichier).insert((List<LinkedHashMap<String, Object>>) datas, dataProduction);

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

    @Override
    public void saveOne(String codeTypeFichier, LinkedHashMap<String, Object> data, String connectedParticipant) {

        stopIfProductionNotPermitted(codeTypeFichier, connectedParticipant);

        try ( Connection connection = new DBConnection(dataSource).connection()) {
            connection.setAutoCommit(false);

            DataProduction dataProduction = newDataProduction(codeTypeFichier, connectedParticipant);
            table(connection, codeTypeFichier).insert(data, dataProduction);

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

    @Override
    public void updateAll(String codeTypeFichier, UpdateRequest updateRequest, String connectedParticipant) {

        stopIfProductionNotPermitted(codeTypeFichier, connectedParticipant);

        try ( Connection connection = new DBConnection(dataSource).connection()) {
            connection.setAutoCommit(false);

            QueryCriterion queryCriterion = new CriteriaEntityFromViewToQueryCriterion(updateRequest.getCriteriaEntityFromView()).queryCriterion();
            table(connection, codeTypeFichier).update(updateRequest.getDataToUpdate(), queryCriterion);

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

    @Override
    public void updateOne(String codeTypeFichier, UpdateRequest updateRequest, String connectedParticipant) {

        stopIfProductionNotPermitted(codeTypeFichier, connectedParticipant);

        try ( Connection connection = new DBConnection(dataSource).connection()) {
            connection.setAutoCommit(false);

            QueryCriterion queryCriterion = new CriteriaEntityFromViewToQueryCriterion(updateRequest.getCriteriaEntityFromView()).queryCriterion();
            table(connection, codeTypeFichier).updateOne(updateRequest.getDataToUpdate(), queryCriterion);

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

    @Override
    public void deleteAll(String codeTypeFichier, CriteriaEntityFromView criterionFromView, String connectedParticipant) {

        stopIfProductionNotPermitted(codeTypeFichier, connectedParticipant);

        try ( Connection connection = new DBConnection(dataSource).connection()) {
            connection.setAutoCommit(false);

            QueryCriterion queryCriterion = new CriteriaEntityFromViewToQueryCriterion(criterionFromView).queryCriterion();
            table(connection, codeTypeFichier).delete(queryCriterion);

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

    @Override
    public void deleteOne(String codeTypeFichier, CriteriaEntityFromView criterionFromView, String connectedParticipant) {

        stopIfProductionNotPermitted(codeTypeFichier, connectedParticipant);

        try ( Connection connection = new DBConnection(dataSource).connection()) {
            connection.setAutoCommit(false);

            QueryCriterion queryCriterion = new CriteriaEntityFromViewToQueryCriterion(criterionFromView).queryCriterion();
            table(connection, codeTypeFichier).deleteOne(queryCriterion);

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

    private FdxApiTable table(Connection connection, String codeTypeFichier) {
        return new FdxApiTable(codeTypeFichier, versionReferentiel(), connection);
    }

    private DataProduction newDataProduction(String codeTypeFichier, String codeParticipant) {
        DataProduction dataProduction = new DataProduction();
        dataProduction.setDateProduction(LocalDateTime.now());
        dataProduction.setReferentielVersion(versionReferentiel());
        dataProduction.setCodeTypeFichier(codeTypeFichier);
        dataProduction.setCodeParticipant(codeParticipant);
        dataProduction.setSource(DataProductionSource.API);

        return dataProduction;
    }

    private String versionReferentiel() {
        return dataInMemoryHandler.getDataInMemory().getReferentielEnCours().getVersion();
    }

    private void stopIfProductionNotPermitted(String codeTypeFichier, String connectedParticipant) {
        if (dataInMemoryHandler.getDataInMemory().getReferentielEnCours() == null) {
            throw new CommonRessourceNotFoundException("Aucun référentiel en cours");
        }
        routingChecker.stopIfTypeFichierNotExists(codeTypeFichier, dataInMemoryHandler.getDataInMemory());
        routingChecker.stopIfNotProducer(codeTypeFichier, dataInMemoryHandler.getDataInMemory(), connectedParticipant);
    }

}