app/models/Comment.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php
require_once __DIR__ . '/../../core/BaseModel.php';

class Comment extends BaseModel {
    protected $table = 'comments';
    protected $fillable = ['post_id', 'user_id', 'parent_id', 'author_name', 'author_email', 'author_url', 'author_ip', 'content', 'status', 'agent'];
    
    public function getApprovedByPost($postId) {
        $sql = "SELECT c.*, u.username, u.avatar, u.nickname 
                FROM {$this->table} c 
                LEFT JOIN users u ON c.user_id = u.id 
                WHERE c.post_id = ? AND c.status = 'approved' 
                ORDER BY c.created_at ASC";
        return $this->db->fetchAll($sql, [$postId]);
    }
    
    public function getCommentTree($postId) {
        $comments = $this->getApprovedByPost($postId);
        return $this->buildTree($comments);
    }
    
    private function buildTree($comments, $parentId = 0) {
        $tree = [];
        foreach ($comments as $comment) {
            if ($comment['parent_id'] == $parentId) {
                $children = $this->buildTree($comments, $comment['id']);
                if ($children) {
                    $comment['children'] = $children;
                }
                $tree[] = $comment;
            }
        }
        return $tree;
    }
    
    public function getRecentComments($limit = 10) {
        $sql = "SELECT c.*, p.title as post_title, p.slug as post_slug 
                FROM {$this->table} c 
                INNER JOIN posts p ON c.post_id = p.id 
                WHERE c.status = 'approved' 
                ORDER BY c.created_at DESC 
                LIMIT ?";
        return $this->db->fetchAll($sql, [$limit]);
    }
    
    public function getPendingComments($page = 1, $perPage = PER_PAGE) {
        return $this->paginate($page, $perPage, "status = 'pending'", [], 'created_at', 'DESC');
    }
    
    public function approve($id) {
        return $this->update($id, ['status' => 'approved']);
    }
    
    public function markAsSpam($id) {
        return $this->update($id, ['status' => 'spam']);
    }
    
    public function moveToTrash($id) {
        return $this->update($id, ['status' => 'trash']);
    }