Feat/16 ✨ FCM 푸시알림 구현

build.gradle

@@ -52,6 +52,10 @@ dependencies {
 	implementation 'io.springfox:springfox-swagger-ui:2.9.2'
 	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.0.2'
 
+	// fcm
+	implementation 'com.google.firebase:firebase-admin:9.2.0'
+//	implementation group: 'com.squareup.okhttp3', name: 'okhttp', version : '4.2.2'
+
 	annotationProcessor "org.springframework.boot:spring-boot-configuration-processor"
 }
 

src/main/java/cmc/peerna/apiResponse/code/ResponseStatus.java

@@ -1,5 +1,6 @@
 package cmc.peerna.apiResponse.code;
 
+import com.google.api.Http;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import org.springframework.http.HttpStatus;
@@ -48,6 +49,7 @@ public enum ResponseStatus implements BaseCode {
 
     INVALID_ACCESS_TOKEN(UNAUTHORIZED, 4016, "액세스 토큰이 없거나 유효하지 않습니다."),
 
+    FCM_TOKEN_NOT_FOUND(BAD_REQUEST, 4017, "해당 유저의 FCM 토큰이 존재하지 않습니다."),
 
     WRONG_POST_TEST(BAD_REQUEST, 4101, "잘못된 POST 테스트 요청입니다."),
 
@@ -58,8 +60,9 @@ public enum ResponseStatus implements BaseCode {
 
     // 500번대 에러
     _INTERNAL_SERVER_ERROR(INTERNAL_SERVER_ERROR, 5000, "서버 에러, 관리자에게 문의 바랍니다."),
-    FEIGN_CLIENT_ERROR_500(HttpStatus.INTERNAL_SERVER_ERROR, 5001, "Inter server Error in feign client");
+    FEIGN_CLIENT_ERROR_500(HttpStatus.INTERNAL_SERVER_ERROR, 5001, "Inter server Error in feign client"),
 
+    FCM_ACCESS_TOKEN_REQUEST_ERROR(INTERNAL_SERVER_ERROR, 5002, "서버 에러, FCM 서버에 AccessToken 요청할 때 에러 발생.");
 
     private final HttpStatus httpStatus;
     private final Integer code;

src/main/java/cmc/peerna/apiResponse/exception/handler/NotificationException.java

@@ -0,0 +1,10 @@
+package cmc.peerna.apiResponse.exception.handler;
+
+import cmc.peerna.apiResponse.code.ResponseStatus;
+import cmc.peerna.apiResponse.exception.GeneralException;
+
+public class NotificationException extends GeneralException {
+    public NotificationException(ResponseStatus code){
+        super(code);
+    }
+}

src/main/java/cmc/peerna/domain/FcmToken.java

@@ -0,0 +1,34 @@
+package cmc.peerna.domain;
+
+import jakarta.persistence.*;
+import lombok.*;
+import org.hibernate.annotations.DynamicInsert;
+import org.hibernate.annotations.DynamicUpdate;
+
+@Getter
+@Builder
+@Entity
+@DynamicInsert
+@DynamicUpdate
+@AllArgsConstructor(access = AccessLevel.PROTECTED)
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class FcmToken {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    private Member member;
+
+    private String token;
+
+    public FcmToken(final String token, final Member member) {
+        this.token = token;
+        this.member = member;
+    }
+
+    public void update(final String token) {
+        this.token = token;
+    }
+}

src/main/java/cmc/peerna/domain/PushAlarm.java

@@ -0,0 +1,35 @@
+package cmc.peerna.domain;
+
+import cmc.peerna.domain.common.BaseEntity;
+import jakarta.persistence.*;
+import lombok.*;
+import org.hibernate.annotations.DynamicInsert;
+import org.hibernate.annotations.DynamicUpdate;
+
+@Entity
+@Getter
+@Builder
+@AllArgsConstructor(access = AccessLevel.PROTECTED)
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@DynamicInsert
+@DynamicUpdate
+public class PushAlarm extends BaseEntity {
+
+    @Id @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    private String title;
+
+    private String body;
+
+    private Boolean isConfirmed;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "owner_id")
+    private Member ownerMember;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "member_id")
+    private Member targetMember;
+
+}

src/main/java/cmc/peerna/domain/enums/NotificationType.java

