test

 package az.kapitalbank.atlas.card.account.service;


import static az.kapitalbank.atlas.card.account.domain.Attribute.EXT_ACCOUNT_NUMBER;
import static az.kapitalbank.atlas.card.account.domain.Attribute.IBAN;

import az.kapitalbank.atlas.card.account.config.ApplicationProperties;
import az.kapitalbank.atlas.card.account.domain.Account;
import az.kapitalbank.atlas.card.account.domain.Card;
import az.kapitalbank.atlas.card.account.dto.AccountDto;
import az.kapitalbank.atlas.card.account.dto.AttributeDto;
import az.kapitalbank.atlas.card.account.dto.CardDto;
import az.kapitalbank.atlas.card.account.dto.request.AccountSearchFilter;
import az.kapitalbank.atlas.card.account.dto.request.CreateAccountRequest;
import az.kapitalbank.atlas.card.account.dto.request.UpdateAccountAttributeRequest;
import az.kapitalbank.atlas.card.account.dto.request.UpdateAccountRequest;
import az.kapitalbank.atlas.card.account.dto.request.UpdateAccountStatusRequest;
import az.kapitalbank.atlas.card.account.dto.response.CreateAccountResponse;
import az.kapitalbank.atlas.card.account.error.ErrorCodes;
import az.kapitalbank.atlas.card.account.mapper.AccountMapper;
import az.kapitalbank.atlas.card.account.repository.FimiRepository;
import az.kapitalbank.atlas.card.account.repository.OmsRepository;
import az.kapitalbank.atlas.card.account.repository.TwoAccountRepository;
import az.kapitalbank.atlas.lib.common.error.ServiceException;
import java.math.BigDecimal;
import java.util.Collections;
import java.util.List;
import java.util.stream.IntStream;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@Slf4j
@Service
@RequiredArgsConstructor
public class AccountService {

    private final FimiRepository fimiRepository;
    private final TwoAccountRepository twoAccountRepository;
    private final OmsRepository omsRepository;
    private final AccountMapper accountMapper;
    private final ApplicationProperties properties;

    public CreateAccountResponse create(CreateAccountRequest request) {
        log.info("CreateAccount, request: {}", request);
        var rqAccount = accountMapper.toRqAccount(request);
        var response = accountMapper.toCreateAccountResponse(omsRepository.execTran(rqAccount));

        log.info("AccountCreated, accountNumber: {}", response.getAccountNumber());
        return response;
    }

    public void update(String accountNumber, UpdateAccountRequest request) {
        log.info("UpdateAccount, request: {}", request);
        omsRepository.execTran(accountMapper.toRqAccount(accountNumber, request), true);
    }

    public void updateAttributes(String accountNumber, UpdateAccountAttributeRequest request) {
        log.info("UpdateAttributes, accountNumber: {}, attributes: {}",
                accountNumber, request.getAttributes());
        omsRepository.execTran(accountMapper.toRqAccount(accountNumber, request), true);
    }

    public List<AccountDto> findAll(AccountSearchFilter filter) {
        if (filter.isCustomerIdDefined()) {
            var customerId = filter.getCustomerId();
            if (isBlacklistedCustomerId(customerId)) {
                return Collections.emptyList();
            }

            return findAllByCustomerId(customerId);
        }

        if (filter.isCardUIDDefined()) {
            return findAllByCardUID(filter.getCardUID());
        }

        if (filter.isExternalUIDDefined()) {
            return findAllByExternalUID(filter.getExternalUID());
        }

        if (filter.isIbanDefined()) {
            return Collections.singletonList(findByIBAN(filter.getIban()));
        }

        if (filter.isExtAccountNumberDefined()) {
            return findByExtAccountNumber(filter.getExtAccountNumber());
        }

        return Collections.emptyList();
    }

    public List<AccountDto> findAllByCustomerId(Integer customerId) {
        return accountMapper.toAccountDtoList(twoAccountRepository.findAllByCustomerId(customerId));
    }

    public List<AccountDto> findAllByCardUID(String cardUID) {
        return accountMapper.toAccountDtoList(twoAccountRepository.findAllByCardUID(cardUID));
    }

