[Feat] 독서메이트 조회 api 개발

src/main/java/konkuk/thip/common/exception/code/ErrorCode.java

@@ -51,7 +51,7 @@ public enum ErrorCode implements ResponseCode {
     BOOK_KEYWORD_REQUIRED(HttpStatus.BAD_REQUEST, 80007, "검색어는 필수 입력값입니다."),
     BOOK_PAGE_NUMBER_INVALID(HttpStatus.BAD_REQUEST, 80008, "페이지 번호는 1 이상의 값이어야 합니다."),
     BOOK_NAVER_API_ISBN_NOT_FOUND(HttpStatus.BAD_REQUEST, 80009, "네이버 API 에서 ISBN으로 검색한 결과가 존재하지 않습니다."),
-    BOOK_NOT_FOUND(HttpStatus.BAD_REQUEST, 80010, "존재하지 않는 BOOK 입니다."),
+    BOOK_NOT_FOUND(HttpStatus.NOT_FOUND, 80010, "존재하지 않는 BOOK 입니다."),
     BOOK_ALREADY_SAVED(HttpStatus.BAD_REQUEST, 80011, "사용자가 이미 저장한 책입니다."),
     DUPLICATED_BOOKS_IN_COLLECTION(HttpStatus.INTERNAL_SERVER_ERROR, 80012, "중복된 책이 존재합니다."),
     BOOK_NOT_SAVED_CANNOT_DELETE(HttpStatus.BAD_REQUEST, 80013, "사용자가 저장하지 않은 책은 저장삭제 할 수 없습니다."),

src/main/java/konkuk/thip/room/adapter/in/web/RoomQueryController.java

@@ -4,8 +4,10 @@
 import konkuk.thip.common.security.annotation.UserId;
 import konkuk.thip.room.adapter.in.web.response.RoomRecruitingDetailViewResponse;
 import konkuk.thip.room.adapter.in.web.response.RoomGetHomeJoinedListResponse;
+import konkuk.thip.room.adapter.in.web.response.RoomGetMemberListResponse;
 import konkuk.thip.room.adapter.in.web.response.RoomSearchResponse;
 import konkuk.thip.room.application.port.in.RoomGetHomeJoinedListUseCase;
+import konkuk.thip.room.application.port.in.RoomGetMemberListUseCase;
 import konkuk.thip.room.application.port.in.RoomSearchUseCase;
 import jakarta.validation.Valid;
 import konkuk.thip.room.adapter.in.web.request.RoomVerifyPasswordRequest;
@@ -23,9 +25,10 @@
 public class RoomQueryController {
 
     private final RoomSearchUseCase roomSearchUseCase;
+    private final RoomGetHomeJoinedListUseCase roomGetHomeJoinedListUseCase;
     private final RoomVerifyPasswordUseCase roomVerifyPasswordUseCase;
     private final RoomShowRecruitingDetailViewUseCase roomShowRecruitingDetailViewUseCase;
-    private final RoomGetHomeJoinedListUseCase roomGetHomeJoinedListUseCase;
+    private final RoomGetMemberListUseCase roomGetMemberListUseCase;
 
     @GetMapping("/rooms/search")
     public BaseResponse<RoomSearchResponse> searchRooms(
@@ -62,4 +65,10 @@ public BaseResponse<RoomGetHomeJoinedListResponse> getHomeJoinedRooms(@UserId fi
                         .page(page).build()));
     }
 
+    // 독서메이트 조회
+    @GetMapping("/rooms/{roomId}/users")
+    public BaseResponse<RoomGetMemberListResponse> getRoomMemberList(@PathVariable("roomId") final Long roomId){
+        return BaseResponse.ok(roomGetMemberListUseCase.getRoomMemberList(roomId));
+    }
+
 }

src/main/java/konkuk/thip/room/adapter/in/web/response/RoomGetMemberListResponse.java

@@ -0,0 +1,20 @@
+package konkuk.thip.room.adapter.in.web.response;
+
+import lombok.Builder;
+
+import java.util.List;
+
+@Builder
+public record RoomGetMemberListResponse(
+
+        List<MemberSearchResult> userList
+){
+        @Builder
+        public record MemberSearchResult(
+                Long userId,
+                String nickname,
+                String imageUrl,
+                String alias,
+                int subscriberCount
+        ) {}
+}

