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

unit session deals preparation order, logging

Browse source
This commit is contained in:
ialbert 2025-07-09 15:18:40 +03:00
parent b451394004
commit 88ea9e5a66
3 changed files with 4 additions and 2 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/config/state_machine_2/specific/UnitedSessionStateMachineConfig.java
View file

@ -167,9 +167,9 @@ public class UnitedSessionStateMachineConfig
.source(TaskType.StartRevisePart1).target(TaskType.DealsPrepare) .source(TaskType.StartRevisePart1).target(TaskType.DealsPrepare)
.action( .action(
chain( chain(
dealsPrepareTRDT, new CompoundDealsPrepareAction(ExecutionType.ExecutionFond),
dealsPrepareCurrency, new CompoundDealsPrepareAction(ExecutionType.ExecutionCurrency), dealsPrepareCurrency, new CompoundDealsPrepareAction(ExecutionType.ExecutionCurrency),
dealsPrepareFinal, new CompoundDealsPrepareAction(ExecutionType.ExecutionDeposit), dealsPrepareFinal, new CompoundDealsPrepareAction(ExecutionType.ExecutionDeposit))
dealsPrepareTRDT, new CompoundDealsPrepareAction(ExecutionType.ExecutionFond))
) )
.and() .and()
.withExternal() .withExternal()

1
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/DealsPrepareAction.java
View file

@ -116,6 +116,7 @@ public class DealsPrepareAction extends AbstractSessionActionForOkErrorHandling
executionCurrencyImdg.update((ExecutionCurrency) exc); executionCurrencyImdg.update((ExecutionCurrency) exc);
} }
} }
log.info("{} deals were prepared for a processing {}", excs.size(), executionType);
ctx.getExtendedState().getVariables().put(DataEnum.dealsPrepared, excs); ctx.getExtendedState().getVariables().put(DataEnum.dealsPrepared, excs);
} }

1
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/RequirementAndObligationCreationCompoundAction.java
View file

@ -48,6 +48,7 @@ public class RequirementAndObligationCreationCompoundAction extends RequirementA
int efs = executionFond.size(); int efs = executionFond.size();
int eds = executionDeposit.size(); int eds = executionDeposit.size();
int ecs = executionCurrency.size(); int ecs = executionCurrency.size();
log.info("executions: {} fond, {} deposit, {} currency", efs, eds, ecs);
int[] ief = {0}, ied = {0}, iec = {0}; int[] ief = {0}, ied = {0}, iec = {0};
while (ief[0] < efs || ied[0] < eds || iec[0] < ecs) { while (ief[0] < efs || ied[0] < eds || iec[0] < ecs) {