327 lines
8.9 KiB
Dart
Executable File
327 lines
8.9 KiB
Dart
Executable File
import 'dart:convert';
|
||
import 'dart:developer';
|
||
import 'dart:ui';
|
||
import 'package:dio/dio.dart';
|
||
import 'package:flutter_easyloading/flutter_easyloading.dart';
|
||
import '../utils/toast_utils.dart';
|
||
|
||
///请求方式-枚举类型
|
||
enum MethodType { get, post, delete, put, patch }
|
||
|
||
class HttpUtils {
|
||
static final HttpUtils _instance = HttpUtils._internal(baseUrl: '');
|
||
|
||
factory HttpUtils() => _instance;
|
||
|
||
late Dio dio;
|
||
|
||
HttpUtils._internal({required String baseUrl}) {
|
||
BaseOptions options = BaseOptions(
|
||
baseUrl: baseUrl,
|
||
contentType: 'application/json; charset=utf-8',
|
||
connectTimeout: const Duration(milliseconds: 15000),
|
||
receiveTimeout: const Duration(milliseconds: 15000),
|
||
responseType: ResponseType.json,
|
||
validateStatus: (status) {
|
||
return true;
|
||
},
|
||
);
|
||
|
||
dio = Dio(options);
|
||
|
||
/// 添加请求日志
|
||
dio.interceptors.add(LogInterceptor(
|
||
requestBody: true,
|
||
responseHeader: false,
|
||
responseBody: false,
|
||
error: false,
|
||
));
|
||
|
||
/// 添加拦截器
|
||
dio.interceptors.add(InterceptorsWrapper(
|
||
onResponse: (response, handler) {
|
||
/// 打印返回值
|
||
const bool inProduction = bool.fromEnvironment("dart.vm.product");
|
||
if (!inProduction) {
|
||
log(
|
||
jsonEncode(response.data),
|
||
name: 'Response Text: ',
|
||
);
|
||
}
|
||
|
||
/// 对接口抛出异常的检查
|
||
_apiVerify(response);
|
||
return handler.next(response);
|
||
},
|
||
));
|
||
}
|
||
|
||
///统一请求入口
|
||
static Future<NetResult> request(
|
||
String baseUrl,
|
||
String path, {
|
||
String? token,
|
||
MethodType method = MethodType.get,
|
||
Map<String, String>? headers,
|
||
Map<String, dynamic>? body,
|
||
Map<String, dynamic>? queryParameters,
|
||
bool isShowLoading = false,
|
||
CancelToken? cancelToken,
|
||
VoidCallback? unLoginAction,
|
||
}) async {
|
||
///开始网络请求
|
||
late NetResult netResult;
|
||
Dio dio = HttpUtils._internal(baseUrl: baseUrl).dio;
|
||
// String? token1 = token ?? '';
|
||
Map<String, dynamic> headerMap = {};
|
||
if (headers != null) headerMap.addAll(headers);
|
||
headerMap['token'] = token;
|
||
headerMap['Authorization'] = token;
|
||
Options options = Options(
|
||
method: method.name,
|
||
headers: headerMap,
|
||
);
|
||
CancelToken newCancelToken = cancelToken ?? CancelToken();
|
||
try {
|
||
if (isShowLoading) {
|
||
await EasyLoading.show(
|
||
// status: 'loading...',
|
||
maskType: EasyLoadingMaskType.black,
|
||
);
|
||
}
|
||
|
||
final response = await dio.request(
|
||
path,
|
||
options: options,
|
||
queryParameters: queryParameters,
|
||
data: body,
|
||
cancelToken: newCancelToken,
|
||
);
|
||
// if (response.headers["authorization"] != null) {
|
||
// LocalStore.setValue(
|
||
// key: StoreValue.tokenKey,
|
||
// value: response.headers["authorization"]![0]);
|
||
// }
|
||
if (isShowLoading) EasyLoading.dismiss();
|
||
netResult = NetResult(
|
||
headers: response.headers,
|
||
result: response.data,
|
||
statusCode: response.statusCode ?? 0,
|
||
error: _apiIsSucceed(response),
|
||
);
|
||
} on DioError catch (error) {
|
||
if (isShowLoading) EasyLoading.dismiss();
|
||
_formatError(error);
|
||
netResult = NetResult(
|
||
errorMeg: error.message ?? '服务器出现错误',
|
||
);
|
||
}
|
||
return netResult;
|
||
}
|
||
|
||
///下载
|
||
static Future<NetResult> download(
|
||
String path,
|
||
String savePath, {
|
||
ProgressCallback? onReceiveProgress,
|
||
Map<String, dynamic>? queryParameters,
|
||
CancelToken? cancelToken,
|
||
bool deleteOnError = true,
|
||
String lengthHeader = Headers.contentLengthHeader,
|
||
data,
|
||
Options? options,
|
||
}) async {
|
||
///开始网络请求
|
||
late NetResult netResult;
|
||
try {
|
||
Response response = await Dio().download(
|
||
path,
|
||
savePath,
|
||
onReceiveProgress: onReceiveProgress,
|
||
queryParameters: queryParameters,
|
||
cancelToken: cancelToken,
|
||
deleteOnError: deleteOnError,
|
||
lengthHeader: lengthHeader,
|
||
data: data,
|
||
options: options,
|
||
);
|
||
netResult = NetResult(
|
||
headers: response.headers,
|
||
result: 'Download successful',
|
||
statusCode: response.statusCode ?? 0,
|
||
error: response.statusCode != 200,
|
||
);
|
||
} on DioError catch (error) {
|
||
_formatError(error);
|
||
netResult = NetResult(
|
||
errorMeg: error.message ?? '服务器出现错误',
|
||
result: 'Download failure',
|
||
);
|
||
}
|
||
return netResult;
|
||
}
|
||
|
||
///判断接口是否成功
|
||
static bool _apiIsSucceed(Response response) {
|
||
if (response.data != null && response.data != '') {
|
||
Map<String, dynamic> map = response.data;
|
||
return map['resultCode'] == 'OK' ? false : true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
///接口校验
|
||
static void _apiVerify(Response response, {VoidCallback? unLoginAction}) {
|
||
if (response.data != null && response.data != '') {
|
||
///判断返回值是否是Map
|
||
if (response.data is Map) {
|
||
Map<String, dynamic> map = response.data;
|
||
String resultCode = map['resultCode'];
|
||
|
||
if (resultCode.toUpperCase() == "FAIL") {
|
||
throw DioException(
|
||
requestOptions: RequestOptions(path: ''),
|
||
response: response,
|
||
type: DioExceptionType.unknown,
|
||
error: response.data,
|
||
message: map['resultMsg'],
|
||
);
|
||
}
|
||
|
||
if (resultCode.toUpperCase() == "UNLOGIN") {
|
||
unLoginAction?.call();
|
||
return;
|
||
}
|
||
} else if (response.data is String) {
|
||
throw DioException(
|
||
requestOptions: RequestOptions(path: ''),
|
||
response: response,
|
||
type: DioExceptionType.unknown,
|
||
error: response.data,
|
||
message: response.data,
|
||
);
|
||
}
|
||
} else {
|
||
throw DioException(
|
||
requestOptions: RequestOptions(path: ''),
|
||
response: response,
|
||
type: DioExceptionType.unknown,
|
||
error: response.data,
|
||
message: response.data,
|
||
);
|
||
}
|
||
}
|
||
|
||
/*
|
||
* Dio库error统一处理
|
||
*/
|
||
static void _formatError(DioException error) {
|
||
switch (error.type) {
|
||
case DioExceptionType.cancel:
|
||
break;
|
||
case DioExceptionType.connectionTimeout:
|
||
ToastUtils.showToast(msg: '网络连接超时');
|
||
break;
|
||
case DioExceptionType.sendTimeout:
|
||
ToastUtils.showToast(msg: '网络请求超时');
|
||
break;
|
||
case DioExceptionType.receiveTimeout:
|
||
ToastUtils.showToast(msg: '服务响应超时');
|
||
break;
|
||
case DioExceptionType.unknown:
|
||
ToastUtils.showToast(msg: error.message);
|
||
break;
|
||
case DioExceptionType.badResponse:
|
||
try {
|
||
int? errCode = error.response!.statusCode;
|
||
String? errMsg = error.response!.statusMessage;
|
||
switch (errCode) {
|
||
case 400:
|
||
ToastUtils.errorToast(errorText: '请求语法错误');
|
||
break;
|
||
case 401:
|
||
ToastUtils.errorToast(errorText: '没有权限');
|
||
break;
|
||
case 403:
|
||
ToastUtils.errorToast(errorText: '服务器拒绝执行');
|
||
break;
|
||
case 404:
|
||
ToastUtils.errorToast(errorText: '无法连接服务器');
|
||
break;
|
||
case 405:
|
||
ToastUtils.errorToast(errorText: '请求方法被禁止');
|
||
break;
|
||
case 500:
|
||
ToastUtils.errorToast(errorText: '服务器出现问题');
|
||
break;
|
||
case 502:
|
||
ToastUtils.errorToast(errorText: '无效的请求');
|
||
break;
|
||
case 503:
|
||
ToastUtils.errorToast(errorText: '服务器挂了');
|
||
break;
|
||
case 505:
|
||
ToastUtils.errorToast(errorText: '不支持HTTP协议请求');
|
||
break;
|
||
default:
|
||
ToastUtils.errorToast(errorText: errMsg ?? '未知错误');
|
||
break;
|
||
}
|
||
} on Exception catch (_) {
|
||
ToastUtils.errorToast(errorText: '未知错误');
|
||
break;
|
||
}
|
||
break;
|
||
default:
|
||
ToastUtils.errorToast(errorText: error.message);
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
/// 自定义Dio返回类
|
||
class NetResult {
|
||
dynamic result;
|
||
|
||
dynamic headers;
|
||
|
||
int total;
|
||
|
||
bool error;
|
||
|
||
int statusCode;
|
||
|
||
String errorMeg;
|
||
|
||
bool get success => !error;
|
||
|
||
NetResult({
|
||
this.result,
|
||
this.headers,
|
||
this.statusCode = -1,
|
||
this.error = true,
|
||
this.total = 0,
|
||
this.errorMeg = '',
|
||
});
|
||
|
||
@override
|
||
String toString() {
|
||
return 'NetResult：statusCode: $statusCode \n'
|
||
'NetResult: headers: $headers \n'
|
||
'NetResult: error: $error \n'
|
||
'NetResult: total: $total \n'
|
||
'NetResult: errorMeg: $errorMeg \n'
|
||
'NetResult: result: ${result.toString()}';
|
||
}
|
||
}
|
||
|
||
/// 自定义Dio取消请求处理类
|
||
class CustomCancelToken {
|
||
static CancelToken cancelToken = CancelToken();
|
||
|
||
static cancel() {
|
||
cancelToken.cancel('取消请求');
|
||
cancelToken = CancelToken();
|
||
}
|
||
}
|