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

Gestito plu mancante come anomalie in importagione digi
All checks were successful
IntegryManagementSystem_Multi/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Marco Elefante
2025-08-08 15:39:22 +02:00
parent 94f21f78a8
commit a21c13f798
2 changed files with 19 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ems-engine/src/main/java/it/integry/ems/retail/Import/BilanceImporter.java
View File

@@ -17,7 +17,7 @@ public class BilanceImporter extends BaseEntityImporter<List<EntityBase>> implem
if (enumFormat != null){
switch (enumFormat) {
case DIGI:
entities = getContextBean(BilanceService.class).importBilance(type, format, requestDto);
entities = getContextBean(BilanceService.class).importBilance(type, format, requestDto, anomalie);
break;
default:
throw new Exception("Tipo " + format + " non supportato");

24
ems-engine/src/main/java/it/integry/ems/retail/service/BilanceService.java
View File

@@ -1,5 +1,6 @@
package it.integry.ems.retail.service;
import it.integry.ems.Import.dto.AnomalieDTO;
import it.integry.ems.Import.dto.ImportRequestDTO;
import it.integry.ems.service.EntityProcessor;
import it.integry.ems.sync.MultiDBTransaction.Connection;
@@ -35,16 +36,19 @@ public class BilanceService {
@Autowired
private SetupGest setupGest;
public List<EntityBase> importBilance(String type, String format, ImportRequestDTO requestDto) throws Exception {
public List<EntityBase> importBilance(String type, String format, ImportRequestDTO requestDto, List<AnomalieDTO> anomalie) throws Exception {
Connection conn = multiDBTransactionManager.getPrimaryConnection();
List<EntityBase> returnList = new ArrayList<>();
String pathFile = setupGest.getImportSetup(conn, type, format, "PATH_FILE");
if (UtilityString.isNullOrEmpty(pathFile)) throw new Exception(("Directory non configurata per l'importazione delle bilance"));
if (!UtilityFile.directoryExists(pathFile)) throw new Exception("La directory specificata non esiste: " + pathFile);
if (UtilityString.isNullOrEmpty(pathFile))
throw new Exception(("Directory non configurata per l'importazione delle bilance"));
if (!UtilityFile.directoryExists(pathFile))
throw new Exception("La directory specificata non esiste: " + pathFile);
String pathFileImported = setupGest.getImportSetup(conn, type, format, "PATH_FILE_IMPORTED");
if (UtilityString.isNullOrEmpty(pathFileImported)) throw new Exception("Directory per i file importati non configurata");
if (UtilityString.isNullOrEmpty(pathFileImported))
throw new Exception("Directory per i file importati non configurata");
if (!UtilityFile.directoryExists(pathFileImported)) UtilityFile.directoryCreate(pathFileImported);
List<File> listFileToImport = new ArrayList<>();
@@ -60,6 +64,7 @@ public class BilanceService {
for (File file : listFileToImport) {
String fileName = file.getName();
String fileCodMdep = fileName.substring(0, 2);
boolean fileWithError = false;
if (!codMdepList.contains(fileCodMdep))
continue; // Skip files not matching any deposit code
@@ -87,12 +92,19 @@ public class BilanceService {
"WHERE plu = %s",
plu
);
String codMart = UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(conn, sql);
pesata.setCodMart(UtilityDB.executeSimpleQueryOnlyFirstRowFirstColumn(conn, sql));
if (codMart == null) {
anomalie.add(AnomalieDTO.error("Codice PLU non trovato: " + plu + " nel file " + fileName));
fileWithError = true;
break;
}
pesata.setCodMart(codMart);
pesate.add(pesata);
}
if (pesate.isEmpty()) continue; // Skip files with no valid data
if (pesate.isEmpty() || fileWithError) continue; // Skip files with no valid data
List<EntityBase> entityList = entityProcessor.processEntityList(pesate, true);
UtilityEntity.throwEntitiesException(entityList);