    private List<AccountDto> findAllByExternalUID(String externalUID) {
        return accountMapper.toAccountDtoList(twoAccountRepository.findAllByExternalUID(externalUID));
    }

    public AccountDto findByIBAN(String iban) {
        var accountNumber = twoAccountRepository
                .findAccountNumberByAttribute(IBAN, iban)
                .orElseThrow(() -> exAccountNotFound(IBAN, iban));

        var account = twoAccountRepository
                .findByAccountNumber(accountNumber)
                .orElseThrow(() -> exAccountNotFound(accountNumber));

        return accountMapper.toAccountDto(account);
    }

    public List<AccountDto> findByExtAccountNumber(String extAccountNumber) {
        var accountNumber =
                twoAccountRepository.findAccountNumberByAttribute(EXT_ACCOUNT_NUMBER, extAccountNumber)
                        .orElseThrow(() -> exAccountNotFound(EXT_ACCOUNT_NUMBER, extAccountNumber));

        var account = twoAccountRepository.findByAccountNumber(accountNumber)
                .orElseThrow(() -> exAccountNotFound(accountNumber));

        return accountMapper.toAccountDtoList(List.of(account));
    }

    public List<AttributeDto> findAttributesByAccountNumber(String accountNumber) {
        return accountMapper.toAttributeDtoList(
                twoAccountRepository.findAttributesByAccountNumber(accountNumber));
    }

    public void updateStatus(String accountNumber, UpdateAccountStatusRequest request) {
        log.info("Update account status, accountNumber: {}, status: {}",
                accountNumber, request.getStatus());
        fimiRepository.updateStatus(
                accountMapper.toUpdateAccountStatusRequest(accountNumber, request));
    }

    public AccountDto findByAccountNumber(String accountNumber, boolean additionalInfo) {
        AccountDto accountDto = findByAccountNumberWithAdditionalInfo(accountNumber, additionalInfo);

        if (!additionalInfo && accountDto.getCards() != null) {
            accountDto.getCards().forEach(card -> card.setIsDigital(null));
        }

        return accountDto;
    }

    private AccountDto findByAccountNumberWithAdditionalInfo(String accountNumber,
                                                             boolean additionalInfo) {
        Account account = (additionalInfo
                ? twoAccountRepository.findByAccountNumberWithAdditionalInfo(accountNumber)
                : twoAccountRepository.findByAccountNumber(accountNumber))
                .orElseThrow(() -> exAccountNotFound(accountNumber));

        AccountDto accountDto = accountMapper.toAccountDto(account);
        BigDecimal balance = account.getAvailableBalance();

        accountDto.getCards().forEach(card -> calcAvailableLimit1(card, balance));

        return accountDto;
    }

    private BigDecimal calcAvailableLimit1(CardDto card,
                                          BigDecimal balance) {
        BigDecimal maxValue = card.getMaxValue();
        BigDecimal currentValue = card.getCurrentValue();

        if (maxValue == null || BigDecimal.ZERO.compareTo(maxValue) == 0) {
            return balance;
        }
        BigDecimal diff = maxValue.subtract(
                currentValue != null ? currentValue : BigDecimal.ZERO);
        return diff.compareTo(balance) >= 0 ? balance : diff;
    }

    private BigDecimal calcAvailableLimit(BigDecimal maxValue,
                                          BigDecimal currentValue,
                                          BigDecimal balance) {
        if (maxValue == null || BigDecimal.ZERO.compareTo(maxValue) == 0) {
            return balance;
        }
        BigDecimal diff = maxValue.subtract(
                currentValue != null ? currentValue : BigDecimal.ZERO);
        return diff.compareTo(balance) >= 0 ? balance : diff;
    }

    private boolean isBlacklistedCustomerId(Integer customerId) {
        return properties.getCustomerBlacklist()
                .stream()
                .anyMatch(blacklistedCustomerId -> blacklistedCustomerId.equals(customerId));
    }