src/main/java/konkuk/thip/room/application/port/in/RoomGetMemberListUseCase.java

@@ -0,0 +1,7 @@
+package konkuk.thip.room.application.port.in;
+
+import konkuk.thip.room.adapter.in.web.response.RoomGetMemberListResponse;
+
+public interface RoomGetMemberListUseCase {
+    RoomGetMemberListResponse getRoomMemberList(Long roomId);
+}

src/main/java/konkuk/thip/room/application/service/RoomGetMemberListService.java

@@ -0,0 +1,72 @@
+package konkuk.thip.room.application.service;
+
+import konkuk.thip.room.adapter.in.web.response.RoomGetMemberListResponse;
+import konkuk.thip.room.application.port.in.RoomGetMemberListUseCase;
+import konkuk.thip.room.application.port.out.RoomCommandPort;
+import konkuk.thip.room.domain.Room;
+import konkuk.thip.user.application.port.out.FollowingQueryPort;
+import konkuk.thip.user.application.port.out.UserCommandPort;
+import konkuk.thip.user.application.port.out.UserRoomCommandPort;
+import konkuk.thip.user.domain.User;
+import konkuk.thip.user.domain.UserRoom;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+
+@Service
+@RequiredArgsConstructor
+public class RoomGetMemberListService implements RoomGetMemberListUseCase {
+
+    private final RoomCommandPort roomCommandPort;
+    private final UserRoomCommandPort userRoomCommandPort;
+    private final UserCommandPort userCommandPort;
+    private final FollowingQueryPort followingQueryPort;
+
+    @Override
+    @Transactional(readOnly = true)
+    public RoomGetMemberListResponse getRoomMemberList(Long roomId) {
+
+        // 1. 방 검증 및 방 조회
+        Room room = roomCommandPort.findById(roomId);
+
+        // 2. 방 참여자(UserRoom) 전체 조회
+        List<UserRoom> userRooms = userRoomCommandPort.findAllByRoomId(room.getId());
+
+
+        // 3. 참여자 userId 목록 추출
+        List<Long> userIds = userRooms.stream()
+                .map(UserRoom::getUserId)
+                .toList();
+
+        // 4. 배치 쿼리로 유저 정보, 팔로워 수 조회
+        Map<Long, User> userMap = userCommandPort.findByIds(userIds);
+        Map<Long, Integer> subscriberCountMap = followingQueryPort.countByFollowingUserIds(userIds);
+
+        // 5. 각 userRoom에 대해 DTO 조립
+        List<RoomGetMemberListResponse.MemberSearchResult> userList = userRooms.stream()
+                .map(userRoom -> {
+                    Long userId = userRoom.getUserId();
+                    User user = userMap.get(userId);
+                    int subscriberCount = subscriberCountMap.getOrDefault(userId, 0);
+
+                    return RoomGetMemberListResponse.MemberSearchResult.builder()
+                            .userId(userId)
+                            .nickname(user.getNickname())
+                            .imageUrl(user.getAlias().getImageUrl())
+                            .alias(user.getAlias().getValue())
+                            .subscriberCount(subscriberCount)
+                            .build();
+                })
+                .toList();
+
+        // 6. DTO 반환
+        return RoomGetMemberListResponse.builder()
+                .userList(userList)
+                .build();
+    }
+
+
+}

src/main/java/konkuk/thip/user/adapter/out/persistence/FollowingJpaRepository.java

@@ -0,0 +1,7 @@
+package konkuk.thip.user.adapter.out.persistence;
+
+import konkuk.thip.user.adapter.out.jpa.FollowingJpaEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface FollowingJpaRepository extends JpaRepository<FollowingJpaEntity, Long>,FollowingQueryRepository {
+}

src/main/java/konkuk/thip/user/adapter/out/persistence/FollowingQueryPersistenceAdapter.java

@@ -0,0 +1,22 @@
+package konkuk.thip.user.adapter.out.persistence;
+
+import konkuk.thip.user.adapter.out.mapper.FollowingMapper;
+import konkuk.thip.user.application.port.out.FollowingQueryPort;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Map;
+
+@Repository
+@RequiredArgsConstructor
+public class FollowingQueryPersistenceAdapter implements FollowingQueryPort {
+
+    private final FollowingJpaRepository followingJpaRepository;
+    private final FollowingMapper followingMapper;
+
+    @Override
+    public Map<Long, Integer> countByFollowingUserIds(List<Long> userIds) {
+        return followingJpaRepository.countByFollowingUserIds(userIds);
+    }
+}

