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

PAYM session start & continue

Browse source
This commit is contained in:
ialbert 2024-10-01 19:19:15 +03:00
parent 3b37d06e56
commit 0334d8fcdf
2 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -40,6 +40,7 @@ import ru.spcex.clearing.service.payment.PaymentInstructionOutboundService;
import ru.spcex.clearing.session.stage.CurrencySession; import ru.spcex.clearing.session.stage.CurrencySession;
import ru.spcex.clearing.session.stage.FinalMkrSession; import ru.spcex.clearing.session.stage.FinalMkrSession;
import ru.spcex.clearing.session.stage.IntermediateMkrSession; import ru.spcex.clearing.session.stage.IntermediateMkrSession;
import ru.spcex.clearing.session.stage.PaymSession;
import ru.spcex.clearing.session.stage.PrimaryAuctionB0Session; import ru.spcex.clearing.session.stage.PrimaryAuctionB0Session;
import ru.spcex.clearing.session.stage.PrimaryAuctionBnSession; import ru.spcex.clearing.session.stage.PrimaryAuctionBnSession;
import ru.spcex.clearing.session.stage.PrimaryAuctionT0Session; import ru.spcex.clearing.session.stage.PrimaryAuctionT0Session;
@ -69,6 +70,7 @@ public class EventsReceiver extends QueueConsumerV2 implements InitializingBean
private final PrimaryAuctionB0Session primaryAuctionB0Session; private final PrimaryAuctionB0Session primaryAuctionB0Session;
private final IntermediateMkrSession intermediateMkrSession; private final IntermediateMkrSession intermediateMkrSession;
private final FinalMkrSession finalMkrSession; private final FinalMkrSession finalMkrSession;
private final PaymSession paymSession;
private final UnitedSession unitedSession; private final UnitedSession unitedSession;
private final ReturnDepositSession returnDepositSession; private final ReturnDepositSession returnDepositSession;
private final SessionManager sessionManager; private final SessionManager sessionManager;
@ -91,7 +93,7 @@ public class EventsReceiver extends QueueConsumerV2 implements InitializingBean
PrimaryAuctionBnSession primaryAuctionBnSession, PrimaryAuctionBnSession primaryAuctionBnSession,
SecondaryAuctionT0Session secondaryAuctionT0Session, SecondaryAuctionT0Session secondaryAuctionT0Session,
CurrencySession currencySession, CurrencySession currencySession,
PrimaryAuctionB0Session primaryAuctionB0Session, PrimaryAuctionT0Session primaryAuctionT0Session, IntermediateMkrSession intermediateMkrSession, FinalMkrSession finalMkrSession, UnitedSession unitedSession, ReturnDepositSession returnDepositSession, SessionManager sessionManager, PrimaryAuctionB0Session primaryAuctionB0Session, PrimaryAuctionT0Session primaryAuctionT0Session, IntermediateMkrSession intermediateMkrSession, FinalMkrSession finalMkrSession, PaymSession paymSession, UnitedSession unitedSession, ReturnDepositSession returnDepositSession, SessionManager sessionManager,
Sdf06Executor sdf06Executor, Sdf06Executor sdf06Executor,
Sdf10Executor sdf10Executor, BalanceRevise balanceRevise, Sdf05Sender sdf05Sender, StatementServiceV2 statementService, SessionTerminator sessionTerminator, PaymentInstructionOutboundService pmtOutboundService, ExecutionCurrencyComponent execCurrUpload, ExecutionDepositComponent execDepUpload, ExecutionFondComponent execFondUpload) { Sdf10Executor sdf10Executor, BalanceRevise balanceRevise, Sdf05Sender sdf05Sender, StatementServiceV2 statementService, SessionTerminator sessionTerminator, PaymentInstructionOutboundService pmtOutboundService, ExecutionCurrencyComponent execCurrUpload, ExecutionDepositComponent execDepUpload, ExecutionFondComponent execFondUpload) {
super(kafkaQueue, kafkaResponseQueue); super(kafkaQueue, kafkaResponseQueue);
@ -106,6 +108,7 @@ public class EventsReceiver extends QueueConsumerV2 implements InitializingBean
this.primaryAuctionT0Session = primaryAuctionT0Session; this.primaryAuctionT0Session = primaryAuctionT0Session;
this.intermediateMkrSession = intermediateMkrSession; this.intermediateMkrSession = intermediateMkrSession;
this.finalMkrSession = finalMkrSession; this.finalMkrSession = finalMkrSession;
this.paymSession = paymSession;
this.unitedSession = unitedSession; this.unitedSession = unitedSession;
this.returnDepositSession = returnDepositSession; this.returnDepositSession = returnDepositSession;
this.sessionManager = sessionManager; this.sessionManager = sessionManager;
@ -170,6 +173,7 @@ public class EventsReceiver extends QueueConsumerV2 implements InitializingBean
finalMkrSession.continueSession(req); finalMkrSession.continueSession(req);
unitedSession.continueSession(req); unitedSession.continueSession(req);
returnDepositSession.continueSession(req); returnDepositSession.continueSession(req);
paymSession.continueSession(req);
}) })
.forDestination(Consts.CONTINUE_SESSION_BN_FIRST_PART, callbacks::put); .forDestination(Consts.CONTINUE_SESSION_BN_FIRST_PART, callbacks::put);

