This reverts commit 178aa11561.
This commit is contained in:
parent
52e703bfd8
commit
e1275da162
1 changed files with 3 additions and 9 deletions
|
|
@ -185,25 +185,19 @@ public class TradeImporterService {
|
|||
* returns OK - everything is kk
|
||||
*/
|
||||
private boolean fillNessessaryFields(STrades tradesDb) {
|
||||
Consumer<String> log = (st) -> {
|
||||
if (tradesDb.getClassCode().contains("INSTR"))
|
||||
this.log.warn("strades {} {} {}", tradesDb.getTradeDate(), tradesDb.getTradeNum(), st);
|
||||
else {
|
||||
this.log.error("strades {} {} {}", tradesDb.getTradeDate(), tradesDb.getTradeNum(), st);
|
||||
}
|
||||
};
|
||||
Consumer<String> logErr = (st) -> log.error("strades {} {} {}", tradesDb.getTradeDate(), tradesDb.getTradeNum(), st);
|
||||
try {
|
||||
Market market = marketImdg.getFirstObjectBySQL("code = '%s'".formatted(tradesDb.getClassCode()));
|
||||
if (market == null) {
|
||||
if (blacklistMarketImdg.getFirstObjectByFieldValues(Map.of("code", tradesDb.getClassCode())) == null) {
|
||||
log.accept("couldn't find market.section for classCode " + tradesDb.getClassCode());
|
||||
logErr.accept("couldn't find market.section for classCode " + tradesDb.getClassCode());
|
||||
}
|
||||
return false;
|
||||
}
|
||||
tradesDb.setSection(market.getSection());
|
||||
return true;
|
||||
} catch (Exception e) {
|
||||
log.accept(ExceptionUtils.getStackTrace(e));
|
||||
logErr.accept(ExceptionUtils.getStackTrace(e));
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue