From 8c444e4e1cb542f09b20916a1adb24f22a46e60b Mon Sep 17 00:00:00 2001 From: ialbert Date: Wed, 31 Jul 2024 16:49:55 +0300 Subject: [PATCH] sessions InclusionObligations (step 4) disable execution updates for TRDT/CURR/UNIT/IPOT --- .../session/stage/impl/InclusionObligations.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/InclusionObligations.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/InclusionObligations.java index 337928b39..13006c37b 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/InclusionObligations.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/InclusionObligations.java @@ -135,6 +135,8 @@ public class InclusionObligations implements ISessionStage { Optional ssnType = obtainSessionType(sessionId); Map rgsToUpdate = new HashMap<>(); List execsToUpdate = new ArrayList<>(); + boolean loadExecs = !IEnumKey.contains(sessionType, + SessionType.TRDT, SessionType.CURR, SessionType.UNIT, SessionType.IPOT); for (Map.Entry> entrySet : registryByGroupId.entrySet()) { log.debug("Processing set of registry with groupId: {}", entrySet.getKey()); String rgsSection = null; @@ -148,10 +150,14 @@ public class InclusionObligations implements ISessionStage { rgsSection = registry.getSection(); } } - execsToUpdate.addAll(updateExecutions(sessionId, entrySet.getKey(), rgsSection)); + if (loadExecs) { + execsToUpdate.addAll(updateExecutions(sessionId, entrySet.getKey(), rgsSection)); + } } registryImdg.putAll(rgsToUpdate); - updateExecsBatchV2(execsToUpdate); + if (loadExecs) { + updateExecsBatchV2(execsToUpdate); + } return new StageResult(null, true); }