jiazhizhong/OpenIsle
1
0
Fork 0
mirror of https://github.com/nagisa77/OpenIsle.git synced 2026-02-20 22:11:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Revert "optimize(backend): optimize /api/posts/latest-reply"

Browse Source 
This reverts commit 1e87e9252d.
This commit is contained in:
tim
2025-08-14 18:54:12 +08:00
parent 76176e135c
commit df56d7e885
5 changed files with 2 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
backend/src/main/java/com/openisle/config/PostDataSyncer.java
View File

@@ -1,43 +0,0 @@
package com.openisle.config;
import com.openisle.service.CommentService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.CommandLineRunner;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.util.List;
/**
*
*/
@Slf4j
@RequiredArgsConstructor
@Component
public class PostDataSyncer implements CommandLineRunner {
private final JdbcTemplate jdbcTemplate;
private final CommentService commentService;
@Override
public void run(String... args) {
// 我们需要处理下历史数据，一些帖子的评论数量和最后回复时间可能为空
// 系统下次升级后，可以删掉这些代码
List<Long> oldPosts = jdbcTemplate.query("""
select distinct p.id from posts p join comments c on p.id = c.post_id
where last_reply_at is null
""",
(rs, rowNum) -> rs.getLong(1));
log.info("found {} old posts: {}", oldPosts.size(), oldPosts);
oldPosts.forEach(postId -> {
long cnt = commentService.countComments(postId);
LocalDateTime lastCommentTime = commentService.getLastCommentTime(postId);
jdbcTemplate.update("update posts set comment_count = ?, last_reply_at = ? where id = ?", cnt, lastCommentTime, postId);
log.info("update post {} success", postId);
});
}
}

3
backend/src/main/java/com/openisle/mapper/PostMapper.java
View File

@@ -60,8 +60,7 @@ public class PostMapper {
dto.setCategory(categoryMapper.toDto(post.getCategory()));
dto.setTags(post.getTags().stream().map(tagMapper::toDto).collect(Collectors.toList()));
dto.setViews(post.getViews());
//dto.setCommentCount(commentService.countComments(post.getId()));
dto.setCommentCount(post.getCommentCount());
dto.setCommentCount(commentService.countComments(post.getId()));
dto.setStatus(post.getStatus());
dto.setPinnedAt(post.getPinnedAt());

6
backend/src/main/java/com/openisle/model/Post.java
View File

@@ -67,10 +67,4 @@ public class Post {
@Column
private LocalDateTime pinnedAt;
@Column(nullable = false)
private long commentCount = 0;
@Column
private LocalDateTime lastReplyAt;
}

12
backend/src/main/java/com/openisle/service/CommentService.java
View File

@@ -58,11 +58,6 @@ public class CommentService {
comment.setContent(content);
comment = commentRepository.save(comment);
log.debug("Comment {} saved for post {}", comment.getId(), postId);
post.setCommentCount(post.getCommentCount() + 1);
post.setLastReplyAt(LocalDateTime.now());
postRepository.save(post);
imageUploader.addReferences(imageUploader.extractUrls(content));
if (!author.getId().equals(post.getAuthor().getId())) {
notificationService.createNotification(post.getAuthor(), NotificationType.COMMENT_REPLY, post, comment, null, null, null, null);
@@ -106,13 +101,6 @@ public class CommentService {
comment.setContent(content);
comment = commentRepository.save(comment);
log.debug("Reply {} saved for parent {}", comment.getId(), parentId);
Post post = postRepository.findById(parent.getPost().getId())
.orElseThrow(() -> new com.openisle.exception.NotFoundException("Post not found"));
post.setCommentCount(post.getCommentCount() + 1);
post.setLastReplyAt(LocalDateTime.now());
postRepository.save(post);
imageUploader.addReferences(imageUploader.extractUrls(content));
if (!author.getId().equals(parent.getAuthor().getId())) {
notificationService.createNotification(parent.getAuthor(), NotificationType.COMMENT_REPLY, parent.getPost(), comment, null, null, null, null);

2
backend/src/main/java/com/openisle/service/PostService.java
View File

@@ -612,7 +612,7 @@ public class PostService {
.sorted(java.util.Comparator
.comparing(Post::getPinnedAt, java.util.Comparator.nullsLast(java.util.Comparator.reverseOrder()))
.thenComparing(p -> {
java.time.LocalDateTime t = p.getLastReplyAt();
java.time.LocalDateTime t = commentRepository.findLastCommentTime(p);
return t != null ? t : p.getCreatedAt();
}, java.util.Comparator.nullsLast(java.util.Comparator.reverseOrder())))
.toList();