[Feature] 알림 기능 구현

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;

src/main/java/hanium/modic/backend/domain/follow/service/FollowService.java

@@ -15,9 +15,11 @@
 import hanium.modic.backend.domain.follow.dto.FollowerWithStatus;
 import hanium.modic.backend.domain.follow.dto.FollowingWithStatus;
 import hanium.modic.backend.domain.follow.repository.FollowEntityRepository;
+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.domain.user.repository.UserImageEntityRepository;
 import hanium.modic.backend.domain.user.service.UserImageService;
 import hanium.modic.backend.web.follow.dto.response.GetFollowersResponse;
 import hanium.modic.backend.web.follow.dto.response.GetFollowersWithStatusResponse;
@@ -28,10 +30,15 @@
 @Service
 @RequiredArgsConstructor
 public class FollowService {
+	// 팔로우 관련
 	private final FollowEntityRepository followRepository;
+
+	// 유저 관련
 	private final UserEntityRepository userRepository;
 	private final UserImageService userImageService;
-	private final UserImageEntityRepository userImageRepository;
+
+	// 알림 관련
+	private final NotificationService notificationService;
 
 	// 팔로우 또는 언팔로우 처리
 	@Transactional
@@ -51,6 +58,14 @@ public void followOrUnfollow(
 		// 팔로우 요청 및 기존 팔로우 존재 여부에 따라 팔로우, 언팔로우 처리
 		if (type == FOLLOW) {
 			followRepository.insertFollowIfExist(me.getId(), target.getId());
+
+			// 알림 생성
+			notificationService.createNotification(
+				targetId,
+				NotificationType.FOLLOWED,
+				NotificationPayload.builder(me.getId(), me.getName(), me.getEmail())
+					.build()
+			);
 		} else if (type == UNFOLLOW) {
 			followRepository.deleteByMyIdAndFollowingId(me.getId(), targetId);
 		}

src/main/java/hanium/modic/backend/domain/notification/dto/GetNotificationsResponse.java

@@ -0,0 +1,30 @@
+package hanium.modic.backend.domain.notification.dto;
+
+import java.time.LocalDateTime;
+
+import hanium.modic.backend.domain.notification.entity.NotificationEntity;
+import hanium.modic.backend.domain.notification.enums.NotificationStatus;
+import hanium.modic.backend.domain.notification.enums.NotificationType;
+
+public record GetNotificationsResponse(
+	Long notificationId,
+	NotificationType type,
+	NotificationStatus status,
+	String title,
+	String body,
+	Long postId,
+	LocalDateTime createdAt
+) {
+
+	public static GetNotificationsResponse of(NotificationEntity entity, NotificationPayload payload) {
+		return new GetNotificationsResponse(
+			entity.getId(),
+			entity.getType(),
+			entity.getStatus(),
+			entity.getTitle(),
+			entity.getBody(),
+			payload.postId(),
+			entity.getCreateAt()
+		);
+	}
+}

src/main/java/hanium/modic/backend/domain/notification/dto/GetUnreadCountResponse.java

@@ -0,0 +1,6 @@
+package hanium.modic.backend.domain.notification.dto;
+
+public record GetUnreadCountResponse(
+	long unreadCount
+) {
+}

src/main/java/hanium/modic/backend/domain/notification/dto/NotificationPayload.java

@@ -0,0 +1,71 @@
+package hanium.modic.backend.domain.notification.dto;
+
+public record NotificationPayload(
+	Long senderId,
+	String senderNickname,
+	String senderEmail,   // 추가됨
+	Long postId,
+	String postTitle,
+	Long amount,
+	String reviewContent
+) {
+
+	public static NotificationPayload empty() {
+		return new NotificationPayload(
+			null, null, null, null, null, null, null
+		);
+	}
+
+	public static Builder builder(Long senderId, String senderNickname, String senderEmail) {
+		return new Builder(senderId, senderNickname, senderEmail);
+	}
+
+	public static class Builder {
+		private final Long senderId;
+		private final String senderNickname;
+		private final String senderEmail;
+
+		private Long postId;
+		private String postTitle;
+		private Long amount;
+		private String reviewContent;
+
+		public Builder(Long senderId, String senderNickname, String senderEmail) {
+			this.senderId = senderId;
+			this.senderNickname = senderNickname;
+			this.senderEmail = senderEmail;
+		}
+
+		public Builder postId(Long postId) {
+			this.postId = postId;
+			return this;
+		}
+
+		public Builder postTitle(String postTitle) {
+			this.postTitle = postTitle;
+			return this;
+		}
+
+		public Builder amount(Long amount) {
+			this.amount = amount;
+			return this;
+		}
+
+		public Builder reviewContent(String reviewContent) {
+			this.reviewContent = reviewContent;
+			return this;
+		}
+
+		public NotificationPayload build() {
+			return new NotificationPayload(
+				senderId,
+				senderNickname,
+				senderEmail,
+				postId,
+				postTitle,
+				amount,
+				reviewContent
+			);
+		}
+	}
+}