diff --git a/ems-engine/src/main/java/it/integry/ems/system/exchange/service/ExchangeDestinatariImportService.java b/ems-engine/src/main/java/it/integry/ems/system/exchange/service/ExchangeDestinatariImportService.java index 9b97df95c9..a2cfa8075e 100644 --- a/ems-engine/src/main/java/it/integry/ems/system/exchange/service/ExchangeDestinatariImportService.java +++ b/ems-engine/src/main/java/it/integry/ems/system/exchange/service/ExchangeDestinatariImportService.java @@ -120,10 +120,12 @@ public class ExchangeDestinatariImportService { private void singleUpdateImported(Connection connection, GtbAnag importedData, boolean useTempTable) throws Exception { - final HashMap importedKey = new HashMap() {{ - put("cod_anag", importedData.getCodAnag()); - }}; + final List> importedRowKeys = importedData.getVtbDest().stream() + .map(x -> new HashMap() {{ + put("cod_anag", x.getCodAnag()); + put("cod_vdes", x.getCodVdes()); + }}).collect(Collectors.toList()); - exchangeImportDataManagerService.updateImportedStatus(connection, "vtb_dest", importedKey, useTempTable); + exchangeImportDataManagerService.updateImportedStatus(connection, "vtb_dest", importedRowKeys, useTempTable); } }