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

поправлены баги при создании инструментов

Browse source
This commit is contained in:
etreschenkov 2023-07-12 18:56:46 +03:00
parent 343277caa3
commit 97322f6e0f
1 changed files with 25 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/cud/GatewaySecurityService.java
View file

@ -186,6 +186,11 @@ public class GatewaySecurityService extends QueueConsumer implements Initializin
if (InstrumentType.BOND.equalsByKey(req.getSecurityType())) { if (InstrumentType.BOND.equalsByKey(req.getSecurityType())) {
FixedIncomeGatewayRequest fixedIncomeGatewayRequest = (FixedIncomeGatewayRequest) req; FixedIncomeGatewayRequest fixedIncomeGatewayRequest = (FixedIncomeGatewayRequest) req;
FixedIncomeSecurityNewRequest fixedIncomeRequest = fixedIncomeGatewayRequest.getSecurity(); FixedIncomeSecurityNewRequest fixedIncomeRequest = fixedIncomeGatewayRequest.getSecurity();
if (StringUtils.isEmpty(fixedIncomeRequest.getSecuritySymbol())){
log.warn("Skip creating eqtySecurtity without securityId: uuid: {}", req.getUuid());
return null;
}
log.debug("Processed request with securitySymbol: {}", fixedIncomeRequest.getSecuritySymbol());
fixedIncomeRequest.setIssuerId(companyId); fixedIncomeRequest.setIssuerId(companyId);
log.trace("FixedIncomeSecurityNewRequest - BOND"); log.trace("FixedIncomeSecurityNewRequest - BOND");
String securitySymbol = fixedIncomeRequest.getSecuritySymbol(); String securitySymbol = fixedIncomeRequest.getSecuritySymbol();
@ -198,6 +203,26 @@ public class GatewaySecurityService extends QueueConsumer implements Initializin
security = fixedIncomeSecurityService.updateFixedIncome0(updateRequest); security = fixedIncomeSecurityService.updateFixedIncome0(updateRequest);
} }
} }
if (InstrumentType.EQTY.equalsByKey(req.getSecurityType())) {
EquitySecurityGatewayRequest equitySecurityGatewayRequest = (EquitySecurityGatewayRequest) req;
EquitySecurityNewRequest equityRequest = equitySecurityGatewayRequest.getSecurity();
if (StringUtils.isEmpty(equityRequest.getSecuritySymbol())){
log.warn("Skip creating eqtySecurtity without securityId: uuid: {}", req.getUuid());
return null;
}
log.debug("Processed request with securitySymbol: {}", equityRequest.getSecuritySymbol());
equityRequest.setIssuerId(companyId);
log.trace("EquitySecurityNewRequest - FOND");
String securitySymbol = equityRequest.getSecuritySymbol();
security = findSecurityBySecuritySymbol(equitySecurityImdg, securitySymbol);
if (security == null) {
security = equitySecurityService.newEquity0(equityRequest);
} else {
EquitySecurityUpdateRequest updateRequest = toUpdateRequest(security, equityRequest);
security = equitySecurityService.updateEquity0(updateRequest);
}
}
} catch (ValidationException expected) { } catch (ValidationException expected) {
log.warn("Error create or update issue: {}", expected.toString()); log.warn("Error create or update issue: {}", expected.toString());
return requestHelper.makeErrorResponse(baseRequest, expected.getEnumMsg()); return requestHelper.makeErrorResponse(baseRequest, expected.getEnumMsg());