Compare commits

...

2 Commits

Author SHA1 Message Date
efrilm
04811015b6 data sync overflow 2025-09-20 03:12:32 +07:00
efrilm
f104390141 sync product to local 2025-09-20 03:10:05 +07:00
21 changed files with 4617 additions and 514 deletions

View File

@ -0,0 +1,87 @@
import 'dart:async';
import 'package:sqflite/sqflite.dart';
import 'package:path/path.dart';
class DatabaseHelper {
static DatabaseHelper? _instance;
static Database? _database;
DatabaseHelper._internal();
static DatabaseHelper get instance {
_instance ??= DatabaseHelper._internal();
return _instance!;
}
Future<Database> get database async {
_database ??= await _initDatabase();
return _database!;
}
Future<Database> _initDatabase() async {
String path = join(await getDatabasesPath(), 'pos_database.db');
return await openDatabase(
path,
version: 1,
onCreate: _onCreate,
onUpgrade: _onUpgrade,
);
}
Future<void> _onCreate(Database db, int version) async {
// Products table
await db.execute('''
CREATE TABLE products (
id TEXT PRIMARY KEY,
organization_id TEXT,
category_id TEXT,
sku TEXT,
name TEXT,
description TEXT,
price INTEGER,
cost INTEGER,
business_type TEXT,
image_url TEXT,
printer_type TEXT,
metadata TEXT,
is_active INTEGER,
created_at TEXT,
updated_at TEXT
)
''');
// Product Variants table
await db.execute('''
CREATE TABLE product_variants (
id TEXT PRIMARY KEY,
product_id TEXT,
name TEXT,
price_modifier INTEGER,
cost INTEGER,
metadata TEXT,
created_at TEXT,
updated_at TEXT,
FOREIGN KEY (product_id) REFERENCES products (id) ON DELETE CASCADE
)
''');
// Create indexes for better performance
await db.execute(
'CREATE INDEX idx_products_category_id ON products(category_id)');
await db.execute('CREATE INDEX idx_products_name ON products(name)');
await db.execute('CREATE INDEX idx_products_sku ON products(sku)');
await db.execute(
'CREATE INDEX idx_products_description ON products(description)');
}
Future<void> _onUpgrade(Database db, int oldVersion, int newVersion) async {
// Handle database upgrades here
}
Future<void> close() async {
final db = await database;
await db.close();
_database = null;
}
}

View File

@ -0,0 +1,29 @@
import 'package:sqflite/sqflite.dart';
class DatabaseMigrationHandler {
static Future<void> migrate(
Database db, int oldVersion, int newVersion) async {
if (oldVersion < 2) {
// Add indexes for better performance
await db.execute(
'CREATE INDEX IF NOT EXISTS idx_products_name_search ON products(name)');
await db.execute(
'CREATE INDEX IF NOT EXISTS idx_products_sku_search ON products(sku)');
}
if (oldVersion < 3) {
// Add full text search support
await db.execute(
'CREATE VIRTUAL TABLE products_fts USING fts5(name, sku, description, content=products, content_rowid=rowid)');
await db.execute(
'INSERT INTO products_fts SELECT name, sku, description FROM products');
}
if (oldVersion < 4) {
// Add sync tracking
await db.execute('ALTER TABLE products ADD COLUMN last_sync_at TEXT');
await db.execute(
'ALTER TABLE products ADD COLUMN sync_version INTEGER DEFAULT 1');
}
}
}

View File

@ -0,0 +1,53 @@
import 'dart:developer';
import 'dart:io';
import 'package:sqflite/sqflite.dart';
class DatabaseErrorHandler {
static Future<T> executeWithRetry<T>(
Future<T> Function() operation, {
int maxRetries = 3,
Duration delay = const Duration(milliseconds: 500),
}) async {
int attempts = 0;
while (attempts < maxRetries) {
try {
return await operation();
} catch (e) {
attempts++;
if (attempts >= maxRetries) {
rethrow;
}
log('Database operation failed (attempt $attempts/$maxRetries): $e');
await Future.delayed(delay * attempts);
}
}
throw Exception('Max retries exceeded');
}
static bool isDatabaseCorrupted(dynamic error) {
final errorString = error.toString().toLowerCase();
return errorString.contains('corrupt') ||
errorString.contains('malformed') ||
errorString.contains('no such table');
}
static Future<void> handleDatabaseCorruption() async {
try {
// Delete corrupted database
final dbPath = await getDatabasesPath();
final file = File('$dbPath/pos_database.db');
if (await file.exists()) {
await file.delete();
}
log('Corrupted database deleted, will be recreated');
} catch (e) {
log('Error handling database corruption: $e');
}
}
}

View File

@ -0,0 +1,64 @@
import 'dart:developer';
class DatabasePerformanceMonitor {
static final Map<String, List<int>> _queryTimes = {};
static Future<T> monitorQuery<T>(
String queryName,
Future<T> Function() query,
) async {
final stopwatch = Stopwatch()..start();
try {
final result = await query();
stopwatch.stop();
_recordQueryTime(queryName, stopwatch.elapsedMilliseconds);
return result;
} catch (e) {
stopwatch.stop();
log('Query "$queryName" failed after ${stopwatch.elapsedMilliseconds}ms: $e');
rethrow;
}
}
static void _recordQueryTime(String queryName, int milliseconds) {
if (!_queryTimes.containsKey(queryName)) {
_queryTimes[queryName] = [];
}
_queryTimes[queryName]!.add(milliseconds);
// Keep only last 100 entries
if (_queryTimes[queryName]!.length > 100) {
_queryTimes[queryName]!.removeAt(0);
}
// Log slow queries
if (milliseconds > 1000) {
log('Slow query detected: "$queryName" took ${milliseconds}ms');
}
}
static Map<String, dynamic> getPerformanceStats() {
final stats = <String, dynamic>{};
_queryTimes.forEach((queryName, times) {
if (times.isNotEmpty) {
final avgTime = times.reduce((a, b) => a + b) / times.length;
final maxTime = times.reduce((a, b) => a > b ? a : b);
final minTime = times.reduce((a, b) => a < b ? a : b);
stats[queryName] = {
'average_ms': avgTime.round(),
'max_ms': maxTime,
'min_ms': minTime,
'total_queries': times.length,
};
}
});
return stats;
}
}

View File

@ -0,0 +1,496 @@
import 'dart:convert';
import 'dart:developer';
import 'dart:io';
import 'package:enaklo_pos/core/database/database_handler.dart';
import 'package:enaklo_pos/data/models/response/product_response_model.dart';
import 'package:sqflite/sqflite.dart';
import 'package:path/path.dart' as p;
class ProductLocalDatasource {
static ProductLocalDatasource? _instance;
ProductLocalDatasource._internal();
static ProductLocalDatasource get instance {
_instance ??= ProductLocalDatasource._internal();
return _instance!;
}
Future<Database> get _db async => await DatabaseHelper.instance.database;
// ========================================
// CACHING SYSTEM
// ========================================
final Map<String, List<Product>> _queryCache = {};
final Duration _cacheExpiry = Duration(minutes: 5);
final Map<String, DateTime> _cacheTimestamps = {};
// ========================================
// ENHANCED BATCH SAVE
// ========================================
Future<void> saveProductsBatch(List<Product> products,
{bool clearFirst = false}) async {
final db = await _db;
try {
await db.transaction((txn) async {
if (clearFirst) {
log('🗑️ Clearing existing products...');
await txn.delete('product_variants');
await txn.delete('products');
}
log('đź’ľ Batch saving ${products.length} products...');
// âś… BATCH INSERT PRODUCTS - Much faster than individual inserts
final batch = txn.batch();
for (final product in products) {
batch.insert(
'products',
_productToMap(product),
conflictAlgorithm: ConflictAlgorithm.replace,
);
}
await batch.commit(noResult: true);
// âś… BATCH INSERT VARIANTS
final variantBatch = txn.batch();
for (final product in products) {
if (product.variants?.isNotEmpty == true) {
// Delete existing variants in batch
variantBatch.delete(
'product_variants',
where: 'product_id = ?',
whereArgs: [product.id],
);
// Insert new variants
for (final variant in product.variants!) {
variantBatch.insert(
'product_variants',
_variantToMap(variant),
conflictAlgorithm: ConflictAlgorithm.replace,
);
}
}
}
await variantBatch.commit(noResult: true);
});
// Clear cache after update
clearCache();
log('âś… Successfully batch saved ${products.length} products');
} catch (e) {
log('❌ Error batch saving products: $e');
rethrow;
}
}
// ========================================
// CACHED QUERY - HIGH PERFORMANCE
// ========================================
Future<List<Product>> getCachedProducts({
int page = 1,
int limit = 10,
String? categoryId,
String? search,
}) async {
final cacheKey = _generateCacheKey(page, limit, categoryId, search);
final now = DateTime.now();
// âś… CHECK CACHE FIRST
if (_queryCache.containsKey(cacheKey) &&
_cacheTimestamps.containsKey(cacheKey)) {
final cacheTime = _cacheTimestamps[cacheKey]!;
if (now.difference(cacheTime) < _cacheExpiry) {
log('🚀 Cache HIT: $cacheKey (${_queryCache[cacheKey]!.length} products)');
return _queryCache[cacheKey]!; // Return from cache - SUPER FAST
}
}
log('đź“€ Cache MISS: $cacheKey, querying database...');
// Cache miss, query database
final products = await getProducts(
page: page,
limit: limit,
categoryId: categoryId,
search: search,
);
// âś… STORE IN CACHE for next time
_queryCache[cacheKey] = products;
_cacheTimestamps[cacheKey] = now;
log('đź’ľ Cached ${products.length} products for key: $cacheKey');
return products;
}
// ========================================
// REGULAR GET PRODUCTS (No Cache)
// ========================================
Future<List<Product>> getProducts({
int page = 1,
int limit = 10,
String? categoryId,
String? search,
}) async {
final db = await _db;
try {
String query = 'SELECT * FROM products WHERE 1=1';
List<dynamic> whereArgs = [];
if (categoryId != null && categoryId.isNotEmpty) {
query += ' AND category_id = ?';
whereArgs.add(categoryId);
}
if (search != null && search.isNotEmpty) {
query += ' AND (name LIKE ? OR sku LIKE ? OR description LIKE ?)';
whereArgs.add('%$search%');
whereArgs.add('%$search%');
whereArgs.add('%$search%');
}
query += ' ORDER BY created_at DESC';
if (limit > 0) {
query += ' LIMIT ?';
whereArgs.add(limit);
if (page > 1) {
query += ' OFFSET ?';
whereArgs.add((page - 1) * limit);
}
}
final List<Map<String, dynamic>> maps =
await db.rawQuery(query, whereArgs);
List<Product> products = [];
for (final map in maps) {
final variants = await _getProductVariants(db, map['id']);
final product = _mapToProduct(map, variants);
products.add(product);
}
log('📊 Retrieved ${products.length} products from database');
return products;
} catch (e) {
log('❌ Error getting products: $e');
return [];
}
}
// ========================================
// OPTIMIZED SEARCH with RANKING
// ========================================
Future<List<Product>> searchProductsOptimized(String query) async {
final db = await _db;
try {
log('🔍 Optimized search for: "$query"');
// âś… Smart query with prioritization
final List<Map<String, dynamic>> maps = await db.rawQuery('''
SELECT * FROM products
WHERE name LIKE ? OR sku LIKE ? OR description LIKE ?
ORDER BY
CASE
WHEN name LIKE ? THEN 1 -- Highest priority: name match
WHEN sku LIKE ? THEN 2 -- Second priority: SKU match
ELSE 3 -- Lowest priority: description
END,
name ASC
LIMIT 50
''', [
'%$query%', '%$query%', '%$query%',
'$query%', '$query%' // Prioritize results that start with query
]);
List<Product> products = [];
for (final map in maps) {
final variants = await _getProductVariants(db, map['id']);
products.add(_mapToProduct(map, variants));
}
log('🎯 Optimized search found ${products.length} results');
return products;
} catch (e) {
log('❌ Error in optimized search: $e');
return [];
}
}
// ========================================
// DATABASE ANALYTICS & MONITORING
// ========================================
Future<Map<String, dynamic>> getDatabaseStats() async {
final db = await _db;
try {
final productCount = Sqflite.firstIntValue(
await db.rawQuery('SELECT COUNT(*) FROM products')) ??
0;
final variantCount = Sqflite.firstIntValue(
await db.rawQuery('SELECT COUNT(*) FROM product_variants')) ??
0;
final categoryCount = Sqflite.firstIntValue(await db.rawQuery(
'SELECT COUNT(DISTINCT category_id) FROM products WHERE category_id IS NOT NULL')) ??
0;
final dbSize = await _getDatabaseSize();
final stats = {
'total_products': productCount,
'total_variants': variantCount,
'total_categories': categoryCount,
'database_size_mb': dbSize,
'cache_entries': _queryCache.length,
'cache_size_mb': _getCacheSize(),
};
log('📊 Database Stats: $stats');
return stats;
} catch (e) {
log('❌ Error getting database stats: $e');
return {};
}
}
Future<double> _getDatabaseSize() async {
try {
final dbPath = p.join(await getDatabasesPath(), 'pos_database.db');
final file = File(dbPath);
if (await file.exists()) {
final size = await file.length();
return size / (1024 * 1024); // Convert to MB
}
} catch (e) {
log('Error getting database size: $e');
}
return 0.0;
}
double _getCacheSize() {
double totalSize = 0;
_queryCache.forEach((key, products) {
totalSize += products.length * 0.001; // Rough estimate in MB
});
return totalSize;
}
// ========================================
// CACHE MANAGEMENT
// ========================================
String _generateCacheKey(
int page, int limit, String? categoryId, String? search) {
return 'products_${page}_${limit}_${categoryId ?? 'null'}_${search ?? 'null'}';
}
void clearCache() {
final count = _queryCache.length;
_queryCache.clear();
_cacheTimestamps.clear();
log('đź§ą Cache cleared: $count entries removed');
}
void clearExpiredCache() {
final now = DateTime.now();
final expiredKeys = <String>[];
_cacheTimestamps.forEach((key, timestamp) {
if (now.difference(timestamp) > _cacheExpiry) {
expiredKeys.add(key);
}
});
for (final key in expiredKeys) {
_queryCache.remove(key);
_cacheTimestamps.remove(key);
}
if (expiredKeys.isNotEmpty) {
log('⏰ Expired cache cleared: ${expiredKeys.length} entries');
}
}
// ========================================
// OTHER METHODS (Same as basic but with enhanced logging)
// ========================================
Future<Product?> getProductById(String id) async {
final db = await _db;
try {
final List<Map<String, dynamic>> maps = await db.query(
'products',
where: 'id = ?',
whereArgs: [id],
);
if (maps.isEmpty) {
log('❌ Product not found: $id');
return null;
}
final variants = await _getProductVariants(db, id);
final product = _mapToProduct(maps.first, variants);
log('âś… Product found: ${product.name}');
return product;
} catch (e) {
log('❌ Error getting product by ID: $e');
return null;
}
}
Future<int> getTotalCount({String? categoryId, String? search}) async {
final db = await _db;
try {
String query = 'SELECT COUNT(*) FROM products WHERE 1=1';
List<dynamic> whereArgs = [];
if (categoryId != null && categoryId.isNotEmpty) {
query += ' AND category_id = ?';
whereArgs.add(categoryId);
}
if (search != null && search.isNotEmpty) {
query += ' AND (name LIKE ? OR sku LIKE ? OR description LIKE ?)';
whereArgs.add('%$search%');
whereArgs.add('%$search%');
whereArgs.add('%$search%');
}
final result = await db.rawQuery(query, whereArgs);
final count = Sqflite.firstIntValue(result) ?? 0;
log('📊 Total count: $count (categoryId: $categoryId, search: $search)');
return count;
} catch (e) {
log('❌ Error getting total count: $e');
return 0;
}
}
Future<bool> hasProducts() async {
final count = await getTotalCount();
final hasData = count > 0;
log('🔍 Has products: $hasData ($count products)');
return hasData;
}
Future<void> clearAllProducts() async {
final db = await _db;
try {
await db.transaction((txn) async {
await txn.delete('product_variants');
await txn.delete('products');
});
clearCache();
log('🗑️ All products cleared from local DB');
} catch (e) {
log('❌ Error clearing products: $e');
rethrow;
}
}
// ========================================
// HELPER METHODS
// ========================================
Future<List<ProductVariant>> _getProductVariants(
Database db, String productId) async {
try {
final List<Map<String, dynamic>> maps = await db.query(
'product_variants',
where: 'product_id = ?',
whereArgs: [productId],
orderBy: 'name ASC',
);
return maps.map((map) => _mapToVariant(map)).toList();
} catch (e) {
log('❌ Error getting variants for product $productId: $e');
return [];
}
}
Map<String, dynamic> _productToMap(Product product) {
return {
'id': product.id,
'organization_id': product.organizationId,
'category_id': product.categoryId,
'sku': product.sku,
'name': product.name,
'description': product.description,
'price': product.price,
'cost': product.cost,
'business_type': product.businessType,
'image_url': product.imageUrl,
'printer_type': product.printerType,
'metadata':
product.metadata != null ? json.encode(product.metadata) : null,
'is_active': product.isActive == true ? 1 : 0,
'created_at': product.createdAt?.toIso8601String(),
'updated_at': product.updatedAt?.toIso8601String(),
};
}
Map<String, dynamic> _variantToMap(ProductVariant variant) {
return {
'id': variant.id,
'product_id': variant.productId,
'name': variant.name,
'price_modifier': variant.priceModifier,
'cost': variant.cost,
'metadata':
variant.metadata != null ? json.encode(variant.metadata) : null,
'created_at': variant.createdAt?.toIso8601String(),
'updated_at': variant.updatedAt?.toIso8601String(),
};
}
Product _mapToProduct(
Map<String, dynamic> map, List<ProductVariant> variants) {
return Product(
id: map['id'],
organizationId: map['organization_id'],
categoryId: map['category_id'],
sku: map['sku'],
name: map['name'],
description: map['description'],
price: map['price'],
cost: map['cost'],
businessType: map['business_type'],
imageUrl: map['image_url'],
printerType: map['printer_type'],
metadata: map['metadata'] != null ? json.decode(map['metadata']) : null,
isActive: map['is_active'] == 1,
createdAt:
map['created_at'] != null ? DateTime.parse(map['created_at']) : null,
updatedAt:
map['updated_at'] != null ? DateTime.parse(map['updated_at']) : null,
variants: variants,
);
}
ProductVariant _mapToVariant(Map<String, dynamic> map) {
return ProductVariant(
id: map['id'],
productId: map['product_id'],
name: map['name'],
priceModifier: map['price_modifier'],
cost: map['cost'],
metadata: map['metadata'] != null ? json.decode(map['metadata']) : null,
createdAt:
map['created_at'] != null ? DateTime.parse(map['created_at']) : null,
updatedAt:
map['updated_at'] != null ? DateTime.parse(map['updated_at']) : null,
);
}
}

