[volume-1] TDD 기반 1주차 과제 (회원, 포인트) 기능 구현

apps/commerce-api/src/main/java/com/loopers/application/point/PointFacade.java

@@ -0,0 +1,44 @@
+package com.loopers.application.point;
+
+import com.loopers.domain.point.PointModel;
+import com.loopers.domain.point.PointService;
+import com.loopers.domain.user.UserModel;
+import com.loopers.domain.user.UserService;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@RequiredArgsConstructor
+@Component
+public class PointFacade {
+    private final PointService pointService;
+    private final UserService userService;
+
+    public PointInfo getPoint(String userId) {
+        UserModel user = userService.getUser(userId);
+        if (user == null) {
+            throw new CoreException(ErrorType.NOT_FOUND, "존재하지 않는 요청입니다.");
+        }
+        PointModel pointModel = new PointModel(user, 0);
+        PointModel point = pointService.findPoint(pointModel);
+
+        if (point == null) {
+            throw new CoreException(ErrorType.NOT_FOUND, "포인트 정보가 없습니다.");
+        }
+
+        return PointInfo.from(point);
+    }
+
+    public PointInfo chargePoint(String userId, int amount) {
+        UserModel user = userService.getUser(userId);
+        if (user == null) {
+            throw new CoreException(ErrorType.NOT_FOUND, "존재하지 않는 요청입니다.");
+        }
+        PointModel pointModel = new PointModel(user, amount);
+        pointService.charge(pointModel);
+
+        PointModel charged = pointService.findPoint(new PointModel(user, 0));
+        return PointInfo.from(charged);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/application/point/PointInfo.java

@@ -0,0 +1,13 @@
+package com.loopers.application.point;
+
+import com.loopers.domain.point.PointModel;
+import com.loopers.domain.user.UserModel;
+
+public record PointInfo(Long id, UserModel user, int point) {
+    public static PointInfo from(PointModel model) {
+        return new PointInfo(model.getId(), model.getUser(), model.getPoint());
+    }
+    public int getPoint() {
+        return point;
+    }
+}

apps/commerce-api/src/main/java/com/loopers/application/user/UserFacade.java

@@ -0,0 +1,28 @@
+package com.loopers.application.user;
+
+import com.loopers.domain.user.UserModel;
+import com.loopers.domain.user.UserService;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@RequiredArgsConstructor
+@Component
+public class UserFacade {
+    private final UserService userService;
+
+    public UserInfo signup(String userId, String email, String birthDate) {
+        UserModel userModel = new UserModel(userId, email, birthDate);
+        UserModel savedUser = userService.signUp(userModel);
+        return UserInfo.from(savedUser);
+    }
+
+    public UserInfo getUser(String userId) {
+        UserModel user = userService.getUser(userId);
+        if (user == null) {
+            throw new CoreException(ErrorType.NOT_FOUND, "존재하지 않는 요청입니다.");
+        }
+        return UserInfo.from(user);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/application/user/UserInfo.java

@@ -0,0 +1,13 @@
+package com.loopers.application.user;
+
+import com.loopers.domain.user.UserModel;
+
+public record UserInfo(String userId, String email, String birthDate) {
+    public static UserInfo from(UserModel model) {
+        return new UserInfo(
+            model.getUserId(),
+            model.getEmail(),
+            model.getBirthDate()
+        );
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/point/PointModel.java

@@ -0,0 +1,57 @@
+package com.loopers.domain.point;
+
+import com.loopers.domain.BaseEntity;
+import com.loopers.domain.user.UserModel;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import jakarta.persistence.Entity;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.ManyToOne;
+import jakarta.persistence.Table;
+
+@Entity
+@Table(name = "point")
+public class PointModel extends BaseEntity {
+
+    @ManyToOne
+    @JoinColumn(name = "user_model_id")
+    private UserModel user;
+    private int point = 0;
+
+    public PointModel() {}
+
+    public PointModel(UserModel user, int point) {
+
+        if( point < 0 ){
+            throw new CoreException(ErrorType.BAD_REQUEST, "포인트는 0 이상이어야 합니다.");
+        }
+        this.user = user;
+        this.point = point;
+    }
+
+    public UserModel getUser() {
+        return user;
+    }
+
+    public int getPoint() {
+        return point;
+    }
+
+    public void charge(int amount) {
+        if (amount < 0) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "포인트는 0 이상이어야 합니다.");
+        }
+        this.point += amount;
+    }
+
+    public void use(int amount) {
+
+        if (amount < 0) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "사용 금액은 0보다 커야 합니다.");
+        }
+        if (point < 0) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "포인트는 0 이상이어야 합니다.");
+        }
+        this.point -= amount;
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/point/PointRepository.java

@@ -0,0 +1,10 @@
+package com.loopers.domain.point;
+
+import com.loopers.domain.user.UserModel;
+
+import java.util.Optional;
+
+public interface PointRepository {
+    Optional<PointModel> findPoint(UserModel user);
+    PointModel save(PointModel pointModel);
+}

apps/commerce-api/src/main/java/com/loopers/domain/point/PointService.java

@@ -0,0 +1,43 @@
+package com.loopers.domain.point;
+
+import com.loopers.domain.user.UserRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.stereotype.Component;
+
+import com.loopers.domain.user.UserModel;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+
+@RequiredArgsConstructor
+@Component
+public class PointService {
+
+    private final PointRepository pointRepository;
+    private final UserRepository userRepository;
+
+    @Transactional(readOnly = true)
+    public PointModel findPoint(PointModel point) {
+        UserModel requestUser = point.getUser();
+        var foundUser = userRepository.find(requestUser.getUserId());
+        if (foundUser.isEmpty()) {
+            return null;
+        }
+        return pointRepository.findPoint(foundUser.get()).orElse(null);
+    }
+
+    @Transactional
+    public void charge(PointModel point) {
+        UserModel user = point.getUser();
+        var foundUser = userRepository.find(user.getUserId())
+            .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "유저가 존재하지 않습니다."));
+
+        var existing = pointRepository.findPoint(foundUser);
+        if (existing.isPresent()) {
+            existing.get().charge(point.getPoint());
+            pointRepository.save(existing.get());
+            return;
+        }
+        pointRepository.save(new PointModel(foundUser, point.getPoint()));
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/user/UserModel.java

@@ -0,0 +1,59 @@
+package com.loopers.domain.user;
+
+import com.loopers.domain.BaseEntity;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Table;
+
+@Entity
+@Table(name = "user")
+public class UserModel extends BaseEntity {
+
+    private String userId;
+    private String email;
+    private String birthDate;
+
+    protected UserModel() {}
+
+    public UserModel(String userId, String email, String birthDate) {
+
+        if ( userId == null || userId.isBlank() ) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "UserId는 비어있을 수 없습니다.");
+        }
+        if ( !userId.matches("^[a-zA-Z0-9_-]{1,10}$") ) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "ID 가 `영문 및 숫자 10자 이내` 형식에 맞아야 합니다.");
+        }
+
+        if ( email == null || email.isBlank() ) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "이메일은 비어있을 수 없습니다.");
+        }
+        if ( !email.matches("^[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+\\.[a-zA-Z]{2,6}$") ) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "이메일이 `xx@yy.zz` 형식에 맞아야 합니다.");
+        }
+
+        if ( birthDate == null || birthDate.isBlank() ) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "생년월일은 비어있을 수 없습니다.");
+        }
+        if ( !birthDate.matches("^\\d{4}-\\d{2}-\\d{2}$") ) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "생년월일이 `yyyy-MM-dd` 형식에 맞아야 합니다.");
+        }
+
+        this.userId = userId;
+        this.email = email;
+        this.birthDate = birthDate;
+    }
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public String getBirthDate() {
+        return birthDate;
+    }
+
+}

apps/commerce-api/src/main/java/com/loopers/domain/user/UserRepository.java

@@ -0,0 +1,10 @@
+package com.loopers.domain.user;
+
+import java.util.Optional;
+
+public interface UserRepository {
+    Optional<UserModel> find(String userId);
+    Optional<UserModel> findById(Long id);
+
+    UserModel save(UserModel userModel);
+}

apps/commerce-api/src/main/java/com/loopers/domain/user/UserService.java

@@ -0,0 +1,31 @@
+package com.loopers.domain.user;
+
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Optional;
+
+@RequiredArgsConstructor
+@Component
+public class UserService {
+
+    private final UserRepository userRepository;
+
+     @Transactional(readOnly = true)
+     public UserModel getUser(String userId) {
+         return userRepository.find(userId).orElse(null);
+     }
+
+    @Transactional
+    public UserModel signUp(UserModel userModel) {
+        Optional<UserModel> user = userRepository.find(userModel.getUserId());
+
+        if (user.isPresent()) {
+            throw new CoreException(ErrorType.CONFLICT, "[userId = " + userModel.getUserId() + "] 아이디가 중복되었습니다.");
+        }
+        return userRepository.save(userModel);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/point/PointJpaRepository.java

@@ -0,0 +1,11 @@
+package com.loopers.infrastructure.point;
+
+import com.loopers.domain.point.PointModel;
+import com.loopers.domain.user.UserModel;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.Optional;
+
+public interface PointJpaRepository extends JpaRepository<PointModel, Long> {
+    Optional<PointModel> findByUser(UserModel user);
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/point/PointRepositoryImpl.java

@@ -0,0 +1,25 @@
+package com.loopers.infrastructure.point;
+
+import com.loopers.domain.point.PointModel;
+import com.loopers.domain.point.PointRepository;
+import com.loopers.domain.user.UserModel;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.util.Optional;
+
+@RequiredArgsConstructor
+@Component
+public class PointRepositoryImpl implements PointRepository {
+    private final PointJpaRepository pointJpaRepository;
+
+    @Override
+    public Optional<PointModel> findPoint(UserModel user) {
+        return pointJpaRepository.findByUser(user);
+    }
+
+    @Override
+    public PointModel save(PointModel pointModel) {
+        return pointJpaRepository.save(pointModel);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/user/UserJpaRepository.java

@@ -0,0 +1,10 @@
+package com.loopers.infrastructure.user;
+
+import com.loopers.domain.user.UserModel;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.Optional;
+
+public interface UserJpaRepository extends JpaRepository<UserModel, Long> {
+    Optional<UserModel> findByUserId(String userId);
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/user/UserRepositoryImpl.java

@@ -0,0 +1,32 @@
+package com.loopers.infrastructure.user;
+
+import com.loopers.domain.user.UserModel;
+import com.loopers.domain.user.UserRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.util.Optional;
+
+@RequiredArgsConstructor
+@Component
+public class UserRepositoryImpl implements UserRepository {
+    private final UserJpaRepository userJpaRepository;
+
+    @Override
+    public Optional<UserModel> find(String userId) {
+         return userJpaRepository.findByUserId(userId);
+     }
+
+    @Override
+    public Optional<UserModel> findById(Long id) {
+        return Optional.empty();
+    }
+
+    @Override
+    public UserModel save(UserModel userModel) {
+        return userJpaRepository.save(userModel);
+    }
+
+
+
+}