Merge pull request #201 from PSR-Co/feat/#197-getChatRooms

[feat] 채팅방 목록 조회 API

src/main/kotlin/com/psr/psr/chat/controller/ChatController.kt

@@ -1,6 +1,7 @@
 package com.psr.psr.chat.controller
 
 import com.psr.psr.chat.dto.request.ChatMessageReq
+import com.psr.psr.chat.dto.response.GetChatRoomsRes
 import com.psr.psr.chat.service.ChatService
 import com.psr.psr.global.dto.BaseResponse
 import com.psr.psr.global.jwt.UserAccount
@@ -78,12 +79,29 @@ class ChatController(
             )]
     )
     @PostMapping("/{chatRoomId}")
-    fun createChatMessage(@AuthenticationPrincipal userAccount: UserAccount,
-                          @Parameter(description = "(Long) 채팅방 id", example = "1") @PathVariable chatRoomId: Long,
-                          @RequestBody @Valid request: ChatMessageReq
+    fun createChatMessage(
+        @AuthenticationPrincipal userAccount: UserAccount,
+        @Parameter(description = "(Long) 채팅방 id", example = "1") @PathVariable chatRoomId: Long,
+        @RequestBody @Valid request: ChatMessageReq
     ): BaseResponse<Unit> {
         return BaseResponse(chatService.createChatMessage(userAccount.getUser(), chatRoomId, request))
     }
 
 
+    /**
+     * 채팅방 목록 조회
+     */
+    @Operation(summary = "채팅방 목록 조회(박소정)", description = "채팅방 목록을 조회한다.")
+    @ApiResponses(
+        value = [
+            ApiResponse(responseCode = "200", description = "요청에 성공했습니다.")]
+    )
+    @GetMapping("/rooms")
+    fun getChatRooms(
+        @AuthenticationPrincipal userAccount: UserAccount
+    ): BaseResponse<GetChatRoomsRes?> {
+        return BaseResponse(chatService.getChatRooms(userAccount.getUser()));
+    }
+
+
 }

src/main/kotlin/com/psr/psr/chat/dto/response/ChatRoomRes.kt

@@ -0,0 +1,53 @@
+package com.psr.psr.chat.dto.response
+
+import com.fasterxml.jackson.annotation.JsonFormat
+import com.psr.psr.chat.entity.ChatMessage
+import com.psr.psr.chat.entity.ChatRoom
+import com.psr.psr.user.entity.User
+import com.querydsl.core.annotations.QueryProjection
+import io.swagger.v3.oas.annotations.media.Schema
+import java.time.LocalDateTime
+
+data class ChatRoomRes @QueryProjection constructor(
+    @Schema(description = "채팅방 id", example = "1")
+    val chatRoomId: Long,
+
+    @Schema(description = "프로필 이미지", example = "imgUrl")
+    val profileImgUrl: String? = null,
+
+    @Schema(description = "닉네임", example = "마리")
+    val nickname: String,
+
+    @Schema(description = "최근 메시지", example = "안녕하세요!")
+    val message: String? = null,
+
+    @Schema(description = "최근 메시지 날짜", example = "11.30")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "MM.dd")
+    val date: LocalDateTime? = null,
+
+    @Schema(description = "본인이 메시지 읽음 여부", example = "false")
+    val isRead: Boolean,
+
+    @Schema(description = "읽지 않은 메시지 수 (없으면 0)", example = "3")
+    val numOfUnread: Int? = null
+
+) {
+    companion object {
+        fun toDto(chatRoom: ChatRoom, chatMessage: ChatMessage, partner: User, numOfUnread: Int): ChatRoomRes {
+            val isRead: Boolean =
+                if (chatMessage.senderUser == partner) chatMessage.isRead
+                else true
+
+            return ChatRoomRes(
+                chatRoom.id!!,
+                partner.imgUrl,
+                partner.nickname,
+                chatMessage.message,
+                chatMessage.createdAt,
+                isRead,
+                numOfUnread
+            )
+
+        }
+    }
+}

src/main/kotlin/com/psr/psr/chat/dto/response/GetChatRoomsRes.kt

