From 23a46b4be35277e06ec89f48730eeb694e686be8 Mon Sep 17 00:00:00 2001
From: Kenmegne <stephanie.kenmegne@gmail.com>
Date: Thu, 18 Jun 2026 15:40:06 +0000
Subject: [PATCH] add fdx-commons and fdx-consultation
---
fdx-consultation/fdxconsultation-service-impl/src/main/java/com/megatim/fdxconsultation/service/impl/camel/consumer/ProductionMetaDaConsumer.java | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 52 insertions(+), 0 deletions(-)
diff --git a/fdx-consultation/fdxconsultation-service-impl/src/main/java/com/megatim/fdxconsultation/service/impl/camel/consumer/ProductionMetaDaConsumer.java b/fdx-consultation/fdxconsultation-service-impl/src/main/java/com/megatim/fdxconsultation/service/impl/camel/consumer/ProductionMetaDaConsumer.java
new file mode 100644
index 0000000..40bd770
--- /dev/null
+++ b/fdx-consultation/fdxconsultation-service-impl/src/main/java/com/megatim/fdxconsultation/service/impl/camel/consumer/ProductionMetaDaConsumer.java
@@ -0,0 +1,52 @@
+package com.megatim.fdxconsultation.service.impl.camel.consumer;
+
+import com.megatim.fdxcommons.model.dataproduction.metadata.ProductionMetaData;
+import com.megatim.fdxcommons.model.dtos.dataproduction.ProductionMetaDataDto;
+import com.megatim.fdxcommons.model.enumeration.StatutDataProduction;
+import com.megatim.fdxcommons.tools.database.connection.DBConnection;
+import javax.inject.Inject;
+import org.apache.camel.Handler;
+import com.megatim.fdxconsultation.dao.impl.dataproduction.metadata.CreateDataProductionQuery;
+import com.megatim.fdxconsultation.dao.impl.dataproduction.metadata.CreateProductionMetaDataQuery;
+import com.megatim.fdxconsultation.model.dataproduction.DataProduction;
+import com.megatim.fdxconsultation.model.mappers.MapStructMapper;
+import com.megatim.fdxconsultation.tools.context.AppCommonContext;
+import java.sql.Connection;
+import javax.annotation.Resource;
+import javax.sql.DataSource;
+
+/**
+ *
+ * @author lenovo
+ */
+public class ProductionMetaDaConsumer {
+
+ @Resource(lookup = AppCommonContext.JNDI_NAME)
+ private DataSource dataSource;
+
+ @Inject
+ private MapStructMapper mapper;
+
+ @Inject
+ private com.megatim.fdxcommons.model.mappers.MapStructMapper commonMapper;
+
+ @Handler
+ public void saveData(ProductionMetaDataDto dto) throws Exception {
+ System.out.println("----------------In ProductionMetaDaConsumer--------------------");
+ DataProduction dataProduction = mapper.commonDataProductionDtoToDataProduction(dto.getDataProduction());
+ dataProduction.setId(dto.getDataProduction().getId());
+ dataProduction.setStatutDataProduction(StatutDataProduction.ENCOURS_DE_CONSOMMATION);
+ System.out.println("------------ NbreElts " + dataProduction.getNbreElements() + ", FileName = " + dataProduction.getFileName() + ", IntegrationFileName = " + dataProduction.getIntegrationFileName());
+
+ ProductionMetaData pmd = commonMapper.productionMetaDataDtoToProductionMetaData(dto);
+
+ try ( Connection connection = new DBConnection(dataSource).connection()) {
+ connection.setAutoCommit(false);
+
+ new CreateDataProductionQuery(dataProduction, connection).execute();
+ new CreateProductionMetaDataQuery(pmd, dataProduction.getDataProductionType(), connection).execute();
+
+ connection.commit();
+ }
+ }
+}
--
Gitblit v1.10.0