feat : 질문 생성해서 사용자에게 전송하는 기능 구현

Author: ttaehee

src/main/java/com/taehee/bot/domain/question/application/QuestionService.java

@@ -0,0 +1,34 @@
+package com.taehee.bot.domain.question.application;
+
+import com.taehee.bot.domain.member.model.Member;
+import com.taehee.bot.domain.member.repository.MemberRepository;
+import com.taehee.bot.domain.question.dto.response.SendQuestionResponse;
+import com.taehee.bot.domain.question.model.QuestionGenerator;
+import com.taehee.bot.global.sender.QuestionSender;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import javax.transaction.Transactional;
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+public class QuestionService {
+
+    private final QuestionGenerator questionGenerator;
+    private final QuestionSender questionSender;
+    private final MemberRepository memberRepository;
+
+    @Transactional
+    public void sendQuestion() {
+        List<Member> members = memberRepository.findAll();
+        members.forEach(
+                member -> generateAndSend(member.getCategory().name(), member.getEmail())
+        );
+    }
+
+    private void generateAndSend(String categoryName, String toAddress){
+        SendQuestionResponse generatedQuestions = questionGenerator.generate(categoryName);
+        questionSender.send(toAddress, generatedQuestions.combineToSting());
+    }
+}

src/main/java/com/taehee/bot/domain/question/dto/response/SendQuestionResponse.java

@@ -0,0 +1,26 @@
+package com.taehee.bot.domain.question.dto.response;
+
+import com.taehee.bot.global.feign.openai.dto.response.OpenAiResponse;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+public record SendQuestionResponse(
+        List<String> questions
+) {
+
+    public static SendQuestionResponse toSendQuestionResponse(OpenAiResponse openAiResponse) {
+        return new SendQuestionResponse(
+                openAiResponse.choices().stream()
+                        .map(choice -> choice.message().content())
+                        .collect(Collectors.toList())
+        );
+    }
+
+    public String combineToSting() {
+        return  questions.stream()
+                .map(String::valueOf)
+                .collect(Collectors.joining("/n"));
+    }
+
+}