treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-276

Browse source 
Поправил лог.
This commit is contained in:
psemenkov 2023-05-03 12:22:01 +03:00
parent 2f2835cc91
commit 948b8187bc
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
View file

@ -53,10 +53,10 @@ public class TradeImporterService {
} }
public void process(boolean byCommand) { public void process(boolean byCommand) {
log.debug("start process import STrades from DB"); log.debug("Start process import STrades from DB");
Collection<STrades> tradesFromDB = jdbcTemplate.query("SELECT * FROM Trades", (resultSet, i) -> readSTrades(resultSet)); Collection<STrades> 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) { for (STrades tradesDb : tradesFromDB) {
if (isValidTrades(tradesDb)) { if (isValidTrades(tradesDb)) {
STrades sTrades = getSTradesFromImdg(tradesDb, sTradesImdg); STrades sTrades = getSTradesFromImdg(tradesDb, sTradesImdg);
@ -70,8 +70,10 @@ public class TradeImporterService {
if (byCommand) { if (byCommand) {
STradesImportedRequest sTradesImportedRequest = new STradesImportedRequest(); STradesImportedRequest sTradesImportedRequest = new STradesImportedRequest();
producer.send(new ProducerRecord<>(S_TRADES_IMPORTED, sTradesImportedRequest)); producer.send(new ProducerRecord<>(S_TRADES_IMPORTED, sTradesImportedRequest));
log.debug("successfully import STrades from DB by command"); 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"); } else {
log.debug("Successfully import STrades from DB by scheduled");
}
} }
public STrades getSTradesFromImdg(STrades tradesDb, Imdg<STrades> sTradesImdg) { public STrades getSTradesFromImdg(STrades tradesDb, Imdg<STrades> sTradesImdg) {