generated from dellevin/template
服务端接口优化
todo：待添加影评海报，书评书摘的接口与标签接口
This commit is contained in:
DelLevin-Home
@@ -2,16 +2,21 @@ import 'dart:async';
|
||||
import 'dart:convert';
|
||||
import 'dart:io';
|
||||
import 'package:flutter/foundation.dart';
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:http/http.dart' as http;
|
||||
import 'package:path_provider/path_provider.dart';
|
||||
import 'package:path/path.dart' as p;
|
||||
import 'package:sqflite/sqflite.dart';
|
||||
import '../user_prefs.dart';
|
||||
import '../database_helper.dart';
|
||||
import '../../models/data_models.dart';
|
||||
import '../movie/movie_dao.dart';
|
||||
import '../book/book_dao.dart';
|
||||
import '../note/note_dao.dart';
|
||||
import 'server_data_service.dart';
|
||||
|
||||
/// 服务端实时同步服务
|
||||
/// - 开启时：上传一次本地数据到服务器，后续 CRUD 走 API
|
||||
/// - 关闭时：从服务器下载数据到本地，切换本地数据库
|
||||
/// - 开启时：智能合并本地与服务端数据
|
||||
/// - 关闭时：从服务器下载数据到本地
|
||||
class ServerSyncService {
|
||||
static final ServerSyncService instance = ServerSyncService._();
|
||||
ServerSyncService._();
|
||||
@@ -46,59 +51,131 @@ class ServerSyncService {
|
||||
try { final d = jsonDecode(s); return d is Map<String, dynamic> ? d : null; } catch (_) { return null; }
|
||||
}
|
||||
|
||||
/// 开启同步：上传本地数据到服务器
|
||||
Future<bool> uploadToServer() async {
|
||||
/// 开启同步：智能合并本地与服务端数据
|
||||
Future<bool> syncWithServer() async {
|
||||
if (!isConfigured || _isSyncing) return false;
|
||||
_isSyncing = true;
|
||||
try {
|
||||
final url = _prefs.syncServerUrl;
|
||||
final code = _prefs.syncActivationCode;
|
||||
final deviceId = _prefs.deviceId;
|
||||
final server = ServerDataService.instance;
|
||||
|
||||
final dbPath = await DatabaseHelper.instance.databasePath;
|
||||
if (dbPath == null || !File(dbPath).existsSync()) {
|
||||
debugPrint('[Sync] 数据库文件不存在');
|
||||
return false;
|
||||
}
|
||||
// 读取本地数据
|
||||
final localMovies = await MovieDao().getAllMovies();
|
||||
final localBooks = await BookDao().getAllBooks();
|
||||
final localNotes = await NoteDao().getAllNotes();
|
||||
|
||||
final request = http.MultipartRequest('POST', Uri.parse('$url/api/sync/upload'));
|
||||
request.fields['code'] = code;
|
||||
request.fields['device_id'] = deviceId;
|
||||
request.files.add(await http.MultipartFile.fromPath('database', dbPath));
|
||||
// 读取服务端数据
|
||||
final remoteMovies = await server.getMovies();
|
||||
final remoteBooks = await server.getBooks();
|
||||
final remoteNotes = await server.getNotes();
|
||||
|
||||
final appDir = await getApplicationDocumentsDirectory();
|
||||
final imgDir = Directory(p.join(appDir.path, 'images'));
|
||||
if (await imgDir.exists()) {
|
||||
await for (final entity in imgDir.list(recursive: true)) {
|
||||
if (entity is File) {
|
||||
final relPath = p.relative(entity.path, from: appDir.path).replaceAll('\\', '/');
|
||||
request.files.add(await http.MultipartFile('images', entity.readAsBytes().asStream(), await entity.length(), filename: relPath));
|
||||
// 需要 push 到服务端的数据
|
||||
final pushMovies = <Movie>[];
|
||||
final pushBooks = <Book>[];
|
||||
final pushNotes = <Note>[];
|
||||
final imagePaths = <String>[];
|
||||
|
||||
// 服务端无数据 → 全量 push
|
||||
if (remoteMovies.isEmpty && remoteBooks.isEmpty && remoteNotes.isEmpty) {
|
||||
pushMovies.addAll(localMovies);
|
||||
pushBooks.addAll(localBooks);
|
||||
pushNotes.addAll(localNotes);
|
||||
} else {
|
||||
// 按 updated_at 合并
|
||||
final remoteMovieMap = {for (final m in remoteMovies) m.id: m};
|
||||
for (final m in localMovies) {
|
||||
final r = remoteMovieMap.remove(m.id);
|
||||
if (r == null || m.updatedAt.isAfter(r.updatedAt)) {
|
||||
pushMovies.add(m);
|
||||
} else {
|
||||
await _upsertLocalMovie(m: r);
|
||||
}
|
||||
}
|
||||
for (final r in remoteMovieMap.values) {
|
||||
await _upsertLocalMovie(m: r);
|
||||
}
|
||||
|
||||
final remoteBookMap = {for (final b in remoteBooks) b.id: b};
|
||||
for (final b in localBooks) {
|
||||
final r = remoteBookMap.remove(b.id);
|
||||
if (r == null || b.updatedAt.isAfter(r.updatedAt)) {
|
||||
pushBooks.add(b);
|
||||
} else {
|
||||
await _upsertLocalBook(b: r);
|
||||
}
|
||||
}
|
||||
for (final r in remoteBookMap.values) {
|
||||
await _upsertLocalBook(b: r);
|
||||
}
|
||||
|
||||
final remoteNoteMap = {for (final n in remoteNotes) n.id: n};
|
||||
for (final n in localNotes) {
|
||||
final r = remoteNoteMap.remove(n.id);
|
||||
if (r == null || n.updatedAt.isAfter(r.updatedAt)) {
|
||||
pushNotes.add(n);
|
||||
} else {
|
||||
await _upsertLocalNote(n: r);
|
||||
}
|
||||
}
|
||||
for (final r in remoteNoteMap.values) {
|
||||
await _upsertLocalNote(n: r);
|
||||
}
|
||||
}
|
||||
|
||||
final avatarsDir = Directory(p.join(appDir.path, 'avatars'));
|
||||
if (await avatarsDir.exists()) {
|
||||
await for (final entity in avatarsDir.list()) {
|
||||
if (entity is File) {
|
||||
final relPath = p.relative(entity.path, from: appDir.path).replaceAll('\\', '/');
|
||||
request.files.add(await http.MultipartFile('images', entity.readAsBytes().asStream(), await entity.length(), filename: relPath));
|
||||
}
|
||||
// 批量 push 到服务端
|
||||
if (pushMovies.isNotEmpty || pushBooks.isNotEmpty || pushNotes.isNotEmpty) {
|
||||
final db = await DatabaseHelper.instance.database;
|
||||
final localTags = await db.query('tags');
|
||||
final result = await server.batchSync(
|
||||
movies: pushMovies.isEmpty ? null : pushMovies,
|
||||
books: pushBooks.isEmpty ? null : pushBooks,
|
||||
notes: pushNotes.isEmpty ? null : pushNotes,
|
||||
tags: localTags.isEmpty ? null : localTags.cast<Map<String, dynamic>>(),
|
||||
);
|
||||
debugPrint('[Sync] 批量推送: $result');
|
||||
|
||||
// 收集需要上传的图片
|
||||
for (final m in pushMovies) {
|
||||
if (m.posterPath != null && m.posterPath!.isNotEmpty) imagePaths.add(m.posterPath!);
|
||||
}
|
||||
for (final b in pushBooks) {
|
||||
if (b.coverPath != null && b.coverPath!.isNotEmpty) imagePaths.add(b.coverPath!);
|
||||
}
|
||||
for (final n in pushNotes) {
|
||||
imagePaths.addAll(n.images.where((i) => i.isNotEmpty));
|
||||
}
|
||||
}
|
||||
|
||||
final resp = await request.send().timeout(const Duration(seconds: 300));
|
||||
if (resp.statusCode == 200) {
|
||||
debugPrint('[Sync] 上传成功');
|
||||
return true;
|
||||
// 上传图片
|
||||
if (imagePaths.isNotEmpty) {
|
||||
debugPrint('[Sync] 上传 ${imagePaths.length} 张图片');
|
||||
await ServerDataService.uploadLocalImages(imagePaths);
|
||||
}
|
||||
debugPrint('[Sync] 上传失败 HTTP ${resp.statusCode}');
|
||||
|
||||
debugPrint('[Sync] 合并完成');
|
||||
return true;
|
||||
} catch (e) {
|
||||
debugPrint('[Sync] 上传异常: $e');
|
||||
debugPrint('[Sync] 合并异常: $e');
|
||||
return false;
|
||||
} finally {
|
||||
_isSyncing = false;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
// ─── 合并辅助方法 ────────────────────────────────────────────
|
||||
|
||||
Future<void> _upsertLocalMovie({required Movie m}) async {
|
||||
final db = await DatabaseHelper.instance.database;
|
||||
await db.insert('movies', m.toJson(), conflictAlgorithm: ConflictAlgorithm.replace);
|
||||
}
|
||||
|
||||
Future<void> _upsertLocalBook({required Book b}) async {
|
||||
final db = await DatabaseHelper.instance.database;
|
||||
await db.insert('books', b.toJson(), conflictAlgorithm: ConflictAlgorithm.replace);
|
||||
}
|
||||
|
||||
Future<void> _upsertLocalNote({required Note n}) async {
|
||||
final db = await DatabaseHelper.instance.database;
|
||||
await db.insert('notes', n.toJson(), conflictAlgorithm: ConflictAlgorithm.replace);
|
||||
}
|
||||
|
||||
/// 关闭同步：从服务器下载数据到本地
|
||||
|
||||
Reference in New Issue
Block a user