From f4af7a48c77a7bb6d96a2dafec928d02addf9907 Mon Sep 17 00:00:00 2001
From: Tim <135014430+nagisa77@users.noreply.github.com>
Date: Fri, 11 Jul 2025 17:24:48 +0800
Subject: [PATCH] Add post and comment deletion

---
 open-isle-cli/src/components/CommentItem.vue  | 20 +++++++++-
 open-isle-cli/src/views/PostPageView.vue      | 37 ++++++++++++++++-
 .../controller/CommentController.java         |  5 +++
 .../openisle/controller/PostController.java   |  5 +++
 .../repository/NotificationRepository.java    |  4 ++
 .../com/openisle/service/CommentService.java  | 31 ++++++++++++++
 .../com/openisle/service/PostService.java     | 40 +++++++++++++++++++
 7 files changed, 139 insertions(+), 3 deletions(-)

diff --git a/open-isle-cli/src/components/CommentItem.vue b/open-isle-cli/src/components/CommentItem.vue
index f5928212e..edf3e380e 100644
--- a/open-isle-cli/src/components/CommentItem.vue
+++ b/open-isle-cli/src/components/CommentItem.vue
@@ -70,6 +70,7 @@ import ReactionsGroup from './ReactionsGroup.vue'
 import DropdownMenu from './DropdownMenu.vue'
 const CommentItem = {
   name: 'CommentItem',
+  emits: ['deleted'],
   props: {
     comment: {
       type: Object,
@@ -84,7 +85,7 @@ const CommentItem = {
       default: false
     }
   },
-  setup(props) {
+  setup(props, { emit }) {
     const router = useRouter()
     const showReplies = ref(props.defaultShowReplies)
     watch(
@@ -105,7 +106,22 @@ const CommentItem = {
     const commentMenuItems = computed(() =>
       isAuthor.value ? [{ text: '删除评论', color: 'red', onClick: () => deleteComment() }] : []
     )
-    const deleteComment = () => {
+    const deleteComment = async () => {
+      const token = getToken()
+      if (!token) {
+        toast.error('请先登录')
+        return
+      }
+      const res = await fetch(`${API_BASE_URL}/api/comments/${props.comment.id}`, {
+        method: 'DELETE',
+        headers: { Authorization: `Bearer ${token}` }
+      })
+      if (res.ok) {
+        toast.success('已删除')
+        emit('deleted', props.comment.id)
+      } else {
+        toast.error('操作失败')
+      }
     }
     const submitReply = async (text) => {
       if (!text.trim()) return
diff --git a/open-isle-cli/src/views/PostPageView.vue b/open-isle-cli/src/views/PostPageView.vue
index edcbe10d8..950ee57c0 100644
--- a/open-isle-cli/src/views/PostPageView.vue
+++ b/open-isle-cli/src/views/PostPageView.vue
@@ -64,7 +64,7 @@
       <div class="comments-container">
         <BaseTimeline :items="comments">
           <template #item="{ item }">
-            <CommentItem :key="item.id" :comment="item" :level="level + 1" :default-show-replies="item.openReplies" />
+            <CommentItem :key="item.id" :comment="item" :level="level + 1" :default-show-replies="item.openReplies" @deleted="onCommentDeleted" />
           </template>
         </BaseTimeline>
         <!-- <CommentItem
@@ -209,6 +209,24 @@ export default {
       }
     }
 
+    const removeCommentFromList = (id, list) => {
+      for (let i = 0; i < list.length; i++) {
+        const item = list[i]
+        if (item.id === id) {
+          list.splice(i, 1)
+          return true
+        }
+        if (item.reply && item.reply.length) {
+          if (removeCommentFromList(id, item.reply)) return true
+        }
+      }
+      return false
+    }
+
+    const onCommentDeleted = (id) => {
+      removeCommentFromList(Number(id), comments.value)
+    }
+
     const fetchPost = async () => {
       try {
         isWaitingFetchingPost.value = true;
@@ -347,6 +365,21 @@ export default {
     }
 
     const deletePost = async () => {
+      const token = getToken()
+      if (!token) {
+        toast.error('请先登录')
+        return
+      }
+      const res = await fetch(`${API_BASE_URL}/api/posts/${postId}`, {
+        method: 'DELETE',
+        headers: { Authorization: `Bearer ${token}` }
+      })
+      if (res.ok) {
+        toast.success('已删除')
+        router.push('/')
+      } else {
+        toast.error('操作失败')
+      }
     }
 
     const rejectPost = async () => {
@@ -443,6 +476,8 @@ export default {
       status,
       isAdmin,
       approvePost,
+      onCommentDeleted,
+      deletePost,
       rejectPost
     }
   }
diff --git a/src/main/java/com/openisle/controller/CommentController.java b/src/main/java/com/openisle/controller/CommentController.java
index caa73e1a6..99032228a 100644
--- a/src/main/java/com/openisle/controller/CommentController.java
+++ b/src/main/java/com/openisle/controller/CommentController.java
@@ -65,6 +65,11 @@ public class CommentController {
         return dto;
     }
 
+    @DeleteMapping("/comments/{id}")
+    public void deleteComment(@PathVariable Long id, Authentication auth) {
+        commentService.deleteComment(auth.getName(), id);
+    }
+
     private CommentDto toDto(Comment comment) {
         CommentDto dto = new CommentDto();
         dto.setId(comment.getId());
diff --git a/src/main/java/com/openisle/controller/PostController.java b/src/main/java/com/openisle/controller/PostController.java
index 683770d76..9dae40e85 100644
--- a/src/main/java/com/openisle/controller/PostController.java
+++ b/src/main/java/com/openisle/controller/PostController.java
@@ -48,6 +48,11 @@ public class PostController {
         return ResponseEntity.ok(toDto(post));
     }
 
+    @DeleteMapping("/{id}")
+    public void deletePost(@PathVariable Long id, Authentication auth) {
+        postService.deletePost(id, auth.getName());
+    }
+
     @GetMapping("/{id}")
     public ResponseEntity<PostDto> getPost(@PathVariable Long id, Authentication auth) {
         String viewer = auth != null ? auth.getName() : null;
diff --git a/src/main/java/com/openisle/repository/NotificationRepository.java b/src/main/java/com/openisle/repository/NotificationRepository.java
index 06bf87881..31038481b 100644
--- a/src/main/java/com/openisle/repository/NotificationRepository.java
+++ b/src/main/java/com/openisle/repository/NotificationRepository.java
@@ -2,6 +2,8 @@ package com.openisle.repository;
 
 import com.openisle.model.Notification;
 import com.openisle.model.User;
+import com.openisle.model.Post;
+import com.openisle.model.Comment;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 import java.util.List;
@@ -11,4 +13,6 @@ public interface NotificationRepository extends JpaRepository<Notification, Long
     List<Notification> findByUserOrderByCreatedAtDesc(User user);
     List<Notification> findByUserAndReadOrderByCreatedAtDesc(User user, boolean read);
     long countByUserAndRead(User user, boolean read);
+    List<Notification> findByPost(Post post);
+    List<Notification> findByComment(Comment comment);
 }
diff --git a/src/main/java/com/openisle/service/CommentService.java b/src/main/java/com/openisle/service/CommentService.java
index c929bf5d2..ca359e5be 100644
--- a/src/main/java/com/openisle/service/CommentService.java
+++ b/src/main/java/com/openisle/service/CommentService.java
@@ -7,8 +7,12 @@ import com.openisle.model.NotificationType;
 import com.openisle.repository.CommentRepository;
 import com.openisle.repository.PostRepository;
 import com.openisle.repository.UserRepository;
+import com.openisle.repository.ReactionRepository;
+import com.openisle.repository.CommentSubscriptionRepository;
+import com.openisle.repository.NotificationRepository;
 import com.openisle.service.NotificationService;
 import com.openisle.service.SubscriptionService;
+import com.openisle.model.Role;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -24,6 +28,9 @@ public class CommentService {
     private final UserRepository userRepository;
     private final NotificationService notificationService;
     private final SubscriptionService subscriptionService;
+    private final ReactionRepository reactionRepository;
+    private final CommentSubscriptionRepository commentSubscriptionRepository;
+    private final NotificationRepository notificationRepository;
 
     public Comment addComment(String username, Long postId, String content) {
         User author = userRepository.findByUsername(username)
@@ -115,4 +122,28 @@ public class CommentService {
     public java.util.List<Comment> getCommentsByIds(java.util.List<Long> ids) {
         return commentRepository.findAllById(ids);
     }
+
+    @org.springframework.transaction.annotation.Transactional
+    public void deleteComment(String username, Long id) {
+        User user = userRepository.findByUsername(username)
+                .orElseThrow(() -> new IllegalArgumentException("User not found"));
+        Comment comment = commentRepository.findById(id)
+                .orElseThrow(() -> new IllegalArgumentException("Comment not found"));
+        if (!user.getId().equals(comment.getAuthor().getId()) && user.getRole() != Role.ADMIN) {
+            throw new IllegalArgumentException("Unauthorized");
+        }
+        deleteCommentCascade(comment);
+    }
+
+    @org.springframework.transaction.annotation.Transactional
+    public void deleteCommentCascade(Comment comment) {
+        List<Comment> replies = commentRepository.findByParentOrderByCreatedAtAsc(comment);
+        for (Comment c : replies) {
+            deleteCommentCascade(c);
+        }
+        reactionRepository.findByComment(comment).forEach(reactionRepository::delete);
+        commentSubscriptionRepository.findByComment(comment).forEach(commentSubscriptionRepository::delete);
+        notificationRepository.findByComment(comment).forEach(n -> { n.setComment(null); notificationRepository.save(n); });
+        commentRepository.delete(comment);
+    }
 }
diff --git a/src/main/java/com/openisle/service/PostService.java b/src/main/java/com/openisle/service/PostService.java
index baf5590a8..82e43efe9 100644
--- a/src/main/java/com/openisle/service/PostService.java
+++ b/src/main/java/com/openisle/service/PostService.java
@@ -5,12 +5,19 @@ import com.openisle.model.PostStatus;
 import com.openisle.model.PublishMode;
 import com.openisle.model.User;
 import com.openisle.model.Category;
+import com.openisle.model.Comment;
 import com.openisle.model.NotificationType;
 import com.openisle.repository.PostRepository;
 import com.openisle.repository.UserRepository;
 import com.openisle.repository.CategoryRepository;
 import com.openisle.repository.TagRepository;
 import com.openisle.service.SubscriptionService;
+import com.openisle.service.CommentService;
+import com.openisle.repository.CommentRepository;
+import com.openisle.repository.ReactionRepository;
+import com.openisle.repository.PostSubscriptionRepository;
+import com.openisle.repository.NotificationRepository;
+import com.openisle.model.Role;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
@@ -27,6 +34,11 @@ public class PostService {
     private PublishMode publishMode;
     private final NotificationService notificationService;
     private final SubscriptionService subscriptionService;
+    private final CommentService commentService;
+    private final CommentRepository commentRepository;
+    private final ReactionRepository reactionRepository;
+    private final PostSubscriptionRepository postSubscriptionRepository;
+    private final NotificationRepository notificationRepository;
 
     @org.springframework.beans.factory.annotation.Autowired
     public PostService(PostRepository postRepository,
@@ -35,6 +47,11 @@ public class PostService {
                        TagRepository tagRepository,
                        NotificationService notificationService,
                        SubscriptionService subscriptionService,
+                       CommentService commentService,
+                       CommentRepository commentRepository,
+                       ReactionRepository reactionRepository,
+                       PostSubscriptionRepository postSubscriptionRepository,
+                       NotificationRepository notificationRepository,
                        @Value("${app.post.publish-mode:DIRECT}") PublishMode publishMode) {
         this.postRepository = postRepository;
         this.userRepository = userRepository;
@@ -42,6 +59,11 @@ public class PostService {
         this.tagRepository = tagRepository;
         this.notificationService = notificationService;
         this.subscriptionService = subscriptionService;
+        this.commentService = commentService;
+        this.commentRepository = commentRepository;
+        this.reactionRepository = reactionRepository;
+        this.postSubscriptionRepository = postSubscriptionRepository;
+        this.notificationRepository = notificationRepository;
         this.publishMode = publishMode;
     }
 
@@ -317,6 +339,24 @@ public class PostService {
         return post;
     }
 
+    @org.springframework.transaction.annotation.Transactional
+    public void deletePost(Long id, String username) {
+        Post post = postRepository.findById(id)
+                .orElseThrow(() -> new IllegalArgumentException("Post not found"));
+        User user = userRepository.findByUsername(username)
+                .orElseThrow(() -> new IllegalArgumentException("User not found"));
+        if (!user.getId().equals(post.getAuthor().getId()) && user.getRole() != Role.ADMIN) {
+            throw new IllegalArgumentException("Unauthorized");
+        }
+        for (Comment c : commentRepository.findByPostAndParentIsNullOrderByCreatedAtAsc(post)) {
+            commentService.deleteCommentCascade(c);
+        }
+        reactionRepository.findByPost(post).forEach(reactionRepository::delete);
+        postSubscriptionRepository.findByPost(post).forEach(postSubscriptionRepository::delete);
+        notificationRepository.findByPost(post).forEach(n -> { n.setPost(null); notificationRepository.save(n); });
+        postRepository.delete(post);
+    }
+
     public java.util.List<Post> getPostsByIds(java.util.List<Long> ids) {
         return postRepository.findAllById(ids);
     }