feature : 그룹 채팅방 목록 조회

yyytir777 · yyytir777 · commit e2bbff02f17a · 2026-01-11T01:22:54.000+09:00
diff --git a/src/main/java/ita/tinybite/domain/chat/controller/ChatController.java b/src/main/java/ita/tinybite/domain/chat/controller/ChatController.java
@@ -7,6 +7,7 @@
 import ita.tinybite.domain.chat.service.ChatService;
 import ita.tinybite.global.response.APIResponse;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.messaging.handler.annotation.MessageMapping;
 import org.springframework.messaging.simp.SimpMessageHeaderAccessor;
 import org.springframework.messaging.simp.SimpMessagingTemplate;
@@ -17,6 +18,7 @@
 import static ita.tinybite.global.response.APIResponse.*;
 
 
+@Slf4j
 @Controller
 @RequiredArgsConstructor
 public class ChatController {
@@ -42,6 +44,7 @@ public void sendMessage(ChatMessageReqDto req,
         // message 저장
         ChatMessage saved = chatService.saveMessage(message);
 
+        log.info("[chat log] send message: {}, [{}] - {}", saved.getSenderId(), saved.getMessageType(), saved.getContent());
         // subscribe 한 사용자에게 전송
         simpMessagingTemplate.convertAndSend("/subscribe/chat/room/" + saved.getChatRoomId(), ChatMessageResDto.of(saved, userId));
 
diff --git a/src/main/java/ita/tinybite/domain/chat/controller/ChatRoomController.java b/src/main/java/ita/tinybite/domain/chat/controller/ChatRoomController.java
@@ -1,5 +1,6 @@
 package ita.tinybite.domain.chat.controller;
 
+import ita.tinybite.domain.chat.dto.res.GroupChatRoomResDto;
 import ita.tinybite.domain.chat.dto.res.OneToOneChatRoomResDto;
 import ita.tinybite.domain.chat.service.ChatRoomService;
 import ita.tinybite.global.response.APIResponse;
@@ -10,6 +11,8 @@
 
 import java.util.List;
 
+import static ita.tinybite.global.response.APIResponse.success;
+
 @RestController
 @RequestMapping("/api/v1/chatroom")
 @RequiredArgsConstructor
@@ -19,6 +22,11 @@ public class ChatRoomController {
 
     @GetMapping("/one-to-one")
     public APIResponse<List<OneToOneChatRoomResDto>> getOneToOneChatRooms() {
-        return APIResponse.success(chatRoomService.getOneToOneRooms());
+        return success(chatRoomService.getOneToOneRooms());
+    }
+
+    @GetMapping("/group")
+    public APIResponse<List<GroupChatRoomResDto>> getGroupChatRooms() {
+        return success(chatRoomService.getGroupRooms());
     }
 }
diff --git a/src/main/java/ita/tinybite/domain/chat/dto/res/GroupChatRoomResDto.java b/src/main/java/ita/tinybite/domain/chat/dto/res/GroupChatRoomResDto.java
@@ -0,0 +1,34 @@
+package ita.tinybite.domain.chat.dto.res;
+
+import ita.tinybite.domain.chat.entity.ChatRoom;
+import ita.tinybite.domain.chat.enums.ChatRoomType;
+import ita.tinybite.domain.party.enums.PartyStatus;
+import lombok.Builder;
+
+@Builder
+public record GroupChatRoomResDto(
+        Long chatRoomId,
+        ChatRoomType roomType,
+        String partyTitle,
+        String partyImage,
+        String recentTime,
+        Integer currentParticipantCnt,
+        PartyStatus partyStatus,
+        String recentMessage,
+        Long unreadMessageCnt
+) {
+
+    public static GroupChatRoomResDto of(ChatRoom chatRoom, String timeAgo, String recentMessage, Long unreadCnt) {
+        return GroupChatRoomResDto.builder()
+                .chatRoomId(chatRoom.getId())
+                .roomType(chatRoom.getType())
+                .partyTitle(chatRoom.getParty().getTitle())
+                .partyImage(chatRoom.getParty().getThumbnailImage())
+                .recentTime(timeAgo)
+                .currentParticipantCnt(chatRoom.getParty().getCurrentParticipants())
+                .partyStatus(chatRoom.getParty().getStatus())
+                .recentMessage(recentMessage)
+                .unreadMessageCnt(unreadCnt)
+                .build();
+    }
+}
diff --git a/src/main/java/ita/tinybite/domain/chat/entity/ChatRoomMember.java b/src/main/java/ita/tinybite/domain/chat/entity/ChatRoomMember.java
@@ -47,4 +47,8 @@ public void leave() {
         this.isActive = false;
         this.leftAt = LocalDateTime.now();
     }
+
+    public void updateLastReadAt() {
+        this.lastReadAt = LocalDateTime.now();
+    }
 }
diff --git a/src/main/java/ita/tinybite/domain/chat/service/ChatRoomService.java b/src/main/java/ita/tinybite/domain/chat/service/ChatRoomService.java
@@ -1,18 +1,17 @@
 package ita.tinybite.domain.chat.service;
 
 import ita.tinybite.domain.auth.service.SecurityProvider;
+import ita.tinybite.domain.chat.dto.res.GroupChatRoomResDto;
 import ita.tinybite.domain.chat.dto.res.OneToOneChatRoomResDto;
 import ita.tinybite.domain.chat.entity.ChatMessage;
 import ita.tinybite.domain.chat.entity.ChatRoom;
 import ita.tinybite.domain.chat.entity.ChatRoomMember;
 import ita.tinybite.domain.chat.enums.ChatRoomType;
 import ita.tinybite.domain.chat.repository.ChatMessageRepository;
 import ita.tinybite.domain.chat.repository.ChatRoomMemberRepository;
-import ita.tinybite.domain.chat.repository.ChatRoomRepository;
 import ita.tinybite.domain.party.entity.PartyParticipant;
 import ita.tinybite.domain.party.enums.ParticipantStatus;
 import ita.tinybite.domain.party.repository.PartyParticipantRepository;
-import ita.tinybite.domain.party.repository.PartyRepository;
 import ita.tinybite.domain.user.entity.User;
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.domain.Limit;
@@ -23,6 +22,7 @@
 import java.util.List;
 
 @Service
+@Transactional(readOnly = true)
 @RequiredArgsConstructor
 public class ChatRoomService {
 
@@ -32,7 +32,6 @@ public class ChatRoomService {
     private final PartyParticipantRepository partyParticipantRepository;
 
 
-    @Transactional(readOnly = true)
     public List<OneToOneChatRoomResDto> getOneToOneRooms() {
         User user = securityProvider.getCurrentUser();
 
@@ -65,6 +64,33 @@ public List<OneToOneChatRoomResDto> getOneToOneRooms() {
                 .toList();
     }
 
+
+    public List<GroupChatRoomResDto> getGroupRooms() {
+        User user = securityProvider.getCurrentUser();
+
+        // 유저가 참여 중인 chatRoom (이면서 그룹 채팅만)
+        List<ChatRoom> chatRooms = chatRoomMemberRepository.findByUser(user).stream()
+                .map(ChatRoomMember::getChatRoom)
+                .filter(chatRoom -> chatRoom.getType().equals(ChatRoomType.GROUP)).toList();
+
+        return chatRooms.stream()
+                .map(chatRoom -> {
+                    // chatRoom으로 가장 최신의 메시지 조회
+                    ChatMessage recentMessage = chatMessageRepository.findByChatRoomIdOrderByCreatedAtDesc(chatRoom.getId(), Limit.of(1));
+                    String timeAgo = getTimeAgo(chatRoom.getCreatedAt());
+
+                    ChatRoomMember chatRoomMember = chatRoomMemberRepository.findByChatRoomAndUser(chatRoom, user).orElseThrow();
+
+                    // 마지막으로 읽은 시점을 기점으로 몇 개의 메시지가 안 읽혔는지 확인
+                    long unreadCnt = chatMessageRepository.countByChatRoomIdAndCreatedAtAfterAndSenderIdNot(chatRoom.getId(), chatRoomMember.getLastReadAt(), user.getUserId());
+
+                    return GroupChatRoomResDto.of(chatRoom, timeAgo, recentMessage.getContent(), unreadCnt);
+                })
+                .toList();
+    }
+
+
+
     private static String getTimeAgo(LocalDateTime then) {
         LocalDateTime now = LocalDateTime.now();
 
diff --git a/src/main/java/ita/tinybite/domain/chat/service/ChatService.java b/src/main/java/ita/tinybite/domain/chat/service/ChatService.java
@@ -9,6 +9,7 @@
 import ita.tinybite.domain.chat.enums.ChatRoomType;
 import ita.tinybite.domain.chat.enums.MessageType;
 import ita.tinybite.domain.chat.repository.ChatMessageRepository;
+import ita.tinybite.domain.chat.repository.ChatRoomMemberRepository;
 import ita.tinybite.domain.chat.repository.ChatRoomRepository;
 import ita.tinybite.domain.notification.service.facade.NotificationFacade;
 import ita.tinybite.domain.user.entity.User;
@@ -38,6 +39,7 @@ public class ChatService {
     private final ChatSubscribeRegistry registry;
     private final NotificationFacade notificationFacade;
     private final SecurityProvider securityProvider;
+    private final ChatRoomMemberRepository chatRoomMemberRepository;
 
     public ChatMessage saveMessage(ChatMessage message) {
         return chatMessageRepository.save(message);
@@ -97,16 +99,21 @@ public void sendNotification(ChatMessage message, Long chatRoomId) {
     }
 
     public ChatMessageSliceResDto getChatMessage(Long roomId, int page, int size) {
-        Long currentUserId = securityProvider.getCurrentUser().getUserId();
+        User user = securityProvider.getCurrentUser();
 
         Pageable pageable = PageRequest.of(page, size, Sort.by(Sort.Direction.DESC, "createdAt"));
         Slice<ChatMessage> messages = chatMessageRepository.findByChatRoomId(roomId, pageable);
 
+        ChatRoom chatRoom = chatRoomRepository.findById(roomId).orElseThrow();
+        ChatRoomMember chatRoomMember = chatRoomMemberRepository.findByChatRoomAndUser(chatRoom, user).orElseThrow();
+
+        chatRoomMember.updateLastReadAt();
+
         List<ChatMessageResDto> list = messages
                 .getContent()
                 .stream()
                 .map(chatMessage ->
-                    ChatMessageResDto.of(chatMessage, currentUserId)
+                    ChatMessageResDto.of(chatMessage, user.getUserId())
                 )
                 .toList();
 

Original file line number	Diff line number	Diff line change
`@@ -47,4 +47,8 @@ public void leave() {`
`47`	`47`	`this.isActive = false;`
`48`	`48`	`this.leftAt = LocalDateTime.now();`
`49`	`49`	`}`
	`50`	`+`
	`51`	`+ public void updateLastReadAt() {`
	`52`	`+ this.lastReadAt = LocalDateTime.now();`
	`53`	`+ }`
`50`	`54`	`}`