Реализация обмена сообщениями между пользователями на PHP

Расширенные примеры реализации

Полноценный класс для работы с сообщениями (PDO)

<?php
class MessageManager {
    private PDO $pdo;

    public function __construct(PDO $pdo) {
        $this->pdo = $pdo;
    }

    public function send(int $sender, int $receiver, string $subject, string $text): int {
        $sql = 'INSERT INTO messages (sender_id, receiver_id, subject, message_text, created_at) 
                VALUES (:sender, :receiver, :subject, :text, NOW())';
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute([
            'sender' => $sender,
            'receiver' => $receiver,
            'subject' => htmlspecialchars($subject),
            'text' => htmlspecialchars($text)
        ]);
        return (int)$this->pdo->lastInsertId();
    }

    public function getInbox(int $userId, int $page = 1, int $perPage = 10): array {
        $offset = ($page - 1) * $perPage;
        $sql = 'SELECT m.id, m.subject, m.is_read, m.created_at, u.username AS sender_name
                FROM messages m
                JOIN users u ON m.sender_id = u.id
                WHERE m.receiver_id = :userId
                ORDER BY m.created_at DESC
                LIMIT :limit OFFSET :offset';
        $stmt = $this->pdo->prepare($sql);
        $stmt->bindValue(':userId', $userId, PDO::PARAM_INT);
        $stmt->bindValue(':limit', $perPage, PDO::PARAM_INT);
        $stmt->bindValue(':offset', $offset, PDO::PARAM_INT);
        $stmt->execute();
        return $stmt->fetchAll(PDO::FETCH_ASSOC);
    }

    public function markAsRead(int $messageId, int $userId): bool {
        $sql = 'UPDATE messages SET is_read = 1 WHERE id = :id AND receiver_id = :userId';
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute(['id' => $messageId, 'userId' => $userId]);
        return $stmt->rowCount() > 0;
    }

    public function deleteForUser(int $messageId, int $userId): bool {
        // Мягкое удаление: можно добавить поле deleted_receiver
        $sql = 'DELETE FROM messages WHERE id = :id AND (sender_id = :userId OR receiver_id = :userId)';
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute(['id' => $messageId, 'userId' => $userId]);
        return $stmt->rowCount() > 0;
    }

    public function countUnread(int $userId): int {
        $stmt = $this->pdo->prepare('SELECT COUNT(*) FROM messages WHERE receiver_id = :userId AND is_read = 0');
        $stmt->execute(['userId' => $userId]);
        return (int)$stmt->fetchColumn();
    }
}
?>

Пример использования:

<?php
$pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '');
$manager = new MessageManager($pdo);
$manager->send(5, 42, 'Вопрос', 'Как дела?');
echo 'Отправлено, ID: ' . $manager->lastInsertId();
?>

Отправлено, ID: 101

Миграция таблицы с помощью SQL (MySQL)

CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL UNIQUE,
    email VARCHAR(100) NOT NULL UNIQUE,
    password_hash VARCHAR(255) NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

CREATE TABLE IF NOT EXISTS messages (
    id INT AUTO_INCREMENT PRIMARY KEY,
    sender_id INT NOT NULL,
    receiver_id INT NOT NULL,
    subject VARCHAR(255) DEFAULT NULL,
    message_text TEXT NOT NULL,
    is_read TINYINT(1) DEFAULT 0,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    INDEX idx_receiver (receiver_id, is_read),
    INDEX idx_sender (sender_id),
    FOREIGN KEY (sender_id) REFERENCES users(id) ON DELETE CASCADE,
    FOREIGN KEY (receiver_id) REFERENCES users(id) ON DELETE CASCADE
);

Вывод списка сообщений с пагинацией (HTML + PHP)

<?php
$page = isset($_GET['page']) ? (int)$_GET['page'] : 1;
$perPage = 10;
$inbox = $manager->getInbox($_SESSION['user_id'], $page, $perPage);
?>
<table>
    <tr><th>Отправитель</th><th>Тема</th><th>Дата</th><th>Статус</th></tr>
    <?php foreach ($inbox as $msg): ?>
    <tr>
        <td><?= htmlspecialchars($msg['sender_name']) ?></td>
        <td><?= htmlspecialchars($msg['subject']) ?></td>
        <td><?= $msg['created_at'] ?></td>
        <td><?= $msg['is_read'] ? 'Прочитано' : 'Новое' ?></td>
    </tr>
    <?php endforeach; ?>
</table>
<?php
// Пагинация
$total = $manager->getInboxCount($_SESSION['user_id']); // доработайте метод
echo 'Страница ' . $page . ' из ' . ceil($total / $perPage);
?>

Отметка о прочтении при открытии сообщения (AJAX)

// PHP: mark.php
<?php
session_start();
require 'db.php';
$manager = new MessageManager($pdo);
$msgId = (int)$_POST['msg_id'];
$userId = $_SESSION['user_id'];
$result = $manager->markAsRead($msgId, $userId);
echo json_encode(['success' => $result]);
?>

// JavaScript
function markRead(msgId) {
    fetch('mark.php', {
        method: 'POST',
        headers: {'Content-Type': 'application/x-www-form-urlencoded'},
        body: 'msg_id=' + msgId
    });
}

Получение последних сообщений через WebSocket (продвинутый вариант)

Для реального времени используют WebSocket (например, Ratchet) или long polling. Пример с long polling:

// poll.php
<?php
session_start();
header('Content-Type: application/json');
$lastId = isset($_GET['last_id']) ? (int)$_GET['last_id'] : 0;
$userId = $_SESSION['user_id'];
$pdo = new PDO(...);
$stmt = $pdo->prepare('SELECT * FROM messages WHERE receiver_id = :uid AND id > :last_id ORDER BY id DESC LIMIT 10');
$stmt->execute(['uid' => $userId, 'last_id' => $lastId]);
echo json_encode($stmt->fetchAll(PDO::FETCH_ASSOC));
?>

Обработка ошибок и валидация

<?php
try {
    if (!$manager->send($sender, $receiver, $subject, $text)) {
        throw new Exception('Не удалось отправить сообщение');
    }
} catch (PDOException $e) {
    error_log($e->getMessage());
    echo 'Внутренняя ошибка. Попробуйте позже.';
}
?>