From 7bbe9b4bfba2334caa57828875a6d911868f9d7a Mon Sep 17 00:00:00 2001 From: etreschenkov Date: Thu, 14 Aug 2025 17:46:43 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-899 (cherry picked from commit 178aa1156144a618aa14072d771f4b7a4aae2f0f) --- .../importer/services/TradeImporterService.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) 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 8add89ed9..2940ca7a5 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,19 +185,25 @@ public class TradeImporterService { * returns OK - everything is kk */ private boolean fillNessessaryFields(STrades tradesDb) { - Consumer logErr = (st) -> log.error("strades {} {} {}", tradesDb.getTradeDate(), tradesDb.getTradeNum(), st); + 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); + } + }; try { Market market = marketImdg.getFirstObjectBySQL("code = '%s'".formatted(tradesDb.getClassCode())); if (market == null) { if (blacklistMarketImdg.getFirstObjectByFieldValues(Map.of("code", tradesDb.getClassCode())) == null) { - logErr.accept("couldn't find market.section for classCode " + tradesDb.getClassCode()); + log.accept("couldn't find market.section for classCode " + tradesDb.getClassCode()); } return false; } tradesDb.setSection(market.getSection()); return true; } catch (Exception e) { - logErr.accept(ExceptionUtils.getStackTrace(e)); + log.accept(ExceptionUtils.getStackTrace(e)); return false; } }