dellevin/MookNote
1
0
Fork 0
generated from dellevin/template
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

同步优化2

Browse Source
This commit is contained in:
DelLevin-Home
2026-05-28 08:28:19 +08:00
parent 7efd03c6ba
commit e2e0b11d3d
2 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
lib/pages/sync/server_sync_page.dart
View File

@@ -129,6 +129,7 @@ class _ServerSyncPageState extends State<ServerSyncPage> {
if (value && _isActivated) { if (value && _isActivated) {
// 开启同步：合并本地与服务端数据 // 开启同步：合并本地与服务端数据
await _prefs.setSyncEnabled(true); await _prefs.setSyncEnabled(true);
if (!mounted) return;
setState(() => _syncEnabled = true); setState(() => _syncEnabled = true);
if (mounted) ToastUtil.show(context, '正在同步数据...'); if (mounted) ToastUtil.show(context, '正在同步数据...');
await ServerSyncService.instance.syncWithServer(); await ServerSyncService.instance.syncWithServer();
@@ -142,6 +143,7 @@ class _ServerSyncPageState extends State<ServerSyncPage> {
if (mounted) ToastUtil.show(context, '正在从服务器下载数据...'); if (mounted) ToastUtil.show(context, '正在从服务器下载数据...');
final success = await ServerSyncService.instance.downloadToLocal(); final success = await ServerSyncService.instance.downloadToLocal();
await _prefs.setSyncEnabled(false); await _prefs.setSyncEnabled(false);
if (!mounted) return;
setState(() => _syncEnabled = false); setState(() => _syncEnabled = false);
final provider = context.read<AppProvider>(); final provider = context.read<AppProvider>();
await provider.loadMovies(); await provider.loadMovies();

9
lib/utils/sync/server_sync_service.dart
View File

@@ -404,9 +404,14 @@ class ServerSyncService {
final dbPath = await DatabaseHelper.instance.databasePath; final dbPath = await DatabaseHelper.instance.databasePath;
if (dbPath != null) { if (dbPath != null) {
final dbFile = File(dbPath);
// 先关掉旧连接，删除旧文件，再写入新数据库
await DatabaseHelper.instance.close(); await DatabaseHelper.instance.close();
await File(dbPath).writeAsBytes(dbResp.bodyBytes); if (await dbFile.exists()) await dbFile.delete();
await DatabaseHelper.instance.reopen(); await dbFile.writeAsBytes(dbResp.bodyBytes);
// 设置正确的版本号
final db = await openDatabase(dbPath, version: 14);
await db.close();
debugPrint('[Sync] 数据库已写入: $dbPath'); debugPrint('[Sync] 数据库已写入: $dbPath');
} }