Update Saqel Platform: 2026-09-04 21:26:55

apps/super_admin_app/lib/logic/cubits/super_admin_cubit.dart

@@ -0,0 +1,44 @@
+import 'package:flutter_bloc/flutter_bloc.dart';
+import '../../data/repositories/super_admin_repository.dart';
+import 'super_admin_state.dart';
+
+/**
+ * ==============================================================================
+ * SAQEL SOVEREIGN COMMAND - SUPER ADMIN CUBIT
+ * ==============================================================================
+ * 
+ * إدارة حالة المؤشرات السيادية الكلية، والتحكم بالخوادم، ومفتاح الطوارئ (Kill-Switch).
+ */
+
+class SuperAdminCubit extends Cubit<SuperAdminState> {
+  final SuperAdminRepository repository;
+
+  SuperAdminCubit({required this.repository}) : super(SuperAdminInitial());
+
+  Future<void> loadDashboard() async {
+    emit(SuperAdminLoading());
+    try {
+      final telemetry = await repository.getMacroTelemetry();
+      final aiNodes = await repository.getAiClusterNodes();
+      final alerts = await repository.getSecurityAlerts();
+
+      emit(SuperAdminLoaded(
+        telemetry: telemetry,
+        aiNodes: aiNodes,
+        alerts: alerts,
+        isEmergencyKillSwitchActive: false,
+      ));
+    } catch (e) {
+      emit(SuperAdminError('فشل تحميل لوحة القيادة السيادية: $e'));
+    }
+  }
+
+  void toggleEmergencyKillSwitch() {
+    if (state is SuperAdminLoaded) {
+      final cur = state as SuperAdminLoaded;
+      emit(cur.copyWith(
+        isEmergencyKillSwitchActive: !cur.isEmergencyKillSwitchActive,
+      ));
+    }
+  }
+}

apps/super_admin_app/lib/logic/cubits/super_admin_state.dart

@@ -0,0 +1,42 @@
+import '../../data/models/super_admin_models.dart';
+
+abstract class SuperAdminState {
+  const SuperAdminState();
+}
+
+class SuperAdminInitial extends SuperAdminState {}
+
+class SuperAdminLoading extends SuperAdminState {}
+
+class SuperAdminLoaded extends SuperAdminState {
+  final MacroTelemetryModel telemetry;
+  final List<AiClusterNodeModel> aiNodes;
+  final List<SecurityIntegrityAlertModel> alerts;
+  final bool isEmergencyKillSwitchActive;
+
+  const SuperAdminLoaded({
+    required this.telemetry,
+    required this.aiNodes,
+    required this.alerts,
+    this.isEmergencyKillSwitchActive = false,
+  });
+
+  SuperAdminLoaded copyWith({
+    MacroTelemetryModel? telemetry,
+    List<AiClusterNodeModel>? aiNodes,
+    List<SecurityIntegrityAlertModel>? alerts,
+    bool? isEmergencyKillSwitchActive,
+  }) {
+    return SuperAdminLoaded(
+      telemetry: telemetry ?? this.telemetry,
+      aiNodes: aiNodes ?? this.aiNodes,
+      alerts: alerts ?? this.alerts,
+      isEmergencyKillSwitchActive: isEmergencyKillSwitchActive ?? this.isEmergencyKillSwitchActive,
+    );
+  }
+}
+
+class SuperAdminError extends SuperAdminState {
+  final String message;
+  const SuperAdminError(this.message);
+}

apps/super_admin_app/lib/logic/cubits/treasury_cubit.dart

@@ -0,0 +1,110 @@
+import 'package:flutter_bloc/flutter_bloc.dart';
+import '../../data/models/super_admin_models.dart';
+import '../../data/repositories/super_admin_repository.dart';
+
+abstract class TreasuryState {
+  const TreasuryState();
+}
+
+class TreasuryInitial extends TreasuryState {}
+
+class TreasuryLoading extends TreasuryState {}
+
+class TreasuryLoaded extends TreasuryState {
+  final List<PayoutQueueItemModel> queue;
+  final double totalTreasuryBalanceJod;
+  final double totalApprovedTodayJod;
+
+  const TreasuryLoaded({
+    required this.queue,
+    required this.totalTreasuryBalanceJod,
+    required this.totalApprovedTodayJod,
+  });
+
+  TreasuryLoaded copyWith({
+    List<PayoutQueueItemModel>? queue,
+    double? totalTreasuryBalanceJod,
+    double? totalApprovedTodayJod,
+  }) {
+    return TreasuryLoaded(
+      queue: queue ?? this.queue,
+      totalTreasuryBalanceJod: totalTreasuryBalanceJod ?? this.totalTreasuryBalanceJod,
+      totalApprovedTodayJod: totalApprovedTodayJod ?? this.totalApprovedTodayJod,
+    );
+  }
+}
+
+class TreasuryCubit extends Cubit<TreasuryState> {
+  final SuperAdminRepository repository;
+
+  TreasuryCubit({required this.repository}) : super(TreasuryInitial());
+
+  Future<void> loadTreasury() async {
+    emit(TreasuryLoading());
+    try {
+      final queue = await repository.getPayoutQueue();
+      emit(TreasuryLoaded(
+        queue: queue,
+        totalTreasuryBalanceJod: 54200.0,
+        totalApprovedTodayJod: 0.0,
+      ));
+    } catch (_) {
+      emit(const TreasuryLoaded(
+        queue: [],
+        totalTreasuryBalanceJod: 54200.0,
+        totalApprovedTodayJod: 0.0,
+      ));
+    }
+  }
+
+  void approvePayout(int payoutId) {
+    if (state is TreasuryLoaded) {
+      final cur = state as TreasuryLoaded;
+      double approvedAmt = 0.0;
+
+      final updated = cur.queue.map((item) {
+        if (item.id == payoutId) {
+          approvedAmt = item.amountJod;
+          return PayoutQueueItemModel(
+            id: item.id,
+            teacherName: item.teacherName,
+            cliqAlias: item.cliqAlias,
+            amountJod: item.amountJod,
+            requestedAt: item.requestedAt,
+            status: 'completed',
+          );
+        }
+        return item;
+      }).toList();
+
+      emit(cur.copyWith(
+        queue: updated,
+        totalApprovedTodayJod: cur.totalApprovedTodayJod + approvedAmt,
+      ));
+    }
+  }
+
+  void approveAllPayouts() {
+    if (state is TreasuryLoaded) {
+      final cur = state as TreasuryLoaded;
+      double sum = 0.0;
+
+      final updated = cur.queue.map((item) {
+        if (item.status == 'queued') sum += item.amountJod;
+        return PayoutQueueItemModel(
+          id: item.id,
+          teacherName: item.teacherName,
+          cliqAlias: item.cliqAlias,
+          amountJod: item.amountJod,
+          requestedAt: item.requestedAt,
+          status: 'completed',
+        );
+      }).toList();
+
+      emit(cur.copyWith(
+        queue: updated,
+        totalApprovedTodayJod: cur.totalApprovedTodayJod + sum,
+      ));
+    }
+  }
+}