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

http://jira.mfd.msk:8088/browse/CLS-290 stage 7

Browse source
This commit is contained in:
etreshenkov 2023-05-18 17:49:14 +03:00
parent 715328e4c9
commit df63b37e3c
2 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/TaskType.java
View file

@ -24,6 +24,10 @@ public enum TaskType {
* Step 6: forming Registry on Obligations and Settlement requirements * Step 6: forming Registry on Obligations and Settlement requirements
*/ */
FormingRegistersOnOS, FormingRegistersOnOS,
/**
* step 7
*/
FormingPaymentInstruction,
/** /**

8
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/FormingPaymentInstruction.java
View file

@ -50,8 +50,8 @@ public class FormingPaymentInstruction implements ISessionStage {
public StageResult submit(Task<?> task) { public StageResult submit(Task<?> task) {
InspectionPoolPayload payload = (InspectionPoolPayload) task.getData(); InspectionPoolPayload payload = (InspectionPoolPayload) task.getData();
switch (task.getTaskType()) { switch (task.getTaskType()) {
case InclusionToPool -> { case FormingPaymentInstruction -> {
return inspectionPool(payload.getProcessedCompanyId()); return formingPaymentInstruction(payload.getProcessedCompanyId());
} }
default -> { default -> {
throw new IllegalStateException("Unknown task type: " + task.getTaskType()); throw new IllegalStateException("Unknown task type: " + task.getTaskType());
@ -60,7 +60,7 @@ public class FormingPaymentInstruction implements ISessionStage {
} }
private StageResult inspectionPool(Long processedCompanyId) { private StageResult formingPaymentInstruction(Long processedCompanyId) {
RegistryTradingParams registryTradingParamsL = new RegistryTradingParams(RegistryDesignation.L, RegistryTradingParams registryTradingParamsL = new RegistryTradingParams(RegistryDesignation.L,
RegistryInstrumentType.S, null, RegistryUnit.T); RegistryInstrumentType.S, null, RegistryUnit.T);
RegistryTradingParams registryTradingParamsC = new RegistryTradingParams(RegistryDesignation.C, RegistryTradingParams registryTradingParamsC = new RegistryTradingParams(RegistryDesignation.C,
@ -172,7 +172,7 @@ public class FormingPaymentInstruction implements ISessionStage {
registryCodeCondition = RegistryCodeSqlBuilder.getInstance(registryTradingParamsLT).build(); registryCodeCondition = RegistryCodeSqlBuilder.getInstance(registryTradingParamsLT).build();
String sqlCondition = String.format("(%s) and securityId = %s and tradingClearingRegistryId = %s and companyId = %s and counterPartyId = %s", String sqlCondition = String.format("(%s) and securityId = %s and tradingClearingRegistryId = %s and companyId = %s and counterPartyId = %s",
registryCodeCondition, obligation.getSecurityId(), obligation.getTradingClearingRegistryId(), obligation.getCompanyId(), obligation.getCounterPartyId()); registryCodeCondition, obligation.getSecurityId(), obligation.getTradingClearingRegistryId(), obligation.getCompanyId(), obligation.getCounterPartyId());
Collection<Registry> registries = registryImdg.getCollectionObjectsBySQL(registryCodeCondition); Collection<Registry> registries = registryImdg.getCollectionObjectsBySQL(sqlCondition);
BigDecimal sumBalance = registries.stream().map(Registry::getBalance).reduce(BigDecimal.ZERO, BigDecimal::add); BigDecimal sumBalance = registries.stream().map(Registry::getBalance).reduce(BigDecimal.ZERO, BigDecimal::add);
PaymentInstruction paymentInstruction = createPaymentInstruction(obligation, sumBalance); PaymentInstruction paymentInstruction = createPaymentInstruction(obligation, sumBalance);