6
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SessionManager.java
View file

@ -38,6 +38,8 @@ public class SessionManager {
private final IntermediateMkrSession intermediateMkrSession; private final IntermediateMkrSession intermediateMkrSession;
private final FinalMkrSession finalMkrSession; private final FinalMkrSession finalMkrSession;
private final PrepSession prepSession; private final PrepSession prepSession;
private final PaymSession paymSession;
private final ReturnDepositSession returnDepositSession; private final ReturnDepositSession returnDepositSession;
private final UnitedSession unitedSession; private final UnitedSession unitedSession;
private final TradingTimeService time; private final TradingTimeService time;
@ -47,7 +49,7 @@ public class SessionManager {
PrimaryAuctionBnSession primaryAuctionBnSession, PrimaryAuctionBnSession primaryAuctionBnSession,
PrimaryAuctionB0Session primaryAuctionB0Session, PrimaryAuctionB0Session primaryAuctionB0Session,
SecondaryAuctionT0Session secondaryAuctionT0Session, CurrencySession currencySession, SecondaryAuctionT0Session secondaryAuctionT0Session, CurrencySession currencySession,
IntermediateMkrSession intermediateMkrSession, FinalMkrSession finalMkrSession, PrepSession prepSession, ReturnDepositSession returnDepositSession, UnitedSession unitedSession, TradingTimeService time) { IntermediateMkrSession intermediateMkrSession, FinalMkrSession finalMkrSession, PrepSession prepSession, PaymSession paymSession, ReturnDepositSession returnDepositSession, UnitedSession unitedSession, TradingTimeService time) {
this.notification = notification; this.notification = notification;
this.msgs = msgs; this.msgs = msgs;
this.primaryAuctionT0Session = primaryAuctionT0Session; this.primaryAuctionT0Session = primaryAuctionT0Session;
@ -58,6 +60,7 @@ public class SessionManager {
this.intermediateMkrSession = intermediateMkrSession; this.intermediateMkrSession = intermediateMkrSession;
this.finalMkrSession = finalMkrSession; this.finalMkrSession = finalMkrSession;
this.prepSession = prepSession; this.prepSession = prepSession;
this.paymSession = paymSession;
this.returnDepositSession = returnDepositSession; this.returnDepositSession = returnDepositSession;
sessionImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_Session, Session.class); sessionImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_Session, Session.class);
@ -122,6 +125,7 @@ public class SessionManager {
case MEDM -> session = intermediateMkrSession; case MEDM -> session = intermediateMkrSession;
case FINL -> session = finalMkrSession; case FINL -> session = finalMkrSession;
case PREP -> session = prepSession; case PREP -> session = prepSession;
case PAYM -> session = paymSession;
case XDEP -> session = returnDepositSession; case XDEP -> session = returnDepositSession;
case UNIT -> session = unitedSession; case UNIT -> session = unitedSession;
} }