package com.megatim.apifdxweb.service.impl.camel.routes.out;

import com.megatim.apifdxweb.tools.AppContext;
import com.megatim.fdxcommons.model.dataproduction.DataProduction;
import com.megatim.fdxcommons.model.enumeration.StatutDataProduction;
import com.megatim.fdxcommons.tools.integration.FdxConsultationIntegrationData;
import com.megatim.fdxcommons.tools.integration.dto.FdxConsultationIntegrationDataDto;
import com.megatim.fdxcommons.tools.resolvers.JacksonMapperFormat;
import java.time.LocalDateTime;
import javax.enterprise.context.ApplicationScoped;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.jta.JtaTransactionErrorHandlerBuilder;

/**
 *
 * @author lenovo
 */
@ApplicationScoped
public class FileIntegrationRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {

        JtaTransactionErrorHandlerBuilder transactionErrorHandler = new JtaTransactionErrorHandlerBuilder();
        errorHandler(transactionErrorHandler);

        onException(Exception.class)
                .handled(true)
                .log("Exception occured: ${exception.message}")
                .logStackTrace(true)
                .end();

        from("direct:" + AppContext.DATA_TO_API_DIRECT)
                .transacted()
                .marshal(JacksonMapperFormat.jacksonDataFormat(FdxConsultationIntegrationDataDto.class))
                .to("rabbitmq:"
                        + com.megatim.fdxcommons.tools.context.AppContext.DATA_INTEGRATION_EXCHANGE
                        + "?queue=" + com.megatim.fdxcommons.tools.context.AppContext.DATA_INTEGRATION_QUEUE
                        + "&routingKey=" + com.megatim.fdxcommons.tools.context.AppContext.DATA_INTEGRATION_ROUTING_KEY
                        + "&autoDelete=false")
                .unmarshal(JacksonMapperFormat.jacksonDataFormat(FdxConsultationIntegrationDataDto.class))
                .process(ex -> {

                    FdxConsultationIntegrationDataDto dto = ex.getIn().getBody(FdxConsultationIntegrationDataDto.class);
                    FdxConsultationIntegrationData integrationData = new FdxConsultationIntegrationData(dto.getRows(), dto.getDataProduction());
                    ex.getIn().setHeader("id", integrationData.getDataProduction().getId());
                    ex.getIn().setHeader("statutDataProduction", StatutDataProduction.CONSOMME.name());
                    ex.getIn().setHeader("dateMiseAJour", LocalDateTime.now());

                    String query = "UPDATE " + DataProduction.class.getSimpleName().toLowerCase()
                            + " SET statutDataProduction= :?statutDataProduction, dateMiseAJour = :?dateMiseAJour"
                            + " WHERE id = :?id";

                    ex.getIn().setBody(query);
                })
                .to("jdbc:datasource?useHeadersAsParameters=true&resetAutoCommit=false")
                .end();
    }

}