PHPを使用してブロードキャストリマインダー機能を実装するにはどうすればよいですか?詳細なチュートリアルの共有

CREATE TABLE streamers (
    id INT AUTO_INCREMENT PRIMARY KEY,
    streamer_id INT,
    streamer_name VARCHAR(50)
);

CREATE TABLE subscriptions (
    id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT,
    streamer_id INT
);

<?php
// 连接数据库
$conn = new mysqli("localhost", "root", "root", "live_streaming");

// 处理主播发送开播请求
if(isset($_POST['streamer_id'])) {
    $streamer_id = $_POST['streamer_id'];
    $streamer_name = $_POST['streamer_name'];

    $sql = "INSERT INTO streamers (streamer_id, streamer_name) VALUES ('$streamer_id', '$streamer_name')";
    $conn->query($sql);
    echo "开播请求已发送";
}

// 处理用户订阅主播
if(isset($_POST['user_id']) && isset($_POST['streamer_id'])) {
    $user_id = $_POST['user_id'];
    $streamer_id = $_POST['streamer_id'];

    $sql = "INSERT INTO subscriptions (user_id, streamer_id) VALUES ('$user_id', '$streamer_id')";
    $conn->query($sql);
    echo "订阅成功";
}
?>

<?php
// 查询订阅了该主播的用户
$sql = "SELECT user_id FROM subscriptions WHERE streamer_id = $streamer_id";
$result = $conn->query($sql);

if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
        $user_id = $row['user_id'];
        // 向用户发送提醒通知，可使用邮件、短信等方式
        sendNotification($user_id, "主播{$streamer_name}已开播");
    }
}

function sendNotification($user_id, $message) {
    // 具体实现发送通知的代码
}
?>