http://jira.mfd.msk:8088/browse/CLS-894 ObligationAdmission <-> InclusionToPool

This commit is contained in:
ialbert 2025-08-07 18:33:26 +03:00
parent fc77ea4247
commit 31de6ed6dc
8 changed files with 65 additions and 64 deletions

View file

@ -173,12 +173,13 @@ public class CurrencySessionStateMachineConfig extends EnumStateMachineConfigure
.action(reqAndOblAction) .action(reqAndOblAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.RequirementsAndObligationsCreate).target(TaskType.ObligationsAdmission) .source(TaskType.RequirementsAndObligationsCreate).target(TaskType.InclusionToPool)
.action(obligationAdmissionAction) .action(inclusionToPoolAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.InclusionToPool).target(TaskType.InspectionObligations) .source(TaskType.InclusionToPool)
.action(inspectionObligationsV2Action); .target(TaskType.ObligationsAdmission)
.action(obligationAdmissionAction);
sourceObligationAdmission(transitions); sourceObligationAdmission(transitions);
sourcePseudoAfterOAPause(transitions); sourcePseudoAfterOAPause(transitions);
@ -214,17 +215,17 @@ public class CurrencySessionStateMachineConfig extends EnumStateMachineConfigure
.action(pauseWsAction) .action(pauseWsAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.ObligationsAdmission).target(TaskType.InclusionToPool) .source(TaskType.ObligationsAdmission).target(TaskType.InspectionObligations)
.guard(invert(oblAdmGuard)) .guard(invert(oblAdmGuard))
.action(chain(obligationAdmissionContinueAction, inclusionToPoolAction)); .action(chain(obligationAdmissionContinueAction, inspectionObligationsV2Action));
} }
private void sourcePseudoAfterOAPause(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception { private void sourcePseudoAfterOAPause(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception {
transitions transitions
//continue and repeat after ObligationAdmission //continue and repeat after ObligationAdmission
.withExternal() .withExternal()
.source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InclusionToPool) .source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InspectionObligations)
.action(chain(activeWsAction, obligationAdmissionContinueAction, inclusionToPoolAction)) .action(chain(activeWsAction, obligationAdmissionContinueAction, inspectionObligationsV2Action))
.event(SsnEvent.CONTINUE); .event(SsnEvent.CONTINUE);
for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) { for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) {
transitions transitions

View file

@ -191,13 +191,13 @@ public class FinalSessionStateMachineConfig
.action(reqAndOblAction) .action(reqAndOblAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.RequirementsAndObligationsCreate).target(TaskType.ObligationsAdmission) .source(TaskType.RequirementsAndObligationsCreate).target(TaskType.InclusionToPool)
.action(obligationAdmissionAction) .action(inclusionToPoolAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.InclusionToPool).target(TaskType.InspectionObligationDepositReturn) .source(TaskType.InclusionToPool).target(TaskType.ObligationsAdmission)
//нужно сменить статус ручками, т.к. псевдо состояние //нужно сменить статус ручками, т.к. псевдо состояние
.action(inspOblDepositReturnAction); .action(obligationAdmissionAction);
sourceObligationAdmission(transitions); sourceObligationAdmission(transitions);
sourcePseudoAfterOAPause(transitions); sourcePseudoAfterOAPause(transitions);
@ -218,9 +218,9 @@ public class FinalSessionStateMachineConfig
.action(pauseWsAction) .action(pauseWsAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.ObligationsAdmission).target(TaskType.InclusionToPool) .source(TaskType.ObligationsAdmission).target(TaskType.InspectionObligationDepositReturn)
.guard(invert(oblAdmGuard)) .guard(invert(oblAdmGuard))
.action(chain(obligationAdmissionContinueAction, inclusionToPoolAction)); .action(chain(obligationAdmissionContinueAction, inspOblDepositReturnAction));
} }
private void sourceIODepositReturn(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception { private void sourceIODepositReturn(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception {
@ -296,8 +296,8 @@ public class FinalSessionStateMachineConfig
private void sourcePseudoAfterOAPause(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception { private void sourcePseudoAfterOAPause(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception {
transitions transitions
.withExternal() .withExternal()
.source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InclusionToPool) .source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InspectionObligationDepositReturn)
.action(chain(activeWsAction, obligationAdmissionContinueAction, inclusionToPoolAction)) .action(chain(activeWsAction, obligationAdmissionContinueAction, inspOblDepositReturnAction))
.event(SsnEvent.CONTINUE); .event(SsnEvent.CONTINUE);
for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) { for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) {
transitions transitions

View file

@ -180,12 +180,12 @@ public class IntermediateMkrSessionStateMachineConfig
.action(reqAndOblAction) .action(reqAndOblAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.RequirementsAndObligationsCreate).target(TaskType.ObligationsAdmission) .source(TaskType.RequirementsAndObligationsCreate).target(TaskType.InclusionToPool)
.action(obligationAdmissionAction) .action(inclusionToPoolAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.InclusionToPool).target(TaskType.InspectionObligations) .source(TaskType.InclusionToPool).target(TaskType.ObligationsAdmission)
.action(inspectionObligationsV2Action); .action(obligationAdmissionAction);
sourceObligationAdmission(transitions); sourceObligationAdmission(transitions);
sourcePseudoAfterOAPause(transitions); sourcePseudoAfterOAPause(transitions);
@ -213,17 +213,17 @@ public class IntermediateMkrSessionStateMachineConfig
.action(pauseWsAction) .action(pauseWsAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.ObligationsAdmission).target(TaskType.InclusionToPool) .source(TaskType.ObligationsAdmission).target(TaskType.InspectionObligations)
.guard(invert(oblAdmGuard)) .guard(invert(oblAdmGuard))
.action(chain(obligationAdmissionContinueAction, inclusionToPoolAction)); .action(chain(obligationAdmissionContinueAction, inspectionObligationsV2Action));
} }
private void sourcePseudoAfterOAPause(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception { private void sourcePseudoAfterOAPause(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception {
transitions transitions
//continue and repeat after ObligationAdmission //continue and repeat after ObligationAdmission
.withExternal() .withExternal()
.source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InclusionToPool) .source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InspectionObligations)
.action(chain(activeWsAction, obligationAdmissionContinueAction, inclusionToPoolAction)) .action(chain(activeWsAction, obligationAdmissionContinueAction, inspectionObligationsV2Action))
.event(SsnEvent.CONTINUE); .event(SsnEvent.CONTINUE);
for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) { for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) {
transitions transitions

View file

@ -182,12 +182,12 @@ public class PrimaryAuctionB0SessionStateMachineConfig
.action(reqAndOblAction) .action(reqAndOblAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.RequirementsAndObligationsCreate).target(TaskType.ObligationsAdmission) .source(TaskType.RequirementsAndObligationsCreate).target(TaskType.InclusionToPool)
.action(obligationAdmissionAction) .action(inclusionToPoolAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.InclusionToPool).target(TaskType.InspectionObligations) .source(TaskType.InclusionToPool).target(TaskType.ObligationsAdmission)
.action(inspectionObligationsV2Action); .action(obligationAdmissionAction);
sourceObligationAdmission(transitions); sourceObligationAdmission(transitions);
sourcePseudoAfterOAPause(transitions); sourcePseudoAfterOAPause(transitions);
sourcePseudoAfterIOPause(transitions); sourcePseudoAfterIOPause(transitions);
@ -207,9 +207,9 @@ public class PrimaryAuctionB0SessionStateMachineConfig
.action(pauseWsAction) .action(pauseWsAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.ObligationsAdmission).target(TaskType.InclusionToPool) .source(TaskType.ObligationsAdmission).target(TaskType.InspectionObligations)
.guard(invert(oblAdmGuard)) .guard(invert(oblAdmGuard))
.action(chain(obligationAdmissionContinueAction, inclusionToPoolAction)); .action(chain(obligationAdmissionContinueAction, inspectionObligationsV2Action));
} }
private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception { private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception {
@ -232,8 +232,8 @@ public class PrimaryAuctionB0SessionStateMachineConfig
transitions transitions
//continue and repeat after ObligationAdmission //continue and repeat after ObligationAdmission
.withExternal() .withExternal()
.source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InclusionToPool) .source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InspectionObligations)
.action(chain(activeWsAction, obligationAdmissionContinueAction, inclusionToPoolAction)) .action(chain(activeWsAction, obligationAdmissionContinueAction, inspectionObligationsV2Action))
.event(SsnEvent.CONTINUE); .event(SsnEvent.CONTINUE);
for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) { for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) {
transitions transitions

View file

@ -176,12 +176,12 @@ public class PrimaryAuctionBnSessionStateMachineConfig
.action(reqAndOblAction) .action(reqAndOblAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.RequirementsAndObligationsCreate).target(TaskType.ObligationsAdmission) .source(TaskType.RequirementsAndObligationsCreate).target(TaskType.InclusionToPool)
.action(obligationAdmissionAction) .action(inclusionToPoolAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.InclusionToPool).target(TaskType.InspectionObligations) .source(TaskType.InclusionToPool).target(TaskType.ObligationsAdmission)
.action(inspectionObligationsV2Action); .action(obligationAdmissionAction);
sourceObligationAdmission(transitions); sourceObligationAdmission(transitions);
sourcePseudoAfterOAPause(transitions); sourcePseudoAfterOAPause(transitions);
@ -200,9 +200,9 @@ public class PrimaryAuctionBnSessionStateMachineConfig
.action(pauseWsAction) .action(pauseWsAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.ObligationsAdmission).target(TaskType.InclusionToPool) .source(TaskType.ObligationsAdmission).target(TaskType.InspectionObligations)
.guard(invert(oblAdmGuard)) .guard(invert(oblAdmGuard))
.action(chain(obligationAdmissionContinueAction, inclusionToPoolAction)); .action(chain(obligationAdmissionContinueAction, inspectionObligationsV2Action));
} }
private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception { private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception {
@ -224,8 +224,8 @@ public class PrimaryAuctionBnSessionStateMachineConfig
transitions transitions
//continue and repeat after ObligationAdmission //continue and repeat after ObligationAdmission
.withExternal() .withExternal()
.source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InclusionToPool) .source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InspectionObligations)
.action(chain(activeWsAction, obligationAdmissionContinueAction, inclusionToPoolAction)) .action(chain(activeWsAction, obligationAdmissionContinueAction, inspectionObligationsV2Action))
.event(SsnEvent.CONTINUE); .event(SsnEvent.CONTINUE);
for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) { for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) {
transitions transitions

View file

@ -183,12 +183,12 @@ public class PrimaryAuctionT0SessionStateMachineConfig
.action(reqAndOblAction) .action(reqAndOblAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.RequirementsAndObligationsCreate).target(TaskType.ObligationsAdmission) .source(TaskType.RequirementsAndObligationsCreate).target(TaskType.InclusionToPool)
.action(obligationAdmissionAction) .action(inclusionToPoolAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.InclusionToPool).target(TaskType.InspectionObligations) .source(TaskType.InclusionToPool).target(TaskType.ObligationsAdmission)
.action(inspectionObligationsV2Action); .action(obligationAdmissionAction);
sourceObligationAdmission(transitions); sourceObligationAdmission(transitions);
sourcePseudoAfterOAPause(transitions); sourcePseudoAfterOAPause(transitions);
@ -209,9 +209,9 @@ public class PrimaryAuctionT0SessionStateMachineConfig
.action(pauseWsAction) .action(pauseWsAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.ObligationsAdmission).target(TaskType.InclusionToPool) .source(TaskType.ObligationsAdmission).target(TaskType.InspectionObligations)
.guard(invert(oblAdmGuard)) .guard(invert(oblAdmGuard))
.action(chain(obligationAdmissionContinueAction, inclusionToPoolAction)); .action(chain(obligationAdmissionContinueAction, inspectionObligationsV2Action));
} }
private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception { private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception {
@ -233,8 +233,8 @@ public class PrimaryAuctionT0SessionStateMachineConfig
transitions transitions
//continue and repeat after ObligationAdmission //continue and repeat after ObligationAdmission
.withExternal() .withExternal()
.source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InclusionToPool) .source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InspectionObligations)
.action(chain(activeWsAction, obligationAdmissionContinueAction, inclusionToPoolAction)) .action(chain(activeWsAction, obligationAdmissionContinueAction, inspectionObligationsV2Action))
.event(SsnEvent.CONTINUE); .event(SsnEvent.CONTINUE);
for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) { for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) {
transitions transitions

View file

@ -183,12 +183,12 @@ public class SecondaryAuctionT0SessionStateMachineConfig
.action(reqAndOblAction) .action(reqAndOblAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.RequirementsAndObligationsCreate).target(TaskType.ObligationsAdmission) .source(TaskType.RequirementsAndObligationsCreate).target(TaskType.InclusionToPool)
.action(obligationAdmissionAction) .action(inclusionToPoolAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.InclusionToPool).target(TaskType.InspectionObligations) .source(TaskType.InclusionToPool).target(TaskType.ObligationsAdmission)
.action(inspectionObligationsV2Action); .action(obligationAdmissionAction);
sourceObligationAdmission(transitions); sourceObligationAdmission(transitions);
sourcePseudoAfterOAPause(transitions); sourcePseudoAfterOAPause(transitions);
@ -209,9 +209,9 @@ public class SecondaryAuctionT0SessionStateMachineConfig
.action(pauseWsAction) .action(pauseWsAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.ObligationsAdmission).target(TaskType.InclusionToPool) .source(TaskType.ObligationsAdmission).target(TaskType.InspectionObligations)
.guard(invert(oblAdmGuard)) .guard(invert(oblAdmGuard))
.action(chain(obligationAdmissionContinueAction, inclusionToPoolAction)); .action(chain(obligationAdmissionContinueAction, inspectionObligationsV2Action));
} }
private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception { private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception {
@ -233,8 +233,8 @@ public class SecondaryAuctionT0SessionStateMachineConfig
transitions transitions
//continue and repeat after ObligationAdmission //continue and repeat after ObligationAdmission
.withExternal() .withExternal()
.source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InclusionToPool) .source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InspectionObligations)
.action(chain(activeWsAction, obligationAdmissionContinueAction, inclusionToPoolAction)) .action(chain(activeWsAction, obligationAdmissionContinueAction, inspectionObligationsV2Action))
.event(SsnEvent.CONTINUE); .event(SsnEvent.CONTINUE);
for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) { for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) {
transitions.withExternal() transitions.withExternal()

View file

@ -198,12 +198,12 @@ public class UnitedSessionStateMachineConfig
.action(reqAndOblAction) .action(reqAndOblAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.RequirementsAndObligationsCreate).target(TaskType.ObligationsAdmission) .source(TaskType.RequirementsAndObligationsCreate).target(TaskType.InclusionToPool)
.action(obligationAdmissionAction) .action(inclusionToPoolAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.InclusionToPool).target(TaskType.InspectionObligations) .source(TaskType.InclusionToPool).target(TaskType.ObligationsAdmission)
.action(inspectionObligationsV2Action); .action(obligationAdmissionAction);
sourceObligationAdmission(transitions); sourceObligationAdmission(transitions);
sourcePseudoAfterOAPause(transitions); sourcePseudoAfterOAPause(transitions);
sourcePseudoAfterIOPause(transitions); sourcePseudoAfterIOPause(transitions);
@ -240,9 +240,9 @@ public class UnitedSessionStateMachineConfig
.action(pauseWsAction) .action(pauseWsAction)
.and() .and()
.withExternal() .withExternal()
.source(TaskType.ObligationsAdmission).target(TaskType.InclusionToPool) .source(TaskType.ObligationsAdmission).target(TaskType.InspectionObligations)
.guard(invert(oblAdmGuard)) .guard(invert(oblAdmGuard))
.action(chain(obligationAdmissionContinueAction, inclusionToPoolAction)); .action(chain(obligationAdmissionContinueAction, inspectionObligationsV2Action));
} }
private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception { private void sourceInspection(StateMachineTransitionConfigurer<TaskType, SsnEvent> transitions) throws Exception {
@ -264,8 +264,8 @@ public class UnitedSessionStateMachineConfig
transitions transitions
//continue and repeat after ObligationAdmission //continue and repeat after ObligationAdmission
.withExternal() .withExternal()
.source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InclusionToPool) .source(TaskType.PSEUDO_waitAfterObligationAdmissionError).target(TaskType.InspectionObligations)
.action(chain(activeWsAction, obligationAdmissionContinueAction, inclusionToPoolAction)) .action(chain(activeWsAction, obligationAdmissionContinueAction, inspectionObligationsV2Action))
.event(SsnEvent.CONTINUE); .event(SsnEvent.CONTINUE);
for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) { for (var taskType : List.of(TaskType.PSEUDO_waitAfterObligationAdmissionError, TaskType.PSEUDO_waitAfterObligationAdmissionRestore)) {
transitions transitions