/*
 * 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.service.impl.camel.routes.timers.processor;

import com.megatim.fdxcommons.model.dataproduction.DataProductionToDelete;
import javax.enterprise.context.Dependent;
import com.megatim.fdxcommons.model.enumeration.Operateur;
import com.megatim.fdxcommons.model.enumeration.StatutDataProduction;
import com.megatim.fdxcommons.tools.database.connection.DBConnection;
import com.megatim.fdxcommons.tools.database.queries.DeleteTableDataQuery;
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.fdxconsultation.core.ifaces.dataproduction.DataProductionManager;
import com.megatim.fdxconsultation.core.ifaces.dataproduction.DataProductionToDeleteManager;
import com.megatim.fdxconsultation.core.impl.factory.FdxConsultationTableFactory;
import com.megatim.fdxconsultation.model.dataproduction.DataProduction;
import com.megatim.fdxconsultation.service.ifaces.timer.processor.DeleteDataProductionJob;
import com.megatim.fdxconsultation.tools.context.AppCommonContext;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Arrays;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.Resource;
import javax.inject.Inject;
import javax.sql.DataSource;
import javax.transaction.Transactional;

/**
 *
 * @author ASUS
 */
@Dependent
public class DeleteDataProductionJobImpl implements DeleteDataProductionJob {

    @Inject
    private DataProductionToDeleteManager dataProdToDeleteManager;

    @Inject
    private DataProductionManager dataProdManager;

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

    @Override
    public void delete() throws Exception {
        List<DataProductionToDelete> liste = dataProdToDeleteManager.findAll(null, Arrays.asList(), Arrays.asList());

        if (liste != null && !liste.isEmpty()) {

            try ( Connection connection = new DBConnection(dataSource).connection()) {

                liste.stream().forEach(dt -> {
                    try {
                        DataProduction dataProduction = dataProdManager.getById(dt.getId());

                        if (dataProduction != null && dataProduction.getStatutDataProduction().equals(StatutDataProduction.A_CONSOMMER)) {
                            System.out.println("------------------In Consultation DeleteDataProductionTimer dataProductionId = " + dt.getId() + " --------------------------------");
                            deleteDataProductionToDelete(dataProduction, connection);
                        }
                    } catch (Exception ex) {
                        Logger.getLogger(DeleteDataProductionJobImpl.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
                    }
                });
            } catch (Exception ex) {
                Logger.getLogger(DeleteDataProductionJobImpl.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
            }
        }
    }

    @Transactional
    private void deleteDataProductionToDelete(DataProduction dataProduction, Connection connection) throws SQLException, Exception {
        System.out.println("------------------------------------------in Consultation deleteDataProductionToDelete------------------------------------");
        FdxConsultationTable consTable = FdxConsultationTableFactory.createTable(dataProduction.getCodeTypeFichier(), dataProduction.getReferentielVersion(), connection);
        new DeleteTableDataQuery(consTable.getTableName().name(connection),
                connection,
                deleteTableDataCriterion(dataProduction.getId())
        ).execute();

        String query = "DELETE FROM dataproductiontodelete WHERE id = ?";

        try ( PreparedStatement statement = connection.prepareStatement(query)) {
            statement.setLong(1, dataProduction.getId());
            statement.executeUpdate();
        }
    }

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