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

Fix su EXCHANGE

Browse Source
This commit is contained in:
Giuseppe Scorrano
2024-07-29 11:46:44 +02:00
parent 7a86247e12
commit 15ac3df1ce
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ems-core/src/main/java/it/integry/ems_model/base/EntityBase.java
View File

@@ -1448,7 +1448,7 @@ public abstract class EntityBase implements Serializable, Cloneable, EntityInter
final Object value = fieldsWithoutIdentityAndNotNull.get(i - 1).getSecond();
insertBulkPs.setObject(i, value);
// traceSql = traceSql.replaceFirst("\\?", UtilityDB.valueToString(value).replaceAll("\\$", "\\\\\\$"));
traceSql = traceSql.replace("?", UtilityDB.valueToString(value));
}
logger.trace("Query tracing: {}", traceSql);

4
ems-engine/src/main/java/it/integry/ems/system/exchange/service/ExchangePartiteMagazzinoImportService.java
View File

@@ -20,6 +20,7 @@ import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;
@SuppressWarnings("rawtypes")
@Service
@@ -65,6 +66,9 @@ public class ExchangePartiteMagazzinoImportService {
allData.forEach(x -> x.setOperation(x.getOperation() == OperationType.INSERT ? OperationType.INSERT_OR_UPDATE : x.getOperation()));
allData = allData.stream().filter(x -> x.getOperation() != OperationType.DELETE)
.collect(Collectors.toList());
final Exception[] firstExceptionToThrow = {null};
AtomicInteger importedCounter = new AtomicInteger();