account-service http://jira.mfd.msk:8088/browse/CLS-231 валидация и спринг (spring=весна)
This commit is contained in:
parent
29a9261ee8
commit
1fe0168446
2 changed files with 7 additions and 0 deletions
|
|
@ -1,5 +1,7 @@
|
||||||
package ru.spcex.clearing.account.config;
|
package ru.spcex.clearing.account.config;
|
||||||
|
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Bean;
|
||||||
import org.springframework.context.annotation.Configuration;
|
import org.springframework.context.annotation.Configuration;
|
||||||
import ru.clearing.classes.statics.data.account.Account;
|
import ru.clearing.classes.statics.data.account.Account;
|
||||||
|
|
@ -24,9 +26,11 @@ import java.util.function.Function;
|
||||||
|
|
||||||
@Configuration
|
@Configuration
|
||||||
public class ValidationConfig {
|
public class ValidationConfig {
|
||||||
|
Logger log = LoggerFactory.getLogger(getClass());
|
||||||
private final Map<String, Imdg<? extends SpcexObjectBase>> imdgs;
|
private final Map<String, Imdg<? extends SpcexObjectBase>> imdgs;
|
||||||
|
|
||||||
public ValidationConfig(ImdgProvider imdgProvider) {
|
public ValidationConfig(ImdgProvider imdgProvider) {
|
||||||
|
log.debug("Init validator config");
|
||||||
this.imdgs = new HashMap<>();
|
this.imdgs = new HashMap<>();
|
||||||
BiConsumer<String, Class<? extends SpcexObjectBase>> addImdg = (s, aClass) -> imdgs.put(s, imdgProvider.getImdg(s, aClass));
|
BiConsumer<String, Class<? extends SpcexObjectBase>> addImdg = (s, aClass) -> imdgs.put(s, imdgProvider.getImdg(s, aClass));
|
||||||
addImdg.accept(IMDGDistributedNames.Map_Account, Account.class);
|
addImdg.accept(IMDGDistributedNames.Map_Account, Account.class);
|
||||||
|
|
@ -44,6 +48,7 @@ public class ValidationConfig {
|
||||||
|
|
||||||
@Bean("bankAccountNewRequestValidator")
|
@Bean("bankAccountNewRequestValidator")
|
||||||
public Function<BankAccountNewRequest, IValidator> bankAccountNewRequestValidator() {
|
public Function<BankAccountNewRequest, IValidator> bankAccountNewRequestValidator() {
|
||||||
|
log.debug("Create validator bankAccountNewRequestValidator");
|
||||||
return bankAccountNewRequest -> {
|
return bankAccountNewRequest -> {
|
||||||
ImdgValidationContext<BankAccountNewRequest> context = new ImdgValidationContext<>();
|
ImdgValidationContext<BankAccountNewRequest> context = new ImdgValidationContext<>();
|
||||||
context.setValidatedObject(bankAccountNewRequest);
|
context.setValidatedObject(bankAccountNewRequest);
|
||||||
|
|
|
||||||
|
|
@ -6,6 +6,7 @@ import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.beans.factory.InitializingBean;
|
import org.springframework.beans.factory.InitializingBean;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.beans.factory.annotation.Qualifier;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import ru.clearing.classes.statics.data.account.Account;
|
import ru.clearing.classes.statics.data.account.Account;
|
||||||
import ru.clearing.classes.statics.data.account.BankAccount;
|
import ru.clearing.classes.statics.data.account.BankAccount;
|
||||||
|
|
@ -51,6 +52,7 @@ public class BankAccountService extends QueueConsumer implements InitializingBea
|
||||||
ImdgProvider imdgProvider,
|
ImdgProvider imdgProvider,
|
||||||
IMessageResolver messageResolver,
|
IMessageResolver messageResolver,
|
||||||
|
|
||||||
|
@Qualifier("bankAccountNewRequestValidator")
|
||||||
Function<BankAccountNewRequest, IValidator> bankAccountNewRequestValidator) {
|
Function<BankAccountNewRequest, IValidator> bankAccountNewRequestValidator) {
|
||||||
super(kafkaQueue, kafkaProducer);
|
super(kafkaQueue, kafkaProducer);
|
||||||
this.bankAccountMap = imdgProvider.getImdg(IMDGDistributedNames.Map_BankAccount, BankAccount.class);
|
this.bankAccountMap = imdgProvider.getImdg(IMDGDistributedNames.Map_BankAccount, BankAccount.class);
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue