clearing-service http://jira.mfd.msk:8088/browse/CLS-188 упростил выборку

This commit is contained in:
AKurakin 2023-02-01 12:05:03 +03:00
parent 1f09042271
commit f47d3c0914

View file

@ -98,9 +98,9 @@ public class ExecutionDepositComponent {
}
public void processNewTS() {
log.debug("Start check new S_TRADE. Start tradeNum={}", tradeNum);
log.debug("Start check new S_TRADE after {}", tradingDay);
ImdgPredicateBuilder pb = sTradeImdg.predicateBuilder();
ImdgPredicate sql = pb.and(pb.greater("tradeNum", tradeNum), pb.greatEqual("tradeDateTime", tradingDay));
ImdgPredicate sql = pb.greatEqual("tradeDateTime", tradingDay);
Collection<STrade> sTrades = sTradeImdg.getCollectionObjectsByPredicate(sql);
log.info("Found {} new s_trade with trade_num>{}", sTrades.size(), tradeNum);
@ -132,7 +132,7 @@ public class ExecutionDepositComponent {
LocalDate today = LocalDate.now();
for (STrade trade : sTrades) {
log.trace("Check s_trade[{}].tradeNum={} on date {}", trade.getId(), trade.getTradeNum());
log.trace("Check s_trade[{}].tradeNum={} on date {}", trade.getId(), trade.getTradeNum(), today);
Collection<ExecutionDeposit> existsEDeposit = executionDepositImdg.getCollectionObjectsByFieldValues(Map.of(
"exchangeExecutionId", trade.getTradeNum(),
"clearingDate", today