mirror of
https://ghfast.top/https://github.com/StarCitizenToolBox/app.git
synced 2025-05-10 03:51:23 +08:00
102 lines
2.8 KiB
Dart
102 lines
2.8 KiB
Dart
import 'dart:io';
|
||
import 'package:flutter/foundation.dart';
|
||
import 'package:path/path.dart' as path;
|
||
import 'package:path_provider/path_provider.dart';
|
||
import 'dart:convert';
|
||
import 'package:crypto/crypto.dart';
|
||
import 'package:starcitizen_doctor/common/io/rs_http.dart';
|
||
|
||
class FileCacheUtils {
|
||
// 存储正在进行的下载任务
|
||
static final Map<String, Future<File>> _downloadingTasks = {};
|
||
|
||
// 缓存目录
|
||
static Directory? _cacheDir;
|
||
|
||
/// 获取缓存目录
|
||
static Future<Directory> _getCacheDirectory() async {
|
||
if (_cacheDir != null) return _cacheDir!;
|
||
|
||
final tempDir = await getTemporaryDirectory();
|
||
_cacheDir = Directory(path.join(tempDir.path, 'ScToolbox_File_Cache'));
|
||
|
||
if (!await _cacheDir!.exists()) {
|
||
await _cacheDir!.create(recursive: true);
|
||
}
|
||
|
||
return _cacheDir!;
|
||
}
|
||
|
||
/// 从URL获取文件，如果已经在下载中，则共享同一个下载任务
|
||
static Future<File> getFile(String url) async {
|
||
// 如果已经在下载中，直接返回正在进行的下载任务
|
||
if (_downloadingTasks.containsKey(url)) {
|
||
return _downloadingTasks[url]!;
|
||
}
|
||
|
||
final fileTask = _downloadFile(url);
|
||
_downloadingTasks[url] = fileTask;
|
||
|
||
try {
|
||
final file = await fileTask;
|
||
return file;
|
||
} finally {
|
||
// 无论成功失败，下载完成后从任务列表中移除
|
||
_downloadingTasks.remove(url);
|
||
}
|
||
}
|
||
|
||
/// 实际进行下载的方法
|
||
static Future<File> _downloadFile(String url) async {
|
||
// 生成文件名 (使用URL的MD5哈希作为文件名)
|
||
final filename = md5.convert(utf8.encode(url)).toString();
|
||
final cacheDir = await _getCacheDirectory();
|
||
final file = File(path.join(cacheDir.path, filename));
|
||
|
||
// 检查文件是否已经存在
|
||
if (await file.exists()) {
|
||
return file;
|
||
}
|
||
|
||
// 下载文件
|
||
final response = await RSHttp.get(url);
|
||
|
||
if (response.statusCode == 200) {
|
||
await file.writeAsBytes(response.data ?? []);
|
||
return file;
|
||
} else {
|
||
throw Exception('Failed to download file: ${response.statusCode}');
|
||
}
|
||
}
|
||
|
||
/// 清除特定URL的缓存
|
||
static Future<bool> clearCache(String url) async {
|
||
try {
|
||
final filename = md5.convert(utf8.encode(url)).toString();
|
||
final cacheDir = await _getCacheDirectory();
|
||
final file = File(path.join(cacheDir.path, filename));
|
||
|
||
if (await file.exists()) {
|
||
await file.delete();
|
||
return true;
|
||
}
|
||
return false;
|
||
} catch (e) {
|
||
return false;
|
||
}
|
||
}
|
||
|
||
/// 清除所有缓存
|
||
static Future<void> clearAllCache() async {
|
||
try {
|
||
final cacheDir = await _getCacheDirectory();
|
||
if (await cacheDir.exists()) {
|
||
await cacheDir.delete(recursive: true);
|
||
await cacheDir.create();
|
||
}
|
||
} catch (e) {
|
||
debugPrint('clear All Cache Error: $e');
|
||
}
|
||
}
|
||
}
|