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

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

Browse source
This commit is contained in:
etreshenkov 2023-05-23 14:58:23 +03:00
parent 9f62b4fa76
commit be35cf9c5f
2 changed files with 5 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java
View file

@ -119,15 +119,15 @@ public class PrimaryAuctionBnSession extends QueueConsumer implements Initializi
runStage(TaskType.InclusionToPool, inclusionToPoolPayload, inclusionObligations); runStage(TaskType.InclusionToPool, inclusionToPoolPayload, inclusionObligations);
} }
//stage 5 //stage 5
InspectionPoolPayload companyIdPayload = new InspectionPoolPayload();
companyIdPayload.setProcessedCompanyId(currSession.getCompanyId());
{ {
InspectionPoolPayload companyIdPayload = new InspectionPoolPayload();
companyIdPayload.setProcessedCompanyId(currSession.getCompanyId());
runStage(TaskType.InspectionObligations, companyIdPayload, inclusionObligations); runStage(TaskType.InspectionObligations, companyIdPayload, inclusionObligations);
} }
//stage 6 //stage 6
runStage(TaskType.FormingRegistersOnOS, formingRegistersOnOS); //returns Collection<Registry> runStage(TaskType.FormingRegistersOnOS, formingRegistersOnOS); //returns Collection<Registry>
//stage 7 //stage 7
runStage(TaskType.FormingPaymentInstruction, companyIdPayload, formingPaymentInstruction); runStage(TaskType.FormingPaymentInstruction, formingPaymentInstruction);
//stage 8 //stage 8
{ {
UnlockResourcesPayload unlockResourcesPayload = new UnlockResourcesPayload(); UnlockResourcesPayload unlockResourcesPayload = new UnlockResourcesPayload();

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

@ -13,7 +13,6 @@ import ru.spcex.clearing.service.builder.sql.RegistryCodeSqlBuilder;
import ru.spcex.clearing.session.stage.ISessionStage; import ru.spcex.clearing.session.stage.ISessionStage;
import ru.spcex.clearing.session.stage.StageResult; import ru.spcex.clearing.session.stage.StageResult;
import ru.spcex.clearing.session.stage.Task; import ru.spcex.clearing.session.stage.Task;
import ru.spcex.clearing.session.stage.task.InspectionPoolPayload;
import ru.spcex.platform.enumeration.RegistryDesignation; import ru.spcex.platform.enumeration.RegistryDesignation;
import ru.spcex.platform.enumeration.RegistryInstrumentType; import ru.spcex.platform.enumeration.RegistryInstrumentType;
import ru.spcex.platform.enumeration.RegistryUnit; import ru.spcex.platform.enumeration.RegistryUnit;
@ -48,10 +47,9 @@ public class FormingPaymentInstruction implements ISessionStage {
@Override @Override
public StageResult submit(Task<?> task) { public StageResult submit(Task<?> task) {
InspectionPoolPayload payload = (InspectionPoolPayload) task.getData();
switch (task.getTaskType()) { switch (task.getTaskType()) {
case FormingPaymentInstruction -> { case FormingPaymentInstruction -> {
return formingPaymentInstruction(payload.getProcessedCompanyId()); return formingPaymentInstruction();
} }
default -> { default -> {
throw new IllegalStateException("Unknown task type: " + task.getTaskType()); throw new IllegalStateException("Unknown task type: " + task.getTaskType());
@ -60,7 +58,7 @@ public class FormingPaymentInstruction implements ISessionStage {
} }
private StageResult formingPaymentInstruction(Long processedCompanyId) { private StageResult formingPaymentInstruction() {
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,