[fix]: 1:1 → 1:N 관계 변경 및 중복 채팅방 방지 로직 추가 #44

Author: Hyeromon

src/main/java/org/dfbf/soundlink/domain/chat/entity/ChatRoom.java

@@ -32,7 +32,7 @@ public class ChatRoom {
     @JoinColumn (name = "request_user_id")
     private User requestUserId;
 
-    @OneToOne
+    @ManyToOne
     @JoinColumn(name = "record_id")
     private EmotionRecord recordId;
 

src/main/java/org/dfbf/soundlink/domain/chat/repository/ChatRoomRepository.java

@@ -1,7 +1,10 @@
 package org.dfbf.soundlink.domain.chat.repository;
 
 import org.dfbf.soundlink.domain.chat.entity.ChatRoom;
+import org.dfbf.soundlink.domain.emotionRecord.entity.EmotionRecord;
+import org.dfbf.soundlink.domain.user.entity.User;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 public interface ChatRoomRepository extends JpaRepository<ChatRoom, Long> {
+    boolean existsByRequestUserIdAndRecordId(User requestUserId, EmotionRecord recordId);
 }

src/main/java/org/dfbf/soundlink/domain/chat/service/ChatRoomService.java

@@ -43,6 +43,10 @@ public ResponseResult createChatRoom(@AuthenticationPrincipal Long userId, Long
             //감정기록 조회
             EmotionRecord emotionRecord = emotionRecordRepository.findById(recordId)
                     .orElseThrow(EmotionRecordNotFoundException::new);
+            //이미 존재하는 채팅방인지 확인
+            if(chatRoomRepository.existsByRequestUserIdAndRecordId(requestUserId,emotionRecord)){
+                return new ResponseResult(ErrorCode.CHAT_FAILED, "이미 존재하는 채팅방입니다.");
+            }
 
             Long responseUserId = emotionRecord.getUser().getUserId();
 
@@ -62,9 +66,6 @@ public ResponseResult createChatRoom(@AuthenticationPrincipal Long userId, Long
             redisTemplate.opsForValue().set("Room::"+chatRoom.getChatRoomId(), String.valueOf(chatReqDto));
 
             return new ResponseResult(ErrorCode.SUCCESS, chatRoom);
-        }
-        catch (DataIntegrityViolationException e) {
-            return new ResponseResult(ErrorCode.CHAT_FAILED, "채팅방 생성 실패: 이미 존재하는 데이터입니다."); // recordId 값 중복 시
         } catch (Exception e) {
             return new ResponseResult(ErrorCode.INTERNAL_SERVER_ERROR, e.getMessage());
         }