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

trade-importer http://jira.mfd.msk:8088/browse/CLS-276 поправил копирование объекта

Browse source
This commit is contained in:
AKurakin 2023-05-23 11:58:38 +03:00
parent 63b1babed9
commit 5c93f133dd
1 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -63,20 +63,30 @@ public class TradeImporterService {
Instant currentInstant = Instant.now(); Instant currentInstant = Instant.now();
log.debug("load from DB STrades: {}", tradesFromDB.size()); log.debug("load from DB STrades: {}", tradesFromDB.size());
int created = 0;
int updated = 0;
for (STrades tradesDb : tradesFromDB) { for (STrades tradesDb : tradesFromDB) {
if (isValidTrades(tradesDb)) { if (isValidTrades(tradesDb)) {
STrades sTrades = getSTradesFromImdg(tradesDb, sTradesImdg); STrades sTrades = getSTradesFromImdg(tradesDb, sTradesImdg);
if (sTrades != null) { if (sTrades != null) {
// Обновление всех полей объекта из БД
tradesDb.setId(sTrades.getId()); tradesDb.setId(sTrades.getId());
tradesDb.setCreated(sTrades.getCreated());
tradesDb.setUpdated(currentInstant); tradesDb.setUpdated(currentInstant);
sTradesImdg.update(tradesDb);
updated++;
} else { } else {
// Создание объекта из БД
tradesDb.setCreated(currentInstant); tradesDb.setCreated(currentInstant);
tradesDb.setUpdated(currentInstant);
sTradesImdg.insert(tradesDb);
created++;
} }
sTradesImdg.insert(tradesDb);
} else { } else {
log.warn(messageResolver.resolve(new EnumMessage(sTradesNotValid, tradesDb.getTradeNum()))); log.warn(messageResolver.resolve(new EnumMessage(sTradesNotValid, tradesDb.getTradeNum())));
} }
} }
log.debug("Created {} new STrades, {} updated.", created, updated);
if (byCommand) { if (byCommand) {
log.debug("Successfully import STrades from DB by command. Send to kafka command, topic={}", S_TRADES_IMPORTED); log.debug("Successfully import STrades from DB by command. Send to kafka command, topic={}", S_TRADES_IMPORTED);