    private ServiceException exAccountNotFound(String accountNumber) {
        return ServiceException.of(ErrorCodes.ACCOUNT_NOT_FOUND,
                "accountNumber", accountNumber);
    }

    private ServiceException exAccountNotFound(String id, String value) {
        return ServiceException.of(ErrorCodes.ACCOUNT_NOT_FOUND,
                id.toLowerCase(), value);
    }

}















package az.kapitalbank.atlas.card.account.service;

import static az.kapitalbank.atlas.card.account.domain.Attribute.EXT_ACCOUNT_NUMBER;
import static az.kapitalbank.atlas.card.account.domain.Attribute.IBAN;

import az.kapitalbank.atlas.card.account.config.ApplicationProperties;
import az.kapitalbank.atlas.card.account.domain.Account;
import az.kapitalbank.atlas.card.account.domain.Card;
import az.kapitalbank.atlas.card.account.dto.AccountDto;
import az.kapitalbank.atlas.card.account.dto.AttributeDto;
import az.kapitalbank.atlas.card.account.dto.CardDto;
import az.kapitalbank.atlas.card.account.dto.request.AccountSearchFilter;
import az.kapitalbank.atlas.card.account.dto.request.CreateAccountRequest;
import az.kapitalbank.atlas.card.account.dto.request.UpdateAccountAttributeRequest;
import az.kapitalbank.atlas.card.account.dto.request.UpdateAccountRequest;
import az.kapitalbank.atlas.card.account.dto.request.UpdateAccountStatusRequest;
import az.kapitalbank.atlas.card.account.dto.response.CreateAccountResponse;
import az.kapitalbank.atlas.card.account.error.ErrorCodes;
import az.kapitalbank.atlas.card.account.mapper.AccountMapper;
import az.kapitalbank.atlas.card.account.repository.FimiRepository;
import az.kapitalbank.atlas.card.account.repository.OmsRepository;
import az.kapitalbank.atlas.card.account.repository.TwoAccountRepository;
import az.kapitalbank.atlas.lib.common.error.ServiceException;
import java.math.BigDecimal;
import java.util.Collections;
import java.util.List;
import java.util.stream.IntStream;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@Slf4j
@Service
@RequiredArgsConstructor
public class AccountService {

    private final FimiRepository fimiRepository;
    private final TwoAccountRepository twoAccountRepository;
    private final OmsRepository omsRepository;
    private final AccountMapper accountMapper;
    private final ApplicationProperties properties;

    public CreateAccountResponse create(CreateAccountRequest request) {
        log.info("CreateAccount, request: {}", request);
        var rqAccount = accountMapper.toRqAccount(request);
        var response = accountMapper.toCreateAccountResponse(omsRepository.execTran(rqAccount));

        log.info("AccountCreated, accountNumber: {}", response.getAccountNumber());
        return response;
    }

    public void update(String accountNumber, UpdateAccountRequest request) {
        log.info("UpdateAccount, request: {}", request);
        omsRepository.execTran(accountMapper.toRqAccount(accountNumber, request), true);
    }

    public void updateAttributes(String accountNumber, UpdateAccountAttributeRequest request) {
        log.info("UpdateAttributes, accountNumber: {}, attributes: {}",
                accountNumber, request.getAttributes());
        omsRepository.execTran(accountMapper.toRqAccount(accountNumber, request), true);
    }

    public List<AccountDto> findAll(AccountSearchFilter filter) {
        if (filter.isCustomerIdDefined()) {
            var customerId = filter.getCustomerId();
            if (isBlacklistedCustomerId(customerId)) {
                return Collections.emptyList();
            }

            return findAllByCustomerId(customerId);
        }

        if (filter.isCardUIDDefined()) {
            return findAllByCardUID(filter.getCardUID());
        }

        if (filter.isExternalUIDDefined()) {
            return findAllByExternalUID(filter.getExternalUID());
        }

        if (filter.isIbanDefined()) {
            return Collections.singletonList(findByIBAN(filter.getIban()));
        }

        if (filter.isExtAccountNumberDefined()) {
            return findByExtAccountNumber(filter.getExtAccountNumber());
        }

        return Collections.emptyList();
    }

