From c73b9347105f576645645b210dbd96e1368c49d5 Mon Sep 17 00:00:00 2001
From: pierre-maraval <pierre.maraval@gmail.com>
Date: Mon, 8 Jul 2024 16:19:02 +0200
Subject: [PATCH] =?UTF-8?q?Fix=20:=20Correction=20increment=20compteur=20c?=
 =?UTF-8?q?urrent=20line=20en=202=20=C3=A9tapes,=20et=20changement=20condi?=
 =?UTF-8?q?tion=20comparaison?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/fr/abes/kafkatosudoc/kafka/KbartListener.java    | 8 ++++----
 .../java/fr/abes/kafkatosudoc/kafka/WorkInProgress.java   | 5 +++--
 2 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java b/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java
index 6316a72..6f2d5b7 100644
--- a/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java
+++ b/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java
@@ -89,13 +89,13 @@ public void listenKbartToCreateFromKafka(ConsumerRecord<String, LigneKbartConnec
             });
         }
 
-
         if (lignesKbart.value().getBESTPPN() != null && !lignesKbart.value().getBESTPPN().isEmpty()) {
             //on alimente la liste des notices d'un package qui sera traitée intégralement
             this.workInProgressMap.get(filename).addNotice(lignesKbart.value());
         }
+        this.workInProgressMap.get(filename).incrementCurrentNbLignes();
         //Si le nombre de lignes traitées est égal au nombre de lignes total du fichier, on est arrivé en fin de fichier, on traite dans le sudoc
-        if (Objects.equals(this.workInProgressMap.get(filename).incrementCurrentNbLignes(), this.workInProgressMap.get(filename).getNbLinesTotal())) {
+        if (this.workInProgressMap.get(filename).getCurrentNbLines().get() == this.workInProgressMap.get(filename).getNbLinesTotal()) {
             log.debug("Traitement des notices existantes dans le Sudoc à partir du kbart");
             traiterPackageDansSudoc(this.workInProgressMap.get(filename).getListeNotices(), filename);
             if (!this.workInProgressMap.get(filename).getErrorMessages().isEmpty())
@@ -374,7 +374,7 @@ public void listenKbartFromKafkaExNihilo(ConsumerRecord<String, LigneKbartConnec
         this.workInProgressMapExNihilo.get(filename).addNotice(ligneKbart.value());
 
         //Si le nombre de lignes traitées est égal au nombre de lignes total du fichier, on est arrivé en fin de fichier, on traite dans le sudoc
-        if (this.workInProgressMapExNihilo.get(filename).getCurrentNbLines().equals(this.workInProgressMapExNihilo.get(filename).getNbLinesTotal())) {
+        if (this.workInProgressMapExNihilo.get(filename).getCurrentNbLines().get() == this.workInProgressMapExNihilo.get(filename).getNbLinesTotal()) {
             log.debug("Traitement des notices existantes dans le Sudoc à parir de ex nihilo");
             SudocService service = new SudocService();
             try {
@@ -454,7 +454,7 @@ public void listenKbartFromKafkaImprime(ConsumerRecord<String, LigneKbartImprime
         this.workInProgressMapImprime.get(filename).addNotice(lignesKbart.value());
 
         //Si le nombre de lignes traitées est égal au nombre de lignes total du fichier, on est arrivé en fin de fichier, on traite dans le sudoc
-        if (this.workInProgressMapImprime.get(filename).getCurrentNbLines().equals(this.workInProgressMapImprime.get(filename).getNbLinesTotal())) {
+        if (this.workInProgressMapImprime.get(filename).getCurrentNbLines().get() == this.workInProgressMapImprime.get(filename).getNbLinesTotal()) {
             log.debug("Traitement des notices existantes dans le Sudoc à partir de imprimé");
 
             String provider = CheckFiles.getProviderFromFilename(filename);
diff --git a/src/main/java/fr/abes/kafkatosudoc/kafka/WorkInProgress.java b/src/main/java/fr/abes/kafkatosudoc/kafka/WorkInProgress.java
index 1e34960..3e276bd 100644
--- a/src/main/java/fr/abes/kafkatosudoc/kafka/WorkInProgress.java
+++ b/src/main/java/fr/abes/kafkatosudoc/kafka/WorkInProgress.java
@@ -37,8 +37,9 @@ public void addNotice(T notice) {
     }
 
     public Integer incrementCurrentNbLignes() {
-        log.debug("Thread : " + Thread.currentThread().getName() + " / Current line : " + (this.currentNbLines.get() + 1) + " / total lines : " + this.getNbLinesTotal());
-        return this.currentNbLines.incrementAndGet();
+        int cpt = this.currentNbLines.incrementAndGet();
+        log.debug("Thread : " + Thread.currentThread().getName() + " / Current line : " + cpt + " / total lines : " + this.getNbLinesTotal());
+        return cpt;
     }
 
     public void addErrorMessagesConnectionCbs(String message) {