Merge pull request #7 from nagisa77/codex/add-comment-module-with-sub-comments

Add comment module

README.md

@@ -9,6 +9,7 @@ OpenIsle 是一个基于 Spring Boot 的社区后端平台示例，提供注册
 - **邮件通知**：示例通过 Resend API 发送欢迎邮件，可根据需要修改。
 - **灵活配置**：数据库地址、账户密码、Resend API Key 等均可通过环境变量或 `application.properties` 配置。
 - **角色权限**：内置 `ADMIN` 和 `USER` 两种角色，`/api/admin/**` 接口仅管理员可访问。
+- **文章/评论**：支持发表文章并在文章下发布评论，评论可多级回复。
 
 ## 快速开始
 

src/main/java/com/openisle/config/SecurityConfig.java

@@ -64,6 +64,7 @@ public class SecurityConfig {
             .authorizeHttpRequests(auth -> auth
                     .requestMatchers(HttpMethod.POST, "/api/auth/**").permitAll()
                     .requestMatchers(HttpMethod.GET, "/api/posts/**").permitAll()
+                    .requestMatchers(HttpMethod.GET, "/api/comments/**").permitAll()
                     .requestMatchers("/api/admin/**").hasAuthority("ADMIN")
                     .anyRequest().authenticated()
             )

src/main/java/com/openisle/controller/CommentController.java

@@ -0,0 +1,75 @@
+package com.openisle.controller;
+
+import com.openisle.model.Comment;
+import com.openisle.service.CommentService;
+import lombok.Data;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.core.Authentication;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@RestController
+@RequestMapping("/api")
+@RequiredArgsConstructor
+public class CommentController {
+    private final CommentService commentService;
+
+    @PostMapping("/posts/{postId}/comments")
+    public ResponseEntity<CommentDto> createComment(@PathVariable Long postId,
+                                                    @RequestBody CommentRequest req,
+                                                    Authentication auth) {
+        Comment comment = commentService.addComment(auth.getName(), postId, req.getContent());
+        return ResponseEntity.ok(toDto(comment));
+    }
+
+    @PostMapping("/comments/{commentId}/replies")
+    public ResponseEntity<CommentDto> replyComment(@PathVariable Long commentId,
+                                                   @RequestBody CommentRequest req,
+                                                   Authentication auth) {
+        Comment comment = commentService.addReply(auth.getName(), commentId, req.getContent());
+        return ResponseEntity.ok(toDto(comment));
+    }
+
+    @GetMapping("/posts/{postId}/comments")
+    public List<CommentDto> listComments(@PathVariable Long postId) {
+        return commentService.getCommentsForPost(postId).stream()
+                .map(this::toDtoWithReplies)
+                .collect(Collectors.toList());
+    }
+
+    private CommentDto toDtoWithReplies(Comment comment) {
+        CommentDto dto = toDto(comment);
+        List<CommentDto> replies = commentService.getReplies(comment.getId()).stream()
+                .map(this::toDtoWithReplies)
+                .collect(Collectors.toList());
+        dto.setReplies(replies);
+        return dto;
+    }
+
+    private CommentDto toDto(Comment comment) {
+        CommentDto dto = new CommentDto();
+        dto.setId(comment.getId());
+        dto.setContent(comment.getContent());
+        dto.setCreatedAt(comment.getCreatedAt());
+        dto.setAuthor(comment.getAuthor().getUsername());
+        return dto;
+    }
+
+    @Data
+    private static class CommentRequest {
+        private String content;
+    }
+
+    @Data
+    private static class CommentDto {
+        private Long id;
+        private String content;
+        private LocalDateTime createdAt;
+        private String author;
+        private List<CommentDto> replies;
+    }
+}

src/main/java/com/openisle/model/Comment.java

@@ -0,0 +1,42 @@
+package com.openisle.model;
+
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.time.LocalDateTime;
+
+@Entity
+@Getter
+@Setter
+@NoArgsConstructor
+@Table(name = "comments")
+public class Comment {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(nullable = false, columnDefinition = "TEXT")
+    private String content;
+
+    @Column(nullable = false)
+    private LocalDateTime createdAt;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "author_id")
+    private User author;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "post_id")
+    private Post post;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "parent_id")
+    private Comment parent;
+
+    @PrePersist
+    protected void onCreate() {
+        this.createdAt = LocalDateTime.now();
+    }
+}

src/main/java/com/openisle/repository/CommentRepository.java

@@ -0,0 +1,12 @@
+package com.openisle.repository;
+
+import com.openisle.model.Comment;
+import com.openisle.model.Post;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+public interface CommentRepository extends JpaRepository<Comment, Long> {
+    List<Comment> findByPostAndParentIsNullOrderByCreatedAtAsc(Post post);
+    List<Comment> findByParentOrderByCreatedAtAsc(Comment parent);
+}

src/main/java/com/openisle/service/CommentService.java

@@ -0,0 +1,57 @@
+package com.openisle.service;
+
+import com.openisle.model.Comment;
+import com.openisle.model.Post;
+import com.openisle.model.User;
+import com.openisle.repository.CommentRepository;
+import com.openisle.repository.PostRepository;
+import com.openisle.repository.UserRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+public class CommentService {
+    private final CommentRepository commentRepository;
+    private final PostRepository postRepository;
+    private final UserRepository userRepository;
+
+    public Comment addComment(String username, Long postId, String content) {
+        User author = userRepository.findByUsername(username)
+                .orElseThrow(() -> new IllegalArgumentException("User not found"));
+        Post post = postRepository.findById(postId)
+                .orElseThrow(() -> new IllegalArgumentException("Post not found"));
+        Comment comment = new Comment();
+        comment.setAuthor(author);
+        comment.setPost(post);
+        comment.setContent(content);
+        return commentRepository.save(comment);
+    }
+
+    public Comment addReply(String username, Long parentId, String content) {
+        User author = userRepository.findByUsername(username)
+                .orElseThrow(() -> new IllegalArgumentException("User not found"));
+        Comment parent = commentRepository.findById(parentId)
+                .orElseThrow(() -> new IllegalArgumentException("Comment not found"));
+        Comment comment = new Comment();
+        comment.setAuthor(author);
+        comment.setPost(parent.getPost());
+        comment.setParent(parent);
+        comment.setContent(content);
+        return commentRepository.save(comment);
+    }
+
+    public List<Comment> getCommentsForPost(Long postId) {
+        Post post = postRepository.findById(postId)
+                .orElseThrow(() -> new IllegalArgumentException("Post not found"));
+        return commentRepository.findByPostAndParentIsNullOrderByCreatedAtAsc(post);
+    }
+
+    public List<Comment> getReplies(Long parentId) {
+        Comment parent = commentRepository.findById(parentId)
+                .orElseThrow(() -> new IllegalArgumentException("Comment not found"));
+        return commentRepository.findByParentOrderByCreatedAtAsc(parent);
+    }
+}