최종발표용 v2 배포

.github/workflows/cd_prod.yml

@@ -24,6 +24,9 @@ jobs:
           java-version: '17'
           distribution: 'temurin'
 
+      - name: Set up GPT_PROMPT_SYSTEM environment variable decode
+        run: echo "GPT_PROMPT_SYSTEM=${{ secrets.GPT_PROMPT_SYSTEM }}" >> $GITHUB_ENV
+
       - name: Set yaml file
         uses: microsoft/variable-substitution@v1
         with:
@@ -39,6 +42,7 @@ jobs:
           logging.level.com.twentythree.peech: off
           logging.config: classpath:spring-logback.xml
           gpt.api.key: ${{secrets.GPT_API_KEY_PROD}}
+          gpt.prompt.system: ${{env.GPT_PROMPT_SYSTEM}}
           jwt.secret.key: ${{secrets.JWT_SECRET_KEY_PROD}}
           jwt.access.key: ${{secrets.JWT_ACCESS_KEY}}
           jwt.refresh.key: ${{secrets.JWT_REFRESH_KEY}}
@@ -55,6 +59,9 @@ jobs:
           ffmpeg.path: ${{ secrets.FFMPEG_PATH_PROD }}
           ffprobe.path: ${{ secrets.FFPROBE_PATH_PROD }}
           spring.cors.allowed-origins: ${{ secrets.CORS_ALLOWED_ORIGINS_PROD }}
+          fcm.secret-key: ${{ secrets.FCM_SECRET_KEY }}
+          fcm.key-path: ${{ secrets.FCM_KEY_PATH }}
+          fcm.project-id: ${{ secrets.FCM_PROJECT_ID }}
           meta.api-version: ${{ secrets.META_API_VERSION}}
           meta.web.pixel-id: ${{ secrets.META_WEB_PIXEL_ID_PROD}}
           meta.web.access-token: ${{ secrets.META_WEB_ACCESS_TOKEN_PROD}}
@@ -71,6 +78,12 @@ jobs:
       - name: Run chmod to make gradlew executable
         run: chmod +x ./gradlew
 
+      # fcm 서버 키 설정
+      - name: Set up FCM server key
+        run: |
+          cd ./src/main/resources/
+          echo "${{ secrets.FCM_SECRET_KEY }}" | base64 --decode > ./peech_fcm.json  
+
       # 2. Spring Boot 애플리케이션 빌드
       - name: Build with Gradle
         uses: gradle/gradle-build-action@67421db6bd0bf253fb4bd25b31ebb98943c375e1

.github/workflows/ci_prod.yml

@@ -24,6 +24,9 @@ jobs:
           java-version: '17'
           distribution: 'temurin'
 
+      - name: Set up GPT_PROMPT_SYSTEM environment variable decode
+        run: echo "GPT_PROMPT_SYSTEM=${{ secrets.GPT_PROMPT_SYSTEM }}" >> $GITHUB_ENV
+
       - name: Set yaml file
         uses: microsoft/variable-substitution@v1
         with:
@@ -39,6 +42,7 @@ jobs:
           logging.level.com.twentythree.peech: off
           logging.config: classpath:spring-logback.xml
           gpt.api.key: ${{secrets.GPT_API_KEY_PROD}}
+          gpt.prompt.system: ${{env.GPT_PROMPT_SYSTEM}}
           jwt.secret.key: ${{secrets.JWT_SECRET_KEY_PROD}}
           jwt.access.key: ${{secrets.JWT_ACCESS_KEY}}
           jwt.refresh.key: ${{secrets.JWT_REFRESH_KEY}}
@@ -55,6 +59,9 @@ jobs:
           ffmpeg.path: ${{ secrets.FFMPEG_PATH_PROD }}
           ffprobe.path: ${{ secrets.FFPROBE_PATH_PROD }}
           spring.cors.allowed-origins: ${{ secrets.CORS_ALLOWED_ORIGINS_PROD }}
