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

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

Browse source 
---
fixup
This commit is contained in:
aalehin 2023-07-07 15:59:33 +03:00
parent a0de1d0afc
commit cd920fbdf8
1 changed files with 10 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
clearing-parent/registry-service/src/main/java/ru/spcex/clearing/registry/service/MoneyBalanceRegisterService.java
View file

@ -84,9 +84,9 @@ public class MoneyBalanceRegisterService extends QueueConsumer implements Initia
private void insertMoneyBalanceRegister(Registry registry) { private void insertMoneyBalanceRegister(Registry registry) {
log.trace("Started generating MoneyBalanceRegister entity..."); log.trace("Started generating MoneyBalanceRegister entity...");
MoneyBalanceRegister moneyBalanceRegister = new MoneyBalanceRegister(); MoneyBalanceRegister moneyBalanceRegister = new MoneyBalanceRegister();
Registry registryForRemainderSum = registryMap.getSingleObjectBySQL(getSqlForRemainderSum()); Registry registryForRemainderSum = registryMap.getSingleObjectBySQL(getSqlForRemainderSum(registry.getCompanyId()));
Registry registryForBlockedSum = registryMap.getSingleObjectBySQL(getSqlForBlockedSum()); Registry registryForBlockedSum = registryMap.getSingleObjectBySQL(getSqlForBlockedSum(registry.getCompanyId()));
Registry registryForUnblockedSum = registryMap.getSingleObjectBySQL(getSqlForUnblockedSum()); Registry registryForUnblockedSum = registryMap.getSingleObjectBySQL(getSqlForUnblockedSum(registry.getCompanyId()));
Company company = companyMap.getSingleObjectByFieldValues(Map.of("id", 2L)); Company company = companyMap.getSingleObjectByFieldValues(Map.of("id", 2L));
CompanySymbols companySymbol = companySymbolsMap.getSingleObjectByFieldValues(Map.of("companyId", registry.getCompanyId())); CompanySymbols companySymbol = companySymbolsMap.getSingleObjectByFieldValues(Map.of("companyId", registry.getCompanyId()));
String setHouseName = company != null ? company.getShortName() : null; String setHouseName = company != null ? company.getShortName() : null;
@ -121,22 +121,22 @@ public class MoneyBalanceRegisterService extends QueueConsumer implements Initia
private String getSqlForRegistries(Long companyId) { private String getSqlForRegistries(Long companyId) {
log.trace("Started generating sql predicate for registries..."); log.trace("Started generating sql predicate for registries...");
return String.format("companyId = '%s' registryCode LIKE 'AM__'", companyId); return String.format("companyId = '%s' and registryCode LIKE 'AM__'", companyId);
} }
private String getSqlForRemainderSum() { private String getSqlForRemainderSum(Long companyId) {
log.trace("Started generating sql predicate for registries remainder sum..."); log.trace("Started generating sql predicate for registries remainder sum...");
return "registryCode LIKE 'AM_T'"; return String.format("companyId = '%s' and registryCode LIKE 'AM_T'", companyId);
} }
private String getSqlForBlockedSum() { private String getSqlForBlockedSum(Long companyId) {
log.trace("Started generating sql predicate for registries blocked sum..."); log.trace("Started generating sql predicate for registries blocked sum...");
return "registryCode LIKE 'AM_T'"; return String.format("companyId = '%s' and registryCode LIKE 'AM_B'", companyId);
} }
private String getSqlForUnblockedSum() { private String getSqlForUnblockedSum(Long companyId) {
log.trace("Started generating sql predicate for registries unblocked sum..."); log.trace("Started generating sql predicate for registries unblocked sum...");
return "registryCode LIKE 'AM_F'"; return String.format("companyId = '%s' and registryCode LIKE 'AM_F'", companyId);
} }
} }