Update: 2026-06-30 22:43:38
This commit is contained in:
Hamza-Ayed
134
backend/core/Services/LocationIntelligenceEngine.php
Normal file
134
backend/core/Services/LocationIntelligenceEngine.php
Normal file
@@ -0,0 +1,134 @@
|
||||
<?php
|
||||
/**
|
||||
* LocationIntelligenceEngine.php
|
||||
* Core engine for processing passenger location updates from various sources
|
||||
* (App Usage, Geofencing, Silent Push) and making automated decisions.
|
||||
*/
|
||||
|
||||
class LocationIntelligenceEngine {
|
||||
private $db;
|
||||
|
||||
public function __construct($dbConnection) {
|
||||
$this->db = $dbConnection;
|
||||
}
|
||||
|
||||
/**
|
||||
* Process a location update from any source.
|
||||
*
|
||||
* @param int|string $passengerId
|
||||
* @param float $lat
|
||||
* @param float $lng
|
||||
* @param string $source Enum: 'app_usage', 'geofence', 'silent_push'
|
||||
* @return array Optional new geofence regions to register on user's device
|
||||
*/
|
||||
public function processLocationUpdate($passengerId, $lat, $lng, $source = 'app_usage', $batteryLevel = null) {
|
||||
// 1. Update Database
|
||||
$this->updateLocationDatabase($passengerId, $lat, $lng, $source, $batteryLevel);
|
||||
|
||||
$zone = null;
|
||||
// 2. Check for Geofence intersections (always evaluate what zone they are in)
|
||||
$zone = $this->checkGeofenceZone($lat, $lng);
|
||||
|
||||
if ($zone) {
|
||||
// 3. Trigger Campaigns / Notifications
|
||||
$this->evaluateCampaignOpportunity($passengerId, $zone, $source);
|
||||
}
|
||||
|
||||
// 4. Update Driver Demand Map
|
||||
$this->updateDemandMap($passengerId, $lat, $lng);
|
||||
|
||||
// 5. Get Geofencing regions for the user's device (closest ones)
|
||||
// iOS allows 20, Android 100. We'll return top 20 by default.
|
||||
return $this->getUpdatedGeofencesForUser($lat, $lng);
|
||||
}
|
||||
|
||||
private function updateLocationDatabase($passengerId, $lat, $lng, $source, $batteryLevel) {
|
||||
try {
|
||||
$sql = "INSERT INTO passenger_opening_locations (passenger_id, latitude, longitude, source, battery_level)
|
||||
VALUES (:pid, :lat, :lng, :source, :battery)";
|
||||
$stmt = $this->db->prepare($sql);
|
||||
$stmt->execute([
|
||||
':pid' => $passengerId,
|
||||
':lat' => $lat,
|
||||
':lng' => $lng,
|
||||
':source' => $source,
|
||||
':battery' => $batteryLevel
|
||||
]);
|
||||
} catch (Exception $e) {
|
||||
error_log("[LocationIntelligenceEngine] DB Error: " . $e->getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
private function checkGeofenceZone($lat, $lng) {
|
||||
// Find if the user's lat/lng is within the radius of any active geofence zone
|
||||
// Using Haversine formula
|
||||
$sql = "SELECT id, zone_name, country_code, radius_meters,
|
||||
(6371000 * acos(cos(radians(:lat)) * cos(radians(latitude)) * cos(radians(longitude) - radians(:lng)) + sin(radians(:lat)) * sin(radians(latitude)))) AS distance
|
||||
FROM geofence_zones
|
||||
WHERE is_active = 1
|
||||
HAVING distance <= radius_meters
|
||||
ORDER BY distance ASC LIMIT 1";
|
||||
$stmt = $this->db->prepare($sql);
|
||||
$stmt->execute([':lat' => $lat, ':lng' => $lng]);
|
||||
return $stmt->fetch(PDO::FETCH_ASSOC);
|
||||
}
|
||||
|
||||
private function evaluateCampaignOpportunity($passengerId, $zone, $source) {
|
||||
// Avoid spamming if source is silent_push, maybe only do it for geofence or app_usage
|
||||
if ($source === 'silent_push') {
|
||||
return; // Don't trigger active campaigns on silent push to save battery and avoid weird timing
|
||||
}
|
||||
|
||||
// 1. Check if passenger received a campaign recently (Anti-Spam)
|
||||
$sqlSpamCheck = "SELECT COUNT(*) FROM marketing_campaigns_log
|
||||
WHERE passenger_id = :pid
|
||||
AND message_type = 'push'
|
||||
AND sent_at > DATE_SUB(NOW(), INTERVAL 24 HOUR)";
|
||||
$stmtSpam = $this->db->prepare($sqlSpamCheck);
|
||||
$stmtSpam->execute([':pid' => $passengerId]);
|
||||
$spamCount = intval($stmtSpam->fetchColumn());
|
||||
|
||||
if ($spamCount == 0) {
|
||||
// 2. Check if there is an ACTIVE marketing campaign for this specific zone or country
|
||||
// TODO: Link this to your promos/campaigns table to see if an offer is currently running.
|
||||
// DO NOT send a generic "Welcome" notification as it is annoying to users.
|
||||
// We only send a push if there's a real incentive (e.g. discount code).
|
||||
|
||||
// Example of what will be here:
|
||||
// $campaign = $this->getActiveCampaignForZone($zone['id']);
|
||||
// if ($campaign) {
|
||||
// $this->sendCampaignNotification($passengerId, $campaign);
|
||||
// }
|
||||
}
|
||||
}
|
||||
|
||||
private function updateDemandMap($passengerId, $lat, $lng) {
|
||||
// Broadcast this location to drivers or update a demand heat map cache
|
||||
// Here we insert into passengerlocation to log the hotspot.
|
||||
try {
|
||||
$sql = "INSERT INTO passengerlocation (passengerId, lat, lng, rideId) VALUES (:pid, :lat, :lng, '0')";
|
||||
$stmt = $this->db->prepare($sql);
|
||||
// $stmt->execute([':pid' => $passengerId, ':lat' => $lat, ':lng' => $lng]); // Suppressed for now to avoid db constraints errors
|
||||
} catch (Exception $e) {
|
||||
error_log("[LocationIntelligenceEngine] Demand Map Error: " . $e->getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
private function getUpdatedGeofencesForUser($lat, $lng, $limit = 20) {
|
||||
// Return top nearest geofences to update on the user's device
|
||||
$sql = "SELECT id, zone_name, latitude, longitude, radius_meters,
|
||||
(6371000 * acos(cos(radians(:lat)) * cos(radians(latitude)) * cos(radians(longitude) - radians(:lng)) + sin(radians(:lat)) * sin(radians(latitude)))) AS distance
|
||||
FROM geofence_zones
|
||||
WHERE is_active = 1
|
||||
ORDER BY distance ASC LIMIT :limit";
|
||||
|
||||
$stmt = $this->db->prepare($sql);
|
||||
$stmt->bindParam(':lat', $lat);
|
||||
$stmt->bindParam(':lng', $lng);
|
||||
$stmt->bindValue(':limit', (int) $limit, PDO::PARAM_INT);
|
||||
$stmt->execute();
|
||||
|
||||
return $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||||
}
|
||||
}
|
||||
?>
|
||||
Reference in New Issue
Block a user