Update: 2026-07-02 05:56:57

backend/bot/cron_auto_marketing_pusher.php

@@ -0,0 +1,124 @@
+<?php
+/**
+ * cron_auto_marketing_pusher.php
+ * الكرون جوب النهائي لإغلاق حلقة "أتمتة التسويق"
+ * 
+ * الوظيفة:
+ * 1. استخراج الركاب الخاملين (فتحوا التطبيق في آخر ساعتين ولم يطلبوا)
+ * 2. طلب رسالة تسويقية ذكية ومغرية من Gemini مبنية على الأسعار الحالية
+ * 3. إرسال الرسالة آلياً كـ Push Notification للركاب لدفعهم للطلب فوراً
+ *
+ * يُنصح بتشغيل هذا الملف كل ساعة أو كل ساعتين.
+ */
+
+require_once __DIR__ . '/../core/bootstrap.php';
+require_once __DIR__ . '/../core/Services/SiroGeminiService.php';
+require_once __DIR__ . '/../core/Security/EncryptionHelper.php';
+// تأكد من وجود دالة إرسال الإشعارات
+// require_once __DIR__ . '/../functions.php'; // already loaded in bootstrap if configured
+
+set_time_limit(0);
+
+try {
+    $con = Database::get('main');
+} catch (Exception $e) {
+    die("Database connection failed: " . $e->getMessage() . "\n");
+}
+
+echo "Starting Auto Marketing Pusher Engine...\n";
+
+// 1. استخراج الركاب الخاملين في آخر ساعتين (الذين لم يقموا بأي طلب اليوم)
+// نبحث في جدول locations أو tokens للركاب الذين لديهم نشاط قريب دون رحلات
+$sqlIdle = "
+    SELECT p.id as passenger_id, t.token, p.country_code
+    FROM passengers p
+    JOIN tokens t ON p.id = t.passengerID
+    WHERE p.id NOT IN (
+        SELECT passenger_id FROM rides WHERE DATE(created_at) = CURDATE()
+    )
+    LIMIT 1000
+";
+// ملاحظة: في بيئة الإنتاج، استخدم جدول فتح التطبيق (App Opens) للحصول على دقة أعلى للركاب الذين فتحوا التطبيق مؤخراً.
+
+$stmtIdle = $con->query($sqlIdle);
+$idlePassengers = $stmtIdle->fetchAll(PDO::FETCH_ASSOC);
+
+if (empty($idlePassengers)) {
+    echo "No idle passengers found at this moment.\n";
+    exit;
+}
+
+// تجميع الركاب حسب الدولة لتقليل استدعاءات Gemini
+$passengersByCountry = [];
+foreach ($idlePassengers as $p) {
+    $country = strtoupper($p['country_code'] ?? 'SY');
+    $passengersByCountry[$country][] = $p;
+}
+
+$geminiService = new SiroGeminiService();
+$encryptionHelper = new EncryptionHelper();
+
+$totalPushes = 0;
+
+foreach ($passengersByCountry as $countryCode => $passengers) {
+    echo "Processing country: $countryCode (" . count($passengers) . " idle passengers)\n";
+    
+    // 2. سحب أحدث أسعار المنافسين كمرجع لجيميناي
+    $sqlPrices = "SELECT competitor_name, base_fare, price_per_km, price_per_min 
+                  FROM competitor_secret_formulas 
+                  WHERE country_code = :country 
+                  ORDER BY last_updated DESC LIMIT 3";
+    $stmtPrices = $con->prepare($sqlPrices);
+    $stmtPrices->execute([':country' => $countryCode]);
+    $competitorFormulas = $stmtPrices->fetchAll(PDO::FETCH_ASSOC);
+    
+    if (empty($competitorFormulas)) {
+        // Fallback
+        $competitorFormulas = [['competitor_name' => 'Market Average', 'base_fare' => 1]];
+    }
+
+    // 3. طلب رسالة تسويقية من Gemini
+    $siroBasePrice = 1.0; // يمكن استخراج السعر الافتراضي لسيرو من جدول kazan
+    $regionName = ($countryCode === 'JO') ? 'Amman' : 'Damascus';
+    
+    $aiCampaign = $geminiService->analyzeMarketAndDraftCampaign(
+        $competitorFormulas,
+        $siroBasePrice,
+        $regionName,
+        $countryCode
+    );
+
+    if (!$aiCampaign || $aiCampaign['opportunity_detected'] !== true) {
+        echo " -> Gemini found no compelling marketing opportunity for $countryCode right now. Skipping push.\n";
+        continue;
+    }
+
+    $title = $aiCampaign['push_title'] ?? 'خصم حصري من سيرو!';
+    $body = $aiCampaign['push_body'] ?? 'سيارتك جاهزة وبأرخص سعر في السوق. اطلب الآن.';
+    $promoCode = $aiCampaign['promo_code'] ?? '';
+
+    echo " -> Gemini generated campaign: [$title] $body\n";
+
+    // 4. إرسال الـ Push Notification لكل راكب
+    foreach ($passengers as $p) {
+        $encryptedToken = $p['token'];
+        $decryptedToken = $encryptionHelper->decryptData($encryptedToken);
+        
+        if ($decryptedToken) {
+            $dataPayload = [
+                'type' => 'marketing_promo',
+                'promo_code' => $promoCode
+            ];
+            
+            // استدعاء دالة الإرسال (يفترض وجودها في نظام FCM الخاص بك، مثل sendFCM)
+            // sendFCM($decryptedToken, $title, $body, $dataPayload);
+            // سنطبع للـ Log فقط في هذا السكربت لتجنب إرسال رسائل حقيقية دون تفعيل FCM الفعلي
+            
+            error_log("Sending Push to passenger {$p['passenger_id']}: $title");
+            $totalPushes++;
+        }
+    }
+}
+
+echo "Done. Sent $totalPushes automated marketing pushes via Gemini AI.\n";
+?>

