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

ProcessorConfiguration

Browse source
This commit is contained in:
akulikov 2023-05-27 19:53:32 +03:00
parent 0feec2cfa2
commit de3a2a6759
9 changed files with 176 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/config/PipelineConfiguration.java
View file

@ -1,30 +0,0 @@
package ru.spcex.clearing.gatewayapi.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import ru.spcex.clearing.gatewayapi.logic.Stage;
import ru.spcex.clearing.gatewayapi.logic.listings_fond.*;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
import ru.spcex.platform.imdg.api.ImdgProvider;
import java.util.ArrayList;
import java.util.List;
@Configuration
public class PipelineConfiguration {
@Bean
public List<Stage<FondListingsRequestParam>> listingsRequestPipeline(ImdgProvider imdgProvider, KafkaSender kafkaSender) {
List<Stage<FondListingsRequestParam>> pipeline = new ArrayList<>();
pipeline.add(new PrepareSecurities());
pipeline.add(new PrepareIssuerCompanies());
pipeline.add(new ValidateIncomeSecurities());
pipeline.add(new ValidateIssuerCompanies());
pipeline.add(new CheckFondSecurityExist(imdgProvider));
pipeline.add(new CheckIssuerCompanyExist(imdgProvider));
pipeline.add(new SendMessageToCompanyServiceWithIssuerCompanies(kafkaSender, imdgProvider));
pipeline.add(new SendMessageToSecurityServiceWithFondSecurities(kafkaSender, imdgProvider));
return pipeline;
}
}

63
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/config/ProcessorConfiguration.java Normal file
View file

@ -0,0 +1,63 @@
package ru.spcex.clearing.gatewayapi.config;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import ru.spcex.clearing.gatewayapi.logic.Processor;
import ru.spcex.clearing.gatewayapi.logic.Stage;
import ru.spcex.clearing.gatewayapi.logic.companies.*;
import ru.spcex.clearing.gatewayapi.logic.listings_fond.*;
import ru.spcex.clearing.gatewayapi.logic.listings_mm.*;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
import ru.spcex.platform.imdg.api.ImdgProvider;
import java.util.ArrayList;
import java.util.List;
@Configuration
public class ProcessorConfiguration {
@Qualifier("fondListingsRequestProcessor")
@Bean
public Processor<FondListingsRequestParam> fondListingsRequestProcessor(ImdgProvider imdgProvider, KafkaSender kafkaSender) {
Processor<FondListingsRequestParam> processor = new Processor<>();
List<Stage<FondListingsRequestParam>> pipeline = new ArrayList<>();
pipeline.add(new PrepareSecurities());
pipeline.add(new PrepareIssuerCompanies());
pipeline.add(new ValidateIncomeSecurities());
pipeline.add(new ValidateIssuerCompanies());
pipeline.add(new CheckFondSecurityExist(imdgProvider));
pipeline.add(new CheckIssuerCompanyExist(imdgProvider));
pipeline.add(new SendMessageToCompanyServiceWithIssuerCompanies(kafkaSender, imdgProvider));
pipeline.add(new SendMessageToSecurityServiceWithFondSecurities(kafkaSender, imdgProvider));
processor.setPipeline(pipeline);
return processor;
}
@Qualifier("mmListingsRequestProcessor")
@Bean
public Processor<MMListingsRequestParam> mmListingsRequestProcessor(ImdgProvider imdgProvider, KafkaSender kafkaSender) {
Processor<MMListingsRequestParam> processor = new Processor<>();
List<Stage<MMListingsRequestParam>> pipeline = new ArrayList<>();
pipeline.add(new PrepareExchangeInstruments());
pipeline.add(new ValidateExchangeInstruments(imdgProvider));
pipeline.add(new CheckMoneyMarketSecurityExist(imdgProvider));
pipeline.add(new SendMessageToSecurityServiceWithMMSecurities(kafkaSender));
processor.setPipeline(pipeline);
return processor;
}
@Qualifier("companiesRequestProcessor")
@Bean
public Processor<CompaniesRequestParam> companiesRequestProcessor(ImdgProvider imdgProvider, KafkaSender kafkaSender) {
Processor<CompaniesRequestParam> processor = new Processor<>();
List<Stage<CompaniesRequestParam>> pipeline = new ArrayList<>();
pipeline.add(new PrepareMemberCompanies());
pipeline.add(new ValidateMemberCompanies());
pipeline.add(new CheckMemberCompanyExist(imdgProvider));
pipeline.add(new SendMessageToCompanyServiceWithMemberCompanies(kafkaSender, imdgProvider));
processor.setPipeline(pipeline);
return processor;
}
}

