Feat: 알림 추가 기능 구현

Feat: 알림 추가 기능 구현

Author: caminobelllo

src/main/java/UMC/news/newsIntelligent/domain/member/repository/MemberTopicRepository.java

@@ -1,5 +1,7 @@
 package UMC.news.newsIntelligent.domain.member.repository;
 
+import java.util.Collection;
+import java.util.List;
 import java.util.Optional;
 
 import UMC.news.newsIntelligent.domain.member.entity.MemberTopic;
@@ -59,4 +61,20 @@ Slice<Topic> searchReadTopicsByKeyword(
          order by t.summaryTime desc
     """)
     Page<Topic> findSubscribedTopicsOrderByUpdatedDesc(@Param("memberId") Long memberId, Pageable pageable);
+
+    // 해당 토픽을 구독한 멤버 조회
+    @Query("""
+        SELECT mt.member.id
+        FROM MemberTopic mt
+        WHERE mt.topic.id = :topicId AND mt.isSubscribe = true
+    """)
+    List<Long> findSubscribedMemberIdsByTopicId(Long topicId);
+
+    // 해당 토픽을 읽은 멤버 조회
+    @Query("""
+        SELECT mt.member.id
+        FROM MemberTopic mt
+        WHERE mt.topic.id IN :topicId AND mt.isRead = true
+    """)
+    List<Long> findReadMemberIdsByTopicId(Long topicId);
 }

src/main/java/UMC/news/newsIntelligent/domain/news/entity/LatestCorrection.java

@@ -0,0 +1,44 @@
+package UMC.news.newsIntelligent.domain.news.entity.latestCorrection;
+
+import UMC.news.newsIntelligent.domain.topic.entity.Topic;
+import UMC.news.newsIntelligent.global.entity.BaseEntity;
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Table(name = "latest_correction")
+public class LatestCorrection extends BaseEntity {
+
+    @Id @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "run_key", nullable = false, length = 36)
+    private String runKey;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "topic_id", nullable = false)
+    private Topic topic;
+
+    @OneToMany(mappedBy = "latestCorrection", cascade = CascadeType.ALL, orphanRemoval = true)
+    private List<LatestCorrectionItem> items = new ArrayList<>();
+
+    public static LatestCorrection of(String runKey, Topic topic) {
+        LatestCorrection lc = new LatestCorrection();
+        lc.runKey = runKey;
+        lc.topic = topic;
+        return lc;
+    }
+
+    public void addItem(LatestCorrectionItem item) {
+        this.items.add(item);
+    }
+}

src/main/java/UMC/news/newsIntelligent/domain/news/entity/latestCorrection/LatestCorrection.java

@@ -0,0 +1,34 @@
+package UMC.news.newsIntelligent.domain.news.entity.latestCorrection;
+
+import UMC.news.newsIntelligent.domain.news.entity.News;
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import static jakarta.persistence.FetchType.LAZY;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Table(name = "latest_correction_item")
+public class LatestCorrectionItem {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @ManyToOne(fetch = LAZY, optional = false)
+    @JoinColumn(name="latest_correction_id", nullable=false)
+    private LatestCorrection latestCorrection;
+
+    @ManyToOne(fetch = LAZY, optional = false)
+    @JoinColumn(name="news_id", nullable=false)
+    private News news;
+
+    public static LatestCorrectionItem of(LatestCorrection lc, News news) {
+        LatestCorrectionItem item = new LatestCorrectionItem();
+        item.latestCorrection = lc;
+        item.news = news;
+        return item;
+    }
+}

src/main/java/UMC/news/newsIntelligent/domain/news/entity/latestCorrection/LatestCorrectionItem.java

@@ -73,6 +73,19 @@ SELECT MAX(n3.id)
 """)
     List<OldestPerTopicProjection> findOldestPerTopic(java.util.Collection<Long> topicIds);
 
+    // is_new = true AND is_third = false 인 기사 중
+    // 아직 어떤 run에서도 LatestCorrectionItem 에 기록되지 않은 것만
+    @Query("""
+        SELECT n
+        FROM News n
+        WHERE n.isNew = true AND n.isThird = false
+          AND NOT EXISTS (
+              SELECT 1 FROM LatestCorrectionItem i
+              WHERE i.news.id = n.id
+          )
+    """)
+    List<News> findAllQualifiedNotRecorded();
+
     // 특정 토픽 내에서 가장 오래된 publishDate, id가 가장 큰 기사
     Optional<News> findFirstByTopicIdOrderByPublishDateAscIdDesc(Long topicId);
 }

