Food: background location + native delivery overlay

siro_driver/lib/controller/food_delivery/food_delivery_controller.dart

@@ -7,6 +7,7 @@
 //   3) active.php — مصدر الحقيقة لحالة المهام، يُصحّح أي فارق بعد أي انقطاع.
 import 'dart:async';
 
+import 'package:flutter_background_service/flutter_background_service.dart';
 import 'package:get/get.dart';
 import 'package:just_audio/just_audio.dart';
 
@@ -16,11 +17,12 @@ import '../../main.dart';
 import '../../print.dart';
 import '../../views/food_delivery/food_offer_page.dart';
 import '../../views/widgets/error_snakbar.dart';
-import '../functions/location_controller.dart';
 import '../voice_call_controller.dart';
 import 'food_delivery_models.dart';
 import 'food_delivery_service.dart';
+import 'food_location_broadcaster.dart';
 import 'food_notification_service.dart';
+import 'food_overlay_bridge.dart';
 import 'food_socket_service.dart';
 
 class FoodDeliveryController extends GetxController {
@@ -70,6 +72,7 @@ class FoodDeliveryController extends GetxController {
 
     final s = res.data!;
     isDeliveryModeEnabled = s.deliveryModeEnabled;
+    box.write(BoxName.foodDeliveryModeEnabled, s.deliveryModeEnabled);
     todayOrdersCount = s.todayOrdersCount;
     todayEarnings = s.todayEarnings;
 
@@ -92,6 +95,11 @@ class FoodDeliveryController extends GetxController {
 
     if (res.success) {
       isDeliveryModeEnabled = enable;
+      // العزلة الخلفية تقرأ هذا المفتاح لتقرر فتح سوكيت الطعام أو إغلاقه،
+      // فيصل العرض حتى والتطبيق مغلق
+      box.write(BoxName.foodDeliveryModeEnabled, enable);
+      FlutterBackgroundService().invoke('foodModeChanged', {'enabled': enable});
+
       if (enable) {
         await FoodSocketService.instance.connect();
       } else {
@@ -193,8 +201,17 @@ class FoodDeliveryController extends GetxController {
     final isForeground = box.read(BoxName.isAppInForeground) ?? false;
     if (isForeground == true) {
       _openOfferScreen();
-    } else {
-      // التطبيق في الخلفية — إشعار ملء شاشة بقناة التوصيل الخاصة
+      return;
+    }
+
+    // التطبيق في الخلفية: النافذة العائمة أولاً (أندرويد)، وإن تعذّرت —
+    // صلاحية ناقصة أو iOS — يبقى الإشعار ملء الشاشة هو المسار البديل.
+    _showBackgroundOffer(offer);
+  }
+
+  Future<void> _showBackgroundOffer(FoodDeliveryOffer offer) async {
+    final shown = await FoodOverlayBridge.show(offer);
+    if (!shown) {
       FoodNotificationService.instance.showOfferNotification(offer);
     }
   }
@@ -236,26 +253,6 @@ class FoodDeliveryController extends GetxController {
       await _fetchPendingOffers();
     }
     await fetchActiveTasks(silent: true);
-    await _broadcastLocation();
-  }
-
-  // موقع السائق يُبثّ فقط ما دامت هناك مهمة نشطة — لا شيء يُرسل قبل الإسناد
-  // ولا بعد التسليم، والخادم يرفضه في الحالتين أصلاً كطبقة ثانية.
-  Future<void> _broadcastLocation() async {
-    if (activeTasks.isEmpty) return;
-    if (!Get.isRegistered<LocationController>()) return;
-
-    final loc = Get.find<LocationController>();
-    if (loc.myLocation.latitude == 0 && loc.myLocation.longitude == 0) return;
-
-    for (final task in activeTasks) {
-      await FoodDeliveryService.sendLocation(
-        orderId: task.id,
-        lat: loc.myLocation.latitude,
-        lng: loc.myLocation.longitude,
-        heading: loc.heading,
-      );
-    }
   }
 
   Future<void> _fetchPendingOffers() async {
@@ -274,6 +271,10 @@ class FoodDeliveryController extends GetxController {
     final res = await FoodDeliveryService.getActiveTasks();
     isLoadingTasks = false;
     if (res.success) activeTasks = res.data ?? [];
+
+    // البثّ نفسه يجري في LocationController (المصدر الوحيد للموقع) — نكتفي
+    // هنا بتسجيل المهام النشطة كي يستمر البثّ بعد إغلاق هذه الشاشة.
+    FoodLocationBroadcaster.setActiveOrders(activeTasks.map((t) => t.id).toList());
     _syncRideAvailability();
     update();
   }
@@ -323,6 +324,7 @@ class FoodDeliveryController extends GetxController {
     _respondingOfferIds.remove(orderId);
     pendingOffers.removeWhere((o) => o.orderId == orderId);
     FoodNotificationService.instance.cancelOfferNotification();
+    FoodOverlayBridge.hide();
 
     if (!res.success) {
       mySnackbarWarning(res.message);

siro_driver/lib/controller/food_delivery/food_location_broadcaster.dart

@@ -0,0 +1,79 @@
+// food_location_broadcaster.dart — بثّ موقع السائق للزبون أثناء التوصيل
+//
+// لماذا هنا ولا في الخدمة الخلفية (background_service.dart):
+// قاعدة معمارية مثبّتة في المشروع تمنع أي تدفّق GPS ثانٍ في العزلة الخلفية —
+// `LocationController` هو المصدر الوحيد، وهو يبقى حياً في الخلفية أصلاً عبر
+// enableBackgroundMode. فتح تدفّق ثانٍ هناك يعني مستمعَي GPS متوازيين واستنزاف
+// بطارية وتجميد أجهزة (موثّق في driver_lifecycle.md). فالبثّ يركب على النبضة
+// القائمة في LocationController بدل إنشاء مصدر جديد — وهو ما يجعله يستمر بعد
+// إغلاق شاشة التوصيل، وهو المطلوب فعلاً.
+//
+// المهام النشطة تُحفظ في التخزين المحلي، فلا يحتاج هذا الملف كنترولر التوصيل
+// ولا يموت بموته.
+import 'dart:convert';
+
+import '../../constant/box_name.dart';
+import '../../main.dart';
+import '../../print.dart';
+import 'food_delivery_service.dart';
+
+class FoodLocationBroadcaster {
+  FoodLocationBroadcaster._();
+
+  static const Duration _minInterval = Duration(seconds: 7);
+  static DateTime? _lastSentAt;
+  static bool _inFlight = false;
+
+  /// تُخزَّن من كنترولر التوصيل عند كل تحديث للمهام
+  static void setActiveOrders(List<int> orderIds) {
+    box.write(BoxName.foodActiveOrders, jsonEncode(orderIds));
+  }
+
+  static List<int> get activeOrders {
+    try {
+      final raw = box.read(BoxName.foodActiveOrders);
+      if (raw == null) return const [];
+      return (jsonDecode(raw.toString()) as List)
+          .map((e) => int.tryParse(e.toString()) ?? 0)
+          .where((e) => e != 0)
+          .toList();
+    } catch (_) {
+      return const [];
+    }
+  }
+
+  static void clear() => box.remove(BoxName.foodActiveOrders);
+
+  /// يُنادى من LocationController على كل تحديث موقع — يخرج فوراً إن لم تكن
+  /// هناك مهمة توصيل، فلا يكلّف شيئاً في الحالة الغالبة.
+  static Future<void> maybeSend({
+    required double lat,
+    required double lng,
+    double? heading,
+  }) async {
+    final orders = activeOrders;
+    if (orders.isEmpty) return;
+    if (lat == 0 && lng == 0) return;
+    if (_inFlight) return;
+
+    final now = DateTime.now();
+    if (_lastSentAt != null && now.difference(_lastSentAt!) < _minInterval) return;
+    _lastSentAt = now;
+
+    _inFlight = true;
+    try {
+      for (final orderId in orders) {
+        await FoodDeliveryService.sendLocation(
+          orderId: orderId,
+          lat: lat,
+          lng: lng,
+          heading: heading,
+        );
+      }
+    } catch (e) {
+      Log.print('🍔 [FoodLocation] تعذّر بثّ الموقع: $e');
+    } finally {
+      _inFlight = false;
+    }
+  }
+}

siro_driver/lib/controller/food_delivery/food_overlay_bridge.dart

@@ -0,0 +1,92 @@
+// food_overlay_bridge.dart — نافذة عرض التوصيل العائمة (أندرويد) ونتيجتها
+//
+// لماذا جسر مستقل عن كنترولر التوصيل:
+// العرض قد يصل والتطبيق في الخلفية وشاشة التوصيل مغلقة — بل وقد يصل من العزلة
+// الخلفية حيث لا وجود لأي كنترولر. فالاشتراك في نتيجة النافذة يجب أن يكون
+// عالمياً ويعيش طوال عمر التطبيق، ويردّ على الخادم بنفسه بلا انتظار شاشة.
+import 'dart:async';
+
+import 'package:get/get.dart';
+import 'package:trip_overlay_plugin/trip_overlay_plugin.dart';
+
+import '../../print.dart';
+import '../../views/food_delivery/food_task_details_page.dart';
+import '../../views/widgets/error_snakbar.dart';
+import 'food_delivery_models.dart';
+import 'food_delivery_service.dart';
+
+class FoodOverlayBridge {
+  FoodOverlayBridge._();
+
+  static StreamSubscription<String>? _acceptSub;
+  static StreamSubscription<String>? _rejectSub;
+
+  /// تُنادى مرة واحدة عند إقلاع التطبيق
+  static void attach() {
+    if (!TripOverlayPlugin.isSupported) return; // أندرويد فقط
+    if (_acceptSub != null) return;
+
+    TripOverlayPlugin.initialize();
+
+    _acceptSub = TripOverlayPlugin.onFoodOrderAccepted.listen(_onAccepted);
+    _rejectSub = TripOverlayPlugin.onFoodOrderRejected.listen(_onRejected);
+    Log.print('🍔 [FoodOverlay] جاهز لاستقبال نتائج النافذة العائمة');
+  }
+
+  static Future<void> _onAccepted(String orderIdRaw) async {
+    final orderId = int.tryParse(orderIdRaw) ?? 0;
+    if (orderId == 0) return;
+
+    Log.print('🍔 [FoodOverlay] قبول من النافذة — طلب #$orderId');
+
+    // القبول يتم هنا لا في الشاشة: النافذة تُغلق فوراً والخادم لا ينتظر
+    // فتح واجهة. لو تأخّرنا حتى تُبنى الشاشة قد تنتهي مهلة العرض.
+    final res = await FoodDeliveryService.respondToOffer(orderId, true);
+
+    if (res.success) {
+      mySnackbarSuccess('تم قبول طلب التوصيل');
+      Get.to(() => FoodTaskDetailsPage(orderId: orderId));
+    } else {
+      mySnackbarWarning(res.message);
+    }
+  }
+
+  static Future<void> _onRejected(String orderIdRaw) async {
+    final orderId = int.tryParse(orderIdRaw) ?? 0;
+    if (orderId == 0) return;
+
+    // الرفض الصريح يُبلَّغ الخادم ليعرض الطلب على سائق آخر فوراً بدل انتظار
+    // انتهاء المهلة. انتهاء المهلة يصل بنفس الحدث، والخادم يتعامل مع الحالتين
+    // بأمان (يرفض إن لم يعد العرض قائماً).
+    Log.print('🍔 [FoodOverlay] رفض/انتهاء مهلة — طلب #$orderId');
+    await FoodDeliveryService.respondToOffer(orderId, false);
+  }
+
+  /// عرض النافذة لعرض توصيل وارد — تُنادى حين يكون التطبيق في الخلفية
+  static Future<bool> show(FoodDeliveryOffer offer, {String? distanceText}) {
+    return TripOverlayPlugin.showFoodOverlay(
+      FoodOrderOverlayData(
+        orderId: offer.orderId.toString(),
+        merchantName: offer.merchantNameAr,
+        merchantAddress: offer.merchantAddress ?? '',
+        // التنسيق يتم هنا لا في Kotlin — العملة والوحدة الصغرى منطق تطبيق
+        deliveryFeeText: foodFormatPrice(offer.deliveryFee),
+        cashToCollectText:
+            offer.cashToCollect > 0 ? foodFormatPrice(offer.cashToCollect) : '',
+        distanceText: distanceText ?? '',
+        itemsCount: offer.itemsCount,
+        isCash: offer.isCash,
+      ),
+      autoCloseSeconds: offer.secondsRemaining.clamp(5, 20),
+    );
+  }
+
+  static Future<void> hide() => TripOverlayPlugin.hideOverlay();
+
+  static void detach() {
+    _acceptSub?.cancel();
+    _rejectSub?.cancel();
+    _acceptSub = null;
+    _rejectSub = null;
+  }
+}

siro_driver/lib/controller/functions/background_service.dart

@@ -11,6 +11,7 @@ import 'package:flutter_overlay_window/flutter_overlay_window.dart' as Overlay;
 import 'package:get_storage/get_storage.dart';
 import '../../constant/box_name.dart';
 import '../../constant/links.dart';
+import 'package:trip_overlay_plugin/trip_overlay_plugin.dart';
 import '../firebase/local_notification.dart';
 
 const String notificationChannelId = 'driver_service_channel';
@@ -138,9 +139,115 @@ Future<bool> onStart(ServiceInstance service) async {
     });
   }
 
+
+  // ══════════════════════════════════════════════════════════════════════
+  // سوكيت الطعام في العزلة الخلفية — مستقل تماماً عن سوكيت الرحلات أعلاه
+  // (خادم وبورت وغرفة مختلفة). بدونه لا يصل عرض توصيل والتطبيق مغلق، لأن
+  // FoodSocketService يعيش في العزلة الرئيسية التي يوقفها أندرويد.
+  // نفتحه فقط إن كان وضع التوصيل مفعّلاً — لا اتصال دائم بلا داعٍ.
+  // ══════════════════════════════════════════════════════════════════════
+  IO.Socket? foodSocket;
+
+  void connectFoodSocket() {
+    if (foodSocket != null || driverId.isEmpty) return;
+
+    foodSocket = IO.io(
+        AppLink.foodSocketUrl,
+        IO.OptionBuilder()
+            .setTransports(['websocket'])
+            .setQuery({
+              'role': 'driver',
+              'id': driverId,
+              'jwt': token,
+              'platform': Platform.isIOS ? 'ios' : 'android',
+            })
+            .enableReconnection()
+            .setReconnectionDelay(3000)
+            .build());
+
+    foodSocket!.onConnect((_) => print('🍔 Background: food socket connected'));
+
+    foodSocket!.on('food_delivery_offer', (data) async {
+      print('🍔 Background: food delivery offer received');
+      await GetStorage.init();
+      final box = GetStorage();
+
+      // الواجهة أمام السائق تتكفّل بالعرض إن كان التطبيق مفتوحاً
+      final bool isAppInForeground = box.read(BoxName.isAppInForeground) ?? false;
+      if (isAppInForeground) return;
+
+      Map<String, dynamic>? payload;
+      if (data is Map) {
+        payload = Map<String, dynamic>.from(data);
+      } else if (data is List && data.isNotEmpty && data.first is Map) {
+        payload = Map<String, dynamic>.from(data.first as Map);
+      }
+      if (payload == null) return;
+
+      if (Platform.isAndroid) {
+        final shown = await TripOverlayPlugin.showFoodOverlay(
+          FoodOrderOverlayData(
+            orderId: payload['order_id'].toString(),
+            merchantName: payload['merchant_name_ar']?.toString() ?? 'مطعم',
+            merchantAddress: payload['merchant_address']?.toString() ?? '',
+            deliveryFeeText: _formatFoodPrice(payload['delivery_fee']),
+            cashToCollectText: _formatFoodPrice(payload['cash_to_collect']),
+            distanceText: '',
+            itemsCount: int.tryParse(payload['items_count']?.toString() ?? '') ?? 0,
+            isCash: payload['payment_method']?.toString() == 'cash',
+          ),
+          autoCloseSeconds: 20,
+        );
+        if (shown) return;
+      }
+
+      // iOS أو تعذّرت النافذة — إشعار على قناة التوصيل الخاصة
+      flutterLocalNotificationsPlugin.show(
+        id: 7001,
+        title: '🍔 عرض توصيل جديد',
+        body: '${payload['merchant_name_ar'] ?? 'مطعم'} — '
+            '${_formatFoodPrice(payload['delivery_fee'])}',
+        notificationDetails: const NotificationDetails(
+          android: AndroidNotificationDetails(
+            'food_delivery_offer_channel',
+            'عروض التوصيل',
+            importance: Importance.max,
+            priority: Priority.max,
+            fullScreenIntent: true,
+            category: AndroidNotificationCategory.call,
+          ),
+          iOS: DarwinNotificationDetails(
+            presentAlert: true,
+            presentBadge: true,
+            presentSound: true,
+          ),
+        ),
+        payload: jsonEncode({'food_event': 'offer', 'order_id': payload['order_id']}),
+      );
+    });
+  }
+
+  if (box.read(BoxName.foodDeliveryModeEnabled) == true) {
+    connectFoodSocket();
+  }
+
+  // تفعيل/إطفاء وضع التوصيل من الواجهة ينعكس هنا بلا إعادة تشغيل الخدمة
+  service.on('foodModeChanged').listen((event) {
+    final enabled = event?['enabled'] == true;
+    if (enabled) {
+      connectFoodSocket();
+    } else {
+      foodSocket?.clearListeners();
+      foodSocket?.dispose();
+      foodSocket = null;
+    }
+  });
+
   service.on('stopService').listen((event) {
     socket?.clearListeners();
     socket?.dispose();
+    foodSocket?.clearListeners();
+    foodSocket?.dispose();
     service.stopSelf();
   });
 
@@ -185,6 +292,14 @@ Future<bool> onStart(ServiceInstance service) async {
   return true;
 }
 
+// نفس قاعدة foodFormatPrice في نماذج الطعام — مكرّرة هنا عمداً لأن العزلة
+// الخلفية يجب أن تبقى خفيفة الاعتماديات ولا تسحب طبقة النماذج كاملة.
+String _formatFoodPrice(dynamic smallestUnit) {
+  final v = int.tryParse(smallestUnit?.toString() ?? '') ?? 0;
+  if (v == 0) return '';
+  return '${(v / 1000).toStringAsFixed(3)} د.أ';
+}
+
 class BackgroundServiceHelper {
   static Future<void> initialize() async {
     final service = FlutterBackgroundService();

siro_driver/lib/controller/functions/location_controller.dart

@@ -25,6 +25,7 @@ import '../home/navigation/navigation_controller.dart';
 import 'background_service.dart';
 import 'crud.dart';
 import '../transit/transit_driver_controller.dart';
+import '../food_delivery/food_location_broadcaster.dart';
 
 /// إعدادات تتبّع الموقع لحالة معيّنة من حالات السائق.
 /// الهدف: عدم تشغيل الـ GPS بأقصى طاقته إلا أثناء الرحلة الفعلية.
@@ -697,6 +698,15 @@ class LocationController extends GetxController with WidgetsBindingObserver {
         navCtrl.handleLocationUpdateFromCentral(pos, speed, heading);
       }
 
+      // بثّ الموقع للزبون أثناء مهمة توصيل — يركب على هذه النبضة بدل تدفّق
+      // GPS ثانٍ، فيستمر بعد إغلاق شاشة التوصيل ما دامت هذه الخدمة حية.
+      // يخرج فوراً إن لم تكن هناك مهمة نشطة.
+      FoodLocationBroadcaster.maybeSend(
+        lat: pos.latitude,
+        lng: pos.longitude,
+        heading: heading,
+      );
+
       await _saveBehaviorIfMoved(pos, now, currentSpeed: speed);
     }, onError: (e) => Log.print('❌ Location Stream Error: $e'));
   }