Merge pull request #265 from Modic-2025/feature/243-implement-notification

[Feature] 알림 기능 구현

Author: yooooonshine

src/main/java/hanium/modic/backend/common/property/config/PropertyConfig.java

@@ -7,6 +7,7 @@
 import hanium.modic.backend.common.property.property.CloudFrontProperties;
 import hanium.modic.backend.common.property.property.CorsProperties;
 import hanium.modic.backend.common.property.property.EmailProperty;
+import hanium.modic.backend.common.property.property.NotificationProperties;
 import hanium.modic.backend.common.property.property.RabbitMqProperties;
 import hanium.modic.backend.common.property.property.RedisProperty;
 import hanium.modic.backend.common.property.property.S3Properties;
@@ -28,7 +29,8 @@
 	RabbitMqProperties.class,
 	CloudFrontProperties.class,
 	AiProperties.class,
-	VoteProperties.class
+	VoteProperties.class,
+	NotificationProperties.class
 })
 public class PropertyConfig {
 }

src/main/java/hanium/modic/backend/common/property/property/NotificationProperties.java

@@ -0,0 +1,31 @@
+package hanium.modic.backend.common.property.property;
+
+import java.time.Duration;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@ConfigurationProperties(prefix = "notification")
+public class NotificationProperties {
+
+	/**
+	 * 읽은 알림을 얼마 동안 유지할지(분 단위)
+	 */
+	private long readRetentionMinutes = Duration.ofDays(30).toMinutes(); // 기본값: 30일
+
+	public long getReadRetentionMinutes() {
+		return readRetentionMinutes;
+	}
+
+	public void setReadRetentionMinutes(long readRetentionMinutes) {
+		this.readRetentionMinutes = readRetentionMinutes;
+	}
+
+	public Duration getReadRetentionDuration() {
+		return Duration.ofMinutes(readRetentionMinutes);
+	}
+}

src/main/java/hanium/modic/backend/common/scheduler/DailyScheduler.java

@@ -0,0 +1,20 @@
+package hanium.modic.backend.common.scheduler;
+
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import hanium.modic.backend.domain.notification.service.NotificationService;
+import lombok.RequiredArgsConstructor;
+
+@Component
+@RequiredArgsConstructor
+public class DailyScheduler {
+
+	private final NotificationService notificationService;
+
+	// 매일 자정(00:00:00)에 실행
+	@Scheduled(cron = "0 0 0 * * *")
+	public void runEveryMidnight() {
+		notificationService.cleanupExpiredNotifications();
+	}
+}

src/main/java/hanium/modic/backend/common/scheduler/config/SchedulingConfig.java

@@ -0,0 +1,9 @@
+package hanium.modic.backend.common.scheduler.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@Configuration
+@EnableScheduling
+public class SchedulingConfig {
+}

src/main/java/hanium/modic/backend/domain/ai/aiChat/service/AiImagePermissionService.java

@@ -7,7 +7,12 @@
 
 import hanium.modic.backend.common.error.exception.AppException;
 import hanium.modic.backend.common.error.exception.LockException;
-import hanium.modic.backend.common.redis.distributedLock.LockManager;
+import hanium.modic.backend.domain.notification.dto.NotificationPayload;
+import hanium.modic.backend.domain.notification.enums.NotificationType;
+import hanium.modic.backend.domain.notification.service.NotificationService;
+import hanium.modic.backend.domain.user.entity.UserEntity;
+import hanium.modic.backend.domain.user.repository.UserEntityRepository;
+import hanium.modic.backend.infra.redis.distributedLock.LockManager;
 import hanium.modic.backend.domain.ai.aiChat.entity.AiChatRoomEntity;
 import hanium.modic.backend.domain.ai.aiChat.repository.AiChatRoomRepository;
 import hanium.modic.backend.domain.post.entity.PostEntity;
