当前位置：首页 > PHP

php实现网约车

2026-02-28 00:49:26PHP

PHP 网约车系统实现

网约车系统通常包含乘客端、司机端和管理后台三部分。以下是一个基于PHP的网约车系统核心功能实现方案：

数据库设计

主要数据表结构示例：

CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    username VARCHAR(50) NOT NULL,
    password VARCHAR(255) NOT NULL,
    user_type ENUM('passenger','driver','admin') NOT NULL,
    phone VARCHAR(20) NOT NULL
);

CREATE TABLE vehicles (
    id INT PRIMARY KEY AUTO_INCREMENT,
    driver_id INT NOT NULL,
    plate_number VARCHAR(20) NOT NULL,
    vehicle_type VARCHAR(50) NOT NULL,
    FOREIGN KEY (driver_id) REFERENCES users(id)
);

CREATE TABLE rides (
    id INT PRIMARY KEY AUTO_INCREMENT,
    passenger_id INT NOT NULL,
    driver_id INT,
    pickup_location POINT NOT NULL,
    dropoff_location POINT NOT NULL,
    status ENUM('pending','accepted','in_progress','completed','cancelled') DEFAULT 'pending',
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    FOREIGN KEY (passenger_id) REFERENCES users(id),
    FOREIGN KEY (driver_id) REFERENCES users(id)
);

核心功能实现

乘客下单功能

php实现网约车

function createRideRequest($passengerId, $pickupLat, $pickupLng, $dropoffLat, $dropoffLng) {
    $stmt = $pdo->prepare("INSERT INTO rides (passenger_id, pickup_location, dropoff_location) 
                          VALUES (?, POINT(?, ?), POINT(?, ?))");
    $stmt->execute([$passengerId, $pickupLat, $pickupLng, $dropoffLat, $dropoffLng]);
    return $pdo->lastInsertId();
}

司机接单功能

function acceptRide($driverId, $rideId) {
    $stmt = $pdo->prepare("UPDATE rides SET driver_id = ?, status = 'accepted' 
                          WHERE id = ? AND status = 'pending'");
    return $stmt->execute([$driverId, $rideId]);
}

位置计算（距离公式）

php实现网约车

function calculateDistance($lat1, $lon1, $lat2, $lon2) {
    $theta = $lon1 - $lon2;
    $dist = sin(deg2rad($lat1)) * sin(deg2rad($lat2)) + 
            cos(deg2rad($lat1)) * cos(deg2rad($lat2)) * cos(deg2rad($theta));
    $dist = acos($dist);
    $dist = rad2deg($dist);
    return $dist * 60 * 1.1515 * 1.609344; // 返回公里数
}

司机派单逻辑

附近司机查询

function findNearbyDrivers($lat, $lng, $radius = 5) {
    $query = "SELECT u.id, u.username, v.vehicle_type, 
              (ST_Distance_Sphere(pickup_location, POINT(?, ?)) / 1000) AS distance
              FROM users u
              JOIN vehicles v ON u.id = v.driver_id
              WHERE u.user_type = 'driver' 
              AND ST_Distance_Sphere(pickup_location, POINT(?, ?)) <= ? * 1000
              ORDER BY distance ASC";

    $stmt = $pdo->prepare($query);
    $stmt->execute([$lat, $lng, $lat, $lng, $radius]);
    return $stmt->fetchAll(PDO::FETCH_ASSOC);
}

支付系统集成

支付处理示例

function processPayment($rideId, $amount) {
    // 调用支付网关API
    $paymentGateway = new PaymentGateway();
    $result = $paymentGateway->charge($amount);

    if($result['success']) {
        $stmt = $pdo->prepare("UPDATE rides SET payment_status = 'paid', fare = ? WHERE id = ?");
        $stmt->execute([$amount, $rideId]);
        return true;
    }
    return false;
}

实时通信

使用WebSocket或第三方服务实现实时通信：

// 使用Pusher示例
$pusher = new Pusher\Pusher(APP_KEY, APP_SECRET, APP_ID);
$pusher->trigger('ride-channel', 'driver-assigned', [
    'ride_id' => $rideId,
    'driver_id' => $driverId
]);