[feat] 진행중인 방 상세보기 api 개발

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

@@ -98,6 +98,7 @@ public enum ErrorCode implements ResponseCode {
      * 140000 : userRoom error
      */
     USER_ROOM_NOT_FOUND(HttpStatus.NOT_FOUND, 140000, "존재하지 않는 USER_ROOM (방과 사용자 관계) 입니다."),
+    USER_NOT_BELONG_TO_ROOM(HttpStatus.BAD_REQUEST, 140001, "현재 모임방에 속하지 않는 유저입니다."),
 
     /**
      * 150000 : Category error

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

@@ -2,17 +2,17 @@
 
 import konkuk.thip.common.dto.BaseResponse;
 import konkuk.thip.common.security.annotation.UserId;
+import konkuk.thip.room.adapter.in.web.response.RoomPlayingDetailViewResponse;
 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.*;
 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;
-import konkuk.thip.room.application.port.in.RoomShowRecruitingDetailViewUseCase;
-import konkuk.thip.room.application.port.in.RoomVerifyPasswordUseCase;
 import konkuk.thip.room.application.port.in.dto.RoomGetHomeJoinedListQuery;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -29,6 +29,7 @@ public class RoomQueryController {
     private final RoomVerifyPasswordUseCase roomVerifyPasswordUseCase;
     private final RoomShowRecruitingDetailViewUseCase roomShowRecruitingDetailViewUseCase;
     private final RoomGetMemberListUseCase roomGetMemberListUseCase;
+    private final RoomShowPlayingDetailViewUseCase roomShowPlayingDetailViewUseCase;
 
     @GetMapping("/rooms/search")
     public BaseResponse<RoomSearchResponse> searchRooms(
@@ -48,6 +49,7 @@ public BaseResponse<Void> verifyRoomPassword(@PathVariable("roomId") final Long
         return BaseResponse.ok(roomVerifyPasswordUseCase.verifyRoomPassword(roomVerifyPasswordRequest.toQuery(roomId)));
     }
 
+    // 모집중인 방 상세보기
     @GetMapping("/rooms/{roomId}/recruiting")
     public BaseResponse<RoomRecruitingDetailViewResponse> getRecruitingRoomDetailView(
             @UserId final Long userId,
@@ -71,4 +73,13 @@ public BaseResponse<RoomGetMemberListResponse> getRoomMemberList(@PathVariable("
         return BaseResponse.ok(roomGetMemberListUseCase.getRoomMemberList(roomId));
     }
 
+    // 진행중인 방 상세보기
+    @GetMapping("/rooms/{roomId}/playing")
+    public BaseResponse<RoomPlayingDetailViewResponse> getPlayingRoomDetailView(
+            @UserId final Long userId,
+            @PathVariable("roomId") final Long roomId
+    ) {
+        return BaseResponse.ok(roomShowPlayingDetailViewUseCase.getPlayingRoomDetailView(userId, roomId));
+    }
+
 }

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

@@ -0,0 +1,37 @@
+package konkuk.thip.room.adapter.in.web.response;
+
+import lombok.Builder;
+
+import java.util.List;
+
+@Builder
+public record RoomPlayingDetailViewResponse(
+        boolean isHost,
+        Long roomId,
+        String roomName,
+        String roomImageUrl,
+        boolean isPublic,
+        String progressStartDate,
+        String progressEndDate,
+        String category,
+        String roomDescription,
+        int memberCount,
+        int recruitCount,
+        String isbn,
+        String bookTitle,
+        String authorName,
+        int currentPage,
+        double userPercentage,
+        List<CurrentVote> currentVotes
+) {
+    public record CurrentVote(
+            String content,
+            int page,
+            boolean isOverview,
+            List<VoteItem> voteItems
+    ) {
+        public record VoteItem(
+                String itemName
+        ) {}
+    }
+}

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

@@ -0,0 +1,8 @@
+package konkuk.thip.room.application.port.in;
+
+import konkuk.thip.room.adapter.in.web.response.RoomPlayingDetailViewResponse;
+
+public interface RoomShowPlayingDetailViewUseCase {
+
+    RoomPlayingDetailViewResponse getPlayingRoomDetailView(Long userId, Long roomId);
+}

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

@@ -0,0 +1,71 @@
+package konkuk.thip.room.application.service;
+
+import konkuk.thip.book.application.port.out.BookCommandPort;
+import konkuk.thip.book.domain.Book;
+import konkuk.thip.common.util.DateUtil;
+import konkuk.thip.room.adapter.in.web.response.RoomPlayingDetailViewResponse;
+import konkuk.thip.room.application.port.in.RoomShowPlayingDetailViewUseCase;
+import konkuk.thip.room.application.port.out.RoomCommandPort;
+import konkuk.thip.room.domain.Room;
+import konkuk.thip.user.application.port.out.UserRoomCommandPort;
+import konkuk.thip.user.domain.RoomParticipants;
+import konkuk.thip.user.domain.UserRoom;
+import konkuk.thip.vote.application.port.out.VoteQueryPort;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+public class RoomShowPlayingDetailViewService implements RoomShowPlayingDetailViewUseCase {
+
+    private static final int TOP_PARTICIPATION_VOTES_COUNT = 3;
+
+    private final RoomCommandPort roomCommandPort;
+    private final BookCommandPort bookCommandPort;
+    private final UserRoomCommandPort userRoomCommandPort;
+    private final VoteQueryPort voteQueryPort;
+
+    @Override
+    @Transactional(readOnly = true)
+    public RoomPlayingDetailViewResponse getPlayingRoomDetailView(Long userId, Long roomId) {
+        // 1. Room 조회, Book 조회
+        Room room = roomCommandPort.findById(roomId);
+        Book book = bookCommandPort.findById(room.getBookId());
+
+        // 2. Room과 연관된 UserRoom 조회, RoomParticipants 일급 컬렉션 생성
+        // TODO. Room 도메인에 memberCount 값 추가된 후 리펙토링
+        List<UserRoom> findByRoomId = userRoomCommandPort.findAllByRoomId(roomId);
+        RoomParticipants roomParticipants = RoomParticipants.from(findByRoomId);
+
+        // 3. 투표 참여율이 가장 높은 투표 조회
+        List<RoomPlayingDetailViewResponse.CurrentVote> topParticipationVotes = voteQueryPort.findTopParticipationVotesByRoom(room, TOP_PARTICIPATION_VOTES_COUNT);
+
+        // 4. response 구성
+        return buildResponse(userId, room, book, roomParticipants, topParticipationVotes);
+    }
+
+    private RoomPlayingDetailViewResponse buildResponse(Long userId, Room room, Book book, RoomParticipants roomParticipants, List<RoomPlayingDetailViewResponse.CurrentVote> topParticipationVotes) {
+        return RoomPlayingDetailViewResponse.builder()
+                .isHost(roomParticipants.isHostOfRoom(userId))
+                .roomId(room.getId())
+                .roomName(room.getTitle())
+                .roomImageUrl(room.getCategory().getImageUrl())
+                .isPublic(room.isPublic())
+                .progressStartDate(DateUtil.formatDate(room.getStartDate()))
+                .progressEndDate(DateUtil.formatDate(room.getEndDate()))
+                .category(room.getCategory().getValue())
+                .roomDescription(room.getDescription())
+                .memberCount(roomParticipants.calculateMemberCount())
+                .recruitCount(room.getRecruitCount())
+                .isbn(book.getIsbn())
+                .bookTitle(book.getTitle())
+                .authorName(book.getAuthorName())
+                .currentPage(roomParticipants.getCurrentPageOfUser(userId))
+                .userPercentage(roomParticipants.getUserPercentageOfUser(userId))
+                .currentVotes(topParticipationVotes)
+                .build();
+    }
+}

src/main/java/konkuk/thip/user/domain/RoomParticipants.java

@@ -1,11 +1,14 @@
 package konkuk.thip.user.domain;
 
+import konkuk.thip.common.exception.InvalidStateException;
 import konkuk.thip.user.adapter.out.jpa.UserRoomRole;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 
 import java.util.List;
 
+import static konkuk.thip.common.exception.code.ErrorCode.USER_NOT_BELONG_TO_ROOM;
+
 @Getter
 @RequiredArgsConstructor
 public class RoomParticipants {
@@ -33,4 +36,20 @@ public boolean isHostOfRoom(Long userId) {
                 .filter(userRoom -> userRoom.getUserId().equals(userId))
                 .anyMatch(userRoom -> userRoom.getUserRoomRole().equals(UserRoomRole.HOST.getType()));
     }
+
+    public int getCurrentPageOfUser(Long userId) {
+        return participants.stream()
+                .filter(userRoom -> userRoom.getUserId().equals(userId))
+                .map(UserRoom::getCurrentPage)
+                .findFirst()
+                .orElseThrow(() -> new InvalidStateException(USER_NOT_BELONG_TO_ROOM));
+    }
+
+    public double getUserPercentageOfUser(Long userId) {
+        return participants.stream()
+                .filter(userRoom -> userRoom.getUserId().equals(userId))
+                .map(UserRoom::getUserPercentage)
+                .findFirst()
+                .orElseThrow(() -> new InvalidStateException(USER_NOT_BELONG_TO_ROOM));
+    }
 }

src/main/java/konkuk/thip/vote/adapter/out/persistence/VoteQueryPersistenceAdapter.java

@@ -1,10 +1,14 @@
 package konkuk.thip.vote.adapter.out.persistence;
 
+import konkuk.thip.room.adapter.in.web.response.RoomPlayingDetailViewResponse;
+import konkuk.thip.room.domain.Room;
 import konkuk.thip.vote.adapter.out.mapper.VoteMapper;
 import konkuk.thip.vote.application.port.out.VoteQueryPort;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 @Repository
 @RequiredArgsConstructor
 public class VoteQueryPersistenceAdapter implements VoteQueryPort {
@@ -17,4 +21,9 @@ public class VoteQueryPersistenceAdapter implements VoteQueryPort {
     public boolean isUserVoted(Long userId, Long voteItemId) {
         return userVoteJpaRepository.existsByUserJpaEntity_UserIdAndVoteItemJpaEntity_VoteItemId(userId, voteItemId);
     }
+
+    @Override
+    public List<RoomPlayingDetailViewResponse.CurrentVote> findTopParticipationVotesByRoom(Room room, int count) {
+        return voteJpaRepository.findTopParticipationVotesByRoom(room.getId(), count);
+    }
 }

src/main/java/konkuk/thip/vote/adapter/out/persistence/VoteQueryRepository.java

@@ -1,10 +1,13 @@
 package konkuk.thip.vote.adapter.out.persistence;
 
+import konkuk.thip.room.adapter.in.web.response.RoomPlayingDetailViewResponse;
 import konkuk.thip.vote.adapter.out.jpa.VoteJpaEntity;
 
 import java.util.List;
 
 public interface VoteQueryRepository {
 
     List<VoteJpaEntity> findVotesByRoom(Long roomId, String type, Integer pageStart, Integer pageEnd, Long userId);
+
+    List<RoomPlayingDetailViewResponse.CurrentVote> findTopParticipationVotesByRoom(Long roomId, int count);
 }

src/main/java/konkuk/thip/vote/adapter/out/persistence/VoteQueryRepositoryImpl.java

@@ -2,7 +2,9 @@
 
 import com.querydsl.core.types.dsl.BooleanExpression;
 import com.querydsl.jpa.impl.JPAQueryFactory;
+import konkuk.thip.room.adapter.in.web.response.RoomPlayingDetailViewResponse;
 import konkuk.thip.user.adapter.out.jpa.QUserJpaEntity;
+import konkuk.thip.vote.adapter.out.jpa.QVoteItemJpaEntity;
 import konkuk.thip.vote.adapter.out.jpa.QVoteJpaEntity;
 import konkuk.thip.vote.adapter.out.jpa.VoteJpaEntity;
 import lombok.RequiredArgsConstructor;
@@ -16,11 +18,12 @@ public class VoteQueryRepositoryImpl implements VoteQueryRepository {
 
     private final JPAQueryFactory jpaQueryFactory;
 
+    private final QVoteJpaEntity vote = QVoteJpaEntity.voteJpaEntity;
+    private final QUserJpaEntity user = QUserJpaEntity.userJpaEntity;
+    private final QVoteItemJpaEntity voteItem = QVoteItemJpaEntity.voteItemJpaEntity;
+
     @Override
     public List<VoteJpaEntity> findVotesByRoom(Long roomId, String type, Integer pageStart, Integer pageEnd, Long userId) {
-        QVoteJpaEntity vote = QVoteJpaEntity.voteJpaEntity;
-        QUserJpaEntity user = QUserJpaEntity.userJpaEntity;
-
         return jpaQueryFactory
                 .select(vote)
                 .from(vote)
@@ -43,4 +46,39 @@ private BooleanExpression filterByType(String type, QVoteJpaEntity post, Long us
         }
         return null;
     }
+
+    @Override
+    public List<RoomPlayingDetailViewResponse.CurrentVote> findTopParticipationVotesByRoom(Long roomId, int count) {
+        // 1. Fetch top votes by total participation count
+        List<VoteJpaEntity> topVotes = jpaQueryFactory
+                .select(vote)
+                .from(vote)
+                .leftJoin(voteItem).on(voteItem.voteJpaEntity.eq(vote))
+                .where(vote.roomJpaEntity.roomId.eq(roomId))
+                .groupBy(vote)
+                .orderBy(voteItem.count.sum().desc())       // 해당 투표에 참여한 총 참여자 수 기준 내림차순 정렬
+                .limit(count)
+                .fetch();
+
+        // 2. Map to DTOs including vote items
+        return topVotes.stream()
+                .map(vote -> {
+                    List<RoomPlayingDetailViewResponse.CurrentVote.VoteItem> voteItems = jpaQueryFactory
+                            .select(voteItem)
+                            .from(voteItem)
+                            .where(voteItem.voteJpaEntity.eq(vote))
+                            .orderBy(voteItem.count.desc())
+                            .fetch()
+                            .stream()
+                            .map(item -> new RoomPlayingDetailViewResponse.CurrentVote.VoteItem(item.getItemName()))
+                            .toList();
+                    return new RoomPlayingDetailViewResponse.CurrentVote(
+                            vote.getContent(),
+                            vote.getPage(),
+                            vote.isOverview(),
+                            voteItems
+                    );
+                })
+                .toList();
+    }
 }

src/main/java/konkuk/thip/vote/application/port/out/VoteQueryPort.java

@@ -1,7 +1,13 @@
 package konkuk.thip.vote.application.port.out;
 
+import konkuk.thip.room.adapter.in.web.response.RoomPlayingDetailViewResponse;
+import konkuk.thip.room.domain.Room;
+
+import java.util.List;
+
 public interface VoteQueryPort {
 
     boolean isUserVoted(Long userId, Long voteId);
 
+    List<RoomPlayingDetailViewResponse.CurrentVote> findTopParticipationVotesByRoom(Room room, int count);
 }