@@ -0,0 +1,15 @@
+package com.psr.psr.chat.dto.response
+
+import com.querydsl.core.annotations.QueryProjection
+import io.swagger.v3.oas.annotations.media.Schema
+
+data class GetChatRoomsRes @QueryProjection constructor(
+    @Schema(description = "채팅방 리스트")
+    val noticeLists: List<ChatRoomRes>?
+) {
+    companion object {
+        fun toDto(response: MutableList<ChatRoomRes>): GetChatRoomsRes? {
+            return GetChatRoomsRes(response)
+        }
+    }
+}

src/main/kotlin/com/psr/psr/chat/entity/ChatMessage.kt

@@ -19,9 +19,12 @@ data class ChatMessage(
     var chatRoom: ChatRoom,
 
     @NotNull
-    var message: String
+    var message: String,
 
-) : BaseEntity() {
+    @NotNull
+    var isRead: Boolean = false,
+
+    ) : BaseEntity() {
     companion object {
         fun toEntity(user: User, chatRoom: ChatRoom, message: String): ChatMessage {
             return ChatMessage(

src/main/kotlin/com/psr/psr/chat/entity/ChatRoom.kt

@@ -20,7 +20,7 @@ data class ChatRoom(
 
         @OneToOne
         @JoinColumn(nullable = false, name = "order_id")
-        var order: Order?
+        var order: Order
 
 ) : BaseEntity() {
         fun leave(user: User) {

src/main/kotlin/com/psr/psr/chat/repository/ChatMessageCustom.kt

@@ -0,0 +1,11 @@
+package com.psr.psr.chat.repository
+
+import com.psr.psr.chat.dto.response.GetChatRoomsRes
+import com.psr.psr.chat.entity.ChatRoom
+import com.psr.psr.user.entity.User
+
+
+interface ChatMessageCustom {
+    fun getRecentChat(user: User, chatRooms: List<ChatRoom>): GetChatRoomsRes?
+
+}

src/main/kotlin/com/psr/psr/chat/repository/ChatMessageRepository.kt

@@ -5,5 +5,5 @@ import org.springframework.data.jpa.repository.JpaRepository
 import org.springframework.stereotype.Repository
 
 @Repository
-interface ChatMessageRepository : JpaRepository<ChatMessage, Long> {
+interface ChatMessageRepository : JpaRepository<ChatMessage, Long>, ChatMessageCustom {
 }

src/main/kotlin/com/psr/psr/chat/repository/ChatMessageRepositoryImpl.kt

@@ -0,0 +1,54 @@
+package com.psr.psr.chat.repository
+
+import com.psr.psr.chat.dto.response.ChatRoomRes
+import com.psr.psr.chat.dto.response.GetChatRoomsRes
+import com.psr.psr.chat.entity.ChatMessage
+import com.psr.psr.chat.entity.ChatRoom
+import com.psr.psr.chat.entity.QChatMessage.chatMessage
+import com.psr.psr.global.Constant.UserStatus.UserStatus.ACTIVE_STATUS
+import com.psr.psr.user.entity.User
+import com.querydsl.jpa.impl.JPAQueryFactory
+import org.springframework.stereotype.Component
+
+@Component
+class ChatMessageRepositoryImpl(
+    private val queryFactory: JPAQueryFactory
+) : ChatMessageCustom {
+    override fun getRecentChat(user: User, chatRooms: List<ChatRoom>): GetChatRoomsRes? {
+
+        val response: MutableList<ChatRoomRes> = mutableListOf()
+
+        for (chatRoom in chatRooms) {
+            val chat: ChatMessage = queryFactory
+                .selectFrom(chatMessage)
+                .where(
+                    chatMessage.chatRoom.eq(chatRoom),
+                    chatMessage.status.eq(ACTIVE_STATUS),
+                )
+                .orderBy(chatMessage.updatedAt.desc())
+                .fetchFirst()
+
+            val numOfUnread: Int = queryFactory
+                .select(chatMessage)
+                .from(chatMessage)
+                .where(
+                    chatMessage.chatRoom.eq(chatRoom),
+                    chatMessage.status.eq(ACTIVE_STATUS),
+                    chatMessage.isRead.eq(false),
+                    !chatMessage.senderUser.eq(user)
+                )
+                .fetch()
+                .size
+
+            val partner: User =
+                if (user == chatRoom.order.user) chatRoom.order.product.user
+                else chatRoom.order.user
+
+            val chatRoomRes: ChatRoomRes = ChatRoomRes.toDto(chatRoom, chat, partner, numOfUnread)
+            response.add(chatRoomRes)
+        }
+
+        return GetChatRoomsRes.toDto(response)
+    }
+
+}

src/main/kotlin/com/psr/psr/chat/repository/ChatRoomCustom.kt

@@ -0,0 +1,10 @@
+package com.psr.psr.chat.repository
+
+import com.psr.psr.chat.entity.ChatRoom
+import com.psr.psr.user.entity.User
+
+
+interface ChatRoomCustom {
+    fun getChatRooms(user: User): List<ChatRoom>?
+
+}

src/main/kotlin/com/psr/psr/chat/repository/ChatRoomRepository.kt

@@ -1,13 +1,12 @@
 package com.psr.psr.chat.repository
 
 import com.psr.psr.chat.entity.ChatRoom
-import com.psr.psr.order.entity.Order
 import com.psr.psr.user.entity.User
 import org.springframework.data.jpa.repository.JpaRepository
 import org.springframework.stereotype.Repository
 
 @Repository
-interface ChatRoomRepository: JpaRepository<ChatRoom, Long> {
+interface ChatRoomRepository : JpaRepository<ChatRoom, Long>, ChatRoomCustom {
     fun deleteBySenderUser(user: User)
     fun deleteByReceiverUser(user: User)
     fun findByIdAndStatus(chatRoomId: Long, activeStatus: String): ChatRoom?

src/main/kotlin/com/psr/psr/chat/repository/ChatRoomRepositoryImpl.kt

@@ -0,0 +1,25 @@
+package com.psr.psr.chat.repository
+
+import com.psr.psr.chat.entity.ChatRoom
+import com.psr.psr.chat.entity.QChatRoom.chatRoom
+import com.psr.psr.global.Constant.UserStatus.UserStatus.ACTIVE_STATUS
+import com.psr.psr.user.entity.User
+import com.querydsl.jpa.impl.JPAQueryFactory
+import org.springframework.stereotype.Component
+
+@Component
+class ChatRoomRepositoryImpl(
+    private val queryFactory: JPAQueryFactory
+) : ChatRoomCustom {
+    override fun getChatRooms(user: User): List<ChatRoom> {
+        return queryFactory
+            .selectFrom(chatRoom)
+            .where(
+                chatRoom.status.eq(ACTIVE_STATUS),
+                (chatRoom.senderUser.eq(user)).or(chatRoom.receiverUser.eq(user))
+            )
+            .orderBy(chatRoom.updatedAt.desc())
+            .fetch()
+    }
+
+}

src/main/kotlin/com/psr/psr/chat/service/ChatService.kt

@@ -1,6 +1,7 @@
 package com.psr.psr.chat.service
 
 import com.psr.psr.chat.dto.request.ChatMessageReq
+import com.psr.psr.chat.dto.response.GetChatRoomsRes
 import com.psr.psr.chat.entity.ChatMessage
 import com.psr.psr.chat.entity.ChatRoom
 import com.psr.psr.chat.repository.ChatMessageRepository
@@ -36,7 +37,7 @@ class ChatService(
     }
 
     private fun checkChatRoom(chatRoom: ChatRoom) {
-        if(chatRoom.senderUser==null && chatRoom.receiverUser==null)
+        if (chatRoom.senderUser == null && chatRoom.receiverUser == null)
             chatRoomRepository.delete(chatRoom)
     }
 
@@ -46,4 +47,10 @@ class ChatService(
             ?: throw BaseException(BaseResponseCode.NOT_FOUND_CHATROOM)
         chatMessageRepository.save(ChatMessage.toEntity(user, chatRoom, request.message))
     }
+
+    fun getChatRooms(user: User): GetChatRoomsRes? {
+        val chatRooms: List<ChatRoom>? = chatRoomRepository.getChatRooms(user)
+        if (chatRooms?.isEmpty() == true) return null;
+        return chatMessageRepository.getRecentChat(user, chatRooms!!)
+    }
 }