<?php
session_start();

$servername = "localhost";
$username = "root";
$password = "root";
$dbname = "cyberpunk";

$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
    die("连接数据库失败: " . $conn->connect_error);
}

// 获取POST数据
$car_id = $_POST['car_id'];
$user_id = isset($_SESSION['id']) ? $_SESSION['id'] : null; // 检查用户ID是否存在

if (empty($user_id)) {
    die("用户未登录或会话ID不存在");
}

// 防止重复添加（假设user_cart表中有user_id和vehicle_id唯一索引）
$sqlCheck = "SELECT * FROM user_cart WHERE user_id=? AND vehicle_id=?";
$stmtCheck = $conn->prepare($sqlCheck);

// 错误检查 - 预处理SQL检查语句
if (!$stmtCheck) {
    die("预处理 SQL 语句（检查购物车是否存在商品）失败: " . $conn->error);
}

// 绑定参数并执行查询
$stmtCheck->bind_param("ii", $user_id, $car_id);
$stmtCheck->execute();
$result = $stmtCheck->get_result(); // 使用get_result获取结果集
$count = $result->num_rows;

if (!$count) {
    $sql = "INSERT INTO user_cart (user_id, vehicle_id) VALUES (?, ?)";
    $stmt = $conn->prepare($sql);

    // 错误检查 - 预处理SQL插入语句
    if (!$stmt) {
        die("预处理 SQL 语句（插入购物车商品）失败: " . $conn->error);
    }

    // 绑定参数并执行插入操作
    $stmt->bind_param("ii", $user_id, $car_id);
    $stmt->execute();
    echo "success"; // 返回成功信号给前端，可通过Ajax处理
} else {
    echo "exists"; // 返回已存在信号给前端，同样可通过Ajax处理
}

$stmtCheck->close();

// 增加条件判断以避免关闭未初始化的 $stmt
if ($stmt !== null) {
    $stmt->close();
}

$conn->close();
?>