[FEAT] 안읽은 채팅 개수 (#158)

src/main/java/com/skyhorsemanpower/chatService/chat/application/ChatService.java

@@ -2,6 +2,7 @@
 
 import com.skyhorsemanpower.chatService.chat.data.dto.BeforeChatRoomDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.ChatRoomMemberResponseDto;
+import com.skyhorsemanpower.chatService.chat.data.dto.UnReadChatCountResponseDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.UpdateProfileImageRequestDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.ChatRoomTitleResponseDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.LeaveChatRoomDto;
@@ -38,4 +39,6 @@ PreviousChatResponseVo getPreviousChat(String roomNumber, LocalDateTime enterTim
     void updateProfileImage(UpdateProfileImageRequestDto updateProfileImageRequestDto);
 
     List<ChatRoomMemberResponseDto> getChatRoomMembers(String roomNumber);
+
+    UnReadChatCountResponseDto getUnreadChatCount(String roomNumber, String uuid);
 }

src/main/java/com/skyhorsemanpower/chatService/chat/application/ChatServiceImp.java

@@ -3,6 +3,7 @@
 import com.mongodb.client.model.changestream.OperationType;
 import com.skyhorsemanpower.chatService.chat.data.dto.BeforeChatRoomDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.ChatRoomMemberResponseDto;
+import com.skyhorsemanpower.chatService.chat.data.dto.UnReadChatCountResponseDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.UpdateProfileImageRequestDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.ChatRoomTitleResponseDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.LeaveChatRoomDto;
@@ -395,4 +396,19 @@ public List<ChatRoomMemberResponseDto> getChatRoomMembers(String roomNumber) {
         }
     }
 
+    @Override
+    public UnReadChatCountResponseDto getUnreadChatCount(String roomNumber, String uuid) {
+        ChatRoomMember chatRoomMember = chatRoomMemberRepository
+            .findByMemberUuidAndRoomNumber(uuid, roomNumber)
+            .orElseThrow(() -> new CustomException(ResponseStatus.WRONG_CHATROOM_AND_MEMBER));
+        // 해당 채팅방에서 uuid의 lastReadTime 이후의 채팅 개수
+        Long count = mongoTemplate.count(
+            Query.query(
+                Criteria.where("roomNumber").is(roomNumber).and("createdAt")
+                    .gt(chatRoomMember.getLastReadTime())), "chat");
+        return UnReadChatCountResponseDto.builder()
+            .count(count)
+            .build();
+    }
+
 }

src/main/java/com/skyhorsemanpower/chatService/chat/data/dto/UnReadChatCountResponseDto.java

@@ -0,0 +1,17 @@
+package com.skyhorsemanpower.chatService.chat.data.dto;
+
+import com.skyhorsemanpower.chatService.chat.data.vo.UnReadChatCountResponseVo;
+import lombok.Builder;
+import lombok.Getter;
+
+@Getter
+@Builder
+public class UnReadChatCountResponseDto {
+    Long count;
+
+    public static UnReadChatCountResponseVo dtoToVo(UnReadChatCountResponseDto unReadChatCountResponseDto) {
+        return UnReadChatCountResponseVo.builder()
+            .count(unReadChatCountResponseDto.getCount())
+            .build();
+    }
+}

src/main/java/com/skyhorsemanpower/chatService/chat/data/vo/UnReadChatCountResponseVo.java

@@ -0,0 +1,10 @@
+package com.skyhorsemanpower.chatService.chat.data.vo;
+
+import lombok.Builder;
+import lombok.Getter;
+
+@Getter
+@Builder
+public class UnReadChatCountResponseVo {
+    private Long count;
+}

src/main/java/com/skyhorsemanpower/chatService/chat/presentation/ChatController.java

@@ -5,6 +5,7 @@
 import com.skyhorsemanpower.chatService.chat.data.dto.ChatRoomTitleResponseDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.LeaveChatRoomDto;
 import com.skyhorsemanpower.chatService.chat.data.dto.SendChatRequestDto;
+import com.skyhorsemanpower.chatService.chat.data.dto.UnReadChatCountResponseDto;
 import com.skyhorsemanpower.chatService.chat.data.vo.ChatRoomMemberResponseVo;
 import com.skyhorsemanpower.chatService.chat.data.vo.ChatRoomResponseVo;
 import com.skyhorsemanpower.chatService.chat.data.vo.ChatRoomTitleResponseVo;
@@ -13,6 +14,7 @@
 import com.skyhorsemanpower.chatService.chat.data.vo.LeaveChatRoomRequestVo;
 import com.skyhorsemanpower.chatService.chat.data.vo.PreviousChatResponseVo;
 import com.skyhorsemanpower.chatService.chat.data.vo.SendChatRequestVo;
+import com.skyhorsemanpower.chatService.chat.data.vo.UnReadChatCountResponseVo;
 import com.skyhorsemanpower.chatService.common.SuccessResponse;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -141,12 +143,22 @@ public SuccessResponse<ChatRoomTitleResponseVo> chatRoomTitle(
 
     @GetMapping(value = "/roomNumber/{roomNumber}/member")
     @Operation(summary = "채팅방 멤버 목록", description = "채팅방 내에서 채팅방 멤버들을 표시합니다")
-    public SuccessResponse<List<ChatRoomMemberResponseVo>> chatRoomMembers(@PathVariable(value = "roomNumber") String roomNumber) {
-        List<ChatRoomMemberResponseDto> chatRoomMemberResponseDtos = chatService.getChatRoomMembers(roomNumber);
+    public SuccessResponse<List<ChatRoomMemberResponseVo>> chatRoomMembers(
+        @PathVariable(value = "roomNumber") String roomNumber) {
+        List<ChatRoomMemberResponseDto> chatRoomMemberResponseDtos = chatService.getChatRoomMembers(
+            roomNumber);
         List<ChatRoomMemberResponseVo> chatRoomMemberResponseVos = chatRoomMemberResponseDtos.stream()
             .map(ChatRoomMemberResponseDto::dtoToVo)
             .toList();
         return new SuccessResponse<>(chatRoomMemberResponseVos);
     }
 
+    @GetMapping(value = "/roomNumber/{roomNumber}/unread")
+    @Operation(summary = "안 읽은 채팅 개수", description = "채팅 리스트에서 안 읽은 채팅 개수 최초 조회")
+    public SuccessResponse<UnReadChatCountResponseVo> countUnreadChats(
+        @PathVariable(value = "roomNumber") String roomNumber,
+        @RequestHeader String uuid) {
+        return new SuccessResponse<>(UnReadChatCountResponseDto.dtoToVo(chatService
+            .getUnreadChatCount(roomNumber, uuid)));
+    }
 }