Files
MookNote/lib/utils/sync/auto_backup_service.dart
2026-06-28 02:25:07 +08:00

237 lines
7.0 KiB
Dart
Raw Blame History

This file contains ambiguous Unicode characters
This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.
import 'dart:async';
import 'dart:io';
import 'package:flutter/foundation.dart';
import 'package:path_provider/path_provider.dart';
import 'package:path/path.dart' as path;
import 'package:shared_preferences/shared_preferences.dart';
import 'backup_service.dart';
/// 自动备份服务 - 定时自动备份到下载目录
class AutoBackupService {
static final AutoBackupService instance = AutoBackupService._init();
AutoBackupService._init();
Timer? _timer;
bool _isRunning = false;
static const String _prefsKey = 'auto_backup_enabled';
static const String _backupDirName = 'mooknote';
static const int _maxBackups = 5;
static const Duration _backupInterval = Duration(minutes: 5);
/// 是否正在运行
bool get isRunning => _isRunning;
/// 获取自动备份状态
Future<bool> getEnabled() async {
final prefs = await SharedPreferences.getInstance();
return prefs.getBool(_prefsKey) ?? false;
}
/// 设置自动备份状态
Future<void> setEnabled(bool enabled) async {
final prefs = await SharedPreferences.getInstance();
await prefs.setBool(_prefsKey, enabled);
if (enabled) {
await start();
} else {
await stop();
}
}
/// 启动自动备份
Future<void> start() async {
if (_isRunning) return;
_isRunning = true;
// 立即执行一次备份
await _performBackup();
// 启动定时器
_timer = Timer.periodic(_backupInterval, (_) async {
await _performBackup();
});
}
/// 停止自动备份
Future<void> stop() async {
_timer?.cancel();
_timer = null;
_isRunning = false;
}
/// 执行备份
Future<void> _performBackup() async {
try {
final backupDir = await _getBackupDirectory();
if (backupDir == null) {
debugPrint('AutoBackup: 无法获取备份目录');
return;
}
// 确保备份目录存在
if (!await backupDir.exists()) {
await backupDir.create(recursive: true);
}
// 导出数据
final result = await BackupService.instance.exportDataForAutoBackup();
if (!result.success) {
debugPrint('AutoBackup: 导出失败 - ${result.errorMessage}');
return;
}
// 生成备份文件名
final fileName = 'auto_backup_${_formatDateTime(DateTime.now())}.zip';
final backupFile = File(path.join(backupDir.path, fileName));
// 写入备份文件
await backupFile.writeAsBytes(result.zipBytes!);
debugPrint('AutoBackup: 备份成功 - ${backupFile.path}');
// 清理旧备份只保留最新的5个
await _cleanupOldBackups(backupDir);
} catch (e) {
debugPrint('AutoBackup: 备份失败 - $e');
}
}
/// 获取备份目录(下载目录/mooknote
Future<Directory?> _getBackupDirectory() async {
try {
if (Platform.isAndroid) {
// 优先级 1: 官方 API 获取下载目录
try {
final dirs = await getExternalStorageDirectories(
type: StorageDirectory.downloads,
);
if (dirs != null && dirs.isNotEmpty) {
return Directory('${dirs.first.path}/$_backupDirName');
}
} catch (_) {}
// 优先级 2: 标准路径直接拼
final standardPath = '/storage/emulated/0/Download/$_backupDirName';
final standardDir = Directory(standardPath);
if (await standardDir.parent.exists()) {
return standardDir;
}
// 优先级 3: 从外部存储路径推导(旧逻辑兜底)
final externalDir = await getExternalStorageDirectory();
if (externalDir != null) {
final segments = externalDir.uri.pathSegments;
if (segments.length >= 3) {
final pkg = segments[segments.length - 3];
final downloadPath = externalDir.path.replaceAll(
'/Android/data/$pkg/files',
'/Download',
);
return Directory('$downloadPath/$_backupDirName');
}
}
// 优先级 4: 降级到 app 内部目录
final appDir = await getApplicationDocumentsDirectory();
return Directory('${appDir.path}/$_backupDirName');
} else if (Platform.isIOS) {
final docDir = await getApplicationDocumentsDirectory();
return Directory('${docDir.path}/$_backupDirName');
} else {
// 桌面端
final home = Platform.environment['HOME'] ?? Platform.environment['USERPROFILE'];
if (home != null) {
return Directory('$home/Downloads/$_backupDirName');
}
final docDir = await getApplicationDocumentsDirectory();
return Directory('${docDir.path}/$_backupDirName');
}
} catch (e) {
debugPrint('AutoBackup: 获取备份目录失败 - $e');
return null;
}
}
/// 清理旧备份只保留最新的5个
Future<void> _cleanupOldBackups(Directory backupDir) async {
try {
final files = await backupDir
.list()
.where((entity) => entity is File && entity.path.endsWith('.zip'))
.cast<File>()
.toList();
// 按修改时间排序(最新的在前)
files.sort((a, b) {
final aStat = a.statSync();
final bStat = b.statSync();
return bStat.modified.compareTo(aStat.modified);
});
// 删除超过10个的旧备份
if (files.length > _maxBackups) {
for (var i = _maxBackups; i < files.length; i++) {
try {
await files[i].delete();
debugPrint('AutoBackup: 删除旧备份 - ${files[i].path}');
} catch (e) {
debugPrint('AutoBackup: 删除旧备份失败 - $e');
}
}
}
} catch (e) {
debugPrint('AutoBackup: 清理旧备份失败 - $e');
}
}
/// 获取备份文件列表
Future<List<File>> getBackupFiles() async {
try {
final backupDir = await _getBackupDirectory();
if (backupDir == null || !await backupDir.exists()) {
return [];
}
final files = await backupDir
.list()
.where((entity) => entity is File && entity.path.endsWith('.zip'))
.cast<File>()
.toList();
// 按修改时间排序(最新的在前)
files.sort((a, b) {
final aStat = a.statSync();
final bStat = b.statSync();
return bStat.modified.compareTo(aStat.modified);
});
return files;
} catch (e) {
debugPrint('AutoBackup: 获取备份列表失败 - $e');
return [];
}
}
/// 获取备份目录路径
Future<String?> getBackupDirectoryPath() async {
final dir = await _getBackupDirectory();
return dir?.path;
}
/// 格式化日期时间用于文件名
String _formatDateTime(DateTime dateTime) {
return '${dateTime.year}${_pad(dateTime.month)}${_pad(dateTime.day)}_${_pad(dateTime.hour)}${_pad(dateTime.minute)}${_pad(dateTime.second)}';
}
String _pad(int number) {
return number.toString().padLeft(2, '0');
}
}