sincronizzazione banche aziendali

This commit is contained in:
2024-09-17 15:29:27 +02:00
parent 94625a04f1
commit 9534dabdf1

View File

@@ -4,6 +4,7 @@ import it.integry.common.var.CommonConstants;
import it.integry.ems.javabeans.RequestDataDTO; import it.integry.ems.javabeans.RequestDataDTO;
import it.integry.ems.response.ServiceRestResponse; import it.integry.ems.response.ServiceRestResponse;
import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager; import it.integry.ems.sync.MultiDBTransaction.MultiDBTransactionManager;
import it.integry.ems.system.exchange.service.ExchangeBancheAziendaliImportService;
import it.integry.ems.system.exchange.service.ExchangePartiteMagazzinoImportService; import it.integry.ems.system.exchange.service.ExchangePartiteMagazzinoImportService;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
@@ -21,7 +22,7 @@ public class ExchangeBancheAziendaliImportController {
private final Logger logger = LogManager.getLogger(); private final Logger logger = LogManager.getLogger();
@Autowired @Autowired
private ExchangePartiteMagazzinoImportService exchangeBancheAziendaliImportService; private ExchangeBancheAziendaliImportService exchangeBancheAziendaliImportService;
@Autowired @Autowired
private RequestDataDTO requestDataDTO; private RequestDataDTO requestDataDTO;
@@ -35,7 +36,7 @@ public class ExchangeBancheAziendaliImportController {
try (MultiDBTransactionManager internalDb = new MultiDBTransactionManager(profileDb); try (MultiDBTransactionManager internalDb = new MultiDBTransactionManager(profileDb);
MultiDBTransactionManager exchangeDb = new MultiDBTransactionManager(profileDbExchange)) { MultiDBTransactionManager exchangeDb = new MultiDBTransactionManager(profileDbExchange)) {
exchangeBancheAziendaliImportService.importPartiteMagazzinoLavorazione(internalDb, exchangeDb,requestDataDTO); exchangeBancheAziendaliImportService.importBancheAziendali(internalDb, exchangeDb,requestDataDTO);
} }
return ServiceRestResponse.createPositiveResponse(); return ServiceRestResponse.createPositiveResponse();
} }