notification_system.php

<?php
class NotificationSystem {
    private $pdo;
    private $userId;
    private $currentTime;

    public function __construct($pdo, $userId) {
        $this->pdo = $pdo;
        $this->userId = $userId;
        $this->currentTime = '2025-06-14 12:47:29';
    }

    public function createNotification($type, $data) {
        $stmt = $this->pdo->prepare("
            INSERT INTO notifications 
            (user_id, type, data, created_at, is_read)
            VALUES (?, ?, ?, ?, 0)
        ");
        return $stmt->execute([
            $this->userId,
            $type,
            json_encode($data),
            $this->currentTime
        ]);
    }

    public function getUnreadNotifications() {
        $stmt = $this->pdo->prepare("
            SELECT * FROM notifications
            WHERE user_id = ?
            AND is_read = 0
            ORDER BY created_at DESC
        ");
        $stmt->execute([$this->userId]);
        return $stmt->fetchAll();
    }

    public function markAsRead($notificationId) {
        $stmt = $this->pdo->prepare("
            UPDATE notifications
            SET is_read = 1,
                read_at = ?
            WHERE id = ?
            AND user_id = ?
        ");
        return $stmt->execute([$this->currentTime, $notificationId, $this->userId]);
    }
}
?>