e3b9716f7c
- sendImage: 本地预览→上传→远程URL替换 - doctorListProvider: 8s超时+mock医生fallback - currentExercisePlanProvider: 8s超时→显示空状态 - 用药编辑: try-catch防黑屏+刷新列表 - 服药打卡: 接入后端confirm()接口
114 lines
3.5 KiB
Dart
114 lines
3.5 KiB
Dart
import 'dart:io';
|
||
import 'package:dio/dio.dart';
|
||
import 'local_database.dart';
|
||
|
||
/// API 基础地址
|
||
const String baseUrl = 'http://10.4.185.103:5000';
|
||
|
||
/// Dio HTTP 客户端封装——带 token 注入、401 自动刷新
|
||
class ApiClient {
|
||
final Dio _dio;
|
||
final LocalDatabase _db;
|
||
|
||
ApiClient({required LocalDatabase db})
|
||
: _db = db,
|
||
_dio = Dio(BaseOptions(
|
||
baseUrl: baseUrl,
|
||
connectTimeout: const Duration(seconds: 15),
|
||
receiveTimeout: const Duration(seconds: 60),
|
||
headers: {'Content-Type': 'application/json'},
|
||
)) {
|
||
_dio.interceptors.add(_AuthInterceptor(this));
|
||
_dio.interceptors.add(LogInterceptor(requestBody: true, responseBody: false));
|
||
}
|
||
|
||
Dio get dio => _dio;
|
||
|
||
Future<String?> get accessToken => _db.read('access_token');
|
||
Future<String?> get refreshToken => _db.read('refresh_token');
|
||
|
||
Future<void> saveTokens(String access, String refresh) async {
|
||
await _db.write('access_token', access);
|
||
await _db.write('refresh_token', refresh);
|
||
}
|
||
|
||
Future<void> clearTokens() async {
|
||
await _db.deleteAll();
|
||
}
|
||
|
||
/// 带 token 的 GET 请求
|
||
Future<Response> get(String path, {Map<String, dynamic>? queryParameters}) async {
|
||
return _dio.get(path, queryParameters: queryParameters);
|
||
}
|
||
|
||
/// 带 token 的 POST 请求
|
||
Future<Response> post(String path, {dynamic data}) async {
|
||
return _dio.post(path, data: data);
|
||
}
|
||
|
||
/// 带 token 的 PUT 请求
|
||
Future<Response> put(String path, {dynamic data}) async {
|
||
return _dio.put(path, data: data);
|
||
}
|
||
|
||
/// 带 token 的 DELETE 请求
|
||
Future<Response> delete(String path) async {
|
||
return _dio.delete(path);
|
||
}
|
||
|
||
/// 上传文件（multipart），返回文件 URL
|
||
Future<String?> uploadFile(String path, File file, {String fieldName = 'file'}) async {
|
||
final formData = FormData.fromMap({
|
||
fieldName: await MultipartFile.fromFile(file.path, filename: file.path.split('/').last),
|
||
});
|
||
final res = await _dio.post(path, data: formData);
|
||
final data = res.data;
|
||
if (data is Map) {
|
||
return data['url']?.toString() ?? data['data']?['url']?.toString();
|
||
}
|
||
return null;
|
||
}
|
||
}
|
||
|
||
/// 认证拦截器：自动注入 token + 401 刷新
|
||
class _AuthInterceptor extends Interceptor {
|
||
final ApiClient _client;
|
||
|
||
_AuthInterceptor(this._client);
|
||
|
||
@override
|
||
void onRequest(RequestOptions options, RequestInterceptorHandler handler) async {
|
||
if (!options.path.contains('/auth/')) {
|
||
final token = await _client.accessToken;
|
||
if (token != null) {
|
||
options.headers['Authorization'] = 'Bearer $token';
|
||
}
|
||
}
|
||
handler.next(options);
|
||
}
|
||
|
||
@override
|
||
void onError(DioException err, ErrorInterceptorHandler handler) async {
|
||
if (err.response?.statusCode == 401) {
|
||
final refresh = await _client.refreshToken;
|
||
if (refresh != null) {
|
||
try {
|
||
final response = await Dio(BaseOptions(baseUrl: baseUrl))
|
||
.post('/api/auth/refresh', data: {'refreshToken': refresh});
|
||
final data = response.data['data'];
|
||
if (data != null) {
|
||
await _client.saveTokens(data['accessToken'], data['refreshToken']);
|
||
final opts = err.requestOptions;
|
||
final token = data['accessToken'];
|
||
opts.headers['Authorization'] = 'Bearer $token';
|
||
final retryResponse = await Dio(BaseOptions(baseUrl: baseUrl)).fetch(opts);
|
||
return handler.resolve(retryResponse);
|
||
}
|
||
} catch (_) {}
|
||
}
|
||
await _client.clearTokens();
|
||
}
|
||
handler.next(err);
|
||
}
|
||
}
|