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 
Дбавил обработку полей создания записи STrades и ее апдейта.
This commit is contained in:
psemenkov 2023-05-12 18:08:57 +03:00
parent 183babf1c2
commit aa15b344b1
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -55,12 +55,18 @@ 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));
Instant currentInstant = Instant.now();
log.debug("load from DB STrades: {}", 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);
if (sTrades != null) tradesDb.setId(sTrades.getId()); if (sTrades != null) {
tradesDb.setId(sTrades.getId());
tradesDb.setUpdated(currentInstant);
} else {
tradesDb.setCreated(currentInstant);
}
sTradesImdg.insert(tradesDb); sTradesImdg.insert(tradesDb);
} else { } else {
log.warn(messageResolver.resolve(new EnumMessage(sTradesNotValid, tradesDb.getTradeNum()))); log.warn(messageResolver.resolve(new EnumMessage(sTradesNotValid, tradesDb.getTradeNum())));