Integry/IntegryManagementSystem
19
0
Fork 0
Code Actions Packages Projects Releases Activity

Implementato servizio di reset selle posizioni MonoUl
All checks were successful
IntegryManagementSystem_Multi/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Giuseppe Scorrano 2025-12-11 16:46:35 +01:00
parent 8df579448c
commit 33a6538b66
5 changed files with 85 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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);

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

@ -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);

20
ems-core/src/main/java/it/integry/ems/utility/entity/MtbDepoPosizioniUtils.java Normal file
View File

@ -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());
}
}

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

@ -733,4 +733,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();
}
}

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

@ -42,6 +42,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.db.ResultSetMapper;
import it.integry.ems_model.entity.*;
@ -3208,4 +3209,59 @@ public class WMSGenericService {
return UtilityDB.executeSimpleQueryDTO(connection, sql, MtbColr.class);
}
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.getBarcodeUl(), 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;
}
}
}