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

http://jira.mfd.msk:8088/browse/CLS-290

Browse source
This commit is contained in:
etreschenkov 2023-05-29 19:01:49 +03:00
parent 3bf9d651cd
commit b3a5565dc0
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -124,7 +124,11 @@ public class InspectionObligations implements ISessionStage {
currentRegistry.getCompanyId()); currentRegistry.getCompanyId());
Registry counterRegistry = registryImdg.getSingleObjectBySQL(sqlCounterRegistryCondition); Registry counterRegistry = registryImdg.getSingleObjectBySQL(sqlCounterRegistryCondition);
if (counterRegistry == null) { if (counterRegistry == null) {
log.warn("Not found registry by params: {}", sqlCounterRegistryCondition); log.warn("Not found registry by params: {}; set not uncovered", sqlCounterRegistryCondition);
currentRegistry.setRegistryStatus("UNCV");
alreadyUpdatedToUncover.add(currentRegistry.getId());
insecurityGroups.add(currentRegistry.getGroupId());
registryImdg.update(currentRegistry);
continue; continue;
} }
if (currentRegistry.getBalance().compareTo(counterRegistry.getBalance()) > 0) { if (currentRegistry.getBalance().compareTo(counterRegistry.getBalance()) > 0) {
@ -144,6 +148,7 @@ public class InspectionObligations implements ISessionStage {
for (Long insecuritiesGroupId : insecurityGroups) { for (Long insecuritiesGroupId : insecurityGroups) {
for (Registry registry : registryByGroupIdAndCompanyId.get(insecuritiesGroupId)) { for (Registry registry : registryByGroupIdAndCompanyId.get(insecuritiesGroupId)) {
if (!alreadyUpdatedToUncover.contains(registry)) { if (!alreadyUpdatedToUncover.contains(registry)) {
log.warn("set fail for registry.id: {}", registry.getId());
registry.setRegistryStatus("FAIL"); registry.setRegistryStatus("FAIL");
registryImdg.update(registry); registryImdg.update(registry);
} }