securities-service http://jira.mfd.msk:8088/browse/CLS-258 оправил заполнение поля

This commit is contained in:
AKurakin 2023-06-05 18:12:26 +03:00
parent c10dd23a38
commit ae37e501f6
5 changed files with 13 additions and 1 deletions

View file

@ -101,6 +101,7 @@ public class EquitySecurityService extends QueueConsumer implements Initializing
equity.setInstrumentType(req.getInstrumentType()); equity.setInstrumentType(req.getInstrumentType());
equity.setSecurityId(equity.getId()); equity.setSecurityId(equity.getId());
equity.setCreated(Instant.now()); equity.setCreated(Instant.now());
equity.setUpdated(equity.getCreated());
try { try {
transaction.beginTransaction(); transaction.beginTransaction();
Imdg<EquitySecurity> equityImdg = transaction.getImdg(IMDGDistributedNames.Map_EquitySecurity, EquitySecurity.class); Imdg<EquitySecurity> equityImdg = transaction.getImdg(IMDGDistributedNames.Map_EquitySecurity, EquitySecurity.class);

View file

@ -105,6 +105,7 @@ public class FixedIncomeSecurityService extends QueueConsumer implements Initial
fixedIncome.setInstrumentType(req.getInstrumentType()); fixedIncome.setInstrumentType(req.getInstrumentType());
fixedIncome.setSecurityId(fixedIncome.getId()); fixedIncome.setSecurityId(fixedIncome.getId());
fixedIncome.setCreated(Instant.now()); fixedIncome.setCreated(Instant.now());
fixedIncome.setUpdated(fixedIncome.getCreated());
try { try {
transaction.beginTransaction(); transaction.beginTransaction();
Imdg<FixedIncomeSecurity> fixedIncomeImdg = transaction.getImdg(IMDGDistributedNames.Map_FixedIncomeSecurity, FixedIncomeSecurity.class); Imdg<FixedIncomeSecurity> fixedIncomeImdg = transaction.getImdg(IMDGDistributedNames.Map_FixedIncomeSecurity, FixedIncomeSecurity.class);

View file

@ -135,7 +135,9 @@ public class MoneyMarketSecurityService extends QueueConsumer implements Initial
mms.setIssuerId(req.getIssuerId()); mms.setIssuerId(req.getIssuerId());
mms.setSecurityId(mms.getId()); mms.setSecurityId(mms.getId());
mms.setDescription(req.getDescription()); mms.setDescription(req.getDescription());
mms.setConvention(req.getConvention());
mms.setCreated(Instant.now()); mms.setCreated(Instant.now());
mms.setUpdated(mms.getCreated());
if (req.getWorkflowStatus() == null) { if (req.getWorkflowStatus() == null) {
mms.setWorkflowStatus(WorkflowStatus.Active.getKey()); mms.setWorkflowStatus(WorkflowStatus.Active.getKey());
} else { } else {
@ -206,6 +208,7 @@ public class MoneyMarketSecurityService extends QueueConsumer implements Initial
mms.setIssuerId(req.getIssuerId()); mms.setIssuerId(req.getIssuerId());
mms.setSecurityId(mms.getId()); mms.setSecurityId(mms.getId());
mms.setDescription(req.getDescription()); mms.setDescription(req.getDescription());
mms.setConvention(req.getConvention());
if (req.getWorkflowStatus() != null) { if (req.getWorkflowStatus() != null) {
mms.setWorkflowStatus(req.getWorkflowStatus()); mms.setWorkflowStatus(req.getWorkflowStatus());
} }

View file

@ -18,10 +18,12 @@ import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.securities.config.ErrorResolverConfig; import ru.spcex.clearing.securities.config.ErrorResolverConfig;
import ru.spcex.clearing.securities.config.ValidationConfig; import ru.spcex.clearing.securities.config.ValidationConfig;
import ru.spcex.clearing.securities.service.cud.*; import ru.spcex.clearing.securities.service.cud.*;
import ru.spcex.clearing.securities.validation.ListingValidationProvider;
import ru.spcex.clearing.securities.validation.ValidationProvider; import ru.spcex.clearing.securities.validation.ValidationProvider;
import ru.spcex.clearing.test.MatcherFactory; import ru.spcex.clearing.test.MatcherFactory;
import ru.spcex.clearing.test.config.ImdgTestConfig; import ru.spcex.clearing.test.config.ImdgTestConfig;
import ru.spcex.clearing.test.config.KafkaTestConfig; import ru.spcex.clearing.test.config.KafkaTestConfig;
import ru.spcex.clearing.util.security.SecuritySelector;
import ru.spcex.platform.imdg.api.Imdg; import ru.spcex.platform.imdg.api.Imdg;
import ru.spcex.platform.imdg.api.ImdgProvider; import ru.spcex.platform.imdg.api.ImdgProvider;
@ -37,7 +39,8 @@ import static ru.spcex.clearing.test.config.ImdgTestConfig.waitAvailableImdgProv
EquitySecurityService.class, EquitySecurityService.class,
FixedIncomeSecurityService.class, FixedIncomeSecurityService.class,
MoneyMarketSecurityService.class, MoneyMarketSecurityService.class,
ListingService.class, ListingService.class, ListingValidationProvider.class,
SecuritySelector.class,
ImdgTestConfig.class, ImdgTestConfig.class,
KafkaTestConfig.class, KafkaTestConfig.class,
ValidationProvider.class, ValidationProvider.class,

View file

@ -24,6 +24,7 @@ class MoneyMarketSecurityFactory {
private String fullName = "estat"; private String fullName = "estat";
private String shortName = "esasdftat"; private String shortName = "esasdftat";
private String securitySymbol = "sdfafd"; private String securitySymbol = "sdfafd";
private String convention = "convention";
private String istin = "istin"; private String istin = "istin";
private String termType = AbstractServiceTest.termType; private String termType = AbstractServiceTest.termType;
@ -106,6 +107,7 @@ class MoneyMarketSecurityFactory {
moneyMarketSecurity.setDescription(description); moneyMarketSecurity.setDescription(description);
moneyMarketSecurity.setLotSize(lotSize); moneyMarketSecurity.setLotSize(lotSize);
moneyMarketSecurity.setSecuritySymbol(securitySymbol); moneyMarketSecurity.setSecuritySymbol(securitySymbol);
moneyMarketSecurity.setConvention(convention);
moneyMarketSecurity.setWorkflowStatus(ru.spcex.platform.enumeration.Status.Active.getKey()); moneyMarketSecurity.setWorkflowStatus(ru.spcex.platform.enumeration.Status.Active.getKey());
return moneyMarketSecurity; return moneyMarketSecurity;
@ -131,6 +133,7 @@ class MoneyMarketSecurityFactory {
moneyMarketSecurityUpdateRequest.setIssuerId(issuerId); moneyMarketSecurityUpdateRequest.setIssuerId(issuerId);
moneyMarketSecurityUpdateRequest.setDescription(description); moneyMarketSecurityUpdateRequest.setDescription(description);
moneyMarketSecurityUpdateRequest.setSecuritySymbol(securitySymbol); moneyMarketSecurityUpdateRequest.setSecuritySymbol(securitySymbol);
moneyMarketSecurityUpdateRequest.setConvention(convention);
moneyMarketSecurityUpdateRequest.setWorkflowStatus(ru.spcex.platform.enumeration.Status.Active.getKey()); moneyMarketSecurityUpdateRequest.setWorkflowStatus(ru.spcex.platform.enumeration.Status.Active.getKey());
return moneyMarketSecurityUpdateRequest; return moneyMarketSecurityUpdateRequest;
@ -160,6 +163,7 @@ class MoneyMarketSecurityFactory {
keyRequest.setIsin(istin); keyRequest.setIsin(istin);
keyRequest.setDescription(description); keyRequest.setDescription(description);
keyRequest.setSecuritySymbol(securitySymbol); keyRequest.setSecuritySymbol(securitySymbol);
keyRequest.setConvention(convention);
keyRequest.setWorkflowStatus(ru.spcex.platform.enumeration.Status.Active.getKey()); keyRequest.setWorkflowStatus(ru.spcex.platform.enumeration.Status.Active.getKey());