package com.megatim.fdxconsultation.core.impl.helper;
|
|
import com.megatim.fdxcommons.core.ifaces.customtypefichier.DynamicClassCreator;
|
import com.megatim.fdxcommons.core.ifaces.db.ReferentielDataSaver;
|
import com.megatim.fdxcommons.core.ifaces.helper.DataInMemoryHandler;
|
import com.megatim.fdxcommons.core.ifaces.helper.ReferentielConsumptionHelper;
|
import com.megatim.fdxcommons.core.ifaces.helper.referentiel.DynamicTableCreator;
|
import com.megatim.fdxcommons.core.ifaces.helper.referentiel.TableDefinitionFilter;
|
import com.megatim.fdxcommons.model.pojo.ReferentielToImportData;
|
import com.megatim.fdxcommons.model.referentiel.Referentiel;
|
import com.megatim.fdxconsultation.core.ifaces.helper.TableauBordHandler;
|
import com.megatim.fdxconsultation.core.ifaces.referentiel.ReferentielManager;
|
import com.megatim.fdxconsultation.tools.context.AppCommonContext;
|
import javax.annotation.Resource;
|
import javax.enterprise.context.Dependent;
|
import javax.inject.Inject;
|
import javax.sql.DataSource;
|
import javax.transaction.Transactional;
|
import com.megatim.fdxconsultation.core.ifaces.referentiel.historique.ReferentielIntegrationHistoriqueManager;
|
import com.megatim.fdxcommons.model.referentiel.historique.ReferentielIntegrationHistorique;
|
import java.util.List;
|
import com.megatim.fdxcommons.model.referentiel.historique.pojo.TableDefinitionFiltered;
|
import java.util.ArrayList;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
@Dependent
|
public class ReferentielConsumptionHelperImpl implements ReferentielConsumptionHelper {
|
|
@Inject
|
private DynamicClassCreator dynamicClassCreator;
|
|
@Inject
|
TableauBordHandler tableauBordHandler;
|
|
@Inject
|
ReferentielManager referentielManager;
|
|
@Inject
|
private DynamicTableCreator dynamicTableCreator;
|
|
@Inject
|
private ReferentielDataSaver referentielDataSaver;
|
|
@Inject
|
private DataInMemoryHandler dataInMemoryHandler;
|
|
@Resource(lookup = AppCommonContext.JNDI_NAME)
|
private DataSource dataSource;
|
|
@Inject
|
private ReferentielIntegrationHistoriqueManager refIntegrationHistoriqueManager;
|
|
@Inject
|
TableDefinitionFilter tableDefinitionFilter;
|
|
@Override
|
@Transactional
|
public void consume(ReferentielToImportData referentielToImportData) throws Exception {
|
Referentiel previousRef = referentielManager.getReferentielEnCours();
|
|
//On enregistre les données de référentiel
|
referentielDataSaver.persist(referentielToImportData);
|
|
List<ReferentielIntegrationHistorique> refsHistoriqueIntegration = previousRef == null
|
? new ArrayList<>()
|
: refIntegrationHistoriqueManager.suitableIntegrationHistorique(previousRef.getVersion());
|
|
TableDefinitionFiltered tableDefinitionFiltered = tableDefinitionFilter
|
.doFilter(previousRef == null ? null : previousRef.getVersion(),
|
referentielToImportData,
|
refsHistoriqueIntegration);
|
|
dynamicTableCreator.createDynamicTables(tableDefinitionFiltered.getTablesToCreate());
|
saveRefIntegrationHistorique(tableDefinitionFiltered.getRefIntegrationHistorique());
|
|
//Charger les nouvelles informations du référentiel dans un objet en mémoire
|
dataInMemoryHandler.initializeDataInMemory();
|
|
//Charger les nouvelles informations du référentiel dans un objet en mémoire
|
dataInMemoryHandler.initializeDataInMemory();
|
|
}
|
|
private void saveRefIntegrationHistorique(List<ReferentielIntegrationHistorique> refIntHistoriques) {
|
for (ReferentielIntegrationHistorique r : refIntHistoriques) {
|
refIntegrationHistoriqueManager.save(r);
|
}
|
}
|
}
|
