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 2dd2a0bc9..5499fd324 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 @@ -64,7 +64,8 @@ public class TradeImporterService { public void process(boolean byCommand) { log.debug("Start process import STrades from DB"); - Collection tradesFromDB = jdbcTemplate.query(String.format("SELECT * FROM %s.Trades", schema), (resultSet, i) -> readSTrades(resultSet)); + Collection tradesFromDB = jdbcTemplate.query(String.format("SELECT * FROM %s.Trades", schema), + (resultSet, i) -> readSTrades(resultSet)); Instant currentInstant = Instant.now(); log.debug("load from DB STrades: {}", tradesFromDB.size()); @@ -177,10 +178,8 @@ public class TradeImporterService { sTrades.setSecName(resultSet.getObject("SecName", String.class)); sTrades.setSettleDate(getLocalDateFromSqlDate(resultSet, "SettleDate")); sTrades.setSettleCurrency(resultSet.getObject("SettleCurrency", String.class)); - sTrades.setTradeCurrency(resultSet.getObject("TradeCurrency", String.class)); sTrades.setTradeTimeMs(resultSet.getObject("TradeTimeMs", Long.class)); sTrades.setBankAccId(resultSet.getObject("BankAccId", String.class)); - sTrades.setSection(resultSet.getObject("Section", String.class)); return sTrades; }