Debut de réécriture sdu système de logs

batch/src/main/java/fr/abes/item/service/logging/DemandeLoggerService.java

@@ -0,0 +1,48 @@
+package fr.abes.item.service.logging;
+
+import fr.abes.item.entities.item.Demande;
+import fr.abes.item.entities.item.LigneFichier;
+import lombok.Data;
+import lombok.experimental.Accessors;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@Data
+@Accessors(chain = true)
+public class DemandeLoggerService {
+    private Demande demande;
+    private LigneFichier ligneFichier;
+    private List<Long> heureEvenements;
+    private String objetDeTraitementEnCours = "";
+    private String exception = "";
+    StringBuilder sb = new StringBuilder();
+
+    public String logInfo(){
+
+        sb.append("DEMANDE:");
+        if(demande != null){
+            sb.append(demande.getNumDemande());
+        }else{
+            sb.append("NULL");
+        }
+        sb.append("|");
+
+        if(!objetDeTraitementEnCours.isEmpty()){
+            sb.append("TACHE:");
+            sb.append(this.objetDeTraitementEnCours);
+            sb.append("|");
+        }
+
+        if(!objetDeTraitementEnCours.isEmpty()){
+            sb.append("EXCEPTION:");
+            sb.append(this.exception);
+            sb.append("|");
+        }
+
+
+        return sb.toString();
+    }
+}

batch/src/main/java/fr/abes/item/traitement/tasklets/obtention/ProchaineDemandeModification.java

@@ -4,6 +4,7 @@
 import fr.abes.item.entities.item.DemandeModif;
 import fr.abes.item.exception.DemandeCheckingException;
 import fr.abes.item.service.impl.DemandeModifService;
+import fr.abes.item.service.logging.DemandeLoggerService;
 import lombok.NonNull;
 import lombok.extern.slf4j.Slf4j;
 import org.hibernate.exception.ConstraintViolationException;
@@ -24,6 +25,8 @@
 public class ProchaineDemandeModification implements Tasklet, StepExecutionListener {
     @Autowired
     DemandeModifService demandeModifService;
+    @Autowired
+    DemandeLoggerService demandeLoggerService;
 
     private DemandeModif demande;
 
@@ -38,7 +41,7 @@ public ProchaineDemandeModification(int minHour, int maxHour) {
 
     @Override
     public void beforeStep(@NonNull StepExecution stepExecution) {
-        log.info(Constant.JOB_TRAITER_LIGNE_FICHIER_START_MODIF);
+        demandeLoggerService.setObjetDeTraitementEnCours("Obtention de la demande à traiter").setDemande(this.demande).logInfo();
     }
 
     @Override
@@ -52,18 +55,23 @@ public ExitStatus afterStep(StepExecution stepExecution) {
 
     @Override
     public RepeatStatus execute(@NonNull StepContribution stepContribution, @NonNull ChunkContext chunkContext) throws Exception {
-        log.warn(Constant.ENTER_EXECUTE_FROM_GETNEXTDEMANDEMODIFTASKLET);
+        demandeLoggerService.setObjetDeTraitementEnCours("Obtention de la prochaine demande à traiter");
+        demandeLoggerService.logInfo();
         try {
             this.demande = (DemandeModif) demandeModifService.getIdNextDemandeToProceed(this.minHour, this.maxHour);
             if (this.demande == null) {
-                log.warn(Constant.NO_DEMANDE_TO_PROCESS);
+                demandeLoggerService.setObjetDeTraitementEnCours("Pas de demande à traiter, sortie");
+                demandeLoggerService.logInfo();
                 stepContribution.setExitStatus(new ExitStatus("AUCUNE DEMANDE"));
                 return RepeatStatus.FINISHED;
             }
+            demandeLoggerService.setDemande(this.demande);
+            demandeLoggerService.setObjetDeTraitementEnCours("Passage de cette demande au statut en cours");
+            demandeLoggerService.logInfo();
             demandeModifService.changeState(this.demande, Constant.ETATDEM_ENCOURS);
         } catch (DemandeCheckingException e) {
-            log.error(Constant.ERROR_PASSERENCOURS_FROM_GETNEXTDEMANDEMODIFTASKLET
-                    + e);
+            demandeLoggerService.setException("DemandeCheckingException|" + e);
+            demandeLoggerService.logInfo();
             stepContribution.setExitStatus(ExitStatus.FAILED);
             return RepeatStatus.FINISHED;
         } catch (JDBCConnectionException | ConstraintViolationException j){

batch/src/test/java/fr/abes/item/service/logging/DemandeLoggerServiceTest.java

@@ -0,0 +1,19 @@
+package fr.abes.item.service.logging;
+
+import fr.abes.item.entities.item.Demande;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class DemandeLoggerServiceTest {
+
+    private Demande demande;
+    @Test
+    void testLombokAccessors(){
+        DemandeLoggerService demandeLoggerService = new DemandeLoggerService();
+        //log.info(demandeLoggerService.setObjetDeTraitementEnCours("Obtention de la demande à traiter").setDemande(this.demande).logInfo());
+    }
+}