This commit is contained in:
parent
2ab03e6fcc
commit
6c5623797e
1 changed files with 4 additions and 4 deletions
|
|
@ -41,7 +41,7 @@ public abstract class AbstractExporterService {
|
|||
private final Logger log = LoggerFactory.getLogger(getClass());
|
||||
protected final Imdg<Registry> registryImdg;
|
||||
private final List<String> validStatus = List.of(ServiceStatus.Active.getKey(), ServiceStatus.Reopened.getKey());
|
||||
private final List<String> validAccountStatus = List.of(AccountStatus.ACTIVE.getKey(), AccountStatus.CLOSE.getKey());
|
||||
private final List<String> invalidAccountStatus = List.of(AccountStatus.BLOCKED.getKey(), AccountStatus.CLOSE.getKey());
|
||||
private final Imdg<TradingClearingRegistry> tradingClearingRegistryImdg;
|
||||
private final Imdg<Account> accountImdg;
|
||||
private final SecuritySelector<Security> securitySelector;
|
||||
|
|
@ -156,15 +156,15 @@ public abstract class AbstractExporterService {
|
|||
log.warn("For registry.id={} not exist tradingClearingRegistry.id={}", registry.getId(), registry.getTradingClearingRegistryId());
|
||||
return false;
|
||||
}
|
||||
if (validStatus.contains(tradingClearingRegistry.getStatus())) {
|
||||
if (!validStatus.contains(tradingClearingRegistry.getStatus())) {
|
||||
return false;
|
||||
}
|
||||
if (registry.getBalance().equals(BigDecimal.ZERO)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
Account account = accountImdg.getSingleObjectByID(tradingClearingRegistry.getMoneyAccountId());
|
||||
return !validAccountStatus.contains(account.getAccount());
|
||||
Account account = accountImdg.getSingleObjectByID(registry.getAccountId());
|
||||
return !invalidAccountStatus.contains(account.getAccount());
|
||||
}
|
||||
|
||||
protected BigDecimal sumNegativeABS(Collection<Registry> registries) {
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue