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

Secondary SecondaryAuctionT0Session session fix

Browse source
This commit is contained in:
ialbert 2023-05-30 11:59:21 +03:00
parent b29e6b7ab8
commit 6b34b26852
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SecondaryAuctionT0Session.java
View file

@ -86,6 +86,7 @@ public class SecondaryAuctionT0Session extends AbstractSession implements Initia
dealsPrepare.addExecutionFondCondition(execFondPb.in("market", marketCodes.get().toArray(new String[0]))); dealsPrepare.addExecutionFondCondition(execFondPb.in("market", marketCodes.get().toArray(new String[0])));
} }
@Override
public void runSession(BaseRequest<?> req) { public void runSession(BaseRequest<?> req) {
if (!startSession()) { if (!startSession()) {
return; return;
@ -146,15 +147,14 @@ public class SecondaryAuctionT0Session extends AbstractSession implements Initia
//stage 7 //stage 7
StageResult<Collection<PaymentInstruction>> paymentResult = runStage(TaskType.FormingPaymentInstruction, formingPaymentInstruction); StageResult<Collection<PaymentInstruction>> paymentResult = runStage(TaskType.FormingPaymentInstruction, formingPaymentInstruction);
if (paymentResult.getStageResult().isEmpty()) { if (paymentResult.getStageResult().isEmpty()) {
runStage(TaskType.ContinueRevise, balanceRevise); runStage(TaskType.FormingPaymentInstruction, balanceRevise);
finishPart(req); // finishPart(req);
} }
} catch (StageException e) { } catch (StageException e) {
//already logged //already logged
} }
} }
public void finishPart(BaseRequest<?> req) { public void finishPart(BaseRequest<?> req) {
try { try {
if (!checkStage(TaskType.FormingPaymentInstruction)) { if (!checkStage(TaskType.FormingPaymentInstruction)) {
@ -171,6 +171,7 @@ public class SecondaryAuctionT0Session extends AbstractSession implements Initia
{ {
EndStageNotificationPayload payload = new EndStageNotificationPayload(); EndStageNotificationPayload payload = new EndStageNotificationPayload();
payload.setSection(currSession.getSection()); payload.setSection(currSession.getSection());
payload.setSessionId(currSession.getId());
runStage(TaskType.EndStageNotification, payload, endStageNotification); runStage(TaskType.EndStageNotification, payload, endStageNotification);
} }
} catch (StageException e) { } catch (StageException e) {
@ -184,10 +185,12 @@ public class SecondaryAuctionT0Session extends AbstractSession implements Initia
log.info("already running session.id={}", this.currSession.getId()); log.info("already running session.id={}", this.currSession.getId());
return false; return false;
} else { } else {
TaskType startStatus = TaskType.StartRevise;
Session newSession = new Session(); Session newSession = new Session();
newSession.setSection(Section.FOND.getKey()); newSession.setSection(Section.FOND.getKey());
newSession.setSessionType(SessionType.TRDT.getKey()); newSession.setSessionType(SessionType.TRDT.getKey());
newSession.setSessionStatus(SessionStatus.CLRN.getKey()); newSession.setSessionStatus(startStatus.getKey());
newSession.setWorkflowStatus(SessionStatus.ACTV.getKey());
newSession.setClearingDate(LocalDate.now()); newSession.setClearingDate(LocalDate.now());
//todo companyId/securityId/userId передается из сообщения очереди //todo companyId/securityId/userId передается из сообщения очереди