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
---
apifdxweb/api/apifdxweb-service-impl/src/main/java/com/megatim/apifdxweb/service/impl/camel/consumers/FichierDataConsumer.java | 69 ++++++++++++++++++++++++++++++++++
1 files changed, 69 insertions(+), 0 deletions(-)
diff --git a/apifdxweb/api/apifdxweb-service-impl/src/main/java/com/megatim/apifdxweb/service/impl/camel/consumers/FichierDataConsumer.java b/apifdxweb/api/apifdxweb-service-impl/src/main/java/com/megatim/apifdxweb/service/impl/camel/consumers/FichierDataConsumer.java
new file mode 100644
index 0000000..57025d8
--- /dev/null
+++ b/apifdxweb/api/apifdxweb-service-impl/src/main/java/com/megatim/apifdxweb/service/impl/camel/consumers/FichierDataConsumer.java
@@ -0,0 +1,69 @@
+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);
+ }
+
+}
--
Gitblit v1.10.0