registry-service http://jira.mfd.msk:8088/browse/CLS-653 improvement MoneyBalanceRegisterService

This commit is contained in:
AKurakin 2024-03-04 13:03:51 +03:00
parent 42c75db19e
commit c705b4e27c
2 changed files with 8 additions and 1 deletions

View file

@ -93,7 +93,7 @@ public class ExecutionRegisterReportBuilder extends XLSXReportBuilder<ExecutionR
entity.setBuyerCode(companySymbolsByCompanyId.getCompanySymbolValue());
}
entity.setBuyerTkr(input.getPartyTradingClearingRegistry());
}
} else
if (Arrays.asList(Side.SELL.getKey(), MoneyFlowSide.SELL.getKey()).contains(input.getSide().toUpperCase())) {
if (companyByCompanyId != null) {
entity.setSeller(companyByCompanyId.getShortName());
@ -108,7 +108,13 @@ public class ExecutionRegisterReportBuilder extends XLSXReportBuilder<ExecutionR
entity.setBuyerCode(companySymbolsByCounterPartyId.getCompanySymbolValue());
}
entity.setBuyerTkr(input.getCounterPartyTradingClearingRegistry());
} else {
log.warn("{}[{}] has wrong or empty field: side={}. Can not fill buyer/seller.",
input.getClass().getSimpleName(), input.getId(), input.getSide());
}
} else {
log.warn("{}[{}] has wrong or empty field: side={} CompanyId={} CounterPartyId={}. Can not fill buyer/seller.",
input.getClass().getSimpleName(), input.getId(), input.getSide(), input.getCompanyId(), input.getCounterPartyId());
}
if (input.getExchangeExecutionTime() != null)

View file

@ -148,6 +148,7 @@ public class MoneyBalanceRegisterService extends QueueConsumer implements Initia
ImdgPredicate finalPredicate = pb.and(
registryPredicate,
pb.notNull("object.tradingClearingRegistry"),
pb.equals("object.accountType", AccountType.Info.getKey()),
pb.and(
pb.greatEqual("eventTime", now),
pb.less("eventTime", now.plus(1, ChronoUnit.DAYS))