Feature/26 notification

build.gradle

@@ -63,6 +63,9 @@ dependencies {
 
     // sms
     implementation 'com.solapi:sdk:1.0.3'
+
+    // firebase
+    implementation 'com.google.firebase:firebase-admin:9.1.1'
 }
 
 tasks.named('test') {

src/main/java/ita/tinybite/TinyBiteApplication.java

@@ -3,9 +3,11 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @EnableJpaAuditing
+@EnableScheduling
 public class TinyBiteApplication {
     public static void main(String[] args) {
         SpringApplication.run(TinyBiteApplication.class, args);

src/main/java/ita/tinybite/domain/notification/controller/FcmTokenController.java

@@ -0,0 +1,29 @@
+package ita.tinybite.domain.notification.controller;
+
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestHeader;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import ita.tinybite.domain.notification.dto.request.FcmTokenRequest;
+import ita.tinybite.domain.notification.service.FcmTokenService;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api/v1/fcm")
+public class FcmTokenController {
+
+	private final FcmTokenService fcmTokenService;
+
+	// token 이미 존재 시 업데이트 해줌
+	@PostMapping("/token")
+	public ResponseEntity<Void> registerToken(@RequestBody @Valid FcmTokenRequest request,
+		@RequestHeader(name = "User-ID") Long currentUserId) {
+		fcmTokenService.saveOrUpdateToken(currentUserId, request.token());
+		return ResponseEntity.noContent().build();
+	}
+}

src/main/java/ita/tinybite/domain/notification/converter/NotificationLogConverter.java

@@ -0,0 +1,23 @@
+package ita.tinybite.domain.notification.converter;
+
+import org.springframework.stereotype.Component;
+
+import ita.tinybite.domain.notification.entity.Notification;
+import ita.tinybite.domain.notification.enums.NotificationType;
+
+@Component
+public class NotificationLogConverter {
+
+	public Notification toEntity(Long targetUserId, String type, String title,String detail) {
+
+		NotificationType notificationType = NotificationType.valueOf(type);
+
+		return Notification.builder()
+			.userId(targetUserId)
+			.notificationType(notificationType)
+			.notificationTitle(title)
+			.notificationDetail(detail)
+			.isRead(false)
+			.build();
+	}
+}

src/main/java/ita/tinybite/domain/notification/converter/NotificationRequestConverter.java

@@ -0,0 +1,26 @@
+package ita.tinybite.domain.notification.converter;
+
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.stereotype.Component;
+
+import ita.tinybite.domain.notification.dto.request.NotificationMulticastRequest;
+
+@Component
+public class NotificationRequestConverter {
+
+	public NotificationMulticastRequest toMulticastRequest(
+		List<String> tokens,
+		String title,
+		String body,
+		Map<String, String> data) {
+
+		return NotificationMulticastRequest.builder()
+			.tokens(tokens)
+			.title(title)
+			.body(body)
+			.data(data)
+			.build();
+	}
+}

src/main/java/ita/tinybite/domain/notification/dto/request/FcmTokenRequest.java

@@ -0,0 +1,8 @@
+package ita.tinybite.domain.notification.dto.request;
+
+import jakarta.validation.constraints.NotNull;
+
+public record FcmTokenRequest(
+	@NotNull(message = "FCM 토큰은 필수입니다.")
+	String token
+) {}

src/main/java/ita/tinybite/domain/notification/dto/request/NotificationMulticastRequest.java

@@ -0,0 +1,43 @@
+package ita.tinybite.domain.notification.dto.request;
+
+import java.util.List;
+import java.util.Map;
+
+import com.google.firebase.internal.NonNull;
+import com.google.firebase.messaging.MulticastMessage;
+import com.google.firebase.messaging.Notification;
+
+import lombok.Builder;
+
+@Builder
+public record NotificationMulticastRequest(
+	@NonNull List<String> tokens,
+	String title,
+	String body,
+	Map<String, String> data
+) implements NotificationRequest {
+
+	public MulticastMessage.Builder buildSendMessage() {
+		MulticastMessage.Builder builder = MulticastMessage.builder()
+			.setNotification(toNotification())
+			.addAllTokens(tokens);
+
+		if (this.data != null && !this.data.isEmpty()) {
+			builder.putAllData(this.data);
+		}
+
+		return builder;
+	}
+
+	public Notification toNotification() {
+		return Notification.builder()
+			.setTitle(title)
+			.setBody(body)
+			.build();
+	}
+
+	@Override
+	public Map<String, String> data() {
+		return this.data;
+	}
+}

src/main/java/ita/tinybite/domain/notification/dto/request/NotificationRequest.java

@@ -0,0 +1,12 @@
+package ita.tinybite.domain.notification.dto.request;
+
+import java.util.Map;
+
+import com.google.firebase.messaging.Notification;
+
+public interface NotificationRequest {
+	String title();
+	String body();
+	Notification toNotification();
+	Map<String, String> data();
+}

src/main/java/ita/tinybite/domain/notification/dto/request/NotificationSingleRequest.java

@@ -0,0 +1,42 @@
+package ita.tinybite.domain.notification.dto.request;
+
+import java.util.Map;
+
+import com.google.firebase.internal.NonNull;
+import com.google.firebase.messaging.Message;
+import com.google.firebase.messaging.Notification;
+
+import lombok.Builder;
+
+@Builder
+public record NotificationSingleRequest(
+	@NonNull String token,
+	String title,
+	String body,
+	Map<String, String> data
+) implements NotificationRequest {
+
+	public Message.Builder buildMessage() {
+		Message.Builder builder = Message.builder()
+			.setToken(token)
+			.setNotification(toNotification());
+
+		if (this.data != null && !this.data.isEmpty()) {
+			builder.putAllData(this.data);
+		}
+
+		return builder;
+	}
+
+	public Notification toNotification() {
+		return Notification.builder()
+			.setTitle(title)
+			.setBody(body)
+			.build();
+	}
+
+	@Override
+	public Map<String, String> data() {
+		return this.data;
+	}
+}

src/main/java/ita/tinybite/domain/notification/entity/FcmToken.java

@@ -0,0 +1,42 @@
+package ita.tinybite.domain.notification.entity;
+
+import ita.tinybite.global.entity.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@Builder
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Table(name = "fcm_tokens")
+public class FcmToken extends BaseEntity {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	private Long id;
+
+	@Column(name = "user_id", nullable = false)
+	private Long userId;
+
+	@Column(name = "token", nullable = false)
+	private String token;
+
+	@Builder.Default
+	@Column(name = "is_active", nullable = false)
+	private Boolean isActive = Boolean.TRUE;
+
+	public void updateToken(String newToken) {
+		this.token = newToken;
+		this.isActive = Boolean.TRUE;
+	}
+}

src/main/java/ita/tinybite/domain/notification/entity/Notification.java

@@ -0,0 +1,54 @@
+package ita.tinybite.domain.notification.entity;
+
+import ita.tinybite.domain.notification.enums.NotificationType;
+import ita.tinybite.global.entity.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@Builder
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Table(name = "notification")
+public class Notification extends BaseEntity {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "id")
+	private Long id;
+
+	@Column(name = "user_id", nullable = false)
+	private Long userId;
+
+	@Enumerated(EnumType.STRING)
+	@Column(name = "notification_type", nullable = false)
+	private NotificationType notificationType;
+
+	@Column(name = "notification_title", nullable = false)
+	private String notificationTitle;
+
+	@Column(name = "notification_detail", columnDefinition = "TEXT")
+	private String notificationDetail;
+
+	@Builder.Default
+	@Column(name = "is_read", nullable = false)
+	private Boolean isRead = Boolean.FALSE;
+
+	public void markAsRead() {
+		if (Boolean.FALSE.equals(this.isRead)) {
+			this.isRead = Boolean.TRUE;
+		}
+	}
+}

src/main/java/ita/tinybite/domain/notification/enums/NotificationType.java

@@ -0,0 +1,32 @@
+package ita.tinybite.domain.notification.enums;
+
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor(access = AccessLevel.PROTECTED)
+public enum NotificationType {
+	// 채팅
+	CHAT_NEW_MESSAGE,
+	CHAT_UNREAD_REMINDER,
+
+	// 파티 참여
+	PARTY_APPROVAL,
+	PARTY_REJECTION,
+	PARTY_AUTO_CLOSE,
+	PARTY_ORDER_COMPLETE,
+	PARTY_DELIVERY_REMINDER,
+	PARTY_COMPLETE,
+
+	// 파티 운영
+	PARTY_NEW_REQUEST,
+	PARTY_MEMBER_LEAVE,
+	PARTY_MANAGER_DELIVERY_REMINDER,
+
+	// 마케팅 알림
+	MARKETING_LOCAL_NEW_PARTY,
+	MARKETING_WEEKLY_POPULAR,
+	MARKETING_PROMOTION_EVENT;
+
+}

src/main/java/ita/tinybite/domain/notification/infra/creator/APNsConfigCreator.java

@@ -0,0 +1,32 @@
+package ita.tinybite.domain.notification.infra.creator;
+
+import com.google.firebase.messaging.ApnsConfig;
+import com.google.firebase.messaging.Aps;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public class APNsConfigCreator {
+
+	public static ApnsConfig createDefaultConfig() {
+		return ApnsConfig.builder()
+			.setAps(Aps.builder()
+				.setSound("default")
+				.setBadge(1)
+				.build()
+			)
+			.build();
+	}
+
+	// 이벤트별로 동적인 뱃지 숫자 설정
+	public static ApnsConfig createConfigWithBadge(int badgeCount) {
+		return ApnsConfig.builder()
+			.setAps(Aps.builder()
+				.setSound("default")
+				.setBadge(badgeCount)
+				.build()
+			)
+			.build();
+	}
+}