9
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/logic/ProcessResult.java
View file

@ -1,4 +1,13 @@
package ru.spcex.clearing.gatewayapi.logic;
public class ProcessResult {
private boolean ok = true;
public boolean isOk() {
return ok;
}
public void setOk(boolean ok) {
this.ok = ok;
}
}

2
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/logic/Processor.java
View file

@ -2,7 +2,7 @@ package ru.spcex.clearing.gatewayapi.logic;
import java.util.List;
public abstract class Processor<T> {
public class Processor<T> {
private List<Stage<T>> pipeline;
public ProcessResult process(T param) {

4
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/logic/listings_mm/CheckMoneyMarketSecurityExist.java
View file

@ -29,7 +29,11 @@ public class CheckMoneyMarketSecurityExist extends Stage<MMListingsRequestParam>
List<ExchangeInstrument> exchangeInstrumentList = param.getExchangeInstrumentsList();
for (ExchangeInstrument exchangeInstrument : exchangeInstrumentList) {
if (exchangeInstrument.isInvalidData()) continue;
String securitySymbol = extractSecuritySymbol(exchangeInstrument.getCode());
exchangeInstrument.setSecuritySymbol(securitySymbol);
Collection<MoneyMarketSecurity> securitiesFromImdg = moneyMarketSecurityImdg.getCollectionObjectsByFieldValues(
Map.of(
"securitySymbol", securitySymbol,

54
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/logic/listings_mm/SendMessageToSecurityServiceWithMMSecurities.java Normal file
View file

@ -0,0 +1,54 @@
package ru.spcex.clearing.gatewayapi.logic.listings_mm;
import ru.spcex.clearing.gatewayapi.logic.ProcessResult;
import ru.spcex.clearing.gatewayapi.logic.Stage;
import ru.spcex.clearing.gatewayapi.request.objects.ExchangeInstrument;
import ru.spcex.clearing.platform.messaging.domain.Consts;
import ru.spcex.clearing.platform.messaging.domain.cud.securitites.MoneyMarketSecurityNewRequest;
import ru.spcex.clearing.platform.messaging.domain.cud.securitites.MoneyMarketSecurityUpdateRequest;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
import ru.spcex.platform.enumeration.InstrumentType;
import java.util.List;
public class SendMessageToSecurityServiceWithMMSecurities extends Stage<MMListingsRequestParam> {
private final KafkaSender kafkaSender;
public SendMessageToSecurityServiceWithMMSecurities(KafkaSender kafkaSender) {
this.kafkaSender = kafkaSender;
}
@Override
public ProcessResult process(MMListingsRequestParam param) {
List<ExchangeInstrument> exchangeInstrumentList = param.getExchangeInstrumentsList();
for (ExchangeInstrument exchangeInstrument : exchangeInstrumentList) {
if (exchangeInstrument.isInvalidData()) continue;
if (!exchangeInstrument.isAlreadyExist()) {
MoneyMarketSecurityNewRequest moneyMarketSecurityNewRequest = new MoneyMarketSecurityNewRequest();
moneyMarketSecurityNewRequest.setNominalCurrency(exchangeInstrument.getSettlementCurrencyLetterCode());
moneyMarketSecurityNewRequest.setInstrumentType(InstrumentType.RATE.getKey());
moneyMarketSecurityNewRequest.setShortName(exchangeInstrument.getName());
moneyMarketSecurityNewRequest.setSecuritySymbol(exchangeInstrument.getSecuritySymbol());
moneyMarketSecurityNewRequest.setLotSize(exchangeInstrument.getLot());
moneyMarketSecurityNewRequest.setTermType(exchangeInstrument.getBankDepositAgreementType());
moneyMarketSecurityNewRequest.setIssuerId(exchangeInstrument.getIssuerId());
moneyMarketSecurityNewRequest.setWorkflowStatus(exchangeInstrument.getWorkflowStatus());
kafkaSender.sendRequestToQueue(Consts.DESTINATION_MONEY_MARKET_SECURITY_NEW, moneyMarketSecurityNewRequest);
} else {
MoneyMarketSecurityUpdateRequest moneyMarketSecurityUpdateRequest = new MoneyMarketSecurityUpdateRequest();
moneyMarketSecurityUpdateRequest.setId(exchangeInstrument.getMapId());
moneyMarketSecurityUpdateRequest.setNominalCurrency(exchangeInstrument.getSettlementCurrencyLetterCode());
moneyMarketSecurityUpdateRequest.setInstrumentType(InstrumentType.RATE.getKey());
moneyMarketSecurityUpdateRequest.setShortName(exchangeInstrument.getName());
moneyMarketSecurityUpdateRequest.setSecuritySymbol(exchangeInstrument.getSecuritySymbol());
moneyMarketSecurityUpdateRequest.setLotSize(exchangeInstrument.getLot());
moneyMarketSecurityUpdateRequest.setTermType(exchangeInstrument.getBankDepositAgreementType());
moneyMarketSecurityUpdateRequest.setIssuerId(exchangeInstrument.getIssuerId());
moneyMarketSecurityUpdateRequest.setWorkflowStatus(exchangeInstrument.getWorkflowStatus());
kafkaSender.sendRequestToQueue(Consts.DESTINATION_MONEY_MARKET_SECURITY_NEW, moneyMarketSecurityUpdateRequest);
}
}
return null;
}
}

8
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/logic/listings_mm/ValidateExchangeInstruments.java
View file

@ -10,6 +10,7 @@ import ru.spcex.clearing.gatewayapi.logic.Stage;
import ru.spcex.clearing.gatewayapi.request.objects.ExchangeInstrument;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.platform.enumeration.CompanySymbol;
import ru.spcex.platform.enumeration.TermType;
import ru.spcex.platform.enumeration.WorkflowStatus;
import ru.spcex.platform.imdg.api.Imdg;
import ru.spcex.platform.imdg.api.ImdgProvider;
@ -89,6 +90,13 @@ public class ValidateExchangeInstruments extends Stage<MMListingsRequestParam> {
exchangeInstrument.setInvalidData(true);
}
String bankDepositAgreementTypeStr = exchangeInstrument.getBankDepositAgreementType();
TermType termType = IEnumKey.getEnumByKey(TermType.class, bankDepositAgreementTypeStr);
if (termType == null) {
log.warn("Invalid bank_deposit_agreement_type {} for exchange_instrument (id = {})", bankDepositAgreementTypeStr, exchangeInstrument.getId());
exchangeInstrument.setInvalidData(true);
}
}
List<ExchangeInstrument> filteredExchangeInstrument = exchangeInstrumentList.stream()

19
clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/request/objects/ExchangeInstrument.java
View file

@ -6,6 +6,7 @@ import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import io.swagger.annotations.ApiModelProperty;
import ru.spcex.clearing.gatewayapi.config.deserializers.LocalDateDeserializer;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.util.UUID;
@ -130,7 +131,7 @@ public class ExchangeInstrument extends WithMapId {
value = "Лот",
example = "10"
)
private Long lot;
private BigDecimal lot;
@JsonProperty("order_execution_type_by_price")
@ApiModelProperty(
@ -213,6 +214,10 @@ public class ExchangeInstrument extends WithMapId {
@ApiModelProperty(hidden = true)
private Long issuerId;
@JsonProperty
@ApiModelProperty(hidden = true)
private String securitySymbol;
public UUID getId() {
return id;
@ -390,11 +395,11 @@ public class ExchangeInstrument extends WithMapId {
this.precision = precision;
}
public Long getLot() {
public BigDecimal getLot() {
return lot;
}
public void setLot(Long lot) {
public void setLot(BigDecimal lot) {
this.lot = lot;
}
@ -405,4 +410,12 @@ public class ExchangeInstrument extends WithMapId {
public void setIssuerId(Long issuerId) {
this.issuerId = issuerId;
}
public String getSecuritySymbol() {
return securitySymbol;
}
public void setSecuritySymbol(String securitySymbol) {
this.securitySymbol = securitySymbol;
}
}

21
platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/TermType.java Normal file
View file

@ -0,0 +1,21 @@
package ru.spcex.platform.enumeration;
import ru.spcex.platform.utils.enumeration.IEnumKey;
public enum TermType implements IEnumKey {
S("S"), // Срочный
V("V"), // До востребования
K("K"), // Комбинированный
;
private final String key;
TermType(String key) {
this.key = key;
}
@Override
public String getKey() {
return key;
}
}