    public List<AccountDto> findAllByCustomerId(Integer customerId) {
        return accountMapper.toAccountDtoList(twoAccountRepository.findAllByCustomerId(customerId));
    }

    public List<AccountDto> findAllByCardUID(String cardUID) {
        return accountMapper.toAccountDtoList(twoAccountRepository.findAllByCardUID(cardUID));
    }

    private List<AccountDto> findAllByExternalUID(String externalUID) {
        return accountMapper.toAccountDtoList(twoAccountRepository.findAllByExternalUID(externalUID));
    }

    public AccountDto findByIBAN(String iban) {
        var accountNumber = twoAccountRepository
                .findAccountNumberByAttribute(IBAN, iban)
                .orElseThrow(() -> exAccountNotFound(IBAN, iban));

        var account = twoAccountRepository
                .findByAccountNumber(accountNumber)
                .orElseThrow(() -> exAccountNotFound(accountNumber));

        return accountMapper.toAccountDto(account);
    }

    public List<AccountDto> findByExtAccountNumber(String extAccountNumber) {
        var accountNumber =
                twoAccountRepository.findAccountNumberByAttribute(EXT_ACCOUNT_NUMBER, extAccountNumber)
                        .orElseThrow(() -> exAccountNotFound(EXT_ACCOUNT_NUMBER, extAccountNumber));

        var account = twoAccountRepository.findByAccountNumber(accountNumber)
                .orElseThrow(() -> exAccountNotFound(accountNumber));

        return accountMapper.toAccountDtoList(List.of(account));
    }

    public List<AttributeDto> findAttributesByAccountNumber(String accountNumber) {
        return accountMapper.toAttributeDtoList(
                twoAccountRepository.findAttributesByAccountNumber(accountNumber));
    }

    public void updateStatus(String accountNumber, UpdateAccountStatusRequest request) {
        log.info("Update account status, accountNumber: {}, status: {}",
                accountNumber, request.getStatus());
        fimiRepository.updateStatus(
                accountMapper.toUpdateAccountStatusRequest(accountNumber, request));
    }

    public AccountDto findByAccountNumber(String accountNumber, boolean additionalInfo) {
        AccountDto accountDto = findByAccountNumberWithAdditionalInfo(accountNumber, additionalInfo);

        if (!additionalInfo && accountDto.getCards() != null) {
            accountDto.getCards().forEach(card -> card.setIsDigital(null));
        }

        return accountDto;
    }

    private AccountDto findByAccountNumberWithAdditionalInfo(String accountNumber,
                                                             boolean additionalInfo) {
        Account account = (additionalInfo
                ? twoAccountRepository.findByAccountNumberWithAdditionalInfo(accountNumber)
                : twoAccountRepository.findByAccountNumber(accountNumber))
                .orElseThrow(() -> exAccountNotFound(accountNumber));

        AccountDto accountDto = accountMapper.toAccountDto(account);
        BigDecimal balance = account.getAvailableBalance();

        IntStream.range(0, account.getCards().size())
                .forEach(i -> accountDto.getCards().get(i).setAvailableLimit(
                        calcAvailableLimit(
                                account.getCards().get(i).getMaxValue(),
                                account.getCards().get(i).getCurrentValue(),
                                balance)));

        return accountDto;
    }

    private BigDecimal calcAvailableLimit(BigDecimal maxValue,
                                          BigDecimal currentValue,
                                          BigDecimal balance) {
        if (maxValue == null || BigDecimal.ZERO.compareTo(maxValue) == 0) {
            return balance;
        }
        BigDecimal diff = maxValue.subtract(
                currentValue != null ? currentValue : BigDecimal.ZERO);
        return diff.compareTo(balance) >= 0 ? balance : diff;
    }

    private boolean isBlacklistedCustomerId(Integer customerId) {
        return properties.getCustomerBlacklist()
                .stream()
                .anyMatch(blacklistedCustomerId -> blacklistedCustomerId.equals(customerId));
    }

    private ServiceException exAccountNotFound(String accountNumber) {
        return ServiceException.of(ErrorCodes.ACCOUNT_NOT_FOUND,
                "accountNumber", accountNumber);
    }

