treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-863

Browse source
This commit is contained in:
etreschenkov 2025-06-16 17:02:50 +03:00
parent 2ac98d9f39
commit 5f42c6df63
2 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/DigitalSecurityService.java
View file

@ -1,11 +1,13 @@
package ru.spcex.clearing.gatewayapi.service; package ru.spcex.clearing.gatewayapi.service;
import java.util.List; import java.util.List;
import java.util.Optional;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import ru.spcex.clearing.gatewayapi.controller.inbound.request.listing.fond.DigitalCertificate; import ru.spcex.clearing.gatewayapi.controller.inbound.request.listing.fond.DigitalCertificate;
import ru.spcex.clearing.gatewayapi.controller.inbound.request.listing.fond.FondDigitalListingsRequest; import ru.spcex.clearing.gatewayapi.controller.inbound.request.listing.fond.FondDigitalListingsRequest;
import ru.spcex.clearing.gatewayapi.controller.inbound.request.listing.fond.IssuerCompanySymbols;
import ru.spcex.clearing.gatewayapi.service.adapter.DigitalSecurityRequestAdapter; import ru.spcex.clearing.gatewayapi.service.adapter.DigitalSecurityRequestAdapter;
import ru.spcex.clearing.gatewayapi.service.adapter.SecurityRequestAdapter; import ru.spcex.clearing.gatewayapi.service.adapter.SecurityRequestAdapter;
import ru.spcex.clearing.platform.messaging.domain.Consts; import ru.spcex.clearing.platform.messaging.domain.Consts;
@ -49,6 +51,12 @@ public class DigitalSecurityService {
List<ListingNewRequest> listingRequests = request.getListingList().stream() List<ListingNewRequest> listingRequests = request.getListingList().stream()
.filter(incomeListing -> incomeListing.getSymbolCode().equals(security.getSecuritySymbol())) .filter(incomeListing -> incomeListing.getSymbolCode().equals(security.getSecuritySymbol()))
.map(securityRequestAdapter::toIncomeListing).toList(); .map(securityRequestAdapter::toIncomeListing).toList();
Optional<String> innVal = request.getIssuerCompanySymbolsList().stream()
.filter(issuerCompanySymbols -> issuerCompanySymbols.getCompanyId().equals(security.getIssuerId())
&& issuerCompanySymbols.getCompanySymbol().equals("INN"))
.findFirst()
.map(IssuerCompanySymbols::getCompanySymbolValue);
innVal.ifPresent(digitalCertificateSecurityRequest::setInn);
digitalCertificateSecurityRequest.setListing(listingRequests); digitalCertificateSecurityRequest.setListing(listingRequests);
kafkaSender.sendRequestToQueue(Consts.DESTINATION_SECURITY_DGCT_GATEWAY, digitalCertificateSecurityRequest); kafkaSender.sendRequestToQueue(Consts.DESTINATION_SECURITY_DGCT_GATEWAY, digitalCertificateSecurityRequest);
} catch (Throwable e) { } catch (Throwable e) {

1
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/adapter/DigitalSecurityRequestAdapter.java
View file

@ -15,7 +15,6 @@ public class DigitalSecurityRequestAdapter {
gatewayRequest.setDepoDcId(digitalCertificate.getDepoDcId()); gatewayRequest.setDepoDcId(digitalCertificate.getDepoDcId());
gatewayRequest.setInstrumentType(digitalCertificate.getInstrumentType()); gatewayRequest.setInstrumentType(digitalCertificate.getInstrumentType());
gatewayRequest.setIssuerId(digitalCertificate.getIssuerId()); gatewayRequest.setIssuerId(digitalCertificate.getIssuerId());
gatewayRequest.setInn(digitalCertificate.getUcp().getCompanyInn());
gatewayRequest.setShortName(digitalCertificate.getShortName()); gatewayRequest.setShortName(digitalCertificate.getShortName());
gatewayRequest.setFullName(digitalCertificate.getFullName()); gatewayRequest.setFullName(digitalCertificate.getFullName());
gatewayRequest.setFullNameEng(digitalCertificate.getFullNameEng()); gatewayRequest.setFullNameEng(digitalCertificate.getFullNameEng());