From 3eff12f684db35093d7b68e2e4ff4df653caac2c Mon Sep 17 00:00:00 2001 From: etreschenkov Date: Mon, 14 Jul 2025 12:53:39 +0300 Subject: [PATCH] pause after step 5 --- .../action/PauseWorkflowStatusWithNotificationAction.java | 8 ++++---- .../java/ru/spcex/platform/enumeration/ObjectType.java | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/PauseWorkflowStatusWithNotificationAction.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/PauseWorkflowStatusWithNotificationAction.java index 8029606a3..1240636e9 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/PauseWorkflowStatusWithNotificationAction.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/PauseWorkflowStatusWithNotificationAction.java @@ -35,7 +35,7 @@ public class PauseWorkflowStatusWithNotificationAction extends UpdateWorkflowSta .map(rgsWr -> "ТКР %s: %s".formatted(rgsWr.getRgs().getTradingClearingRegistry(), rgsWr.getErr())) .collect(Collectors.joining(";\r\n", notificationPrefix(ctx), "")); Long ssnId = ctx.getExtendedState().get(DataEnum.sessionId, Long.class); - notificationSender.sendNotification(ObjectType.session, comment, Priority.HIGH, ssnId); + notificationSender.sendNotification(ObjectType.session_pause, comment, Priority.HIGH, ssnId); ctx.getExtendedState().getVariables().remove(DataEnum.erroneousRegistries); } @@ -48,9 +48,9 @@ public class PauseWorkflowStatusWithNotificationAction extends UpdateWorkflowSta case PSEUDO_waitAfterObligationAdmissionError -> { return "Ряд обязательств не допущены к клирингу!!!\r\n"; } -// case PSEUDO_waitAfterInspectionError -> { -// return "Ряд обязательств подлежит исключению из клирингового пула!!!\r\n"; -// } + case PSEUDO_waitAfterInspectionError -> { + return "Ряд обязательств подлежит исключению из клирингового пула!!!\r\n"; + } default -> { return "Ошибка клиринговой сессии\r\n"; } diff --git a/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/ObjectType.java b/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/ObjectType.java index 05e64e121..ca85d0abe 100644 --- a/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/ObjectType.java +++ b/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/ObjectType.java @@ -4,7 +4,7 @@ import ru.spcex.platform.utils.enumeration.IEnumKey; public enum ObjectType implements IEnumKey { statement("STMT"), vfrs("VFRS"), rgst("RGST"), gateway("GTWY"), session("SESN"), - account_block("ACCB"), account_active("ACCA"), diff("DIFF"); + session_pause("SESS"), account_block("ACCB"), account_active("ACCA"), diff("DIFF"); private final String key;