From 3c252ca3f6c09234f2a42cde7d3c176662d4cef6 Mon Sep 17 00:00:00 2001 From: ialbert Date: Sat, 27 May 2023 15:08:43 +0300 Subject: [PATCH] SecondaryT0 stage 7 --- .../clearing/session/stage/SecondaryAuctionT0Session.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SecondaryAuctionT0Session.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SecondaryAuctionT0Session.java index 7ae83e1c7..78bfbf5f3 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SecondaryAuctionT0Session.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SecondaryAuctionT0Session.java @@ -8,6 +8,7 @@ import org.springframework.stereotype.Service; import ru.clearing.classes.statics.data.execution.ExecutionCommon; import ru.clearing.classes.statics.data.execution.ExecutionFond; import ru.clearing.classes.statics.data.misc.Session; +import ru.clearing.classes.statics.data.payment.PaymentInstruction; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.platform.messaging.domain.BaseRequest; import ru.spcex.clearing.session.stage.impl.*; @@ -22,6 +23,7 @@ import ru.spcex.platform.imdg.api.predicate.ImdgPredicateBuilder; import ru.spcex.platform.utils.enumeration.IMessageResolver; import java.time.LocalDate; +import java.util.Collection; import java.util.List; import java.util.function.Supplier; @@ -144,7 +146,11 @@ public class SecondaryAuctionT0Session extends AbstractSession implements Initia //stage 6 runStage(TaskType.FormingRegistersOnOS, formingRegistersOnOS); //returns Collection //stage 7 - runStage(TaskType.FormingPaymentInstruction, formingPaymentInstruction); + StageResult> paymentResult = runStage(TaskType.FormingPaymentInstruction, formingPaymentInstruction); + if (paymentResult.getStageResult().isEmpty()) { + runStage(TaskType.ContinueRevise, balanceRevise); + finishPart(req); + } } catch (StageException e) { //already logged }