etreschenkov 2026-06-17 14:14:57 +03:00
parent c7644bc07e
commit da33692e03

View file

@ -52,7 +52,7 @@ public enum GatewayUpdateEksClientCodeValidationRule implements IValidationRule<
ImdgPredicateBuilder predicateBuilder = accountImdg.predicateBuilder(); ImdgPredicateBuilder predicateBuilder = accountImdg.predicateBuilder();
List<MoneyAccountMsgRequest> accounts = validatedObject.getMoneyAccounts().stream() List<MoneyAccountMsgRequest> accounts = validatedObject.getMoneyAccounts().stream()
.filter(moneyAccountMsgRequest -> .filter(moneyAccountMsgRequest ->
moneyAccountMsgRequest.getStatus().equals("ADD") moneyAccountMsgRequest.getStatus().equals("NEW")
&& !CurrencyCode.RUB.equalsByKey(moneyAccountMsgRequest.getCurrCode())) && !CurrencyCode.RUB.equalsByKey(moneyAccountMsgRequest.getCurrCode()))
.toList(); .toList();
List<Account> clrnAccounts = new ArrayList<>(); List<Account> clrnAccounts = new ArrayList<>();
@ -64,14 +64,12 @@ public enum GatewayUpdateEksClientCodeValidationRule implements IValidationRule<
) )
); );
if (account == null) { if (account == null) {
//todo пропускать такие счета и не выдавать ошибку? just continue;
return of(AccountError.AccountNotFound, request.getAccount()); return of(AccountError.AccountNotFound, request.getAccount());
} }
TradingClearingRegistryList tkrListByAccount = tkrList.getSingleObjectByPredicate( TradingClearingRegistryList tkrListByAccount = tkrList.getSingleObjectByPredicate(
predicateBuilder.equals("accountId", account.getId()) predicateBuilder.equals("accountId", account.getId())
); );
if (tkrListByAccount != null) { if (tkrListByAccount != null) {
//todo пропускать такие счета и не выдавать ошибку? just continue;
return of(AccountError.AccountForTradingClearingRegistryAlreadyUsed, account.getId()); return of(AccountError.AccountForTradingClearingRegistryAlreadyUsed, account.getId());
} }
clrnAccounts.add(account); clrnAccounts.add(account);