14 changed files with 71 additions and 296 deletions
@ -1,254 +0,0 @@
|
||||
// sqlite_provider.dart |
||||
|
||||
import 'package:get/get.dart'; |
||||
import 'package:problem_check_system/app/core/models/problem_sync_status.dart'; |
||||
import 'package:problem_check_system/app/core/models/problem_model.dart'; |
||||
import 'package:sqflite/sqflite.dart'; |
||||
import 'package:path/path.dart'; |
||||
|
||||
/// `SQLiteService` 是一个 GetxService，负责管理本地 SQLite 数据库。 |
||||
/// 作为一个单例服务，它在整个应用生命周期中只会被创建一次。 |
||||
class SQLiteService extends GetxService { |
||||
static const String _dbName = 'problems.db'; |
||||
static const String _tableName = 'problems'; |
||||
static const int _dbVersion = 1; |
||||
|
||||
late Database _database; |
||||
|
||||
@override |
||||
void onInit() { |
||||
super.onInit(); |
||||
_initDatabase(); |
||||
} |
||||
|
||||
/// 异步初始化数据库连接 |
||||
Future<void> _initDatabase() async { |
||||
try { |
||||
final databasePath = await getDatabasesPath(); |
||||
final path = join(databasePath, _dbName); |
||||
|
||||
_database = await openDatabase( |
||||
path, |
||||
version: _dbVersion, |
||||
onCreate: _onCreate, |
||||
onUpgrade: _onUpgrade, |
||||
); |
||||
|
||||
Get.log('数据库初始化成功'); |
||||
} catch (e) { |
||||
Get.log('数据库初始化失败：$e', isError: true); |
||||
rethrow; |
||||
} |
||||
} |
||||
|
||||
/// 数据库创建时的回调函数 |
||||
Future<void> _onCreate(Database db, int version) async { |
||||
await db.execute(''' |
||||
CREATE TABLE $_tableName( |
||||
id TEXT PRIMARY KEY, |
||||
description TEXT NOT NULL, |
||||
location TEXT NOT NULL, |
||||
imageUrls TEXT NOT NULL, |
||||
creationTime INTEGER NOT NULL, |
||||
creatorId TEXT NOT NULL, |
||||
lastModifiedTime INTEGER NOT NULL, |
||||
syncStatus INTEGER NOT NULL, |
||||
censorTaskId TEXT, |
||||
bindData TEXT, |
||||
isChecked INTEGER NOT NULL |
||||
) |
||||
'''); |
||||
|
||||
Get.log('数据库表创建成功'); |
||||
} |
||||
|
||||
/// 数据库版本升级处理 |
||||
Future<void> _onUpgrade(Database db, int oldVersion, int newVersion) async { |
||||
Get.log('正在将数据库从版本 $oldVersion 升级到 $newVersion...'); |
||||
|
||||
// 版本升级迁移逻辑 |
||||
for (int version = oldVersion + 1; version <= newVersion; version++) { |
||||
await _runMigration(db, version); |
||||
} |
||||
|
||||
Get.log('数据库升级完成'); |
||||
} |
||||
|
||||
/// 执行特定版本的数据库迁移 |
||||
Future<void> _runMigration(Database db, int version) async { |
||||
switch (version) { |
||||
case 2: |
||||
// 版本2迁移逻辑 |
||||
// await db.execute('ALTER TABLE $_tableName ADD COLUMN newColumn TEXT;'); |
||||
break; |
||||
// 添加更多版本迁移逻辑 |
||||
default: |
||||
Get.log('没有找到版本 $version 的迁移脚本'); |
||||
} |
||||
} |
||||
|
||||
/// 插入问题记录，并设置同步状态为未同步 |
||||
Future<int> insertProblem(Problem problem) async { |
||||
try { |
||||
final result = await _database.insert( |
||||
_tableName, |
||||
problem.toMap(), |
||||
conflictAlgorithm: ConflictAlgorithm.replace, |
||||
); |
||||
|
||||
Get.log('问题记录插入成功，ID: ${problem.id}'); |
||||
return result; |
||||
} catch (e) { |
||||
Get.log('插入问题失败（ID: ${problem.id}）：$e', isError: true); |
||||
throw Exception(''); |
||||
} |
||||
} |
||||
|
||||
/// 从数据库物理删除问题记录 |
||||
Future<int> deleteProblem(String problemId) async { |
||||
try { |
||||
final result = await _database.delete( |
||||
_tableName, |
||||
where: 'id = ?', |
||||
whereArgs: [problemId], |
||||
); |
||||
|
||||
if (result > 0) { |
||||
Get.log('问题删除成功，ID: $problemId'); |
||||
} else { |
||||
Get.log('未找到要删除的问题，ID: $problemId'); |
||||
} |
||||
|
||||
return result; |
||||
} catch (e) { |
||||
Get.log('删除问题失败（ID: $problemId）：$e', isError: true); |
||||
return 0; |
||||
} |
||||
} |
||||
|
||||
/// 更新问题记录，并设置同步状态为未同步 |
||||
Future<int> updateProblem(Problem problem) async { |
||||
try { |
||||
final result = await _database.update( |
||||
_tableName, |
||||
problem.toMap(), |
||||
where: 'id = ?', |
||||
whereArgs: [problem.id], |
||||
); |
||||
|
||||
if (result > 0) { |
||||
Get.log('问题更新成功，ID: ${problem.id}'); |
||||
} |
||||
|
||||
return result; |
||||
} catch (e) { |
||||
Get.log('更新问题失败（ID: ${problem.id}）：$e', isError: true); |
||||
return 0; |
||||
} |
||||
} |
||||
|
||||
/// 标记问题为已同步（在同步成功后调用） |
||||
Future<int> markAsSynced(String id) async { |
||||
try { |
||||
final result = await _database.update( |
||||
_tableName, |
||||
{'syncStatus': ProblemSyncStatus.synced.index}, |
||||
where: 'id = ?', |
||||
whereArgs: [id], |
||||
); |
||||
|
||||
if (result > 0) { |
||||
Get.log('问题标记为已同步，ID: $id'); |
||||
} |
||||
|
||||
return result; |
||||
} catch (e) { |
||||
Get.log('标记同步状态失败（ID: $id）：$e', isError: true); |
||||
return 0; |
||||
} |
||||
} |
||||
|
||||
/// 根据ID获取问题记录 |
||||
Future<Problem?> getProblemById(String id) async { |
||||
try { |
||||
final results = await _database.query( |
||||
_tableName, |
||||
where: 'id = ?', |
||||
whereArgs: [id], |
||||
limit: 1, |
||||
); |
||||
|
||||
return results.isNotEmpty ? Problem.fromMap(results.first) : null; |
||||
} catch (e) { |
||||
Get.log('获取问题失败（ID: $id）：$e', isError: true); |
||||
return null; |
||||
} |
||||
} |
||||
|
||||
/// 获取问题列表（支持多种筛选条件） |
||||
Future<List<Problem>> getProblems({ |
||||
DateTime? startDate, |
||||
DateTime? endDate, |
||||
String? syncStatus, |
||||
String? bindStatus, |
||||
}) async { |
||||
try { |
||||
final whereClauses = <String>[]; |
||||
final whereArgs = <dynamic>[]; |
||||
|
||||
// 时间范围筛选 |
||||
if (startDate != null) { |
||||
whereClauses.add('creationTime >= ?'); |
||||
whereArgs.add(startDate.millisecondsSinceEpoch); |
||||
} |
||||
|
||||
if (endDate != null) { |
||||
whereClauses.add('creationTime <= ?'); |
||||
whereArgs.add(endDate.millisecondsSinceEpoch); |
||||
} |
||||
|
||||
// 同步状态筛选 |
||||
if (syncStatus != null && syncStatus != '全部') { |
||||
if (syncStatus == '未上传') { |
||||
whereClauses.add('syncStatus IN (?, ?, ?)'); |
||||
whereArgs.addAll([ |
||||
ProblemSyncStatus.pendingCreate.index, |
||||
ProblemSyncStatus.pendingUpdate.index, |
||||
ProblemSyncStatus.pendingDelete.index, |
||||
]); |
||||
} else { |
||||
whereClauses.add('syncStatus = ?'); |
||||
whereArgs.add(ProblemSyncStatus.synced.index); |
||||
} |
||||
} |
||||
|
||||
// 绑定状态筛选 |
||||
if (bindStatus != null && bindStatus != '全部') { |
||||
if (bindStatus == '已绑定') { |
||||
whereClauses.add('bindData IS NOT NULL AND bindData != ""'); |
||||
} else { |
||||
whereClauses.add('(bindData IS NULL OR bindData = "")'); |
||||
} |
||||
} |
||||
|
||||
final results = await _database.query( |
||||
_tableName, |
||||
where: whereClauses.isNotEmpty ? whereClauses.join(' AND ') : null, |
||||
whereArgs: whereArgs.isEmpty ? null : whereArgs, |
||||
orderBy: 'creationTime DESC', |
||||
); |
||||
|
||||
return results.map((json) => Problem.fromMap(json)).toList(); |
||||
} catch (e) { |
||||
Get.log('获取问题列表失败：$e', isError: true); |
||||
return []; |
||||
} |
||||
} |
||||
|
||||
@override |
||||
void onClose() { |
||||
_database.close(); |
||||
Get.log('数据库连接已关闭'); |
||||
super.onClose(); |
||||
} |
||||
} |
||||
Loading…
Reference in new issue