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

fix creation registry by sdf01

Browse source
This commit is contained in:
etreshenkov 2023-05-30 15:05:52 +03:00
parent 1710d25188
commit c5d74bd318
2 changed files with 5 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf01Executor.java
View file

@ -264,7 +264,8 @@ public class Sdf01Executor extends AbstractExecutor<SDf01> {
rgs.setRegistryUnit(RegistryUnit.T.getKey()); rgs.setRegistryUnit(RegistryUnit.T.getKey());
rgs.setRegistryCode(RegistryUtil.clearingCode(rgs)); rgs.setRegistryCode(RegistryUtil.clearingCode(rgs));
Collection<TradingClearingRegistry> tcrsByAccount = tradingClearingRegistryImdg.getCollectionObjectsByFieldValues(Map.of( Collection<TradingClearingRegistry> tcrsByAccount = tradingClearingRegistryImdg.getCollectionObjectsByFieldValues(Map.of(
"moneyAccountId", statement.getAccountId() "moneyAccountId", statement.getAccountId(),
"companyId", company.getId()
)); ));
if (!tcrsByAccount.isEmpty()) { if (!tcrsByAccount.isEmpty()) {
TradingClearingRegistry tcr = tcrsByAccount.iterator().next(); TradingClearingRegistry tcr = tcrsByAccount.iterator().next();

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

@ -102,11 +102,9 @@ public class InspectionObligations implements ISessionStage {
log.warn("Not found asset by registry.id={}", obligation.getId()); log.warn("Not found asset by registry.id={}", obligation.getId());
isUncovered = true; isUncovered = true;
} else if (obligation.getBalance().compareTo(asset.getBalance()) > 0) { } else if (obligation.getBalance().compareTo(asset.getBalance()) > 0) {
if (obligation.getBalance().compareTo(asset.getBalance()) > 0) { log.warn("groupId: {}: {}", obligation.getGroupId(),
log.warn("groupId: {}: {}", obligation.getGroupId(), msgResolver.resolve(new EnumMessage(ClearingError.InsecurityObligation, obligation.getCompanyId())));
msgResolver.resolve(new EnumMessage(ClearingError.InsecurityObligation, obligation.getCompanyId()))); isUncovered = true;
isUncovered = true;
}
} }
checkResults.add(new CheckResult(obligation, isUncovered)); checkResults.add(new CheckResult(obligation, isUncovered));
} }