aggiunto log erroru

ems-engine/src/main/java/it/integry/ems/retail/service/GiacenzaService.java

@@ -30,6 +30,7 @@ import org.springframework.stereotype.Service;
 import java.io.IOException;
 import java.math.BigDecimal;
 import java.sql.SQLException;
+import java.time.LocalDate;
 import java.util.*;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.stream.Collectors;
@@ -849,8 +850,13 @@ public class GiacenzaService {
     }
 
     public void archiviazioneGiornaliera() throws Exception {
-        String sql = "SELECT DISTINCT cod_mdep\n" +
-                "FROM carelli_giacenza_prog";
+        LocalDate dataGiac = UtilityLocalDate.getNow();
+        String sql =
+                Query.format(
+                "SELECT DISTINCT cod_mdep\n" +
+                "FROM carelli_giacenza_prog \n" +
+                "WHERE not exists (select * from carelli_giacenza_prog_gg where carelli_giacenza_prog_gg.cod_mdep = carelli_giacenza_prog.cod_mdep and data_giac = %S)",
+        dataGiac);
 
         List<String> codMdepList = UtilityDB.executeSimpleQueryOnlyFirstColumn(multiDBTransactionManager.getPrimaryConnection(), sql);
 
@@ -860,7 +866,7 @@ public class GiacenzaService {
                 List<CarelliGiacenzaProgGg> ggArchivio = giacenzaDTOS.stream().map(
                         x -> {
                             CarelliGiacenzaProgGg g = new CarelliGiacenzaProgGg().
-                                    setDataGiac(UtilityLocalDate.getNow())
+                                    setDataGiac(dataGiac)
                                     .setCodMdep(codMdep)
                                     .setCodMart(x.getCodMart())
                                     .setQtaGiac(x.getQtaInv());
@@ -869,7 +875,12 @@ public class GiacenzaService {
                         }
                 ).collect(Collectors.toList());
 
-                UtilityEntity.throwEntitiesException(entityProcessor.processEntityList(ggArchivio, true));
+                try {
+                    UtilityEntity.throwEntitiesException(entityProcessor.processEntityList(ggArchivio, true));
+                } catch (Exception e) {
+                    logger.error(GiacenzaService.class + " Errore nell'aggiornamento della giacenza del deposito " +codMdep + " " + e.getMessage(), e);
+                    multiDBTransactionManager.rollbackAll();
+                }
             }
         }
     }