From ef0a4a09c7bdf6530371b5d4e5ef56da6fce62df Mon Sep 17 00:00:00 2001 From: ialbert Date: Fri, 3 Feb 2023 17:09:14 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-189 --- .../src/main/java/ru/spcex/clearing/service/Clearing.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java index 179569ee6..6dff5866e 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java @@ -13,6 +13,7 @@ import ru.spcex.clearing.error.ClearingErrorInternal; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.platform.messaging.domain.Consts; import ru.spcex.clearing.platform.messaging.domain.cud.balance.AccountBalanceClearingRequest; +import ru.spcex.clearing.platform.messaging.domain.cud.schedule.LauncherCommandRequest; import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender; import ru.spcex.clearing.service.builder.LiabilitiesClaimsAssetsCreator; import ru.spcex.clearing.service.builder.LiabilitiesClaimsMoneyCreator; @@ -20,6 +21,7 @@ import ru.spcex.clearing.service.builder.PaymentInstructionCreator; import ru.spcex.clearing.service.order.ExecutionDepositSorter; import ru.spcex.platform.enumeration.Allowed; import ru.spcex.platform.enumeration.ClearingCategory; +import ru.spcex.platform.enumeration.Task; import ru.spcex.platform.imdg.api.Imdg; import ru.spcex.platform.imdg.api.ImdgId; import ru.spcex.platform.imdg.api.ImdgProvider; @@ -90,6 +92,8 @@ public class Clearing { processAllowedExecutionDeposit(category, companyExecDeposits); } }); + LauncherCommandRequest sdf03or11 = new LauncherCommandRequest(); + kafka.sendRequestToQueue(Task.createOrder.topic(), sdf03or11); } //кладем в порядке I инициатор, V внутренний, B банк (ответная категория) @@ -225,6 +229,9 @@ public class Clearing { paymentInstructionCreator.updateFieldLiabilitiesClaimsMoneyByPayment(firstLegLiabilitiesClaimsMoney, paymentInstructions, Collections.singleton(category)); liabilitiesClaimsMoneyImdg.update(firstLegLiabilitiesClaimsMoney); log.trace("LiabilitiesClaimsMoney first leg {} was updated", firstLegLiabilitiesClaimsMoney.getId()); + execDeposit.setSessionId(clearingSessionId); + execDeposit.setUpdated(Instant.now()); + executionDepositImdg.update(execDeposit); } }