ITEM-241 : Ajout appender personnalisé

batch/src/main/java/fr/abes/item/batch/traitement/LireLigneFichierTasklet.java

@@ -11,6 +11,7 @@
 import fr.abes.item.core.service.ILigneFichierService;
 import lombok.NonNull;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.logging.log4j.ThreadContext;
 import org.hibernate.exception.ConstraintViolationException;
 import org.hibernate.exception.JDBCConnectionException;
 import org.springframework.batch.core.ExitStatus;
@@ -110,6 +111,8 @@ public ExitStatus afterStep(StepExecution stepExecution) {
             stepExecution.getJobExecution().getExecutionContext().put("lignes", this.lignesFichier);
             stepExecution.getJobExecution().getExecutionContext().put("demandeId", this.demandeId);
             stepExecution.getJobExecution().getExecutionContext().put("typeDemande", this.typeDemande.toString());
+            ThreadContext.put("demandeId", String.valueOf(this.demandeId));
+            ThreadContext.put("typeDemande", this.typeDemande.toString());
         }
         return stepExecution.getExitStatus();
     }

batch/src/main/resources/log4j2.xml

@@ -7,13 +7,14 @@
             <PatternLayout
                     pattern="%style{%d{ISO8601}}{black} %highlight{%-5level }[%style{%t}{bright,blue}] %style{%C{1.}}{dark,yellow}: %msg%n%throwable" />
         </Console>
+        <ItemLogAppender name="ItemLogAppender" />
     </Appenders>
     <Loggers>
         <Root level="info">
             <AppenderRef ref="Console"/>
         </Root>
         <Logger name="fr.abes.item" level="debug" additivity="false">
-            <AppenderRef ref="Console"/>
+            <AppenderRef ref="ItemLogAppender"/>
         </Logger>
     </Loggers>
 </Configuration>

core/src/main/java/fr/abes/item/core/configuration/ItemLogAppender.java

@@ -0,0 +1,75 @@
+package fr.abes.item.core.configuration;
+
+import org.apache.logging.log4j.Level;
+import org.apache.logging.log4j.ThreadContext;
+import org.apache.logging.log4j.core.Appender;
+import org.apache.logging.log4j.core.Filter;
+import org.apache.logging.log4j.core.LogEvent;
+import org.apache.logging.log4j.core.appender.AbstractAppender;
+import org.apache.logging.log4j.core.config.plugins.Plugin;
+import org.apache.logging.log4j.core.config.plugins.PluginAttribute;
+import org.apache.logging.log4j.core.config.plugins.PluginElement;
+import org.apache.logging.log4j.core.config.plugins.PluginFactory;
+
+@Plugin(name = "ItemLogAppender", category = "core", elementType = Appender.ELEMENT_TYPE)
+public class ItemLogAppender extends AbstractAppender {
+
+    // Utilisation d'un ThreadLocal pour stocker l'heure de début de chaque méthode
+    private static final ThreadLocal<Long> startTime = new ThreadLocal<>();
+
+    // Seuil en ms au dessus duquel on veut afficher un message
+    private final int msSeuilDetection = 0;
+
+    protected ItemLogAppender(String name, Filter filter) {
+        super(name, filter, null);
+    }
+
+    // Méthode à appeler pour démarrer le chronométrage
+    public static void startMethodExecution() {
+        startTime.set(System.currentTimeMillis());
+    }
+
+    /**
+     * Appender permettant une normalisation des logs
+     * Pour obtenir le temps d'execution d'une méthode, ajoutez
+     * ItemLogAppender.startMethodExecution();
+     * au début d'une méthode. L'appender calcule par méthode sans
+     * besoin d'une borne d'arrêt ou de fin
+     * @param event
+     */
+    @Override
+    public void append(LogEvent event) {
+        if (event.getLevel().isMoreSpecificThan(Level.INFO)) {
+            String originalMessage = event.getMessage().getFormattedMessage();
+            String demandeId = ThreadContext.get("demandeId");
+            String typeDemande = ThreadContext.get("typeDemande");
+            if (demandeId != null && typeDemande != null) {
+                // Calcul du temps d'exécution
+                Long startTimeValue = startTime.get();
+                long executionTime = startTimeValue != null ? System.currentTimeMillis() - startTimeValue : -1;
+
+                if (executionTime < msSeuilDetection) {
+                    System.out.println("DEM_" + typeDemande + "_" + demandeId + " / "
+                            + event.getSource().getClassName() + " / "
+                            + event.getSource().getMethodName() + " : "
+                            + originalMessage);
+                }
+                //Uniquement si un ItemLogAppender.startMethodExecution(); à été placé au début d'une méthode
+                else{
+                    System.out.println("DEM_" + typeDemande + "_" + demandeId + " / "
+                            + event.getSource().getClassName() + " / "
+                            + event.getSource().getMethodName() + " : "
+                            + originalMessage + " / Execution time: " + executionTime + " ms");
+                }
+            }
+        }
+    }
+
+    // Méthode statique pour créer l'instance de l'appender via le fichier de configuration
+    @PluginFactory
+    public static ItemLogAppender createAppender(
+            @PluginAttribute("name") String name,
+            @PluginElement("Filter") Filter filter) {
+        return new ItemLogAppender(name, filter);
+    }
+}