View File

@ -0,0 +1,145 @@
import 'dart:developer';
import 'package:dartz/dartz.dart';
import 'package:enaklo_pos/data/datasources/product/product_local_datasource.dart';
import 'package:enaklo_pos/data/models/response/product_response_model.dart';
class ProductRepository {
static ProductRepository? _instance;
final ProductLocalDatasource _localDatasource;
ProductRepository._internal()
: _localDatasource = ProductLocalDatasource.instance;
static ProductRepository get instance {
_instance ??= ProductRepository._internal();
return _instance!;
}
// ========================================
// PURE LOCAL DATABASE OPERATIONS
// ========================================
Future<Either<String, ProductResponseModel>> getProducts({
int page = 1,
int limit = 10,
String? categoryId,
String? search,
bool forceRefresh = false, // Ignored - kept for compatibility
}) async {
try {
log('📱 Getting products from local database - page: $page, categoryId: $categoryId, search: $search');
// Clean expired cache for optimal performance
_localDatasource.clearExpiredCache();
// Use cached query for maximum performance
final cachedProducts = await _localDatasource.getCachedProducts(
page: page,
limit: limit,
categoryId: categoryId,
search: search,
);
final totalCount = await _localDatasource.getTotalCount(
categoryId: categoryId,
search: search,
);
final productData = ProductData(
products: cachedProducts,
totalCount: totalCount,
page: page,
limit: limit,
totalPages: totalCount > 0 ? (totalCount / limit).ceil() : 0,
);
final response = ProductResponseModel(
success: true,
data: productData,
errors: null,
);
log('âś… Returned ${cachedProducts.length} local products (${totalCount} total)');
return Right(response);
} catch (e) {
log('❌ Error getting local products: $e');
return Left('Gagal memuat produk dari database lokal: $e');
}
}
// ========================================
// OPTIMIZED LOCAL SEARCH
// ========================================
Future<Either<String, List<Product>>> searchProductsOptimized(
String query) async {
try {
log('🔍 Local optimized search for: "$query"');
final products = await _localDatasource.searchProductsOptimized(query);
log('âś… Local search completed: ${products.length} results');
return Right(products);
} catch (e) {
log('❌ Error in local search: $e');
return Left('Pencarian lokal gagal: $e');
}
}
// ========================================
// LOCAL DATABASE OPERATIONS
// ========================================
// Refresh just cleans cache and reloads from local
Future<Either<String, ProductResponseModel>> refreshProducts({
String? categoryId,
String? search,
}) async {
log('🔄 Refreshing local products...');
// Clear cache for fresh local data
clearCache();
return await getProducts(
page: 1,
limit: 10,
categoryId: categoryId,
search: search,
);
}
Future<Product?> getProductById(String id) async {
log('🔍 Getting product by ID from local: $id');
return await _localDatasource.getProductById(id);
}
Future<bool> hasLocalProducts() async {
final hasProducts = await _localDatasource.hasProducts();
log('📊 Has local products: $hasProducts');
return hasProducts;
}
Future<Map<String, dynamic>> getDatabaseStats() async {
final stats = await _localDatasource.getDatabaseStats();
log('📊 Database stats: $stats');
return stats;
}
void clearCache() {
log('đź§ą Clearing local cache');
_localDatasource.clearCache();
}
// Helper method to check if local database is populated
Future<bool> isLocalDatabaseReady() async {
try {
final stats = await getDatabaseStats();
final productCount = stats['total_products'] ?? 0;
final isReady = productCount > 0;
log('🔍 Local database ready: $isReady ($productCount products)');
return isReady;
} catch (e) {
log('❌ Error checking database readiness: $e');
return false;
}
}
}

View File

@ -0,0 +1,79 @@
import 'dart:async';
import 'dart:developer';
import 'package:connectivity_plus/connectivity_plus.dart';
import 'package:enaklo_pos/data/repositories/product/product_repository.dart';
class SyncManager {
final ProductRepository _productRepository;
final Connectivity _connectivity = Connectivity();
Timer? _syncTimer;
bool _isSyncing = false;
StreamSubscription<List<ConnectivityResult>>? _connectivitySubscription;
SyncManager(this._productRepository) {
_startPeriodicSync();
_listenToConnectivityChanges();
}
void _startPeriodicSync() {
// Sync setiap 5 menit jika ada koneksi
_syncTimer = Timer.periodic(Duration(minutes: 5), (timer) {
_performBackgroundSync();
});
}
void _listenToConnectivityChanges() {
_connectivitySubscription = _connectivity.onConnectivityChanged.listen(
(List<ConnectivityResult> results) {
// Check if any connection is available
final hasConnection =
results.any((result) => result != ConnectivityResult.none);
if (hasConnection) {
log('Connection restored, starting background sync');
_performBackgroundSync();
} else {
log('Connection lost');
}
},
);
}
Future<void> _performBackgroundSync() async {
if (_isSyncing) return;
// Check current connectivity before syncing
final connectivityResults = await _connectivity.checkConnectivity();
final hasConnection =
connectivityResults.any((result) => result != ConnectivityResult.none);
if (!hasConnection) {
log('No internet connection, skipping sync');
return;
}
try {
_isSyncing = true;
log('Starting background sync');
await _productRepository.refreshProducts();
log('Background sync completed');
} catch (e) {
log('Background sync failed: $e');
} finally {
_isSyncing = false;
}
}
// Public method untuk manual sync
Future<void> performManualSync() async {
await _performBackgroundSync();
}
void dispose() {
_syncTimer?.cancel();
_connectivitySubscription?.cancel();
}
}

View File

