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

http://jira.mfd.msk:8088/browse/CLS-967 // http://jira.mfd.msk:8088/browse/CLS-977

Browse source
This commit is contained in:
etreschenkov 2026-04-24 12:19:21 +03:00
parent 103a60f526
commit 0d45ad9554
16 changed files with 73 additions and 120 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/request/cud/securities/RatesNewAction.java
View file

@ -27,7 +27,7 @@ public class RatesNewAction implements IAction<RatesNewRequest> {
private Long currencyId;
@ApiModelProperty(value = "Статус.", example = "1234")
@JsonProperty
private String status;
private String workflowStatus;
@Override
public RatesNewRequest toRequest() {
@ -35,7 +35,7 @@ public class RatesNewAction implements IAction<RatesNewRequest> {
request.setValue(this.value);
request.setValueDate(this.valueDate);
request.setCurrencyId(this.currencyId);
request.setStatus(this.status);
request.setWorkflowStatus(this.workflowStatus);
return request;
}
@ -69,11 +69,11 @@ public class RatesNewAction implements IAction<RatesNewRequest> {
this.currencyId = currencyPairId;
}
public String getStatus() {
return status;
public String getWorkflowStatus() {
return workflowStatus;
}
public void setStatus(String status) {
this.status = status;
public void setWorkflowStatus(String workflowStatus) {
this.workflowStatus = workflowStatus;
}
}

12
clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/request/cud/securities/RatesUpdateAction.java
View file

@ -17,14 +17,14 @@ public class RatesUpdateAction implements IAction<RatesUpdateRequest> {
private BigDecimal value;
@ApiModelProperty(value = "Статус.", example = "1234")
@JsonProperty
private String status;
private String workflowStatus;
@Override
public RatesUpdateRequest toRequest() {
RatesUpdateRequest request = new RatesUpdateRequest();
request.setId(this.id);
request.setValue(this.value);
request.setStatus(this.status);
request.setWorkflowStatus(this.workflowStatus);
return request;
}
@ -50,11 +50,11 @@ public class RatesUpdateAction implements IAction<RatesUpdateRequest> {
this.value = value;
}
public String getStatus() {
return status;
public String getWorkflowStatus() {
return workflowStatus;
}
public void setStatus(String status) {
this.status = status;
public void setWorkflowStatus(String workflowStatus) {
this.workflowStatus = workflowStatus;
}
}

12
clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/request/cud/securities/RiskParameterNewAction.java
View file

@ -23,7 +23,7 @@ public class RiskParameterNewAction implements IAction<RiskParameterNewRequest>
private Long currencyPairId;
@ApiModelProperty(value = "Статус.", example = "1234")
@JsonProperty
private String status;
private String workflowStatus;
@Override
public RiskParameterNewRequest toRequest() {
@ -32,7 +32,7 @@ public class RiskParameterNewAction implements IAction<RiskParameterNewRequest>
request.setQuoteValue(this.quoteValue);
request.setSettlementType(this.settlementType);
request.setCurrencyPairId(this.currencyPairId);
request.setStatus(this.status);
request.setWorkflowStatus(this.workflowStatus);
return request;
}
@ -66,11 +66,11 @@ public class RiskParameterNewAction implements IAction<RiskParameterNewRequest>
this.currencyPairId = currencyPairId;
}
public String getStatus() {
return status;
public String getWorkflowStatus() {
return workflowStatus;
}
public void setStatus(String status) {
this.status = status;
public void setWorkflowStatus(String workflowStatus) {
this.workflowStatus = workflowStatus;
}
}

12
clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/request/cud/securities/RiskParameterUpdateAction.java
View file

@ -20,7 +20,7 @@ public class RiskParameterUpdateAction implements IAction<RiskParameterUpdateReq
private BigDecimal quoteValue;
@ApiModelProperty(value = "Статус.", example = "1234")
@JsonProperty
private String status;
private String workflowStatus;
@Override
public RiskParameterUpdateRequest toRequest() {
@ -28,7 +28,7 @@ public class RiskParameterUpdateAction implements IAction<RiskParameterUpdateReq
request.setId(this.id);
request.setValue(this.value);
request.setQuoteValue(this.quoteValue);
request.setStatus(this.status);
request.setWorkflowStatus(this.workflowStatus);
return request;
}
@ -54,11 +54,11 @@ public class RiskParameterUpdateAction implements IAction<RiskParameterUpdateReq
this.value = value;
}
public String getStatus() {
return status;
public String getWorkflowStatus() {
return workflowStatus;
}
public void setStatus(String status) {
this.status = status;
public void setWorkflowStatus(String workflowStatus) {
this.workflowStatus = workflowStatus;
}
}

8
clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/request/cud/securities/SCrossRateUpdateAction.java
View file

@ -15,12 +15,6 @@ public class SCrossRateUpdateAction implements IAction<SCrossRateUpdateRequest>
@JsonProperty
private Long id;
@JsonProperty
@JsonSerialize(using = LocalDateSerializer.class)
@JsonDeserialize(using = LocalDateDeserializer.class)
private LocalDate date;
@JsonProperty
private String currency;
@JsonProperty
private BigDecimal unitRate;
@JsonProperty
private BigDecimal faceValue;
@ -31,8 +25,6 @@ public class SCrossRateUpdateAction implements IAction<SCrossRateUpdateRequest>
public SCrossRateUpdateRequest toRequest() {
SCrossRateUpdateRequest sCrossRateUpdateRequest = new SCrossRateUpdateRequest();
sCrossRateUpdateRequest.setId(id);
sCrossRateUpdateRequest.setDate(date);
sCrossRateUpdateRequest.setCurrency(currency);
sCrossRateUpdateRequest.setUnitRate(unitRate);
sCrossRateUpdateRequest.setFaceValue(faceValue);
sCrossRateUpdateRequest.setRate(rate);

30
clearing-parent/backend-api/src/main/resources/meta/meta.json
View file

@ -1,6 +1,6 @@
{
"version": "3.23.295.157",
"version": "3.23.295.158",
"enums": {
@ -10906,7 +10906,7 @@
"name": "Добавление центрального курса",
"class": "ru.spcex.clearing.platform.messaging.domain.cud.securitites.SCrossRateNewRequest",
"class": "ru.spcex.clearing.backendapi.controller.request.cud.securities.SCrossRateNewAction",
"fields": [
{"code": "date",
@ -10935,20 +10935,12 @@
"name": "Изменение центрального курса",
"class": "ru.spcex.clearing.platform.messaging.domain.cud.securitites.SCrossRateUpdateRequest",
"class": "ru.spcex.clearing.backendapi.controller.request.cud.securities.SCrossRateUpdateAction",
"fields": [
{"code": "id",
"type": 1,"name": "Идентификатор записи","shortname": "ID","link": "sCrossRate","linkCode": "id","required": true
}
,
{"code": "date",
"name": "Дата торгов","shortname": "Дата","type": 6,"required": true
}
,
{"code": "currency",
"name": "Наименование валюты","shortname": "Валюта","type": 2,"length": 50,"link": "currencyCode","linkCode": "code","required": true
}
,
{"code": "faceValue",
"name": "Единица базовой валюты","shortname": "Единица базовой валюты","type": 10
@ -11036,7 +11028,7 @@
"name": "Добавление параметров риска",
"confirmation": "value,quoteValue,settlementType,currencyPairId,status",
"confirmation": "value,quoteValue,settlementType,currencyPairId,workflowStatus",
"class": "ru.spcex.clearing.backendapi.controller.request.cud.securities.RiskParameterNewAction",
@ -11057,7 +11049,7 @@
"name": "Ставка сопряженной валюты","shortname": "Ставка сопряженной валюты","type": 10
}
,
{"code": "status",
{"code": "workflowStatus",
"name": "Статус","shortname": "Статус","type": 2,"length": 4,"link": "workflowStatus"
}
]
@ -11067,7 +11059,7 @@
"name": "Изменение параметров риска",
"confirmation": "value,quoteValue,status",
"confirmation": "value,quoteValue,workflowStatus",
"class": "ru.spcex.clearing.backendapi.controller.request.cud.securities.RiskParameterUpdateAction",
@ -11084,7 +11076,7 @@
"name": "Ставка сопряженной валюты","shortname": "Ставка сопряженной валюты","type": 10
}
,
{"code": "status",
{"code": "workflowStatus",
"name": "Статус","shortname": "Статус","type": 2,"length": 4,"link": "workflowStatus"
}
]
@ -11132,7 +11124,7 @@
"name": "Добавление расчетного курса",
"confirmation": "value,valueDate,currencyId,status",
"confirmation": "value,valueDate,currencyId,workflowStatus",
"class": "ru.spcex.clearing.backendapi.controller.request.cud.securities.RatesNewAction",
@ -11149,7 +11141,7 @@
"name": "Расчетный курс","shortname": "Расчетный курс","type": 10
}
,
{"code": "status",
{"code": "workflowStatus",
"name": "Статус","shortname": "Статус","type": 2,"length": 4,"link": "workflowStatus"
}
]
@ -11159,7 +11151,7 @@
"name": "Изменение расчетного курса",
"confirmation": "value,status",
"confirmation": "value,workflowStatus",
"class": "ru.spcex.clearing.backendapi.controller.request.cud.securities.RatesUpdateAction",
@ -11172,7 +11164,7 @@
"name": "Расчетный курс","shortname": "Расчетный курс","type": 10
}
,
{"code": "status",
{"code": "workflowStatus",
"name": "Статус","shortname": "Статус","type": 2,"length": 4,"link": "workflowStatus"
}
]

24
clearing-parent/backend-api/src/main/resources/meta/meta.xml
View file

@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--?xml-stylesheet type="text/xsl" href="\..\corp-reports\src\data\meta\meta.server.xslt"?-->
<meta version="3.23.295.157">
<meta version="3.23.295.158">
<!-- _xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" _xsi:noNamespaceSchemaLocation="file:///E:/d/projects/meta/from/meta.xsd" -->
<!--Здесь словари-->
<enums>
@ -2526,17 +2526,15 @@
<createdAt field="created" type="4" webtype="5" dbname="Дата-время создания записи" name="Время создания записи" shortname="Создано" searchable="true" sortable="true" ignore="true"/>
<updatedAt field="updated" type="4" webtype="5" dbname="Дата-время изменения записи" name="Время изменения записи" shortname="Изменено" searchable="true" sortable="true" ignore="true"/>
<actions>
<post name="Добавление центрального курса" class="ru.spcex.clearing.platform.messaging.domain.cud.securitites.SCrossRateNewRequest">
<post name="Добавление центрального курса" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.SCrossRateNewAction">
<date name="Дата торгов" shortname="Дата" type="6" required="true"/>
<currency name="Наименование валюты" shortname="Валюта" type="2" length="50" link="currencyCode" linkCode="code" required="true"/>
<faceValue name="Единица базовой валюты" shortname="Единица базовой валюты" type="10"/>
<rate type="10" name="Курс валюты с учетом размера лота" shortname="Курс валюты"/>
<unitRate type="10" name="Курс за единицу иностранной валюты" shortname="Курс за единицу валюты" required="true"/>
</post>
<put name="Изменение центрального курса" class="ru.spcex.clearing.platform.messaging.domain.cud.securitites.SCrossRateUpdateRequest">
<put name="Изменение центрального курса" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.SCrossRateUpdateAction">
<id type="1" name="Идентификатор записи" shortname="ID" link="sCrossRate" linkCode="id" required="true"/>
<date name="Дата торгов" shortname="Дата" type="6" required="true"/>
<currency name="Наименование валюты" shortname="Валюта" type="2" length="50" link="currencyCode" linkCode="code" required="true"/>
<faceValue name="Единица базовой валюты" shortname="Единица базовой валюты" type="10"/>
<rate type="10" name="Курс валюты с учетом размера лота" shortname="Курс валюты"/>
<unitRate type="10" name="Курс за единицу базовой валюты" shortname="Курс за единицу валюты" required="true"/>
@ -2557,18 +2555,18 @@
<quoteValue name="Ставка сопряженной валюты" shortname="Ставка сопряженной валюты" type="10"/>
<workflowStatus name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
<actions>
<post name="Добавление параметров риска" confirmation="value,quoteValue,settlementType,currencyPairId,status" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.RiskParameterNewAction">
<post name="Добавление параметров риска" confirmation="value,quoteValue,settlementType,currencyPairId,workflowStatus" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.RiskParameterNewAction">
<currencyPairId name="Идентификатор валютной пары" shortname="Валютная пара" type="1" link="currencyPair" linkCode="code" linkKeyCode="id"/>
<settlementType name="Код расчёта" shortname="Код расчёта" type="12" link="currencySettlementType" linkCode="code"/>
<value name="Ставка" shortname="Ставка" type="10"/>
<quoteValue name="Ставка сопряженной валюты" shortname="Ставка сопряженной валюты" type="10"/>
<status name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
<workflowStatus name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
</post>
<put name="Изменение параметров риска" confirmation="value,quoteValue,status" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.RiskParameterUpdateAction">
<put name="Изменение параметров риска" confirmation="value,quoteValue,workflowStatus" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.RiskParameterUpdateAction">
<id type="1" name="Идентификатор записи" shortname="ID" link="riskParameter" linkCode="id" required="true"/>
<value name="Ставка" shortname="Ставка" type="10"/>
<quoteValue name="Ставка сопряженной валюты" shortname="Ставка сопряженной валюты" type="10"/>
<status name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
<workflowStatus name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
</put>
</actions>
</riskParameter>
@ -2580,16 +2578,16 @@
<value name="Расчетный курс" shortname="Расчетный курс" type="10"/>
<workflowStatus name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
<actions>
<post name="Добавление расчетного курса" confirmation="value,valueDate,currencyId,status" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.RatesNewAction">
<post name="Добавление расчетного курса" confirmation="value,valueDate,currencyId,workflowStatus" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.RatesNewAction">
<currencyId name="Идентификатор валюты" shortname="Валюта" type="1" link="currencyCode" linkCode="code" linkKeyCode="id"/>
<valueDate name="Дата, на которую расчетный курс" shortname="Дата" type="6"/>
<value name="Расчетный курс" shortname="Расчетный курс" type="10"/>
<status name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
<workflowStatus name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
</post>
<put name="Изменение расчетного курса" confirmation="value,status" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.RatesUpdateAction">
<put name="Изменение расчетного курса" confirmation="value,workflowStatus" class="ru.spcex.clearing.backendapi.controller.request.cud.securities.RatesUpdateAction">
<id type="1" name="Идентификатор записи" shortname="ID" link="rates" linkCode="id" required="true"/>
<value name="Расчетный курс" shortname="Расчетный курс" type="10"/>
<status name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
<workflowStatus name="Статус" shortname="Статус" type="2" length="4" link="workflowStatus"/>
</put>
</actions>
</rates>

4
clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/facade/RatesFacade.java
View file

@ -38,7 +38,7 @@ public class RatesFacade implements IClearingFacade {
rates.setCurrency(currencyCodeDictionary.getCode());
rates.setValue(request.getValue());
rates.setValueDate(request.getValueDate());
rates.setWorkflowStatus(request.getStatus());
rates.setWorkflowStatus(request.getWorkflowStatus());
rates.setCreated(Instant.now());
ratesImdg.insert(rates);
@ -50,7 +50,7 @@ public class RatesFacade implements IClearingFacade {
Rates ratesForUpdate = ratesImdg.getSingleObjectByID(request.getId());
ratesForUpdate.setValue(request.getValue());
ratesForUpdate.setWorkflowStatus(request.getStatus());
ratesForUpdate.setWorkflowStatus(request.getWorkflowStatus());
ratesForUpdate.setUpdated(Instant.now());
ratesImdg.update(ratesForUpdate);

4
clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/facade/RiskParameterFacade.java
View file

@ -42,7 +42,7 @@ public class RiskParameterFacade implements IClearingFacade {
riskParameter.setSettlementType(request.getSettlementType());
riskParameter.setValue(request.getValue());
riskParameter.setQuoteValue(request.getQuoteValue());
riskParameter.setWorkflowStatus(request.getStatus());
riskParameter.setWorkflowStatus(request.getWorkflowStatus());
riskParameter.setCreated(Instant.now());
riskParameterImdg.insert(riskParameter);
@ -55,7 +55,7 @@ public class RiskParameterFacade implements IClearingFacade {
riskParameterForUpdate.setValue(request.getValue());
riskParameterForUpdate.setQuoteValue(request.getQuoteValue());
riskParameterForUpdate.setWorkflowStatus(request.getStatus());
riskParameterForUpdate.setWorkflowStatus(request.getWorkflowStatus());
riskParameterImdg.update(riskParameterForUpdate);
log.debug("successfully processed, updated risk_parameter id {}", riskParameterForUpdate.getId());

4
clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/facade/SCrossRateFacade.java
View file

@ -38,9 +38,7 @@ public class SCrossRateFacade {
public void update(SCrossRateUpdateRequest req) {
SCrossRate sCrossRate = sCrossRateImdg.getSingleObjectByID(req.getId());
if (req.getDate() != null) {
sCrossRate.setDate(req.getDate());
}
sCrossRate.setUnitRate(req.getUnitRate());
sCrossRate.setFaceValue(req.getFaceValue());
sCrossRate.setRate(req.getRate());

4
clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/listeners/RatesMessageListener.java
View file

@ -145,7 +145,7 @@ public class RatesMessageListener extends QueueConsumer implements InitializingB
newRequest.setCurrencyId(currencyCodeDictionary.getId());
newRequest.setValueDate(sRateElem.getDate());
newRequest.setValue(sRateElem.getPrice());
newRequest.setStatus(WorkflowStatus.Active.getKey());
newRequest.setWorkflowStatus(WorkflowStatus.Active.getKey());
return Optional.of(newRequest);
}
@ -157,7 +157,7 @@ public class RatesMessageListener extends QueueConsumer implements InitializingB
return Optional.empty();
}
updateRequest.setValue(sRateElem.getPrice());
updateRequest.setStatus(WorkflowStatus.Active.getKey());
updateRequest.setWorkflowStatus(WorkflowStatus.Active.getKey());
return Optional.of(updateRequest);
}

27
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/securitites/SCrossRateUpdateRequest.java
View file

@ -1,23 +1,12 @@
package ru.spcex.clearing.platform.messaging.domain.cud.securitites;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import java.math.BigDecimal;
import java.time.LocalDate;
import ru.spcex.clearing.platform.messaging.domain.json.deserialize.LocalDateDeserializer;
import ru.spcex.clearing.platform.messaging.domain.json.serialize.LocalDateSerializer;
public class SCrossRateUpdateRequest {
@JsonProperty
private Long id;
@JsonProperty
@JsonSerialize(using = LocalDateSerializer.class)
@JsonDeserialize(using = LocalDateDeserializer.class)
private LocalDate date;
@JsonProperty
private String currency;
@JsonProperty
private BigDecimal unitRate;
@JsonProperty
private BigDecimal faceValue;
@ -54,20 +43,4 @@ public class SCrossRateUpdateRequest {
public void setRate(BigDecimal rate) {
this.rate = rate;
}
public LocalDate getDate() {
return date;
}
public void setDate(LocalDate date) {
this.date = date;
}
public String getCurrency() {
return currency;
}
public void setCurrency(String currency) {
this.currency = currency;
}
}

10
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/security/RatesNewRequest.java
View file

@ -19,7 +19,7 @@ public class RatesNewRequest {
@JsonProperty
private Long currencyId;
@JsonProperty
private String status;
private String workflowStatus;
public BigDecimal getValue() {
return value;
@ -45,11 +45,11 @@ public class RatesNewRequest {
this.currencyId = currencyId;
}
public String getStatus() {
return status;
public String getWorkflowStatus() {
return workflowStatus;
}
public void setStatus(String status) {
this.status = status;
public void setWorkflowStatus(String workflowStatus) {
this.workflowStatus = workflowStatus;
}
}

10
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/security/RatesUpdateRequest.java
View file

@ -10,7 +10,7 @@ public class RatesUpdateRequest {
@JsonProperty
private BigDecimal value;
@JsonProperty
private String status;
private String workflowStatus;
public Long getId() {
return id;
@ -28,11 +28,11 @@ public class RatesUpdateRequest {
this.value = value;
}
public String getStatus() {
return status;
public String getWorkflowStatus() {
return workflowStatus;
}
public void setStatus(String status) {
this.status = status;
public void setWorkflowStatus(String workflowStatus) {
this.workflowStatus = workflowStatus;
}
}

10
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/security/RiskParameterNewRequest.java
View file

@ -14,7 +14,7 @@ public class RiskParameterNewRequest {
@JsonProperty
private Long currencyPairId;
@JsonProperty
private String status;
private String workflowStatus;
public BigDecimal getValue() {
return value;
@ -48,11 +48,11 @@ public class RiskParameterNewRequest {
this.currencyPairId = currencyPairId;
}
public String getStatus() {
return status;
public String getWorkflowStatus() {
return workflowStatus;
}
public void setStatus(String status) {
this.status = status;
public void setWorkflowStatus(String status) {
this.workflowStatus = status;
}
}

10
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/security/RiskParameterUpdateRequest.java
View file

@ -12,7 +12,7 @@ public class RiskParameterUpdateRequest {
@JsonProperty
private BigDecimal quoteValue;
@JsonProperty
private String status;
private String workflowStatus;
public Long getId() {
return id;
@ -38,11 +38,11 @@ public class RiskParameterUpdateRequest {
this.quoteValue = quoteValue;
}
public String getStatus() {
return status;
public String getWorkflowStatus() {
return workflowStatus;
}
public void setStatus(String status) {
this.status = status;
public void setWorkflowStatus(String status) {
this.workflowStatus = status;
}
}