@@ -25,7 +30,9 @@ public class AiImagePermissionService {
 	private final TicketService ticketService;
 	private final PostEntityRepository postRepository;
 	private final AiChatRoomRepository aiChatRoomRepository;
+	private final NotificationService notificationService;
 	private final LockManager lockManager;
+	private final UserEntityRepository userEntityRepository;
 
 	private final int AI_IMAGE_PERMISSION_COUNT = 20; // 구매 시 제공되는 이미지 생성 횟수
 
@@ -42,6 +49,19 @@ public void buyAiImagePermissionByCoin(Long userId, Long postId) {
 
 		// 3) 코인 후차감, 코인 거래는 별도의 트랜잭션으로 동작하여 후처리, 예외는 전파
 		userCoinService.consumeCoin(userId, post.getNonCommercialPrice());
+
+		// 4) 알림
+		UserEntity user = userEntityRepository.findById(userId)
+			.orElseThrow(() -> new AppException(USER_NOT_FOUND_EXCEPTION));
+		notificationService.createNotification(
+			post.getUserId(),
+			NotificationType.POST_PURCHASED_BY_COIN,
+			NotificationPayload.builder(userId, user.getName(), user.getEmail())
+				.postId(post.getId())
+				.postTitle(post.getTitle())
+				.amount(post.getNonCommercialPrice())
+				.build()
+		);
 	}
 
 	// 티켓으로 AI 이미지 생성권 구매
@@ -56,6 +76,19 @@ public void buyAiImagePermissionByTicket(final Long userId, final Long postId) {
 
 		// 3) 티켓 후차감, 코인 거래는 별도의 트랜잭션으로 동작하여 후처리, 예외는 전파
 		ticketService.useTicket(userId, post.getTicketPrice());
+
+		// 4) 알림
+		UserEntity user = userEntityRepository.findById(userId)
+			.orElseThrow(() -> new AppException(USER_NOT_FOUND_EXCEPTION));
+		notificationService.createNotification(
+			post.getUserId(),
+			NotificationType.POST_PURCHASED_BY_TICKET,
+			NotificationPayload.builder(userId, user.getName(), user.getEmail())
+				.postId(post.getId())
+				.postTitle(post.getTitle())
+				.amount(post.getTicketPrice())
+				.build()
+		);
 	}
 
 	// 이미지 생성권 소모

src/main/java/hanium/modic/backend/domain/ai/aiServer/listener/AiImageCreatedDlqListener.java

@@ -1,6 +1,6 @@
 package hanium.modic.backend.domain.ai.aiServer.listener;
 
-import static hanium.modic.backend.common.amqp.config.RabbitMqConfig.*;
+import static hanium.modic.backend.infra.amqp.config.RabbitMqConfig.*;
 
 import java.util.Optional;
 

src/main/java/hanium/modic/backend/domain/ai/aiServer/listener/AiImageCreatedListener.java

@@ -1,6 +1,6 @@
 package hanium.modic.backend.domain.ai.aiServer.listener;
 
-import static hanium.modic.backend.common.amqp.config.RabbitMqConfig.*;
+import static hanium.modic.backend.infra.amqp.config.RabbitMqConfig.*;
 
 import java.util.Optional;
 

src/main/java/hanium/modic/backend/domain/ai/aiServer/listener/DlqListener.java

@@ -1,6 +1,6 @@
 package hanium.modic.backend.domain.ai.aiServer.listener;
 
-import static hanium.modic.backend.common.amqp.config.RabbitMqConfig.*;
+import static hanium.modic.backend.infra.amqp.config.RabbitMqConfig.*;
 
 import java.util.Optional;
 

src/main/java/hanium/modic/backend/domain/ai/aiServer/service/AiResponseSseService.java

@@ -8,7 +8,7 @@
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
 import hanium.modic.backend.common.error.exception.AppException;
-import hanium.modic.backend.common.sse.service.EmitterService;
+import hanium.modic.backend.infra.sse.service.EmitterService;
 import hanium.modic.backend.domain.ai.aiChat.entity.AiChatMessageEntity;
 import hanium.modic.backend.domain.ai.aiChat.repository.AiChatMessageRepository;
 import hanium.modic.backend.domain.ai.aiServer.enums.SenderType;

src/main/java/hanium/modic/backend/domain/ai/aiServer/service/AiServerService.java

@@ -12,7 +12,7 @@
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 
-import hanium.modic.backend.common.amqp.service.MessageQueueService;
+import hanium.modic.backend.infra.amqp.service.MessageQueueService;
 import hanium.modic.backend.common.error.ErrorCode;
 import hanium.modic.backend.common.error.exception.AppException;
 import hanium.modic.backend.domain.ai.aiChat.entity.AiChatMessageEntity;