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

Merge branch 'dev' into dev_restore-state-machine

Browse source
This commit is contained in:
ialbert 2025-07-30 11:24:11 +03:00
commit a81d4b2f0a
2 changed files with 47 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -7,6 +7,7 @@ public enum SsnEvent {
SDF_13,
SDF_08,
SDF_21,
ALL_SDF_RECEIVED,
PAUSE,
CONTINUE,
REPEAT

46
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/SdfReceivedActionV2.java Normal file
View file

@ -0,0 +1,46 @@
package ru.spcex.clearing.session.state.action;
import java.util.EnumSet;
import java.util.function.Function;
import java.util.stream.Collectors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.statemachine.ExtendedState;
import org.springframework.statemachine.StateContext;
import org.springframework.statemachine.action.Action;
import ru.spcex.clearing.session.state.SsnEvent;
public class SdfReceivedActionV2<S> implements Action<S, SsnEvent> {
private final Logger log = LoggerFactory.getLogger(getClass());
private final EnumSet<SsnEvent> sdfs;
public SdfReceivedActionV2(EnumSet<SsnEvent> sdfs) {
this.sdfs = sdfs;
}
@Override
public void execute(StateContext<S, SsnEvent> ctx) {
ExtendedState state = ctx.getExtendedState();
log.info("event {} flag saving received", ctx.getEvent().name());
state.getVariables().put(ctx.getEvent().name(), true);
Function<SsnEvent, Boolean> was = sdf -> state.get(sdf.name(), Object.class) != null;
boolean everySdfConditionMet = sdfs
.stream()
.allMatch(was::apply);
if (everySdfConditionMet) {
log.info("all of {} conditions were met", sdfs);
sdfs.forEach(sdf -> state.getVariables().remove(sdf.name()));
ctx.getStateMachine().sendEvent(SsnEvent.ALL_SDF_RECEIVED);
} else {
log.info("conditions: {}",
sdfs
.stream()
.map(sdf -> "%s: %s".formatted(sdf.name(), was.apply(sdf) ? "received" : "waiting"))
.collect(Collectors.joining(";", "[", "]"))
);
}
}
}