Merge pull request #16 from gdsc-ssu/feat/#15

[Feat/#15] 대화 내용 요약본 이메일 전송 기능 구현

Author: daeun084

build.gradle

@@ -47,6 +47,9 @@ dependencies {
 
 	//.env
 	implementation 'io.github.cdimascio:java-dotenv:5.2.2'
+
+	// email
+	implementation 'org.springframework.boot:spring-boot-starter-mail'
 }
 
 dependencyManagement {

src/main/java/com/gdg/poppet/auth/domain/converter/AuthConverter.java

@@ -1,6 +1,6 @@
 package com.gdg.poppet.auth.domain.converter;
 
-import com.gdg.poppet.user.domain.enums.EmailPeriod;
+import com.gdg.poppet.email.domain.enums.EmailPeriod;
 import com.gdg.poppet.user.domain.enums.Gender;
 import com.gdg.poppet.user.domain.model.User;
 

src/main/java/com/gdg/poppet/chat/domain/model/ChatRoom.java

@@ -28,10 +28,17 @@ public class ChatRoom extends BaseEntity {
 
     private String username;   // TODO: user 간접 참조
 
+    @Column(name = "is_mail_sent", nullable = false, columnDefinition = "BOOLEAN DEFAULT false")
+    private boolean isMailSent;
+
     @OneToMany(mappedBy = "chatRoom", cascade = CascadeType.ALL, orphanRemoval = true, fetch = FetchType.LAZY)
     private List<Chat> chats;
 
     public boolean isValidChatRoom(LocalDate emailPeriodDate) {
         return !getCreatedAt().toLocalDate().isBefore(emailPeriodDate);
     }
+
+    public void updateIsMailSent() {
+        isMailSent = true;
+    }
 }

src/main/java/com/gdg/poppet/chat/domain/repository/ChatRoomRepository.java

@@ -24,4 +24,11 @@ public interface ChatRoomRepository extends JpaRepository<ChatRoom, Long> {
             "FROM ChatRoom cr " +
             "WHERE cr.chatRoomId = :chatRoomId")
     void deleteChatRoomByChatRoomId(@Param(value = "chatRoomId") Long chatRoomId);
+
+    @Query(value = "SELECT cr " +
+            "FROM ChatRoom cr " +
+            "WHERE cr.username = :username " +
+            "AND cr.isMailSent = FALSE " +
+            "ORDER BY cr.createdAt DESC")
+    List<ChatRoom> findByUsernameAndCreatedAtAndIsMailSent(@Param(value = "username") String username);
 }

src/main/java/com/gdg/poppet/user/application/dto/request/EmailRequestDto.java renamed to src/main/java/com/gdg/poppet/email/application/dto/request/EmailRequestDto.java

@@ -1,4 +1,4 @@
-package com.gdg.poppet.user.application.dto.request;
+package com.gdg.poppet.email.application.dto.request;
 
 import jakarta.validation.constraints.NotBlank;
 import lombok.Getter;

src/main/java/com/gdg/poppet/user/application/dto/response/EmailDto.java renamed to src/main/java/com/gdg/poppet/email/application/dto/response/EmailDto.java

@@ -1,4 +1,4 @@
-package com.gdg.poppet.user.application.dto.response;
+package com.gdg.poppet.email.application.dto.response;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;

src/main/java/com/gdg/poppet/user/application/dto/response/EmailPeriodDto.java renamed to src/main/java/com/gdg/poppet/email/application/dto/response/EmailPeriodDto.java

@@ -1,4 +1,4 @@
-package com.gdg.poppet.user.application.dto.response;
+package com.gdg.poppet.email.application.dto.response;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;

src/main/java/com/gdg/poppet/email/application/event/EmailSendEvent.java

@@ -0,0 +1,16 @@
+package com.gdg.poppet.email.application.event;
+
+import com.gdg.poppet.chat.domain.model.ChatRoom;
+import com.gdg.poppet.user.domain.model.User;
+import lombok.Getter;
+
+@Getter
+public class EmailSendEvent {
+    private final User user;
+    private final ChatRoom chatRoom;
+
+    public EmailSendEvent(User user, ChatRoom chatRoom) {
+        this.user = user;
+        this.chatRoom = chatRoom;
+    }
+}

src/main/java/com/gdg/poppet/email/application/service/EmailService.java

@@ -0,0 +1,21 @@
+package com.gdg.poppet.email.application.service;
+
+import com.gdg.poppet.email.application.dto.request.EmailRequestDto;
+import com.gdg.poppet.email.application.dto.response.EmailDto;
+import com.gdg.poppet.email.application.dto.response.EmailPeriodDto;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public interface EmailService {
+    EmailPeriodDto getEmailPeriod(String name);
+    EmailPeriodDto patchEmailPeriod(String name, int period);
+
+    List<EmailDto> getEmailAddressList(String name);
+    List<EmailDto> postEmailAddress(String name, EmailRequestDto emailRequestDto);
+    void patchEmailAddress(String name, Long emailId, EmailRequestDto emailRequestDto);
+    void deleteEmailAddress(String name, Long emailId);
+
+    void sendEmail(String username);
+}

src/main/java/com/gdg/poppet/user/application/service/EmailServiceImpl.java renamed to src/main/java/com/gdg/poppet/email/application/service/EmailServiceImpl.java

@@ -1,28 +1,38 @@
-package com.gdg.poppet.user.application.service;
+package com.gdg.poppet.email.application.service;
 
+import com.gdg.poppet.chat.domain.model.ChatRoom;
+import com.gdg.poppet.chat.domain.repository.ChatRoomRepository;
+import com.gdg.poppet.email.application.event.EmailSendEvent;
+import com.gdg.poppet.email.infra.application.EmailSendService;
 import com.gdg.poppet.global.exception.GlobalException;
 import com.gdg.poppet.global.status.ErrorStatus;
-import com.gdg.poppet.user.application.dto.request.EmailRequestDto;
-import com.gdg.poppet.user.application.dto.response.EmailDto;
-import com.gdg.poppet.user.application.dto.response.EmailPeriodDto;
-import com.gdg.poppet.user.domain.converter.EmailConverter;
-import com.gdg.poppet.user.domain.model.Email;
+import com.gdg.poppet.email.application.dto.request.EmailRequestDto;
+import com.gdg.poppet.email.application.dto.response.EmailDto;
+import com.gdg.poppet.email.application.dto.response.EmailPeriodDto;
+import com.gdg.poppet.email.domain.converter.EmailConverter;
+import com.gdg.poppet.email.domain.model.Email;
 import com.gdg.poppet.user.domain.model.User;
-import com.gdg.poppet.user.domain.repository.EmailRepository;
+import com.gdg.poppet.email.domain.repository.EmailRepository;
 import com.gdg.poppet.user.domain.repository.UserRepository;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 import java.util.stream.Collectors;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class EmailServiceImpl implements EmailService {
 
     private final UserRepository userRepository;
     private final EmailRepository emailRepository;
+    private final ChatRoomRepository chatRoomRepository;
+    private final EmailSendService emailSendService;
+    private final ApplicationEventPublisher applicationEventPublisher;
 
     /**
      * 사용자의 이메일 전송 주기를 반환한다.
@@ -58,7 +68,7 @@ public EmailPeriodDto patchEmailPeriod(String username, int period) {
      * @return 사용자가 등록한 보호자 이메일 리스트
      */
     @Override
-    public List<EmailDto> getEmailList(String username) {
+    public List<EmailDto> getEmailAddressList(String username) {
         User user = getUser(username);
         List<Email> emailList = emailRepository.findByUser(user);
 
@@ -76,7 +86,7 @@ public List<EmailDto> getEmailList(String username) {
      */
     @Transactional
     @Override
-    public List<EmailDto> postEmail(String username, EmailRequestDto emailRequestDto) {
+    public List<EmailDto> postEmailAddress(String username, EmailRequestDto emailRequestDto) {
         User user = getUser(username);
 
         validateDuplicateEmail(emailRequestDto.getNewEmail(), user);
@@ -103,7 +113,7 @@ public List<EmailDto> postEmail(String username, EmailRequestDto emailRequestDto
      */
     @Transactional
     @Override
-    public void patchEmail(String username, Long emailId, EmailRequestDto emailRequestDto) {
+    public void patchEmailAddress(String username, Long emailId, EmailRequestDto emailRequestDto) {
         User user = getUser(username);
         Email email = getEmail(emailId);
 
@@ -123,14 +133,39 @@ public void patchEmail(String username, Long emailId, EmailRequestDto emailReque
      */
     @Transactional
     @Override
-    public void deleteEmail(String username, Long emailId) {
+    public void deleteEmailAddress(String username, Long emailId) {
         User user = getUser(username);
         Email email = getEmail(emailId);
         validateIsUserAuthorizedForEmail(user, email);
 
         emailRepository.delete(email);
     }
 
+    /**
+     * 유저의 이메일 전송 주기에 따라, 주기 내에 생성된 이메일의 요약 내용을 이메일로 전송한다.
+     */
+    @Transactional
+    @Override
+    public void sendEmail(String username) {
+        // TODO: user data 얻는 과정 수정
+        User user = getUser(username);
+
+        // 가장 최근 생성되고 메일을 보내지 않은 채팅방 조회
+        List<ChatRoom> chatRooms = chatRoomRepository.findByUsernameAndCreatedAtAndIsMailSent(username);
+        if (chatRooms.isEmpty()) return;
+
+        // 메일 보낼 채팅방 요약 내용 추출
+        ChatRoom chatRoom = chatRooms.get(0);
+        String chatSummary = chatRoom.getSummary();
+        if (chatSummary == null) return;
+
+        // 메일 보냄 여부 수정
+        chatRoom.updateIsMailSent();
+
+        // 메일 전송 이벤트 발행
+        applicationEventPublisher.publishEvent(new EmailSendEvent(user, chatRoom));
+    }
+
     private void validateIsUserAuthorizedForEmail(User user, Email email) {
         if (!email.getUser().equals(user)) {
             throw new GlobalException(ErrorStatus.USER_EMAIL_FORBIDDEN);