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-core-impl/src/main/java/com/megatim/apifdxweb/core/impl/tmp/TokenTmpManagerImpl.java |   89 ++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 89 insertions(+), 0 deletions(-)

diff --git a/apifdxweb/api/apifdxweb-core-impl/src/main/java/com/megatim/apifdxweb/core/impl/tmp/TokenTmpManagerImpl.java b/apifdxweb/api/apifdxweb-core-impl/src/main/java/com/megatim/apifdxweb/core/impl/tmp/TokenTmpManagerImpl.java
new file mode 100644
index 0000000..47eb204
--- /dev/null
+++ b/apifdxweb/api/apifdxweb-core-impl/src/main/java/com/megatim/apifdxweb/core/impl/tmp/TokenTmpManagerImpl.java
@@ -0,0 +1,89 @@
+/*
+ * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
+ * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
+ */
+package com.megatim.apifdxweb.core.impl.tmp;
+
+import com.megatim.apifdxweb.core.ifaces.helper.RoutingChecker;
+import com.megatim.apifdxweb.core.ifaces.tmp.TokenTmpManager;
+import com.megatim.apifdxweb.dao.ifaces.tmp.TokenTmpDAO;
+import com.megatim.apifdxweb.model.tmp.StatutTmp;
+import com.megatim.apifdxweb.model.tmp.TokenTmp;
+import com.megatim.fdxcommons.core.ifaces.helper.DataInMemoryHandler;
+import com.mgt.rs.security.core.service.AuthenticationTokenService;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+import java.util.UUID;
+import javax.ejb.EJB;
+import javax.enterprise.context.Dependent;
+import javax.inject.Inject;
+import javax.transaction.Transactional;
+
+/**
+ *
+ * @author ASUS
+ */
+@Dependent
+public class TokenTmpManagerImpl implements TokenTmpManager {
+
+    @EJB
+    private TokenTmpDAO dao;
+
+    @Inject
+    private AuthenticationTokenService authenticationTokenService;
+
+    @Inject
+    private DataInMemoryHandler dataInMemoryHandler;
+
+    @Inject
+    private RoutingChecker routingChecker;
+
+    @Override
+    public TokenTmpDAO getDao() {
+        return this.dao;
+    }
+
+    @Override
+    @Transactional
+    public TokenTmp saveEntity(TokenTmp entity, String connectedParticipant) {
+        
+        stopIfProductionNotPermitted(entity.getCodeTypeFichier(), connectedParticipant);
+        
+        TokenTmp foundToken = dao.getByParticipantAndTypeFichier(connectedParticipant, entity.getCodeTypeFichier());
+        if (foundToken != null) {
+            foundToken.setStatutTmp(StatutTmp.EXPIRE);
+            save(foundToken);
+        }
+        
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmss");
+        String str = LocalDateTime.now().format(formatter);
+        UUID uuid = UUID.nameUUIDFromBytes((str + entity.toString()).getBytes());
+
+        entity.setToken(uuid.toString());
+        entity.setCodeParticipant(connectedParticipant);
+        entity.setDateExpiration(entity.getDateCreation().plusMinutes(entity.getValidite()));
+
+        return save(entity);
+
+    }
+
+    @Override
+    public List<TokenTmp> getByStatutTmp(StatutTmp statut) {
+        return dao.getByStatutTmp(statut);
+    }
+
+    @Override
+    public List<TokenTmp> getExpiredToken() {
+        return dao.getExpiredToken();
+    }
+
+    private void stopIfProductionNotPermitted(String codeTypeFichier, String connectedParticipant) {
+        
+        routingChecker.stopIfCurrentReferentielNotExists(dataInMemoryHandler.getDataInMemory());
+        routingChecker.stopIfTypeFichierNotExists(codeTypeFichier, dataInMemoryHandler.getDataInMemory());
+        routingChecker.stopIfNotProducer(codeTypeFichier, dataInMemoryHandler.getDataInMemory(), connectedParticipant);
+    
+    }
+
+}

--
Gitblit v1.10.0