+          fcm.secret-key: ${{ secrets.FCM_SECRET_KEY }}
+          fcm.key-path: ${{ secrets.FCM_KEY_PATH }}
+          fcm.project-id: ${{ secrets.FCM_PROJECT_ID }}
           meta.api-version: ${{ secrets.META_API_VERSION}}
           meta.web.pixel-id: ${{ secrets.META_WEB_PIXEL_ID_PROD}}
           meta.web.access-token: ${{ secrets.META_WEB_ACCESS_TOKEN_PROD}}
@@ -70,6 +77,12 @@ jobs:
       - name: Run chmod to make gradlew executable
         run: chmod +x ./gradlew
 
+      # fcm 서버 키 설정
+      - name: Set up FCM server key
+        run: |
+          cd ./src/main/resources/
+          echo "${{ secrets.FCM_SECRET_KEY }}" | base64 --decode > ./peech_fcm.json  
+
       # 2. Spring Boot 애플리케이션 빌드
       - name: Build with Gradle
         uses: gradle/gradle-build-action@67421db6bd0bf253fb4bd25b31ebb98943c375e1

.github/workflows/cicd_dev.yml

@@ -24,7 +24,10 @@ jobs:
       with:
         java-version: '17'
         distribution: 'temurin'
-
+
+    - name: Set up GPT_PROMPT_SYSTEM environment variable decode
+      run: echo "GPT_PROMPT_SYSTEM=${{ secrets.GPT_PROMPT_SYSTEM }}" >> $GITHUB_ENV
+
     - name: Set yaml file 
       uses: microsoft/variable-substitution@v1
       with:
@@ -40,6 +43,7 @@ jobs:
         logging.level.com.twentythree.peech: off
         logging.config: classpath:spring-logback.xml
         gpt.api.key: ${{secrets.GPT_API_KEY}}
+        gpt.prompt.system: ${{env.GPT_PROMPT_SYSTEM}}
         jwt.secret.key: ${{secrets.JWT_SECRET_KEY}}
         jwt.access.key: ${{secrets.JWT_ACCESS_KEY}}
         jwt.refresh.key: ${{secrets.JWT_REFRESH_KEY}}
@@ -56,6 +60,9 @@ jobs:
         ffmpeg.path: ${{ secrets.FFMPEG_PATH_DEV }}
         ffprobe.path: ${{ secrets.FFPROBE_PATH_DEV }}
         spring.cors.allowed-origins: ${{ secrets.CORS_ALLOWED_ORIGINS }}
+        fcm.secret-key: ${{ secrets.FCM_SECRET_KEY }}
+        fcm.key-path: ${{ secrets.FCM_KEY_PATH }}
+        fcm.project-id: ${{ secrets.FCM_PROJECT_ID }}
         meta.api-version: ${{ secrets.META_API_VERSION}}
         meta.web.pixel-id: ${{ secrets.META_WEB_PIXEL_ID}}
         meta.web.access-token: ${{ secrets.META_WEB_ACCESS_TOKEN}}
@@ -70,6 +77,12 @@ jobs:
     # excute 허용
     - name: Run chmod to make gradlew executable
       run: chmod +x ./gradlew
+
+    # fcm 서버 키 설정
+    - name: Set up FCM server key
+      run: |
+        cd ./src/main/resources/
+        echo "${{ secrets.FCM_SECRET_KEY }}" | base64 --decode > ./peech_fcm.json 
 
     # 2. Spring Boot 애플리케이션 빌드
     - name: Build with Gradle

.gitignore

@@ -43,3 +43,6 @@ data.sql
 
 ### Logging File ###
 /logs/**
+
+### FCM Admin SDK ###
+**/src/main/resources/peech_fcm.json

build.gradle

