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

GVER теперь запускает сверку

Browse source
This commit is contained in:
ialbert 2023-06-28 10:13:30 +03:00
parent 82cf75ac2d
commit cd35d5ba9c
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/EventsReceiver.java
View file

@ -73,9 +73,9 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
callback(LauncherCommandRequest.class) callback(LauncherCommandRequest.class)
.setConsumer(event -> clearingService.sdfCreate()) .setConsumer(event -> clearingService.sdfCreate())
.forDestination(Task.createOrder.topic(), callbacks::put); .forDestination(Task.createOrder.topic(), callbacks::put);
callback(LauncherCommandRequest.class) // callback(LauncherCommandRequest.class)
.setConsumer(event -> clearingService.executeVerification()) // .setConsumer(event -> clearingService.executeVerification())
.forDestination(Task.getVerification.topic(), callbacks::put); // .forDestination(Task.getVerification.topic(), callbacks::put);
callback(CommonIdRequest.class) callback(CommonIdRequest.class)
.setConsumer(clearingService::continueClearing) .setConsumer(clearingService::continueClearing)
.forDestination(Consts.CONTINUE_CLEARING, callbacks::put); .forDestination(Consts.CONTINUE_CLEARING, callbacks::put);
@ -119,6 +119,12 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
balanceRevise.submit(new ru.spcex.clearing.session.stage.Task<>(TaskType.StartRevise, null)); balanceRevise.submit(new ru.spcex.clearing.session.stage.Task<>(TaskType.StartRevise, null));
}) })
.forDestination(Task.getAllBalance.topic(), callbacks::put); .forDestination(Task.getAllBalance.topic(), callbacks::put);
callback(LauncherCommandRequest.class)
.setConsumer(task -> {
balanceRevise.submit(new ru.spcex.clearing.session.stage.Task<>(TaskType.StartRevise, null));
})
.forDestination(Task.getVerification.topic(), callbacks::put);
init(); init();
} }
} }