src/main/java/konkuk/thip/user/adapter/out/persistence/FollowingQueryRepository.java

@@ -0,0 +1,8 @@
+package konkuk.thip.user.adapter.out.persistence;
+
+import java.util.List;
+import java.util.Map;
+
+public interface FollowingQueryRepository {
+    Map<Long, Integer> countByFollowingUserIds(List<Long> userIds);
+}

src/main/java/konkuk/thip/user/adapter/out/persistence/FollowingQueryRepositoryImpl.java

@@ -0,0 +1,38 @@
+package konkuk.thip.user.adapter.out.persistence;
+
+import com.querydsl.core.Tuple;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import konkuk.thip.user.adapter.out.jpa.QFollowingJpaEntity;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Repository
+@RequiredArgsConstructor
+public class FollowingQueryRepositoryImpl implements FollowingQueryRepository {
+
+    private final JPAQueryFactory jpaQueryFactory;
+
+    // 주어진 userId 리스트에 대해 각 userId의 팔로워(구독자) 수를 집계하여 Map으로 반환
+    public Map<Long, Integer> countByFollowingUserIds(List<Long> userIds) {
+
+        QFollowingJpaEntity following = QFollowingJpaEntity.followingJpaEntity;
+
+        List<Tuple> results = jpaQueryFactory
+                .select(following.followingUserJpaEntity.userId, following.count())
+                .from(following)
+                .where(following.followingUserJpaEntity.userId.in(userIds))
+                .groupBy(following.followingUserJpaEntity.userId)
+                .fetch();
+
+        // 결과를 Map<Long, Integer>로 변환
+        return results.stream()
+                .collect(Collectors.toMap(
+                        tuple -> tuple.get(following.followingUserJpaEntity.userId),
+                        tuple -> tuple.get(following.count()).intValue()
+                ));
+    }
+}

src/main/java/konkuk/thip/user/adapter/out/persistence/UserCommandPersistenceAdapter.java

@@ -9,6 +9,11 @@
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
 import static konkuk.thip.common.exception.code.ErrorCode.ALIAS_NOT_FOUND;
 import static konkuk.thip.common.exception.code.ErrorCode.USER_NOT_FOUND;
 
@@ -37,4 +42,12 @@ public User findById(Long userId) {
 
         return userMapper.toDomainEntity(userJpaEntity);
     }
+
+    @Override
+    public Map<Long, User> findByIds(List<Long> userIds) {
+        List<UserJpaEntity> entities = userJpaRepository.findAllById(userIds);
+        return entities.stream()
+                .map(userMapper::toDomainEntity)
+                .collect(Collectors.toMap(User::getId, Function.identity()));
+    }
 }

src/main/java/konkuk/thip/user/application/port/out/FollowingQueryPort.java

@@ -0,0 +1,9 @@
+package konkuk.thip.user.application.port.out;
+
+import java.util.List;
+import java.util.Map;
+
+public interface FollowingQueryPort {
+    Map<Long, Integer> countByFollowingUserIds(List<Long> userIds);
+}
+

src/main/java/konkuk/thip/user/application/port/out/UserCommandPort.java

@@ -2,8 +2,12 @@
 
 import konkuk.thip.user.domain.User;
 
+import java.util.List;
+import java.util.Map;
+
 public interface UserCommandPort {
 
     Long save(User user);
     User findById(Long userId);
+    Map<Long, User> findByIds(List<Long> userIds);
 }

src/test/java/konkuk/thip/common/util/TestEntityFactory.java

@@ -135,4 +135,11 @@ public static CommentJpaEntity createComment(PostJpaEntity post, UserJpaEntity u
                 .userJpaEntity(user)
                 .build();
     }
+
+    public static FollowingJpaEntity createFollowing(UserJpaEntity user,UserJpaEntity followingUser) {
+        return FollowingJpaEntity.builder()
+                .userJpaEntity(user)
+                .followingUserJpaEntity(followingUser)
+                .build();
+    }
 }