Hamza-AyedandClaude Opus 5
92dc6b3641
نسخة كاملة من مستودع سيرو عند ecfe7568 لتكون أساس تطبيق «انطلق». نُسخ المتعقَّب في git فقط (12,509 ملفاً / 302 م.ب) بـ git archive، لا `cp -r` — فاستُثنيت تلقائياً مخلفات البناء (build · node_modules · .dart_tool · .gradle · Pods ≈ 10.7 غ.ب) وكل ما يستثنيه .gitignore. هذا الكوميت **بلا أي تعديل عمداً** حتى يكون كل ما يليه فرقاً مقروءاً مقابل سيرو الأصلي. سيرو نفسه لم يُمسّ. ⚠️ لا يبني بعد: `.env` و`lib/env/env.g.dart` غير متعقَّبين في سيرو (وهذا صحيح — أسرار لكل مستأجر). كل تطبيق فلاتر هنا يحتاج .env خاصاً بانطلق ثم توليد env.g.dart عبر build_runner. لا تُنسخ أسرار سيرو. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
68 lines
2.4 KiB
PHP
68 lines
2.4 KiB
PHP
<?php
|
|
/**
|
|
* transit/cron_sync_members.php
|
|
* ─────────────────────────────────────────────────────────────────────
|
|
* يعيد بناء مجموعات transit:org_members:{orgId} في Redis (location server)
|
|
* من قاعدة البيانات MySQL — للتشغيل اليدوي أو الكرون اليومي.
|
|
*
|
|
* يُستخدَم بعد:
|
|
* • هجرة قاعدة البيانات (ALTER/INSERT جماعي)
|
|
* • انقطاع Redis (مسح البيانات بعد إعادة التشغيل)
|
|
* • مزامنة دورية للتأكد من عدم الانزلاق
|
|
*
|
|
* crontab مقترح:
|
|
* 0 3 * * * php /home/intaleq-rides/backend/transit/cron_sync_members.php >> /var/log/transit_sync_members.log 2>&1
|
|
*/
|
|
|
|
require_once __DIR__ . '/../core/bootstrap.php';
|
|
|
|
echo "[" . date('Y-m-d H:i:s') . "] Starting transit:org_members sync...\n";
|
|
|
|
if (!$redisLocation) {
|
|
echo "[ERROR] \$redisLocation is not available. Check REDIS_LOCATION_HOST in .env\n";
|
|
exit(1);
|
|
}
|
|
|
|
try {
|
|
$transit_con = Database::get('transit');
|
|
} catch (Exception $e) {
|
|
echo "[ERROR] Cannot connect to siroTransitDb: " . $e->getMessage() . "\n";
|
|
exit(1);
|
|
}
|
|
|
|
// جلب كل العضويات النشطة مع org_id
|
|
$st = $transit_con->prepare(
|
|
"SELECT org_id, passenger_id
|
|
FROM transit_enrollments
|
|
WHERE status = 'active'
|
|
AND passenger_id IS NOT NULL"
|
|
);
|
|
$st->execute();
|
|
$rows = $st->fetchAll(PDO::FETCH_ASSOC);
|
|
|
|
echo "[INFO] Found " . count($rows) . " active enrollments to sync\n";
|
|
|
|
// تجميع per org
|
|
$byOrg = [];
|
|
foreach ($rows as $row) {
|
|
$byOrg[(int)$row['org_id']][] = (string)$row['passenger_id'];
|
|
}
|
|
|
|
$synced = 0;
|
|
foreach ($byOrg as $orgId => $passengerIds) {
|
|
$key = "transit:org_members:{$orgId}";
|
|
|
|
// بناء كامل: احذف المجموعة القديمة وأعد بناءها بدفعة واحدة
|
|
$redisLocation->del($key);
|
|
if (!empty($passengerIds)) {
|
|
// sAdd يقبل array ابتداءً من phpredis 5.x
|
|
$redisLocation->sAdd($key, ...$passengerIds);
|
|
$redisLocation->expire($key, 7 * 86400);
|
|
}
|
|
|
|
echo "[SYNC] org_id={$orgId} → {$key} ({" . count($passengerIds) . "} members)\n";
|
|
$synced++;
|
|
}
|
|
|
|
echo "[" . date('Y-m-d H:i:s') . "] Done. Synced {$synced} orgs, " . count($rows) . " total enrollments.\n";
|