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

clearing-service поправил приоритет нотификаций при сверке: HIGH если не сошлось, LOW если ок

Browse source
This commit is contained in:
ialbert 2023-06-29 11:14:46 +03:00
parent 8004353f37
commit 55fa772b52
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf01Executor.java
View file

@ -168,7 +168,6 @@ public class Sdf01Executor extends AbstractExecutor<SDf01> {
rgs.getDiffBalance()); rgs.getDiffBalance());
reviseFailed = true; reviseFailed = true;
} }
//2. отправить notification на backend
stmt.setOperationStatus(OperationStatus.Executed.getKey()); stmt.setOperationStatus(OperationStatus.Executed.getKey());
statementImdg.update(stmt); statementImdg.update(stmt);
} else { } else {
@ -181,7 +180,7 @@ public class Sdf01Executor extends AbstractExecutor<SDf01> {
NotificationNewRequest reviseNotification = new NotificationNewRequest(); NotificationNewRequest reviseNotification = new NotificationNewRequest();
reviseNotification.setObjectType(ObjectType.rgst.getKey()); reviseNotification.setObjectType(ObjectType.rgst.getKey());
reviseNotification.setComment(reviseFailed ? reviseFailedMessage : reviseSuccessMessage); 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); kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, reviseNotification);
log.info("revise notification sent (revise {})", reviseFailed ? "error" : "success"); log.info("revise notification sent (revise {})", reviseFailed ? "error" : "success");
return result; return result;