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

http://jira.mfd.msk:8088/browse/CLS-943

Browse source
This commit is contained in:
etreschenkov 2026-04-22 18:49:45 +03:00
parent 30cb352377
commit c75a4655c9
1 changed files with 1 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java
View file

@ -143,7 +143,7 @@ public class TaskListener extends QueueConsumer implements InitializingBean {
newReq.setObjectType(ObjectType.rgst.getKey()); newReq.setObjectType(ObjectType.rgst.getKey());
newReq.setPriority(Priority.HIGH.getKey()); newReq.setPriority(Priority.HIGH.getKey());
newReq.setComment(comment); newReq.setComment(comment);
kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, req.getRequestPayload()); kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, newReq);
log.info("SDOR export and send command to fix, request={}", req); log.info("SDOR export and send command to fix, request={}", req);
try { try {
@ -176,10 +176,6 @@ public class TaskListener extends QueueConsumer implements InitializingBean {
} }
if (diff.compareTo(BigDecimal.ZERO) < 0) { if (diff.compareTo(BigDecimal.ZERO) < 0) {
NotificationNewRequest request = new NotificationNewRequest();
request.setObjectType(ObjectType.rgst.getKey());
request.setPriority(Priority.HIGH.getKey());
return String.format("Для ТКР %s компании %s: баланс %s RUB;", return String.format("Для ТКР %s компании %s: баланс %s RUB;",
amtRegistry.getTradingClearingRegistry(), amtRegistry.getShortName(), amtRegistry.getTradingClearingRegistry(), amtRegistry.getShortName(),
diff.setScale(2, RoundingMode.HALF_UP)); diff.setScale(2, RoundingMode.HALF_UP));