diff --git a/clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/cud/GatewaySecurityService.java b/clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/cud/GatewaySecurityService.java index ec5638104..19c9fca07 100644 --- a/clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/cud/GatewaySecurityService.java +++ b/clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/cud/GatewaySecurityService.java @@ -1,6 +1,7 @@ package ru.spcex.clearing.securities.service.cud; import java.util.ArrayList; +import java.util.Arrays; import java.util.Collection; import java.util.HashMap; import java.util.List; @@ -480,6 +481,13 @@ public class GatewaySecurityService extends QueueConsumer implements Initializin DigitalCertificateSecurityGatewayRequest request = baseRequest.getRequestPayload(); DigitalCertificateSecurityNewRequest newRequest = new DigitalCertificateSecurityNewRequest(); newRequest.setBaseCode(request.getDepoDcId()); + + InstrumentType clrInstrumentType = Arrays.asList("DC", "D") + .contains(request.getInstrumentType()) ? InstrumentType.DGCT : null; + if (clrInstrumentType == null) { + log.warn("Not defined instrumentType={}", request.getInstrumentType()); + return null; + } newRequest.setInstrumentType(request.getInstrumentType()); Map> query = new HashMap<>();