feat: 인기 게시글 기능 구현 완료

src/main/java/page/clab/api/domain/community/board/adapter/in/web/HotBoardsRetrievalController.java

@@ -0,0 +1,36 @@
+package page.clab.api.domain.community.board.adapter.in.web;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import page.clab.api.domain.community.board.application.dto.response.BoardListResponseDto;
+import page.clab.api.domain.community.board.application.port.in.RetrieveHotBoardsUseCase;
+import page.clab.api.domain.community.board.domain.HotBoardStrategyType;
+import page.clab.api.global.common.dto.ApiResponse;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/api/v1/boards")
+@RequiredArgsConstructor
+@Tag(name = "Community - Board", description = "커뮤니티 게시판")
+public class HotBoardsRetrievalController {
+
+    private final RetrieveHotBoardsUseCase retrieveHotBoardsUseCase;
+
+    @Operation(summary = "[G] 커뮤니티 인기 게시글 목록 조회", description = "ROLE_GUEST 이상의 권한이 필요함<br>" +
+            "인기 게시글 선정 타입 설정 가능")
+    @PreAuthorize("hasRole('GUEST')")
+    @GetMapping("/hot")
+    public ApiResponse<List<BoardListResponseDto>> retrieveHotBoards(
+            @RequestParam(name = "type") HotBoardStrategyType type
+    ) {
+        List<BoardListResponseDto> boards = retrieveHotBoardsUseCase.retrieveHotBoards(type);
+        return ApiResponse.success(boards);
+    }
+}

src/main/java/page/clab/api/domain/community/board/adapter/out/persistence/BoardPersistenceAdapter.java

@@ -10,6 +10,10 @@
 import page.clab.api.domain.community.board.domain.BoardCategory;
 import page.clab.api.global.exception.NotFoundException;
 
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.stream.Collectors;
+
 @Component
 @RequiredArgsConstructor
 public class BoardPersistenceAdapter implements
@@ -40,6 +44,20 @@ public Board findByIdRegardlessOfDeletion(Long boardId) {
                 .orElseThrow(() -> new NotFoundException("[Board] id: " + boardId + "에 해당하는 게시글이 존재하지 않습니다."));
     }
 