@@ -95,6 +95,9 @@ dependencies {
     // ffmpeg
     implementation 'net.bramp.ffmpeg:ffmpeg:0.8.0'
 
+    //firebase sdk
+    implementation 'com.google.firebase:firebase-admin:9.3.0'
+
     //thymeleaf
     implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
 

src/main/java/com/twentythree/peech/PeechApplication.java

@@ -3,6 +3,7 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableAsync;
 
 @EnableJpaAuditing
 @SpringBootApplication

src/main/java/com/twentythree/peech/analyzescript/application/AnalyzeScriptFacade.java

@@ -0,0 +1,33 @@
+package com.twentythree.peech.analyzescript.application;
+
+import com.twentythree.peech.analyzescript.domain.AnalyzeScriptPredictor;
+import com.twentythree.peech.fcm.application.NotificationService;
+import com.twentythree.peech.script.service.ScriptService;
+import lombok.RequiredArgsConstructor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+
+@RequiredArgsConstructor
+@Service
+public class AnalyzeScriptFacade {
+
+    private final AnalyzeScriptPredictor analyzeScriptPredictor;
+    private final ScriptService scriptService;
+    private final NotificationService notificationService;
+    private final Logger log = LoggerFactory.getLogger(this.getClass());
+
+    @Async
+    public void analyzeScriptAndSave(Long userId, Long scriptId, String scriptContent) {
+        analyzeScriptPredictor.requestAnalyzeScript(scriptContent)
+                .thenAccept(result -> {
+                    scriptService.reflectAnalyzeResult(scriptId, result);
+                    notificationService.pushNotification(userId);
+                })
+                .exceptionally(e -> {
+                    log.error("스크립트 분석 중 예외 발생", e);
+                    return null;
+                });
+    }
+}

src/main/java/com/twentythree/peech/analyzescript/client/AnalyzeScriptGPT.java

@@ -0,0 +1,15 @@
+package com.twentythree.peech.analyzescript.client;
+
+import com.twentythree.peech.analyzescript.dto.request.GPTRequest;
+import com.twentythree.peech.common.dto.response.GPTResponse;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+
+@FeignClient(
+        name = "analyzeScriptGPT",
+        url = "https://api.openai.com/")
+public interface AnalyzeScriptGPT {
+
+    @PostMapping("v1/chat/completions")
+    GPTResponse analyzeScript(GPTRequest gptRequest);
+}

src/main/java/com/twentythree/peech/analyzescript/domain/AnalyzeScriptPredictor.java

@@ -0,0 +1,43 @@
+package com.twentythree.peech.analyzescript.domain;
+
+import com.twentythree.peech.analyzescript.client.AnalyzeScriptGPT;
+import com.twentythree.peech.analyzescript.dto.request.GPTRequest;
+import com.twentythree.peech.common.dto.Message;
+import com.twentythree.peech.common.dto.response.GPTResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+
+@Async
+@RequiredArgsConstructor
+@Component
+public class AnalyzeScriptPredictor {
+
+    @Value("${gpt.prompt.system}")
+    private String gptSystemPrompt;
+
+    private final AnalyzeScriptGPT analyzeScriptGPT;
+
+    public CompletableFuture<String> requestAnalyzeScript(String scriptContent) {
+        List<Message> messages = new ArrayList<>();
+
+        String systemPrompt = gptSystemPrompt;
+        messages.add(new Message("system", systemPrompt));
+
+        String userPrompt = "자기소개서: " +  scriptContent;
+
+        messages.add(new Message("user", userPrompt));
+
+        GPTRequest gptRequest = new GPTRequest("gpt-4o-mini", messages);
+        GPTResponse gptResponse = analyzeScriptGPT.analyzeScript(gptRequest);
+        String result = gptResponse.getChoices().get(0).getMessage().getContent();
+
+        return CompletableFuture.completedFuture(result);
+    }
+
+}

src/main/java/com/twentythree/peech/analyzescript/dto/request/GPTRequest.java

@@ -0,0 +1,14 @@
+package com.twentythree.peech.analyzescript.dto.request;
+
+import com.twentythree.peech.common.dto.Message;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.List;
+
+@Getter
+@AllArgsConstructor
+public class GPTRequest {
+    private String model;
+    private List<Message> messages;
+}

src/main/java/com/twentythree/peech/config/async/AsyncConfig.java

@@ -0,0 +1,24 @@
+package com.twentythree.peech.config.async;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.AsyncConfigurer;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig implements AsyncConfigurer {
+
+    @Override
+    public Executor getAsyncExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(10);       // 기본 스레드 수
+        executor.setMaxPoolSize(30);       // 최대 스레드 수
+        executor.setQueueCapacity(50);     // 작업 대기 큐 크기
+        executor.setThreadNamePrefix("AsyncExecutor-");
+        executor.initialize();
+        return executor;
+    }
+}

