Merge pull request #66 from abes-esr/develop

Merge develop dans main
abes-esr · Jul 8, 2024 · 28f6209 · 28f6209
2 parents 433239f + 439daeb
commit 28f6209
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git 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
@@ -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) {