@ -11,6 +11,7 @@ import 'package:enaklo_pos/data/datasources/table_remote_datasource.dart';
import 'package:enaklo_pos/data/datasources/user_remote_datasource.dart';
import 'package:enaklo_pos/presentation/customer/bloc/customer_form/customer_form_bloc.dart';
import 'package:enaklo_pos/presentation/customer/bloc/customer_loader/customer_loader_bloc.dart';
import 'package:enaklo_pos/presentation/data_sync/bloc/data_sync_bloc.dart';
import 'package:enaklo_pos/presentation/home/bloc/category_loader/category_loader_bloc.dart';
import 'package:enaklo_pos/presentation/home/bloc/current_outlet/current_outlet_bloc.dart';
import 'package:enaklo_pos/presentation/home/bloc/order_form/order_form_bloc.dart';
@ -261,7 +262,7 @@ class _MyAppState extends State<MyApp> {
create: (context) => AddOrderItemsBloc(OrderRemoteDatasource()),
),
BlocProvider(
create: (context) => ProductLoaderBloc(ProductRemoteDatasource()),
create: (context) => ProductLoaderBloc(),
),
BlocProvider(
create: (context) => OrderFormBloc(OrderRemoteDatasource()),
@ -314,6 +315,9 @@ class _MyAppState extends State<MyApp> {
BlocProvider(
create: (context) => CategoryReportBloc(AnalyticRemoteDatasource()),
),
BlocProvider(
create: (context) => DataSyncBloc(),
),
],
child: MaterialApp(
navigatorKey: AuthInterceptor.navigatorKey,

View File

@ -1,3 +1,4 @@
import 'package:enaklo_pos/presentation/data_sync/pages/data_sync_page.dart';
import 'package:flutter/material.dart';
import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:enaklo_pos/data/datasources/auth_local_datasource.dart';
@ -9,7 +10,6 @@ import '../../core/components/buttons.dart';
import '../../core/components/custom_text_field.dart';
import '../../core/components/spaces.dart';
import '../../core/constants/colors.dart';
import '../home/pages/dashboard_page.dart';
import 'bloc/login/login_bloc.dart';
class LoginPage extends StatefulWidget {
@ -104,7 +104,7 @@ class _LoginPageState extends State<LoginPage> {
Navigator.pushReplacement(
context,
MaterialPageRoute(
builder: (context) => const DashboardPage(),
builder: (context) => const DataSyncPage(),
),
);
},

View File

@ -0,0 +1,185 @@
import 'dart:async';
import 'dart:developer';
import 'package:bloc/bloc.dart';
import 'package:enaklo_pos/data/datasources/product/product_local_datasource.dart';
import 'package:freezed_annotation/freezed_annotation.dart';
import '../../../data/datasources/product_remote_datasource.dart';
part 'data_sync_event.dart';
part 'data_sync_state.dart';
part 'data_sync_bloc.freezed.dart';
enum SyncStep { products, categories, variants, completed }
class SyncStats {
final int totalProducts;
final int totalCategories;
final int totalVariants;
final double databaseSizeMB;
SyncStats({
required this.totalProducts,
required this.totalCategories,
required this.totalVariants,
required this.databaseSizeMB,
});
}
class DataSyncBloc extends Bloc<DataSyncEvent, DataSyncState> {
final ProductRemoteDatasource _remoteDatasource = ProductRemoteDatasource();
final ProductLocalDatasource _localDatasource =
ProductLocalDatasource.instance;
Timer? _progressTimer;
bool _isCancelled = false;
DataSyncBloc() : super(const DataSyncState.initial()) {
on<_StartSync>(_onStartSync);
on<_CancelSync>(_onCancelSync);
}
@override
Future<void> close() {
_progressTimer?.cancel();
return super.close();
}
Future<void> _onStartSync(
_StartSync event,
Emitter<DataSyncState> emit,
) async {
log('🔄 Starting data sync...');
_isCancelled = false;
try {
// Step 1: Clear existing local data
emit(const DataSyncState.syncing(
SyncStep.products, 0.1, 'Membersihkan data lama...'));
await _localDatasource.clearAllProducts();
if (_isCancelled) return;
// Step 2: Sync products
await _syncProducts(emit);
if (_isCancelled) return;
// Step 3: Generate final stats
emit(const DataSyncState.syncing(
SyncStep.completed, 0.9, 'Menyelesaikan sinkronisasi...'));
final stats = await _generateSyncStats();
emit(DataSyncState.completed(stats));
log('âś… Sync completed successfully');
} catch (e) {
log('❌ Sync failed: $e');
emit(DataSyncState.error('Gagal sinkronisasi: $e'));
}
}
Future<void> _syncProducts(Emitter<DataSyncState> emit) async {
log('📦 Syncing products...');
int page = 1;
int totalSynced = 0;
int? totalCount;
int? totalPages;
bool shouldContinue = true;
while (!_isCancelled && shouldContinue) {
// Calculate accurate progress based on total count
double progress = 0.2;
if (totalCount != null && (totalCount ?? 0) > 0) {
progress = 0.2 + (totalSynced / (totalCount ?? 0)) * 0.6;
}
emit(DataSyncState.syncing(
SyncStep.products,
progress,
totalCount != null
? 'Mengunduh produk... ($totalSynced dari $totalCount)'
: 'Mengunduh produk... ($totalSynced produk)',
));
final result = await _remoteDatasource.getProducts(
page: page,
limit: 50, // Bigger batch for sync
);
await result.fold(
(failure) async {
throw Exception(failure);
},
(response) async {
final products = response.data?.products ?? [];
final responseData = response.data;
// Get pagination info from first response
if (page == 1 && responseData != null) {
totalCount = responseData.totalCount;
totalPages = responseData.totalPages;
log('📊 Total products to sync: $totalCount (${totalPages} pages)');
}
if (products.isEmpty) {
shouldContinue = false;
return;
}
// Save to local database in batches
await _localDatasource.saveProductsBatch(products);
totalSynced += products.length;
page++;
log('📦 Synced page ${page - 1}: ${products.length} products (Total: $totalSynced)');
// Check if we reached the end using pagination info
if (totalPages != null && page > (totalPages ?? 0)) {
shouldContinue = false;
return;
}
// Fallback check if pagination info not available
if (products.length < 50) {
shouldContinue = false;
return;
}
// Small delay to prevent overwhelming the server
await Future.delayed(Duration(milliseconds: 100));
},
);
}
emit(DataSyncState.syncing(
SyncStep.completed,
0.8,
'Produk berhasil diunduh ($totalSynced dari ${totalCount ?? totalSynced})',
));
log('âś… Products sync completed: $totalSynced products synced');
}
Future<SyncStats> _generateSyncStats() async {
final dbStats = await _localDatasource.getDatabaseStats();
return SyncStats(
totalProducts: dbStats['total_products'] ?? 0,
totalCategories: dbStats['total_categories'] ?? 0,
totalVariants: dbStats['total_variants'] ?? 0,
databaseSizeMB: dbStats['database_size_mb'] ?? 0.0,
);
}
Future<void> _onCancelSync(
_CancelSync event,
Emitter<DataSyncState> emit,
) async {
log('⏹️ Cancelling sync...');
_isCancelled = true;
_progressTimer?.cancel();
emit(const DataSyncState.initial());
}
}

View File

@ -0,0 +1,962 @@
// coverage:ignore-file
// GENERATED CODE - DO NOT MODIFY BY HAND
// ignore_for_file: type=lint
// ignore_for_file: unused_element, deprecated_member_use, deprecated_member_use_from_same_package, use_function_type_syntax_for_parameters, unnecessary_const, avoid_init_to_null, invalid_override_different_default_values_named, prefer_expression_function_bodies, annotate_overrides, invalid_annotation_target, unnecessary_question_mark
part of 'data_sync_bloc.dart';
// **************************************************************************
// FreezedGenerator
// **************************************************************************
T _$identity<T>(T value) => value;
final _privateConstructorUsedError = UnsupportedError(
'It seems like you constructed your class using `MyClass._()`. This constructor is only meant to be used by freezed and you are not supposed to need it nor use it.\nPlease check the documentation here for more information: https://github.com/rrousselGit/freezed#adding-getters-and-methods-to-our-models');
/// @nodoc
mixin _$DataSyncEvent {
@optionalTypeArgs
TResult when<TResult extends Object?>({
required TResult Function() startSync,
required TResult Function() cancelSync,
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult? whenOrNull<TResult extends Object?>({
TResult? Function()? startSync,
TResult? Function()? cancelSync,
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult maybeWhen<TResult extends Object?>({
TResult Function()? startSync,
TResult Function()? cancelSync,
required TResult orElse(),
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult map<TResult extends Object?>({
required TResult Function(_StartSync value) startSync,
required TResult Function(_CancelSync value) cancelSync,
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult? mapOrNull<TResult extends Object?>({
TResult? Function(_StartSync value)? startSync,
TResult? Function(_CancelSync value)? cancelSync,
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult maybeMap<TResult extends Object?>({
TResult Function(_StartSync value)? startSync,
TResult Function(_CancelSync value)? cancelSync,
required TResult orElse(),
}) =>
throw _privateConstructorUsedError;
}
/// @nodoc
abstract class $DataSyncEventCopyWith<$Res> {
factory $DataSyncEventCopyWith(
DataSyncEvent value, $Res Function(DataSyncEvent) then) =
_$DataSyncEventCopyWithImpl<$Res, DataSyncEvent>;
}
/// @nodoc
class _$DataSyncEventCopyWithImpl<$Res, $Val extends DataSyncEvent>
implements $DataSyncEventCopyWith<$Res> {
_$DataSyncEventCopyWithImpl(this._value, this._then);
// ignore: unused_field
final $Val _value;
// ignore: unused_field
final $Res Function($Val) _then;
/// Create a copy of DataSyncEvent
/// with the given fields replaced by the non-null parameter values.
}
/// @nodoc
abstract class _$$StartSyncImplCopyWith<$Res> {
factory _$$StartSyncImplCopyWith(
_$StartSyncImpl value, $Res Function(_$StartSyncImpl) then) =
__$$StartSyncImplCopyWithImpl<$Res>;
}
/// @nodoc
class __$$StartSyncImplCopyWithImpl<$Res>
extends _$DataSyncEventCopyWithImpl<$Res, _$StartSyncImpl>
implements _$$StartSyncImplCopyWith<$Res> {
__$$StartSyncImplCopyWithImpl(
_$StartSyncImpl _value, $Res Function(_$StartSyncImpl) _then)
: super(_value, _then);
/// Create a copy of DataSyncEvent
/// with the given fields replaced by the non-null parameter values.
}
/// @nodoc
class _$StartSyncImpl implements _StartSync {
const _$StartSyncImpl();
@override
String toString() {
return 'DataSyncEvent.startSync()';
}
@override
bool operator ==(Object other) {
return identical(this, other) ||
(other.runtimeType == runtimeType && other is _$StartSyncImpl);
}
@override
int get hashCode => runtimeType.hashCode;
@override
@optionalTypeArgs
TResult when<TResult extends Object?>({
required TResult Function() startSync,
required TResult Function() cancelSync,
}) {
return startSync();
}
@override
@optionalTypeArgs
TResult? whenOrNull<TResult extends Object?>({
TResult? Function()? startSync,
TResult? Function()? cancelSync,
}) {
return startSync?.call();
}
@override
@optionalTypeArgs
TResult maybeWhen<TResult extends Object?>({
TResult Function()? startSync,
TResult Function()? cancelSync,
required TResult orElse(),
}) {
if (startSync != null) {
return startSync();
}
return orElse();
}
@override
@optionalTypeArgs
TResult map<TResult extends Object?>({
required TResult Function(_StartSync value) startSync,
required TResult Function(_CancelSync value) cancelSync,
}) {
return startSync(this);
}
@override
@optionalTypeArgs
TResult? mapOrNull<TResult extends Object?>({
TResult? Function(_StartSync value)? startSync,
TResult? Function(_CancelSync value)? cancelSync,
}) {
return startSync?.call(this);
}
@override
@optionalTypeArgs
TResult maybeMap<TResult extends Object?>({
TResult Function(_StartSync value)? startSync,
TResult Function(_CancelSync value)? cancelSync,
required TResult orElse(),
}) {
if (startSync != null) {
return startSync(this);
}
return orElse();
}
}
abstract class _StartSync implements DataSyncEvent {
const factory _StartSync() = _$StartSyncImpl;
}
/// @nodoc
abstract class _$$CancelSyncImplCopyWith<$Res> {
factory _$$CancelSyncImplCopyWith(
_$CancelSyncImpl value, $Res Function(_$CancelSyncImpl) then) =
__$$CancelSyncImplCopyWithImpl<$Res>;
}
/// @nodoc
class __$$CancelSyncImplCopyWithImpl<$Res>
extends _$DataSyncEventCopyWithImpl<$Res, _$CancelSyncImpl>
implements _$$CancelSyncImplCopyWith<$Res> {
__$$CancelSyncImplCopyWithImpl(
_$CancelSyncImpl _value, $Res Function(_$CancelSyncImpl) _then)
: super(_value, _then);
/// Create a copy of DataSyncEvent
/// with the given fields replaced by the non-null parameter values.
}
/// @nodoc
class _$CancelSyncImpl implements _CancelSync {
const _$CancelSyncImpl();
@override
String toString() {
return 'DataSyncEvent.cancelSync()';
}
@override
bool operator ==(Object other) {
return identical(this, other) ||
(other.runtimeType == runtimeType && other is _$CancelSyncImpl);
}
@override
int get hashCode => runtimeType.hashCode;
@override
@optionalTypeArgs
TResult when<TResult extends Object?>({
required TResult Function() startSync,
required TResult Function() cancelSync,
}) {
return cancelSync();
}
@override
@optionalTypeArgs
TResult? whenOrNull<TResult extends Object?>({
TResult? Function()? startSync,
TResult? Function()? cancelSync,
}) {
return cancelSync?.call();
}
@override
@optionalTypeArgs
TResult maybeWhen<TResult extends Object?>({
TResult Function()? startSync,
TResult Function()? cancelSync,
required TResult orElse(),
}) {
if (cancelSync != null) {
return cancelSync();
}
return orElse();
}
@override
@optionalTypeArgs
TResult map<TResult extends Object?>({
required TResult Function(_StartSync value) startSync,
required TResult Function(_CancelSync value) cancelSync,
}) {
return cancelSync(this);
}
@override
@optionalTypeArgs
TResult? mapOrNull<TResult extends Object?>({
TResult? Function(_StartSync value)? startSync,
TResult? Function(_CancelSync value)? cancelSync,
}) {
return cancelSync?.call(this);
}
@override
@optionalTypeArgs
TResult maybeMap<TResult extends Object?>({
TResult Function(_StartSync value)? startSync,
TResult Function(_CancelSync value)? cancelSync,
required TResult orElse(),
}) {
if (cancelSync != null) {
return cancelSync(this);
}
return orElse();
}
}
abstract class _CancelSync implements DataSyncEvent {
const factory _CancelSync() = _$CancelSyncImpl;
}
/// @nodoc
mixin _$DataSyncState {
@optionalTypeArgs
TResult when<TResult extends Object?>({
required TResult Function() initial,
required TResult Function(SyncStep step, double progress, String message)
syncing,
required TResult Function(SyncStats stats) completed,
required TResult Function(String message) error,
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult? whenOrNull<TResult extends Object?>({
TResult? Function()? initial,
TResult? Function(SyncStep step, double progress, String message)? syncing,
TResult? Function(SyncStats stats)? completed,
TResult? Function(String message)? error,
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult maybeWhen<TResult extends Object?>({
TResult Function()? initial,
TResult Function(SyncStep step, double progress, String message)? syncing,
TResult Function(SyncStats stats)? completed,
TResult Function(String message)? error,
required TResult orElse(),
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult map<TResult extends Object?>({
required TResult Function(_Initial value) initial,
required TResult Function(_Syncing value) syncing,
required TResult Function(_Completed value) completed,
required TResult Function(_Error value) error,
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult? mapOrNull<TResult extends Object?>({
TResult? Function(_Initial value)? initial,
TResult? Function(_Syncing value)? syncing,
TResult? Function(_Completed value)? completed,
TResult? Function(_Error value)? error,
}) =>
throw _privateConstructorUsedError;
@optionalTypeArgs
TResult maybeMap<TResult extends Object?>({
TResult Function(_Initial value)? initial,
TResult Function(_Syncing value)? syncing,
TResult Function(_Completed value)? completed,
TResult Function(_Error value)? error,
required TResult orElse(),
}) =>
throw _privateConstructorUsedError;
}
/// @nodoc
abstract class $DataSyncStateCopyWith<$Res> {
factory $DataSyncStateCopyWith(
DataSyncState value, $Res Function(DataSyncState) then) =
_$DataSyncStateCopyWithImpl<$Res, DataSyncState>;
}
/// @nodoc
class _$DataSyncStateCopyWithImpl<$Res, $Val extends DataSyncState>
implements $DataSyncStateCopyWith<$Res> {
_$DataSyncStateCopyWithImpl(this._value, this._then);
// ignore: unused_field
final $Val _value;
// ignore: unused_field
final $Res Function($Val) _then;
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
}
/// @nodoc
abstract class _$$InitialImplCopyWith<$Res> {
factory _$$InitialImplCopyWith(
_$InitialImpl value, $Res Function(_$InitialImpl) then) =
__$$InitialImplCopyWithImpl<$Res>;
}
/// @nodoc
class __$$InitialImplCopyWithImpl<$Res>
extends _$DataSyncStateCopyWithImpl<$Res, _$InitialImpl>
implements _$$InitialImplCopyWith<$Res> {
__$$InitialImplCopyWithImpl(
_$InitialImpl _value, $Res Function(_$InitialImpl) _then)
: super(_value, _then);
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
}
/// @nodoc
class _$InitialImpl implements _Initial {
const _$InitialImpl();
@override
String toString() {
return 'DataSyncState.initial()';
}
@override
bool operator ==(Object other) {
return identical(this, other) ||
(other.runtimeType == runtimeType && other is _$InitialImpl);
}
@override
int get hashCode => runtimeType.hashCode;
@override
@optionalTypeArgs
TResult when<TResult extends Object?>({
required TResult Function() initial,
required TResult Function(SyncStep step, double progress, String message)
syncing,
required TResult Function(SyncStats stats) completed,
required TResult Function(String message) error,
}) {
return initial();
}
@override
@optionalTypeArgs
TResult? whenOrNull<TResult extends Object?>({
TResult? Function()? initial,
TResult? Function(SyncStep step, double progress, String message)? syncing,
TResult? Function(SyncStats stats)? completed,
TResult? Function(String message)? error,
}) {
return initial?.call();
}
@override
@optionalTypeArgs
TResult maybeWhen<TResult extends Object?>({
TResult Function()? initial,
TResult Function(SyncStep step, double progress, String message)? syncing,
TResult Function(SyncStats stats)? completed,
TResult Function(String message)? error,
required TResult orElse(),
}) {
if (initial != null) {
return initial();
}
return orElse();
}
@override
@optionalTypeArgs
TResult map<TResult extends Object?>({
required TResult Function(_Initial value) initial,
required TResult Function(_Syncing value) syncing,
required TResult Function(_Completed value) completed,
required TResult Function(_Error value) error,
}) {
return initial(this);
}
@override
@optionalTypeArgs
TResult? mapOrNull<TResult extends Object?>({
TResult? Function(_Initial value)? initial,
TResult? Function(_Syncing value)? syncing,
TResult? Function(_Completed value)? completed,
TResult? Function(_Error value)? error,
}) {
return initial?.call(this);
}
@override
@optionalTypeArgs
TResult maybeMap<TResult extends Object?>({
TResult Function(_Initial value)? initial,
TResult Function(_Syncing value)? syncing,
TResult Function(_Completed value)? completed,
TResult Function(_Error value)? error,
required TResult orElse(),
}) {
if (initial != null) {
return initial(this);
}
return orElse();
}
}
abstract class _Initial implements DataSyncState {
const factory _Initial() = _$InitialImpl;
}
/// @nodoc
abstract class _$$SyncingImplCopyWith<$Res> {
factory _$$SyncingImplCopyWith(
_$SyncingImpl value, $Res Function(_$SyncingImpl) then) =
__$$SyncingImplCopyWithImpl<$Res>;
@useResult
$Res call({SyncStep step, double progress, String message});
}
/// @nodoc
class __$$SyncingImplCopyWithImpl<$Res>
extends _$DataSyncStateCopyWithImpl<$Res, _$SyncingImpl>
implements _$$SyncingImplCopyWith<$Res> {
__$$SyncingImplCopyWithImpl(
_$SyncingImpl _value, $Res Function(_$SyncingImpl) _then)
: super(_value, _then);
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
@pragma('vm:prefer-inline')
@override
$Res call({
Object? step = null,
Object? progress = null,
Object? message = null,
}) {
return _then(_$SyncingImpl(
null == step
? _value.step
: step // ignore: cast_nullable_to_non_nullable
as SyncStep,
null == progress
? _value.progress
: progress // ignore: cast_nullable_to_non_nullable
as double,
null == message
? _value.message
: message // ignore: cast_nullable_to_non_nullable
as String,
));
}
}
/// @nodoc
class _$SyncingImpl implements _Syncing {
const _$SyncingImpl(this.step, this.progress, this.message);
@override
final SyncStep step;
@override
final double progress;
@override
final String message;
@override
String toString() {
return 'DataSyncState.syncing(step: $step, progress: $progress, message: $message)';
}
@override
bool operator ==(Object other) {
return identical(this, other) ||
(other.runtimeType == runtimeType &&
other is _$SyncingImpl &&
(identical(other.step, step) || other.step == step) &&
(identical(other.progress, progress) ||
other.progress == progress) &&
(identical(other.message, message) || other.message == message));
}
@override
int get hashCode => Object.hash(runtimeType, step, progress, message);
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
@JsonKey(includeFromJson: false, includeToJson: false)
@override
@pragma('vm:prefer-inline')
_$$SyncingImplCopyWith<_$SyncingImpl> get copyWith =>
__$$SyncingImplCopyWithImpl<_$SyncingImpl>(this, _$identity);
@override
@optionalTypeArgs
TResult when<TResult extends Object?>({
required TResult Function() initial,
required TResult Function(SyncStep step, double progress, String message)
syncing,
required TResult Function(SyncStats stats) completed,
required TResult Function(String message) error,
}) {
return syncing(step, progress, message);
}
@override
@optionalTypeArgs
TResult? whenOrNull<TResult extends Object?>({
TResult? Function()? initial,
TResult? Function(SyncStep step, double progress, String message)? syncing,
TResult? Function(SyncStats stats)? completed,
TResult? Function(String message)? error,
}) {
return syncing?.call(step, progress, message);
}
@override
@optionalTypeArgs
TResult maybeWhen<TResult extends Object?>({
TResult Function()? initial,
TResult Function(SyncStep step, double progress, String message)? syncing,
TResult Function(SyncStats stats)? completed,
TResult Function(String message)? error,
required TResult orElse(),
}) {
if (syncing != null) {
return syncing(step, progress, message);
}
return orElse();
}
@override
@optionalTypeArgs
TResult map<TResult extends Object?>({
required TResult Function(_Initial value) initial,
required TResult Function(_Syncing value) syncing,
required TResult Function(_Completed value) completed,
required TResult Function(_Error value) error,
}) {
return syncing(this);
}
@override
@optionalTypeArgs
TResult? mapOrNull<TResult extends Object?>({
TResult? Function(_Initial value)? initial,
TResult? Function(_Syncing value)? syncing,
TResult? Function(_Completed value)? completed,
TResult? Function(_Error value)? error,
}) {
return syncing?.call(this);
}
@override
@optionalTypeArgs
TResult maybeMap<TResult extends Object?>({
TResult Function(_Initial value)? initial,
TResult Function(_Syncing value)? syncing,
TResult Function(_Completed value)? completed,
TResult Function(_Error value)? error,
required TResult orElse(),
}) {
if (syncing != null) {
return syncing(this);
}
return orElse();
}
}
abstract class _Syncing implements DataSyncState {
const factory _Syncing(
final SyncStep step, final double progress, final String message) =
_$SyncingImpl;
SyncStep get step;
double get progress;
String get message;
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
@JsonKey(includeFromJson: false, includeToJson: false)
_$$SyncingImplCopyWith<_$SyncingImpl> get copyWith =>
throw _privateConstructorUsedError;
}
/// @nodoc
abstract class _$$CompletedImplCopyWith<$Res> {
factory _$$CompletedImplCopyWith(
_$CompletedImpl value, $Res Function(_$CompletedImpl) then) =
__$$CompletedImplCopyWithImpl<$Res>;
@useResult
$Res call({SyncStats stats});
}
/// @nodoc
class __$$CompletedImplCopyWithImpl<$Res>
extends _$DataSyncStateCopyWithImpl<$Res, _$CompletedImpl>
implements _$$CompletedImplCopyWith<$Res> {
__$$CompletedImplCopyWithImpl(
_$CompletedImpl _value, $Res Function(_$CompletedImpl) _then)
: super(_value, _then);
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
@pragma('vm:prefer-inline')
@override
$Res call({
Object? stats = null,
}) {
return _then(_$CompletedImpl(
null == stats
? _value.stats
: stats // ignore: cast_nullable_to_non_nullable
as SyncStats,
));
}
}
/// @nodoc
class _$CompletedImpl implements _Completed {
const _$CompletedImpl(this.stats);
@override
final SyncStats stats;
@override
String toString() {
return 'DataSyncState.completed(stats: $stats)';
}
@override
bool operator ==(Object other) {
return identical(this, other) ||
(other.runtimeType == runtimeType &&
other is _$CompletedImpl &&
(identical(other.stats, stats) || other.stats == stats));
}
@override
int get hashCode => Object.hash(runtimeType, stats);
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
@JsonKey(includeFromJson: false, includeToJson: false)
@override
@pragma('vm:prefer-inline')
_$$CompletedImplCopyWith<_$CompletedImpl> get copyWith =>
__$$CompletedImplCopyWithImpl<_$CompletedImpl>(this, _$identity);
@override
@optionalTypeArgs
TResult when<TResult extends Object?>({
required TResult Function() initial,
required TResult Function(SyncStep step, double progress, String message)
syncing,
required TResult Function(SyncStats stats) completed,
required TResult Function(String message) error,
}) {
return completed(stats);
}
@override
@optionalTypeArgs
TResult? whenOrNull<TResult extends Object?>({
TResult? Function()? initial,
TResult? Function(SyncStep step, double progress, String message)? syncing,
TResult? Function(SyncStats stats)? completed,
TResult? Function(String message)? error,
}) {
return completed?.call(stats);
}
@override
@optionalTypeArgs
TResult maybeWhen<TResult extends Object?>({
TResult Function()? initial,
TResult Function(SyncStep step, double progress, String message)? syncing,
TResult Function(SyncStats stats)? completed,
TResult Function(String message)? error,
required TResult orElse(),
}) {
if (completed != null) {
return completed(stats);
}
return orElse();
}
@override
@optionalTypeArgs
TResult map<TResult extends Object?>({
required TResult Function(_Initial value) initial,
required TResult Function(_Syncing value) syncing,
required TResult Function(_Completed value) completed,
required TResult Function(_Error value) error,
}) {
return completed(this);
}
@override
@optionalTypeArgs
TResult? mapOrNull<TResult extends Object?>({
TResult? Function(_Initial value)? initial,
TResult? Function(_Syncing value)? syncing,
TResult? Function(_Completed value)? completed,
TResult? Function(_Error value)? error,
}) {
return completed?.call(this);
}
@override
@optionalTypeArgs
TResult maybeMap<TResult extends Object?>({
TResult Function(_Initial value)? initial,
TResult Function(_Syncing value)? syncing,
TResult Function(_Completed value)? completed,
TResult Function(_Error value)? error,
required TResult orElse(),
}) {
if (completed != null) {
return completed(this);
}
return orElse();
}
}
abstract class _Completed implements DataSyncState {
const factory _Completed(final SyncStats stats) = _$CompletedImpl;
SyncStats get stats;
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
@JsonKey(includeFromJson: false, includeToJson: false)
_$$CompletedImplCopyWith<_$CompletedImpl> get copyWith =>
throw _privateConstructorUsedError;
}
/// @nodoc
abstract class _$$ErrorImplCopyWith<$Res> {
factory _$$ErrorImplCopyWith(
_$ErrorImpl value, $Res Function(_$ErrorImpl) then) =
__$$ErrorImplCopyWithImpl<$Res>;
@useResult
$Res call({String message});
}
/// @nodoc
class __$$ErrorImplCopyWithImpl<$Res>
extends _$DataSyncStateCopyWithImpl<$Res, _$ErrorImpl>
implements _$$ErrorImplCopyWith<$Res> {
__$$ErrorImplCopyWithImpl(
_$ErrorImpl _value, $Res Function(_$ErrorImpl) _then)
: super(_value, _then);
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
@pragma('vm:prefer-inline')
@override
$Res call({
Object? message = null,
}) {
return _then(_$ErrorImpl(
null == message
? _value.message
: message // ignore: cast_nullable_to_non_nullable
as String,
));
}
}
/// @nodoc
class _$ErrorImpl implements _Error {
const _$ErrorImpl(this.message);
@override
final String message;
@override
String toString() {
return 'DataSyncState.error(message: $message)';
}
@override
bool operator ==(Object other) {
return identical(this, other) ||
(other.runtimeType == runtimeType &&
other is _$ErrorImpl &&
(identical(other.message, message) || other.message == message));
}
@override
int get hashCode => Object.hash(runtimeType, message);
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
@JsonKey(includeFromJson: false, includeToJson: false)
@override
@pragma('vm:prefer-inline')
_$$ErrorImplCopyWith<_$ErrorImpl> get copyWith =>
__$$ErrorImplCopyWithImpl<_$ErrorImpl>(this, _$identity);
@override
@optionalTypeArgs
TResult when<TResult extends Object?>({
required TResult Function() initial,
required TResult Function(SyncStep step, double progress, String message)
syncing,
required TResult Function(SyncStats stats) completed,
required TResult Function(String message) error,
}) {
return error(message);
}
@override
@optionalTypeArgs
TResult? whenOrNull<TResult extends Object?>({
TResult? Function()? initial,
TResult? Function(SyncStep step, double progress, String message)? syncing,
TResult? Function(SyncStats stats)? completed,
TResult? Function(String message)? error,
}) {
return error?.call(message);
}
@override
@optionalTypeArgs
TResult maybeWhen<TResult extends Object?>({
TResult Function()? initial,
TResult Function(SyncStep step, double progress, String message)? syncing,
TResult Function(SyncStats stats)? completed,
TResult Function(String message)? error,
required TResult orElse(),
}) {
if (error != null) {
return error(message);
}
return orElse();
}
@override
@optionalTypeArgs
TResult map<TResult extends Object?>({
required TResult Function(_Initial value) initial,
required TResult Function(_Syncing value) syncing,
required TResult Function(_Completed value) completed,
required TResult Function(_Error value) error,
}) {
return error(this);
}
@override
@optionalTypeArgs
TResult? mapOrNull<TResult extends Object?>({
TResult? Function(_Initial value)? initial,
TResult? Function(_Syncing value)? syncing,
TResult? Function(_Completed value)? completed,
TResult? Function(_Error value)? error,
}) {
return error?.call(this);
}
@override
@optionalTypeArgs
TResult maybeMap<TResult extends Object?>({
TResult Function(_Initial value)? initial,
TResult Function(_Syncing value)? syncing,
TResult Function(_Completed value)? completed,
TResult Function(_Error value)? error,
required TResult orElse(),
}) {
if (error != null) {
return error(this);
}
return orElse();
}
}
abstract class _Error implements DataSyncState {
const factory _Error(final String message) = _$ErrorImpl;
String get message;
/// Create a copy of DataSyncState
/// with the given fields replaced by the non-null parameter values.
@JsonKey(includeFromJson: false, includeToJson: false)
_$$ErrorImplCopyWith<_$ErrorImpl> get copyWith =>
throw _privateConstructorUsedError;
}

View File

@ -0,0 +1,7 @@
part of 'data_sync_bloc.dart';
@freezed
class DataSyncEvent with _$DataSyncEvent {
const factory DataSyncEvent.startSync() = _StartSync;
const factory DataSyncEvent.cancelSync() = _CancelSync;
}

View File

@ -0,0 +1,13 @@
part of 'data_sync_bloc.dart';
@freezed
class DataSyncState with _$DataSyncState {
const factory DataSyncState.initial() = _Initial;
const factory DataSyncState.syncing(
SyncStep step,
double progress,
String message,
) = _Syncing;
const factory DataSyncState.completed(SyncStats stats) = _Completed;
const factory DataSyncState.error(String message) = _Error;
}

View File

@ -0,0 +1,791 @@
import 'dart:async';
import 'package:enaklo_pos/core/extensions/build_context_ext.dart';
import 'package:enaklo_pos/presentation/home/pages/dashboard_page.dart';
import 'package:flutter/material.dart';
import 'package:flutter_bloc/flutter_bloc.dart';
import '../../../core/components/buttons.dart';
import '../../../core/constants/colors.dart';
import '../bloc/data_sync_bloc.dart';
class DataSyncPage extends StatefulWidget {
const DataSyncPage({super.key});
@override
State<DataSyncPage> createState() => _DataSyncPageState();
}
class _DataSyncPageState extends State<DataSyncPage>
with TickerProviderStateMixin {
late AnimationController _animationController;
late Animation<double> _progressAnimation;
@override
void initState() {
super.initState();
_animationController = AnimationController(
duration: Duration(milliseconds: 500),
vsync: this,
);
_progressAnimation = Tween<double>(
begin: 0.0,
end: 1.0,
).animate(CurvedAnimation(
parent: _animationController,
curve: Curves.easeInOut,
));
// Auto start sync
WidgetsBinding.instance.addPostFrameCallback((_) {
context.read<DataSyncBloc>().add(const DataSyncEvent.startSync());
});
}
@override
void dispose() {
_animationController.dispose();
super.dispose();
}
@override
Widget build(BuildContext context) {
final mediaQuery = MediaQuery.of(context);
final isLandscape = mediaQuery.orientation == Orientation.landscape;
final screenHeight = mediaQuery.size.height;
final screenWidth = mediaQuery.size.width;
return Scaffold(
backgroundColor: Colors.grey.shade50,
body: SafeArea(
child: BlocConsumer<DataSyncBloc, DataSyncState>(
listener: (context, state) {
state.maybeWhen(
orElse: () {},
syncing: (step, progress, message) {
_animationController.animateTo(progress);
},
completed: (stats) {
_animationController.animateTo(1.0);
// Navigate to home after delay
Future.delayed(Duration(seconds: 2), () {
context.pushReplacement(DashboardPage());
});
},
error: (message) {
_animationController.stop();
},
);
},
builder: (context, state) {
if (isLandscape) {
return _buildLandscapeLayout(state, screenWidth, screenHeight);
} else {
return _buildPortraitLayout(state, screenHeight);
}
},
),
),
);
}
// Portrait layout (original)
Widget _buildPortraitLayout(DataSyncState state, double screenHeight) {
return Padding(
padding: EdgeInsets.all(24),
child: Column(
children: [
SizedBox(height: screenHeight * 0.08), // Responsive spacing
// Header
_buildHeader(false),
SizedBox(height: screenHeight * 0.08),
// Sync progress
Expanded(
child: state.when(
initial: () => _buildInitialState(false),
syncing: (step, progress, message) =>
_buildSyncingState(step, progress, message, false),
completed: (stats) => _buildCompletedState(stats, false),
error: (message) => _buildErrorState(message, false),
),
),
SizedBox(height: 20),
// Actions
_buildActions(state),
],
),
);
}
// Landscape layout (side by side)
Widget _buildLandscapeLayout(
DataSyncState state, double screenWidth, double screenHeight) {
return Padding(
padding: EdgeInsets.symmetric(horizontal: 32, vertical: 16),
child: Row(
children: [
// Left side - Header and info
Expanded(
flex: 2,
child: Column(
mainAxisAlignment: MainAxisAlignment.center,
children: [
_buildHeader(true),
SizedBox(height: 20),
_buildActions(state),
],
),
),
SizedBox(width: 40),
// Right side - Sync progress
Expanded(
flex: 3,
child: Container(
height: screenHeight * 0.8,
child: state.when(
initial: () => _buildInitialState(true),
syncing: (step, progress, message) =>
_buildSyncingState(step, progress, message, true),
completed: (stats) => _buildCompletedState(stats, true),
error: (message) => _buildErrorState(message, true),
),
),
),
],
),
);
}
Widget _buildHeader(bool isLandscape) {
return Column(
children: [
Container(
width: isLandscape ? 60 : 80,
height: isLandscape ? 60 : 80,
decoration: BoxDecoration(
color: AppColors.primary.withOpacity(0.1),
borderRadius: BorderRadius.circular(isLandscape ? 15 : 20),
),
child: Icon(
Icons.sync,
size: isLandscape ? 30 : 40,
color: AppColors.primary,
),
),
SizedBox(height: isLandscape ? 12 : 20),
Text(
'Sinkronisasi Data',
style: TextStyle(
fontSize: isLandscape ? 20 : 24,
fontWeight: FontWeight.bold,
color: Colors.grey.shade800,
),
),
SizedBox(height: isLandscape ? 4 : 8),
Text(
'Mengunduh data terbaru ke perangkat',
style: TextStyle(
fontSize: isLandscape ? 14 : 16,
color: Colors.grey.shade600,
),
textAlign: TextAlign.center,
),
],
);
}
Widget _buildInitialState(bool isLandscape) {
return Column(
mainAxisAlignment: MainAxisAlignment.center,
children: [
Icon(
Icons.download_rounded,
size: isLandscape ? 48 : 64,
color: Colors.grey.shade400,
),
SizedBox(height: isLandscape ? 12 : 20),
Text(
'Siap untuk sinkronisasi',
style: TextStyle(
fontSize: isLandscape ? 16 : 18,
fontWeight: FontWeight.w500,
),
),
SizedBox(height: isLandscape ? 4 : 8),
Text(
'Tekan tombol mulai untuk mengunduh data',
style: TextStyle(
fontSize: isLandscape ? 12 : 14,
color: Colors.grey.shade600,
),
textAlign: TextAlign.center,
),
],
);
}
Widget _buildSyncingState(
SyncStep step, double progress, String message, bool isLandscape) {
return SingleChildScrollView(
child: Column(
mainAxisAlignment: MainAxisAlignment.center,
children: [
// Progress circle
Stack(
alignment: Alignment.center,
children: [
SizedBox(
width: isLandscape ? 100 : 120,
height: isLandscape ? 100 : 120,
child: AnimatedBuilder(
animation: _progressAnimation,
builder: (context, child) {
return CircularProgressIndicator(
value: _progressAnimation.value,
strokeWidth: isLandscape ? 6 : 8,
backgroundColor: Colors.grey.shade200,
valueColor:
AlwaysStoppedAnimation<Color>(AppColors.primary),
);
},
),
),
Column(
children: [
Icon(
_getSyncIcon(step),
size: isLandscape ? 24 : 32,
color: AppColors.primary,
),
SizedBox(height: 2),
AnimatedBuilder(
animation: _progressAnimation,
builder: (context, child) {
return Text(
'${(_progressAnimation.value * 100).toInt()}%',
style: TextStyle(
fontSize: isLandscape ? 14 : 16,
fontWeight: FontWeight.bold,
color: AppColors.primary,
),
);
},
),
],
),
],
),
SizedBox(height: isLandscape ? 20 : 30),
// Step indicator
_buildStepIndicator(step, isLandscape),
SizedBox(height: isLandscape ? 12 : 20),
// Current message
Container(
padding: EdgeInsets.symmetric(
horizontal: isLandscape ? 16 : 20,
vertical: isLandscape ? 8 : 12),
decoration: BoxDecoration(
color: Colors.blue.shade50,
borderRadius: BorderRadius.circular(8),
),
child: Text(
message,
style: TextStyle(
color: Colors.blue.shade700,
fontSize: isLandscape ? 12 : 14,
fontWeight: FontWeight.w500,
),
textAlign: TextAlign.center,
),
),
SizedBox(height: isLandscape ? 12 : 20),
// Sync details
_buildSyncDetails(step, progress, isLandscape),
],
),
);
}
Widget _buildStepIndicator(SyncStep currentStep, bool isLandscape) {
final steps = [
('Produk', SyncStep.products, Icons.inventory_2),
('Kategori', SyncStep.categories, Icons.category),
('Variant', SyncStep.variants, Icons.tune),
('Selesai', SyncStep.completed, Icons.check_circle),
];
if (isLandscape) {
// Vertical layout for landscape
return Column(
children: steps.map((stepData) {
final (label, step, icon) = stepData;
final isActive = step == currentStep;
final isCompleted = step.index < currentStep.index;
return Container(
margin: EdgeInsets.symmetric(vertical: 2),
padding: EdgeInsets.symmetric(horizontal: 8, vertical: 4),
decoration: BoxDecoration(
color: isActive
? AppColors.primary.withOpacity(0.1)
: isCompleted
? Colors.green.shade50
: Colors.grey.shade100,
borderRadius: BorderRadius.circular(6),
),
child: Row(
mainAxisSize: MainAxisSize.min,
children: [
Icon(
isCompleted ? Icons.check : icon,
size: 12,
color: isActive
? AppColors.primary
: isCompleted
? Colors.green.shade600
: Colors.grey.shade500,
),
SizedBox(width: 4),
Text(
label,
style: TextStyle(
fontSize: 10,
fontWeight: isActive ? FontWeight.w600 : FontWeight.normal,
color: isActive
? AppColors.primary
: isCompleted
? Colors.green.shade600
: Colors.grey.shade600,
),
),
],
),
);
}).toList(),
);
} else {
// Horizontal layout for portrait
return Row(
mainAxisAlignment: MainAxisAlignment.center,
children: steps.map((stepData) {
final (label, step, icon) = stepData;
final isActive = step == currentStep;
final isCompleted = step.index < currentStep.index;
return Container(
margin: EdgeInsets.symmetric(horizontal: 4),
padding: EdgeInsets.symmetric(horizontal: 8, vertical: 4),
decoration: BoxDecoration(
color: isActive
? AppColors.primary.withOpacity(0.1)
: isCompleted
? Colors.green.shade50
: Colors.grey.shade100,
borderRadius: BorderRadius.circular(6),
),
child: Row(
mainAxisSize: MainAxisSize.min,
children: [
Icon(
isCompleted ? Icons.check : icon,
size: 14,
color: isActive
? AppColors.primary
: isCompleted
? Colors.green.shade600
: Colors.grey.shade500,
),
SizedBox(width: 4),
Text(
label,
style: TextStyle(
fontSize: 11,
fontWeight: isActive ? FontWeight.w600 : FontWeight.normal,
color: isActive
? AppColors.primary
: isCompleted
? Colors.green.shade600
: Colors.grey.shade600,
),
),
],
),
);
}).toList(),
);
}
}
Widget _buildSyncDetails(SyncStep step, double progress, bool isLandscape) {
return Container(
padding: EdgeInsets.all(isLandscape ? 12 : 16),
decoration: BoxDecoration(
color: Colors.white,
borderRadius: BorderRadius.circular(8),
border: Border.all(color: Colors.grey.shade200),
),
child: Column(
children: [
Row(
mainAxisAlignment: MainAxisAlignment.spaceBetween,
children: [
Text(
'Status:',
style: TextStyle(
fontSize: isLandscape ? 12 : 14,
fontWeight: FontWeight.w500,
color: Colors.grey.shade700,
),
),
Text(
_getStepLabel(step),
style: TextStyle(
fontSize: isLandscape ? 12 : 14,
fontWeight: FontWeight.w600,
color: AppColors.primary,
),
),
],
),
SizedBox(height: isLandscape ? 6 : 8),
Row(
mainAxisAlignment: MainAxisAlignment.spaceBetween,
children: [
Text(
'Progress:',
style: TextStyle(
fontSize: isLandscape ? 12 : 14,
fontWeight: FontWeight.w500,
color: Colors.grey.shade700,
),
),
Text(
'${(progress * 100).toInt()}%',
style: TextStyle(
fontSize: isLandscape ? 12 : 14,
fontWeight: FontWeight.w600,
color: AppColors.primary,
),
),
],
),
],
),
);
}
Widget _buildCompletedState(SyncStats stats, bool isLandscape) {
return SingleChildScrollView(
child: Column(
mainAxisAlignment: MainAxisAlignment.center,
children: [
// Success icon
Container(
width: isLandscape ? 80 : 100,
height: isLandscape ? 80 : 100,
decoration: BoxDecoration(
color: Colors.green.shade50,
borderRadius: BorderRadius.circular(isLandscape ? 40 : 50),
),
child: Icon(
Icons.check_circle,
size: isLandscape ? 48 : 60,
color: Colors.green.shade600,
),
),
SizedBox(height: isLandscape ? 20 : 30),
Text(
'Sinkronisasi Berhasil!',
style: TextStyle(
fontSize: isLandscape ? 18 : 22,
fontWeight: FontWeight.bold,
color: Colors.green.shade700,
),
),
SizedBox(height: isLandscape ? 8 : 16),
Text(
'Data berhasil diunduh ke perangkat',
style: TextStyle(
fontSize: isLandscape ? 14 : 16,
color: Colors.grey.shade600,
),
),
SizedBox(height: isLandscape ? 20 : 30),
// Stats cards
Container(
padding: EdgeInsets.all(isLandscape ? 16 : 20),
decoration: BoxDecoration(
color: Colors.white,
borderRadius: BorderRadius.circular(12),
border: Border.all(color: Colors.grey.shade200),
),
child: Column(
children: [
Text(
'Data yang Diunduh',
style: TextStyle(
fontSize: isLandscape ? 14 : 16,
fontWeight: FontWeight.w600,
color: Colors.grey.shade700,
),
),
SizedBox(height: isLandscape ? 12 : 16),
if (isLandscape)
// Vertical layout for landscape
Column(
children: [
_buildStatItem('Produk', '${stats.totalProducts}',
Icons.inventory_2, Colors.blue, isLandscape),
SizedBox(height: 8),
_buildStatItem('Kategori', '${stats.totalCategories}',
Icons.category, Colors.green, isLandscape),
SizedBox(height: 8),
_buildStatItem('Variant', '${stats.totalVariants}',
Icons.tune, Colors.orange, isLandscape),
],
)
else
// Horizontal layout for portrait
Row(
mainAxisAlignment: MainAxisAlignment.spaceAround,
children: [
_buildStatItem('Produk', '${stats.totalProducts}',
Icons.inventory_2, Colors.blue, isLandscape),
_buildStatItem('Kategori', '${stats.totalCategories}',
Icons.category, Colors.green, isLandscape),
_buildStatItem('Variant', '${stats.totalVariants}',
Icons.tune, Colors.orange, isLandscape),
],
),
],
),
),
SizedBox(height: isLandscape ? 12 : 20),
Container(
padding: EdgeInsets.symmetric(horizontal: 16, vertical: 8),
decoration: BoxDecoration(
color: Colors.grey.shade100,
borderRadius: BorderRadius.circular(6),
),
child: Text(
'Mengalihkan ke halaman utama...',
style: TextStyle(
color: Colors.grey.shade600,
fontSize: isLandscape ? 10 : 12,
),
),
),
],
),
);
}
Widget _buildErrorState(String message, bool isLandscape) {
return Column(
mainAxisAlignment: MainAxisAlignment.center,
children: [
Icon(
Icons.error_outline,
size: isLandscape ? 48 : 64,
color: Colors.red.shade400,
),
SizedBox(height: isLandscape ? 12 : 20),
Text(
'Sinkronisasi Gagal',
style: TextStyle(
fontSize: isLandscape ? 16 : 20,
fontWeight: FontWeight.bold,
color: Colors.red.shade600,
),
),
SizedBox(height: isLandscape ? 8 : 12),
Container(
padding: EdgeInsets.all(isLandscape ? 12 : 16),
decoration: BoxDecoration(
color: Colors.red.shade50,
borderRadius: BorderRadius.circular(8),
),
child: Text(
message,
style: TextStyle(
fontSize: isLandscape ? 12 : 14,
color: Colors.red.shade700,
),
textAlign: TextAlign.center,
),
),
SizedBox(height: isLandscape ? 12 : 20),
Text(
'Periksa koneksi internet dan coba lagi',
style: TextStyle(
fontSize: isLandscape ? 12 : 14,
color: Colors.grey.shade600,
),
textAlign: TextAlign.center,
),
],
);
}
Widget _buildStatItem(String label, String value, IconData icon, Color color,
bool isLandscape) {
if (isLandscape) {
// Horizontal layout for landscape
return Container(
padding: EdgeInsets.symmetric(horizontal: 12, vertical: 8),
decoration: BoxDecoration(
color: color.withOpacity(0.1),
borderRadius: BorderRadius.circular(8),
),
child: Row(
mainAxisSize: MainAxisSize.min,
children: [
Icon(icon, size: 20, color: color),
SizedBox(width: 8),
Column(
crossAxisAlignment: CrossAxisAlignment.start,
children: [
Text(
value,
style: TextStyle(
fontSize: 16,
fontWeight: FontWeight.bold,
color: color,
),
),
Text(
label,
style: TextStyle(
fontSize: 10,
color: Colors.grey.shade600,
),
),
],
),
],
),
);
} else {
// Vertical layout for portrait
return Column(
children: [
Container(
padding: EdgeInsets.all(12),
decoration: BoxDecoration(
color: color.withOpacity(0.1),
borderRadius: BorderRadius.circular(8),
),
child: Icon(icon, size: 24, color: color),
),
SizedBox(height: 8),
Text(
value,
style: TextStyle(
fontSize: 18,
fontWeight: FontWeight.bold,
color: color,
),
),
Text(
label,
style: TextStyle(
fontSize: 12,
color: Colors.grey.shade600,
),
),
],
);
}
}
Widget _buildActions(DataSyncState state) {
return state.when(
initial: () => Button.filled(
onPressed: () {
context.read<DataSyncBloc>().add(const DataSyncEvent.startSync());
},
label: 'Mulai Sinkronisasi',
),
syncing: (step, progress, message) => Button.outlined(
onPressed: () {
context.read<DataSyncBloc>().add(const DataSyncEvent.cancelSync());
},
label: 'Batalkan',
),
completed: (stats) => Button.filled(
onPressed: () {
context.pushReplacement(DashboardPage());
},
label: 'Lanjutkan ke Aplikasi',
),
error: (message) => Row(
children: [
Expanded(
child: Button.outlined(
onPressed: () {
context.pushReplacement(DashboardPage());
},
label: 'Lewati',
),
),
SizedBox(width: 16),
Expanded(
child: Button.filled(
onPressed: () {
context
.read<DataSyncBloc>()
.add(const DataSyncEvent.startSync());
},
label: 'Coba Lagi',
),
),
],
),
);
}
IconData _getSyncIcon(SyncStep step) {
switch (step) {
case SyncStep.products:
return Icons.inventory_2;
case SyncStep.categories:
return Icons.category;
case SyncStep.variants:
return Icons.tune;
case SyncStep.completed:
return Icons.check_circle;
}
}
String _getStepLabel(SyncStep step) {
switch (step) {
case SyncStep.products:
return 'Mengunduh Produk';
case SyncStep.categories:
return 'Mengunduh Kategori';
case SyncStep.variants:
return 'Mengunduh Variant';
case SyncStep.completed:
return 'Selesai';
}
}
}

View File

@ -1,8 +1,8 @@
import 'dart:async';
import 'package:bloc/bloc.dart';
import 'package:enaklo_pos/data/datasources/product_remote_datasource.dart';
import 'dart:developer';
import 'package:enaklo_pos/data/models/response/product_response_model.dart';
import 'package:enaklo_pos/data/repositories/product/product_repository.dart';
import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:freezed_annotation/freezed_annotation.dart';
part 'product_loader_event.dart';
@ -10,102 +10,114 @@ part 'product_loader_state.dart';
part 'product_loader_bloc.freezed.dart';
class ProductLoaderBloc extends Bloc<ProductLoaderEvent, ProductLoaderState> {
final ProductRemoteDatasource _productRemoteDatasource;
final ProductRepository _productRepository = ProductRepository.instance;
// Debouncing untuk mencegah multiple load more calls
Timer? _loadMoreDebounce;
Timer? _searchDebounce;
bool _isLoadingMore = false;
ProductLoaderBloc(this._productRemoteDatasource)
: super(ProductLoaderState.initial()) {
ProductLoaderBloc() : super(const ProductLoaderState.initial()) {
on<_GetProduct>(_onGetProduct);
on<_LoadMore>(_onLoadMore);
on<_Refresh>(_onRefresh);
on<_SearchProduct>(_onSearchProduct);
on<_GetDatabaseStats>(_onGetDatabaseStats);
on<_ClearCache>(_onClearCache);
}
@override
Future<void> close() {
_loadMoreDebounce?.cancel();
_searchDebounce?.cancel();
return super.close();
}
// Debounce transformer untuk load more
// EventTransformer<T> _debounceTransformer<T>() {
// return (events, mapper) {
// return events
// .debounceTime(const Duration(milliseconds: 300))
// .asyncExpand(mapper);
// };
// }
// Initial load
// Pure local product loading
Future<void> _onGetProduct(
_GetProduct event,
Emitter<ProductLoaderState> emit,
) async {
emit(const _Loading());
_isLoadingMore = false; // Reset loading state
emit(const ProductLoaderState.loading());
_isLoadingMore = false;
final result = await _productRemoteDatasource.getProducts(
log('📱 Loading local products - categoryId: ${event.categoryId}');
// Check if local database is ready
final isReady = await _productRepository.isLocalDatabaseReady();
if (!isReady) {
emit(const ProductLoaderState.error(
'Database lokal belum siap. Silakan lakukan sinkronisasi data terlebih dahulu.'));
return;
}
final result = await _productRepository.getProducts(
page: 1,
limit: 10,
categoryId: event.categoryId,
search: event.search,
);
await result.fold(
(failure) async => emit(_Error(failure)),
(failure) async {
log('❌ Error loading local products: $failure');
emit(ProductLoaderState.error(failure));
},
(response) async {
final products = response.data?.products ?? [];
final hasReachedMax = products.length < 10;
final totalPages = response.data?.totalPages ?? 1;
final hasReachedMax = products.length < 10 || 1 >= totalPages;
emit(_Loaded(
log('âś… Local products loaded: ${products.length}, hasReachedMax: $hasReachedMax, totalPages: $totalPages');
emit(ProductLoaderState.loaded(
products: products,
hasReachedMax: hasReachedMax,
currentPage: 1,
isLoadingMore: false,
categoryId: event.categoryId,
searchQuery: event.search,
));
},
);
}
// Load more with enhanced debouncing
// Pure local load more
Future<void> _onLoadMore(
_LoadMore event,
Emitter<ProductLoaderState> emit,
) async {
final currentState = state;
// Enhanced validation
if (currentState is! _Loaded ||
currentState.hasReachedMax ||
_isLoadingMore ||
currentState.isLoadingMore) {
log('⏹️ Load more blocked - state: ${currentState.runtimeType}, isLoadingMore: $_isLoadingMore');
return;
}
_isLoadingMore = true;
// Emit loading more state
emit(currentState.copyWith(isLoadingMore: true));
final nextPage = currentState.currentPage + 1;
log('đź“„ Loading more local products - page: $nextPage');
try {
final result = await _productRemoteDatasource.getProducts(
final result = await _productRepository.getProducts(
page: nextPage,
limit: 10,
categoryId: event.categoryId,
categoryId: currentState.categoryId,
search: currentState.searchQuery,
);
await result.fold(
(failure) async {
// On error, revert loading state but don't show error
// Just silently fail and allow retry
log('❌ Error loading more local products: $failure');
emit(currentState.copyWith(isLoadingMore: false));
_isLoadingMore = false;
},
(response) async {
final newProducts = response.data?.products ?? [];
final totalPages = response.data?.totalPages ?? 1;
// Prevent duplicate products
final currentProductIds =
@ -117,32 +129,130 @@ class ProductLoaderBloc extends Bloc<ProductLoaderEvent, ProductLoaderState> {
final allProducts = List<Product>.from(currentState.products)
..addAll(filteredNewProducts);
final hasReachedMax = newProducts.length < 10;
final hasReachedMax =
newProducts.length < 10 || nextPage >= totalPages;
emit(_Loaded(
log('âś… More local products loaded: ${filteredNewProducts.length} new, total: ${allProducts.length}');
emit(ProductLoaderState.loaded(
products: allProducts,
hasReachedMax: hasReachedMax,
currentPage: nextPage,
isLoadingMore: false,
categoryId: currentState.categoryId,
searchQuery: currentState.searchQuery,
));
_isLoadingMore = false;
},
);
} catch (e) {
// Handle unexpected errors
log('❌ Exception loading more local products: $e');
emit(currentState.copyWith(isLoadingMore: false));
} finally {
_isLoadingMore = false;
}
}
// Refresh data
// Pure local refresh
Future<void> _onRefresh(
_Refresh event,
Emitter<ProductLoaderState> emit,
) async {
final currentState = state;
String? categoryId;
String? searchQuery;
if (currentState is _Loaded) {
categoryId = currentState.categoryId;
searchQuery = currentState.searchQuery;
}
_isLoadingMore = false;
_loadMoreDebounce?.cancel();
add(const _GetProduct());
_searchDebounce?.cancel();
log('🔄 Refreshing local products');
// Clear local cache
_productRepository.clearCache();
add(ProductLoaderEvent.getProduct(
categoryId: categoryId,
search: searchQuery,
));
}
// Fast local search (no debouncing needed for local data)
Future<void> _onSearchProduct(
_SearchProduct event,
Emitter<ProductLoaderState> emit,
) async {
// Cancel previous search
_searchDebounce?.cancel();
// Minimal debounce for local search (much faster)
_searchDebounce = Timer(Duration(milliseconds: 150), () async {
emit(const ProductLoaderState.loading());
_isLoadingMore = false;
log('🔍 Local search: "${event.query}"');
final result = await _productRepository.getProducts(
page: 1,
limit: 20, // More results for search
categoryId: event.categoryId,
search: event.query,
);
await result.fold(
(failure) async {
log('❌ Local search error: $failure');
emit(ProductLoaderState.error(failure));
},
(response) async {
final products = response.data?.products ?? [];
final totalPages = response.data?.totalPages ?? 1;
final hasReachedMax = products.length < 20 || 1 >= totalPages;
log('âś… Local search results: ${products.length} products found');
emit(ProductLoaderState.loaded(
products: products,
hasReachedMax: hasReachedMax,
currentPage: 1,
isLoadingMore: false,
categoryId: event.categoryId,
searchQuery: event.query,
));
},
);
});
}
// Get local database statistics
Future<void> _onGetDatabaseStats(
_GetDatabaseStats event,
Emitter<ProductLoaderState> emit,
) async {
try {
final stats = await _productRepository.getDatabaseStats();
log('📊 Local database stats retrieved: $stats');
// You can emit a special state here if needed for UI updates
// For now, just log the stats
} catch (e) {
log('❌ Error getting local database stats: $e');
}
}
// Clear local cache
Future<void> _onClearCache(
_ClearCache event,
Emitter<ProductLoaderState> emit,
) async {
log('đź§ą Manually clearing local cache');
_productRepository.clearCache();
// Refresh current data after cache clear
add(const ProductLoaderEvent.refresh());
}
}

View File

@ -2,9 +2,25 @@ part of 'product_loader_bloc.dart';
@freezed
class ProductLoaderEvent with _$ProductLoaderEvent {
const factory ProductLoaderEvent.getProduct(
{String? categoryId, String? search}) = _GetProduct;
const factory ProductLoaderEvent.loadMore(
{String? categoryId, String? search}) = _LoadMore;
const factory ProductLoaderEvent.getProduct({
String? categoryId,
String? search, // Added search parameter
bool? forceRefresh, // Kept for compatibility but ignored
}) = _GetProduct;
const factory ProductLoaderEvent.loadMore({
String? categoryId,
String? search,
}) = _LoadMore;
const factory ProductLoaderEvent.refresh() = _Refresh;
const factory ProductLoaderEvent.searchProduct({
String? query,
String? categoryId,
}) = _SearchProduct;
const factory ProductLoaderEvent.getDatabaseStats() = _GetDatabaseStats;
const factory ProductLoaderEvent.clearCache() = _ClearCache;
}

View File

@ -9,6 +9,8 @@ class ProductLoaderState with _$ProductLoaderState {
required bool hasReachedMax,
required int currentPage,
required bool isLoadingMore,
String? categoryId,
String? searchQuery,
}) = _Loaded;
const factory ProductLoaderState.error(String message) = _Error;
}

View File

@ -1,5 +1,11 @@
// ignore_for_file: public_member_api_docs, sort_constructors_first
// ========================================
// OFFLINE-ONLY HOMEPAGE - NO API CALLS
// lib/presentation/home/pages/home_page.dart
// ========================================
import 'dart:developer';
import 'package:enaklo_pos/core/components/flushbar.dart';
import 'package:enaklo_pos/data/datasources/product/product_local_datasource.dart';
import 'package:enaklo_pos/presentation/home/bloc/category_loader/category_loader_bloc.dart';
import 'package:enaklo_pos/presentation/home/bloc/current_outlet/current_outlet_bloc.dart';
import 'package:enaklo_pos/presentation/home/bloc/product_loader/product_loader_bloc.dart';
@ -44,48 +50,70 @@ class _HomePageState extends State<HomePage> {
final ScrollController scrollController = ScrollController();
String searchQuery = '';
test() async {
// await AuthLocalDataSource().removeAuthData();
}
// Local database only
Map<String, dynamic> _databaseStats = {};
final ProductLocalDatasource _localDatasource =
ProductLocalDatasource.instance;
bool _isLoadingStats = true;
@override
void initState() {
test();
// First sync products from API, then load local products
_syncAndLoadProducts();
super.initState();
_initializeLocalData();
_loadProducts();
}
@override
void dispose() {
// Properly dispose controllers
searchController.dispose();
scrollController.dispose();
super.dispose();
}
void _syncAndLoadProducts() {
// Trigger sync from API first
// context.read<SyncProductBloc>().add(const SyncProductEvent.syncProduct());
// Initialize local data only
void _initializeLocalData() {
_loadDatabaseStats();
}
// Also load local products initially in case sync fails or takes time
// context
// .read<LocalProductBloc>()
// .add(const LocalProductEvent.getLocalProduct());
// Load database statistics
void _loadDatabaseStats() async {
try {
final stats = await _localDatasource.getDatabaseStats();
if (mounted) {
setState(() {
_databaseStats = stats;
_isLoadingStats = false;
});
}
log('📊 Local database stats: $stats');
} catch (e) {
log('❌ Error loading local stats: $e');
setState(() {
_isLoadingStats = false;
});
}
}
void _loadProducts() {
log('📱 Loading products from local database only...');
// Load products from local database only
context
.read<ProductLoaderBloc>()
.add(const ProductLoaderEvent.getProduct());
// Initialize checkout with tax and service charge settings
// Initialize other components
context.read<CheckoutBloc>().add(CheckoutEvent.started(widget.items));
// Get Category
context.read<CategoryLoaderBloc>().add(CategoryLoaderEvent.get());
// Get Outlets
context.read<CurrentOutletBloc>().add(CurrentOutletEvent.currentOutlet());
}
void _refreshLocalData() {
log('🔄 Refreshing local data...');
context.read<ProductLoaderBloc>().add(const ProductLoaderEvent.refresh());
_loadDatabaseStats();
}
void onCategoryTap(int index) {
searchController.clear();
setState(() {
@ -97,10 +125,10 @@ class _HomePageState extends State<HomePage> {
ScrollNotification notification, String? categoryId) {
if (notification is ScrollEndNotification &&
scrollController.position.extentAfter == 0) {
log('đź“„ Loading more local products for category: $categoryId');
context.read<ProductLoaderBloc>().add(
ProductLoaderEvent.loadMore(
categoryId: categoryId,
search: searchQuery,
),
);
return true;
@ -130,133 +158,562 @@ class _HomePageState extends State<HomePage> {
tag: 'confirmation_screen',
child: Scaffold(
backgroundColor: AppColors.white,
body: Row(
body: Column(
children: [
// Local database indicator
_buildLocalModeIndicator(),
// Main content
Expanded(
child: Row(
children: [
// Left panel - Products
Expanded(
flex: 3,
child: Align(
alignment: AlignmentDirectional.topStart,
child: BlocBuilder<CategoryLoaderBloc, CategoryLoaderState>(
child: BlocBuilder<CategoryLoaderBloc,
CategoryLoaderState>(
builder: (context, state) {
return state.maybeWhen(
orElse: () => Center(
child: CircularProgressIndicator(),
),
orElse: () =>
Center(child: CircularProgressIndicator()),
loaded: (categories, categoryId) => Column(
mainAxisAlignment: MainAxisAlignment.start,
children: [
// Enhanced home title with local stats
_buildLocalHomeTitle(categoryId),
// Products section
Expanded(
child: BlocBuilder<ProductLoaderBloc,
ProductLoaderState>(
builder: (context, productState) {
return CategoryTabBar(
categories: categories,
tabViews: categories.map((category) {
return SizedBox(
child: productState.maybeWhen(
orElse: () =>
_buildLoadingState(),
loading: () =>
_buildLoadingState(),
loaded: (products,
hasReachedMax,
currentPage,
isLoadingMore,
categoryId,
searchQuery) {
if (products.isEmpty) {
return _buildEmptyState(
categoryId);
}
return _buildProductGrid(
products,
hasReachedMax,
isLoadingMore,
categoryId,
currentPage,
);
},
error: (message) =>
_buildErrorState(
message, categoryId),
),
);
}).toList(),
);
},
),
),
],
),
);
},
),
),
),
// Right panel - Cart (unchanged)
Expanded(
flex: 2,
child: _buildCartSection(),
),
],
),
),
],
),
),
),
);
}
// Local mode indicator
Widget _buildLocalModeIndicator() {
return Container(
width: double.infinity,
padding: EdgeInsets.symmetric(vertical: 8, horizontal: 16),
color: Colors.blue.shade600,
child: Row(
children: [
Icon(Icons.storage, color: Colors.white, size: 16),
SizedBox(width: 8),
Expanded(
child: Text(
_isLoadingStats
? 'Mode Lokal - Memuat data...'
: 'Mode Lokal - ${_databaseStats['total_products'] ?? 0} produk tersimpan',
style: TextStyle(
color: Colors.white,
fontSize: 13,
fontWeight: FontWeight.w500,
),
),
),
if (_databaseStats.isNotEmpty) ...[
Text(
'${(_databaseStats['database_size_mb'] ?? 0.0).toStringAsFixed(1)} MB',
style: TextStyle(
color: Colors.white.withOpacity(0.8),
fontSize: 11,
),
),
SizedBox(width: 8),
],
InkWell(
onTap: _refreshLocalData,
child: Container(
padding: EdgeInsets.all(4),
decoration: BoxDecoration(
color: Colors.white.withOpacity(0.2),
borderRadius: BorderRadius.circular(4),
),
child: Icon(Icons.refresh, color: Colors.white, size: 14),
),
),
],
),
);
}
// Enhanced home title with local stats only
Widget _buildLocalHomeTitle(String? categoryId) {
return Container(
padding: EdgeInsets.all(16),
decoration: BoxDecoration(
color: Colors.white,
border: Border(bottom: BorderSide(color: Colors.grey.shade200)),
),
child: Column(
children: [
// Original HomeTitle with faster search
HomeTitle(
controller: searchController,
onChanged: (value) {
setState(() {
searchQuery = value;
});
Future.delayed(Duration(milliseconds: 600), () {
// Fast local search - no debounce needed for local data
Future.delayed(Duration(milliseconds: 200), () {
if (value == searchController.text) {
log('🔍 Local search: "$value"');
context.read<ProductLoaderBloc>().add(
ProductLoaderEvent.getProduct(
ProductLoaderEvent.searchProduct(
categoryId: categoryId,
search: value,
query: value,
),
);
}
});
},
),
BlocBuilder<ProductLoaderBloc, ProductLoaderState>(
builder: (context, state) {
return Expanded(
child: CategoryTabBar(
categories: categories,
tabViews: categories.map((category) {
return SizedBox(
child: state.maybeWhen(orElse: () {
return const Center(
child: CircularProgressIndicator(),
);
}, loading: () {
return const Center(
child: CircularProgressIndicator(),
);
}, loaded: (products, hashasReachedMax,
currentPage, isLoadingMore) {
if (products.isEmpty) {
return Center(
child: Column(
// Local database stats
if (_databaseStats.isNotEmpty) ...[
SizedBox(height: 8),
Row(
children: [
Text('No Items Found'),
SpaceHeight(20),
Button.filled(
width: 120,
onPressed: () {
context
.read<
ProductLoaderBloc>()
.add(const ProductLoaderEvent
.getProduct());
// Local storage indicator
Container(
padding: EdgeInsets.symmetric(horizontal: 6, vertical: 3),
decoration: BoxDecoration(
color: Colors.blue.shade50,
borderRadius: BorderRadius.circular(10),
),
child: Row(
mainAxisSize: MainAxisSize.min,
children: [
Icon(Icons.storage,
size: 12, color: Colors.blue.shade600),
SizedBox(width: 3),
Text(
'Lokal',
style: TextStyle(
fontSize: 10,
color: Colors.blue.shade600,
fontWeight: FontWeight.w500,
),
),
],
),
),
SizedBox(width: 8),
// Database stats chips
_buildStatChip(
'${_databaseStats['total_products'] ?? 0}',
'produk',
Icons.inventory_2,
Colors.green,
),
SizedBox(width: 6),
_buildStatChip(
'${_databaseStats['total_variants'] ?? 0}',
'varian',
Icons.tune,
Colors.orange,
),
SizedBox(width: 6),
_buildStatChip(
'${_databaseStats['cache_entries'] ?? 0}',
'cache',
Icons.memory,
Colors.purple,
),
Spacer(),
// Clear cache button
InkWell(
onTap: () {
_localDatasource.clearExpiredCache();
_loadDatabaseStats();
AppFlushbar.showSuccess(context, 'Cache dibersihkan');
},
label: 'Retry',
child: Container(
padding: EdgeInsets.all(5),
decoration: BoxDecoration(
color: Colors.grey.shade100,
borderRadius: BorderRadius.circular(5),
),
child: Icon(
Icons.clear_all,
size: 14,
color: Colors.grey.shade600,
),
),
),
SizedBox(width: 4),
// Refresh button
InkWell(
onTap: _refreshLocalData,
child: Container(
padding: EdgeInsets.all(5),
decoration: BoxDecoration(
color: AppColors.primary.withOpacity(0.1),
borderRadius: BorderRadius.circular(5),
),
child: Icon(
Icons.refresh,
size: 14,
color: AppColors.primary,
),
),
),
],
),
],
],
),
);
}
Widget _buildStatChip(
String value, String label, IconData icon, Color color) {
return Container(
padding: EdgeInsets.symmetric(horizontal: 5, vertical: 2),
decoration: BoxDecoration(
color: color.withOpacity(0.1),
borderRadius: BorderRadius.circular(6),
),
child: Row(
mainAxisSize: MainAxisSize.min,
children: [
Icon(icon, size: 10, color: color),
SizedBox(width: 2),
Text(
value,
style: TextStyle(
fontSize: 9,
fontWeight: FontWeight.w600,
color: color,
),
),
SizedBox(width: 1),
Text(
label,
style: TextStyle(
fontSize: 8,
color: color.withOpacity(0.8),
),
),
],
),
);
}
return NotificationListener<
ScrollNotification>(
onNotification: (notification) {
return _handleScrollNotification(
notification, categoryId);
Widget _buildLoadingState() {
return Center(
child: Column(
mainAxisAlignment: MainAxisAlignment.center,
children: [
CircularProgressIndicator(color: AppColors.primary),
SizedBox(height: 16),
Text(
'Memuat data lokal...',
style: TextStyle(color: Colors.grey.shade600),
),
],
),
);
}
Widget _buildEmptyState(String? categoryId) {
return Center(
child: Column(
mainAxisAlignment: MainAxisAlignment.center,
children: [
Assets.icons.noProduct.svg(),
SizedBox(height: 20),
Text(
searchQuery.isNotEmpty
? 'Produk "$searchQuery" tidak ditemukan'
: 'Belum ada data produk lokal',
textAlign: TextAlign.center,
),
SizedBox(height: 8),
Text(
'Tambahkan produk ke database lokal terlebih dahulu',
style: TextStyle(
color: Colors.grey.shade600,
fontSize: 12,
),
textAlign: TextAlign.center,
),
SpaceHeight(20),
Row(
mainAxisAlignment: MainAxisAlignment.center,
children: [
if (searchQuery.isNotEmpty) ...[
Button.filled(
width: 100,
onPressed: () {
searchController.clear();
setState(() => searchQuery = '');
context.read<ProductLoaderBloc>().add(
ProductLoaderEvent.getProduct(categoryId: categoryId),
);
},
label: 'Reset',
),
SizedBox(width: 12),
],
Button.filled(
width: 120,
onPressed: () {
context.read<ProductLoaderBloc>().add(
ProductLoaderEvent.getProduct(categoryId: categoryId),
);
},
label: 'Muat Ulang',
),
],
),
],
),
);
}
Widget _buildErrorState(String message, String? categoryId) {
return Center(
child: Column(
mainAxisAlignment: MainAxisAlignment.center,
children: [
Icon(
Icons.error_outline,
size: 48,
color: Colors.red.shade400,
),
SizedBox(height: 16),
Text(
'Error Database Lokal',
style: TextStyle(
fontSize: 16,
fontWeight: FontWeight.w600,
),
),
SizedBox(height: 8),
Padding(
padding: EdgeInsets.symmetric(horizontal: 32),
child: Text(
message,
textAlign: TextAlign.center,
style: TextStyle(color: Colors.grey.shade600),
),
),
SizedBox(height: 16),
Button.filled(
width: 120,
onPressed: () {
context.read<ProductLoaderBloc>().add(
ProductLoaderEvent.getProduct(categoryId: categoryId),
);
},
label: 'Coba Lagi',
),
],
),
);
}
Widget _buildProductGrid(
List products,
bool hasReachedMax,
bool isLoadingMore,
String? categoryId,
int currentPage,
) {
return Column(
children: [
// Product count with local indicator
if (products.isNotEmpty)
Container(
padding: EdgeInsets.symmetric(horizontal: 16, vertical: 6),
child: Row(
children: [
Container(
padding: EdgeInsets.symmetric(horizontal: 4, vertical: 1),
decoration: BoxDecoration(
color: Colors.blue.shade50,
borderRadius: BorderRadius.circular(4),
),
child: Row(
mainAxisSize: MainAxisSize.min,
children: [
Icon(Icons.storage,
size: 10, color: Colors.blue.shade600),
SizedBox(width: 2),
Text(
'${products.length}',
style: TextStyle(
fontSize: 11,
fontWeight: FontWeight.w600,
color: Colors.blue.shade600,
),
),
],
),
),
SizedBox(width: 6),
Text(
'produk dari database lokal',
style: TextStyle(
color: Colors.grey.shade600,
fontSize: 11,
),
),
if (currentPage > 1) ...[
SizedBox(width: 6),
Container(
padding: EdgeInsets.symmetric(horizontal: 4, vertical: 1),
decoration: BoxDecoration(
color: AppColors.primary.withOpacity(0.1),
borderRadius: BorderRadius.circular(4),
),
child: Text(
'Hal $currentPage',
style: TextStyle(
color: AppColors.primary,
fontSize: 9,
fontWeight: FontWeight.w500,
),
),
),
],
Spacer(),
if (isLoadingMore)
SizedBox(
width: 12,
height: 12,
child: CircularProgressIndicator(
strokeWidth: 2,
color: AppColors.primary,
),
),
],
),
),
// Products grid - faster loading from local DB
Expanded(
child: NotificationListener<ScrollNotification>(
onNotification: (notification) =>
_handleScrollNotification(notification, categoryId),
child: GridView.builder(
itemCount: products.length,
controller: scrollController,
padding: const EdgeInsets.all(16),
cacheExtent: 80.0,
gridDelegate:
SliverGridDelegateWithMaxCrossAxisExtent(
cacheExtent: 200.0, // Bigger cache for smooth scrolling
gridDelegate: SliverGridDelegateWithMaxCrossAxisExtent(
maxCrossAxisExtent: 180,
mainAxisSpacing: 30,
crossAxisSpacing: 30,
childAspectRatio: 180 / 240,
),
itemBuilder: (context, index) =>
ProductCard(
itemBuilder: (context, index) => ProductCard(
data: products[index],
onCartButton: () {},
),
),
);
}),
);
}).toList(),
),
);
onCartButton: () {
// Cart functionality
},
),
),
),
),
// End of data indicator
if (hasReachedMax && products.isNotEmpty)
Container(
padding: EdgeInsets.all(8),
child: Text(
'Semua produk lokal telah dimuat',
style: TextStyle(
color: Colors.grey.shade500,
fontSize: 11,
),
),
),
],
),
);
},
),
),
),
Expanded(
flex: 2,
child: Align(
}
// Cart section (unchanged from original)
Widget _buildCartSection() {
return Align(
alignment: Alignment.topCenter,
child: Material(
color: Colors.white,
child: Column(
children: [
HomeRightTitle(
table: widget.table,
),
HomeRightTitle(table: widget.table),
Padding(
padding: const EdgeInsets.all(16.0)
.copyWith(bottom: 0, top: 27),
padding: const EdgeInsets.all(16.0).copyWith(bottom: 0, top: 27),
child: Column(
children: [
const Row(
mainAxisAlignment:
MainAxisAlignment.spaceBetween,
mainAxisAlignment: MainAxisAlignment.spaceBetween,
children: [
Text(
'Item',
@ -266,9 +723,7 @@ class _HomePageState extends State<HomePage> {
fontWeight: FontWeight.w600,
),
),
SizedBox(
width: 130,
),
SizedBox(width: 130),
SizedBox(
width: 50.0,
child: Text(
@ -301,11 +756,8 @@ class _HomePageState extends State<HomePage> {
child: BlocBuilder<CheckoutBloc, CheckoutState>(
builder: (context, state) {
return state.maybeWhen(
orElse: () => const Center(
child: Text('No Items'),
),
loaded: (
products,
orElse: () => const Center(child: Text('No Items')),
loaded: (products,
discountModel,
discount,
discountAmount,
@ -315,17 +767,13 @@ class _HomePageState extends State<HomePage> {
totalPrice,
draftName,
orderType,
deliveryType,
) {
deliveryType) {
if (products.isEmpty) {
return const Center(
child: Text('No Items'),
);
return const Center(child: Text('No Items'));
}
return ListView.separated(
shrinkWrap: true,
padding: const EdgeInsets.symmetric(
horizontal: 16),
padding: const EdgeInsets.symmetric(horizontal: 16),
itemBuilder: (context, index) =>
OrderMenu(data: products[index]),
separatorBuilder: (context, index) =>
@ -337,6 +785,8 @@ class _HomePageState extends State<HomePage> {
},
),
),
// Payment section (unchanged)
Padding(
padding: const EdgeInsets.all(16.0).copyWith(top: 0),
child: Column(
@ -344,8 +794,7 @@ class _HomePageState extends State<HomePage> {
const Divider(),
const SpaceHeight(16.0),
Row(
mainAxisAlignment:
MainAxisAlignment.spaceBetween,
mainAxisAlignment: MainAxisAlignment.spaceBetween,
children: [
const Text(
'Pajak',
@ -358,8 +807,7 @@ class _HomePageState extends State<HomePage> {
builder: (context, state) {
final tax = state.maybeWhen(
orElse: () => 0,
loaded: (
products,
loaded: (products,
discountModel,
discount,
discountAmount,
@ -369,13 +817,11 @@ class _HomePageState extends State<HomePage> {
totalPrice,
draftName,
orderType,
deliveryType,
) {
if (products.isEmpty) {
return 0;
}
deliveryType) {
if (products.isEmpty) return 0;
return tax;
});
},
);
return Text(
'$tax %',
style: const TextStyle(
@ -389,8 +835,7 @@ class _HomePageState extends State<HomePage> {
),
const SpaceHeight(16.0),
Row(
mainAxisAlignment:
MainAxisAlignment.spaceBetween,
mainAxisAlignment: MainAxisAlignment.spaceBetween,
children: [
const Text(
'Sub total',
@ -414,19 +859,14 @@ class _HomePageState extends State<HomePage> {
draftName,
orderType,
deliveryType) {
if (products.isEmpty) {
return 0;
}
if (products.isEmpty) return 0;
return products
.map((e) =>
(e.product.price! *
e.quantity) +
(e.variant?.priceModifier ??
0))
.reduce((value, element) =>
value + element);
});
(e.product.price! * e.quantity) +
(e.variant?.priceModifier ?? 0))
.reduce((value, element) => value + element);
},
);
return Text(
price.currencyFormatRp,
style: const TextStyle(
@ -450,9 +890,7 @@ class _HomePageState extends State<HomePage> {
disabled: true,
onPressed: () {
context.push(ConfirmPaymentPage(
isTable: widget.table == null
? false
: true,
isTable: widget.table == null ? false : true,
table: widget.table,
));
},
@ -483,18 +921,14 @@ class _HomePageState extends State<HomePage> {
'Mohon pilih meja terlebih dahulu');
return;
}
if (orderType.name == 'delivery' &&
deliveryType == null) {
AppFlushbar.showError(context,
'Mohon pilih pengiriman terlebih dahulu');
return;
}
context.push(ConfirmPaymentPage(
isTable: widget.table == null
? false
: true,
isTable: widget.table == null ? false : true,
table: widget.table,
));
},
@ -510,34 +944,6 @@ class _HomePageState extends State<HomePage> {
],
),
),
),
),
],
),
),
),
);
}
}
// ignore: unused_element
class _IsEmpty extends StatelessWidget {
const _IsEmpty();
@override
Widget build(BuildContext context) {
return Column(
mainAxisAlignment: MainAxisAlignment.center,
children: [
SpaceHeight(40),
Assets.icons.noProduct.svg(),
const SizedBox(height: 40.0),
const Text(
'Belum Ada Produk',
textAlign: TextAlign.center,
style: TextStyle(fontSize: 16),
),
],
);
}
}

View File

@ -1030,7 +1030,7 @@ packages:
source: hosted
version: "2.1.1"
path:
dependency: transitive
dependency: "direct main"
description:
name: path
sha256: "75cca69d1490965be98c73ceaea117e8a04dd21217b37b292c9ddbec0d955bc5"

View File

@ -69,6 +69,7 @@ dependencies:
syncfusion_flutter_datepicker: ^30.2.5
firebase_core: ^4.1.0
firebase_crashlytics: ^5.0.1
path: ^1.9.1
# imin_printer: ^0.6.10
dev_dependencies: