etreschenkov 2025-08-14 17:46:43 +03:00
parent 2326d7c0a6
commit 178aa11561

View file

@ -185,19 +185,25 @@ public class TradeImporterService {
* returns OK - everything is kk * returns OK - everything is kk
*/ */
private boolean fillNessessaryFields(STrades tradesDb) { private boolean fillNessessaryFields(STrades tradesDb) {
Consumer<String> logErr = (st) -> log.error("strades {} {} {}", tradesDb.getTradeDate(), tradesDb.getTradeNum(), st); 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);
}
};
try { try {
Market market = marketImdg.getFirstObjectBySQL("code = '%s'".formatted(tradesDb.getClassCode())); Market market = marketImdg.getFirstObjectBySQL("code = '%s'".formatted(tradesDb.getClassCode()));
if (market == null) { if (market == null) {
if (blacklistMarketImdg.getFirstObjectByFieldValues(Map.of("code", tradesDb.getClassCode())) == null) { if (blacklistMarketImdg.getFirstObjectByFieldValues(Map.of("code", tradesDb.getClassCode())) == null) {
logErr.accept("couldn't find market.section for classCode " + tradesDb.getClassCode()); log.accept("couldn't find market.section for classCode " + tradesDb.getClassCode());
} }
return false; return false;
} }
tradesDb.setSection(market.getSection()); tradesDb.setSection(market.getSection());
return true; return true;
} catch (Exception e) { } catch (Exception e) {
logErr.accept(ExceptionUtils.getStackTrace(e)); log.accept(ExceptionUtils.getStackTrace(e));
return false; return false;
} }
} }