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 54c3ac0e9..0a5afd27a 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 @@ -8,6 +8,7 @@ import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; import org.springframework.util.StringUtils; +import ru.clearing.classes.statics.data.misc.BlacklistMarket; import ru.clearing.classes.statics.data.misc.Market; import ru.clearing.classes.statics.data.misc.STrades; import ru.clearing.classes.statics.data.scheduler.ClearingCalendar; @@ -47,6 +48,7 @@ public class TradeImporterService { private final Imdg sTradesImdg; private final Imdg marketImdg; private final Imdg clearingCalendarImdg; + private final Imdg blacklistMarketImdg; private final JdbcTemplate jdbcTemplate; private final Supplier kafka; private final IMessageResolver messageResolver; @@ -60,6 +62,7 @@ public class TradeImporterService { this.sTradesImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_STrades, STrades.class); this.marketImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_Market, Market.class); this.clearingCalendarImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_ClearingCalendar, ClearingCalendar.class); + this.blacklistMarketImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_BlacklistMarket, BlacklistMarket.class); this.jdbcTemplate = jdbcTemplate; this.kafka = kafka; this.messageResolver = messageResolver; @@ -157,7 +160,9 @@ public class TradeImporterService { try { Market market = marketImdg.getFirstObjectBySQL("code = '%s'".formatted(tradesDb.getClassCode())); if (market == null) { - logErr.accept("couldn't find market.section for classCode " + tradesDb.getClassCode()); + if (blacklistMarketImdg.getFirstObjectByFieldValues(Map.of("code", tradesDb.getClassCode())) == null) { + logErr.accept("couldn't find market.section for classCode " + tradesDb.getClassCode()); + } return false; } tradesDb.setSection(market.getSection());