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

EndStageNotificationAction bugfix

Browse source
This commit is contained in:
ialbert 2025-06-18 13:27:09 +03:00
parent ed7a15410d
commit 80c9870282
1 changed files with 3 additions and 3 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/state/action/EndStageNotificationAction.java
View file

@ -55,7 +55,7 @@ public class EndStageNotificationAction extends AbstractSessionActionForOkErrorH
@Override
protected void actualExecute(StateContext<TaskType, SsnEvent> ctx) {
Long sessionId = ctx.getExtendedState().get(DataEnum.sessionId, Long.class);
String section = ctx.getExtendedState().get(DataEnum.section, String.class);
Section section = ctx.getExtendedState().get(DataEnum.section, Section.class);
// 1. Изменить статус
Session theSession = sessionImdg.getSingleObjectByID(sessionId);
if (theSession == null) {
@ -79,9 +79,9 @@ public class EndStageNotificationAction extends AbstractSessionActionForOkErrorH
log.trace("For registry group {} send notification",
groupId);
Optional<EnumMessage> sResult;
if (Section.FOND.equalsByKey(section)) {
if (Section.FOND.equals(section)) {
sResult = notificationDF14(groupId);
} else if (Section.MKR.equalsByKey(section)) {
} else if (Section.MKR.equals(section)) {
sResult = notificationDF05(groupId);
} else {
throw new IllegalArgumentException("Unsupported section " + section);