treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

sessions InclusionObligations (step 4) disable execution updates for TRDT/CURR/UNIT/IPOT

Browse source
This commit is contained in:
ialbert 2024-07-31 16:49:55 +03:00
parent 9a51aa5558
commit 8c444e4e1c
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/InclusionObligations.java
View file

@ -135,6 +135,8 @@ public class InclusionObligations implements ISessionStage {
Optional<SessionType> ssnType = obtainSessionType(sessionId); Optional<SessionType> ssnType = obtainSessionType(sessionId);
Map<Long, Registry> rgsToUpdate = new HashMap<>(); Map<Long, Registry> rgsToUpdate = new HashMap<>();
List<ExecutionCommon> execsToUpdate = new ArrayList<>(); List<ExecutionCommon> execsToUpdate = new ArrayList<>();
boolean loadExecs = !IEnumKey.contains(sessionType,
SessionType.TRDT, SessionType.CURR, SessionType.UNIT, SessionType.IPOT);
for (Map.Entry<Long, List<Registry>> entrySet : registryByGroupId.entrySet()) { for (Map.Entry<Long, List<Registry>> entrySet : registryByGroupId.entrySet()) {
log.debug("Processing set of registry with groupId: {}", entrySet.getKey()); log.debug("Processing set of registry with groupId: {}", entrySet.getKey());
String rgsSection = null; String rgsSection = null;
@ -148,10 +150,14 @@ public class InclusionObligations implements ISessionStage {
rgsSection = registry.getSection(); rgsSection = registry.getSection();
} }
} }
execsToUpdate.addAll(updateExecutions(sessionId, entrySet.getKey(), rgsSection)); if (loadExecs) {
execsToUpdate.addAll(updateExecutions(sessionId, entrySet.getKey(), rgsSection));
}
} }
registryImdg.putAll(rgsToUpdate); registryImdg.putAll(rgsToUpdate);
updateExecsBatchV2(execsToUpdate); if (loadExecs) {
updateExecsBatchV2(execsToUpdate);
}
return new StageResult(null, true); return new StageResult(null, true);
} }