From 948b8187bcb24f281d4ea2ca15642623a1cf0960 Mon Sep 17 00:00:00 2001 From: psemenkov Date: Wed, 3 May 2023 12:22:01 +0300 Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-276=20?= =?UTF-8?q?=D0=9F=D0=BE=D0=BF=D1=80=D0=B0=D0=B2=D0=B8=D0=BB=20=D0=BB=D0=BE?= =?UTF-8?q?=D0=B3.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../trade/importer/services/TradeImporterService.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 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 84dd75c82..2d8134533 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 @@ -53,10 +53,10 @@ public class TradeImporterService { } public void process(boolean byCommand) { - log.debug("start process import STrades from DB"); + log.debug("Start process import STrades from DB"); Collection tradesFromDB = jdbcTemplate.query("SELECT * FROM Trades", (resultSet, i) -> readSTrades(resultSet)); - log.debug(String.format("load from DB STrades: %d", tradesFromDB.size())); + log.debug("load from DB STrades: {}", tradesFromDB.size()); for (STrades tradesDb : tradesFromDB) { if (isValidTrades(tradesDb)) { STrades sTrades = getSTradesFromImdg(tradesDb, sTradesImdg); @@ -70,8 +70,10 @@ public class TradeImporterService { if (byCommand) { STradesImportedRequest sTradesImportedRequest = new STradesImportedRequest(); producer.send(new ProducerRecord<>(S_TRADES_IMPORTED, sTradesImportedRequest)); - log.debug("successfully import STrades from DB by command"); - }else log.debug("successfully import STrades from DB by scheduled"); + log.debug("Successfully import STrades from DB by command. Send to kafka command, topic={}", S_TRADES_IMPORTED); + } else { + log.debug("Successfully import STrades from DB by scheduled"); + } } public STrades getSTradesFromImdg(STrades tradesDb, Imdg sTradesImdg) {