@@ -0,0 +1,13 @@
+package cmc.peerna.domain.enums;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+@Getter
+public enum NotificationType {
+    COMMENT("comment"),
+    EVENT("event");
+
+    private final String type;
+}

src/main/java/cmc/peerna/fcm/FcmInit.java

@@ -0,0 +1,35 @@
+package cmc.peerna.fcm;
+
+import com.google.auth.oauth2.GoogleCredentials;
+import com.google.firebase.FirebaseApp;
+import com.google.firebase.FirebaseOptions;
+import com.google.firebase.messaging.FirebaseMessaging;
+import jakarta.annotation.PostConstruct;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.io.ClassPathResource;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+@Configuration
+public class FcmInit {
+    @Value("${firebase.admin-sdk}")
+    private String FIREBASE_KEY_PATH;
+
+    @PostConstruct
+    public void firebaseMessaging() throws IOException {
+        ClassPathResource resource = new ClassPathResource(FIREBASE_KEY_PATH);
+        InputStream credentialStream = resource.getInputStream();
+        try {
+            FirebaseOptions options = FirebaseOptions.builder()
+                    .setCredentials(GoogleCredentials.fromStream(credentialStream))
+                    .build();
+            FirebaseApp.initializeApp(options);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+}

src/main/java/cmc/peerna/fcm/dto/FcmAOSMessage.java

@@ -0,0 +1,35 @@
+package cmc.peerna.fcm.dto;
+
+import lombok.*;
+
+@Builder
+@Getter
+@AllArgsConstructor(access = AccessLevel.PROTECTED)
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class FcmAOSMessage {
+
+    private boolean validateOnly;
+    private Message message;
+
+    @Builder
+    @Getter
+    @AllArgsConstructor(access = AccessLevel.PROTECTED)
+    @NoArgsConstructor(access = AccessLevel.PROTECTED)
+    public static class Message{
+        private Data data;
+        private String token;
+    }
+
+
+    @Builder
+    @Getter
+    @AllArgsConstructor(access = AccessLevel.PROTECTED)
+    @NoArgsConstructor(access = AccessLevel.PROTECTED)
+    public static class Data{
+        private String title;
+        private String body;
+        private String targetView;
+        private String targetPK;
+        private String targetNotificationPK;
+    }
+}

src/main/java/cmc/peerna/fcm/dto/FcmTokenRequest.java

@@ -0,0 +1,12 @@
+package cmc.peerna.fcm.dto;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+@Getter
+public class FcmTokenRequest {
+
+    private final String token;
+    private final Long memberId;
+}

src/main/java/cmc/peerna/fcm/service/FcmService.java

@@ -0,0 +1,36 @@
+package cmc.peerna.fcm.service;
+
+import com.google.firebase.messaging.FirebaseMessaging;
+import com.google.firebase.messaging.FirebaseMessagingException;
+import com.google.firebase.messaging.Message;
+import com.google.firebase.messaging.Notification;
+import lombok.RequiredArgsConstructor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+public class FcmService {
+    Logger logger = LoggerFactory.getLogger(FcmService.class);
+
+    public void testFCMService(String fcmToken)
+    {
+        Message message = Message.builder()
+                .setToken(fcmToken)
+                .setNotification(
+                        Notification.builder()
+                                .setTitle("PeerNa FCM 테스트입니당")
+                                .setBody("테스트 성공했나요??")
+                                .build())
+                .build();
+        try {
+            String response = FirebaseMessaging.getInstance().send(message);
+            logger.info("the response of request FCM : {}",response);
+        }catch (FirebaseMessagingException e){
+            e.printStackTrace();
+        }
+    }
+}

src/main/java/cmc/peerna/feign/FCMFeignClient.java

@@ -0,0 +1,18 @@
+package cmc.peerna.feign;
+
+import cmc.peerna.feign.config.FCMFeignConfig;
+import cmc.peerna.feign.dto.FCMResponseDto;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestHeader;
+
+@FeignClient(name = "FCMFeign", url = "https://fcm.googleapis.com", configuration = FCMFeignConfig.class)
+@Component
+public interface FCMFeignClient {
+
+    @PostMapping("/v1/projects/peerna-68c2d/messages:send")
+    FCMResponseDto getFCMResponse(@RequestHeader("Authorization") String token, @RequestBody String fcmAOSMessage);
+}

src/main/java/cmc/peerna/feign/config/FCMFeignConfig.java

@@ -0,0 +1,27 @@
+package cmc.peerna.feign.config;
+
+import cmc.peerna.feign.exception.FeignClientExceptionErrorDecoder;
+import feign.Logger;
+import feign.RequestInterceptor;
+import feign.codec.ErrorDecoder;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.annotation.Bean;
+
+@RequiredArgsConstructor
+public class FCMFeignConfig {
+
+    @Bean
+    public RequestInterceptor requestInterceptor(){
+        return template -> template.header("Content-Type", "application/json;charset=UTF-8");
+    }
+
+    @Bean
+    public ErrorDecoder errorDecoder() {
+        return  new FeignClientExceptionErrorDecoder();
+    }
+
+    @Bean
+    Logger.Level feignLoggerLevel() {
+        return Logger.Level.FULL;
+    }
+}

src/main/java/cmc/peerna/feign/dto/FCMResponseDto.java

@@ -0,0 +1,10 @@
+package cmc.peerna.feign.dto;
+
+import lombok.*;
+
+@Getter
+@Setter
+@NoArgsConstructor
+public class FCMResponseDto {
+    String name;
+}

src/main/java/cmc/peerna/repository/FcmTokenRepository.java

@@ -0,0 +1,10 @@
+package cmc.peerna.repository;
+
+import cmc.peerna.domain.FcmToken;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.Optional;
+
+public interface FcmTokenRepository extends JpaRepository<FcmToken, Long> {
+    Optional<FcmToken> findByMemberId(Long memberId);
+}

src/main/java/cmc/peerna/repository/PushAlarmRepository.java

@@ -0,0 +1,17 @@
+package cmc.peerna.repository;
+
+import cmc.peerna.domain.Member;
+import cmc.peerna.domain.PushAlarm;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+public interface PushAlarmRepository extends JpaRepository<PushAlarm, Long> {
+
+    Page<PushAlarm> findByOwnerMember(Member member, PageRequest pageRequest);
+
+
+    List<PushAlarm> findByTitleAndOwnerMemberAndIsConfirmedFalse(String title, Member member);
+}

src/main/java/cmc/peerna/service/RootService.java

@@ -4,6 +4,7 @@
 import cmc.peerna.web.dto.responseDto.RootResponseDto;
 import cmc.peerna.web.dto.responseDto.TestResponseDto;
 
+import java.io.IOException;
 import java.util.List;
 
 public interface RootService {

src/main/java/cmc/peerna/service/serviceImpl/RootServiceImpl.java

@@ -8,20 +8,27 @@
 import cmc.peerna.domain.enums.PeerCard;
 import cmc.peerna.domain.enums.PeerGrade;
 import cmc.peerna.domain.enums.TestType;
+import cmc.peerna.fcm.service.FcmService;
 import cmc.peerna.repository.*;
 import cmc.peerna.service.RootService;
 import cmc.peerna.utils.TestResultCalculator;
 import cmc.peerna.web.dto.responseDto.MemberResponseDto;
 import cmc.peerna.web.dto.responseDto.RootResponseDto;
 import cmc.peerna.web.dto.responseDto.TestResponseDto;
+import com.google.firebase.messaging.FirebaseMessaging;
+import com.google.firebase.messaging.FirebaseMessagingException;
+import com.google.firebase.messaging.Message;
+import com.google.firebase.messaging.Notification;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Sort;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
+import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Comparator;
@@ -36,7 +43,9 @@ public class RootServiceImpl implements RootService {
     private final PeerFeedbackRepository peerFeedbackRepository;
     private final PeerGradeResultRepository peerGradeResultRepository;
     private final PeerTestRepository peerTestRepository;
+    private final PushAlarmRepository pushAlarmRepository;
     private final TestResultCalculator testResultCalculator;
+    private final FcmService fcmService;
     @Value("${paging.size}")
     private Integer pageSize;
     @Override
@@ -131,4 +140,5 @@ public RootResponseDto.AllFeedbackDto getFeedbackList(Member member, Integer pag
         return allFeedbackDto;
     }
 
+
 }