From 157411162e273af64f881dd3bc73ede735ab9e4f Mon Sep 17 00:00:00 2001
From: FedericoRuzzier <49512050+FedericoRuzzier@users.noreply.github.com>
Date: Wed, 24 Jul 2024 11:07:26 +0200
Subject: [PATCH 1/3] PAGOPA-1745 adding logs for broker and station

---
 src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java b/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java
index 481f028..f82abf4 100644
--- a/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java
+++ b/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java
@@ -74,6 +74,7 @@ public void run(
                                     .orElseThrow(() -> new RuntimeException(String.format("No data present in api config database for PA %s", organization)));
                             String idStation = stationBroker.getStationCode();
                             String idBroker = stationBroker.getBrokerCode();
+                            logger.log(Level.INFO, () -> "[RetrieveFlows] idPa: " + organization + ", idIntermediario: " + idBroker + ", idStazione: " + idStation );
                             // call NODO dei pagamenti
                             nodeClient.nodoChiediElencoFlussiRendicontazione(organization, idBroker, idStation);
 

From b461654c57bad562ea788c9d1b44ee53786446e5 Mon Sep 17 00:00:00 2001
From: FedericoRuzzier <49512050+FedericoRuzzier@users.noreply.github.com>
Date: Wed, 24 Jul 2024 11:13:55 +0200
Subject: [PATCH 2/3] PAGOPA-1745 add nodochiedielencoflussi in log

---
 src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java b/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java
index f82abf4..0e7e706 100644
--- a/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java
+++ b/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java
@@ -74,7 +74,7 @@ public void run(
                                     .orElseThrow(() -> new RuntimeException(String.format("No data present in api config database for PA %s", organization)));
                             String idStation = stationBroker.getStationCode();
                             String idBroker = stationBroker.getBrokerCode();
-                            logger.log(Level.INFO, () -> "[RetrieveFlows] idPa: " + organization + ", idIntermediario: " + idBroker + ", idStazione: " + idStation );
+                            logger.log(Level.INFO, () -> "[RetrieveFlows][NodoChiediElencoFlussiRendicontazione] idPa: " + organization + ", idIntermediario: " + idBroker + ", idStazione: " + idStation );
                             // call NODO dei pagamenti
                             nodeClient.nodoChiediElencoFlussiRendicontazione(organization, idBroker, idStation);
 

From a772f24de2c46cc81c2dc55c764b8e6e00dec4e5 Mon Sep 17 00:00:00 2001
From: FedericoRuzzier <49512050+FedericoRuzzier@users.noreply.github.com>
Date: Wed, 24 Jul 2024 11:18:18 +0200
Subject: [PATCH 3/3] PAGOPA-1745 add logs

---
 src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java b/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java
index 0e7e706..a6c5d80 100644
--- a/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java
+++ b/src/main/java/it/gov/pagopa/reporting/RetrieveFlows.java
@@ -86,7 +86,7 @@ public void run(
                             if (faultBean != null) {
                                 logger.log(Level.WARNING, () -> "[RetrieveFlows] faultBean DESC " + faultBean.getDescription());
                             } else if (elencoFlussi != null) {
-                                logger.log(Level.INFO, () -> "[RetrieveFlows] elencoFlussi PA " + organization + " TotRestituiti " + elencoFlussi.getTotRestituiti());
+                                logger.log(Level.INFO, () -> "[RetrieveFlows] elencoFlussi PA " + organization + ", idIntermediario: " + idBroker + ", idStazione: " + idStation + " TotRestituiti " + elencoFlussi.getTotRestituiti());
                                 flowsService.flowsProcessing(elencoFlussi.getIdRendicontazione(), organization);
                             }
                         } catch (ClientTransportException e) {