Merge remote-tracking branch 'origin/develop' into develop

ems-core/src/main/java/it/integry/ems/dbms_change_tracker/component/DbmsChangeTrackerComponent.java

@@ -32,6 +32,7 @@ public class DbmsChangeTrackerComponent {
         add(MtbAartBarCode.ENTITY);
         add(MtbUntMis.ENTITY);
         add(MtbDepo.ENTITY);
+        add(MtbDepoPosizioni.ENTITY);
         add(StbEditLimit.ENTITY);
         add(StbGestSetup.ENTITY);
         add(StbGestSetupDepo.ENTITY);

ems-core/src/main/java/it/integry/ems/dynamic_cache/EntityCacheComponent.java

@@ -57,6 +57,7 @@ public class EntityCacheComponent implements ApplicationListener {
         put(MtbAartBarCode.ENTITY, MtbAartBarCode.class);
         put(MtbUntMis.ENTITY, MtbUntMis.class);
         put(MtbDepo.ENTITY, MtbDepo.class);
+        put(MtbDepoPosizioni.ENTITY, MtbDepoPosizioni.class);
         put(StbEditLimit.ENTITY, StbEditLimit.class);
         put(StbGestSetup.ENTITY, StbGestSetup.class);
         put(StbGestSetupDepo.ENTITY, StbGestSetupDepo.class);

ems-core/src/main/java/it/integry/ems/utility/entity/MtbDepoPosizioniUtils.java

@@ -0,0 +1,20 @@
+package it.integry.ems.utility.entity;
+
+import it.integry.ems._context.ApplicationContextProvider;
+import it.integry.ems.dynamic_cache.EntityCacheComponent;
+import it.integry.ems.migration._base.IntegryCustomerDB;
+import it.integry.ems_model.entity.MtbDepoPosizioni;
+
+import java.util.List;
+
+public class MtbDepoPosizioniUtils {
+
+
+    public static final List<MtbDepoPosizioni> getAllMonoUlPositions(IntegryCustomerDB customerDB) {
+        final EntityCacheComponent entityCacheComponent = ApplicationContextProvider.getApplicationContext().getBean(EntityCacheComponent.class);
+
+        return entityCacheComponent.<MtbDepoPosizioni>getCachedEntitiesList(customerDB, MtbDepoPosizioni.ENTITY,
+                x -> x.isFlagMonoCollo());
+    }
+
+}

ems-engine/src/main/java/it/integry/ems/retail/wms/generic/controller/WMSGenericController.java

@@ -709,4 +709,11 @@ public class WMSGenericController {
     ) throws Exception {
         return ServiceRestResponse.createPositiveResponse(WMSUtility.retrieveBarcodesByBarcodeAndCodJfas(multiDBTransactionManager.getPrimaryConnection(),barcodeUl,codJfas, maxResults));
     }
+
+    @GetMapping("wms/resetta-posizioni-mono-ul")
+    ServiceRestResponse resettaPosizioniMonoUl() throws Exception {
+        wmsGenericService.resettaPosizioniMonoUL(multiDBTransactionManager, entityProcessor);
+
+        return ServiceRestResponse.createPositiveResponse();
+    }
 }

ems-engine/src/main/java/it/integry/ems/retail/wms/generic/service/WMSGenericService.java

@@ -37,6 +37,7 @@ import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
 import it.integry.ems.user.UserSession;
 import it.integry.ems.utility.UtilityEntity;
 import it.integry.ems.utility.entity.MtbAartUtils;
+import it.integry.ems.utility.entity.MtbDepoPosizioniUtils;
 import it.integry.ems_model.base.EntityBase;
 import it.integry.ems_model.config.EmsRestConstants;
 import it.integry.ems_model.db.ResultSetMapper;
@@ -103,6 +104,8 @@ public class WMSGenericService {
 
     @Autowired
     private WMSAccettazioneService wmsAccettazioneService;
+    @Autowired
+    private WMSGiacenzaULService wmsGiacenzaULService;
 
     public List<AvailableCodMdepDTO> getAvailableCodMdepsForUser() throws Exception {
 
@@ -3099,4 +3102,59 @@ public class WMSGenericService {
 
         return null;
     }
+
+
+    public void resettaPosizioniMonoUL(MultiDBTransactionManager multiDBTransactionManager, EntityProcessor entityProcessor) throws Exception {
+        List<MtbDepoPosizioni> posizioniMonoUL = MtbDepoPosizioniUtils.getAllMonoUlPositions(multiDBTransactionManager.getPrimaryConnection().getIntegryCustomerDB());
+
+        try {
+            for (MtbDepoPosizioni posizione : posizioniMonoUL) {
+                final List<MtbColt> oldUdcs = getULInPosizione(posizione, false);
+
+                if (oldUdcs == null)
+                    continue;
+
+                oldUdcs.removeIf(ul -> ul.getSegno() != 1); //consider only Lavorazione UDCs
+
+
+                if (oldUdcs.isEmpty()) {
+                    //skip position
+                    continue;
+                } else if (oldUdcs.size() > 1) {
+                    throw new Exception("Posizione " + posizione.getPosizione() + " contiene più di una UDC in una posizione mono UL");
+                }
+                final MtbColt newUdc = wmsLavorazioneService.createUDC(new CreateUDCRequestDTO()
+                        .setCodMdep(posizione.getCodMdep())
+                        .setPosizione(posizione.getPosizione()));
+
+                final MtbColt oldUdc = oldUdcs.get(0);
+
+                final List<MvwSitArtUdcDetInventarioDTO> giacenzaItems = wmsGiacenzaULService.retrieveArtsInGiacenzaByPosition(multiDBTransactionManager.getPrimaryConnection(), posizione.getPosizione());
+
+                if (giacenzaItems != null) {
+                    oldUdc.setMtbColr(WMSUtility.convertMvwItemsToMtbColrs(giacenzaItems));
+
+                    WMSUtility.spostaArtsTraUL(multiDBTransactionManager.getPrimaryConnection(),
+                            oldUdc, newUdc, false, entityProcessor, RequestDataDTO.systemMockupData());
+
+                }
+
+                //remove position from old UL
+                UtilityDB.executeStatement(multiDBTransactionManager.getPrimaryConnection(),
+                        "UPDATE mtb_colt SET posizione = NULL " +
+                                "WHERE gestione = " + UtilityDB.valueToString(oldUdc.getGestione()) + " " +
+                                "AND data_collo = " + UtilityDB.valueToString(oldUdc.getDataCollo()) + " " +
+                                "AND ser_collo = " + UtilityDB.valueToString(oldUdc.getSerCollo()) + " " +
+                                "AND num_collo = " + UtilityDB.valueToString(oldUdc.getNumCollo())
+                );
+
+                //save all
+            }
+
+        } catch (Exception ex) {
+            multiDBTransactionManager.rollbackAll();
+            throw ex;
+        }
+    }
+
 }