src/main/java/UMC/news/newsIntelligent/domain/news/repository/LatestCorrectionRepository.java

@@ -0,0 +1,11 @@
+package UMC.news.newsIntelligent.domain.news.repository.latestCorrection;
+
+import UMC.news.newsIntelligent.domain.news.entity.latestCorrection.LatestCorrectionItem;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface LatestCorrectionItemRepository extends JpaRepository<LatestCorrectionItem, Long> {
+    boolean existsByNews_Id(Long newsId);
+
+    boolean existsByLatestCorrection_IdAndNews_Id(Long latestCorrectionId, Long newsId);
+
+}

src/main/java/UMC/news/newsIntelligent/domain/news/repository/NewsRepository.java

@@ -0,0 +1,15 @@
+package UMC.news.newsIntelligent.domain.news.repository.latestCorrection;
+
+import UMC.news.newsIntelligent.domain.news.entity.latestCorrection.LatestCorrection;
+import org.springframework.data.jpa.repository.EntityGraph;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface LatestCorrectionRepository extends JpaRepository<LatestCorrection, Long> {
+    Optional<LatestCorrection> findByRunKeyAndTopic_Id(String runKey, Long topicId);
+
+    @EntityGraph(attributePaths = {"topic", "items", "items.news"})
+    List<LatestCorrection> findByRunKey(String runKey);
+}

src/main/java/UMC/news/newsIntelligent/domain/news/repository/latestCorrection/LatestCorrectionItemRepository.java

@@ -0,0 +1,61 @@
+package UMC.news.newsIntelligent.domain.news.service;
+
+import UMC.news.newsIntelligent.domain.news.entity.News;
+import UMC.news.newsIntelligent.domain.news.entity.latestCorrection.LatestCorrection;
+import UMC.news.newsIntelligent.domain.news.entity.latestCorrection.LatestCorrectionItem;
+import UMC.news.newsIntelligent.domain.news.repository.NewsRepository;
+import UMC.news.newsIntelligent.domain.news.repository.latestCorrection.LatestCorrectionItemRepository;
+import UMC.news.newsIntelligent.domain.news.repository.latestCorrection.LatestCorrectionRepository;
+import UMC.news.newsIntelligent.domain.topic.entity.Topic;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+public class LatestCorrectionService {
+
+    private final NewsRepository newsRepository;
+    private final LatestCorrectionRepository lcRepository;
+    private final LatestCorrectionItemRepository itemRepository;
+
+    @Transactional
+    public List<LatestCorrection> record(String runKey) {
+        // 이번 사이클에서 조건을 만족하지만 아직 기록되지 않은 뉴스 수집
+        List<News> candidates = newsRepository.findAllQualifiedNotRecorded();
+        if (candidates.isEmpty()) return List.of();
+
+        // 토픽 기준으로 그룹핑
+        Map<Topic, List<News>> byTopic = candidates.stream()
+                .collect(Collectors.groupingBy(News::getTopic, LinkedHashMap::new, Collectors.toList()));
+
+        List<LatestCorrection> out = new ArrayList<>();
+
+        for (var entry : byTopic.entrySet()) {
+            Topic topic = entry.getKey();
+            List<News> newsList = entry.getValue();
+
+            LatestCorrection lc = lcRepository.findByRunKeyAndTopic_Id(runKey, topic.getId())
+                    .orElseGet(() -> lcRepository.save(LatestCorrection.of(runKey, topic)));
+
+            // 각 뉴스에 대해 이미 기록되었으면 스킵, 아니면 추가
+            for (News n : newsList) {
+                if (itemRepository.existsByLatestCorrection_IdAndNews_Id(lc.getId(), n.getId())
+                        || itemRepository.existsByNews_Id(n.getId())) {
+                    continue;
+                }
+                LatestCorrectionItem item = LatestCorrectionItem.of(lc, n);
+                itemRepository.save(item);
+                lc.addItem(item);
+            }
+            out.add(lc);
+        }
+        return out;
+    }
+}