[T3-211] 슬랙 첨부파일 전송 개발 (#84)

thisishwan2 · web-flow · commit 6c53e1833a5c · 2026-03-14T14:55:07.000+09:00
* feat: 슬랙 메세지 커스터마이징 구현 및 파일 업로더 구현

* feat: KPI 추출을 위한 엑셀 처리

* feat: kpi 추출 이벤트 처리

* chore: 서브모듈 업데이트(개발 서버에서 슬랙 발송안되도록 처리)
diff --git a/build.gradle b/build.gradle
@@ -60,6 +60,9 @@ dependencies {
 	// slack
 	implementation 'com.slack.api:slack-api-client:1.45.3'
 
+	// excel
+	implementation 'org.apache.poi:poi-ooxml:5.3.0'
+
 	// bouncycastle
 	implementation 'org.bouncycastle:bcpkix-jdk18on:1.80'
 
@@ -95,4 +98,4 @@ processResources {
 		include 'application-prod.yml'
 		into ''
 	}
-}
+}
diff --git a/config b/config
@@ -1 +1 @@
-Subproject commit 5b928745307b60cfabcc8b087f4a86b9d92f7e98
+Subproject commit d8a4d168f37d4c0000ce261e52de9c5904958899
diff --git a/src/main/java/bitnagil/bitnagil_backend/file/service/FileService.java b/src/main/java/bitnagil/bitnagil_backend/file/service/FileService.java
@@ -6,13 +6,20 @@
 import com.amazonaws.services.s3.AmazonS3;
 import com.amazonaws.services.s3.Headers;
 import com.amazonaws.services.s3.model.CannedAccessControlList;
+import com.amazonaws.services.s3.model.ObjectMetadata;
+import com.amazonaws.services.s3.model.PutObjectRequest;
 import com.amazonaws.services.s3.model.GeneratePresignedUrlRequest;
 import lombok.RequiredArgsConstructor;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
+import java.io.ByteArrayInputStream;
 import java.net.URL;
-import java.util.*;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
 
 @Service
 @RequiredArgsConstructor
@@ -41,6 +48,22 @@ public Map<String, String> getPresignedUrls(List<PresignedUrlRequest> requests)
         return responseMap;
     }
 
+    public String uploadBytes(String key, byte[] data, String contentType) {
+        ObjectMetadata metadata = new ObjectMetadata();
+        metadata.setContentLength(data.length);
+        metadata.setContentType(contentType);
+
+        PutObjectRequest request = new PutObjectRequest(
+                bucket,
+                key,
+                new ByteArrayInputStream(data),
+                metadata
+        ).withCannedAcl(CannedAccessControlList.PublicRead);
+
+        amazonS3.putObject(request);
+        return amazonS3.getUrl(bucket, key).toString();
+    }
+
     // S3 Presigned URL 생성
     private GeneratePresignedUrlRequest getGeneratePresignedUrlRequest(String bucket, String fileName) {
         GeneratePresignedUrlRequest generatePresignedUrlRequest = new GeneratePresignedUrlRequest(bucket, fileName)
@@ -74,4 +97,3 @@ private String createPath(String prefix, String fileName) {
         return String.format("%s/%s", prefix, fileId + "-" + fileName);
     }
 }
-
diff --git a/src/main/java/bitnagil/bitnagil_backend/global/SlackService.java b/src/main/java/bitnagil/bitnagil_backend/global/SlackService.java
diff --git a/src/main/java/bitnagil/bitnagil_backend/global/config/AsyncConfig.java b/src/main/java/bitnagil/bitnagil_backend/global/config/AsyncConfig.java
@@ -0,0 +1,24 @@
+package bitnagil.bitnagil_backend.global.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig {
+
+    @Bean
+    public Executor asyncExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(2);
+        executor.setMaxPoolSize(4);
+        executor.setQueueCapacity(100);
+        executor.setThreadNamePrefix("async-");
+        executor.initialize();
+        return executor;
+    }
+}
diff --git a/src/main/java/bitnagil/bitnagil_backend/global/handler/GlobalExceptionHandler.java b/src/main/java/bitnagil/bitnagil_backend/global/handler/GlobalExceptionHandler.java
@@ -1,6 +1,7 @@
 package bitnagil.bitnagil_backend.global.handler;
 
