Ajout Constant pour objet de mail

+ ajout methode pour envoyer l'env dans l'objet mail
abes-esr · Sep 25, 2024 · 05fe9da · 05fe9da
1 parent 3d79d0d
commit 05fe9da
Showing 1 changed file with 19 additions and 7 deletions.
diff --git a/src/main/java/fr/abes/kafkatosudoc/service/EmailService.java b/src/main/java/fr/abes/kafkatosudoc/service/EmailService.java
@@ -46,6 +46,10 @@ public class EmailService {
     @Value("${spring.profiles.active}")
     private String env;
 
+    private final String SUBJECT_ERROR_EXNIHILO = "Erreurs lors de la création à partir du kbart";
+    private final String SUBJECT_ERROR_IMPRIME = "Erreurs lors de la création à partir de la notice imprimé";
+    private final String SUBJECT_ERROR_AJOUT_BOUQUET = "Erreurs lors de l'ajout des liens en 469";
+
     public void sendErrorsMessageCreateFromKafka(String filename, WorkInProgress<LigneKbartConnect> workInProgress) throws IOException {
         JsonObject listErrors = Json.createObjectBuilder()
                 .add("kbart info : ", getKbartInfo(filename))
@@ -54,7 +58,7 @@ public void sendErrorsMessageCreateFromKafka(String filename, WorkInProgress<Lig
                 .add(workInProgress.getErrorMessages().stream().filter(m -> m.getType().equals(ERROR_TYPE.ADD469)).count() + " erreur(s) d'ajout de 469", formatErrorMessageListToJson(workInProgress.getErrorMessages().stream().filter(m -> m.getType().equals(ERROR_TYPE.ADD469)).toList()))
                 .add(workInProgress.getErrorMessages().stream().filter(m -> m.getType().equals(ERROR_TYPE.SUPP469)).count() + " erreur(s) de suppression de 469", formatErrorMessageListToJson(workInProgress.getErrorMessages().stream().filter(m -> m.getType().equals(ERROR_TYPE.SUPP469)).toList()))
                 .build();
-        sendErrorsMessage(filename, listErrors);
+        sendErrorsMessage(filename, listErrors, SUBJECT_ERROR_AJOUT_BOUQUET);
     }
 
     private JsonObjectBuilder formatErrorMessageListToJson(List<ErrorMessage> list) {
@@ -72,26 +76,26 @@ public void sendErrorMessagesExNihilo(String filename, WorkInProgress<LigneKbart
                 .add("kbart info : ", getKbartInfo(filename))
                 .add(workInProgress.getErrorMessages().stream().filter(m -> m.getType().equals(ERROR_TYPE.EXNIHILO)).count() + " erreur(s) lors de la création de notice(s) ExNihilo", workInProgress.getErrorMessages().stream().filter(m -> m.getType().equals(ERROR_TYPE.EXNIHILO)).toList().toString())
                 .build();
-        sendErrorsMessage(filename, listErrors);
+        sendErrorsMessage(filename, listErrors, SUBJECT_ERROR_EXNIHILO);
     }
 
     public void sendErrorMessagesImprime(String filename, WorkInProgress<LigneKbartImprime> workInProgress) throws IOException {
         JsonObject listErrors = Json.createObjectBuilder()
                 .add("kbart info : ", getKbartInfo(filename))
                 .add(workInProgress.getErrorMessages().stream().filter(m -> m.getType().equals(ERROR_TYPE.FROMIMPRIME)).count() + " erreur(s) lors de la création de notice(s) électronique(s) à partir d'un imprimé",workInProgress.getErrorMessages().stream().filter(m -> m.getType().equals(ERROR_TYPE.FROMIMPRIME)).toList().toString())
                 .build();
-        sendErrorsMessage(filename, listErrors);
+        sendErrorsMessage(filename, listErrors, SUBJECT_ERROR_IMPRIME);
     }
 
-    private void sendErrorsMessage(String filename, JsonObject listErrors) throws IOException {
+    private void sendErrorsMessage(String filename, JsonObject listErrors, String subject) throws IOException {
         // Création du chemin d'accès pour le fichier .json
         Path jsonFilePath = Path.of("errorsList_" + filename + ".json");
 
         //  Création du fichier
         createAttachment(listErrors, jsonFilePath);
 
         //  Création du mail
-        String requestJson = mailToJSON(this.recipient, "[CONVERGENCE]["+env.toUpperCase()+"] Erreurs lors du traitement sur le fichier " + filename, "[CONVERGENCE]["+env.toUpperCase()+"] Erreurs lors du traitement sur le fichier " + filename);
+        String requestJson = mailToJSON(this.recipient, getTag() + " " + subject, "Erreurs lors du traitement sur le fichier " + filename);
 
         //  Récupération du fichier
         File file = jsonFilePath.toFile();
@@ -113,7 +117,7 @@ public void sendErrorMailSuppressionPackage(String packageName, String provider,
                 e.getMessage();
 
         //  Création du mail
-        String requestJson = mailToJSON(this.recipient, "[CONVERGENCE]["+env.toUpperCase()+"] Erreur lors de la suppression du package " + packageName + " / " + provider, body);
+        String requestJson = mailToJSON(this.recipient, getTag() + " Erreur lors de la suppression du package " + packageName + " / " + provider, body);
         //  Envoi du message par mail
         sendMail(requestJson);
         log.info("L'email a été correctement envoyé.");
@@ -132,7 +136,7 @@ public void sendErrorMailProviderPackageDeleted(List<String> listError, String f
         createAttachment(listErrors, jsonFilePath);
 
         // Création du mail
-        String requestJson = mailToJSON(this.recipient, "[CONVERGENCE]["+env.toUpperCase()+"] Erreur lors de la suppression des liens vers les notices bouquet", "[CONVERGENCE]["+env.toUpperCase()+"] Erreur lors de la suppression des liens vers les notices bouquet");
+        String requestJson = mailToJSON(this.recipient, getTag() + " Erreur lors de la suppression des liens vers les notices bouquet", "Erreur lors de la suppression des liens vers les notices bouquet");
 
         //  Récupération du fichier
         File file = jsonFilePath.toFile();
@@ -254,4 +258,12 @@ protected void createAttachment(JsonObject dataLines, Path path) {
             throw new RuntimeException(e);
         }
     }
+
+    private String getTag(){
+        if(env.equalsIgnoreCase("PROD")){
+            return "[CONVERGENCE]";
+        } else {
+            return "[CONVERGENCE][" + env.toUpperCase() + "]";
+        }
+    }
 }