[PAGOPA-2341] fix: refactored RPT_EXTRACTED status

pagopa · Nov 14, 2024 · 85de073 · 85de073
1 parent 4414192
commit 85de073
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/it/gov/pagopa/wispconverter/repository/model/enumz/WorkflowStatus.java b/src/main/java/it/gov/pagopa/wispconverter/repository/model/enumz/WorkflowStatus.java
@@ -8,7 +8,7 @@
 public enum WorkflowStatus {
 
     // === INTERNAL ===
-    RPTS_EXTRACTED(EventCategoryEnum.INTERNAL, "Data extracted from all analyzed RPTs"),
+    RPT_EXTRACTED(EventCategoryEnum.INTERNAL, "Data extracted from all analyzed RPTs"),
     FOUND_RT_IN_STORAGE(EventCategoryEnum.INTERNAL, "RT found in storage"),
     RPT_TIMER_DELETED(EventCategoryEnum.INTERNAL, "Timer RPT deleted from the cache"),
     ECOMMERCE_HANG_TIMER_CREATED(EventCategoryEnum.INTERNAL, "Ecommerce hang timer created"),

diff --git a/...ain/java/it/gov/pagopa/wispconverter/repository/secondary/ReEventRepositorySecondary.java b/...ain/java/it/gov/pagopa/wispconverter/repository/secondary/ReEventRepositorySecondary.java
@@ -60,7 +60,7 @@ List<ReEventEntity> findBySessionIdAndStatusAndPartitionKey(@Param("date") Strin
             "AND ( " +
             "(c.status = 'TRIGGER_PRIMITIVE_PROCESSED' AND c.businessProcess != 'nodoChiediCopiaRT') " +
             "OR " +
-            "(c.businessProcess = 'redirect' AND c.status = 'RPTS_EXTRACTED')" +
+            "(c.businessProcess = 'redirect' AND c.status = 'RPT_EXTRACTED')" +
             " ) " +
             "GROUP BY c.sessionId " +
             ") AS wispSession " +

diff --git a/src/main/java/it/gov/pagopa/wispconverter/service/RPTExtractorService.java b/src/main/java/it/gov/pagopa/wispconverter/service/RPTExtractorService.java
@@ -313,7 +313,7 @@ private void generateRE(SessionDataDTO sessionData) {
                 MDC.put(Constants.MDC_DOMAIN_ID, rpt.getRpt().getDomain().getDomainId());
                 MDC.put(Constants.MDC_IUV, rpt.getIuv());
                 MDC.put(Constants.MDC_CCP, rpt.getCcp());
-                reService.sendEvent(WorkflowStatus.RPTS_EXTRACTED);
+                reService.sendEvent(WorkflowStatus.RPT_EXTRACTED);
             }
         }
     }