package com.megatim.apifdxweb.service.impl.camel.consumers;
|
|
import com.megatim.apifdxweb.model.camel.historique.ConsumedFilesHistory;
|
import com.megatim.apifdxweb.model.camel.historique.ConsumedFileType;
|
import com.megatim.apifdxweb.tools.AppContext;
|
import com.megatim.fdxcommons.model.dataproduction.DataProduction;
|
import com.megatim.fdxcommons.model.dataproduction.DataProductionSource;
|
import com.megatim.fdxcommons.tools.database.connection.DBConnection;
|
import com.megatim.fdxcommons.tools.database.tables.FdxApiTable;
|
import org.apache.camel.Handler;
|
import com.megatim.fdxcommons.tools.integration.ApiIntegrationData;
|
import java.sql.Connection;
|
import java.sql.SQLException;
|
import java.time.LocalDateTime;
|
import javax.annotation.Resource;
|
import javax.inject.Inject;
|
import javax.naming.NamingException;
|
import javax.sql.DataSource;
|
import org.apache.camel.cdi.CdiCamelContext;
|
import com.megatim.apifdxweb.core.ifaces.camel.historique.ConsumedFilesHistoryManager;
|
|
/**
|
*
|
* @author lenovo
|
*/
|
public class FichierDataConsumer {
|
|
@Resource(lookup = AppContext.JNDI_NAME)
|
private DataSource dataSource;
|
|
@Inject
|
ConsumedFilesHistoryManager fichierHistoriqueManger;
|
|
@Inject
|
private CdiCamelContext camelContext;
|
|
@Handler
|
public void saveFileData(ApiIntegrationData integrationData) throws Exception {
|
insert(integrationData);
|
}
|
|
private void insert(ApiIntegrationData integrationData) throws SQLException, NamingException, Exception {
|
DataProduction dataProduction = new DataProduction();
|
dataProduction.setDateProduction(LocalDateTime.now());
|
dataProduction.setReferentielVersion(integrationData.getReferentielVersion());
|
dataProduction.setCodeTypeFichier(integrationData.getCodeTypeFichier());
|
dataProduction.setSource(DataProductionSource.FICHIER);
|
dataProduction.setFileName(integrationData.getFileName());
|
dataProduction.setFileDate(integrationData.getFileDate());
|
|
try ( Connection connection = new DBConnection(dataSource).connection()) {
|
new FdxApiTable(integrationData.getCodeTypeFichier(),
|
integrationData.getReferentielVersion(),
|
connection)
|
.insert(integrationData.getData(), dataProduction);
|
}
|
insertFichierHistorique(integrationData.getFileName());
|
}
|
|
private void insertFichierHistorique(String fileName) {
|
ConsumedFilesHistory fichHist = new ConsumedFilesHistory();
|
fichHist.setDateCreation(LocalDateTime.now());
|
fichHist.setFileName(fileName);
|
fichHist.setConsumedFileType(ConsumedFileType.DONNEES);
|
|
fichierHistoriqueManger.save(fichHist);
|
}
|
|
}
|
