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);