Merge pull request #82 from DorumDorum/feat/#81/동시성-제어-보강-및-상태-정합성-개선

[FEAT] 동시성 제어 보강 및 상태 정합성 개선

Author: KoungQ

src/main/java/com/project/dorumdorum/domain/calendar/application/usecase/LoadCalendarEventsUseCase.java

@@ -19,6 +19,11 @@ public class LoadCalendarEventsUseCase {
     private final CalendarEventService calendarEventService;
     private final CalendarEventMapper calendarEventMapper;
 
+    /**
+     * 기간 내 캘린더 일정 조회
+     * - 시작일~종료일 범위의 일정을 조회
+     * - 응답 DTO 목록으로 변환해 반환
+     */
     public List<CalendarEventResponse> execute(LocalDate startDate, LocalDate endDate) {
         List<CalendarEvent> events = calendarEventService.loadBetween(startDate, endDate);
         return calendarEventMapper.toResponseList(events);

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/GetChatRoomMembersUseCase.java

@@ -24,6 +24,12 @@ public class GetChatRoomMembersUseCase {
     private final RoommateService roommateService;
     private final UserService userService;
 
+    /**
+     * 채팅방 멤버 목록 조회
+     * - 요청 사용자가 채팅방 멤버인지 검증
+     * - 멤버별 닉네임과 방장 여부를 조회
+     * - 방장이 먼저 보이도록 정렬해 반환
+     */
     @Transactional(readOnly = true)
     public List<ChatRoomMemberResponse> execute(String chatRoomNo, String requestingUserNo) {
         ChatRoom chatRoom = chatRoomService.findByChatRoomNo(chatRoomNo);

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/GetOrCreateDirectChatRoomUseCase.java

@@ -23,9 +23,9 @@ public class GetOrCreateDirectChatRoomUseCase {
 
     /**
      * 지원자-방장 1:1 채팅방 조회 또는 생성
-     * - 이미 존재하면 기존 채팅방 반환
-     * - 없으면 생성 후 반환
-     * - 호출자는 방장 또는 지원자여야 함
+     * - 호출자가 방장 또는 지원자인지 검증
+     * - 기존 채팅방이 있으면 그대로 반환
+     * - 없으면 생성 후 양쪽 사용자를 입장시켜 반환
      */
     public String execute(String callerUserNo, String roomNo, String applicantUserNo) {
         Room room = roomService.findById(roomNo);
@@ -46,7 +46,10 @@ public String execute(String callerUserNo, String roomNo, String applicantUserNo
     }
 
     /**
-     * 이벤트 리스너에서 사용 — 인증 없이 채팅방 생성 (방 지원 시 자동 생성)
+     * 지원자-방장 1:1 채팅방 선생성
+     * - 이벤트 리스너에서 인증 없이 호출
+     * - 기존 채팅방이 있으면 그대로 반환
+     * - 없으면 생성 후 양쪽 사용자를 입장시켜 반환
      */
     public String createIfAbsent(String roomNo, String applicantUserNo, String hostUserNo) {
         return chatRoomService.findDirectChatRoom(roomNo, applicantUserNo)

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/JoinChatRoomUseCase.java

@@ -29,10 +29,10 @@ public class JoinChatRoomUseCase {
     private final SimpMessagingTemplate messagingTemplate;
 
     /**
-     * 방장이 룸메이트 승인(RoommateAcceptedEvent) → 채팅방 입장
-     * - 채팅방 없으면 생성 후 방장 + 신규 멤버 입장
-     * - 채팅방 있으면 신규 멤버만 입장 (중복 방지)
-     * - 입장 시스템 메시지 저장
+     * 룸메이트 승인 이벤트 처리
+     * - 그룹 채팅방이 없으면 생성하고 방장을 먼저 입장
+     * - 승인된 사용자를 중복 없이 입장 처리
+     * - 입장 시스템 메시지를 저장하고 실시간 전송
      */
     @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
     @Transactional(propagation = Propagation.REQUIRES_NEW)

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/LeaveChatRoomUseCase.java

@@ -34,42 +34,72 @@ public class LeaveChatRoomUseCase {
     private final UserService userService;
     private final SimpMessagingTemplate messagingTemplate;
 
+    /**
+     * 채팅방 퇴장 처리
+     * - 채팅방 멤버를 조회하고 방장 퇴장 가능 여부를 검증
+     * - 그룹 채팅방이면 룸메이트와 방 인원수를 함께 갱신
+     * - 마지막 멤버면 방을 삭제하고, 아니면 퇴장 메시지를 전송
+     */
     @Transactional
     public void execute(String chatRoomNo, String userNo) {
         ChatRoom chatRoom = chatRoomService.findByChatRoomNo(chatRoomNo);
         ChatRoomMember member = chatRoomMemberService.findByChatRoomAndUserNo(chatRoom, userNo);
         long memberCount = chatRoomMemberService.countByChatRoom(chatRoom);
 
-        if (memberCount > 1) {
-            boolean isHost = roommateService.isHostOfRoom(userNo, chatRoom.getRoomNo());
-            if (isHost) {
-                throw new RestApiException(HOST_CANNOT_LEAVE);
-            }
+        if (ChatRoomType.GROUP.equals(chatRoom.getChatRoomType())) {
+            leaveGroupChatRoom(chatRoom, member, userNo, memberCount);
+            return;
+        }
+
+        leaveDirectChatRoom(chatRoom, member, userNo, memberCount);
+    }
+
+    private void leaveGroupChatRoom(ChatRoom chatRoom, ChatRoomMember member, String userNo, long memberCount) {
+        Room room = roomService.findByIdForUpdate(chatRoom.getRoomNo());
+
+        if (memberCount > 1 && roommateService.isHost(userNo, room)) {
+            throw new RestApiException(HOST_CANNOT_LEAVE);
         }
 
         chatRoomMemberService.leave(member);
+        roommateService.leaveRoom(userNo, chatRoom.getRoomNo());
+        room.minusCurrentMate();
 
-        // GROUP 채팅방인 경우에만 룸메이트 삭제 및 방 인원수 감소
-        if (ChatRoomType.GROUP.equals(chatRoom.getChatRoomType())) {
-            roommateService.leaveRoom(userNo, chatRoom.getRoomNo());
-            Room room = roomService.findById(chatRoom.getRoomNo());
-            room.minusCurrentMate();
+        if (memberCount == 1) {
+            chatMessageService.deleteAllByChatRoom(chatRoom.getChatRoomNo());
+            chatRoomService.delete(chatRoom);
+            return;
         }
 
+        sendLeaveSystemMessage(chatRoom, userNo);
+    }
+
+    private void leaveDirectChatRoom(ChatRoom chatRoom, ChatRoomMember member, String userNo, long memberCount) {
+        if (memberCount > 1 && roommateService.isHostOfRoom(userNo, chatRoom.getRoomNo())) {
+            throw new RestApiException(HOST_CANNOT_LEAVE);
+        }
+
+        chatRoomMemberService.leave(member);
+
         if (memberCount == 1) {
-            // 마지막 멤버가 나가는 경우: 메시지 먼저 삭제 후 채팅방 삭제 (FK 제약 위반 방지)
             chatMessageService.deleteAllByChatRoom(chatRoom.getChatRoomNo());
             chatRoomService.delete(chatRoom);
-        } else {
-            User leavingUser = userService.findById(userNo);
-            String displayName = (leavingUser.getNickname() != null && !leavingUser.getNickname().isBlank())
-                    ? leavingUser.getNickname() : leavingUser.getName();
-            String content = displayName + "가 퇴장했습니다.";
-            ChatMessage message = chatMessageService.save(chatRoom, "SYSTEM", content, MessageType.SYSTEM, 0);
-            ChatMessageResponse response = new ChatMessageResponse(
-                    message.getMessageNo(), chatRoomNo,
-                    "SYSTEM", null, content, MessageType.SYSTEM.name(), message.getCreatedAt());
-            messagingTemplate.convertAndSend("/topic/chat-room/" + chatRoomNo, response);
+            return;
         }
+
+        sendLeaveSystemMessage(chatRoom, userNo);
+    }
+
+    private void sendLeaveSystemMessage(ChatRoom chatRoom, String userNo) {
+        String chatRoomNo = chatRoom.getChatRoomNo();
+        User leavingUser = userService.findById(userNo);
+        String displayName = (leavingUser.getNickname() != null && !leavingUser.getNickname().isBlank())
+                ? leavingUser.getNickname() : leavingUser.getName();
+        String content = displayName + "가 퇴장했습니다.";
+        ChatMessage message = chatMessageService.save(chatRoom, "SYSTEM", content, MessageType.SYSTEM, 0);
+        ChatMessageResponse response = new ChatMessageResponse(
+                message.getMessageNo(), chatRoomNo,
+                "SYSTEM", null, content, MessageType.SYSTEM.name(), message.getCreatedAt());
+        messagingTemplate.convertAndSend("/topic/chat-room/" + chatRoomNo, response);
     }
 }

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/LoadChatMessagesUseCase.java

@@ -33,6 +33,12 @@ public class LoadChatMessagesUseCase {
     private final UserService userService;
     private static final int LIMIT = 30;
 
+    /**
+     * 채팅 메시지 목록 커서 조회
+     * - 요청 사용자의 채팅방 참여 여부와 입장 시점을 확인
+     * - 커서 기준으로 메시지를 조회
+     * - 발신자 표시명을 보강해 다음 커서와 함께 반환
+     */
     @Transactional(readOnly = true)
     public CursorPage<ChatMessageSummary> execute(String chatRoomNo, String userNo, String cursor) {
         ChatRoom chatRoom = chatRoomService.findByChatRoomNo(chatRoomNo);

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/LoadMyChatRoomsUseCase.java

@@ -14,6 +14,11 @@ public class LoadMyChatRoomsUseCase {
 
     private final ChatRoomService chatRoomService;
 
+    /**
+     * 내 채팅방 목록 조회
+     * - 사용자가 속한 채팅방 목록을 조회
+     * - 최근 메시지 기준 요약 정보로 반환
+     */
     @Transactional(readOnly = true)
     public List<ChatRoomSummary> execute(String userNo) {
         return chatRoomService.findMyChatRooms(userNo);

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/MarkChatRoomReadUseCase.java

@@ -1,10 +1,8 @@
 package com.project.dorumdorum.domain.chat.application.usecase;
 
-import com.project.dorumdorum.domain.chat.domain.entity.ChatRoom;
 import com.project.dorumdorum.domain.chat.domain.entity.ChatRoomMember;
 import com.project.dorumdorum.domain.chat.domain.service.ChatMessageService;
 import com.project.dorumdorum.domain.chat.domain.service.ChatRoomMemberService;
-import com.project.dorumdorum.domain.chat.domain.service.ChatRoomService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -15,14 +13,18 @@
 @RequiredArgsConstructor
 public class MarkChatRoomReadUseCase {
 
-    private final ChatRoomService chatRoomService;
     private final ChatRoomMemberService chatRoomMemberService;
     private final ChatMessageService chatMessageService;
 
+    /**
+     * 채팅방 읽음 처리
+     * - 사용자의 채팅방 멤버 정보를 조회
+     * - 마지막 읽은 시점 이후 메시지의 안 읽은 수를 감소
+     * - 현재 시각으로 마지막 읽은 시점을 갱신
+     */
     @Transactional
     public void execute(String chatRoomNo, String userNo) {
-        ChatRoom chatRoom = chatRoomService.findByChatRoomNo(chatRoomNo);
-        ChatRoomMember member = chatRoomMemberService.findByChatRoomAndUserNo(chatRoom, userNo);
+        ChatRoomMember member = chatRoomMemberService.findByChatRoomNoAndUserNoForUpdate(chatRoomNo, userNo);
 
         LocalDateTime fromTime = member.getLastReadAt() != null
                 ? member.getLastReadAt()

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/SendGroupChatMessageUseCase.java

@@ -31,6 +31,12 @@ public class SendGroupChatMessageUseCase {
     private final NotificationRequestPublisher notificationRequestPublisher;
     private final UserService userService;
 
+    /**
+     * 그룹 채팅 메시지 전송
+     * - 발신자가 채팅방 멤버인지 검증
+     * - 메시지를 저장하고 채팅방 최근 메시지를 갱신
+     * - 웹소켓으로 메시지를 전송하고 다른 멤버에게 알림을 발행
+     */
     @RateLimited(tag = "chat-message", key = "#senderNo + ':' + #chatRoomNo")
     @Transactional
     public void send(String chatRoomNo, String senderNo, String content) {

src/main/java/com/project/dorumdorum/domain/chat/domain/entity/ChatRoom.java

@@ -9,7 +9,6 @@
 import jakarta.persistence.Id;
 import jakarta.persistence.Index;
 import jakarta.persistence.Table;
-import jakarta.persistence.UniqueConstraint;
 import lombok.*;
 
 import java.time.LocalDateTime;
@@ -18,11 +17,7 @@
 @Table(
         indexes = {
                 @Index(name = "idx_chat_room_last_message_at", columnList = "last_message_at")
-        },
-        uniqueConstraints = @UniqueConstraint(
-                name = "uk_chat_room_direct",
-                columnNames = {"room_no", "chat_room_type", "applicant_user_no"}
-        )
+        }
 )
 @Getter
 @NoArgsConstructor(access = AccessLevel.PROTECTED)