289 lines
8.2 KiB
Dart
289 lines
8.2 KiB
Dart
import 'dart:convert';
|
||
import 'dart:io';
|
||
|
||
import 'package:circle_app/util/util.dart';
|
||
import 'package:dio/dio.dart';
|
||
|
||
import '../util/device.dart';
|
||
import 'api.dart';
|
||
|
||
const String baseUrl = Api.baseUrl;
|
||
|
||
/// Dio 请求方法
|
||
|
||
enum DioMethod {
|
||
get,
|
||
post,
|
||
put,
|
||
delete,
|
||
}
|
||
|
||
class DioManager {
|
||
factory DioManager() => getInstance();
|
||
|
||
static DioManager get instance => getInstance();
|
||
static DioManager? _instance;
|
||
|
||
static DioManager getInstance() {
|
||
if (_instance == null) {
|
||
_instance = DioManager._init();
|
||
}
|
||
return _instance!;
|
||
}
|
||
|
||
Dio? _dio;
|
||
|
||
DioManager._init() {
|
||
_dio ??= Dio(BaseOptions(
|
||
// 请求基地址
|
||
baseUrl: baseUrl,
|
||
// 连接服务器超时时间，单位是毫秒
|
||
connectTimeout: Duration(seconds: 30000000000),
|
||
// 接收数据的最长时限
|
||
receiveTimeout: Duration(seconds: 30000000000),
|
||
));
|
||
_dio!.interceptors.add(LogInterceptor(responseBody: true));
|
||
}
|
||
|
||
Future download(String urlPath,String savePath,ProgressCallback progressCallback)async{
|
||
|
||
return await _dio!.download(urlPath, savePath, onReceiveProgress : progressCallback);
|
||
}
|
||
|
||
/// get请求
|
||
/// [isShowErrorToast] 出现错误的情况是否自动弹窗提示错误，默认true
|
||
/// [isAddTokenInHeader] 请求头是否添加token
|
||
/// [fromJson]是将json转为model的方法
|
||
Future get<T>({
|
||
required String url,
|
||
bool isShowErrorToast = true,
|
||
bool isAddTokenInHeader = true,
|
||
Map<String, dynamic>? params,
|
||
}) async {
|
||
return await requestHttp(
|
||
url,
|
||
method: DioMethod.get,
|
||
isShowErrorToast: isShowErrorToast,
|
||
params: params,
|
||
);
|
||
}
|
||
|
||
/// post 请求
|
||
Future post<T>({required String url,
|
||
Map<String, dynamic>? params,
|
||
bool isAddTokenInHeader = true,
|
||
bool isShowErrorToast = true,
|
||
FormData? formData,
|
||
CancelToken? cancelToken,
|
||
ProgressCallback? onSendProgress,
|
||
ProgressCallback? onReceiveProgress}) async {
|
||
return await requestHttp<T>(url,
|
||
method: DioMethod.post,
|
||
isShowErrorToast: isShowErrorToast,
|
||
params: params,
|
||
formData: formData,
|
||
cancelToken: cancelToken,
|
||
onSendProgress: onSendProgress,
|
||
onReceiveProgress: onReceiveProgress);
|
||
}
|
||
|
||
/// put 请求
|
||
Future put<T>({
|
||
required String url,
|
||
Map<String, dynamic>? params,
|
||
bool isAddTokenInHeader = true,
|
||
bool isShowErrorToast = true,
|
||
FormData? formData,
|
||
CancelToken? cancelToken,
|
||
ProgressCallback? onSendProgress,
|
||
ProgressCallback? onReceiveProgress,
|
||
}) async {
|
||
return await requestHttp<T>(
|
||
url,
|
||
method: DioMethod.put,
|
||
// 修改请求方法为 put
|
||
isShowErrorToast: isShowErrorToast,
|
||
params: params,
|
||
formData: formData,
|
||
cancelToken: cancelToken,
|
||
onSendProgress: onSendProgress,
|
||
onReceiveProgress: onReceiveProgress,
|
||
);
|
||
}
|
||
|
||
|
||
Future delete<T>({
|
||
required String url,
|
||
Map<String, dynamic>? params,
|
||
bool isAddTokenInHeader = true,
|
||
bool isShowErrorToast = true,
|
||
FormData? formData,
|
||
CancelToken? cancelToken,
|
||
ProgressCallback? onSendProgress,
|
||
ProgressCallback? onReceiveProgress,
|
||
}) async {
|
||
return await requestHttp<T>(
|
||
url,
|
||
method: DioMethod.delete,
|
||
// 修改请求方法为 delete
|
||
isShowErrorToast: isShowErrorToast,
|
||
params: params,
|
||
formData: formData,
|
||
cancelToken: cancelToken,
|
||
onSendProgress: onSendProgress,
|
||
onReceiveProgress: onReceiveProgress,
|
||
);
|
||
}
|
||
|
||
|
||
|
||
/// Dio request 方法
|
||
Future requestHttp<T>(String url,
|
||
{DioMethod method = DioMethod.get,
|
||
Map<String, dynamic>? params,
|
||
bool isShowErrorToast = true,
|
||
bool isAddTokenInHeader = true,
|
||
FormData? formData,
|
||
CancelToken? cancelToken,
|
||
ProgressCallback? onSendProgress,
|
||
ProgressCallback? onReceiveProgress}) async {
|
||
const methodValues = {
|
||
DioMethod.get: 'get',
|
||
DioMethod.post: 'post',
|
||
DioMethod.delete: 'delete',
|
||
DioMethod.put: 'put'
|
||
};
|
||
|
||
try {
|
||
Response response;
|
||
Options options = Options(
|
||
method: methodValues[method], headers: {
|
||
"Authorization": await getAuthorization(),
|
||
'versionName': await getVersionName(),
|
||
'versionCode': await getVersionCode(),
|
||
'osVersion': await getDeviceId(),
|
||
'platform': Platform.isIOS ? '1' : '0',
|
||
'imei': await getImei(),
|
||
'brand': await getBrand(),
|
||
});
|
||
print(">>>>>"+params.toString());
|
||
|
||
/// 不同请求方法，不同的请求参数,按实际项目需求分.
|
||
/// 这里 get 是 queryParameters，其它用 data. FormData 也是 data
|
||
/// 注意: 只有 post 方法支持发送 FormData.
|
||
switch (method) {
|
||
case DioMethod.get:
|
||
response =
|
||
await _dio!.request(url, queryParameters: params, options: options);
|
||
break;
|
||
case DioMethod.post:
|
||
response = await _dio!.post(
|
||
url, data: params, cancelToken: cancelToken, options: options);
|
||
break;
|
||
case DioMethod.put:
|
||
response = await _dio!.put(url, data: json.encode(params), options: options);
|
||
break;
|
||
case DioMethod.delete:
|
||
response =
|
||
await _dio!.delete(url, queryParameters: params, options: options);
|
||
break;
|
||
default:
|
||
// 如果有formData参数，说明是传文件，忽略params的参数
|
||
if (formData != null) {
|
||
response = await _dio!.post(url,
|
||
data: formData,
|
||
cancelToken: cancelToken,
|
||
onSendProgress: onSendProgress,
|
||
onReceiveProgress: onReceiveProgress);
|
||
} else {
|
||
response = await _dio!.request(url,
|
||
data: params, cancelToken: cancelToken, options: options);
|
||
}
|
||
}
|
||
// json转model
|
||
String jsonStr = json.encode(response.data);
|
||
Map<String, dynamic> responseMap = json.decode(jsonStr);
|
||
if (responseMap["code"] == 5003) {
|
||
pushLoginPage();
|
||
}
|
||
return responseMap;
|
||
} on DioException catch (e) {
|
||
// // DioError是指返回值不为200的情况
|
||
// logger.shout('DioError报错${e.type}:${e.error.toString()}');
|
||
// // 对错误进行判断
|
||
// onErrorInterceptor(e);
|
||
// // 判断是否断网了
|
||
// String? errorMsg = isNetworkConnected
|
||
// ? e.requestOptions.extra["errorMsg"]
|
||
// : "网络连接断开，请检查网络设置";
|
||
return {'code': 500, 'msg': '请求失败'};
|
||
} catch (e) {
|
||
// 其他一些意外的报错
|
||
return {'code': 500, 'msg': '请求异常'};
|
||
}
|
||
}
|
||
//
|
||
// // 错误判断
|
||
// void onErrorInterceptor(DioError err) {
|
||
// // 异常分类
|
||
// switch (err.type) {
|
||
// // 4xx 5xx response
|
||
// case DioErrorType.response:
|
||
// err.requestOptions.extra["errorMsg"] = err.response?.data ?? "连接异常";
|
||
// break;
|
||
// case DioErrorType.connectTimeout:
|
||
// err.requestOptions.extra["errorMsg"] = "连接超时";
|
||
// break;
|
||
// case DioErrorType.sendTimeout:
|
||
// err.requestOptions.extra["errorMsg"] = "发送超时";
|
||
// break;
|
||
// case DioErrorType.receiveTimeout:
|
||
// err.requestOptions.extra["errorMsg"] = "接收超时";
|
||
// break;
|
||
// case DioErrorType.cancel:
|
||
// err.requestOptions.extra["errorMsg"] =
|
||
// err.message.isNotEmpty ? err.message : "取消连接";
|
||
// break;
|
||
// case DioErrorType.other:
|
||
// default:
|
||
// err.requestOptions.extra["errorMsg"] = "连接异常";
|
||
// break;
|
||
// }
|
||
// }
|
||
}
|
||
|
||
class BaseResponse<T> {
|
||
int code;
|
||
String msg;
|
||
dynamic? data;
|
||
|
||
BaseResponse({required this.code, required this.msg, required this.data});
|
||
|
||
isSuccess(){
|
||
return code==200;
|
||
}
|
||
|
||
factory BaseResponse.fromJson(Map<String, dynamic> json,
|
||
T Function(dynamic) fromJsonData) {
|
||
return BaseResponse(
|
||
code: json['code'],
|
||
msg: json['msg'],
|
||
data: json['data'] != null ? fromJsonData?.call(json['data']) : '',
|
||
);
|
||
}
|
||
}
|
||
|
||
class QnTokenData {
|
||
final String token;
|
||
final String cdnPrefix;
|
||
|
||
QnTokenData({required this.token, required this.cdnPrefix});
|
||
|
||
factory QnTokenData.fromJson(Map<String, dynamic> json) {
|
||
return QnTokenData(
|
||
token: json['token'],
|
||
cdnPrefix: json['cdn_prefix'],
|
||
);
|
||
}
|
||
}
|