diff --git a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java index 551119d24..496b4b391 100644 --- a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java +++ b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java @@ -55,12 +55,18 @@ public class TradeImporterService { public void process(boolean byCommand) { log.debug("Start process import STrades from DB"); Collection tradesFromDB = jdbcTemplate.query("SELECT * FROM Trades", (resultSet, i) -> readSTrades(resultSet)); + Instant currentInstant = Instant.now(); log.debug("load from DB STrades: {}", tradesFromDB.size()); for (STrades tradesDb : tradesFromDB) { if (isValidTrades(tradesDb)) { STrades sTrades = getSTradesFromImdg(tradesDb, sTradesImdg); - if (sTrades != null) tradesDb.setId(sTrades.getId()); + if (sTrades != null) { + tradesDb.setId(sTrades.getId()); + tradesDb.setUpdated(currentInstant); + } else { + tradesDb.setCreated(currentInstant); + } sTradesImdg.insert(tradesDb); } else { log.warn(messageResolver.resolve(new EnumMessage(sTradesNotValid, tradesDb.getTradeNum())));