Merge pull request #308 from 6QuizOnTheBlock/be/feat/#297-notice_fcm

feat: 알림장 작성 시 FCM 전송 기능
6QuizOnTheBlock · May 13, 2024 · dfa05ee · dfa05ee
2 parents 92fbba4 + bae69bb
commit dfa05ee
Show file tree

Hide file tree

Showing 5 changed files with 45 additions and 8 deletions.
diff --git a/backEnd/src/main/java/com/quiz/ourclass/domain/board/sevice/PostServiceImpl.java b/backEnd/src/main/java/com/quiz/ourclass/domain/board/sevice/PostServiceImpl.java
@@ -22,6 +22,7 @@
 import com.quiz.ourclass.domain.notice.entity.Notice;
 import com.quiz.ourclass.domain.notice.entity.NoticeType;
 import com.quiz.ourclass.domain.notice.repository.NoticeRepository;
+import com.quiz.ourclass.domain.organization.entity.MemberOrganization;
 import com.quiz.ourclass.domain.organization.entity.Organization;
 import com.quiz.ourclass.domain.organization.repository.OrganizationRepository;
 import com.quiz.ourclass.global.dto.FcmDTO;
@@ -102,6 +103,33 @@ public Long write(Long organizationId, MultipartFile file, PostRequest request)
         Post post = postMapper.postRequestToPost(
             request, member, organization, now, image
         );
+        //알림장 작성 시 단체 학생들에게 FCM 발송
+        if (post.getPostCategory() == PostCategory.NOTICE) {
+            String title = fcmUtil.makeNoticeTitle(
+                post.getOrganization().getName(), FcmType.NOTICE.getType()
+            );
+            String body = fcmUtil.makeNoticeBody(
+                post.getOrganization().getName(), FcmType.NOTICE.getType()
+            );
+            FcmDTO fcmDTO = fcmUtil.makeFcmDTO(title, body);
+
+            // 알림 저장
+            Notice notice = Notice.builder()
+                .receiver(post.getOrganization().getManager())
+                .url(member.getName())
+                .content(body)
+                .type(NoticeType.NOTICE)
+                .createTime(LocalDateTime.now())
+                .build();
+            noticeRepository.save(notice);
+
+            fcmUtil.multiFcmSend(
+                organization.getMemberOrganizations().stream()
+                    .map(MemberOrganization::getMember)
+                    .toList(),
+                fcmDTO
+            );
+        }
         return postRepository.save(post).getId();
     }
 

diff --git a/backEnd/src/main/java/com/quiz/ourclass/domain/notice/entity/NoticeType.java b/backEnd/src/main/java/com/quiz/ourclass/domain/notice/entity/NoticeType.java
@@ -1,5 +1,5 @@
 package com.quiz.ourclass.domain.notice.entity;
 
 public enum NoticeType {
-    TAG, RELAY, TALK, REPORT
+    TAG, RELAY, TALK, REPORT, NOTICE
 }
diff --git a/backEnd/src/main/java/com/quiz/ourclass/global/util/ConstantUtil.java b/backEnd/src/main/java/com/quiz/ourclass/global/util/ConstantUtil.java
@@ -13,5 +13,8 @@ public abstract class ConstantUtil {
     public static final int RELAY_DEMERIT = -100;
     public static final int RELAY_REWARD = 50;
     public static final Long RELAY_TIMEOUT_DAY = 1L;
+    public static final String FCM_KEY_PREFIX = "FCM_";
+    public static final int MAX_RETRIES = 5; //최대 재시도 횟수
+    public static final long INITIAL_BACKOFF = 1000L; //초기 백오프 시간 (1초)
 
 }
diff --git a/backEnd/src/main/java/com/quiz/ourclass/global/util/FcmType.java b/backEnd/src/main/java/com/quiz/ourclass/global/util/FcmType.java
@@ -8,6 +8,7 @@
 public enum FcmType {
     POST("게시글"),
     COMMENT("댓글"),
+    NOTICE("알림장"),
     ;
     private final String Type;
 }
diff --git a/backEnd/src/main/java/com/quiz/ourclass/global/util/FcmUtil.java b/backEnd/src/main/java/com/quiz/ourclass/global/util/FcmUtil.java
@@ -18,9 +18,6 @@
 public class FcmUtil {
 
     private final RedisUtil redisUtil;
-    private static final String FCM_KEY_PREFIX = "FCM_";
-    private static final int MAX_RETRIES = 5; //최대 재시도 횟수
-    private static final long INITIAL_BACKOFF = 1000L; //초기 백오프 시간 (1초)
 
     @Async("taskExecutor")
     public void singleFcmSend(Member member, FcmDTO fcmDTO) {
@@ -38,7 +35,7 @@ public void multiFcmSend(List<Member> members, FcmDTO fcmDTO) {
     }
 
     private String getFcmRedisKey(Long memberId) {
-        return FCM_KEY_PREFIX + memberId;
+        return ConstantUtil.FCM_KEY_PREFIX + memberId;
     }
 
     public Message makeMessage(String title, String body, String token) {
@@ -55,17 +52,17 @@ public Message makeMessage(String title, String body, String token) {
 
     private void sendMessage(Message message) {
         int attempt = 0;
-        long backoff = INITIAL_BACKOFF;
+        long backoff = ConstantUtil.INITIAL_BACKOFF;
 
-        while (attempt < MAX_RETRIES) { //지수 백오프 전략
+        while (attempt < ConstantUtil.MAX_RETRIES) { //지수 백오프 전략
             try {
                 FirebaseMessaging.getInstance().send(message);
                 log.info("FCM Send Success");
                 break;  // 성공 시 루프 종료
             } catch (FirebaseMessagingException e) {
                 log.error("FCM Send Error: {}", e.getMessage());
                 attempt++;
-                if (attempt >= MAX_RETRIES) {
+                if (attempt >= ConstantUtil.MAX_RETRIES) {
                     // 최대 재시도 횟수 도달 시 루프 종료
                     // 다른 메시지 시스템으로 알림을 전송하는 방법을 고려해볼 수 있음
                     log.error("Reached Maximum Retry Attempts");
@@ -97,4 +94,12 @@ public String makeReportTitle(String organizationName, String type) {
     public String makeReportBody(String authorMember, String reportMember, String type) {
         return authorMember + " 학생이 작성한 " + type + "을" + reportMember + "학생이 신고하였습니다.";
     }
+
+    public String makeNoticeTitle(String organizationName, String type) {
+        return organizationName + " " + type;
+    }
+
+    public String makeNoticeBody(String organizationName, String type) {
+        return organizationName + " " + type + "이 등록되었어요!!";
+    }
 }