Merge pull request #76 from CommitField/feat/#20

Feat/#20

Author: whale22

src/main/java/cmf/commitField/domain/chat/chatMessage/controller/ChatController.java

@@ -0,0 +1,71 @@
+package cmf.commitField.domain.chat.chatMessage.controller;
+
+import cmf.commitField.domain.chat.chatMessage.controller.request.ChatMsgRequest;
+import cmf.commitField.domain.chat.chatMessage.controller.response.ChatMsgResponse;
+import cmf.commitField.domain.chat.chatMessage.dto.ChatMsgDto;
+import cmf.commitField.domain.chat.chatMessage.service.ChatMessageService;
+import cmf.commitField.domain.user.entity.CustomOAuth2User;
+import cmf.commitField.global.error.ErrorCode;
+import cmf.commitField.global.globalDto.GlobalResponse;
+import cmf.commitField.global.security.LoginCheck;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.security.oauth2.client.authentication.OAuth2AuthenticationToken;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/chat")
+public class ChatMessageController {
+
+    private final ChatMessageService chatMessageService;
+
+    @PostMapping("/msg/{roomId}")
+    @LoginCheck
+    public GlobalResponse<Object> sendChat(
+            @PathVariable Long roomId,
+            @RequestBody @Valid ChatMsgRequest message) {
+
+        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+        if (!(authentication instanceof OAuth2AuthenticationToken)) {
+            return GlobalResponse.error(ErrorCode.NOT_AUTHENTICATED);
+        }
+
+        CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
+        Long userId = principal.getId(); // OAuth2 로그인한 유저의 ID 가져오기
+
+        if (message == null || message.getMessage().trim().isEmpty()) {
+            return GlobalResponse.error(ErrorCode.EMPTY_MESSAGE);
+        }
+
+        ChatMsgResponse response = chatMessageService.sendMessage(message, userId, roomId);
+        return GlobalResponse.success("채팅 메시지 보내기 성공", response);
+    }
+
+    @GetMapping("/msg/{roomId}")
+    @LoginCheck
+    public GlobalResponse<Object> getChatList(
+            @PathVariable Long roomId,
+            @RequestParam(required = false) Long lastId) {
+
+        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+        if (!(authentication instanceof OAuth2AuthenticationToken)) {
+            return GlobalResponse.error(ErrorCode.NOT_AUTHENTICATED);
+        }
+
+        CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
+        Long userId = principal.getId(); // OAuth2 로그인한 유저의 ID 가져오기
+
+        List<ChatMsgDto> roomChatMsgList = chatMessageService.getRoomChatMsgList(roomId, userId, lastId);
+        if (roomChatMsgList == null || roomChatMsgList.isEmpty()) {
+            return GlobalResponse.error(ErrorCode.CHAT_NOT_FOUND);
+        }
+
+        return GlobalResponse.success("해당 채팅방의 메시지들을 조회하였습니다.", roomChatMsgList);
+    }
+}
+

src/main/java/cmf/commitField/domain/chat/chatMessage/controller/ChatMessageController.java

@@ -0,0 +1,17 @@
+package cmf.commitField.domain.chat.chatMessage.controller.request;
+
+import jakarta.validation.constraints.NotEmpty;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.hibernate.validator.constraints.Length;
+
+@Getter
+@AllArgsConstructor
+@NoArgsConstructor
+public class ChatMsgRequest {
+    @NotEmpty
+    @Length(max = 300)
+    private String message;
+
+}

src/main/java/cmf/commitField/domain/chat/chatMessage/controller/request/ChatMsgRequest.java

@@ -0,0 +1,18 @@
+package cmf.commitField.domain.chat.chatMessage.controller.response;
+
+import lombok.*;
+
+import java.time.LocalDateTime;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class ChatMsgResponse {
+    private Long roomId;
+    //사용자(user)
+    private String from;
+    private String message;
+    private LocalDateTime sendAt;
+}

src/main/java/cmf/commitField/domain/chat/chatMessage/controller/response/ChatMsgResponse.java

@@ -0,0 +1,20 @@
+package cmf.commitField.domain.chat.chatMessage.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.time.LocalDateTime;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+public class ChatMsgDto {
+    private Long chatMsgId;
+    private Long userId;
+    private String nickname;
+    private String message;
+    private LocalDateTime sendAt;
+}

