selected outlet

2026-05-12 17:09:50 +07:00
parent 3541fc725c
commit ba2f0cd265
17 changed files with 1034 additions and 211 deletions
@@ -5,36 +5,43 @@ import 'package:injectable/injectable.dart';

 import '../../../domain/analytic/analytic.dart';
 import '../../../domain/analytic/repositories/i_analytic_repository.dart';
-import '../../../domain/user/user.dart';
 import '../../auth/datasources/local_data_provider.dart';
+import '../../outlet/datasource/local_data_provider.dart';
 import '../datasource/remote_data_provider.dart';

@Injectable(as: IAnalyticRepository)
 class AnalyticRepository implements IAnalyticRepository {
  final AnalyticRemoteDataProvider _dataProvider;
  final AuthLocalDataProvider _authLocalDataProvider;
+  final OutletLocalDataProvider _outletLocalDataProvider;
  final String _logName = 'AnalyticRepository';

-  AnalyticRepository(this._dataProvider, this._authLocalDataProvider);
+  AnalyticRepository(
+    this._dataProvider,
+    this._authLocalDataProvider,
+    this._outletLocalDataProvider,
+  );
+
+  /// Resolves outlet_id: pakai param jika ada, fallback ke shared pref
+  String? _resolveOutletId(String? outletId) {
+    return outletId ?? _outletLocalDataProvider.getSelectedOutletId();
+  }

  @override
  Future<Either<AnalyticFailure, SalesAnalytic>> getSales({
    required DateTime dateFrom,
    required DateTime dateTo,
+    String? outletId,
  }) async {
    try {
      final result = await _dataProvider.fetchSales(
        dateFrom: dateFrom,
        dateTo: dateTo,
+        outletId: _resolveOutletId(outletId),
      );

-      if (result.hasError) {
-        return left(result.error!);
-      }
-
-      final auth = result.data!.toDomain();
-
-      return right(auth);
+      if (result.hasError) return left(result.error!);
+      return right(result.data!.toDomain());
    } catch (e, s) {
      log('getSalesError', name: _logName, error: e, stackTrace: s);
      return left(const AnalyticFailure.unexpectedError());
@@ -45,20 +52,17 @@ class AnalyticRepository implements IAnalyticRepository {
  Future<Either<AnalyticFailure, ProfitLossAnalytic>> getProfitLoss({
    required DateTime dateFrom,
    required DateTime dateTo,
+    String? outletId,
  }) async {
    try {
      final result = await _dataProvider.fetchProfitLoss(
        dateFrom: dateFrom,
        dateTo: dateTo,
+        outletId: _resolveOutletId(outletId),
      );

-      if (result.hasError) {
-        return left(result.error!);
-      }
-
-      final auth = result.data!.toDomain();
-
-      return right(auth);
+      if (result.hasError) return left(result.error!);
+      return right(result.data!.toDomain());
    } catch (e, s) {
      log('getProfitLossError', name: _logName, error: e, stackTrace: s);
      return left(const AnalyticFailure.unexpectedError());
@@ -69,20 +73,17 @@ class AnalyticRepository implements IAnalyticRepository {
  Future<Either<AnalyticFailure, CategoryAnalytic>> getCategory({
    required DateTime dateFrom,
    required DateTime dateTo,
+    String? outletId,
  }) async {
    try {
      final result = await _dataProvider.fetchCategory(
        dateFrom: dateFrom,
        dateTo: dateTo,
+        outletId: _resolveOutletId(outletId),
      );

-      if (result.hasError) {
-        return left(result.error!);
-      }
-
-      final auth = result.data!.toDomain();
-
-      return right(auth);
+      if (result.hasError) return left(result.error!);
+      return right(result.data!.toDomain());
    } catch (e, s) {
      log('getCategoryError', name: _logName, error: e, stackTrace: s);
      return left(const AnalyticFailure.unexpectedError());
@@ -93,23 +94,20 @@ class AnalyticRepository implements IAnalyticRepository {
  Future<Either<AnalyticFailure, InventoryAnalytic>> getInventory({
    required DateTime dateFrom,
    required DateTime dateTo,
+    String? outletId,
  }) async {
    try {
-      User currentUser = await _authLocalDataProvider.currentUser();
+      final currentUser = await _authLocalDataProvider.currentUser();
+      final resolvedId = _resolveOutletId(outletId) ?? currentUser.outletId;

      final result = await _dataProvider.fetchInventory(
-        outletId: currentUser.outletId,
+        outletId: resolvedId,
        dateFrom: dateFrom,
        dateTo: dateTo,
      );

-      if (result.hasError) {
-        return left(result.error!);
-      }
-
-      final auth = result.data!.toDomain();
-
-      return right(auth);
+      if (result.hasError) return left(result.error!);
+      return right(result.data!.toDomain());
    } catch (e, s) {
      log('getInventoryError', name: _logName, error: e, stackTrace: s);
      return left(const AnalyticFailure.unexpectedError());
@@ -120,23 +118,17 @@ class AnalyticRepository implements IAnalyticRepository {
  Future<Either<AnalyticFailure, DashboardAnalytic>> getDashboard({
    required DateTime dateFrom,
    required DateTime dateTo,
+    String? outletId,
  }) async {
    try {
-      User currentUser = await _authLocalDataProvider.currentUser();
-
      final result = await _dataProvider.fetchDashboard(
-        outletId: currentUser.outletId,
        dateFrom: dateFrom,
        dateTo: dateTo,
+        outletId: _resolveOutletId(outletId),
      );

-      if (result.hasError) {
-        return left(result.error!);
-      }
-
-      final auth = result.data!.toDomain();
-
-      return right(auth);
+      if (result.hasError) return left(result.error!);
+      return right(result.data!.toDomain());
    } catch (e, s) {
      log('getDashboardError', name: _logName, error: e, stackTrace: s);
      return left(const AnalyticFailure.unexpectedError());
@@ -147,23 +139,17 @@ class AnalyticRepository implements IAnalyticRepository {
  Future<Either<AnalyticFailure, ProductAnalytic>> getProduct({
    required DateTime dateFrom,
    required DateTime dateTo,
+    String? outletId,
  }) async {
    try {
-      User currentUser = await _authLocalDataProvider.currentUser();
-
      final result = await _dataProvider.fetchProduct(
-        outletId: currentUser.outletId,
        dateFrom: dateFrom,
        dateTo: dateTo,
+        outletId: _resolveOutletId(outletId),
      );

-      if (result.hasError) {
-        return left(result.error!);
-      }
-
-      final auth = result.data!.toDomain();
-
-      return right(auth);
+      if (result.hasError) return left(result.error!);
+      return right(result.data!.toDomain());
    } catch (e, s) {
      log('getProductError', name: _logName, error: e, stackTrace: s);
      return left(const AnalyticFailure.unexpectedError());
@@ -174,23 +160,17 @@ class AnalyticRepository implements IAnalyticRepository {
  Future<Either<AnalyticFailure, PaymentMethodAnalytic>> getPaymentMethod({
    required DateTime dateFrom,
    required DateTime dateTo,
+    String? outletId,
  }) async {
    try {
-      User currentUser = await _authLocalDataProvider.currentUser();
-
      final result = await _dataProvider.fetchPaymentMethod(
-        outletId: currentUser.outletId,
        dateFrom: dateFrom,
        dateTo: dateTo,
+        outletId: _resolveOutletId(outletId),
      );

-      if (result.hasError) {
-        return left(result.error!);
-      }
-
-      final auth = result.data!.toDomain();
-
-      return right(auth);
+      if (result.hasError) return left(result.error!);
+      return right(result.data!.toDomain());
    } catch (e, s) {
      log('getPaymentMethodError', name: _logName, error: e, stackTrace: s);
      return left(const AnalyticFailure.unexpectedError());