[Spring Code] DAO - Service - Controller 구조 예시

#  DAO interface

@Mapper
public interface AccountRepository {
 
    // 계좌번호로 계좌 조회
    public Account findByNumber(String number);
    
}

 

#  DAO 쿼리문 xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 
<mapper namespace="com.tenco.bank.repository.interfaces.AccountRepository">
    
    <select id="findByNumber" resultType="com.tenco.bank.repository.model.Account">
        SELECT * FROM account_tb WHERE number = #{number}
    </select>
    
</mapper>

 

#  Service

@Service // IoC 대상
public class AccountService {
 
    @Autowired
    private AccountRepository accountRepository;
    
    @Autowired
    private HistoryRepository historyRepository;
 
 
    // 이체 처리
    @Transactional
    public void updateAccountTransfer(TransferFormDto transferFormDto, Integer principalId) {
        // 출금 계좌 존재 여부 확인 (select)
        Account withdrawAccountEntity = accountRepository.findByNumber(transferFormDto.getWAccountNumber());
        if (withdrawAccountEntity == null) {
            throw new CustomRestfullException("출금 계좌가 존재하지 않습니다.", HttpStatus.INTERNAL_SERVER_ERROR);
        }
        
        // 입금 계좌 존재 여부 확인 (select)
        Account depositAccountEntity = accountRepository.findByNumber(transferFormDto.getDAccountNumber());
        if (depositAccountEntity == null) {
            throw new CustomRestfullException("입금 계좌가 존재하지 않습니다.", HttpStatus.INTERNAL_SERVER_ERROR);
        }
        
        // 출금 계좌의 본인 소유 여부 확인
        withdrawAccountEntity.checkOwner(principalId);
        
        // 출금 계좌 비밀번호 확인 
        withdrawAccountEntity.checkPassword(transferFormDto.getWAccountPassword());
        
        // 출금 계좌 잔액 여부 확인
        withdrawAccountEntity.checkBalance(transferFormDto.getAmount());
        
        // 출금 계좌 잔액 변경 (update)
        withdrawAccountEntity.withdraw(transferFormDto.getAmount());
        accountRepository.updateById(withdrawAccountEntity);
        
        // 입금 계좌 잔액 변경 (update)
        depositAccountEntity.deposit(transferFormDto.getAmount());
        accountRepository.updateById(depositAccountEntity);
        
        // 거래 내역 저장 (insert)
        History history = new History();
        history.setAmount(transferFormDto.getAmount());
        history.setWAccountId(withdrawAccountEntity.getId());
        history.setDAccountId(depositAccountEntity.getId());
        history.setWBalance(withdrawAccountEntity.getBalance());
        history.setDBalance(depositAccountEntity.getBalance());
        int resultRowCount = historyRepository.insert(history);
        
        if (resultRowCount != 1) {
            throw new CustomRestfullException("정상 처리되지 않았습니다.", HttpStatus.INTERNAL_SERVER_ERROR);
        }
        
    }
}

 

#  Controller

@Controller
@RequestMapping("/account")
public class AccountController {
 
    @Autowired
    private HttpSession session;
    
    @Autowired
    private AccountService accountService;
 
 
    // 이체 기능
    @PostMapping("/transfer-proc")
    public String transferProc(TransferFormDto transferFormDto) {
        
        // 인증 검사
        User principal = (User) session.getAttribute(Define.PRINCIPAL);
        
        if (principal == null) {
            throw new UnAuthorizedException("로그인 후 이용해주세요.", HttpStatus.UNAUTHORIZED); // 인증되지 않음 (401)
        }
        
        // 유효성 검사
        // 출금 계좌번호 입력 여부
        if (transferFormDto.getWAccountNumber() == null || transferFormDto.getWAccountNumber().isEmpty()) {
            throw new CustomRestfullException("출금 계좌번호를 입력하세요.", HttpStatus.BAD_REQUEST);
        }
 
        // 입력 계좌번호 입력 여부
        if (transferFormDto.getDAccountNumber() == null || transferFormDto.getDAccountNumber().isEmpty()) {
            throw new CustomRestfullException("입금 계좌번호를 입력하세요.", HttpStatus.BAD_REQUEST);
        }
        
        // 출금 계좌 비밀번호 입력 여부
        if (transferFormDto.getWAccountPassword() == null || transferFormDto.getWAccountPassword().isEmpty()) {
            throw new CustomRestfullException("출금 계좌 비밀번호를 입력하세요.", HttpStatus.BAD_REQUEST);
        }
        
        // 이체 금액 확인
        if (transferFormDto.getAmount() == null) {
            throw new CustomRestfullException("이체 금액을 입력하세요.", HttpStatus.BAD_REQUEST);
        }
        
        if (transferFormDto.getAmount() <= 0) {
            throw new CustomRestfullException("이체 금액을 1원 이상 입력하세요.", HttpStatus.BAD_REQUEST);
        }
        
        // 출금 계좌번호와 입금 계좌번호가 동일하지 않은지 확인
        if (transferFormDto.getWAccountNumber().equals(transferFormDto.getDAccountNumber())) {
            throw new CustomRestfullException("출금 계좌번호와 입금 계좌번호가 동일합니다.", HttpStatus.BAD_REQUEST);
        }
        
        // 서비스 호출
        accountService.updateAccountTransfer(transferFormDto, principal.getId());
        
        return "redirect:/account/list";
    }
 
}

 

  - 인증 검사는 반복되므로 인터셉터로 하기