From 33e75e6e8163bdf3704277baf208e9c9fbd82b21 Mon Sep 17 00:00:00 2001 From: ialbert Date: Tue, 8 Aug 2023 12:59:55 +0300 Subject: [PATCH] sdf07 groupId bug --- .../spcex/clearing/service/executors/Sdf06Executor.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf06Executor.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf06Executor.java index 5c0f3368b..d3ea715f4 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf06Executor.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf06Executor.java @@ -156,7 +156,7 @@ public class Sdf06Executor { statementImdg.insert(stmt); log.debug("Statement created: {}", stmt.getId()); if (InOutDirection.in.getKey().equals(stmt.getInOutDirection())) { - processedApproved(stmt, sDf06, now); + processedApproved(stmt, sDf06, now, sdf07GroupId); sdf07WasCreated = true; } else { requests.add(requestFromStatement(stmt, company.getTradingCode(), tcr.getCode())); @@ -174,12 +174,16 @@ public class Sdf06Executor { } private void processedApproved(Statement stmt, SDf06 sDf06, Instant time) { + processedApproved(stmt, sDf06, time, sdf07GroupId); + } + + private void processedApproved(Statement stmt, SDf06 sDf06, Instant time, Long sdf07GenerationId) { log.trace("statement.id={}, sdf07.id={}, sdf06.id={} executed", stmt.getId(), sDf06.getGenerationId(), sDf06.getId()); SDf07 sdf07 = createSdf07(sDf06, time, successResult); - sdf07.setGenerationId(sdf07GroupId); + sdf07.setGenerationId(sdf07GenerationId); sdf07Imdg.insert(sdf07); stmt.setOperationStatus(OperationStatus.Executed.getKey()); stmt.setUpdated(time);