load_flights.php

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

// Check if user is logged in
if (!isset($_SESSION['logged_in']) || $_SESSION['logged_in'] !== true) {
    echo json_encode(['success' => false, 'message' => 'Please login to load flights.']);
    exit;
}

// Check if user is admin (phone: 222-222-2222)
$userPhone = $_SESSION['phone'] ?? '';
if ($userPhone !== '222-222-2222') {
    echo json_encode(['success' => false, 'message' => 'Only admin can load flights.']);
    exit;
}

// Read flights.json file
$jsonFile = 'flights.json';
if (!file_exists($jsonFile)) {
    echo json_encode(['success' => false, 'message' => 'flights.json file not found.']);
    exit;
}

$jsonData = file_get_contents($jsonFile);
$flights = json_decode($jsonData, true);

if (!$flights || !is_array($flights)) {
    echo json_encode(['success' => false, 'message' => 'Invalid JSON format in flights.json.']);
    exit;
}

try {
    // Clear existing flights (optional - you might want to keep existing ones)
    // $conn->exec("TRUNCATE TABLE flights");
    
    // Prepare insert statement
    $stmt = $conn->prepare("
        INSERT INTO flights (flight_id, origin, destination, departure_date, arrival_date, departure_time, arrival_time, available_seats, price)
        VALUES (:flight_id, :origin, :destination, :departure_date, :arrival_date, :departure_time, :arrival_time, :available_seats, :price)
        ON DUPLICATE KEY UPDATE
            origin = VALUES(origin),
            destination = VALUES(destination),
            departure_date = VALUES(departure_date),
            arrival_date = VALUES(arrival_date),
            departure_time = VALUES(departure_time),
            arrival_time = VALUES(arrival_time),
            available_seats = VALUES(available_seats),
            price = VALUES(price)
    ");
    
    $loaded = 0;
    $errors = [];
    
    foreach ($flights as $flight) {
        // Map JSON fields to database fields
        $flightId = $flight['flightId'] ?? '';
        $origin = $flight['origin'] ?? '';
        $destination = $flight['destination'] ?? '';
        $departureDate = $flight['departureDate'] ?? '';
        $arrivalDate = $flight['arrivalDate'] ?? '';
        $departureTime = $flight['departureTime'] ?? '';
        $arrivalTime = $flight['arrivalTime'] ?? '';
        $availableSeats = $flight['availableSeats'] ?? 0;
        $price = $flight['price'] ?? 0;
        
        // Validate required fields
        if (empty($flightId) || empty($origin) || empty($destination)) {
            $errors[] = "Skipping flight with missing required fields: " . json_encode($flight);
            continue;
        }
        
        try {
            $stmt->execute([
                ':flight_id' => $flightId,
                ':origin' => $origin,
                ':destination' => $destination,
                ':departure_date' => $departureDate,
                ':arrival_date' => $arrivalDate,
                ':departure_time' => $departureTime,
                ':arrival_time' => $arrivalTime,
                ':available_seats' => (int)$availableSeats,
                ':price' => (float)$price
            ]);
            $loaded++;
        } catch (PDOException $e) {
            $errors[] = "Error inserting flight $flightId: " . $e->getMessage();
        }
    }
    
    echo json_encode([
        'success' => true,
        'message' => "Successfully loaded $loaded flights into database.",
        'loaded' => $loaded,
        'total' => count($flights),
        'errors' => $errors
    ]);
    
} catch (PDOException $e) {
    echo json_encode(['success' => false, 'message' => 'Database error: ' . $e->getMessage()]);
}
?>