Модуль форума в приложении PHP: от идеи до реализации

Расширенные примеры кода для модуля форума

1. Полноценный CRUD для тем и постов

Пример модели Topic с методами для создания, чтения, обновления и удаления, а также связью с постами.

<?php
namespace App\Forums\Models;

use Core\Database;

class Topic
{
    public $id;
    public $title;
    public $content;
    public $user_id;
    public $created_at;

    public static function create($data)
    {
        $db = Database::getInstance();
        $stmt = $db->prepare('INSERT INTO topics (title, content, user_id, created_at) VALUES (?, ?, ?, NOW())');
        $stmt->execute([$data['title'], $data['content'], $data['user_id']]);
        return $db->lastInsertId();
    }

    public static function getAll($page = 1, $perPage = 20)
    {
        $offset = ($page - 1) * $perPage;
        $db = Database::getInstance();
        $stmt = $db->prepare('SELECT * FROM topics ORDER BY created_at DESC LIMIT ? OFFSET ?');
        $stmt->bindValue(1, $perPage, \PDO::PARAM_INT);
        $stmt->bindValue(2, $offset, \PDO::PARAM_INT);
        $stmt->execute();
        return $stmt->fetchAll(\PDO::FETCH_CLASS, self::class);
    }

    public function getPosts()
    {
        $db = Database::getInstance();
        $stmt = $db->prepare('SELECT * FROM posts WHERE topic_id = ? ORDER BY created_at ASC');
        $stmt->execute([$this->id]);
        return $stmt->fetchAll(\PDO::FETCH_CLASS, Post::class);
    }

    public function update($data)
    {
        $db = Database::getInstance();
        $stmt = $db->prepare('UPDATE topics SET title = ?, content = ? WHERE id = ?');
        return $stmt->execute([$data['title'], $data['content'], $this->id]);
    }

    public function delete()
    {
        $db = Database::getInstance();
        $stmt = $db->prepare('DELETE FROM topics WHERE id = ?');
        return $stmt->execute([$this->id]);
    }
}
  

Результат вызова Topic::getAll(1, 10) (пример вывода):

Array
(
    [0] => Topic Object
        (
            [id] => 1
            [title] => Добро пожаловать на форум
            [content] => Это первая тема
            [user_id] => 1
            [created_at] => 2025-03-15 10:30:00
        )
    [1] => Topic Object
        (
            [id] => 2
            [title] => Вопрос по PHP
            [content] => Как сделать...
            [user_id] => 2
            [created_at] => 2025-03-15 12:00:00
        )
)
  

2. Обработка вложенных запросов и защита от SQL-инъекций

Использование подготовленных выражений для всех запросов к БД. Пример с транзакцией при создании темы и первого поста:

public static function createWithFirstPost($topicData, $postData)
{
    $db = Database::getInstance();
    try {
        $db->beginTransaction();
        $topicId = self::create($topicData);
        $postData['topic_id'] = $topicId;
        Post::create($postData);
        $db->commit();
        return $topicId;
    } catch (\Exception $e) {
        $db->rollBack();
        throw $e;
    }
}
  

3. Пагинация с ссылками на страницы

В контроллере:

public function index($page = 1)
{
    $perPage = 20;
    $total = Topic::countAll();
    $topics = Topic::getAll($page, $perPage);
    $totalPages = ceil($total / $perPage);
    
    $this->render('forums/views/index.phtml', [
        'topics' => $topics,
        'currentPage' => $page,
        'totalPages' => $totalPages
    ]);
}
  

В представлении (index.phtml) вывод ссылок:

<?php for ($i = 1; $i <= $totalPages; $i++): ?>
    <a href='/forum?page=<?= $i ?>' class='<?= $i == $currentPage ? 'active' : '' ?>'><?= $i ?></a>
<?php endfor; ?>
  

4. Защита от CSRF-атак

Генерация токена в сессии и проверка при POST-запросах.

// В контроллере перед отображением формы
$_SESSION['csrf_token'] = bin2hex(random_bytes(32));

// В форме
<input type='hidden' name='csrf_token' value='<?= $_SESSION['csrf_token'] ?>'>

// В обработчике
if (!hash_equals($_SESSION['csrf_token'], $_POST['csrf_token'])) {
    // ошибка валидации
}
  

5. Поиск по форуму (полнотекстовый)

MySQL FULLTEXT индекс:

ALTER TABLE topics ADD FULLTEXT(title, content);
  

Запрос:

public static function search($query)
{
    $db = Database::getInstance();
    $stmt = $db->prepare('SELECT *, MATCH(title, content) AGAINST(? IN BOOLEAN MODE) AS relevance 
                           FROM topics 
                           WHERE MATCH(title, content) AGAINST(? IN BOOLEAN MODE) 
                           ORDER BY relevance DESC');
    $stmt->execute([$query, $query]);
    return $stmt->fetchAll(\PDO::FETCH_ASSOC);
}
  

Результат для запроса 'PHP':

Array
(
    [0] => Array
        (
            [id] => 2
            [title] => Вопрос по PHP
            [content] => Как сделать...
            [relevance] => 1.5
        )
)
  

6. Обработка ошибок и кастомные исключения

Создание класса исключения для модуля форума:

namespace App\Forums\Exceptions;

class ForumException extends \RuntimeException {}
  

Использование в модели:

if (empty($data['title'])) {
    throw new ForumException('Заголовок темы обязателен');
}
  

В контроллере перехват и вывод сообщения:

try {
    $topic = Topic::create($data);
} catch (ForumException $e) {
    $this->renderError(400, $e->getMessage());
}
  

7. Кеширование списка тем

Использование простого файлового кеша для уменьшения нагрузки на БД.

public static function getAllCached()
{
    $cacheFile = __DIR__ . '/../../cache/topics.cache';
    if (file_exists($cacheFile) && (time() - filemtime($cacheFile) < 300)) {
        return unserialize(file_get_contents($cacheFile));
    }
    $topics = self::getAll();
    file_put_contents($cacheFile, serialize($topics));
    return $topics;
}