package com.megatim.fdxconsultation.service.impl.camel.routes.in;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.SerializationFeature;
|
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
|
import com.megatim.fdxcommons.model.dtos.dataproduction.ProductionMetaDataDto;
|
import com.megatim.fdxcommons.tools.context.AppContext;
|
import com.megatim.fdxcommons.tools.database.connection.DBConnection;
|
import com.megatim.fdxcommons.tools.database.queries.EchecIntegrationQueries;
|
import com.megatim.fdxcommons.tools.database.tables.FdxConsultationTable;
|
import com.megatim.fdxconsultation.core.ifaces.integration.EchecIntegrationManager;
|
import com.megatim.fdxconsultation.service.impl.camel.consumer.ProductionMetaDaConsumer;
|
import com.megatim.fdxconsultation.tools.context.AppCommonContext;
|
import java.sql.Connection;
|
import java.sql.SQLException;
|
import java.util.logging.Level;
|
import java.util.logging.Logger;
|
import javax.annotation.Resource;
|
import javax.inject.Inject;
|
import javax.sql.DataSource;
|
import org.apache.camel.Exchange;
|
import org.apache.camel.builder.RouteBuilder;
|
import org.apache.camel.component.jackson.JacksonDataFormat;
|
|
/**
|
*
|
* @author lenovo
|
*/
|
public class ProductionMetaDataRoute extends RouteBuilder {
|
|
@Inject
|
private EchecIntegrationManager echecIntegrationManager;
|
|
@Resource(lookup = AppCommonContext.JNDI_NAME)
|
private DataSource dataSource;
|
|
@Override
|
public void configure() throws Exception {
|
|
ObjectMapper mapper = new ObjectMapper();
|
mapper.registerModule(new JavaTimeModule());
|
mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
|
|
JacksonDataFormat jacksonDataFormat = new JacksonDataFormat();
|
jacksonDataFormat.setObjectMapper(mapper);
|
jacksonDataFormat.setUnmarshalType(ProductionMetaDataDto.class);
|
|
onException(Exception.class)
|
.handled(false)
|
.log("Exception occured: ${exception.message}")
|
.logStackTrace(true)
|
.process(ex -> {
|
System.out.println("---------------------In Exception process----------------------------");
|
ProductionMetaDataDto dto = ex.getIn().getBody(ProductionMetaDataDto.class);
|
|
if (echecIntegrationManager.getById(dto.getDataProduction().getId()) == null) {
|
updateDb(dto);
|
}
|
})
|
.end();
|
|
from("rabbitmq:"
|
+ AppContext.DATA_INTEGRATION_EXCHANGE
|
+ "?queue=" + AppContext.DATA_INTEGRATION_QUEUE
|
+ "&routingKey=" + AppContext.DATA_INTEGRATION_ROUTING_KEY
|
+ "&autoDelete=false"
|
+ "&autoAck=false")//Désactiver l'auto acquittement du message
|
// .log("************************In FdxConsultation*****************************")
|
.errorHandler(defaultErrorHandler()
|
.maximumRedeliveries(3)
|
.onExceptionOccurred(ex -> {
|
Throwable caused = ex.getProperty(Exchange.EXCEPTION_CAUGHT, Throwable.class);
|
caused.printStackTrace();
|
|
}))
|
.unmarshal(jacksonDataFormat)
|
.log("------------------------------In ProductionMetaDataRoute-----------------------------------")
|
.bean(ProductionMetaDaConsumer.class);
|
}
|
|
private void updateDb(ProductionMetaDataDto dto) {
|
FdxConsultationTable consTable = new FdxConsultationTable(dto.getDataProduction().getCodeTypeFichier(), dto.getDataProduction().getReferentielVersion());
|
|
try ( Connection connection = new DBConnection(dataSource).connection()) {
|
connection.setAutoCommit(false);
|
|
consTable.removeUnCompleteData(connection, dto.getDataProduction().getId());
|
new EchecIntegrationQueries(connection, dto.getDataProduction().getId()).save();
|
|
connection.commit();
|
|
} catch (SQLException ex) {
|
Logger.getLogger(ProductionMetaDataRoute.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
|
} catch (Exception ex) {
|
Logger.getLogger(ProductionMetaDataRoute.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
|
}
|
}
|
}
|