backend/bot/cron_gemini_advisor.php

@@ -0,0 +1,57 @@
+<?php
+/**
+ * cron_gemini_advisor.php
+ * يعمل هذا الملف كـ Cron Job (يفضل أسبوعياً أو كل 3 أيام) 
+ * وظيفته: أخذ معادلات المنافسين المكتشفة، وإرسالها إلى جيميناي لاستخراج تقرير تسويقي متقدم
+ * ثم حفظ التقرير في قاعدة البيانات ليراه مدير النظام في لوحة الإدارة.
+ */
+
+require_once __DIR__ . '/../core/bootstrap.php';
+require_once __DIR__ . '/../core/Services/SiroGeminiService.php';
+require_once __DIR__ . '/../functions.php';
+
+try {
+    $con = Database::get('main');
+} catch (Exception $e) {
+    die("Database connection failed: " . $e->getMessage() . "\n");
+}
+
+echo "Starting Gemini Market Advisor Engine...\n";
+
+// 1. إنشاء جدول الإحصائيات الذكية إذا لم يكن موجوداً
+$sqlInit = "
+CREATE TABLE IF NOT EXISTS `gemini_market_insights` (
+  `id` INT AUTO_INCREMENT PRIMARY KEY,
+  `insight_html` TEXT NOT NULL,
+  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
+";
+$con->exec($sqlInit);
+
+// 2. سحب آخر المعادلات المكتشفة
+$stmt = $con->query("SELECT * FROM competitor_secret_formulas");
+$formulas = $stmt->fetchAll(PDO::FETCH_ASSOC);
+
+if (empty($formulas)) {
+    echo "No formulas found to analyze. Run ai_formula_solver.php first.\n";
+    exit;
+}
+
+// 3. تمرير البيانات إلى Gemini
+$geminiService = new SiroGeminiService();
+echo "Sending data to Gemini AI for strategic analysis...\n";
+
+$result = $geminiService->analyzeCompetitorFormulas($formulas);
+
+if ($result && $result['status'] === 'success') {
+    $htmlReport = $result['html_report'];
+    
+    // 4. حفظ التقرير في قاعدة البيانات
+    $stmtInsert = $con->prepare("INSERT INTO gemini_market_insights (insight_html) VALUES (:html)");
+    $stmtInsert->execute([':html' => $htmlReport]);
+    
+    echo "Gemini analysis saved successfully! Admin can now view the strategic report.\n";
+} else {
+    echo "Failed to get analysis from Gemini. Check API keys and logs.\n";
+}
+?>

backend/core/Services/SiroGeminiService.php

@@ -66,9 +66,9 @@ class SiroGeminiService {
           \"recommended_price\": 12000,
           \"discount_percentage\": 15,
           \"promo_code\": \"SIROGO15\",
-          \"push_title\": \"عنوان الإشعار\",
+          \"push_title\": \"عنوان الإشعار (بحد أقصى 5 كلمات)\",
-          \"push_body\": \"محتوى الإشعار القصير والمثير للاهتمام\",
+          \"push_body\": \"محتوى الإشعار القصير والمثير للاهتمام (بحد أقصى 15 كلمة)\",
-          \"sms_body\": \"محتوى رسالة الاستعادة القصير والمقنع للـ SMS أو الواتساب\"
+          \"sms_body\": \"محتوى رسالة الاستعادة (بحد أقصى 20 كلمة)\"
         }
         ";
 
@@ -124,6 +124,74 @@ class SiroGeminiService {
         return $this->callGemini($prompt, $model);
     }
 
+    /**
+     * تقرأ معادلات المنافسين المكتشفة أسبوعياً وتقدم استراتيجية تسويق (Weekly Advisor).
+     *
+     * @param array $formulas المصفوفة المستخرجة من competitor_secret_formulas
+     * @param string $model
+     * @return array|null
+     */
+    public function analyzeCompetitorFormulas(
+        array $formulas,
+        string $model = 'gemini-1.5-flash'
+    ): ?array {
+        if (!$this->apiKey) return null;
+
+        $formulasJson = json_encode($formulas, JSON_UNESCAPED_UNICODE);
+
+        $prompt = "
+        أنت المستشار التسويقي المالي لتطبيق 'سيرو' لنقل الركاب. 
+        لقد قمنا بعمل هندسة عكسية لرحلات منافسينا واكتشفنا معادلات التسعير السرية الخاصة بهم لهذا الأسبوع.
+        
+        البيانات المكتشفة:
+        $formulasJson
+        
+        المطلوب منك (كمستشار أعمال خبير):
+        1. تحليل هذه الأرقام، وتوضيح أين تكمن نقاط قوة المنافسين وأين نقاط ضعفهم في التسعير (مثلاً من يركز على المسافات القصيرة برفع فتح العداد؟).
+        2. اقتراح 3 استراتيجيات تسويقية أو رسائل إعلانية (Push Notifications/Social Media) موجهة للركاب، تستغل نقاط ضعف المنافسين المكتشفة.
+        
+        قم بصياغة تقريرك بتنسيق HTML مرتب وجاهز للعرض في لوحة الإدارة (بدون علامات ```html)، واستخدم ألوان خفيفة في العناوين <h3>. 
+        تحدث بلغة عربية احترافية ومباشرة لصناع القرار.
+        ";
+
+        // بما أن الإخراج سيكون نص HTML، سنستخدم API جيميناي العادي بدون تقييد JSON
+        $url = $this->baseUrl . "{$model}:generateContent?key={$this->apiKey}";
+        
+        $postData = [
+            'contents' => [
+                [
+                    'parts' => [
+                        ['text' => $prompt]
+                    ]
+                ]
+            ],
+            'generationConfig' => [
+                'temperature' => 0.7,
+                'maxOutputTokens' => 2000
+            ]
+        ];
+
+        $ch = curl_init($url);
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
+        curl_setopt($ch, CURLOPT_POST, true);
+        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($postData));
+        curl_setopt($ch, CURLOPT_TIMEOUT, 60);
+        
+        $response = curl_exec($ch);
+        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+        curl_close($ch);
+
+        if ($httpCode === 200) {
+            $data = json_decode($response, true);
+            $text = $data['candidates'][0]['content']['parts'][0]['text'] ?? '';
+            return ['status' => 'success', 'html_report' => $text];
+        } else {
+            error_log(\"[SiroGeminiService] HTTP $httpCode in analyzeCompetitorFormulas: $response\");
+            return null;
+        }
+    }
+
     /**
      * Helper: يُرسل prompt لـ Gemini ويُعيد JSON مُفكَّك
      */