This commit is contained in:
parent
62b3b419f1
commit
f9898617e8
2 changed files with 6 additions and 3 deletions
|
|
@ -227,6 +227,9 @@ public class ClientCodeMessageListener extends QueueConsumer implements Initiali
|
|||
|
||||
List<Long> accIds = new ArrayList<>();
|
||||
for (MoneyAccountMsgRequest account : tkrAccount.getMoneyAccounts()) {
|
||||
if (account.getStatus().equals("NOW")) {
|
||||
continue;
|
||||
}
|
||||
if (StringUtils.hasText(account.getEks_account())) {
|
||||
log.debug("eks_account is filled, creating info account: {}", account.getEks_account());
|
||||
Pair<Long, String> accId = accountFacade.createAccountInfo(account, company);
|
||||
|
|
|
|||
|
|
@ -132,16 +132,16 @@ public enum GatewayUpdateEksClientCodeValidationRule implements IValidationRule<
|
|||
TradingClearingRegistry tkr = context.getStoredObject(ClientCodeStoreObjects.TRADING_CLEARING_REGISTRY);
|
||||
Imdg<ClientCode> clientCodeImdg = context.obtainMap(IMDGDistributedNames.Map_ClientCode, ClientCode.class);
|
||||
ImdgPredicateBuilder predicate = clientCodeImdg.predicateBuilder();
|
||||
String trkCode = validatedObject.getTkrCode();
|
||||
String clientCode = validatedObject.getClientCode();
|
||||
ClientCode existClientCode = clientCodeImdg.getSingleObjectByPredicate(
|
||||
predicate.and(
|
||||
predicate.equals("code", validatedObject.getClientCode()),
|
||||
predicate.equals("code", clientCode),
|
||||
predicate.equals("tradingClearingRegistryId", tkr.getId()),
|
||||
predicate.equals("status", Status.Active.getKey())
|
||||
)
|
||||
);
|
||||
if (existClientCode == null) {
|
||||
return of(AccountError.ClientCodeNotFound, trkCode);
|
||||
return of(AccountError.ClientCodeNotFound, clientCode);
|
||||
}
|
||||
context.storeObject(ClientCodeStoreObjects.CLIENT_CODE, existClientCode);
|
||||
return empty();
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue