This commit is contained in:
parent
adf0091fef
commit
d85e043060
1 changed files with 5 additions and 2 deletions
|
|
@ -4,6 +4,7 @@ package ru.spcex.clearing.company.service;
|
|||
import java.util.Objects;
|
||||
import java.util.Optional;
|
||||
import java.util.function.Function;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.apache.kafka.clients.consumer.Consumer;
|
||||
import org.apache.kafka.clients.producer.Producer;
|
||||
import org.slf4j.Logger;
|
||||
|
|
@ -165,7 +166,7 @@ public class CompanySymbolService extends QueueConsumer implements InitializingB
|
|||
RequestInfoUpdate requestInfoUpdate = userRoleVerification.validateRoleAndGetResult(symbolRequest);
|
||||
if (requestInfoUpdate != null) return requestInfoUpdate;
|
||||
|
||||
if (!req.getCompanySymbol().equals("TAXN")) {
|
||||
if (!"TAXN".equals(req.getCompanySymbol())) {
|
||||
requestInfoUpdate = validationHelper.validateTillFirstError(symbolRequest, companySymbolUpdateRequestValidator);
|
||||
if (requestInfoUpdate != null) return requestInfoUpdate;
|
||||
}
|
||||
|
|
@ -185,9 +186,11 @@ public class CompanySymbolService extends QueueConsumer implements InitializingB
|
|||
companySymbols.getId(), companySymbols.getCompanySymbol(), req.getCompanySymbol());
|
||||
companyService.updateCompanyBySymbol(transaction, companySymbols, true);
|
||||
companySymbols.setCompanySymbol(req.getCompanySymbol());
|
||||
} else if (StringUtils.isEmpty(req.getCompanySymbol())) {
|
||||
companySymbols.setCompanySymbol(null);
|
||||
}
|
||||
companySymbols.setCompanySymbolValue(req.getCompanySymbolValue());
|
||||
if (!companySymbols.getCompanySymbol().equals("TAXN")) {
|
||||
if (!"TAXN".equals(companySymbols.getCompanySymbol())) {
|
||||
companySymbolsTMap.update(companySymbols);
|
||||
}
|
||||
companyService.updateCompanyBySymbol(transaction, companySymbols, false);
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue