Merge pull request #13 from HongChangMo/round-01

Round 01 - 사용자 관리 기능 PR 작성

Author: HongChangMo

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

@@ -0,0 +1,49 @@
+package com.loopers.application.user;
+
+import com.loopers.domain.user.Gender;
+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 accountUser( String userId, String email, String birthdate, Gender gender ) {
+
+        UserModel user = userService.accountUser(userId, email, birthdate, gender);
+        return UserInfo.from(user);
+
+    }
+
+    public UserInfo getUserInfo(String userId) {
+        UserModel user = userService.getUserByUserId(userId);
+
+        if(user == null) {
+            throw new CoreException(ErrorType.NOT_FOUND, "해당 ID를 가진 회원이 존재하지 않습니다.");
+        }
+
+        return UserInfo.from(user);
+    }
+
+    public Integer getUserPoint(String userId) {
+        UserModel findUser = userService.getUserPointByUserId(userId);
+
+        if (findUser == null ) {
+            throw new CoreException(ErrorType.NOT_FOUND, "해당 ID를 가진 회원이 존재하지 않습니다.");
+        }
+
+        return findUser.getPoint();
+    }
+
+    public UserInfo chargeUserPoint(String userId, Integer chargePoint) {
+        UserModel findUser = userService.chargePointByUserId(userId, chargePoint);
+
+        return UserInfo.from(findUser);
+    }
+}

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

@@ -0,0 +1,17 @@
+package com.loopers.application.user;
+
+import com.loopers.domain.user.Gender;
+import com.loopers.domain.user.UserModel;
+
+public record UserInfo(Long id, String userId, String email, String birthdate, Gender gender, Integer point) {
+    public static UserInfo from(UserModel userModel) {
+        return new UserInfo(
+                userModel.getId(),
+                userModel.getUserId(),
+                userModel.getEmail(),
+                userModel.getBirthdate(),
+                userModel.getGender(),
+                userModel.getPoint()
+        );
+    }
+}

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

@@ -0,0 +1,13 @@
+package com.loopers.domain.user;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
+public enum Gender {
+    MALE("M"),
+    FEMALE("F");
+
+    private final String gender;
+}

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

@@ -0,0 +1,61 @@
+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.*;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor
+@Entity
+@Table(name = "users")
+@Getter
+public class UserModel extends BaseEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+    private String userId;
+    private String email;
+    private String birthdate;
+
+    @Enumerated( EnumType.STRING )
+    private Gender gender;
+    private Integer point = 0;
+
+    @Builder
+    public UserModel(String userId, String email, String birthdate, Gender gender) {
+
+        validUserInfo(userId, email, birthdate);
+
+        this.userId = userId;
+        this.email = email;
+        this.birthdate = birthdate;
+        this.gender = gender;
+    }
+
+    private static void validUserInfo(String userId, String email, String birthdate) {
+        if( !userId.matches("^[a-zA-Z0-9]{1,10}$") ) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "유저 ID 형식 오류");
+        }
+
+        if (!email.matches("^[\\w\\.]+@[\\w\\.]+\\.[a-zA-Z]{2,}$")) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "이메일 형식 오류");
+        }
+
+        if (!birthdate.matches("^\\d{4}-\\d{2}-\\d{2}$")) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "생년월일 형식 오류");
+        }
+    }
+
+    protected void chargePoint(Integer point) {
+
+        if( point <= 0 ) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "충전할 포인트는 1 이상의 정수여야 합니다.");
+        }
+
+        this.point += point;
+    }
+}

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

@@ -0,0 +1,12 @@
+package com.loopers.domain.user;
+
+import java.util.Optional;
+
+public interface UserRepository {
+
+    boolean existsByUserId(String userId);
+
+    UserModel save(UserModel userModel);
+
+    Optional<UserModel> findUserByUserId(String userId);
+}

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

@@ -0,0 +1,57 @@
+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;
+
+@RequiredArgsConstructor
+@Component
+public class UserService {
+
+    private final UserRepository userRepository;
+
+
+    @Transactional
+    public UserModel accountUser(String userId, String email, String birthdate, Gender gender) {
+
+        if( userRepository.existsByUserId(userId) ) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "이미 존재하는 ID 입니다.");
+        }
+
+        UserModel user = UserModel.builder()
+                .userId(userId)
+                .email(email)
+                .birthdate(birthdate)
+                .gender(gender)
+                .build();
+
+        return userRepository.save(user);
+    }
+
+    @Transactional( readOnly = true )
+    public UserModel getUserByUserId(String userId) {
+        return userRepository.findUserByUserId(userId)
+                .orElse(null);
+    }
+
+    @Transactional( readOnly = true )
+    public UserModel getUserPointByUserId(String userId) {
+        return userRepository.findUserByUserId(userId)
+                .orElse(null);
+    }
+
+    @Transactional
+    public UserModel chargePointByUserId(String notExistsUserId, Integer chargePoint) {
+
+        UserModel findUser = userRepository.findUserByUserId(notExistsUserId)
+                .orElseThrow(
+                        () -> new CoreException(ErrorType.NOT_FOUND, "해당 ID 의 회원이 존재하지 않아 포인트 충전이 실패하였습니다.")
+                );
+
+        findUser.chargePoint(chargePoint);
+
+        return findUser;
+    }
+}

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

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

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

@@ -0,0 +1,33 @@
+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 UserModel save(UserModel userModel) {
+
+        return userJpaRepository.save(userModel);
+    }
+
+    @Override
+    public Optional<UserModel> findUserByUserId(String userId) {
+        UserModel user = userJpaRepository.findByUserId(userId);
+
+        return Optional.ofNullable(user);
+    }
+
+    @Override
+    public boolean existsByUserId(String userId) {
+        return userJpaRepository.existsByUserId(userId);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/interfaces/api/ApiControllerAdvice.java

@@ -8,6 +8,8 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.ResponseEntity;
 import org.springframework.http.converter.HttpMessageNotReadableException;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.MissingRequestHeaderException;
 import org.springframework.web.bind.MissingServletRequestParameterException;
 import org.springframework.web.bind.annotation.ExceptionHandler;
 import org.springframework.web.bind.annotation.RestControllerAdvice;
@@ -38,6 +40,15 @@ public ResponseEntity<ApiResponse<?>> handleBadRequest(MethodArgumentTypeMismatc
         return failureResponse(ErrorType.BAD_REQUEST, message);
     }
 
+    @ExceptionHandler
+    public ResponseEntity<ApiResponse<?>> handleBadRequest(MethodArgumentNotValidException e) {
+        String name = e.getObjectName();
+        String type = e.getTypeMessageCode();
+
+        String message = String.format("요청 파라미터 '%s' (타입: %s)의 값이(가) 잘못되었습니다.", name, type);
+        return failureResponse(ErrorType.BAD_REQUEST, message);
+    }
+
     @ExceptionHandler
     public ResponseEntity<ApiResponse<?>> handleBadRequest(MissingServletRequestParameterException e) {
         String name = e.getParameterName();
@@ -46,6 +57,15 @@ public ResponseEntity<ApiResponse<?>> handleBadRequest(MissingServletRequestPara
         return failureResponse(ErrorType.BAD_REQUEST, message);
     }
 
+    @ExceptionHandler
+    public ResponseEntity<ApiResponse<?>> handleBadRequest(MissingRequestHeaderException e) {
+        String name = e.getHeaderName();
+        String type = e.getTypeMessageCode();
+
+        String message = String.format("필수 요청 헤더 '%s' (타입: %s)가 누락되었습니다.", name, type);
+        return failureResponse(ErrorType.BAD_REQUEST, message);
+    }
+
     @ExceptionHandler
     public ResponseEntity<ApiResponse<?>> handleBadRequest(HttpMessageNotReadableException e) {
         String errorMessage;

apps/commerce-api/src/main/java/com/loopers/interfaces/api/user/UserV1ApiSpec.java

@@ -0,0 +1,53 @@
+package com.loopers.interfaces.api.user;
+
+import com.loopers.interfaces.api.ApiResponse;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.enums.ParameterIn;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+public interface UserV1ApiSpec {
+    @Operation(
+            summary = "회원 가입",
+            description = "새로운 사용자를 등록한다."
+    )
+    ApiResponse<UserV1DTO.UserResponse> accountUser(
+            @Schema(name = "회원 가입", description = "회원 가입시 필요한 사용자 정보")
+            UserV1DTO.UserRequest request
+    );
+
+    @Operation(
+            summary = "회원 조회",
+            description = "해당 ID에 해당하는 유저 정보를 반환한다."
+    )
+    ApiResponse<UserV1DTO.UserResponse> getUser(
+            @Schema(name = "회원 조회", description = "조회할 회원의 ID")
+            String userId
+    );
+
+    @Operation(
+            summary = "회원 포인트 조회",
+            description = "해당 ID에 해당하는 유저의 포인트 정보를 반환한다."
+    )
+    ApiResponse<UserV1DTO.UserPointResponse> getUserPoint(
+            @Schema(name = "회원 포인트 조회", description = "조회할 회원의 ID")
+            String userId,
+            @Parameter(
+                    name = "X-USER-ID",
+                    description = "요청 헤더로 전달되는 회원 ID",
+                    in = ParameterIn.HEADER,
+                    required = true
+            )
+            String headerUserId
+    );
+
+    @Operation(
+            summary = "회원 포인트 충전",
+            description = "해당 ID에 해당하는 유저의 포인트를 충전한다."
+    )
+    ApiResponse<UserV1DTO.UserPointResponse> chargeUserPoint(
+            @Schema(name = "회원 포인트 충전", description = "조회할 회원의 ID, 충전할 포인트")
+            UserV1DTO.UserPointRequest request
+    );
+
+}