diff --git a/src/main/java/com/manchui/domain/service/ChatMessageService.java b/src/main/java/com/manchui/domain/service/ChatMessageService.java index 1ba53a4..a213243 100644 --- a/src/main/java/com/manchui/domain/service/ChatMessageService.java +++ b/src/main/java/com/manchui/domain/service/ChatMessageService.java @@ -85,10 +85,13 @@ public Mono findChatList(CustomUserDetails customUserD if (chatRoomUser.isEmpty()) { // 채팅방 첫입장 - chatRoomUserUpdatedAt = chatRoomUserRepository.save(new ChatRoomUser(user, chatRoom)).getUser().getUpdatedAt(); - chatMessageRepository.save(new ChatMessage(roomId, ChatMessageType.ENTER, user.getName(), user.getName() + " 님이 입장 하셨습니다.", LocalDateTime.now())).block(); + ChatRoomUser savedChatRoomUser = chatRoomUserRepository.save(new ChatRoomUser(user, chatRoom)); + chatRoomUserRepository.flush(); + chatRoomUserUpdatedAt = savedChatRoomUser.getUpdatedAt(); + + chatMessageRepository.save(new ChatMessage(roomId, ChatMessageType.ENTER, user.getName(), user.getName() + " 님이 입장 하셨습니다.", chatRoomUserUpdatedAt)).block(); rabbitTemplate.convertAndSend("chat.exchange", "room." + roomId, new ChatMessageResponse( - user.getName(), user.getName() + " 님이 입장 하셨습니다.", ChatMessageType.ENTER, LocalDateTime.now())); + user.getName(), user.getName() + " 님이 입장 하셨습니다.", ChatMessageType.ENTER, chatRoomUserUpdatedAt)); }else if(chatRoomUser.get().getDeletedAt() != null){ // 채팅방 재입장 chatRoomUser.get().restore();