Refactor : 조회수를 즉시반영하도록 변경 (#167)

src/main/java/com/adoonge/seedzip/seed/controller/SeedController.java

@@ -96,10 +96,9 @@ public ApiResponse<SeedResponse.GetAllSeeds> getCategorySeeds(
                             schema = @Schema(implementation = SeedResponse.SeedDetail.class))),
             @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "500", description = "서버 오류")
     })
-    public ApiResponse<SeedResponse.SeedDetail> getSeedDetail(@PathVariable("seedId") Long seedId,
-                                                                          @AuthenticationPrincipal CustomUserDetails customUserDetails) {
-
-        Member member = customUserDetails.getMember();
+    public ApiResponse<SeedResponse.SeedDetail> getSeedDetail(
+        @PathVariable("seedId") Long seedId,
+        @AuthenticationPrincipal CustomUserDetails customUserDetails) {
 
         return new ApiResponse<>(seedService.getSeedDetail(seedId));
     }
@@ -300,10 +299,11 @@ public ApiResponse<SeedResponse.GetAllSeeds> getUnreadSeeds(
         @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "500", description = "서버 오류")
     })
     public ApiResponse<Void> deleteSeedList(
-        @RequestBody @Valid SeedDeleteListRequest request,
+        @RequestParam List<Long> ids,
         @AuthenticationPrincipal CustomUserDetails customUserDetails) {
+
         Member member = customUserDetails.getMember();
-        seedService.deleteSeedList(request, member);
+        seedService.deleteSeedList(ids, member);
         return new ApiResponse<>(ErrorCode.REQUEST_OK);
     }
 

src/main/java/com/adoonge/seedzip/seed/domain/Seed.java

@@ -17,6 +17,7 @@
 import jakarta.persistence.ManyToOne;
 import jakarta.persistence.OneToMany;
 import jakarta.persistence.Table;
+import jakarta.persistence.Version;
 import java.time.LocalDate;
 import java.util.HashSet;
 import java.util.Set;
@@ -59,6 +60,9 @@ public class Seed extends BaseEntity {
     @Column(name = "view_count", nullable = false)
     private long viewCount = 0L; // 조회수
 
+    @Version
+    private Long version;
+
     @ManyToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "member_id")
     @OnDelete(action = OnDeleteAction.CASCADE) // Member 삭제 시 Content도 삭제
@@ -73,7 +77,6 @@ public class Seed extends BaseEntity {
     @OneToMany(mappedBy = "seed", fetch = FetchType.LAZY)
     private Set<CategorySeed> categorySeeds = new HashSet<>();
 
-
     public void updateSeedName(String seedName) {
         this.seedName = seedName;
     }

src/main/java/com/adoonge/seedzip/seed/repository/SeedRepository.java

@@ -48,4 +48,13 @@ default void deleteUnreferencedContents() {}
 	List<Seed> findAllByIdIn(List<Long> seedIds);
 
 	void deleteAllByIdIn(List<Long> seedIds);
+
+	@Modifying
+	@Query("""
+		UPDATE Seed s
+		SET s.viewCount = s.viewCount + 1,
+		    s.version   = s.version + 1
+		WHERE s.id = :id AND s.version = :version
+		""")
+	int increaseViewCount(@Param("id") Long id, @Param("version") Long version);
 }

src/main/java/com/adoonge/seedzip/seed/service/SeedCacheService.java

@@ -17,10 +17,6 @@ public SeedCacheService(RedisTemplate<String, Object> redisTemplate) {
 		this.redisTemplate = redisTemplate;
 	}
 
-	public void increaseViewCounts(Long seedId) {
-		redisTemplate.opsForHash().increment(SEED_VIEWS_KEY, seedId.toString(), 1);
-	}
-
 	public Map<Object, Object> getAllViewCounts() {
 		return redisTemplate.opsForHash().entries(SEED_VIEWS_KEY);
 	}

src/main/java/com/adoonge/seedzip/seed/service/SeedService.java

@@ -64,7 +64,6 @@
 public class SeedService {
 
 	private final FileService fileService;
-	private final SeedCacheService seedCacheService;
 
 	private final SeedRepository seedRepository;
 	private final FileRepository fileRepository;
@@ -172,10 +171,18 @@ public void uploadFiles(Long seedId, List<MultipartFile> files) {
 		fileService.saveFiles(files, seed);
 	}
 
-	@Transactional(readOnly = true)
+	@Transactional
 	public SeedResponse.SeedDetail getSeedDetail(Long seedId) {
 		Seed seed = getSeedOrThrow(seedId);
-		seedCacheService.increaseViewCounts(seedId);
+
+		// 최대 3회 재시도
+		for (int i = 0; i < 3; i++) {
+			int updated = seedRepository.increaseViewCount(seedId, seed.getVersion());
+			if (updated > 0) break; // 성공
+			// 실패면 최신 버전 재조회 후 재시도
+			seed = getSeedOrThrow(seedId);
+		}
+
 		List<File> files = fileRepository.findAllBySeed(seed)
 				.orElseThrow(() -> SeedzipException.from(ErrorCode.FILE_NOT_FOUND));
 
@@ -449,12 +456,11 @@ public SeedResponse.GetAllSeeds getUnreadSeeds(Member member, int page, int size
 	}
 
 	@Transactional
-	public void deleteSeedList(SeedDeleteListRequest request, Member member) {
-		List<Long> seedIds = request.seedIdList();
-		if (seedIds.isEmpty())	return;
+	public void deleteSeedList(List<Long> ids, Member member) {
+		if (ids.isEmpty())	return;
 
-		List<Seed> seeds = seedRepository.findAllByIdIn(seedIds);
-		if(seedIds.size() != seeds.size()) {
+		List<Seed> seeds = seedRepository.findAllByIdIn(ids);
+		if(ids.size() != seeds.size()) {
 			throw SeedzipException.from(ErrorCode.SEED_ACCESS_DENIED);
 		}
 
@@ -466,10 +472,10 @@ public void deleteSeedList(SeedDeleteListRequest request, Member member) {
 			deleteFileFromS3(seed.getId(), seed);
 		}
 
-		categorySeedRepository.deleteAllBySeedIdIn(seedIds);
-		fileRepository.deleteAllBySeedIdIn(seedIds);
-		seedTagRepository.deleteAllBySeedIdIn(seedIds);
-		seedRepository.deleteAllByIdIn(seedIds);
+		categorySeedRepository.deleteAllBySeedIdIn(ids);
+		fileRepository.deleteAllBySeedIdIn(ids);
+		seedTagRepository.deleteAllBySeedIdIn(ids);
+		seedRepository.deleteAllByIdIn(ids);
 	}
 
 	private void deleteFileFromS3(Long id, Seed seed) {