+    @Override
+    public List<Board> findAllWithinDateRange(LocalDateTime startDate, LocalDateTime endDate) {
+        return boardRepository.findAllWithinDateRange(startDate, endDate).stream()
+                .map(boardMapper::toDomain)
+                .collect(Collectors.toList());
+    }
+
+    @Override
+    public List<Board> findAll() {
+        return boardRepository.findAll().stream()
+                .map(boardMapper::toDomain)
+                .collect(Collectors.toList());
+    }
+
     @Override
     public Page<Board> findAllByCategory(BoardCategory category, Pageable pageable) {
         return boardRepository.findAllByCategory(category, pageable)

src/main/java/page/clab/api/domain/community/board/adapter/out/persistence/BoardRepository.java

@@ -1,5 +1,6 @@
 package page.clab.api.domain.community.board.adapter.out.persistence;
 
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Optional;
 import org.springframework.data.domain.Page;
@@ -16,6 +17,9 @@ public interface BoardRepository extends JpaRepository<BoardJpaEntity, Long> {
     @Query("SELECT b FROM BoardJpaEntity b WHERE b.memberId = ?1 AND b.isDeleted = false")
     Page<BoardJpaEntity> findAllByMemberIdAndIsDeletedFalse(String memberId, Pageable pageable);
 
+    @Query("SELECT b FROM BoardJpaEntity b WHERE b.createdAt BETWEEN :start AND :end AND b.isDeleted = false")
+    List<BoardJpaEntity> findAllWithinDateRange(LocalDateTime start, LocalDateTime end);
+
     Page<BoardJpaEntity> findAllByCategory(BoardCategory category, Pageable pageable);
 
     @Query(value = "SELECT b.* FROM board b WHERE b.is_deleted = true", nativeQuery = true)

src/main/java/page/clab/api/domain/community/board/adapter/out/persistence/RedisHotBoardPersistenceAdapter.java

@@ -0,0 +1,38 @@
+package page.clab.api.domain.community.board.adapter.out.persistence;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+import page.clab.api.domain.community.board.application.port.out.RegisterHotBoardPort;
+import page.clab.api.domain.community.board.application.port.out.RemoveHotBoardPort;
+import page.clab.api.domain.community.board.application.port.out.RetrieveHotBoardPort;
+
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class RedisHotBoardPersistenceAdapter implements
+        RegisterHotBoardPort,
+        RetrieveHotBoardPort,
+        RemoveHotBoardPort {
+
+    private static final String HOT_BOARDS_KEY = "hotBoards";
+
+    private final RedisTemplate<String, String> redisTemplate;
+
+    @Override
+    public void save(String boardId) {
+        redisTemplate.opsForList().rightPush(HOT_BOARDS_KEY, boardId);
+    }
+
+    @Override
+    public List<String> findAll() {
+        List<String> hotBoards = redisTemplate.opsForList().range(HOT_BOARDS_KEY, 0, -1);
+        return (hotBoards != null) ? hotBoards : List.of();
+    }
+
+    @Override
+    public void clearHotBoard() {
+        redisTemplate.delete(HOT_BOARDS_KEY);
+    }
+}

src/main/java/page/clab/api/domain/community/board/application/port/in/RetrieveHotBoardsUseCase.java

@@ -0,0 +1,10 @@
+package page.clab.api.domain.community.board.application.port.in;
+
+import page.clab.api.domain.community.board.application.dto.response.BoardListResponseDto;
+import page.clab.api.domain.community.board.domain.HotBoardStrategyType;
+
+import java.util.List;
+
+public interface RetrieveHotBoardsUseCase {
+    List<BoardListResponseDto> retrieveHotBoards(HotBoardStrategyType type);
+}

src/main/java/page/clab/api/domain/community/board/application/port/out/RegisterHotBoardPort.java

@@ -0,0 +1,5 @@
+package page.clab.api.domain.community.board.application.port.out;
+
+public interface RegisterHotBoardPort {
+    void save(String boardId);
+}

src/main/java/page/clab/api/domain/community/board/application/port/out/RemoveHotBoardPort.java

@@ -0,0 +1,5 @@
+package page.clab.api.domain.community.board.application.port.out;
+
+public interface RemoveHotBoardPort {
+    void clearHotBoard();
+}

src/main/java/page/clab/api/domain/community/board/application/port/out/RetrieveBoardPort.java

@@ -5,12 +5,19 @@
 import page.clab.api.domain.community.board.domain.Board;
 import page.clab.api.domain.community.board.domain.BoardCategory;
 
+import java.time.LocalDateTime;
+import java.util.List;
+
 public interface RetrieveBoardPort {
 
     Board getById(Long boardId);
 
     Board findByIdRegardlessOfDeletion(Long boardId);
 
+    List<Board> findAllWithinDateRange(LocalDateTime startDate, LocalDateTime endDate);
+
+    List<Board> findAll();
+
     Page<Board> findAll(Pageable pageable);
 
     Page<Board> findAllByCategory(BoardCategory category, Pageable pageable);

src/main/java/page/clab/api/domain/community/board/application/port/out/RetrieveHotBoardPort.java

@@ -0,0 +1,7 @@
+package page.clab.api.domain.community.board.application.port.out;
+
+import java.util.List;
+
+public interface RetrieveHotBoardPort {
+    List<String> findAll();
+}

src/main/java/page/clab/api/domain/community/board/application/service/DefaultHotBoardService.java

@@ -0,0 +1,137 @@
+package page.clab.api.domain.community.board.application.service;
+
+import com.drew.lang.annotations.NotNull;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import page.clab.api.domain.community.board.application.dto.mapper.BoardDtoMapper;
+import page.clab.api.domain.community.board.application.dto.response.BoardListResponseDto;
+import page.clab.api.domain.community.board.application.port.out.RegisterHotBoardPort;
+import page.clab.api.domain.community.board.application.port.out.RemoveHotBoardPort;
+import page.clab.api.domain.community.board.application.port.out.RetrieveBoardEmojiPort;
+import page.clab.api.domain.community.board.application.port.out.RetrieveBoardPort;
+import page.clab.api.domain.community.board.application.port.out.RetrieveHotBoardPort;
+import page.clab.api.domain.community.board.domain.Board;
+import page.clab.api.domain.memberManagement.member.application.dto.shared.MemberDetailedInfoDto;
+import page.clab.api.external.community.comment.application.port.ExternalRetrieveCommentUseCase;
+import page.clab.api.external.memberManagement.member.application.port.ExternalRetrieveMemberUseCase;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.Comparator;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Service("default")
+@RequiredArgsConstructor
+public class DefaultHotBoardService implements HotBoardsStrategy {
+
+    private final RetrieveBoardPort retrieveBoardPort;
+    private final RetrieveHotBoardPort retrieveHotBoardPort;
+    private final RegisterHotBoardPort registerHotBoardPort;
+    private final RemoveHotBoardPort removeHotBoardPort;
+    private final RetrieveBoardEmojiPort retrieveBoardEmojiPort;
+    private final ExternalRetrieveCommentUseCase externalRetrieveCommentUseCase;
+    private final ExternalRetrieveMemberUseCase externalRetrieveMemberUseCase;
+    private final BoardDtoMapper mapper;
+
+    @Transactional
+    @Override
+    public List<BoardListResponseDto> retrieveHotBoards() {
+        List<String> hotBoardIds = retrieveHotBoardPort.findAll();
+
+        return hotBoardIds.stream()
+                .map(hotBoardId -> retrieveBoardPort.getById(Long.parseLong(hotBoardId)))
+                .map(board -> mapToBoardListResponseDto(board, getMemberDetailedInfoByBoard(board)))
+                .toList();
+    }
+
+    @Transactional
+    @Scheduled(cron = "0 0 0 * * MON") // 매주 월요일 00:00 실행
+    public void saveHotBoards() {
+        clearHotBoards(); // 저장된 지난 인기 게시글 초기화
+
+        List<String> hotBoardIds = getHotBoards().stream()
+                .map(Board::getId)
+                .map(String::valueOf)
+                .toList();
+
+        hotBoardIds.forEach(registerHotBoardPort::save);
+    }
+
+    private List<Board> getHotBoards() {
+        // 만약 게시글의 총 개수가 5개보다 적다면 모든 게시글 반환
+        List<Board> allBoards = retrieveBoardPort.findAll();
+        if (allBoards.size() < 5) {
+            return sortBoardsByReactionAndDateWithLimit(allBoards.size(), allBoards);
+        }
+
+        List<Board> hotBoards = getHotBoardsForWeek(1, 5);
+
+        int weeksAgo = 2;
+        // 필요한 수량을 확보할 때까지 반복해서 이전 주로 이동하여 인기 게시글 보충
+        while (hotBoards.size() < 5) {
+            List<Board> additionalBoards = getLatestHotBoardForWeek(weeksAgo++, 5 - hotBoards.size());
+            if (additionalBoards != null && !additionalBoards.isEmpty()) {
+                hotBoards.addAll(additionalBoards);
+            }
+        }
+
+        return hotBoards;
+    }
+
+    private List<Board> getHotBoardsForWeek(int weeksAgo, int size) {
+        LocalDateTime startDate = LocalDate.now().minusWeeks(weeksAgo).with(DayOfWeek.MONDAY).atStartOfDay();
+        LocalDateTime endDate = LocalDate.now().minusWeeks(weeksAgo).with(DayOfWeek.SUNDAY).atTime(23, 59, 59);
+
+        List<Board> boardsForWeek = retrieveBoardPort.findAllWithinDateRange(startDate, endDate);
+
+        return sortBoardsByReactionAndDateWithLimit(size, boardsForWeek);
+    }
+
+    private List<Board> sortBoardsByReactionAndDateWithLimit(int size, List<Board> boardsForWeek) {
+        if (boardsForWeek == null) {
+            return null;
+        }
+
+        return boardsForWeek.stream()
+                .sorted(Comparator
+                        .comparingInt(this::getTotalReactionCount).reversed()
+                        .thenComparing(Board::getCreatedAt, Comparator.reverseOrder()))
+                .limit(size)
+                .collect(Collectors.toList());
+    }
+
+    private List<Board> getLatestHotBoardForWeek(int weeksAgo, int size) {
+
+        List<Board> topHotBoardsForWeek = getHotBoardsForWeek(weeksAgo, size);
+
+        return topHotBoardsForWeek.stream()
+                .sorted(Comparator.comparing(Board::getCreatedAt).reversed())
+                .toList();
+    }
+
+    private int getTotalReactionCount(Board board) {
+        Long commentCount = externalRetrieveCommentUseCase.countByBoardId(board.getId());
+        int emojiCount = retrieveBoardEmojiPort.findEmojiClickCountsByBoardId(board.getId(), null).size();
+
+        return commentCount.intValue() + emojiCount;
+    }
+
+    private MemberDetailedInfoDto getMemberDetailedInfoByBoard(Board board) {
+        return externalRetrieveMemberUseCase.getMemberDetailedInfoById(board.getMemberId());
+    }
+
+    @NotNull
+    private BoardListResponseDto mapToBoardListResponseDto(Board board, MemberDetailedInfoDto memberInfo) {
+        Long commentCount = externalRetrieveCommentUseCase.countByBoardId(board.getId());
+
+        return mapper.toListDto(board, memberInfo, commentCount);
+    }
+
+    private void clearHotBoards() {
+        removeHotBoardPort.clearHotBoard();
+    }
+}

src/main/java/page/clab/api/domain/community/board/application/service/HotBoardsRetrievalService.java

@@ -0,0 +1,23 @@
+package page.clab.api.domain.community.board.application.service;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import page.clab.api.domain.community.board.application.dto.response.BoardListResponseDto;
+import page.clab.api.domain.community.board.application.port.in.RetrieveHotBoardsUseCase;
+import page.clab.api.domain.community.board.domain.HotBoardStrategyType;
+
+import java.util.List;
+import java.util.Map;
+
+@Service
+@RequiredArgsConstructor
+public class HotBoardsRetrievalService implements RetrieveHotBoardsUseCase {
+
+    private final Map<String, HotBoardsStrategy> strategies;
+
+    @Override
+    public List<BoardListResponseDto> retrieveHotBoards(HotBoardStrategyType type) {
+        HotBoardsStrategy hotBoardsStrategy = strategies.get(type.getKey());
+        return hotBoardsStrategy.retrieveHotBoards();
+    }
+}

src/main/java/page/clab/api/domain/community/board/application/service/HotBoardsStrategy.java

@@ -0,0 +1,9 @@
+package page.clab.api.domain.community.board.application.service;
+
+import page.clab.api.domain.community.board.application.dto.response.BoardListResponseDto;
+
+import java.util.List;
+
+public interface HotBoardsStrategy {
+    List<BoardListResponseDto> retrieveHotBoards();
+}

src/main/java/page/clab/api/domain/community/board/domain/HotBoardStrategyType.java

@@ -0,0 +1,14 @@
+package page.clab.api.domain.community.board.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum HotBoardStrategyType {
+
+    DEFAULT("default", "댓글, 반응순 정렬");
+
+    private final String key;
+    private final String description;
+}

src/main/resources/messages.properties

@@ -61,6 +61,7 @@ email.member.email=올바른 이메일 형식으로 입력하세요.
 min.application.grade=학년은 {value}학년 이상이어야 합니다.
 min.donation.amount=금액은 {value}원 이상이어야 합니다.
 min.member.grade=최소값은 {value} 이상이어야 합니다.
+min.board.size=최소값은 {value} 이상이어야 합니다.
 max.application.grade=학년은 {value}학년 이하여야 합니다.
 max.member.grade=최대값은 {value} 이하여야 합니다.
 url.application.githubUrl=올바른 URL 형식으로 입력하세요.