clearing-service fix NPE on fix reset-balance 6b036c8e91
This commit is contained in:
parent
6b036c8e91
commit
23fbf503c9
1 changed files with 10 additions and 8 deletions
|
|
@ -100,18 +100,20 @@ public class RegistryService {
|
||||||
rgs.getAccount() != null && rgs.getSecurityId() != null &&
|
rgs.getAccount() != null && rgs.getSecurityId() != null &&
|
||||||
rgs.getTradingClearingRegistryId() != null && rgs.getCompanyId() != null &&
|
rgs.getTradingClearingRegistryId() != null && rgs.getCompanyId() != null &&
|
||||||
RegistryUnit.B.equalsByKey(rgs.getRegistryUnit()) &&
|
RegistryUnit.B.equalsByKey(rgs.getRegistryUnit()) &&
|
||||||
rgs.getSecurityId().equals(registry.getSecurityId()) &&
|
rgs.getSecurityId() != null && rgs.getSecurityId().equals(registry.getSecurityId()) &&
|
||||||
rgs.getCompanyId().equals(registry.getCompanyId()) &&
|
rgs.getCompanyId() != null && rgs.getCompanyId().equals(registry.getCompanyId()) &&
|
||||||
rgs.getAccount().equals(registry.getAccount()) &&
|
rgs.getAccount() != null && rgs.getAccount().equals(registry.getAccount()) &&
|
||||||
rgs.getTradingClearingRegistryId().equals(registry.getTradingClearingRegistryId())).findFirst();
|
rgs.getTradingClearingRegistryId() != null && rgs.getTradingClearingRegistryId().equals(registry.getTradingClearingRegistryId())
|
||||||
|
).findFirst();
|
||||||
Optional<Registry> registryTOptional = registriesA.stream().filter(rgs ->
|
Optional<Registry> registryTOptional = registriesA.stream().filter(rgs ->
|
||||||
rgs.getAccount() != null && rgs.getSecurityId() != null &&
|
rgs.getAccount() != null && rgs.getSecurityId() != null &&
|
||||||
rgs.getTradingClearingRegistryId() != null && rgs.getCompanyId() != null &&
|
rgs.getTradingClearingRegistryId() != null && rgs.getCompanyId() != null &&
|
||||||
RegistryUnit.T.equalsByKey(rgs.getRegistryUnit()) &&
|
RegistryUnit.T.equalsByKey(rgs.getRegistryUnit()) &&
|
||||||
rgs.getSecurityId().equals(registry.getSecurityId()) &&
|
rgs.getSecurityId() != null && rgs.getSecurityId().equals(registry.getSecurityId()) &&
|
||||||
rgs.getCompanyId().equals(registry.getCompanyId()) &&
|
rgs.getCompanyId() != null && rgs.getCompanyId().equals(registry.getCompanyId()) &&
|
||||||
rgs.getAccount().equals(registry.getAccount()) &&
|
rgs.getAccount() != null && rgs.getAccount().equals(registry.getAccount()) &&
|
||||||
rgs.getTradingClearingRegistryId().equals(registry.getTradingClearingRegistryId())).findFirst();
|
rgs.getTradingClearingRegistryId() != null && rgs.getTradingClearingRegistryId().equals(registry.getTradingClearingRegistryId())
|
||||||
|
).findFirst();
|
||||||
BigDecimal balanceB;
|
BigDecimal balanceB;
|
||||||
if (registryBOptional.isPresent()) {
|
if (registryBOptional.isPresent()) {
|
||||||
balanceB = registryBOptional.get().getBalance();
|
balanceB = registryBOptional.get().getBalance();
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue