Migliorie magazzino automatico eurofork
All checks were successful
IntegryManagementSystem_Multi/pipeline/head This commit looks good

This commit is contained in:
2025-11-18 16:09:46 +01:00
parent dd62a4f5e0
commit a2edd0f29c
2 changed files with 10 additions and 5 deletions

View File

@@ -1,14 +1,15 @@
package it.integry.ems.logistic.missioni.magazzino_automatico.service;
import groovy.lang.Tuple3;
import it.integry.annotations.CustomerService;
import it.integry.ems.javabeans.RequestDataDTO;
import it.integry.ems.logistic.missioni.magazzino_automatico.dto.EuroforkLuPositionDTO;
import it.integry.ems.migration._base.IntegryCustomer;
import it.integry.ems.retail.wms.Utility.WMSUtility;
import it.integry.ems.retail.wms.generic.dto.MvwSitArtUdcDetInventarioDTO;
import it.integry.ems.retail.wms.generic.service.WMSGiacenzaULService;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.utility.UtilityDebug;
import it.integry.ems_model.config.EmsRestConstants;
import it.integry.ems_model.entity.MtbColr;
import it.integry.ems_model.entity.MtbColt;
@@ -28,7 +29,7 @@ import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
//@CustomerService(IntegryCustomer.Biolevante)
@CustomerService(IntegryCustomer.Biolevante)
public class EuroforkDataSyncronizerService {
private final Logger logger = LogManager.getLogger();
@@ -49,12 +50,14 @@ public class EuroforkDataSyncronizerService {
@Scheduled(fixedDelay = 1, timeUnit = TimeUnit.MINUTES)
private void syncLuScheduled() {
if (UtilityDebug.isDebugExecution() || UtilityDebug.isIntegryServer())
return;
// if (UtilityDebug.isDebugExecution() || UtilityDebug.isIntegryServer())
// return;
String sqlRetrieveEuroforkStatus = "SELECT barcode_ul,\n" +
" posizione,\n" +
" ROW_NUMBER() OVER (PARTITION BY posizione ORDER BY Quote DESC) AS sequence\n" +
" IIF(ColumnSide = 'L',\n" +
" ROW_NUMBER() OVER (PARTITION BY posizione ORDER BY Quote ASC),\n" +
" ROW_NUMBER() OVER (PARTITION BY posizione ORDER BY Quote DESC)) AS sequence\n" +
"FROM (SELECT LU.[Number] AS barcode_ul,\n" +
" ISNULL(\n" +
" IIF(LEN(Cells.[Note]) > 0, CONCAT('WH1', Cells.[Note]), NULL),\n" +
@@ -62,6 +65,7 @@ public class EuroforkDataSyncronizerService {
" FORMAT(Cells.[Level], '00'),\n" +
" Cells.[ColumnSide],\n" +
" FORMAT(Cells.[Column], '000'))) AS posizione,\n" +
" Cells.[ColumnSide],\n" +
" LU.[Quote]\n" +
" FROM LU\n" +
" INNER JOIN Cells ON LU.Cells_ID = Cells.ID\n" +

View File

@@ -281,6 +281,7 @@ public class MissioniMagazzinoAutomaticoService {
missioneRow.setOperation(OperationType.UPDATE);
missioneRow.setErrorMessage(errorMessage);
missioneRow.setUpdatedAt(LocalDateTime.now());
missioneRow.setEndedAt(LocalDateTime.now());
MtbMissioneMagAuto missione = new MtbMissioneMagAuto()
.setId(missionId);