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 2940ca7a5..8add89ed9 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 @@ -185,25 +185,19 @@ public class TradeImporterService { * returns OK - everything is kk */ private boolean fillNessessaryFields(STrades tradesDb) { - Consumer log = (st) -> { - if (tradesDb.getClassCode().contains("INSTR")) - this.log.warn("strades {} {} {}", tradesDb.getTradeDate(), tradesDb.getTradeNum(), st); - else { - this.log.error("strades {} {} {}", tradesDb.getTradeDate(), tradesDb.getTradeNum(), st); - } - }; + Consumer logErr = (st) -> log.error("strades {} {} {}", tradesDb.getTradeDate(), tradesDb.getTradeNum(), st); try { Market market = marketImdg.getFirstObjectBySQL("code = '%s'".formatted(tradesDb.getClassCode())); if (market == null) { if (blacklistMarketImdg.getFirstObjectByFieldValues(Map.of("code", tradesDb.getClassCode())) == null) { - log.accept("couldn't find market.section for classCode " + tradesDb.getClassCode()); + logErr.accept("couldn't find market.section for classCode " + tradesDb.getClassCode()); } return false; } tradesDb.setSection(market.getSection()); return true; } catch (Exception e) { - log.accept(ExceptionUtils.getStackTrace(e)); + logErr.accept(ExceptionUtils.getStackTrace(e)); return false; } }