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

инициирование сверки SDF56 по команде от scheduler-service

Browse source
This commit is contained in:
ialbert 2023-06-23 15:48:35 +03:00
parent 168d54a040
commit 2acf7a1e24
1 changed files with 11 additions and 1 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

@ -17,6 +17,7 @@ import ru.spcex.clearing.platform.messaging.domain.cud.utilities.STradesImported
import ru.spcex.clearing.platform.messaging.service.QueueConsumer; import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
import ru.spcex.clearing.service.executors.Sdf06Executor; import ru.spcex.clearing.service.executors.Sdf06Executor;
import ru.spcex.clearing.session.stage.*; import ru.spcex.clearing.session.stage.*;
import ru.spcex.clearing.session.stage.impl.BalanceRevise;
import ru.spcex.platform.enumeration.Task; import ru.spcex.platform.enumeration.Task;
import static ru.spcex.clearing.platform.messaging.domain.Consts.S_TRADES_IMPORTED; import static ru.spcex.clearing.platform.messaging.domain.Consts.S_TRADES_IMPORTED;
@ -35,6 +36,7 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
private final ReturnDepositSession returnDepositSession; private final ReturnDepositSession returnDepositSession;
private final SessionManager sessionManager; private final SessionManager sessionManager;
private final Sdf06Executor sdf06Executor; private final Sdf06Executor sdf06Executor;
private final BalanceRevise balanceRevise;
@Autowired @Autowired
public EventsReceiver(Consumer<String, Object> kafkaQueue, public EventsReceiver(Consumer<String, Object> kafkaQueue,
@ -43,7 +45,8 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
PrimaryAuctionBnSession primaryAuctionBnSession, PrimaryAuctionBnSession primaryAuctionBnSession,
SecondaryAuctionT0Session secondaryAuctionT0Session, SecondaryAuctionT0Session secondaryAuctionT0Session,
PrimaryAuctionB0Session primaryAuctionB0Session, PrimaryAuctionT0Session primaryAuctionT0Session, IntermediateMkrSession intermediateMkrSession, FinalMkrSession finalMkrSession, ReturnDepositSession returnDepositSession, SessionManager sessionManager, PrimaryAuctionB0Session primaryAuctionB0Session, PrimaryAuctionT0Session primaryAuctionT0Session, IntermediateMkrSession intermediateMkrSession, FinalMkrSession finalMkrSession, ReturnDepositSession returnDepositSession, SessionManager sessionManager,
Sdf06Executor sdf06Executor) { Sdf06Executor sdf06Executor,
BalanceRevise balanceRevise) {
super(kafkaQueue); super(kafkaQueue);
this.clearingService = clearingService; this.clearingService = clearingService;
this.registryService = registryService; this.registryService = registryService;
@ -56,6 +59,7 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
this.returnDepositSession = returnDepositSession; this.returnDepositSession = returnDepositSession;
this.sessionManager = sessionManager; this.sessionManager = sessionManager;
this.sdf06Executor = sdf06Executor; this.sdf06Executor = sdf06Executor;
this.balanceRevise = balanceRevise;
} }
@Override @Override
@ -109,6 +113,12 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
callback(LauncherCommandRequest.class) callback(LauncherCommandRequest.class)
.setConsumer(event -> registryService.resetBalances()) .setConsumer(event -> registryService.resetBalances())
.forDestination(Task.createRegistry_GRYT.topic(), callbacks::put); .forDestination(Task.createRegistry_GRYT.topic(), callbacks::put);
callback(LauncherCommandRequest.class)
.setConsumer(task -> {
balanceRevise.submit(new ru.spcex.clearing.session.stage.Task<>(TaskType.StartRevise, null));
})
.forDestination(Task.getAllBalance.topic(), callbacks::put);
init(); init();
} }
} }