Merge pull request #50 from abes-esr/CDE-476-si-force-et-format-incor…

…rect-il-genere-pas-bad ajout check format du fichier incorrect meme en force
abes-esr · Dec 11, 2024 · 8db86f9 · 8db86f9
2 parents 38fa88d + 547bd73
commit 8db86f9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
@@ -78,7 +78,9 @@ public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord<String, Stri
 
             if ((dto.getMessage().contains("Traitement terminé pour fichier " + packageName)) || (dto.getMessage().contains("Traitement refusé du fichier " + packageName))) {
                 saveDatas(workInProgressMap.get(packageName).getMessages());
-                if (!packageName.contains("_FORCE")) {
+                if (!packageName.contains("_FORCE") || workInProgressMap.get(packageName).getMessages().stream().anyMatch(log ->
+                    (log.getNbLine() == -1) && log.getMessage().equals("Format du fichier incorrect")
+                )) {
                     createFileBad(packageName);
                 }
                 workInProgressMap.remove(packageName);