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

Finish Hotfix-100
All checks were successful
IntegryManagementSystem_Multi/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Mina Ruggiero
2025-11-14 13:34:07 +01:00
parent 9f25bd2bf6 ca78b09ad8
commit a9068c45cd
1 changed files with 35 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
ems-engine/src/main/java/it/integry/ems/logistic/service/Slim2kLogisticService.java
View File

@@ -421,41 +421,46 @@ public class Slim2kLogisticService {
);
List<MtbPartitaMag> listaPartita = UtilityDB.executeSimpleQueryDTO(multiDBTransactionManager.getPrimaryConnection(), q, MtbPartitaMag.class);
if (listaPartita == null || listaPartita.isEmpty()) {
return null;
}
Optional<MtbPartitaMag> first = listaPartita.stream().filter(x -> x.getDataScad() == null || x.getDataScad().equals(dataScad)).findFirst();
MtbPartitaMag mtbPartitaMag;
if (first.isPresent()) {
mtbPartitaMag = first.get();
if ( mtbPartitaMag.getDataScad() == null ) {
mtbPartitaMag.setDataScad(dataScad);
mtbPartitaMag.setOperation(OperationType.UPDATE);
}
if (listaPartita == null || listaPartita.isEmpty()) {
mtbPartitaMag = new MtbPartitaMag()
.setCodMart(codMart)
.setPartitaMag(partitaMag)
.setDataScad(dataScad)
.setPartitaMagProd(partitaMag);
mtbPartitaMag.setOperation(OperationType.INSERT);
} else {
String lastPartitaMag = listaPartita.stream()
.max(Comparator.comparing(MtbPartitaMag::getPartitaMag))
.map(x -> x.getPartitaMag())
.orElse(null);
Optional<MtbPartitaMag> first = listaPartita.stream().filter(x -> x.getDataScad() == null || x.getDataScad().equals(dataScad)).findFirst();
String id = lastPartitaMag.substring(partitaMag.length());
if (UtilityString.isNullOrEmpty(id)) {
id = "1";
if (first.isPresent()) {
mtbPartitaMag = first.get();
if (mtbPartitaMag.getDataScad() == null) {
mtbPartitaMag.setDataScad(dataScad);
mtbPartitaMag.setOperation(OperationType.UPDATE);
}
} else {
id = Integer.toString(Integer.parseInt(id) + 1);
String lastPartitaMag = listaPartita.stream()
.max(Comparator.comparing(MtbPartitaMag::getPartitaMag))
.map(x -> x.getPartitaMag())
.orElse(null);
String id = lastPartitaMag.substring(partitaMag.length());
if (UtilityString.isNullOrEmpty(id)) {
id = "1";
} else {
id = Integer.toString(Integer.parseInt(id) + 1);
}
String partitaMagNew = partitaMag + "_" + id;
mtbPartitaMag = new MtbPartitaMag()
.setCodMart(codMart)
.setPartitaMag(partitaMagNew)
.setDataScad(dataScad)
.setPartitaMagProd(partitaMag);
mtbPartitaMag.setOperation(OperationType.INSERT);
}
String partitaMagNew = partitaMag + "_" + id;
mtbPartitaMag = new MtbPartitaMag()
.setCodMart(codMart)
.setPartitaMag(partitaMagNew)
.setDataScad(dataScad)
.setPartitaMagProd(partitaMag);
mtbPartitaMag.setOperation(OperationType.INSERT);
}
return mtbPartitaMag;
}