diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf01Executor.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf01Executor.java index ecfa779f5..5e3636e0b 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf01Executor.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf01Executor.java @@ -168,7 +168,6 @@ public class Sdf01Executor extends AbstractExecutor { rgs.getDiffBalance()); reviseFailed = true; } - //2. отправить notification на backend stmt.setOperationStatus(OperationStatus.Executed.getKey()); statementImdg.update(stmt); } else { @@ -181,7 +180,7 @@ public class Sdf01Executor extends AbstractExecutor { NotificationNewRequest reviseNotification = new NotificationNewRequest(); reviseNotification.setObjectType(ObjectType.rgst.getKey()); reviseNotification.setComment(reviseFailed ? reviseFailedMessage : reviseSuccessMessage); - reviseNotification.setPriority(Priority.HIGH.getKey()); + reviseNotification.setPriority(reviseFailed ? Priority.HIGH.getKey() : Priority.LOW.getKey()); kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, reviseNotification); log.info("revise notification sent (revise {})", reviseFailed ? "error" : "success"); return result;