Hamza-AyedandClaude Opus 5
4d8414c96b
قرار المالك 2026-07-27: باك إند سيرو PHP هو المعتمد، وتطبيقاته المجرّبة ميدانياً تحل محل إعادة البناء المؤرشفة. سيرو نفسه لم يُمسّ. الخريطة: backend · payment_server · loction_server · ride_server · passenger_server · docker · dashboard · stress_test → الجذر siro_rider → apps/rider siro_driver → apps/driver siro_admin → dashboards/admin siro_service → dashboards/service android_bot → apps/android_bot socialBot → apps/socialBot نُسخ المتعقَّب في git سيرو فقط عبر `git archive` (3,198 ملفاً / ~169 م.ب) لا `cp -r` — فاستُثنيت مخلفات البناء تلقائياً. بلا أي تعديل محتوى عمداً: كل ما يلي يصير فرقاً مقروءاً مقابل المصدر. لم يُستورد وسببه: siromove.com (الموقع التسويقي يبقى marketing/ في تريبز، سيرو فيه 8 ملفات) · docs و planning (تريبز له docs/ الخاص) · deploy.sh (ليس نشراً على سيرفر بل `git add . && git push origin --all` — فخّ في مستودع آخر) · transit_dashboard (بانتظار قرار مصير backend-transit و dashboards/transit-web). ⚠️ لا يبني بعد — ثلاثة نواقص متوقعة ومقصودة: 1. `.env` و `lib/env/env.g.dart` غير متعقَّبين في سيرو (أسرار لكل مستأجر): كل تطبيق فلاتر يحتاج .env خاصاً ثم توليد env.g.dart بـ build_runner. 2. إعدادات Firebase (9 ملفات google-services.json و GoogleService-Info.plist) يستبعدها .gitignore تريبز — ولكل مستأجر مشروع Firebase خاص أصلاً. 3. apps/driver في سيرو يشير إلى `../../Intaleq/packages/get` خارج المستودع → يجب ضمّ الحزم داخله أسوة بـ apps/rider. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
337 lines
15 KiB
PHP
337 lines
15 KiB
PHP
<?php
|
||
/**
|
||
* cron_ai_engine.php - AI Pricing Engine v2
|
||
*
|
||
* يقرأ معادلات المنافسين من Node.js Pricing Engine (competitor_secret_formulas)
|
||
* ويطبّق تسعيراً ذكياً بناءً على النتائج الإحصائية بدلاً من الحسابات البدائية.
|
||
*
|
||
* لم يعُد هذا الملف يحسب بنفسه - بل يعتمد على التحليل الإحصائي من pricing-engine.
|
||
*/
|
||
|
||
require_once __DIR__ . '/../core/bootstrap.php';
|
||
require_once __DIR__ . '/../functions.php';
|
||
require_once __DIR__ . '/../ride/pricing/pricing_helper.php';
|
||
|
||
try {
|
||
$con = Database::get('main');
|
||
$redis = getRedisConnection();
|
||
} catch (Exception $e) {
|
||
die("Connection failed: " . $e->getMessage() . "\n");
|
||
}
|
||
|
||
echo "Starting Siro AI Engine v2 (Powered by Pricing Engine)...\n";
|
||
|
||
// ==========================================
|
||
// 0. جدول افتراضات عمولة المنافسين (لميزة "أرباحك أعلى" للسائق)
|
||
// ==========================================
|
||
$con->exec("
|
||
CREATE TABLE IF NOT EXISTS `competitor_commission_assumptions` (
|
||
`country_code` VARCHAR(5) NOT NULL,
|
||
`competitor_name` VARCHAR(64) NOT NULL,
|
||
`commission_pct` DECIMAL(5,2) NOT NULL,
|
||
`updated_at` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
|
||
PRIMARY KEY (`country_code`, `competitor_name`)
|
||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
|
||
");
|
||
|
||
// زرع أولي بأرقام حقيقية زوّدنا فيها — INSERT IGNORE عشان ما نبهدل أي تعديل يدوي لاحق من الأدمن
|
||
$commissionSeed = [
|
||
// الأردن — كل التطبيقات المذكورة أعطتنا نفس النسبة 23%
|
||
['JO', 'com.careem.ae', 23.0],
|
||
['JO', 'com.ubercab', 23.0],
|
||
['JO', 'com.jeeny.app', 23.0],
|
||
['JO', 'com.taxif.passenger', 23.0],
|
||
['JO', 'gogo', 23.0],
|
||
['JO', 'petra_ride', 23.0],
|
||
// سوريا
|
||
['SY', 'yallago', 20.0],
|
||
['SY', 'zaken', 17.0],
|
||
['SY', 'tufaddal', 15.0],
|
||
// مصر — استخدمنا الطرف الأدنى من كل مجال أعطانا إياه المستخدم (تحفظاً)
|
||
['EG', 'uber', 25.0],
|
||
['EG', 'careem', 20.0],
|
||
['EG', 'didi', 15.0],
|
||
['EG', 'indrive', 14.0],
|
||
];
|
||
$seedStmt = $con->prepare("
|
||
INSERT IGNORE INTO competitor_commission_assumptions (country_code, competitor_name, commission_pct)
|
||
VALUES (:cc, :name, :pct)
|
||
");
|
||
foreach ($commissionSeed as [$cc, $name, $pct]) {
|
||
$seedStmt->execute([':cc' => $cc, ':name' => $name, ':pct' => $pct]);
|
||
}
|
||
|
||
// ==========================================
|
||
// 1. التسعير الديناميكي بناءً على المعادلات الإحصائية
|
||
// ==========================================
|
||
echo "1. Reading competitor formulas from Pricing Engine...\n";
|
||
try {
|
||
// قراءة آخر المعادلات من التحليل الإحصائي
|
||
$sql = "SELECT * FROM competitor_secret_formulas
|
||
WHERE last_updated >= DATE_SUB(NOW(), INTERVAL 24 HOUR)
|
||
ORDER BY last_updated DESC";
|
||
$stmt = $con->query($sql);
|
||
$formulas = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||
|
||
if (empty($formulas)) {
|
||
echo " ⚠️ No recent formulas found. Run pricing-engine first.\n";
|
||
} else {
|
||
// تجميع المعادلات حسب الدولة
|
||
$byCountry = [];
|
||
foreach ($formulas as $f) {
|
||
$country = $f['country_code'];
|
||
if (!isset($byCountry[$country])) $byCountry[$country] = [];
|
||
$byCountry[$country][] = $f;
|
||
}
|
||
|
||
foreach ($byCountry as $country => $countryFormulas) {
|
||
$countryNameMap = ['JO' => 'Jordan', 'SY' => 'Syria', 'EG' => 'Egypt', 'IQ' => 'Iraq'];
|
||
$countryName = $countryNameMap[$country] ?? $country;
|
||
|
||
// اختيار أفضل معادلة للتسعير حسب الأولوية:
|
||
// 1. Economy tier (الأكثر تنافسية)
|
||
// 2. Standard tier (إذا ما في Economy)
|
||
// 3. أي tier ثاني بأعلى R²
|
||
$tierPriority = ['economy', 'standard', 'premium'];
|
||
$bestFormula = null;
|
||
$bestTierIdx = 999;
|
||
|
||
foreach ($countryFormulas as $f) {
|
||
$tier = $f['tier'] ?? 'standard';
|
||
$tierIdx = array_search($tier, $tierPriority);
|
||
if ($tierIdx === false) $tierIdx = 999;
|
||
|
||
$currentRSq = (float)($f['r_squared'] ?? 0);
|
||
$currentKm = (float)($f['price_per_km'] ?? 0);
|
||
|
||
// أفضلية: Tier أعلى أولوية، ثم R² أعلى
|
||
if ($currentKm > 0 && (
|
||
$bestFormula === null ||
|
||
$tierIdx < $bestTierIdx ||
|
||
($tierIdx === $bestTierIdx && $currentRSq > (float)($bestFormula['r_squared'] ?? 0))
|
||
)) {
|
||
$bestTierIdx = $tierIdx;
|
||
$bestFormula = $f;
|
||
}
|
||
}
|
||
|
||
$bestTier = null;
|
||
if ($bestFormula) {
|
||
$bestKmRate = (float)$bestFormula['price_per_km'];
|
||
$bestMinRate = (float)$bestFormula['price_per_min'];
|
||
$bestBaseFare = (float)$bestFormula['base_fare'];
|
||
$bestMinFare = (float)$bestFormula['min_fare'];
|
||
$bestRSq = (float)($bestFormula['r_squared'] ?? 0);
|
||
$bestTier = $bestFormula['tier'] ?? 'standard';
|
||
}
|
||
|
||
if ($bestKmRate === null) {
|
||
echo " ⚠️ No valid formula for $countryName. Skipping.\n";
|
||
continue;
|
||
}
|
||
|
||
// تسعير Siro: أرخص بنسبة 6.5% من المنافس مع الحفاظ على هيكل التسعير
|
||
$discountFactor = 1 - 0.065;
|
||
$ourKmRate = round($bestKmRate * $discountFactor, 3);
|
||
$ourMinRate = round($bestMinRate * $discountFactor, 3);
|
||
$ourBase = round($bestBaseFare * $discountFactor, 3);
|
||
|
||
echo " 📊 $countryName: Using formula [tier=$bestTier] (R²=$bestRSq)\n";
|
||
echo " Competitor: KM=$bestKmRate, MIN=$bestMinRate, Base=$bestBaseFare, MinFare=$bestMinFare\n";
|
||
echo " Siro (6.5% less): KM=$ourKmRate, MIN=$ourMinRate, Base=$ourBase\n";
|
||
|
||
// تحديث جدول kazan
|
||
$speedPrice = $ourKmRate;
|
||
$comfortPrice = round($ourKmRate * 1.30, 3);
|
||
$ladyPrice = round($ourKmRate * 1.10, 3);
|
||
$electricPrice = round($ourKmRate * 1.20, 3);
|
||
$vanPrice = round($ourKmRate * 1.50, 3);
|
||
$deliveryPrice = round($ourKmRate * 0.90, 3);
|
||
$mishwarVipPrice = round($ourKmRate * 1.40, 3);
|
||
$fixedPrice = $speedPrice;
|
||
$awfarPrice = round($ourKmRate * 0.85, 3);
|
||
|
||
// أسعار الدقائق
|
||
if ($country === 'JO') {
|
||
$normalMin = $ourMinRate > 0 ? $ourMinRate : 0.05;
|
||
$peakMin = round($normalMin * 1.15, 3);
|
||
$lateMin = $normalMin;
|
||
} else {
|
||
$normalMin = $ourMinRate > 0 ? $ourMinRate : round($speedPrice / 4, 3);
|
||
$peakMin = round($normalMin * 1.15, 3);
|
||
$lateMin = round($normalMin * 1.25, 3);
|
||
}
|
||
|
||
$updateSql = "UPDATE kazan
|
||
SET speedPrice = :speedPrice,
|
||
comfortPrice = :comfortPrice,
|
||
ladyPrice = :ladyPrice,
|
||
electricPrice = :electricPrice,
|
||
vanPrice = :vanPrice,
|
||
deliveryPrice = :deliveryPrice,
|
||
mishwarVipPrice = :mishwarVipPrice,
|
||
fixedPrice = :fixedPrice,
|
||
awfarPrice = :awfarPrice,
|
||
normalMinPrice = :normalMin,
|
||
peakMinPrice = :peakMin,
|
||
lateMinPrice = :lateMin,
|
||
startPrice = :startPrice
|
||
WHERE country = :countryName";
|
||
|
||
$upStmt = $con->prepare($updateSql);
|
||
$upStmt->execute([
|
||
':speedPrice' => $speedPrice,
|
||
':comfortPrice' => $comfortPrice,
|
||
':ladyPrice' => $ladyPrice,
|
||
':electricPrice' => $electricPrice,
|
||
':vanPrice' => $vanPrice,
|
||
':deliveryPrice' => $deliveryPrice,
|
||
':mishwarVipPrice' => $mishwarVipPrice,
|
||
':fixedPrice' => $fixedPrice,
|
||
':awfarPrice' => $awfarPrice,
|
||
':normalMin' => $normalMin,
|
||
':peakMin' => $peakMin,
|
||
':lateMin' => $lateMin,
|
||
':startPrice' => $ourBase,
|
||
':countryName' => $countryName
|
||
]);
|
||
|
||
echo " ✅ Updated $countryName pricing in kazan table.\n";
|
||
|
||
// ── تخزين معاملات المنافس الحالي بـ Redis لميزة "أرباحك أعلى" للسائق ──
|
||
// get.php / add_ride.php يقرأوا هذا المفتاح فقط (بدون أي استعلام DB
|
||
// وقت إنشاء الرحلة) عبر estimateDriverEarningsAdvantage()
|
||
try {
|
||
$commStmt = $con->prepare("
|
||
SELECT commission_pct FROM competitor_commission_assumptions
|
||
WHERE country_code = :cc AND competitor_name = :name LIMIT 1
|
||
");
|
||
$commStmt->execute([':cc' => $country, ':name' => $bestFormula['competitor_name']]);
|
||
$commissionPct = (float)($commStmt->fetchColumn() ?: 20.0);
|
||
|
||
$driverComparisonData = [
|
||
'competitor_name' => $bestFormula['competitor_name'],
|
||
'base_fare' => $bestBaseFare,
|
||
'km_rate' => $bestKmRate,
|
||
'min_rate' => $bestMinRate,
|
||
'commission_pct' => $commissionPct,
|
||
'currency' => getCurrencyByCountry($countryName),
|
||
'updated_at' => date('Y-m-d H:i:s'),
|
||
];
|
||
// TTL أطول من فترة الجدولة (3 ساعات) بهامش أمان
|
||
$redis->setex("pricing:driver_comparison:{$country}", 14400, json_encode($driverComparisonData));
|
||
echo " 💰 Cached driver-comparison data for $countryName (commission assumed: {$commissionPct}%)\n";
|
||
} catch (Exception $e) {
|
||
echo " ⚠️ Failed to cache driver-comparison data: " . $e->getMessage() . "\n";
|
||
}
|
||
}
|
||
}
|
||
} catch (Exception $e) {
|
||
echo " ❌ Error in Pricing Module: " . $e->getMessage() . "\n";
|
||
}
|
||
|
||
// ==========================================
|
||
// 2. قراءة Surge Insights من الـ Pricing Engine
|
||
// ==========================================
|
||
echo "2. Reading surge insights from Pricing Engine...\n";
|
||
try {
|
||
$sql = "SELECT * FROM competitor_surge_insights
|
||
WHERE detected_at >= DATE_SUB(NOW(), INTERVAL 12 HOUR)
|
||
ORDER BY surge_multiplier DESC
|
||
LIMIT 20";
|
||
$stmt = $con->query($sql);
|
||
$surgeRecords = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||
|
||
if (!empty($surgeRecords)) {
|
||
$surgeByCountry = [];
|
||
foreach ($surgeRecords as $sr) {
|
||
$country = $sr['country_code'];
|
||
if (!isset($surgeByCountry[$country])) {
|
||
$surgeByCountry[$country] = [
|
||
'avg_multiplier' => 0,
|
||
'count' => 0,
|
||
'peak_hours' => []
|
||
];
|
||
}
|
||
$surgeByCountry[$country]['avg_multiplier'] += $sr['surge_multiplier'];
|
||
$surgeByCountry[$country]['count']++;
|
||
$surgeByCountry[$country]['peak_hours'][] = "{$sr['peak_start_hour']}:00-{$sr['peak_end_hour']}:00";
|
||
}
|
||
|
||
foreach ($surgeByCountry as $country => $data) {
|
||
$avgMult = round($data['avg_multiplier'] / $data['count'], 3);
|
||
$peakHoursStr = implode(', ', array_unique($data['peak_hours']));
|
||
|
||
// تخزين ملخص إحصائي (object) على مفتاح خاص ومستقل — لا نكتب على
|
||
// surge:opportunities / surge:opportunities:{country} لأنها خرائط
|
||
// grid_id → multiplier يملأها ويقرأها نظام آخر بالكامل
|
||
// (cron_surge_opportunity.php / get.php / get_surge_heatmap.php /
|
||
// winback_hotspot_targets.php / cron_kazan_adjuster.php). كتابة
|
||
// object مسطّح على نفس المفتاح كانت تبهدل تلك الخريطة كل 3 ساعات.
|
||
$surgeData = [
|
||
'avg_competitor_surge' => $avgMult,
|
||
'suggested_multiplier' => round(1.0 + ($avgMult - 1.0) * 0.6, 3),
|
||
'peak_hours' => $data['peak_hours'],
|
||
'updated_at' => date('Y-m-d H:i:s')
|
||
];
|
||
$redis->setex("pricing_engine:competitor_surge_summary:{$country}", 7200, json_encode($surgeData));
|
||
|
||
echo " ⚡ $country: Avg competitor surge = {$avgMult}x, peak hours: {$peakHoursStr}\n";
|
||
}
|
||
} else {
|
||
echo " ℹ️ No recent surge insights found.\n";
|
||
}
|
||
} catch (Exception $e) {
|
||
echo " ❌ Error in Surge Module: " . $e->getMessage() . "\n";
|
||
}
|
||
|
||
// ==========================================
|
||
// 3. وحدة استهداف الركاب الخاملين (Smart Retention) - كما هي
|
||
// ==========================================
|
||
echo "3. Running Smart Retention Module...\n";
|
||
try {
|
||
$sql = "SELECT source, COUNT(*) as opens
|
||
FROM passenger_opening_locations
|
||
WHERE created_at >= DATE_SUB(NOW(), INTERVAL 3 HOUR)
|
||
GROUP BY source
|
||
HAVING opens >= 3";
|
||
|
||
$stmt = $con->query($sql);
|
||
$idleRiders = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||
$notifiedCount = count($idleRiders);
|
||
echo " 📱 Identified $notifiedCount idle riders requiring push notifications.\n";
|
||
} catch (Exception $e) {
|
||
echo " ❌ Error in Smart Retention: " . $e->getMessage() . "\n";
|
||
}
|
||
|
||
// ==========================================
|
||
// 4. Export AI Hotzones to Redis for Captains
|
||
// ==========================================
|
||
echo "4. Exporting AI Hotzones to Redis...\n";
|
||
try {
|
||
$sql = "SELECT latitude, longitude, competitor_name AS top_competitor, avg_ppk AS avg_price
|
||
FROM competitor_surge_zones
|
||
WHERE detected_at >= DATE_SUB(NOW(), INTERVAL 6 HOUR)
|
||
AND surge_multiplier > 1.1";
|
||
|
||
$stmt = $con->query($sql);
|
||
$zones = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||
|
||
if (!empty($zones)) {
|
||
$redisData = [
|
||
'status' => 'success',
|
||
'data' => $zones
|
||
];
|
||
$redis->setex('siro:cache:ai:hotzones', 3600, json_encode($redisData));
|
||
echo " 🗺️ Exported " . count($zones) . " hot zones to Redis (siro:cache:ai:hotzones).\n";
|
||
} else {
|
||
// Clear if no surge to avoid stale data
|
||
$redis->del('siro:cache:ai:hotzones');
|
||
echo " ℹ️ No active hot zones to export.\n";
|
||
}
|
||
} catch (Exception $e) {
|
||
echo " ❌ Error in Hotzones Export: " . $e->getMessage() . "\n";
|
||
}
|
||
|
||
echo "AI Engine v2 finished successfully.\n";
|