This commit is contained in:
parent
34f376dfae
commit
3909af085c
1 changed files with 8 additions and 0 deletions
|
|
@ -1,6 +1,7 @@
|
||||||
package ru.spcex.clearing.securities.service.cud;
|
package ru.spcex.clearing.securities.service.cud;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Arrays;
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
@ -480,6 +481,13 @@ public class GatewaySecurityService extends QueueConsumer implements Initializin
|
||||||
DigitalCertificateSecurityGatewayRequest request = baseRequest.getRequestPayload();
|
DigitalCertificateSecurityGatewayRequest request = baseRequest.getRequestPayload();
|
||||||
DigitalCertificateSecurityNewRequest newRequest = new DigitalCertificateSecurityNewRequest();
|
DigitalCertificateSecurityNewRequest newRequest = new DigitalCertificateSecurityNewRequest();
|
||||||
newRequest.setBaseCode(request.getDepoDcId());
|
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());
|
newRequest.setInstrumentType(request.getInstrumentType());
|
||||||
|
|
||||||
Map<String, Comparable<?>> query = new HashMap<>();
|
Map<String, Comparable<?>> query = new HashMap<>();
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue