[#2] 도슨트 생성 파이프라인

.gitignore

@@ -37,4 +37,5 @@ out/
 .vscode/
 
 # macOS
-.DS_Store
+.DS_Store
+/src/main/resources/gcp-service-account-key.json

build.gradle

@@ -4,6 +4,11 @@ plugins {
     id 'io.spring.dependency-management' version '1.1.7'
 }
 
+ext {
+    springAiVersion = "1.1.0"
+    springCloudVersion = "2025.0.0"
+}
+
 group = 'com.earseo'
 version = '0.0.1-SNAPSHOT'
 description = 'backend-core'
@@ -21,6 +26,7 @@ repositories {
 dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.springframework.boot:spring-boot-starter-actuator'
+    implementation 'org.springframework.cloud:spring-cloud-starter-openfeign'
     runtimeOnly 'io.micrometer:micrometer-registry-prometheus'
 
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
@@ -49,6 +55,16 @@ dependencies {
 
     implementation 'org.springframework.boot:spring-boot-starter-data-redis'
     implementation 'org.springframework.kafka:spring-kafka'
+
+    implementation 'org.springframework.ai:spring-ai-starter-model-openai'
+    implementation 'com.google.cloud:google-cloud-texttospeech:2.78.0'
+}
+
+dependencyManagement {
+    imports {
+        mavenBom "org.springframework.ai:spring-ai-bom:$springAiVersion"
+        mavenBom "org.springframework.cloud:spring-cloud-dependencies:$springCloudVersion"
+    }
 }
 
 tasks.named('test') {

src/main/java/com/earseo/core/BackendCoreApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
 
 @SpringBootApplication
+@EnableFeignClients
 public class BackendCoreApplication {
 
     public static void main(String[] args) {

src/main/java/com/earseo/core/common/config/AiConfig.java

@@ -0,0 +1,29 @@
+package com.earseo.core.common.config;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.ai.chat.client.ChatClient;
+import org.springframework.ai.openai.OpenAiChatModel;
+import org.springframework.ai.openai.OpenAiChatOptions;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@RequiredArgsConstructor
+public class AiConfig {
+    private final OpenAiChatModel openAiChatModel;
+
+    @Bean
+    public OpenAiChatOptions openAiChatOptions() {
+        return OpenAiChatOptions.builder()
+                .model("gpt-4.1-mini")
+                .temperature(0.3)
+                .build();
+    }
+
+    @Bean
+    public ChatClient chatClient() {
+        return ChatClient.builder(openAiChatModel)
+                .defaultOptions(openAiChatOptions())
+                .build();
+    }
+}

src/main/java/com/earseo/core/common/config/GoogleCloudConfig.java

@@ -0,0 +1,38 @@
+package com.earseo.core.common.config;
+
+import com.google.api.gax.core.FixedCredentialsProvider;
+import com.google.auth.Credentials;
+import com.google.auth.oauth2.GoogleCredentials;
+import com.google.cloud.texttospeech.v1.TextToSpeechClient;
+import com.google.cloud.texttospeech.v1.TextToSpeechSettings;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+import org.springframework.core.io.ClassPathResource;
+
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Base64;
+
+@Configuration
+@Profile("!test")
+public class GoogleCloudConfig {
+
+    @Value("${gcp.credentials.base64:}")
+    private String credentialsBase64;
+
+    @Bean
+    public TextToSpeechClient textToSpeechClient() throws IOException {
+        byte[] decodedBytes = Base64.getDecoder().decode(credentialsBase64);
+        InputStream credentialsStream = new ByteArrayInputStream(decodedBytes);
+        Credentials credentials = GoogleCredentials.fromStream(credentialsStream);
+
+        TextToSpeechSettings settings = TextToSpeechSettings.newBuilder()
+                .setCredentialsProvider(FixedCredentialsProvider.create(credentials))
+                .build();
+
+        return TextToSpeechClient.create(settings);
+    }
+}

src/main/java/com/earseo/core/controller/DocentController.java

@@ -0,0 +1,23 @@
+package com.earseo.core.controller;
+
+import com.earseo.core.common.BaseResponse;
+import com.earseo.core.service.DocentService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+public class DocentController {
+
+    private final DocentService docentService;
+
+    @PostMapping("/admin/core/docent")
+    public ResponseEntity<BaseResponse<String>> initDocent() {
+        docentService.initDocent();
+        docentService.getDocent();
+        docentService.getDocentJson();
+        return ResponseEntity.ok(BaseResponse.ok(null));
+    }
+}

src/main/java/com/earseo/core/controller/internal/CoreInternalController.java

@@ -0,0 +1,23 @@
+package com.earseo.core.controller.internal;
+
+import com.earseo.core.dto.internal.StoryDocentRequest;
+import com.earseo.core.dto.internal.StoryDocentResponse;
+import com.earseo.core.service.internal.InternalService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequiredArgsConstructor
+public class CoreInternalController {
+
+    private final InternalService internalService;
+
+    @PostMapping("/internal/core/docent/story")
+    public List<StoryDocentResponse> getStoryDocent(@RequestBody List<StoryDocentRequest> request) {
+        return internalService.createStorySpotDocent(request);
+    }
+}

src/main/java/com/earseo/core/dto/etl/DocentItemDto.java

@@ -0,0 +1,8 @@
+package com.earseo.core.dto.etl;
+
+public record DocentItemDto(
+        String contentId,
+        String script,
+        String docentUrl
+) {
+}

src/main/java/com/earseo/core/dto/etl/JoinItemDto.java

@@ -0,0 +1,10 @@
+package com.earseo.core.dto.etl;
+
+public record JoinItemDto(
+        Long id,
+        String contentId,
+        String title,
+        String outl,
+        String script
+) {
+}

src/main/java/com/earseo/core/dto/internal/StoryDocentRequest.java

@@ -0,0 +1,8 @@
+package com.earseo.core.dto.internal;
+
+public record StoryDocentRequest(
+        Long summaryId,
+        String summary,
+        String locale
+) {
+}

src/main/java/com/earseo/core/dto/internal/StoryDocentResponse.java

@@ -0,0 +1,8 @@
+package com.earseo.core.dto.internal;
+
+public record StoryDocentResponse(
+        Long summaryId,
+        String docentScript,
+        String docentUrl
+) {
+}

src/main/java/com/earseo/core/entity/Docent.java

@@ -0,0 +1,28 @@
+package com.earseo.core.entity;
+
+import jakarta.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class Docent {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "content_id", nullable = false, unique = true)
+    private String contentId;
+
+    @Column(name = "script", columnDefinition = "TEXT")
+    private String script;
+
+    @Column(name = "docent_url")
+    private String docentUrl;
+}

src/main/java/com/earseo/core/entity/Master.java

@@ -67,7 +67,7 @@ public class Master {
     @Column(name = "modifiedtime")
     private String modifiedtime;
 
-    @Column(name = "tel")
+    @Column(name = "tel", columnDefinition = "TEXT")
     private String tel;
 
     @Column(name = "m_level")

src/main/java/com/earseo/core/entity/OdiiData.java

@@ -0,0 +1,25 @@
+package com.earseo.core.entity;
+
+import jakarta.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class OdiiData {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "title")
+    private String title;
+
+    @Column(name = "script", columnDefinition = "TEXT")
+    private String script;
+}

src/main/java/com/earseo/core/repository/DocentRepository.java

@@ -0,0 +1,7 @@
+package com.earseo.core.repository;
+
+import com.earseo.core.entity.Docent;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface DocentRepository extends JpaRepository<Docent, Long> {
+}

src/main/java/com/earseo/core/repository/OdiiDataRepository.java

@@ -0,0 +1,21 @@
+package com.earseo.core.repository;
+
+import com.earseo.core.dto.etl.JoinItemDto;
+import com.earseo.core.entity.OdiiData;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface OdiiDataRepository extends JpaRepository<OdiiData, Long> {
+
+    @Query(value = """
+            SELECT DISTINCT m.id, m.content_id, m.title, MIN(o.script), m.outl
+            FROM odii_data o
+                     RIGHT JOIN master m ON m.title = o.title
+            WHERE m.title IS NOT NULL
+            GROUP BY m.id, m.content_id, m.title, m.outl
+            ORDER BY m.id
+            """, nativeQuery = true)
+    List<JoinItemDto> joinWithMaster();
+}