[도메인 주도 개발 시작하기] - 표현 영역과 응용 영역

@PostMapping("/member/join") public ModelAndVeiw join(HttpServletRequest request) { String email = request.getParameter("email"); String password = request.getPassword("password"); //사용자 요청을 응용 서비스에 맞게 변환 JoinReuqest joinReq = new JoinRequest(email, password); // 변환한 객체(데이터)를 이용해서 응용 서비스 실행 JoinService.join(joinReq); ... }

public Result doSomeFunc(SomeReq req) { // 1. 리포지터리에서 애그리거트를 구한다. SomeAgg agg = someAggRepository.findById(req.getId()); checkNull(agg); // 2. 애그리거트의 도메인 기능을 실행한다. agg.doFunc(req.getValau()); // 3. 결과를 리턴한다. return createSuccessResult(agg); }

public Result doSomeCreation(CreateSomeReq req) { // 1. 데이터 중복 등 데이이터가 유효한지 검사한다. validate(req); // 2. 에그리거트를 생성한다. someAgg newAgg = createSome(req); // 3. 리포지터리에 에그리거트를 저장한다. someAggRepository.save(newAgg); // 4. 결과를 리턴한다. return createSuccessResult(newAgg); }

public void blockMembers(String[] blockIds) { if (blockingIds == null || blockingIds.length == 0) return; List<Member> members = memberRepostiory.findByIdIn(blockIds); for (Member member : members) { mem.block(); } }

public class changePasswordService { public void changePassword(String memberId, String oldPw, String newPw) { Member member = memberRepository.findById(memberId); checkMemberExists(member); member.changePassword(oldpw, newPw); } ... }

public class Member { public void changePasswrod(String oldPw, String newPw) { if (!matchPassword(oldPw)) throw new badPasswordException(); setPassword(newPw); } // 현재 암호와 일치하는지 검사하는 도메인 로직 public boolean matchPassword(String pwd) { return passwordEncoder.matches(pwd); } private void setPasswrod(String newPw) { if (isEmpty(newPw)) throw new IllegalArgumentException("no new password"); this.password = newPw; } }

public class ChangePasswordService { public void changePassword(String memberId, String oldPw, String newPw) { Member member = memberRepository.findById(memberId); if (!passwordEncoder.matches(oldPw, member.getPassword())) { throw new badPasswordException(); } member.setPassword(newPw); } }

public class MemberService { // 각 기능을 구현하는 데 필요한 리포지터리, 도메인 서비스 필드 추가 private MemberRepository memberRepostiory; public void join(MemberJoinRequest joinRequest) {...} public void changePassword(String memberId, String curPw, String newPw) {...} ... }

public class ChangePasswordService { private MemberRepostiory memberRepostiory; public void changePassword(String memberId, String curPw, String newPw) { Member member = memberRepostory.findById(memberId); if (member == null) throw new NoMemberException(memberId); member.changePassword(curPw, newPw); } ... }

//각 응용 서비스에서 공통되는 로직을 별도 클래스로 구현 public final class MemberServiceHelper { public static Member findExistingMember(MemberRepositry repo, String memberId) { Member member = repo.findById(memberId); if (member == null) throw new NoMemberException(); return member; } } // 공통 로직을 제공하는 메서드를 응용 서비스에서 사용 public class ChangePasswordService { private MemberRepositry memberRepostiory; public void changePassword(String memberId, String curPw, String newPw) { Member member = findExistingMember(memberRepostiory, memberid); member.changePassword(curPw, newPw); } }

public class ChangePasswordService { // 암호 변경 기능 구현에 필요한 값을 파라미터로 전달 받음 public void changePassword(String memberId, String curPw, String newPw) { ... } }

public class ChangePasswordRequest { private String memberId; private String currentPassword; private String newPassword(); .. get 메서드 등 생략 }

public class ChangePasswordService { // 암호 변경 기능 구현에 필요한 값을 파라미터로 전달 받음 public void changePassword(ChangePasswordRequest req) { Member member = findExistingMember(req.getMemberId()); member.changePassword(req.getCurrentPassword(), req.getNewPassword()); } ... }

@Controller @RequestMapping("/member/changePassword") public class MemberPasswordController { @PostMapping public String submit(HttpSergiceRequest request) { try{ // 응용 서비스가 표현 영역을 의존하면 안됨 changePasswordService.changePassword(request); } catch (NoMemberException ex){ // 알맞은 익셉션 처리 및 응답 } } }

public class AuthenticationService { public void authenticate(HttpServletRequest request) { ... // 응용 서비스에서 표현 영역이 상태 처리 HttpSession session = request.getSession() ... } }

@PostMapping() public String changePassword(HttpServletRequest requeset, Errors errors) { // 표현 영역은 사용자 요청을 응용 서비스가 요구하는 형식으로 변환한다. String curPw = requeset.getParameter("curPw"); String newPw = requeset.getParameter("newPw"); String memberId = SecurityContext.getAuthentication().getId(); ChangePasswordRequest chPwdReq = new ChangePasswordRequest(memberId, curPw, newPw); try { // 응용 서비스를 실행 changePasswordService.changePassword(chPwdReq); return successView; } catch (BadPasswordExcetption | NoMemberException ex) { // 응용 서비스의 처리 결과를 알맞은 응답으로 변환 erros.reject(""idPasswordNotMatch); return fomeView; } }

public class JoinService { @Transcation public void join(joinRequest joinReq) { // 값 형식 검사 checkEmpty(request.getId(), "id"); .. // 로직 검사 checkDuplicateId(joinReq.getId()); } private void checkDuplicateId(String id) { int count = memberRepsoitory.countsById(id); if(count > 0) { throw new DuplicationException(); } } }

@Transacional public OrderNo placeOrder(OrderRequest orderRequest) { List<ValidationError> errors = new ArrayList<>(); if (orderRequest == null) { errors.add(ValiddationError.of("emtpy")); } else { if (orderRequest.getOrdererMemberID() == null) { errors.add(ValiddationError.of("ordererMemberId", "emtpy")) } if (orderRequest.getOrderProducts() == null) { errors.add(ValiddationError.of("getOrderProducts", "emtpy")) } if (orderRequest.getOrderProducts().isEmpty()) { errors.add(ValiddationError.of("getOrderProducts", "emtpy")) } } // 응용 서비스가 입력 오류를 하나의 익셉션으로 모아서 발생 if (!erros.isEmpty()) throw new ValidationErrorExceptions(errors); }

public class ValidationErrorException extends RuntimeException { private List<ValidationError> errors; public ValidationErrorException(List<ValidationError> errors) { this.errors = errors; } public List<ValidationError> getErrors() { return errors; } }

@Controller public class Controller { @PostMapping("/member/join") public Strig join(JoinReuqest joinRequest, Erros erros) { new JoinRequestValidator().validate(joinRequest, erros); if (erros.hasErros()) return forView; try { } catch (DuplicatedIdException ex) { erros.rejectValue(ex.getPropertyName(), "duplicate"); return formView; } } }

public class BlockMemberService { private MemberRepostiory memberRepository; @PreAuthorize(hasRole('ADMIN')) public void block(String memberId) { Member member = memberRepository.findById(memberId); if (Objects.isNull(member)) throw new NoMemberExcetpion(); member.block(); } }

public class DeletedArticleService { public void delete(String userId, Long articleId) { Article article = articleRepository.findById(articleId); checkArticleExistence(article); permissionService.checkDeletePermission(userId, articleId); } }