[Feature] system messages 구현

manabom/build.gradle

@@ -75,6 +75,9 @@ dependencies {
 	implementation 'org.flywaydb:flyway-core'
 	implementation 'org.flywaydb:flyway-database-postgresql'
 
+	//api 문서
+	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.8.17'
+
 
 }
 

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/event/ChatSystemMessageEvent.java

@@ -0,0 +1,40 @@
+package mannabom_server.manabom.application.chat.dto.event;
+
+import mannabom_server.manabom.application.chat.message.SystemMessageType;
+
+import java.util.List;
+import java.util.Map;
+
+public record ChatSystemMessageEvent(
+        Long roomId,
+        SystemMessageType type,
+        Long actorUserId,
+        List<Long> recipientUserIds,
+        Map<String, Object> data,
+        boolean pushEnabled
+) {
+    public ChatSystemMessageEvent {
+        recipientUserIds = recipientUserIds == null ? null : List.copyOf(recipientUserIds);
+        data = data == null ? Map.of() : Map.copyOf(data);
+    }
+
+    public static ChatSystemMessageEvent of(
+            Long roomId,
+            SystemMessageType type,
+            Long actorUserId,
+            List<Long> recipientUserIds,
+            Map<String, Object> data
+    ) {
+        return new ChatSystemMessageEvent(roomId, type, actorUserId, recipientUserIds, data, true);
+    }
+
+    public static ChatSystemMessageEvent withoutPush(
+            Long roomId,
+            SystemMessageType type,
+            Long actorUserId,
+            List<Long> recipientUserIds,
+            Map<String, Object> data
+    ) {
+        return new ChatSystemMessageEvent(roomId, type, actorUserId, recipientUserIds, data, false);
+    }
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatMessageEvent.java

@@ -4,6 +4,8 @@
 import lombok.Getter;
 
 import java.time.Instant;
+import java.util.List;
+import java.util.Map;
 
 //메세지 보내진 사실을 모든 참여자들에게 보내는 이벤트 서버->클
 @Getter
@@ -12,8 +14,14 @@ public class ChatMessageEvent {
     private Long roomId;
 
     private Long senderUserId;
+    private Long actorUserId;
+    private List<Long> recipientUserIds;
     private String messageType;
+    private String systemEventType;
+    private String systemTitle;
+    private String actorNickname;
     private String content;
+    private Map<String, Object> data;
 
     private Long messageId;
     private String clientMessageId;

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatMessageResponse.java

@@ -5,13 +5,19 @@
 import mannabom_server.manabom.domain.chat.entity.ChatMessage;
 
 import java.time.Instant;
+import java.util.Map;
 
 @Getter
 @Builder
 public class ChatMessageResponse {
     private Long messageId;
     private String content;
     private String messageType;
+    private String systemEventType;
+    private String systemTitle;
+    private Long actorUserId;
+    private String actorNickname;
+    private Map<String, Object> data;
     private Instant createdAt;
 
     private Long senderId;
@@ -21,8 +27,13 @@ public static ChatMessageResponse of(ChatMessage msg){
                 .messageId(msg.getId())
                 .createdAt(msg.getCreatedAt())
                 .messageType(msg.getType().name())
-                .senderId(msg.getUser().getUserId())
+                .senderId(msg.getUser() != null ? msg.getUser().getUserId() : null)
                 .content(msg.getContent())
+                .systemEventType(msg.getSystemEventType())
+                .systemTitle(msg.getSystemTitle())
+                .actorUserId(msg.getActorUserId())
+                .actorNickname(msg.getActorNickname())
+                .data(msg.getSystemData())
                 .build();
     }
 }

manabom/src/main/java/mannabom_server/manabom/application/chat/dto/response/ChatRoomListResponse.java

@@ -4,7 +4,7 @@
 import lombok.Getter;
 import mannabom_server.manabom.domain.chat.entity.ChatMessage;
 import mannabom_server.manabom.domain.chat.entity.ChatRoom;
-import mannabom_server.manabom.domain.chat.enums.ChatRoomType;
+import mannabom_server.manabom.domain.chat.enums.ChatMessageType;
 
 import java.time.Instant;
 
@@ -21,10 +21,17 @@ public static ChatRoomListResponse of(ChatRoom room,String roomName, ChatMessage
         return ChatRoomListResponse.builder()
                 .roomId(room.getId())
                 .roomName(roomName)
-                .lastMessage(lastMsg!=null ? lastMsg.getType().getDisplayMessage(lastMsg.getContent()): null )
+                .lastMessage(lastMsg != null ? lastMessagePreview(lastMsg) : null)
                 .lastmessageAt(lastMsg != null ? lastMsg.getCreatedAt() : null)
                 .hasUnreadMessages(hasUnreadMessages)
                 .build();
     }
 
+    private static String lastMessagePreview(ChatMessage message) {
+        if (message.getType() == ChatMessageType.SYSTEM && message.getSystemTitle() != null) {
+            return message.getSystemTitle();
+        }
+        return message.getType().getDisplayMessage(message.getContent());
+    }
+
 }

manabom/src/main/java/mannabom_server/manabom/application/chat/handler/ChatSystemMessageEventHandler.java

@@ -0,0 +1,67 @@
+package mannabom_server.manabom.application.chat.handler;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import mannabom_server.manabom.application.chat.dto.event.ChatSystemMessageEvent;
+import mannabom_server.manabom.application.chat.service.SystemMessageService;
+import mannabom_server.manabom.application.notification.dto.MatchFailureEvent;
+import mannabom_server.manabom.application.notification.dto.MatchFoundEvent;
+import mannabom_server.manabom.application.notification.dto.MatchSuccessEvent;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class ChatSystemMessageEventHandler {
+
+    private final SystemMessageService systemMessageService;
+
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void handleMatchFound(MatchFoundEvent event) {
+        try {
+            systemMessageService.dispatch(
+                    systemMessageService.recordMatchFound(event.matchId(), event.decisionDeadline())
+            );
+        } catch (RuntimeException e) {
+            log.error("매칭 발견 시스템 메시지 처리 실패: matchId={}", event.matchId(), e);
+        }
+    }
+
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void handleMatchFailure(MatchFailureEvent event) {
+        try {
+            systemMessageService.dispatch(systemMessageService.recordMatchFailure(
+                    event.matchId(),
+                    event.triggerUserId(),
+                    Boolean.TRUE.equals(event.isByTimeout())
+            ));
+        } catch (RuntimeException e) {
+            log.error("매칭 실패 시스템 메시지 처리 실패: matchId={}", event.matchId(), e);
+        }
+    }
+
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void handleMatchSuccess(MatchSuccessEvent event) {
+        try {
+            systemMessageService.dispatch(systemMessageService.recordMatchSuccess(
+                    event.matchId(),
+                    event.triggerUserId(),
+                    event.chatRoomId()
+            ));
+        } catch (RuntimeException e) {
+            log.error("매칭 성사 시스템 메시지 처리 실패: matchId={}", event.matchId(), e);
+        }
+    }
+
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void handleRoomSystemMessage(ChatSystemMessageEvent event) {
+        try {
+            systemMessageService.dispatch(systemMessageService.recordForRoom(event));
+        } catch (RuntimeException e) {
+            log.error("채팅방 시스템 메시지 처리 실패: roomId={}, type={}",
+                    event.roomId(), event.type(), e);
+        }
+    }
+}

manabom/src/main/java/mannabom_server/manabom/application/chat/message/SystemMessageType.java

@@ -0,0 +1,175 @@
+package mannabom_server.manabom.application.chat.message;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import org.springframework.util.StringUtils;
+
+import java.util.Map;
+
+@Getter
+@RequiredArgsConstructor
+public enum SystemMessageType {
+    MATCHING_STARTED(
+            "매칭을 시작했어요",
+            "팀장님이 매칭을 시작하셨어요."
+    ),
+    MATCHING_STOPPED(
+            "매칭을 중단했어요",
+            "팀장님이 매칭을 중단하셨어요."
+    ),
+    MATCH_FOUND(
+            "미팅할 상대 팀을 찾았어요‼️✨",
+            "수락 가능 시간 안에 팀원들과 상의해 주세요.\n"
+                    + "팀장은 상단 헤더에서 수락을 확정해 주세요.\n"
+                    + "수락 가능 시간이 지나면 자동 거절돼요."
+    ),
+    MATCH_REJECTED_BY_LEADER(
+            "아쉽네요",
+            "팀장님이 매칭을 거절했어요.\n새로운 상대 팀을 찾고 있어요."
+    ),
+    MATCH_REJECTED_BY_OPPONENT(
+            "아쉽네요",
+            "이번에는 상대 팀과 연결되지 않았어요.\n다시 매칭 신청을 눌러주세요!"
+    ),
+    MATCH_TIMED_OUT(
+            "응답 시간이 지났어요",
+            "수락 가능 시간이 지나 매칭이 자동으로 거절됐어요."
+    ),
+    OPPONENT_MATCH_TIMED_OUT(
+            "아쉽네요",
+            "상대 팀의 응답 시간이 지나 매칭이 취소됐어요.\n다시 매칭 신청을 눌러주세요!"
+    ),
+    MATCH_COMPLETED(
+            "미팅이 성사되었어요 🎉🎉",
+            "이 채팅방은 더 이상 이용하실 수 없습니다.\n"
+                    + "새로운 채팅방으로 이동하여 상대 팀과 이야기를 나눠보세요!"
+    ),
+    CHAT_ROOM_CREATED(
+            "매칭이 성사되었어요 🎉",
+            "서로 인사를 나누고 즐거운 대화를 시작해 보세요."
+    ),
+    MEETING_VERIFICATION_STARTED(
+            "만남인증 시작",
+            "만남인증이 시작되었어요."
+    ),
+    MEETING_VERIFICATION_SUCCEEDED(
+            "만남인증 성공",
+            "만남인증이 완료되었어요."
+    ),
+    MEETING_VERIFICATION_FAILED(
+            "만남인증 실패",
+            "만남인증이 완료되지 않았어요."
+    ),
+    MEETING_CANCELLATION_VOTE_STARTED(
+            "미팅 취소 투표",
+            "미팅 취소 투표가 시작되었어요.\n"
+                    + "모든 인원이 취소에 동의하면 채팅방이 사라지고 채팅방에서 사용된 팅은 위약금으로 제외하고 환불해드려요."
+    ),
+    MEETING_CANCELLATION_APPROVED(
+            "미팅 취소 투표 결과",
+            "모두가 동의하여 미팅과 채팅방이 취소되었어요."
+    ),
+    MEETING_CANCELLATION_REJECTED(
+            "미팅 취소 투표 결과",
+            "모두가 동의하지 않아 취소되지 않았어요."
+    ),
+    MEETING_CANCELLATION_EXPIRED(
+            "미팅 취소 투표 결과",
+            "투표 시간이 지나 미팅이 취소되지 않았어요."
+    ),
+    PHOTO_REQUESTED(
+            "프로필 공개 요청",
+            "수락할 시 서로의 프로필이 공개됩니다.\n헤더를 내려 수락하기 버튼을 눌러주세요."
+    ),
+    PHOTO_REQUEST_ACCEPTED(
+            "서로의 프로필이 공개되었습니다! ✨",
+            "서로의 프로필을 눌러 더 다양한 대화를 나눠보세요!"
+    ),
+    PHOTO_REQUEST_REJECTED(
+            "프로필 공개가 거절되었어요",
+            "아직 상대가 조심스러운가 봐요.\n더 대화를 나눠보세요!"
+    );
+
+    private final String defaultTitle;
+    private final String defaultBody;
+
+    public RenderedSystemMessage render(String actorNickname, Map<String, Object> data) {
+        String nickname = StringUtils.hasText(actorNickname) ? actorNickname : "사용자";
+        int participantCount = number(data, "participantCount");
+        int verifiedParticipantCount = data != null && data.containsKey("verifiedParticipantCount")
+                ? number(data, "verifiedParticipantCount")
+                : participantCount;
+
+        return switch (this) {
+            case MATCHING_STARTED -> message(
+                    defaultTitle,
+                    "팀장 " + nickname + "님이 매칭을 시작하셨어요."
+            );
+            case MATCHING_STOPPED -> message(
+                    defaultTitle,
+                    "팀장 " + nickname + "님이 매칭을 중단하셨어요."
+            );
+            case MATCH_REJECTED_BY_LEADER -> message(
+                    defaultTitle,
+                    "팀장 " + nickname + "님이 매칭을 거절했어요.\n새로운 상대 팀을 찾고 있어요."
+            );
+            case MEETING_VERIFICATION_STARTED -> message(
+                    defaultTitle,
+                    nickname + "님이 만남인증을 시작했어요."
+            );
+            case MEETING_VERIFICATION_SUCCEEDED -> message(
+                    defaultTitle,
+                    nickname + "님의 참여로 만남인증이 완료되었어요.\n"
+                            + "참여인원 : " + verifiedParticipantCount + "명"
+            );
+            case MEETING_VERIFICATION_FAILED -> message(
+                    defaultTitle,
+                    nickname + "님이 시작한 만남인증이 완료되지 않았어요.\n"
+                            + "참여인원 : " + participantCount + "명"
+            );
+            case MEETING_CANCELLATION_VOTE_STARTED -> message(
+                    defaultTitle,
+                    nickname + "님이 미팅 취소 투표를 시작하셨어요!\n"
+                            + "모든 인원이 취소에 동의하면 채팅방이 사라지고 채팅방에서 사용된 팅은 위약금으로 제외하고 환불해드려요."
+            );
+            case PHOTO_REQUESTED -> message(
+                    nickname + "님이 프로필 공개를 요청했어요",
+                    defaultBody
+            );
+            case PHOTO_REQUEST_ACCEPTED -> message(
+                    defaultTitle,
+                    nickname + "님이 프로필 공개 요청을 수락했어요.\n" + defaultBody
+            );
+            case PHOTO_REQUEST_REJECTED -> message(
+                    defaultTitle,
+                    nickname + "님이 아직은 조심스러운가 봐요.\n더 대화를 나눠보세요!"
+            );
+            default -> message(defaultTitle, defaultBody);
+        };
+    }
+
+    private static int number(Map<String, Object> data, String key) {
+        if (data == null) {
+            return 0;
+        }
+        Object value = data.get(key);
+        if (value instanceof Number number) {
+            return number.intValue();
+        }
+        if (value instanceof String stringValue) {
+            try {
+                return Integer.parseInt(stringValue);
+            } catch (NumberFormatException ignored) {
+                return 0;
+            }
+        }
+        return 0;
+    }
+
+    private static RenderedSystemMessage message(String title, String body) {
+        return new RenderedSystemMessage(title, body);
+    }
+
+    public record RenderedSystemMessage(String title, String body) {
+    }
+}