src/main/java/com/twentythree/peech/fcm/application/NotificationService.java

@@ -0,0 +1,10 @@
+package com.twentythree.peech.fcm.application;
+
+import com.twentythree.peech.fcm.dto.request.RequestFCMTokenDTO;
+
+public interface NotificationService {
+    void pushNotification(Long userId);
+    void saveOrUpdateToken(RequestFCMTokenDTO fcmTokenDTO, Long userId);
+    void testPushNotification(Long userId);
+    void deleteToken(String deviceId);
+}

src/main/java/com/twentythree/peech/fcm/application/NotificationServiceImpl.java

@@ -0,0 +1,79 @@
+package com.twentythree.peech.fcm.application;
+
+
+import com.twentythree.peech.fcm.dto.request.RequestFCMTokenDTO;
+import com.twentythree.peech.fcm.entity.NotificationEntity;
+import com.twentythree.peech.fcm.event.FCMPushedEvent;
+import com.twentythree.peech.fcm.event.FCMTestPushEvent;
+import com.twentythree.peech.fcm.infra.NotificationRepository;
+import com.twentythree.peech.user.entity.UserEntity;
+import com.twentythree.peech.user.repository.UserRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+@RequiredArgsConstructor
+@Service
+public class NotificationServiceImpl implements NotificationService {
+
+    private final NotificationRepository notificationRepository;
+    private final UserRepository userRepository;
+    private final ApplicationEventPublisher applicationEventPublisher;
+
+    public void pushNotification(Long userId) {
+        List<String> fcmTokenList = notificationRepository.findAllByUserId(userId);
+
+        if(fcmTokenList.isEmpty()){
+            throw new IllegalStateException("FCM 토큰이 존재하지 않습니다.");
+        }
+
+        applicationEventPublisher.publishEvent(new FCMPushedEvent(fcmTokenList));
+    }
+
+    @Transactional
+    @Override
+    public void saveOrUpdateToken(RequestFCMTokenDTO request, Long userId) {
+        notificationRepository.findByDeviceId(request.getDeviceId())
+                .ifPresentOrElse(
+                        fcmToken -> updateFCMToken(fcmToken, request.getFcmToken()),
+
+                        () -> {
+                            UserEntity userEntity = userRepository.findById(userId)
+                                    .orElseThrow(() -> new IllegalStateException("유저가 존재하지 않습니다."));
+                            NotificationEntity newEntity = NotificationEntity
+                                    .ofCreateFCMToken(
+                                            userEntity,
+                                            request.getDeviceId(),
+                                            request.getFcmToken()
+                                    );
+                            notificationRepository.save(newEntity);
+                        });
+    }
+
+    @Override
+    public void testPushNotification(Long userId) {
+        List<String> fcmTokenList = notificationRepository.findAllByUserId(userId);
+
+        if(fcmTokenList.isEmpty()){
+            throw new IllegalStateException("FCM 토큰이 존재하지 않습니다.");
+        }
+
+        applicationEventPublisher.publishEvent(new FCMTestPushEvent(fcmTokenList));
+    }
+
+    @Override
+    public void deleteToken(String deviceId) {
+        notificationRepository.findByDeviceId(deviceId)
+                .ifPresentOrElse(
+                        notificationRepository::delete,
+                        () -> { throw new IllegalStateException("deviceId가 존재하지 않습니다.");}
+                );
+    }
+
+    private void updateFCMToken(NotificationEntity originEntity, String newToken){
+        originEntity.updateToken(newToken);
+    }
+}

src/main/java/com/twentythree/peech/fcm/client/FCMClient.java

@@ -0,0 +1,21 @@
+package com.twentythree.peech.fcm.client;
+
+
+import com.google.firebase.messaging.FirebaseMessaging;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.PostMapping;
+
+@FeignClient(
+        name = "FCMClient",
+        url = "https://fcm.googleapis.com/v1/projects/${fcm.project-id}/messages:send"
+)
+public interface FCMClient {
+
+    @PostMapping(consumes = MediaType.APPLICATION_JSON_VALUE)
+    void sendNotification(
+            FirebaseMessaging message
+    );
+
+
+}