package com.megatim.apifdxweb.service.impl.scheduler;
|
|
import com.megatim.apifdxweb.core.ifaces.helper.ApiRequestDataExporter;
|
import com.megatim.apifdxweb.core.ifaces.dataproduction.DataProductionManager;
|
import com.megatim.apifdxweb.tools.AppContext;
|
import com.megatim.fdxcommons.tools.utils.CustomColumns;
|
import com.megatim.fdxcommons.tools.integration.FdxConsultationIntegrationData;
|
import com.megatim.fdxcommons.model.enumeration.Operateur;
|
import javax.enterprise.context.Dependent;
|
import javax.inject.Inject;
|
import com.megatim.apifdxweb.service.ifaces.scheduler.TypeFichierDataJob;
|
import com.megatim.apifdxweb.service.impl.camel.config.CamelRouteConfiguration;
|
import com.megatim.fdxcommons.model.dataproduction.DataProduction;
|
import com.megatim.fdxcommons.model.dataproduction.DataProductionSource;
|
import com.megatim.fdxcommons.model.enumeration.CriteriaLogicConnector;
|
import com.megatim.fdxcommons.model.enumeration.StatutDataProduction;
|
import com.megatim.fdxcommons.model.searchentities.DataProductionSearch;
|
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.DataProductionIdColumnDefinition;
|
import com.megatim.fdxcommons.tools.database.tables.FdxApiTable;
|
import com.megatim.fdxcommons.tools.integration.dto.FdxConsultationIntegrationDataDto;
|
import java.util.Arrays;
|
import java.util.logging.Level;
|
import java.util.logging.Logger;
|
import org.apache.camel.ProducerTemplate;
|
import org.apache.camel.cdi.CdiCamelContext;
|
import com.megatim.fdxcommons.tools.mappers.FdxTableMapper;
|
import java.io.IOException;
|
import java.sql.Connection;
|
import java.util.List;
|
import javax.annotation.Resource;
|
import javax.sql.DataSource;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
@Dependent
|
public class TypeFichierDataJobImpl implements TypeFichierDataJob {
|
|
@Resource(lookup = AppContext.JNDI_NAME)
|
private DataSource dataSource;
|
|
@Inject
|
private DataProductionManager dataProductionManager;
|
|
@Inject
|
private CdiCamelContext camelContext;
|
|
@Inject
|
private ApiRequestDataExporter dataExporter;
|
|
@Inject
|
private FdxTableMapper fdxTableMapper;
|
|
@Override
|
public void publishData() {
|
|
List<DataProduction> dataProductions = dataProductionsToPublish();
|
|
for (DataProduction d : dataProductions) {
|
QueryCriterion queryCriterion = constructQueryCriterion(d);
|
|
try ( Connection connection = new DBConnection(dataSource).connection()) {
|
SelectQueryResult result = new FdxApiTable(
|
d.getCodeTypeFichier(),
|
d.getReferentielVersion(),
|
connection
|
).selectResultWithAllColumns(queryCriterion);
|
FdxConsultationIntegrationData integrationData = new FdxConsultationIntegrationData(fdxTableMapper.fdxTableRowListToFdxTableRowDtoList(result.rows()), d);
|
|
if (!integrationData.getRows().isEmpty()) {
|
System.out.println("********************dataProduction Id " + integrationData.getDataProduction().getId() + " rows to send " + integrationData.getRows().size());
|
sendData(integrationData);
|
System.out.println("****************************Really send " + integrationData.getDataProduction().getId());
|
}
|
} catch (Exception ex) {
|
Logger.getLogger(TypeFichierDataJobImpl.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
|
throw new com.megatim.commons.tools.exceptions.ApplicationServerException(ex.getMessage());
|
}
|
}
|
|
}
|
|
private QueryCriterion constructQueryCriterion(DataProduction d) {
|
|
if (d.getDateMiseAJour() == null) {
|
return new QueryCriterion(new DataProductionIdColumnDefinition().name(),
|
d.getId(),
|
Operateur.EQUALS,
|
null,
|
Arrays.asList());
|
} else {
|
return new QueryCriterion(null, null, null, CriteriaLogicConnector.AND,
|
Arrays.asList(new QueryCriterion(new DataProductionIdColumnDefinition().name(),
|
d.getId(),
|
Operateur.EQUALS,
|
null,
|
Arrays.asList()),
|
new QueryCriterion(CustomColumns.DATE_ACTION_COLUMN,
|
d.getDateMiseAJour(),
|
Operateur.EQUALS,
|
null,
|
Arrays.asList())
|
));
|
}
|
}
|
|
private void sendData(FdxConsultationIntegrationData integrationData) throws IOException {
|
System.out.println("*************************PRODUCING DATA FOR FILE " + integrationData.getDataProduction().getCodeTypeFichier());
|
|
if (integrationData.getDataProduction().getSource().equals(DataProductionSource.API)) {
|
String standaloneTmpDir
|
= new CamelRouteConfiguration(AppContext.PROPERTY_FILE_PATH)
|
.standaloneTmpDir();
|
dataExporter.export(integrationData, standaloneTmpDir);
|
}
|
|
ProducerTemplate producerTemplate = camelContext.createProducerTemplate();
|
producerTemplate.sendBody("direct:" + AppContext.DATA_TO_API_DIRECT,
|
new FdxConsultationIntegrationDataDto(integrationData.getRows(), integrationData.getDataProduction()));
|
|
}
|
|
private List<DataProduction> dataProductionsToPublish() {
|
DataProductionSearch searchEntity = new DataProductionSearch();
|
searchEntity.setStatutDataProduction(StatutDataProduction.A_CONSOMMER);
|
|
List<DataProduction> dataProductions = dataProductionManager.getAll(searchEntity);
|
|
return dataProductions;
|
|
}
|
}
|