    private ServiceException exAccountNotFound(String id, String value) {
        return ServiceException.of(ErrorCodes.ACCOUNT_NOT_FOUND,
                id.toLowerCase(), value);
    }

}

Комментарии

Отправить комментарий

Популярные сообщения из этого блога

Lesson1: JDK, JVM, JRE

Изображение
1. Compiler - takes the entire programming code written in high language and translates the whole of it into machine code at once. After this process the an executable file will be ready to run. The translation takes some times to be done, but after that execution is so fast. 2. Interpreter - takes each single instructions of the code translates it and then executes it on its own. The translation step is before the program runs is fast, but execution is slow. JDK = JRE + development tools JRE = JVM + library class JDK -> Java Development Kit. A kit which provides the environment to develop and execute (run) Java program. JRE -> Java Runtime Environment. Provides environment to only run. JVM -> Java Virtual Machine f * Compiled: Fortran, C, C++, Pascal, Haskell, Rust, Go * Interpreted: JavaScript, PHP, Python, Ruby Java both compiled and interpreted language. Terminalda : javac Main.java yazdiqda, source fayli(.java) bytecode(.class) faylina cevirir. Terminalda: java Main (bu z...
Далее...

IoC:ApplicationContext, BeanFactory. Bean

 Bean - bean is an instance of a class managed by Spring Boot. In Spring Boot—and the broader Spring Framework—a bean is essentially an object that is managed by the Spring Inversion of Control (IoC) container. Beans are the backbone of a Spring application; they are the components that form the application and are responsible for performing its operations. Key Concepts: Inversion of Control (IoC): Instead of the application code controlling the flow of the program, control is inverted and given to the IoC container. This means the container is responsible for instantiating, configuring, and managing the lifecycle of beans. Dependency Injection (DI): This is a design pattern that allows an object (the client) to receive other objects it depends on (the services) from the IoC container, rather than creating them directly. Defining a Bean: In Spring Boot, you can declare beans in several ways: Using Annotations: @Component : A generic stereotype for any Spring-managed ...
Далее...

Preparation for Java interview

Изображение
1.⁠ ⁠Eror ve Exception  2.⁠ ⁠⁠Heap and Stack  3.⁠ ⁠⁠String pool  4.⁠ ⁠⁠Mutable and Immutable class  5.⁠ ⁠⁠Classi nece  Immutible ede bilerik?  6.⁠ ⁠⁠StringBulder vs StringBuffer  7.⁠ ⁠⁠Thread  nece yaradilir?  2.⁠ ⁠⁠checked and anchecked  3.⁠ ⁠⁠exception Handler  4.⁠ ⁠⁠Entity relationships   5.⁠ ⁠⁠Entity fetch Type LAZY and EGAR  5.⁠ ⁠⁠OOP prinsips   6.⁠ ⁠⁠SOLID  7.⁠ ⁠⁠Singlton designs pattern  8.⁠ ⁠⁠Connection pool  8.⁠ ⁠⁠Bulder  9.⁠ ⁠⁠Prox 10.⁠ ⁠⁠Protodtype 11.⁠ ⁠Hansi type  12.⁠ ⁠⁠ArrayList vs LinkedList 13.⁠ ⁠⁠Set and Hashest 14.⁠ ⁠⁠HashMap ve HashTable 15.⁠ ⁠⁠Interface Ve Abstract class ferq 16.⁠ ⁠⁠Java 8 features  17.⁠ ⁠⁠Functional Interface nece yaradilir ve Java 8 de gelen hazir Functional Interfaces 17.⁠ ⁠⁠Stream API, intermadite, terminal, Lazy Intialise 15.⁠ ⁠⁠Spring boot features  16.⁠ ⁠⁠Spring Boot transactions management  17.⁠ ⁠⁠ACID 18.⁠ ⁠⁠Duty read, repeatable read, non-repeatable  19.⁠ ⁠⁠Isolation Levels 4 nov 20.⁠ ⁠⁠propigat...
Далее...