From a4febcafb1b146143f9d215d30fd987e1ee2dd2d Mon Sep 17 00:00:00 2001 From: ialbert Date: Wed, 14 Aug 2024 12:23:25 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-732 sdf54 & DM*I hotfix --- .../payment/PaymentInstructionOutboundService.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/payment/PaymentInstructionOutboundService.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/payment/PaymentInstructionOutboundService.java index ee1e59243..422afad0c 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/payment/PaymentInstructionOutboundService.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/payment/PaymentInstructionOutboundService.java @@ -187,13 +187,6 @@ public class PaymentInstructionOutboundService { SDf54 sDf54 = sdf54Creator.create(pmt); sDf54.setId(idGenerator.nextId()); sDf54.setGenerationId(pmt.getId()); - sdf54Imdg.insert(sDf54); - log.debug("new sdf54.id: {}", sDf54.getId()); - dmiService.setProcComment(tcr.getId(), - curr, - safeBD(amount).negate(), - sDf54.getDocnm_ref()); - assetsMng.process(assets.get().a__b(), assets.get().a__t(), assets.get().a__f(), BigDecimal.ZERO); if (time.isTradingTime()) { Supplier builder = () -> GatewayRequestCreator.from(pmt, assets.get().a__b().getTradingCode(), @@ -213,6 +206,13 @@ public class PaymentInstructionOutboundService { return error(req.getId(), ClearingError.GeneralError); } } + sdf54Imdg.insert(sDf54); + log.debug("new sdf54.id: {}", sDf54.getId()); + dmiService.setProcComment(tcr.getId(), + curr, + safeBD(amount).negate(), + sDf54.getDocnm_ref()); + assetsMng.process(assets.get().a__b(), assets.get().a__t(), assets.get().a__f(), BigDecimal.ZERO); SdfClearingRequest exp = new SdfClearingRequest(); exp.setGroupId(sDf54.getGenerationId()); kafkaSender.sendRequestToQueue(Consts.SDF54_PROCESS, exp);