src/main/java/cmf/commitField/domain/chat/chatMessage/dto/ChatMsgDto.java

@@ -16,7 +16,7 @@
 @Setter
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 @AllArgsConstructor(access = AccessLevel.PROTECTED)
-public class ChatMessage extends BaseEntity {
+public class ChatMsg extends BaseEntity {
 
     private String message;
 

…chat/chatMessage/entity/ChatMessage.java …ain/chat/chatMessage/entity/ChatMsg.javasrc/main/java/cmf/commitField/domain/chat/chatMessage/entity/ChatMessage.java renamed to src/main/java/cmf/commitField/domain/chat/chatMessage/entity/ChatMsg.java src/main/java/cmf/commitField/domain/chat/chatMessage/entity/ChatMessage.java renamed to src/main/java/cmf/commitField/domain/chat/chatMessage/entity/ChatMsg.java

@@ -0,0 +1,11 @@
+package cmf.commitField.domain.chat.chatMessage.repository;
+
+import cmf.commitField.domain.chat.chatMessage.entity.ChatMsg;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface ChatMessageCustomRepository {
+    List<ChatMsg> findChatRoomIdByChatMsg(Long chatMsg, Long lastId);
+}

src/main/java/cmf/commitField/domain/chat/chatMessage/repository/ChatMessageCustomRepository.java

@@ -0,0 +1,39 @@
+package cmf.commitField.domain.chat.chatMessage.repository;
+
+import cmf.commitField.domain.chat.chatMessage.entity.ChatMsg;
+import jakarta.persistence.EntityManager;
+import jakarta.persistence.TypedQuery;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+@RequiredArgsConstructor
+public class ChatMessageCustomRepositoryImpl implements ChatMessageCustomRepository {
+
+    private final EntityManager entityManager;
+
+    @Override
+    public List<ChatMsg> findChatRoomIdByChatMsg(Long chatMsg, Long lastId) {
+        String first = "select c from ChatMsg c where c.chatRoom.id =: chatMsg order by c.id asc";
+        String paging = "select c from ChatMsg c where c.chatRoom.id =: chatMsg and c.id > :lastId order by c.id asc";
+
+        TypedQuery<ChatMsg> query = null;
+
+        if (lastId == null) {
+            query = entityManager
+                    .createQuery(first, ChatMsg.class)
+                    .setParameter("chatMsg", chatMsg);
+        } else {
+            query = entityManager
+                    .createQuery(paging, ChatMsg.class)
+                    .setParameter("chatMsg", chatMsg)
+                    .setParameter("lastId", lastId);
+        }
+        return query
+                .setMaxResults(10)
+                .getResultList();
+    }
+
+}

src/main/java/cmf/commitField/domain/chat/chatMessage/repository/ChatMessageCustomRepositoryImpl.java

@@ -1,9 +1,10 @@
 package cmf.commitField.domain.chat.chatMessage.repository;
 
-import cmf.commitField.domain.chat.chatMessage.entity.ChatMessage;
+import cmf.commitField.domain.chat.chatMessage.entity.ChatMsg;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 
 @Repository
-public interface ChatMessageRepository extends JpaRepository<ChatMessage, Long> {
+public interface ChatMessageRepository extends JpaRepository<ChatMsg, Long> {
+    void deleteChatMsgByChatRoom_Id(Long chatRoomId);
 }

src/main/java/cmf/commitField/domain/chat/chatMessage/repository/ChatMessageRepository.java

@@ -0,0 +1,13 @@
+package cmf.commitField.domain.chat.chatMessage.service;
+
+import cmf.commitField.domain.chat.chatMessage.controller.request.ChatMsgRequest;
+import cmf.commitField.domain.chat.chatMessage.controller.response.ChatMsgResponse;
+import cmf.commitField.domain.chat.chatMessage.dto.ChatMsgDto;
+
+import java.util.List;
+
+public interface ChatMessageService {
+    ChatMsgResponse sendMessage(ChatMsgRequest message, Long userId, Long roomId);
+
+    List<ChatMsgDto> getRoomChatMsgList(Long roomId, Long userId, Long lastId);
+}