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

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

Browse Source
This commit is contained in:
Giuseppe Scorrano
2024-12-11 17:58:40 +01:00
parent 8f3bb93c0d 7152234567
commit 02a7764c8e
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
ems-engine/src/main/java/it/integry/ems/system/exchange/service/ExchangeArticoliImportService.java
View File

@@ -65,9 +65,18 @@ public class ExchangeArticoliImportService {
allData.stream()
.filter(x -> x.getOperation() == OperationType.INSERT)
.forEach(x -> x.setOperation(OperationType.INSERT_OR_UPDATE));
.map(x -> (MtbAart) x)
.forEach(x -> x
.setFlagStato("A")
.setOperation(OperationType.INSERT_OR_UPDATE));
final Exception[] firstExceptionToThrow = {null};
allData.parallelStream()
.filter(x -> x.getOperation() == OperationType.DELETE)
.map(x -> (MtbAart) x)
.forEach(x -> x.setFlagStato("I")
.setOperation(OperationType.UPDATE));
final Exception[] firstExceptionToThrow = { null };
AtomicInteger importedCounter = new AtomicInteger();