Compare commits
2 Commits
44402140fb
...
5b980d237f
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5b980d237f | ||
|
|
c12d6525fa |
@ -23,7 +23,7 @@ class DatabaseHelper {
|
|||||||
|
|
||||||
return await openDatabase(
|
return await openDatabase(
|
||||||
path,
|
path,
|
||||||
version: 2, // Updated version for printer table
|
version: 3, // Updated version for categories table
|
||||||
onCreate: _onCreate,
|
onCreate: _onCreate,
|
||||||
onUpgrade: _onUpgrade,
|
onUpgrade: _onUpgrade,
|
||||||
);
|
);
|
||||||
@ -66,7 +66,22 @@ class DatabaseHelper {
|
|||||||
)
|
)
|
||||||
''');
|
''');
|
||||||
|
|
||||||
// Printer table - NEW
|
// Categories table - NEW
|
||||||
|
await db.execute('''
|
||||||
|
CREATE TABLE categories (
|
||||||
|
id TEXT PRIMARY KEY,
|
||||||
|
organization_id TEXT,
|
||||||
|
name TEXT NOT NULL,
|
||||||
|
description TEXT,
|
||||||
|
business_type TEXT,
|
||||||
|
metadata TEXT,
|
||||||
|
is_active INTEGER DEFAULT 1,
|
||||||
|
created_at TEXT,
|
||||||
|
updated_at TEXT
|
||||||
|
)
|
||||||
|
''');
|
||||||
|
|
||||||
|
// Printer table
|
||||||
await db.execute('''
|
await db.execute('''
|
||||||
CREATE TABLE printers (
|
CREATE TABLE printers (
|
||||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||||
@ -85,6 +100,11 @@ class DatabaseHelper {
|
|||||||
'CREATE INDEX idx_products_category_id ON products(category_id)');
|
'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_name ON products(name)');
|
||||||
await db.execute('CREATE INDEX idx_products_sku ON products(sku)');
|
await db.execute('CREATE INDEX idx_products_sku ON products(sku)');
|
||||||
|
await db.execute('CREATE INDEX idx_categories_name ON categories(name)');
|
||||||
|
await db.execute(
|
||||||
|
'CREATE INDEX idx_categories_organization_id ON categories(organization_id)');
|
||||||
|
await db.execute(
|
||||||
|
'CREATE INDEX idx_categories_is_active ON categories(is_active)');
|
||||||
await db.execute('CREATE INDEX idx_printers_code ON printers(code)');
|
await db.execute('CREATE INDEX idx_printers_code ON printers(code)');
|
||||||
await db.execute('CREATE INDEX idx_printers_type ON printers(type)');
|
await db.execute('CREATE INDEX idx_printers_type ON printers(type)');
|
||||||
}
|
}
|
||||||
@ -105,10 +125,32 @@ class DatabaseHelper {
|
|||||||
)
|
)
|
||||||
''');
|
''');
|
||||||
|
|
||||||
// Add indexes for printer table
|
|
||||||
await db.execute('CREATE INDEX idx_printers_code ON printers(code)');
|
await db.execute('CREATE INDEX idx_printers_code ON printers(code)');
|
||||||
await db.execute('CREATE INDEX idx_printers_type ON printers(type)');
|
await db.execute('CREATE INDEX idx_printers_type ON printers(type)');
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (oldVersion < 3) {
|
||||||
|
// Add categories table in version 3
|
||||||
|
await db.execute('''
|
||||||
|
CREATE TABLE categories (
|
||||||
|
id TEXT PRIMARY KEY,
|
||||||
|
organization_id TEXT,
|
||||||
|
name TEXT NOT NULL,
|
||||||
|
description TEXT,
|
||||||
|
business_type TEXT,
|
||||||
|
metadata TEXT,
|
||||||
|
is_active INTEGER DEFAULT 1,
|
||||||
|
created_at TEXT,
|
||||||
|
updated_at TEXT
|
||||||
|
)
|
||||||
|
''');
|
||||||
|
|
||||||
|
await db.execute('CREATE INDEX idx_categories_name ON categories(name)');
|
||||||
|
await db.execute(
|
||||||
|
'CREATE INDEX idx_categories_organization_id ON categories(organization_id)');
|
||||||
|
await db.execute(
|
||||||
|
'CREATE INDEX idx_categories_is_active ON categories(is_active)');
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
Future<void> close() async {
|
Future<void> close() async {
|
||||||
|
|||||||
373
lib/data/datasources/category/category_local_datasource.dart
Normal file
373
lib/data/datasources/category/category_local_datasource.dart
Normal file
@ -0,0 +1,373 @@
|
|||||||
|
import 'dart:convert';
|
||||||
|
import 'dart:developer';
|
||||||
|
import 'package:enaklo_pos/core/database/database_handler.dart';
|
||||||
|
import 'package:enaklo_pos/data/models/response/category_response_model.dart';
|
||||||
|
import 'package:sqflite/sqflite.dart';
|
||||||
|
|
||||||
|
class CategoryLocalDatasource {
|
||||||
|
static CategoryLocalDatasource? _instance;
|
||||||
|
|
||||||
|
CategoryLocalDatasource._internal();
|
||||||
|
|
||||||
|
static CategoryLocalDatasource get instance {
|
||||||
|
_instance ??= CategoryLocalDatasource._internal();
|
||||||
|
return _instance!;
|
||||||
|
}
|
||||||
|
|
||||||
|
Future<Database> get _db async => await DatabaseHelper.instance.database;
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// CACHING SYSTEM
|
||||||
|
// ========================================
|
||||||
|
final Map<String, List<CategoryModel>> _queryCache = {};
|
||||||
|
final Duration _cacheExpiry =
|
||||||
|
Duration(minutes: 10); // Lebih lama untuk categories
|
||||||
|
final Map<String, DateTime> _cacheTimestamps = {};
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// BATCH SAVE CATEGORIES
|
||||||
|
// ========================================
|
||||||
|
Future<void> saveCategoriesBatch(List<CategoryModel> categories,
|
||||||
|
{bool clearFirst = false}) async {
|
||||||
|
final db = await _db;
|
||||||
|
|
||||||
|
try {
|
||||||
|
await db.transaction((txn) async {
|
||||||
|
if (clearFirst) {
|
||||||
|
log('🗑️ Clearing existing categories...');
|
||||||
|
await txn.delete('categories');
|
||||||
|
}
|
||||||
|
|
||||||
|
log('💾 Batch saving ${categories.length} categories...');
|
||||||
|
|
||||||
|
// Batch insert categories
|
||||||
|
final batch = txn.batch();
|
||||||
|
for (final category in categories) {
|
||||||
|
batch.insert(
|
||||||
|
'categories',
|
||||||
|
_categoryToMap(category),
|
||||||
|
conflictAlgorithm: ConflictAlgorithm.replace,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
await batch.commit(noResult: true);
|
||||||
|
});
|
||||||
|
|
||||||
|
// Clear cache after update
|
||||||
|
clearCache();
|
||||||
|
log('✅ Successfully batch saved ${categories.length} categories');
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error batch saving categories: $e');
|
||||||
|
rethrow;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// CACHED QUERY
|
||||||
|
// ========================================
|
||||||
|
Future<List<CategoryModel>> getCachedCategories({
|
||||||
|
int page = 1,
|
||||||
|
int limit = 10,
|
||||||
|
bool isActive = true,
|
||||||
|
String? search,
|
||||||
|
}) async {
|
||||||
|
final cacheKey = _generateCacheKey(page, limit, isActive, 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} categories)');
|
||||||
|
return _queryCache[cacheKey]!;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
log('📀 Cache MISS: $cacheKey, querying database...');
|
||||||
|
|
||||||
|
// Cache miss, query database
|
||||||
|
final categories = await getCategories(
|
||||||
|
page: page,
|
||||||
|
limit: limit,
|
||||||
|
isActive: isActive,
|
||||||
|
search: search,
|
||||||
|
);
|
||||||
|
|
||||||
|
// Store in cache
|
||||||
|
_queryCache[cacheKey] = categories;
|
||||||
|
_cacheTimestamps[cacheKey] = now;
|
||||||
|
|
||||||
|
log('💾 Cached ${categories.length} categories for key: $cacheKey');
|
||||||
|
return categories;
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// REGULAR GET CATEGORIES
|
||||||
|
// ========================================
|
||||||
|
Future<List<CategoryModel>> getCategories({
|
||||||
|
int page = 1,
|
||||||
|
int limit = 10,
|
||||||
|
bool isActive = true,
|
||||||
|
String? search,
|
||||||
|
}) async {
|
||||||
|
final db = await _db;
|
||||||
|
|
||||||
|
try {
|
||||||
|
String query = 'SELECT * FROM categories WHERE 1=1';
|
||||||
|
List<dynamic> whereArgs = [];
|
||||||
|
|
||||||
|
// Note: Assuming is_active will be added to database schema
|
||||||
|
if (isActive) {
|
||||||
|
query += ' AND is_active = ?';
|
||||||
|
whereArgs.add(1);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (search != null && search.isNotEmpty) {
|
||||||
|
query += ' AND (name LIKE ? OR description LIKE ?)';
|
||||||
|
whereArgs.add('%$search%');
|
||||||
|
whereArgs.add('%$search%');
|
||||||
|
}
|
||||||
|
|
||||||
|
query += ' ORDER BY name ASC';
|
||||||
|
|
||||||
|
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<CategoryModel> categories = [];
|
||||||
|
for (final map in maps) {
|
||||||
|
categories.add(_mapToCategory(map));
|
||||||
|
}
|
||||||
|
|
||||||
|
log('📊 Retrieved ${categories.length} categories from database');
|
||||||
|
return categories;
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error getting categories: $e');
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// GET ALL CATEGORIES (For dropdowns)
|
||||||
|
// ========================================
|
||||||
|
Future<List<CategoryModel>> getAllCategories() async {
|
||||||
|
const cacheKey = 'all_categories';
|
||||||
|
final now = DateTime.now();
|
||||||
|
|
||||||
|
// Check cache
|
||||||
|
if (_queryCache.containsKey(cacheKey) &&
|
||||||
|
_cacheTimestamps.containsKey(cacheKey)) {
|
||||||
|
final cacheTime = _cacheTimestamps[cacheKey]!;
|
||||||
|
if (now.difference(cacheTime) < _cacheExpiry) {
|
||||||
|
return _queryCache[cacheKey]!;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
final db = await _db;
|
||||||
|
|
||||||
|
try {
|
||||||
|
final List<Map<String, dynamic>> maps = await db.query(
|
||||||
|
'categories',
|
||||||
|
orderBy: 'name ASC',
|
||||||
|
);
|
||||||
|
|
||||||
|
final categories = maps.map((map) => _mapToCategory(map)).toList();
|
||||||
|
|
||||||
|
// Cache all categories
|
||||||
|
_queryCache[cacheKey] = categories;
|
||||||
|
_cacheTimestamps[cacheKey] = now;
|
||||||
|
|
||||||
|
log('📊 Retrieved ${categories.length} total categories');
|
||||||
|
return categories;
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error getting all categories: $e');
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// GET CATEGORY BY ID
|
||||||
|
// ========================================
|
||||||
|
Future<CategoryModel?> getCategoryById(String id) async {
|
||||||
|
final db = await _db;
|
||||||
|
|
||||||
|
try {
|
||||||
|
final List<Map<String, dynamic>> maps = await db.query(
|
||||||
|
'categories',
|
||||||
|
where: 'id = ?',
|
||||||
|
whereArgs: [id],
|
||||||
|
);
|
||||||
|
|
||||||
|
if (maps.isEmpty) {
|
||||||
|
log('❌ Category not found: $id');
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
final category = _mapToCategory(maps.first);
|
||||||
|
log('✅ Category found: ${category.name}');
|
||||||
|
return category;
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error getting category by ID: $e');
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// GET TOTAL COUNT
|
||||||
|
// ========================================
|
||||||
|
Future<int> getTotalCount({bool isActive = true, String? search}) async {
|
||||||
|
final db = await _db;
|
||||||
|
|
||||||
|
try {
|
||||||
|
String query = 'SELECT COUNT(*) FROM categories WHERE 1=1';
|
||||||
|
List<dynamic> whereArgs = [];
|
||||||
|
|
||||||
|
if (isActive) {
|
||||||
|
query += ' AND is_active = ?';
|
||||||
|
whereArgs.add(1);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (search != null && search.isNotEmpty) {
|
||||||
|
query += ' AND (name LIKE ? OR description LIKE ?)';
|
||||||
|
whereArgs.add('%$search%');
|
||||||
|
whereArgs.add('%$search%');
|
||||||
|
}
|
||||||
|
|
||||||
|
final result = await db.rawQuery(query, whereArgs);
|
||||||
|
final count = Sqflite.firstIntValue(result) ?? 0;
|
||||||
|
log('📊 Category total count: $count (isActive: $isActive, search: $search)');
|
||||||
|
return count;
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error getting category total count: $e');
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// HAS CATEGORIES
|
||||||
|
// ========================================
|
||||||
|
Future<bool> hasCategories() async {
|
||||||
|
final count = await getTotalCount();
|
||||||
|
final hasData = count > 0;
|
||||||
|
log('🔍 Has categories: $hasData ($count categories)');
|
||||||
|
return hasData;
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// CLEAR ALL CATEGORIES
|
||||||
|
// ========================================
|
||||||
|
Future<void> clearAllCategories() async {
|
||||||
|
final db = await _db;
|
||||||
|
|
||||||
|
try {
|
||||||
|
await db.delete('categories');
|
||||||
|
clearCache();
|
||||||
|
log('🗑️ All categories cleared from local DB');
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error clearing categories: $e');
|
||||||
|
rethrow;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// CACHE MANAGEMENT
|
||||||
|
// ========================================
|
||||||
|
String _generateCacheKey(int page, int limit, bool isActive, String? search) {
|
||||||
|
return 'categories_${page}_${limit}_${isActive}_${search ?? 'null'}';
|
||||||
|
}
|
||||||
|
|
||||||
|
void clearCache() {
|
||||||
|
final count = _queryCache.length;
|
||||||
|
_queryCache.clear();
|
||||||
|
_cacheTimestamps.clear();
|
||||||
|
log('🧹 Category 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 category cache cleared: ${expiredKeys.length} entries');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// DATABASE STATS
|
||||||
|
// ========================================
|
||||||
|
Future<Map<String, dynamic>> getDatabaseStats() async {
|
||||||
|
final db = await _db;
|
||||||
|
|
||||||
|
try {
|
||||||
|
final categoryCount = Sqflite.firstIntValue(
|
||||||
|
await db.rawQuery('SELECT COUNT(*) FROM categories')) ??
|
||||||
|
0;
|
||||||
|
|
||||||
|
final activeCount = Sqflite.firstIntValue(await db.rawQuery(
|
||||||
|
'SELECT COUNT(*) FROM categories WHERE is_active = 1')) ??
|
||||||
|
0;
|
||||||
|
|
||||||
|
final stats = {
|
||||||
|
'total_categories': categoryCount,
|
||||||
|
'active_categories': activeCount,
|
||||||
|
'cache_entries': _queryCache.length,
|
||||||
|
};
|
||||||
|
|
||||||
|
log('📊 Category Database Stats: $stats');
|
||||||
|
return stats;
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error getting category database stats: $e');
|
||||||
|
return {};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// HELPER METHODS
|
||||||
|
// ========================================
|
||||||
|
Map<String, dynamic> _categoryToMap(CategoryModel category) {
|
||||||
|
return {
|
||||||
|
'id': category.id,
|
||||||
|
'organization_id': category.organizationId,
|
||||||
|
'name': category.name,
|
||||||
|
'description': category.description,
|
||||||
|
'business_type': category.businessType,
|
||||||
|
'metadata': json.encode(category.metadata),
|
||||||
|
'is_active': 1, // Assuming all synced categories are active
|
||||||
|
'created_at': category.createdAt.toIso8601String(),
|
||||||
|
'updated_at': category.updatedAt.toIso8601String(),
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
CategoryModel _mapToCategory(Map<String, dynamic> map) {
|
||||||
|
return CategoryModel(
|
||||||
|
id: map['id'],
|
||||||
|
organizationId: map['organization_id'],
|
||||||
|
name: map['name'],
|
||||||
|
description: map['description'],
|
||||||
|
businessType: map['business_type'],
|
||||||
|
metadata: map['metadata'] != null ? json.decode(map['metadata']) : {},
|
||||||
|
createdAt: DateTime.parse(map['created_at']),
|
||||||
|
updatedAt: DateTime.parse(map['updated_at']),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
285
lib/data/repositories/category/category_repository.dart
Normal file
285
lib/data/repositories/category/category_repository.dart
Normal file
@ -0,0 +1,285 @@
|
|||||||
|
import 'dart:developer';
|
||||||
|
import 'package:dartz/dartz.dart';
|
||||||
|
import 'package:enaklo_pos/data/datasources/category/category_local_datasource.dart';
|
||||||
|
import 'package:enaklo_pos/data/datasources/category/category_remote_datasource.dart';
|
||||||
|
import 'package:enaklo_pos/data/models/response/category_response_model.dart';
|
||||||
|
|
||||||
|
class CategoryRepository {
|
||||||
|
static CategoryRepository? _instance;
|
||||||
|
|
||||||
|
final CategoryLocalDatasource _localDatasource;
|
||||||
|
final CategoryRemoteDatasource _remoteDatasource;
|
||||||
|
|
||||||
|
CategoryRepository._internal()
|
||||||
|
: _localDatasource = CategoryLocalDatasource.instance,
|
||||||
|
_remoteDatasource = CategoryRemoteDatasource();
|
||||||
|
|
||||||
|
static CategoryRepository get instance {
|
||||||
|
_instance ??= CategoryRepository._internal();
|
||||||
|
return _instance!;
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// SYNC STRATEGY: REMOTE-FIRST WITH LOCAL FALLBACK
|
||||||
|
// ========================================
|
||||||
|
Future<Either<String, CategoryResponseModel>> getCategories({
|
||||||
|
int page = 1,
|
||||||
|
int limit = 10,
|
||||||
|
bool isActive = true,
|
||||||
|
String? search,
|
||||||
|
bool forceRemote = false,
|
||||||
|
}) async {
|
||||||
|
try {
|
||||||
|
log('📱 Getting categories - page: $page, isActive: $isActive, search: $search, forceRemote: $forceRemote');
|
||||||
|
|
||||||
|
// Clean expired cache
|
||||||
|
_localDatasource.clearExpiredCache();
|
||||||
|
|
||||||
|
// Check if we should try remote first
|
||||||
|
if (forceRemote || !await _localDatasource.hasCategories()) {
|
||||||
|
log('🌐 Attempting remote fetch first...');
|
||||||
|
|
||||||
|
final remoteResult = await _getRemoteCategories(
|
||||||
|
page: page,
|
||||||
|
limit: limit,
|
||||||
|
isActive: isActive,
|
||||||
|
);
|
||||||
|
|
||||||
|
return await remoteResult.fold(
|
||||||
|
(failure) async {
|
||||||
|
log('❌ Remote fetch failed: $failure');
|
||||||
|
log('📱 Falling back to local data...');
|
||||||
|
return _getLocalCategories(
|
||||||
|
page: page,
|
||||||
|
limit: limit,
|
||||||
|
isActive: isActive,
|
||||||
|
search: search,
|
||||||
|
);
|
||||||
|
},
|
||||||
|
(response) async {
|
||||||
|
log('✅ Remote fetch successful, syncing to local...');
|
||||||
|
|
||||||
|
// Sync remote data to local
|
||||||
|
if (response.data.categories.isNotEmpty) {
|
||||||
|
await _syncToLocal(response.data.categories,
|
||||||
|
clearFirst: page == 1);
|
||||||
|
}
|
||||||
|
|
||||||
|
return Right(response);
|
||||||
|
},
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
log('📱 Using local data (cache available)...');
|
||||||
|
return _getLocalCategories(
|
||||||
|
page: page,
|
||||||
|
limit: limit,
|
||||||
|
isActive: isActive,
|
||||||
|
search: search,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error in getCategories: $e');
|
||||||
|
return Left('Gagal memuat kategori: $e');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// PURE LOCAL OPERATIONS
|
||||||
|
// ========================================
|
||||||
|
Future<Either<String, CategoryResponseModel>> _getLocalCategories({
|
||||||
|
int page = 1,
|
||||||
|
int limit = 10,
|
||||||
|
bool isActive = true,
|
||||||
|
String? search,
|
||||||
|
}) async {
|
||||||
|
try {
|
||||||
|
final cachedCategories = await _localDatasource.getCachedCategories(
|
||||||
|
page: page,
|
||||||
|
limit: limit,
|
||||||
|
isActive: isActive,
|
||||||
|
search: search,
|
||||||
|
);
|
||||||
|
|
||||||
|
final totalCount = await _localDatasource.getTotalCount(
|
||||||
|
isActive: isActive,
|
||||||
|
search: search,
|
||||||
|
);
|
||||||
|
|
||||||
|
final categoryData = CategoryData(
|
||||||
|
categories: cachedCategories,
|
||||||
|
totalCount: totalCount,
|
||||||
|
page: page,
|
||||||
|
limit: limit,
|
||||||
|
totalPages: totalCount > 0 ? (totalCount / limit).ceil() : 0,
|
||||||
|
);
|
||||||
|
|
||||||
|
final response = CategoryResponseModel(
|
||||||
|
success: true,
|
||||||
|
data: categoryData,
|
||||||
|
);
|
||||||
|
|
||||||
|
log('✅ Returned ${cachedCategories.length} local categories (${totalCount} total)');
|
||||||
|
return Right(response);
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error getting local categories: $e');
|
||||||
|
return Left('Gagal memuat kategori dari database lokal: $e');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// REMOTE FETCH
|
||||||
|
// ========================================
|
||||||
|
Future<Either<String, CategoryResponseModel>> _getRemoteCategories({
|
||||||
|
int page = 1,
|
||||||
|
int limit = 10,
|
||||||
|
bool isActive = true,
|
||||||
|
}) async {
|
||||||
|
try {
|
||||||
|
log('🌐 Fetching categories from remote...');
|
||||||
|
return await _remoteDatasource.getCategories(
|
||||||
|
page: page,
|
||||||
|
limit: limit,
|
||||||
|
isActive: isActive,
|
||||||
|
);
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Remote fetch error: $e');
|
||||||
|
return Left('Gagal mengambil data dari server: $e');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// SYNC TO LOCAL
|
||||||
|
// ========================================
|
||||||
|
Future<void> _syncToLocal(List<CategoryModel> categories,
|
||||||
|
{bool clearFirst = false}) async {
|
||||||
|
try {
|
||||||
|
log('💾 Syncing ${categories.length} categories to local database...');
|
||||||
|
await _localDatasource.saveCategoriesBatch(categories,
|
||||||
|
clearFirst: clearFirst);
|
||||||
|
log('✅ Categories synced to local successfully');
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error syncing categories to local: $e');
|
||||||
|
rethrow;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// MANUAL SYNC OPERATIONS
|
||||||
|
// ========================================
|
||||||
|
Future<Either<String, String>> syncAllCategories() async {
|
||||||
|
try {
|
||||||
|
log('🔄 Starting manual sync of all categories...');
|
||||||
|
|
||||||
|
int page = 1;
|
||||||
|
const limit = 50; // Higher limit for bulk sync
|
||||||
|
bool hasMore = true;
|
||||||
|
int totalSynced = 0;
|
||||||
|
|
||||||
|
// Clear local data first for fresh sync
|
||||||
|
await _localDatasource.clearAllCategories();
|
||||||
|
|
||||||
|
while (hasMore) {
|
||||||
|
log('📄 Syncing page $page...');
|
||||||
|
|
||||||
|
final result = await _remoteDatasource.getCategories(
|
||||||
|
page: page,
|
||||||
|
limit: limit,
|
||||||
|
isActive: true,
|
||||||
|
);
|
||||||
|
|
||||||
|
await result.fold(
|
||||||
|
(failure) async {
|
||||||
|
log('❌ Sync failed at page $page: $failure');
|
||||||
|
throw Exception(failure);
|
||||||
|
},
|
||||||
|
(response) async {
|
||||||
|
final categories = response.data.categories;
|
||||||
|
|
||||||
|
if (categories.isNotEmpty) {
|
||||||
|
await _localDatasource.saveCategoriesBatch(
|
||||||
|
categories,
|
||||||
|
clearFirst: false, // Don't clear on subsequent pages
|
||||||
|
);
|
||||||
|
totalSynced += categories.length;
|
||||||
|
|
||||||
|
// Check if we have more pages
|
||||||
|
hasMore = page < response.data.totalPages;
|
||||||
|
page++;
|
||||||
|
|
||||||
|
log('📦 Page $page synced: ${categories.length} categories');
|
||||||
|
} else {
|
||||||
|
hasMore = false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
final message = 'Berhasil sinkronisasi $totalSynced kategori';
|
||||||
|
log('✅ $message');
|
||||||
|
return Right(message);
|
||||||
|
} catch (e) {
|
||||||
|
final error = 'Gagal sinkronisasi kategori: $e';
|
||||||
|
log('❌ $error');
|
||||||
|
return Left(error);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// UTILITY METHODS
|
||||||
|
// ========================================
|
||||||
|
Future<Either<String, CategoryResponseModel>> refreshCategories({
|
||||||
|
bool isActive = true,
|
||||||
|
String? search,
|
||||||
|
}) async {
|
||||||
|
log('🔄 Refreshing categories...');
|
||||||
|
clearCache();
|
||||||
|
|
||||||
|
return await getCategories(
|
||||||
|
page: 1,
|
||||||
|
limit: 10,
|
||||||
|
isActive: isActive,
|
||||||
|
search: search,
|
||||||
|
forceRemote: true, // Force remote refresh
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
Future<CategoryModel?> getCategoryById(String id) async {
|
||||||
|
log('🔍 Getting category by ID: $id');
|
||||||
|
return await _localDatasource.getCategoryById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
Future<List<CategoryModel>> getAllCategories() async {
|
||||||
|
log('📋 Getting all categories for dropdown...');
|
||||||
|
return await _localDatasource.getAllCategories();
|
||||||
|
}
|
||||||
|
|
||||||
|
Future<bool> hasLocalCategories() async {
|
||||||
|
final hasCategories = await _localDatasource.hasCategories();
|
||||||
|
log('📊 Has local categories: $hasCategories');
|
||||||
|
return hasCategories;
|
||||||
|
}
|
||||||
|
|
||||||
|
Future<Map<String, dynamic>> getDatabaseStats() async {
|
||||||
|
final stats = await _localDatasource.getDatabaseStats();
|
||||||
|
log('📊 Category database stats: $stats');
|
||||||
|
return stats;
|
||||||
|
}
|
||||||
|
|
||||||
|
void clearCache() {
|
||||||
|
log('🧹 Clearing category cache');
|
||||||
|
_localDatasource.clearCache();
|
||||||
|
}
|
||||||
|
|
||||||
|
Future<bool> isLocalDatabaseReady() async {
|
||||||
|
try {
|
||||||
|
final stats = await getDatabaseStats();
|
||||||
|
final categoryCount = stats['total_categories'] ?? 0;
|
||||||
|
final isReady = categoryCount > 0;
|
||||||
|
log('🔍 Category database ready: $isReady ($categoryCount categories)');
|
||||||
|
return isReady;
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error checking category database readiness: $e');
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -34,7 +34,7 @@ import 'package:firebase_crashlytics/firebase_crashlytics.dart';
|
|||||||
import 'package:flutter/material.dart';
|
import 'package:flutter/material.dart';
|
||||||
import 'package:enaklo_pos/data/datasources/auth_local_datasource.dart';
|
import 'package:enaklo_pos/data/datasources/auth_local_datasource.dart';
|
||||||
import 'package:enaklo_pos/data/datasources/auth_remote_datasource.dart';
|
import 'package:enaklo_pos/data/datasources/auth_remote_datasource.dart';
|
||||||
import 'package:enaklo_pos/data/datasources/category_remote_datasource.dart';
|
import 'package:enaklo_pos/data/datasources/category/category_remote_datasource.dart';
|
||||||
import 'package:enaklo_pos/data/datasources/discount_remote_datasource.dart';
|
import 'package:enaklo_pos/data/datasources/discount_remote_datasource.dart';
|
||||||
import 'package:enaklo_pos/data/datasources/midtrans_remote_datasource.dart';
|
import 'package:enaklo_pos/data/datasources/midtrans_remote_datasource.dart';
|
||||||
import 'package:enaklo_pos/data/datasources/order_remote_datasource.dart';
|
import 'package:enaklo_pos/data/datasources/order_remote_datasource.dart';
|
||||||
@ -275,7 +275,7 @@ class _MyAppState extends State<MyApp> {
|
|||||||
create: (context) => UploadFileBloc(FileRemoteDataSource()),
|
create: (context) => UploadFileBloc(FileRemoteDataSource()),
|
||||||
),
|
),
|
||||||
BlocProvider(
|
BlocProvider(
|
||||||
create: (context) => CategoryLoaderBloc(CategoryRemoteDatasource()),
|
create: (context) => CategoryLoaderBloc(),
|
||||||
),
|
),
|
||||||
BlocProvider(
|
BlocProvider(
|
||||||
create: (context) => GetPrinterTicketBloc(),
|
create: (context) => GetPrinterTicketBloc(),
|
||||||
|
|||||||
@ -1,6 +1,8 @@
|
|||||||
import 'package:bloc/bloc.dart';
|
import 'dart:async';
|
||||||
import 'package:enaklo_pos/data/datasources/category_remote_datasource.dart';
|
import 'dart:developer';
|
||||||
import 'package:enaklo_pos/data/models/response/category_response_model.dart';
|
import 'package:enaklo_pos/data/models/response/category_response_model.dart';
|
||||||
|
import 'package:enaklo_pos/data/repositories/category/category_repository.dart';
|
||||||
|
import 'package:flutter_bloc/flutter_bloc.dart';
|
||||||
import 'package:freezed_annotation/freezed_annotation.dart';
|
import 'package:freezed_annotation/freezed_annotation.dart';
|
||||||
|
|
||||||
part 'category_loader_event.dart';
|
part 'category_loader_event.dart';
|
||||||
@ -9,35 +11,310 @@ part 'category_loader_bloc.freezed.dart';
|
|||||||
|
|
||||||
class CategoryLoaderBloc
|
class CategoryLoaderBloc
|
||||||
extends Bloc<CategoryLoaderEvent, CategoryLoaderState> {
|
extends Bloc<CategoryLoaderEvent, CategoryLoaderState> {
|
||||||
final CategoryRemoteDatasource _datasource;
|
final CategoryRepository _categoryRepository = CategoryRepository.instance;
|
||||||
CategoryLoaderBloc(this._datasource) : super(CategoryLoaderState.initial()) {
|
|
||||||
on<_Get>((event, emit) async {
|
Timer? _searchDebounce;
|
||||||
emit(const _Loading());
|
bool _isLoadingMore = false;
|
||||||
final result = await _datasource.getCategories(limit: 50);
|
|
||||||
result.fold(
|
CategoryLoaderBloc() : super(const CategoryLoaderState.initial()) {
|
||||||
(l) => emit(_Error(l)),
|
on<_GetCategories>(_onGetCategories);
|
||||||
(r) async {
|
on<_LoadMore>(_onLoadMore);
|
||||||
List<CategoryModel> categories = r.data.categories;
|
on<_Refresh>(_onRefresh);
|
||||||
categories.insert(
|
on<_Search>(_onSearch);
|
||||||
0,
|
on<_SyncAll>(_onSyncAll);
|
||||||
CategoryModel(
|
on<_GetAllCategories>(_onGetAllCategories);
|
||||||
id: "",
|
on<_ClearCache>(_onClearCache);
|
||||||
name: 'Semua',
|
on<_GetDatabaseStats>(_onGetDatabaseStats);
|
||||||
organizationId: '',
|
}
|
||||||
businessType: '',
|
|
||||||
metadata: {},
|
@override
|
||||||
createdAt: DateTime.now(),
|
Future<void> close() {
|
||||||
updatedAt: DateTime.now(),
|
_searchDebounce?.cancel();
|
||||||
),
|
return super.close();
|
||||||
);
|
}
|
||||||
emit(_Loaded(categories, null));
|
|
||||||
|
// ========================================
|
||||||
|
// GET CATEGORIES (Remote-first with local fallback)
|
||||||
|
// ========================================
|
||||||
|
Future<void> _onGetCategories(
|
||||||
|
_GetCategories event,
|
||||||
|
Emitter<CategoryLoaderState> emit,
|
||||||
|
) async {
|
||||||
|
emit(const CategoryLoaderState.loading());
|
||||||
|
_isLoadingMore = false;
|
||||||
|
|
||||||
|
log('📱 Loading categories - isActive: ${event.isActive}, forceRemote: ${event.forceRemote}');
|
||||||
|
|
||||||
|
final result = await _categoryRepository.getCategories(
|
||||||
|
page: 1,
|
||||||
|
limit: 10,
|
||||||
|
isActive: event.isActive,
|
||||||
|
search: event.search,
|
||||||
|
forceRemote: event.forceRemote,
|
||||||
|
);
|
||||||
|
|
||||||
|
await result.fold(
|
||||||
|
(failure) async {
|
||||||
|
log('❌ Error loading categories: $failure');
|
||||||
|
emit(CategoryLoaderState.error(failure));
|
||||||
|
},
|
||||||
|
(response) async {
|
||||||
|
final categories = response.data.categories;
|
||||||
|
final totalPages = response.data.totalPages;
|
||||||
|
final hasReachedMax = categories.length < 10 || 1 >= totalPages;
|
||||||
|
|
||||||
|
log('✅ Categories loaded: ${categories.length}, hasReachedMax: $hasReachedMax');
|
||||||
|
|
||||||
|
emit(CategoryLoaderState.loaded(
|
||||||
|
categories: categories,
|
||||||
|
hasReachedMax: hasReachedMax,
|
||||||
|
currentPage: 1,
|
||||||
|
isLoadingMore: false,
|
||||||
|
isActive: event.isActive,
|
||||||
|
searchQuery: event.search,
|
||||||
|
));
|
||||||
|
},
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// LOAD MORE CATEGORIES
|
||||||
|
// ========================================
|
||||||
|
Future<void> _onLoadMore(
|
||||||
|
_LoadMore event,
|
||||||
|
Emitter<CategoryLoaderState> emit,
|
||||||
|
) async {
|
||||||
|
final currentState = state;
|
||||||
|
|
||||||
|
if (currentState is! _Loaded ||
|
||||||
|
currentState.hasReachedMax ||
|
||||||
|
_isLoadingMore ||
|
||||||
|
currentState.isLoadingMore) {
|
||||||
|
log('⏹️ Load more blocked - state: ${currentState.runtimeType}, isLoadingMore: $_isLoadingMore');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
_isLoadingMore = true;
|
||||||
|
emit(currentState.copyWith(isLoadingMore: true));
|
||||||
|
|
||||||
|
final nextPage = currentState.currentPage + 1;
|
||||||
|
log('📄 Loading more categories - page: $nextPage');
|
||||||
|
|
||||||
|
try {
|
||||||
|
final result = await _categoryRepository.getCategories(
|
||||||
|
page: nextPage,
|
||||||
|
limit: 10,
|
||||||
|
isActive: currentState.isActive,
|
||||||
|
search: currentState.searchQuery,
|
||||||
|
);
|
||||||
|
|
||||||
|
await result.fold(
|
||||||
|
(failure) async {
|
||||||
|
log('❌ Error loading more categories: $failure');
|
||||||
|
emit(currentState.copyWith(isLoadingMore: false));
|
||||||
|
},
|
||||||
|
(response) async {
|
||||||
|
final newCategories = response.data.categories;
|
||||||
|
final totalPages = response.data.totalPages;
|
||||||
|
|
||||||
|
// Prevent duplicate categories
|
||||||
|
final currentCategoryIds =
|
||||||
|
currentState.categories.map((c) => c.id).toSet();
|
||||||
|
final filteredNewCategories = newCategories
|
||||||
|
.where((category) => !currentCategoryIds.contains(category.id))
|
||||||
|
.toList();
|
||||||
|
|
||||||
|
final allCategories =
|
||||||
|
List<CategoryModel>.from(currentState.categories)
|
||||||
|
..addAll(filteredNewCategories);
|
||||||
|
|
||||||
|
final hasReachedMax =
|
||||||
|
newCategories.length < 10 || nextPage >= totalPages;
|
||||||
|
|
||||||
|
log('✅ More categories loaded: ${filteredNewCategories.length} new, total: ${allCategories.length}');
|
||||||
|
|
||||||
|
emit(CategoryLoaderState.loaded(
|
||||||
|
categories: allCategories,
|
||||||
|
hasReachedMax: hasReachedMax,
|
||||||
|
currentPage: nextPage,
|
||||||
|
isLoadingMore: false,
|
||||||
|
isActive: currentState.isActive,
|
||||||
|
searchQuery: currentState.searchQuery,
|
||||||
|
));
|
||||||
|
},
|
||||||
|
);
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Exception loading more categories: $e');
|
||||||
|
emit(currentState.copyWith(isLoadingMore: false));
|
||||||
|
} finally {
|
||||||
|
_isLoadingMore = false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// REFRESH CATEGORIES
|
||||||
|
// ========================================
|
||||||
|
Future<void> _onRefresh(
|
||||||
|
_Refresh event,
|
||||||
|
Emitter<CategoryLoaderState> emit,
|
||||||
|
) async {
|
||||||
|
final currentState = state;
|
||||||
|
bool isActive = true;
|
||||||
|
String? searchQuery;
|
||||||
|
|
||||||
|
if (currentState is _Loaded) {
|
||||||
|
isActive = currentState.isActive;
|
||||||
|
searchQuery = currentState.searchQuery;
|
||||||
|
}
|
||||||
|
|
||||||
|
_isLoadingMore = false;
|
||||||
|
_searchDebounce?.cancel();
|
||||||
|
|
||||||
|
log('🔄 Refreshing categories');
|
||||||
|
|
||||||
|
// Clear local cache
|
||||||
|
_categoryRepository.clearCache();
|
||||||
|
|
||||||
|
add(CategoryLoaderEvent.getCategories(
|
||||||
|
isActive: isActive,
|
||||||
|
search: searchQuery,
|
||||||
|
forceRemote: true, // Force remote refresh
|
||||||
|
));
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// SEARCH CATEGORIES
|
||||||
|
// ========================================
|
||||||
|
Future<void> _onSearch(
|
||||||
|
_Search event,
|
||||||
|
Emitter<CategoryLoaderState> emit,
|
||||||
|
) async {
|
||||||
|
// Cancel previous search
|
||||||
|
_searchDebounce?.cancel();
|
||||||
|
|
||||||
|
// Debounce search for better UX
|
||||||
|
_searchDebounce = Timer(Duration(milliseconds: 300), () async {
|
||||||
|
emit(const CategoryLoaderState.loading());
|
||||||
|
_isLoadingMore = false;
|
||||||
|
|
||||||
|
log('🔍 Searching categories: "${event.query}"');
|
||||||
|
|
||||||
|
final result = await _categoryRepository.getCategories(
|
||||||
|
page: 1,
|
||||||
|
limit: 20, // More results for search
|
||||||
|
isActive: event.isActive,
|
||||||
|
search: event.query,
|
||||||
|
);
|
||||||
|
|
||||||
|
await result.fold(
|
||||||
|
(failure) async {
|
||||||
|
log('❌ Search error: $failure');
|
||||||
|
emit(CategoryLoaderState.error(failure));
|
||||||
|
},
|
||||||
|
(response) async {
|
||||||
|
final categories = response.data.categories;
|
||||||
|
final totalPages = response.data.totalPages;
|
||||||
|
final hasReachedMax = categories.length < 20 || 1 >= totalPages;
|
||||||
|
|
||||||
|
log('✅ Search results: ${categories.length} categories found');
|
||||||
|
|
||||||
|
emit(CategoryLoaderState.loaded(
|
||||||
|
categories: categories,
|
||||||
|
hasReachedMax: hasReachedMax,
|
||||||
|
currentPage: 1,
|
||||||
|
isLoadingMore: false,
|
||||||
|
isActive: event.isActive,
|
||||||
|
searchQuery: event.query,
|
||||||
|
));
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
on<_SetCategoryId>((event, emit) async {
|
}
|
||||||
var currentState = state as _Loaded;
|
|
||||||
|
|
||||||
emit(_Loaded(currentState.categories, event.categoryId));
|
// ========================================
|
||||||
});
|
// SYNC ALL CATEGORIES
|
||||||
|
// ========================================
|
||||||
|
Future<void> _onSyncAll(
|
||||||
|
_SyncAll event,
|
||||||
|
Emitter<CategoryLoaderState> emit,
|
||||||
|
) async {
|
||||||
|
emit(const CategoryLoaderState.syncing());
|
||||||
|
|
||||||
|
log('🔄 Starting full category sync...');
|
||||||
|
|
||||||
|
final result = await _categoryRepository.syncAllCategories();
|
||||||
|
|
||||||
|
await result.fold(
|
||||||
|
(failure) async {
|
||||||
|
log('❌ Sync failed: $failure');
|
||||||
|
emit(CategoryLoaderState.syncError(failure));
|
||||||
|
|
||||||
|
// After sync error, try to load local data
|
||||||
|
Timer(Duration(seconds: 2), () {
|
||||||
|
add(const CategoryLoaderEvent.getCategories());
|
||||||
|
});
|
||||||
|
},
|
||||||
|
(successMessage) async {
|
||||||
|
log('✅ Sync completed: $successMessage');
|
||||||
|
emit(CategoryLoaderState.syncSuccess(successMessage));
|
||||||
|
|
||||||
|
// After successful sync, load the updated data
|
||||||
|
Timer(Duration(seconds: 1), () {
|
||||||
|
add(const CategoryLoaderEvent.getCategories());
|
||||||
|
});
|
||||||
|
},
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// GET ALL CATEGORIES (For Dropdown)
|
||||||
|
// ========================================
|
||||||
|
Future<void> _onGetAllCategories(
|
||||||
|
_GetAllCategories event,
|
||||||
|
Emitter<CategoryLoaderState> emit,
|
||||||
|
) async {
|
||||||
|
try {
|
||||||
|
log('📋 Loading all categories for dropdown...');
|
||||||
|
|
||||||
|
final categories = await _categoryRepository.getAllCategories();
|
||||||
|
|
||||||
|
emit(CategoryLoaderState.allCategoriesLoaded(categories));
|
||||||
|
log('✅ All categories loaded: ${categories.length}');
|
||||||
|
} catch (e) {
|
||||||
|
log('❌ Error loading all categories: $e');
|
||||||
|
emit(CategoryLoaderState.error('Gagal memuat semua kategori: $e'));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// GET DATABASE STATS
|
||||||
|
// ========================================
|
||||||
|
Future<void> _onGetDatabaseStats(
|
||||||
|
_GetDatabaseStats event,
|
||||||
|
Emitter<CategoryLoaderState> emit,
|
||||||
|
) async {
|
||||||
|
try {
|
||||||
|
final stats = await _categoryRepository.getDatabaseStats();
|
||||||
|
log('📊 Category 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 category database stats: $e');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========================================
|
||||||
|
// CLEAR CACHE
|
||||||
|
// ========================================
|
||||||
|
Future<void> _onClearCache(
|
||||||
|
_ClearCache event,
|
||||||
|
Emitter<CategoryLoaderState> emit,
|
||||||
|
) async {
|
||||||
|
log('🧹 Manually clearing category cache');
|
||||||
|
_categoryRepository.clearCache();
|
||||||
|
|
||||||
|
// Refresh current data after cache clear
|
||||||
|
add(const CategoryLoaderEvent.refresh());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
@ -2,7 +2,26 @@ part of 'category_loader_bloc.dart';
|
|||||||
|
|
||||||
@freezed
|
@freezed
|
||||||
class CategoryLoaderEvent with _$CategoryLoaderEvent {
|
class CategoryLoaderEvent with _$CategoryLoaderEvent {
|
||||||
const factory CategoryLoaderEvent.get() = _Get;
|
const factory CategoryLoaderEvent.getCategories({
|
||||||
const factory CategoryLoaderEvent.setCategoryId(String categoryId) =
|
@Default(true) bool isActive,
|
||||||
_SetCategoryId;
|
String? search,
|
||||||
|
@Default(false) bool forceRemote,
|
||||||
|
}) = _GetCategories;
|
||||||
|
|
||||||
|
const factory CategoryLoaderEvent.loadMore() = _LoadMore;
|
||||||
|
|
||||||
|
const factory CategoryLoaderEvent.refresh() = _Refresh;
|
||||||
|
|
||||||
|
const factory CategoryLoaderEvent.search({
|
||||||
|
required String query,
|
||||||
|
@Default(true) bool isActive,
|
||||||
|
}) = _Search;
|
||||||
|
|
||||||
|
const factory CategoryLoaderEvent.syncAll() = _SyncAll;
|
||||||
|
|
||||||
|
const factory CategoryLoaderEvent.getAllCategories() = _GetAllCategories;
|
||||||
|
|
||||||
|
const factory CategoryLoaderEvent.getDatabaseStats() = _GetDatabaseStats;
|
||||||
|
|
||||||
|
const factory CategoryLoaderEvent.clearCache() = _ClearCache;
|
||||||
}
|
}
|
||||||
|
|||||||
@ -3,8 +3,29 @@ part of 'category_loader_bloc.dart';
|
|||||||
@freezed
|
@freezed
|
||||||
class CategoryLoaderState with _$CategoryLoaderState {
|
class CategoryLoaderState with _$CategoryLoaderState {
|
||||||
const factory CategoryLoaderState.initial() = _Initial;
|
const factory CategoryLoaderState.initial() = _Initial;
|
||||||
|
|
||||||
const factory CategoryLoaderState.loading() = _Loading;
|
const factory CategoryLoaderState.loading() = _Loading;
|
||||||
const factory CategoryLoaderState.loaded(
|
|
||||||
List<CategoryModel> categories, String? categoryId) = _Loaded;
|
const factory CategoryLoaderState.loaded({
|
||||||
|
required List<CategoryModel> categories,
|
||||||
|
required bool hasReachedMax,
|
||||||
|
required int currentPage,
|
||||||
|
required bool isLoadingMore,
|
||||||
|
required bool isActive,
|
||||||
|
String? searchQuery,
|
||||||
|
}) = _Loaded;
|
||||||
|
|
||||||
const factory CategoryLoaderState.error(String message) = _Error;
|
const factory CategoryLoaderState.error(String message) = _Error;
|
||||||
|
|
||||||
|
// Sync-specific states
|
||||||
|
const factory CategoryLoaderState.syncing() = _Syncing;
|
||||||
|
|
||||||
|
const factory CategoryLoaderState.syncSuccess(String message) = _SyncSuccess;
|
||||||
|
|
||||||
|
const factory CategoryLoaderState.syncError(String message) = _SyncError;
|
||||||
|
|
||||||
|
// For dropdown/all categories
|
||||||
|
const factory CategoryLoaderState.allCategoriesLoaded(
|
||||||
|
List<CategoryModel> categories,
|
||||||
|
) = _AllCategoriesLoaded;
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,6 +1,5 @@
|
|||||||
// ignore_for_file: public_member_api_docs, sort_constructors_first
|
// ignore_for_file: public_member_api_docs, sort_constructors_first
|
||||||
import 'dart:async';
|
import 'dart:async';
|
||||||
import 'dart:developer';
|
|
||||||
|
|
||||||
import 'package:connectivity_plus/connectivity_plus.dart';
|
import 'package:connectivity_plus/connectivity_plus.dart';
|
||||||
import 'package:enaklo_pos/presentation/customer/pages/customer_page.dart';
|
import 'package:enaklo_pos/presentation/customer/pages/customer_page.dart';
|
||||||
|
|||||||
@ -1,11 +1,11 @@
|
|||||||
// ========================================
|
// ========================================
|
||||||
// OFFLINE-ONLY HOMEPAGE - NO API CALLS
|
// HOMEPAGE - LOCAL DATA ONLY, NO SYNC
|
||||||
// lib/presentation/home/pages/home_page.dart
|
// lib/presentation/home/pages/home_page.dart
|
||||||
// ========================================
|
// ========================================
|
||||||
|
|
||||||
import 'dart:developer';
|
import 'dart:developer';
|
||||||
import 'package:enaklo_pos/core/components/flushbar.dart';
|
import 'package:enaklo_pos/core/components/flushbar.dart';
|
||||||
import 'package:enaklo_pos/data/datasources/product/product_local_datasource.dart';
|
import 'package:enaklo_pos/data/models/response/category_response_model.dart';
|
||||||
import 'package:enaklo_pos/presentation/home/bloc/category_loader/category_loader_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/current_outlet/current_outlet_bloc.dart';
|
||||||
import 'package:enaklo_pos/presentation/home/bloc/product_loader/product_loader_bloc.dart';
|
import 'package:enaklo_pos/presentation/home/bloc/product_loader/product_loader_bloc.dart';
|
||||||
@ -50,17 +50,10 @@ class _HomePageState extends State<HomePage> {
|
|||||||
final ScrollController scrollController = ScrollController();
|
final ScrollController scrollController = ScrollController();
|
||||||
String searchQuery = '';
|
String searchQuery = '';
|
||||||
|
|
||||||
// Local database only
|
|
||||||
Map<String, dynamic> _databaseStats = {};
|
|
||||||
final ProductLocalDatasource _localDatasource =
|
|
||||||
ProductLocalDatasource.instance;
|
|
||||||
bool _isLoadingStats = true;
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void initState() {
|
void initState() {
|
||||||
super.initState();
|
super.initState();
|
||||||
_initializeLocalData();
|
_loadData();
|
||||||
_loadProducts();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
@ -70,48 +63,28 @@ class _HomePageState extends State<HomePage> {
|
|||||||
super.dispose();
|
super.dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
// Initialize local data only
|
void _loadData() {
|
||||||
void _initializeLocalData() {
|
log('📱 Loading data from local database...');
|
||||||
_loadDatabaseStats();
|
|
||||||
}
|
|
||||||
|
|
||||||
// Load database statistics
|
// Load categories from local database
|
||||||
void _loadDatabaseStats() async {
|
context
|
||||||
try {
|
.read<CategoryLoaderBloc>()
|
||||||
final stats = await _localDatasource.getDatabaseStats();
|
.add(const CategoryLoaderEvent.getCategories());
|
||||||
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() {
|
// Load products from local database
|
||||||
log('📱 Loading products from local database only...');
|
|
||||||
|
|
||||||
// Load products from local database only
|
|
||||||
context
|
context
|
||||||
.read<ProductLoaderBloc>()
|
.read<ProductLoaderBloc>()
|
||||||
.add(const ProductLoaderEvent.getProduct());
|
.add(const ProductLoaderEvent.getProduct());
|
||||||
|
|
||||||
// Initialize other components
|
// Initialize other components
|
||||||
context.read<CheckoutBloc>().add(CheckoutEvent.started(widget.items));
|
context.read<CheckoutBloc>().add(CheckoutEvent.started(widget.items));
|
||||||
context.read<CategoryLoaderBloc>().add(CategoryLoaderEvent.get());
|
|
||||||
context.read<CurrentOutletBloc>().add(CurrentOutletEvent.currentOutlet());
|
context.read<CurrentOutletBloc>().add(CurrentOutletEvent.currentOutlet());
|
||||||
}
|
}
|
||||||
|
|
||||||
void _refreshLocalData() {
|
void _refreshData() {
|
||||||
log('🔄 Refreshing local data...');
|
log('🔄 Refreshing local data...');
|
||||||
context.read<ProductLoaderBloc>().add(const ProductLoaderEvent.refresh());
|
context.read<ProductLoaderBloc>().add(const ProductLoaderEvent.refresh());
|
||||||
_loadDatabaseStats();
|
context.read<CategoryLoaderBloc>().add(const CategoryLoaderEvent.refresh());
|
||||||
}
|
}
|
||||||
|
|
||||||
void onCategoryTap(int index) {
|
void onCategoryTap(int index) {
|
||||||
@ -125,11 +98,9 @@ class _HomePageState extends State<HomePage> {
|
|||||||
ScrollNotification notification, String? categoryId) {
|
ScrollNotification notification, String? categoryId) {
|
||||||
if (notification is ScrollEndNotification &&
|
if (notification is ScrollEndNotification &&
|
||||||
scrollController.position.extentAfter == 0) {
|
scrollController.position.extentAfter == 0) {
|
||||||
log('📄 Loading more local products for category: $categoryId');
|
log('📄 Loading more products...');
|
||||||
context.read<ProductLoaderBloc>().add(
|
context.read<ProductLoaderBloc>().add(
|
||||||
ProductLoaderEvent.loadMore(
|
ProductLoaderEvent.loadMore(),
|
||||||
categoryId: categoryId,
|
|
||||||
),
|
|
||||||
);
|
);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
@ -142,7 +113,6 @@ class _HomePageState extends State<HomePage> {
|
|||||||
listener: (context, state) {
|
listener: (context, state) {
|
||||||
state.maybeWhen(
|
state.maybeWhen(
|
||||||
orElse: () {},
|
orElse: () {},
|
||||||
loading: () {},
|
|
||||||
success: () {
|
success: () {
|
||||||
Future.delayed(Duration(milliseconds: 300), () {
|
Future.delayed(Duration(milliseconds: 300), () {
|
||||||
AppFlushbar.showSuccess(context, 'Outlet berhasil diubah');
|
AppFlushbar.showSuccess(context, 'Outlet berhasil diubah');
|
||||||
@ -160,81 +130,33 @@ class _HomePageState extends State<HomePage> {
|
|||||||
backgroundColor: AppColors.white,
|
backgroundColor: AppColors.white,
|
||||||
body: Column(
|
body: Column(
|
||||||
children: [
|
children: [
|
||||||
// Local database indicator
|
// Simple local mode indicator
|
||||||
_buildLocalModeIndicator(),
|
_buildLocalIndicator(),
|
||||||
|
|
||||||
// Main content
|
// Main content
|
||||||
Expanded(
|
Expanded(
|
||||||
child: Row(
|
child: Row(
|
||||||
children: [
|
children: [
|
||||||
// Left panel - Products
|
// Left panel - Products with Categories
|
||||||
Expanded(
|
Expanded(
|
||||||
flex: 3,
|
flex: 3,
|
||||||
child: Align(
|
child:
|
||||||
alignment: AlignmentDirectional.topStart,
|
BlocBuilder<CategoryLoaderBloc, CategoryLoaderState>(
|
||||||
child: BlocBuilder<CategoryLoaderBloc,
|
builder: (context, categoryState) {
|
||||||
CategoryLoaderState>(
|
return categoryState.maybeWhen(
|
||||||
builder: (context, state) {
|
orElse: () => _buildCategoryLoadingState(),
|
||||||
return state.maybeWhen(
|
loading: () => _buildCategoryLoadingState(),
|
||||||
orElse: () =>
|
error: (message) =>
|
||||||
Center(child: CircularProgressIndicator()),
|
_buildCategoryErrorState(message),
|
||||||
loaded: (categories, categoryId) => Column(
|
loaded: (categories, hasReachedMax, currentPage,
|
||||||
mainAxisAlignment: MainAxisAlignment.start,
|
isLoadingMore, isActive, searchQuery) =>
|
||||||
children: [
|
_buildCategoryContent(categories),
|
||||||
// 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)
|
// Right panel - Cart
|
||||||
Expanded(
|
Expanded(
|
||||||
flex: 2,
|
flex: 2,
|
||||||
child: _buildCartSection(),
|
child: _buildCartSection(),
|
||||||
@ -249,8 +171,8 @@ class _HomePageState extends State<HomePage> {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
// Local mode indicator
|
// Simple local mode indicator without sync
|
||||||
Widget _buildLocalModeIndicator() {
|
Widget _buildLocalIndicator() {
|
||||||
return Container(
|
return Container(
|
||||||
width: double.infinity,
|
width: double.infinity,
|
||||||
padding: EdgeInsets.symmetric(vertical: 8, horizontal: 16),
|
padding: EdgeInsets.symmetric(vertical: 8, horizontal: 16),
|
||||||
@ -261,9 +183,7 @@ class _HomePageState extends State<HomePage> {
|
|||||||
SizedBox(width: 8),
|
SizedBox(width: 8),
|
||||||
Expanded(
|
Expanded(
|
||||||
child: Text(
|
child: Text(
|
||||||
_isLoadingStats
|
'Mode Lokal - Data tersimpan di perangkat',
|
||||||
? 'Mode Lokal - Memuat data...'
|
|
||||||
: 'Mode Lokal - ${_databaseStats['total_products'] ?? 0} produk tersimpan',
|
|
||||||
style: TextStyle(
|
style: TextStyle(
|
||||||
color: Colors.white,
|
color: Colors.white,
|
||||||
fontSize: 13,
|
fontSize: 13,
|
||||||
@ -271,18 +191,10 @@ class _HomePageState extends State<HomePage> {
|
|||||||
),
|
),
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
if (_databaseStats.isNotEmpty) ...[
|
|
||||||
Text(
|
// Only refresh button
|
||||||
'${(_databaseStats['database_size_mb'] ?? 0.0).toStringAsFixed(1)} MB',
|
|
||||||
style: TextStyle(
|
|
||||||
color: Colors.white.withOpacity(0.8),
|
|
||||||
fontSize: 11,
|
|
||||||
),
|
|
||||||
),
|
|
||||||
SizedBox(width: 8),
|
|
||||||
],
|
|
||||||
InkWell(
|
InkWell(
|
||||||
onTap: _refreshLocalData,
|
onTap: _refreshData,
|
||||||
child: Container(
|
child: Container(
|
||||||
padding: EdgeInsets.all(4),
|
padding: EdgeInsets.all(4),
|
||||||
decoration: BoxDecoration(
|
decoration: BoxDecoration(
|
||||||
@ -297,170 +209,125 @@ class _HomePageState extends State<HomePage> {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
// Enhanced home title with local stats only
|
Widget _buildCategoryLoadingState() {
|
||||||
Widget _buildLocalHomeTitle(String? categoryId) {
|
return Center(
|
||||||
|
child: Column(
|
||||||
|
mainAxisAlignment: MainAxisAlignment.center,
|
||||||
|
children: [
|
||||||
|
CircularProgressIndicator(color: AppColors.primary),
|
||||||
|
SizedBox(height: 16),
|
||||||
|
Text(
|
||||||
|
'Memuat kategori...',
|
||||||
|
style: TextStyle(color: Colors.grey.shade600),
|
||||||
|
),
|
||||||
|
],
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
Widget _buildCategoryErrorState(String message) {
|
||||||
|
return Center(
|
||||||
|
child: Column(
|
||||||
|
mainAxisAlignment: MainAxisAlignment.center,
|
||||||
|
children: [
|
||||||
|
Icon(Icons.error_outline, size: 48, color: Colors.red.shade400),
|
||||||
|
SizedBox(height: 16),
|
||||||
|
Text('Error Kategori',
|
||||||
|
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<CategoryLoaderBloc>()
|
||||||
|
.add(const CategoryLoaderEvent.getCategories());
|
||||||
|
},
|
||||||
|
label: 'Coba Lagi',
|
||||||
|
),
|
||||||
|
],
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
Widget _buildCategoryContent(List<CategoryModel> categories) {
|
||||||
|
return Column(
|
||||||
|
children: [
|
||||||
|
// Simple home title
|
||||||
|
_buildSimpleHomeTitle(),
|
||||||
|
|
||||||
|
// Products section with categories
|
||||||
|
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, category.id),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}).toList(),
|
||||||
|
);
|
||||||
|
},
|
||||||
|
),
|
||||||
|
),
|
||||||
|
],
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Simple home title
|
||||||
|
Widget _buildSimpleHomeTitle() {
|
||||||
return Container(
|
return Container(
|
||||||
padding: EdgeInsets.all(16),
|
padding: EdgeInsets.all(16),
|
||||||
decoration: BoxDecoration(
|
decoration: BoxDecoration(
|
||||||
color: Colors.white,
|
color: Colors.white,
|
||||||
border: Border(bottom: BorderSide(color: Colors.grey.shade200)),
|
border: Border(bottom: BorderSide(color: Colors.grey.shade200)),
|
||||||
),
|
),
|
||||||
child: Column(
|
child: HomeTitle(
|
||||||
children: [
|
controller: searchController,
|
||||||
// Original HomeTitle with faster search
|
onChanged: (value) {
|
||||||
HomeTitle(
|
setState(() {
|
||||||
controller: searchController,
|
searchQuery = value;
|
||||||
onChanged: (value) {
|
});
|
||||||
setState(() {
|
|
||||||
searchQuery = value;
|
|
||||||
});
|
|
||||||
|
|
||||||
// Fast local search - no debounce needed for local data
|
// Fast local search
|
||||||
Future.delayed(Duration(milliseconds: 200), () {
|
Future.delayed(Duration(milliseconds: 200), () {
|
||||||
if (value == searchController.text) {
|
if (value == searchController.text) {
|
||||||
log('🔍 Local search: "$value"');
|
log('🔍 Local search: "$value"');
|
||||||
context.read<ProductLoaderBloc>().add(
|
context.read<ProductLoaderBloc>().add(
|
||||||
ProductLoaderEvent.searchProduct(
|
ProductLoaderEvent.searchProduct(
|
||||||
categoryId: categoryId,
|
query: value,
|
||||||
query: value,
|
|
||||||
),
|
|
||||||
);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
},
|
|
||||||
),
|
|
||||||
|
|
||||||
// Local database stats
|
|
||||||
if (_databaseStats.isNotEmpty) ...[
|
|
||||||
SizedBox(height: 8),
|
|
||||||
Row(
|
|
||||||
children: [
|
|
||||||
// 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');
|
|
||||||
},
|
|
||||||
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),
|
|
||||||
),
|
|
||||||
),
|
|
||||||
],
|
|
||||||
),
|
),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
@ -473,7 +340,7 @@ class _HomePageState extends State<HomePage> {
|
|||||||
CircularProgressIndicator(color: AppColors.primary),
|
CircularProgressIndicator(color: AppColors.primary),
|
||||||
SizedBox(height: 16),
|
SizedBox(height: 16),
|
||||||
Text(
|
Text(
|
||||||
'Memuat data lokal...',
|
'Memuat data...',
|
||||||
style: TextStyle(color: Colors.grey.shade600),
|
style: TextStyle(color: Colors.grey.shade600),
|
||||||
),
|
),
|
||||||
],
|
],
|
||||||
@ -491,12 +358,12 @@ class _HomePageState extends State<HomePage> {
|
|||||||
Text(
|
Text(
|
||||||
searchQuery.isNotEmpty
|
searchQuery.isNotEmpty
|
||||||
? 'Produk "$searchQuery" tidak ditemukan'
|
? 'Produk "$searchQuery" tidak ditemukan'
|
||||||
: 'Belum ada data produk lokal',
|
: 'Belum ada data produk',
|
||||||
textAlign: TextAlign.center,
|
textAlign: TextAlign.center,
|
||||||
),
|
),
|
||||||
SizedBox(height: 8),
|
SizedBox(height: 8),
|
||||||
Text(
|
Text(
|
||||||
'Tambahkan produk ke database lokal terlebih dahulu',
|
'Data akan dimuat dari database lokal',
|
||||||
style: TextStyle(
|
style: TextStyle(
|
||||||
color: Colors.grey.shade600,
|
color: Colors.grey.shade600,
|
||||||
fontSize: 12,
|
fontSize: 12,
|
||||||
@ -542,18 +409,11 @@ class _HomePageState extends State<HomePage> {
|
|||||||
child: Column(
|
child: Column(
|
||||||
mainAxisAlignment: MainAxisAlignment.center,
|
mainAxisAlignment: MainAxisAlignment.center,
|
||||||
children: [
|
children: [
|
||||||
Icon(
|
Icon(Icons.error_outline, size: 48, color: Colors.red.shade400),
|
||||||
Icons.error_outline,
|
|
||||||
size: 48,
|
|
||||||
color: Colors.red.shade400,
|
|
||||||
),
|
|
||||||
SizedBox(height: 16),
|
SizedBox(height: 16),
|
||||||
Text(
|
Text(
|
||||||
'Error Database Lokal',
|
'Error Database',
|
||||||
style: TextStyle(
|
style: TextStyle(fontSize: 16, fontWeight: FontWeight.w600),
|
||||||
fontSize: 16,
|
|
||||||
fontWeight: FontWeight.w600,
|
|
||||||
),
|
|
||||||
),
|
),
|
||||||
SizedBox(height: 8),
|
SizedBox(height: 8),
|
||||||
Padding(
|
Padding(
|
||||||
@ -588,61 +448,19 @@ class _HomePageState extends State<HomePage> {
|
|||||||
) {
|
) {
|
||||||
return Column(
|
return Column(
|
||||||
children: [
|
children: [
|
||||||
// Product count with local indicator
|
// Simple product count
|
||||||
if (products.isNotEmpty)
|
if (products.isNotEmpty)
|
||||||
Container(
|
Container(
|
||||||
padding: EdgeInsets.symmetric(horizontal: 16, vertical: 6),
|
padding: EdgeInsets.symmetric(horizontal: 16, vertical: 6),
|
||||||
child: Row(
|
child: Row(
|
||||||
children: [
|
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(
|
Text(
|
||||||
'produk dari database lokal',
|
'${products.length} produk ditemukan',
|
||||||
style: TextStyle(
|
style: TextStyle(
|
||||||
color: Colors.grey.shade600,
|
color: Colors.grey.shade600,
|
||||||
fontSize: 11,
|
fontSize: 12,
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
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(),
|
Spacer(),
|
||||||
if (isLoadingMore)
|
if (isLoadingMore)
|
||||||
SizedBox(
|
SizedBox(
|
||||||
@ -657,7 +475,7 @@ class _HomePageState extends State<HomePage> {
|
|||||||
),
|
),
|
||||||
),
|
),
|
||||||
|
|
||||||
// Products grid - faster loading from local DB
|
// Products grid
|
||||||
Expanded(
|
Expanded(
|
||||||
child: NotificationListener<ScrollNotification>(
|
child: NotificationListener<ScrollNotification>(
|
||||||
onNotification: (notification) =>
|
onNotification: (notification) =>
|
||||||
@ -666,7 +484,7 @@ class _HomePageState extends State<HomePage> {
|
|||||||
itemCount: products.length,
|
itemCount: products.length,
|
||||||
controller: scrollController,
|
controller: scrollController,
|
||||||
padding: const EdgeInsets.all(16),
|
padding: const EdgeInsets.all(16),
|
||||||
cacheExtent: 200.0, // Bigger cache for smooth scrolling
|
cacheExtent: 200.0,
|
||||||
gridDelegate: SliverGridDelegateWithMaxCrossAxisExtent(
|
gridDelegate: SliverGridDelegateWithMaxCrossAxisExtent(
|
||||||
maxCrossAxisExtent: 180,
|
maxCrossAxisExtent: 180,
|
||||||
mainAxisSpacing: 30,
|
mainAxisSpacing: 30,
|
||||||
@ -683,12 +501,12 @@ class _HomePageState extends State<HomePage> {
|
|||||||
),
|
),
|
||||||
),
|
),
|
||||||
|
|
||||||
// End of data indicator
|
// End indicator
|
||||||
if (hasReachedMax && products.isNotEmpty)
|
if (hasReachedMax && products.isNotEmpty)
|
||||||
Container(
|
Container(
|
||||||
padding: EdgeInsets.all(8),
|
padding: EdgeInsets.all(8),
|
||||||
child: Text(
|
child: Text(
|
||||||
'Semua produk lokal telah dimuat',
|
'Semua produk telah dimuat',
|
||||||
style: TextStyle(
|
style: TextStyle(
|
||||||
color: Colors.grey.shade500,
|
color: Colors.grey.shade500,
|
||||||
fontSize: 11,
|
fontSize: 11,
|
||||||
@ -786,7 +604,7 @@ class _HomePageState extends State<HomePage> {
|
|||||||
),
|
),
|
||||||
),
|
),
|
||||||
|
|
||||||
// Payment section (unchanged)
|
// Payment section
|
||||||
Padding(
|
Padding(
|
||||||
padding: const EdgeInsets.all(16.0).copyWith(top: 0),
|
padding: const EdgeInsets.all(16.0).copyWith(top: 0),
|
||||||
child: Column(
|
child: Column(
|
||||||
|
|||||||
@ -1,6 +1,5 @@
|
|||||||
import 'package:enaklo_pos/core/constants/colors.dart';
|
import 'package:enaklo_pos/core/constants/colors.dart';
|
||||||
import 'package:enaklo_pos/data/models/response/category_response_model.dart';
|
import 'package:enaklo_pos/data/models/response/category_response_model.dart';
|
||||||
import 'package:enaklo_pos/presentation/home/bloc/category_loader/category_loader_bloc.dart';
|
|
||||||
import 'package:enaklo_pos/presentation/home/bloc/product_loader/product_loader_bloc.dart';
|
import 'package:enaklo_pos/presentation/home/bloc/product_loader/product_loader_bloc.dart';
|
||||||
import 'package:flutter/material.dart';
|
import 'package:flutter/material.dart';
|
||||||
import 'package:flutter_bloc/flutter_bloc.dart';
|
import 'package:flutter_bloc/flutter_bloc.dart';
|
||||||
@ -37,9 +36,6 @@ class _CategoryTabBarState extends State<CategoryTabBar>
|
|||||||
context.read<ProductLoaderBloc>().add(
|
context.read<ProductLoaderBloc>().add(
|
||||||
ProductLoaderEvent.getProduct(categoryId: selectedCategoryId),
|
ProductLoaderEvent.getProduct(categoryId: selectedCategoryId),
|
||||||
);
|
);
|
||||||
context
|
|
||||||
.read<CategoryLoaderBloc>()
|
|
||||||
.add(CategoryLoaderEvent.setCategoryId(selectedCategoryId ?? ""));
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|||||||
@ -1,5 +1,5 @@
|
|||||||
import 'package:bloc/bloc.dart';
|
import 'package:bloc/bloc.dart';
|
||||||
import 'package:enaklo_pos/data/datasources/category_remote_datasource.dart';
|
import 'package:enaklo_pos/data/datasources/category/category_remote_datasource.dart';
|
||||||
import 'package:enaklo_pos/data/models/response/category_response_model.dart';
|
import 'package:enaklo_pos/data/models/response/category_response_model.dart';
|
||||||
import 'package:freezed_annotation/freezed_annotation.dart';
|
import 'package:freezed_annotation/freezed_annotation.dart';
|
||||||
|
|
||||||
|
|||||||
@ -1,5 +1,3 @@
|
|||||||
import 'dart:async';
|
|
||||||
|
|
||||||
import 'package:bloc/bloc.dart';
|
import 'package:bloc/bloc.dart';
|
||||||
import 'package:enaklo_pos/data/models/response/table_model.dart';
|
import 'package:enaklo_pos/data/models/response/table_model.dart';
|
||||||
import 'package:freezed_annotation/freezed_annotation.dart';
|
import 'package:freezed_annotation/freezed_annotation.dart';
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user