// 假設這是WebSocket服務器的一部分
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class Chat implements MessageComponentInterface {
    protected $clients;
    protected $db; // 數(shù)據(jù)庫連接

    public function __construct() {
        $this->clients = new \SplObjectStorage;
        // 初始化數(shù)據(jù)庫連接
        // $this->db = new PDO(...); 
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        // 獲取用戶ID (例如從Session或認證信息中獲取)
        $userId = $conn->resourceId; // 實際應用中需要更可靠的用戶識別

        // 將用戶標記為在線
        // $stmt = $this->db->prepare("INSERT INTO activeuserlist (user_id) VALUES (?) ON DUPLICATE KEY UPDATE last_active = NOW()");
        // $stmt->execute([$userId]);
        echo "New connection! ({$userId})\n";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        // 處理消息...
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        $userId = $conn->resourceId; // 同上，需要更可靠的用戶識別

        // 將用戶標記為離線或從activeuserlist中移除
        // $stmt = $this->db->prepare("DELETE FROM activeuserlist WHERE user_id = ?");
        // $stmt->execute([$userId]);
        echo "Connection {$userId} has disconnected\n";
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "An error has occurred: {$e->getMessage()}\n";
        $conn->close();
    }
}

// 啟動WebSocket服務器
// $server = IoServer::factory(new Chat(), 8080);
// $server->run();

// 當用戶登錄后，嘗試建立WebSocket連接
const ws = new WebSocket('ws://your-websocket-server.com:8080');

ws.onopen = function() {
    console.log('WebSocket connection established.');
    // 此時服務器會收到onOpen事件并更新用戶在線狀態(tài)
};

ws.onclose = function() {
    console.log('WebSocket connection closed.');
    // 此時服務器會收到onClose事件并更新用戶離線狀態(tài)
};

ws.onerror = function(error) {
    console.error('WebSocket error:', error);
};

// ... 其他消息處理邏輯

// 假設用戶已登錄
function sendHeartbeat() {
    fetch('/api/update_online_status.php', {
        method: 'POST',
        headers: {
            'Content-Type': 'application/json'
        },
        body: JSON.stringify({ userId: 'current_user_id' }) // 實際中可能通過session或token識別
    })
    .then(response => response.json())
    .then(data => {
        if (data.status === 'success') {
            // console.log('Online status updated.');
        }
    })
    .catch(error => {
        console.error('Error updating online status:', error);
    });
}

// 每20秒發(fā)送一次心跳
setInterval(sendHeartbeat, 20000); 

// 首次加載頁面時立即發(fā)送一次
sendHeartbeat();

<?php
session_start();
header('Content-Type: application/json');

// 假設已經(jīng)建立了數(shù)據(jù)庫連接 $pdo
// 確保用戶已認證
if (!isset($_SESSION['user_id'])) {
    echo json_encode(['status' => 'error', 'message' => 'Unauthorized']);
    exit;
}

$userId = $_SESSION['user_id']; // 從會話中獲取用戶ID

try {
    $stmt = $pdo->prepare("INSERT INTO activeuserlist (user_id, last_active) VALUES (:user_id, NOW()) ON DUPLICATE KEY UPDATE last_active = NOW()");
    $stmt->execute([':user_id' => $userId]);
    echo json_encode(['status' => 'success']);
} catch (PDOException $e) {
    error_log("Database error: " . $e->getMessage());
    echo json_encode(['status' => 'error', 'message' => 'Database update failed']);
}
?>

<?php
// 假設已經(jīng)建立了數(shù)據(jù)庫連接 $pdo

// 定義離線閾值，例如3分鐘（3 * 60秒）
$offlineThresholdSeconds = 3 * 60; 

try {
    // 從activeuserlist中刪除超過閾值未活躍的用戶
    $stmt = $pdo->prepare("DELETE FROM activeuserlist WHERE last_active < (NOW() - INTERVAL :threshold SECOND)");
    $stmt->execute([':threshold' => $offlineThresholdSeconds]);

    echo "Cleaned up " . $stmt->rowCount() . " offline users.\n";
} catch (PDOException $e) {
    error_log("Cron job database error: " . $e->getMessage());
    echo "Error during cleanup: " . $e->getMessage() . "\n";
}
?>