-import bitnagil.bitnagil_backend.global.SlackService;
+import bitnagil.bitnagil_backend.global.slack.SlackMessageOptions;
+import bitnagil.bitnagil_backend.global.slack.SlackService;
 import bitnagil.bitnagil_backend.global.errorcode.ErrorCode;
 import bitnagil.bitnagil_backend.global.exception.CustomException;
 import bitnagil.bitnagil_backend.global.response.ErrorResponseDto;
@@ -197,7 +198,11 @@ private void sendSlackMessage(Exception e, ErrorCode errorCode) {
         String title = "에러 코드: " + errorCode.getCode() + "\n"
                 + "상태 코드: " + errorCode.getHttpStatus().value() + "\n"
                 + "메시지: " + errorCode.getMessage();
-        slackService.sendMessage(title, messageMap);
+        SlackMessageOptions options = SlackMessageOptions.builder()
+                .title(title)
+                .data(messageMap)
+                .build();
+        slackService.sendMessage(options);
     }
 
     /**
@@ -212,7 +217,11 @@ private void sendSlackMessage(Exception e, ErrorCode errorCode, String message)
                 + "상태 코드: " + errorCode.getHttpStatus().value() + "\n"
                 + "메시지: " + errorCode.getMessage() + "\n"
                 + "추가 메시지: " + message;
-        slackService.sendMessage(title, messageMap);
+        SlackMessageOptions options = SlackMessageOptions.builder()
+                .title(title)
+                .data(messageMap)
+                .build();
+        slackService.sendMessage(options);
     }
 
     /**
diff --git a/src/main/java/bitnagil/bitnagil_backend/global/slack/Color.java b/src/main/java/bitnagil/bitnagil_backend/global/slack/Color.java
@@ -1,4 +1,4 @@
-package bitnagil.bitnagil_backend.global;
+package bitnagil.bitnagil_backend.global.slack;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
diff --git a/src/main/java/bitnagil/bitnagil_backend/global/slack/SlackFileSender.java b/src/main/java/bitnagil/bitnagil_backend/global/slack/SlackFileSender.java
@@ -0,0 +1,62 @@
+package bitnagil.bitnagil_backend.global.slack;
+
+import com.slack.api.Slack;
+import com.slack.api.methods.MethodsClient;
+import com.slack.api.methods.request.files.FilesUploadV2Request;
+import com.slack.api.methods.request.files.FilesUploadV2Request.UploadFile;
+import com.slack.api.methods.response.files.FilesUploadV2Response;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@Slf4j
+public class SlackFileSender {
+
+    private final Slack slack = Slack.getInstance();
+
+    public void upload(SlackFileUploadOptions options) {
+        if (options == null) {
+            return;
+        }
+
+        if (options.getBotToken() == null || options.getBotToken().isEmpty()) {
+            return;
+        }
+
+        if (options.getChannelId() == null || options.getChannelId().isEmpty()) {
+            return;
+        }
+
+        if (options.getFilename() == null || options.getFilename().isEmpty()) {
+            return;
+        }
+
+        if (options.getFileBytes() == null || options.getFileBytes().length == 0) {
+            return;
+        }
+
+        try {
+            MethodsClient client = slack.methods(options.getBotToken());
+            UploadFile uploadFile = UploadFile.builder()
+                    .filename(options.getFilename())
+                    .fileData(options.getFileBytes())
+                    .title(options.getFilename())
+                    .build();
+
+            FilesUploadV2Request request = FilesUploadV2Request.builder()
+                    .channel(options.getChannelId())
+                    .initialComment(options.getInitialComment())
+                    .uploadFiles(List.of(uploadFile))
+                    .build();
+
+            FilesUploadV2Response response = client.filesUploadV2(request);
+            if (!response.isOk()) {
+                log.error("Slack 파일 업로드 실패: {}", response.getError());
+            }
+        } catch (Exception e) {
+            log.error("Slack 파일 업로드에 실패했습니다.", e);
+        }
+    }
+}
diff --git a/src/main/java/bitnagil/bitnagil_backend/global/slack/SlackFileUploadOptions.java b/src/main/java/bitnagil/bitnagil_backend/global/slack/SlackFileUploadOptions.java
@@ -0,0 +1,14 @@
+package bitnagil.bitnagil_backend.global.slack;
+
+import lombok.Builder;
+import lombok.Getter;
+
+@Getter
+@Builder
+public class SlackFileUploadOptions {
+    private final String botToken;
+    private final String channelId;
+    private final String filename;
+    private final byte[] fileBytes;
+    private final String initialComment;
+}
diff --git a/src/main/java/bitnagil/bitnagil_backend/global/slack/SlackMessageOptions.java b/src/main/java/bitnagil/bitnagil_backend/global/slack/SlackMessageOptions.java
@@ -0,0 +1,17 @@
+package bitnagil.bitnagil_backend.global.slack;
+
+import lombok.Builder;
+import lombok.Getter;
+
+import java.util.Map;
+
+@Getter
+@Builder
+public class SlackMessageOptions {
+    private final String title;
+    private final Map<String, String> data;
+    private final String webhookUrl;
+    private final String colorCode;
+    @Builder.Default
+    private final boolean enabled = true;
+}
diff --git a/src/main/java/bitnagil/bitnagil_backend/global/slack/SlackService.java b/src/main/java/bitnagil/bitnagil_backend/global/slack/SlackService.java
@@ -0,0 +1,90 @@
+package bitnagil.bitnagil_backend.global.slack;
+
+import com.slack.api.Slack;
+import com.slack.api.model.Attachment;
+import com.slack.api.model.Field;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import static com.slack.api.webhook.WebhookPayloads.payload;
+
+@Service
+@Slf4j
+public class SlackService {
+
+    @Value("${slack.webhook-url}")
+    private String SLACK_WEBHOOK_URL;
+
+    private final Slack slackClient = Slack.getInstance();
+
+    /**
+     * 슬랙 메시지 전송
+     **/
+    public void sendMessage(String title, Map<String, String> data) {
+        sendMessage(SlackMessageOptions.builder()
+                .title(title)
+                .data(data)
+                .build());
+    }
+
+    /**
+     * 슬랙 메시지 전송 (커스터마이징 옵션 사용)
+     **/
+    public void sendMessage(SlackMessageOptions options) {
+        if (options == null || !options.isEnabled()) {
+            return;
+        }
+
+        String webhookUrl = resolveWebhookUrl(options.getWebhookUrl());
+        // Production 환경에서만 슬랙 메시지를 전송합니다.
+        if (webhookUrl == null || webhookUrl.isEmpty()) {
+            return;
+        }
+        try {
+            String colorCode = resolveColorCode(options.getColorCode());
+            Map<String, String> data = options.getData();
+            slackClient.send(webhookUrl, payload(p -> p
+                    .text(options.getTitle()) // 메시지 제목
+                    .attachments(List.of(
+                            Attachment.builder().color(colorCode) // 메시지 색상
+                                    .fields( // 메시지 본문 내용
+                                            data == null ? List.of() : data.keySet().stream()
+                                                    .map(key -> generateSlackField(key, data.get(key)))
+                                                    .collect(Collectors.toList())
+                                    ).build())))
+            );
+        } catch (Exception e) {
+            log.error("Slack 메시지 전송에 실패했습니다.", e);
+        }
+    }
+
+    /**
+     * Slack Field 생성
+     **/
+    private Field generateSlackField(String title, String value) {
+        return Field.builder()
+                .title(title)
+                .value(value)
+                .valueShortEnough(false)
+                .build();
+    }
+
+    private String resolveWebhookUrl(String customWebhookUrl) {
+        if (customWebhookUrl != null && !customWebhookUrl.isEmpty()) {
+            return customWebhookUrl;
+        }
+        return SLACK_WEBHOOK_URL;
+    }
+
+    private String resolveColorCode(String customColorCode) {
+        if (customColorCode != null && !customColorCode.isEmpty()) {
+            return customColorCode;
+        }
+        return Color.RED.getCode();
+    }
+}
diff --git a/src/main/java/bitnagil/bitnagil_backend/kpi/event/KpiReportListener.java b/src/main/java/bitnagil/bitnagil_backend/kpi/event/KpiReportListener.java
diff --git a/src/main/java/bitnagil/bitnagil_backend/kpi/event/MonthlyKpiSavedEvent.java b/src/main/java/bitnagil/bitnagil_backend/kpi/event/MonthlyKpiSavedEvent.java
diff --git a/src/main/java/bitnagil/bitnagil_backend/kpi/service/KpiExcelExporterService.java b/src/main/java/bitnagil/bitnagil_backend/kpi/service/KpiExcelExporterService.java
diff --git a/src/main/java/bitnagil/bitnagil_backend/kpi/service/KpiService.java b/src/main/java/bitnagil/bitnagil_backend/kpi/service/KpiService.java

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package bitnagil.bitnagil_backend.global;`
	`1`	`+package bitnagil.bitnagil_backend.global.slack;`
`2`	`2`
`3`	`3`	`import lombok.Getter;`
`4`	`4`	`import lombok.RequiredArgsConstructor;`