直接上代码吧，拿走不谢！
import 'dart:convert'; import 'package:connectivity/connectivity.dart'; import 'package:dio/dio.dart'; import 'package:flutter_application_yiguan/utils/jq_utils.dart'; import 'package:fluttertoast/fluttertoast.dart'; /** * json在线生成model工具 * https://caijinglong.github.io/json2dart/index_ch.html * 运行以下命令： * flutter packages pub run build_runner build * flutter packages pub run build_runner watch */ /// 请求完成回调方法 typedef CompleteCallback = void Function(DioError? error, dynamic result); const String kNoConnectivityCode = '3001'; /// brief: 请求方式 枚举值 /// 注意：Dart语言的枚举不支持指定原始值 enum JQHttpType { get, post } class JQBaseHttpRequest { /// JQHttpType type 请求方式 /// String url 请求地址 /// Map<String, String> httpHeader /// Map params 请求参数 /// CompleteCallback completeCallback 请求完成回调 static httpRequest({ required String url, required JQHttpType type, Map<String, dynamic>? httpHeader, Map<String, dynamic>? params, CompleteCallback? completeCallback, }) async { JQUtils.printf('url-->$url'); JQUtils.printf('params-->$params'); /// 设置 Options Options option = Options(); /// 请求方式 option.method = (type != JQHttpType.post) ? 'GET' : 'POST'; /// 设置 headers Map<String, dynamic> headers = new Map(); if (httpHeader != null) { headers.addAll(httpHeader); } option.headers = headers; JQUtils.printf('option.headers---------->${option.headers}'); /// 超时时间 15000毫秒ms（15秒） /// 发送超时 option.sendTimeout = 15000; /// 接收超时 option.receiveTimeout = 15000; var connectivityResult = await (new Connectivity().checkConnectivity()); if (connectivityResult == ConnectivityResult.none) { /// 没有网络 RequestOptions requestOptions = RequestOptions(path: url); Response response = Response( data: {'status': kNoConnectivityCode, 'message': '当前网络不可用，请检查网络是否正常'}, requestOptions: requestOptions, statusCode: 3001, statusMessage: '当前网络不可用，请检查网络是否正常', ); DioError error = DioError( response: response, requestOptions: RequestOptions(path: url), type: DioErrorType.other, error: Error.safeToString('当前网络不可用，请检查网络是否正常'), ); completeCallback!(error, null); /// 实际上返回的是response的data数据 return response.data; } else { /// 有网络 Dio dio = new Dio(); try { Response response = await dio.request(url, // data: params, queryParameters: params, options: option); JQUtils.printf('网络请求成功'); JQUtils.printf('-----------response----------'); /// 打印headers JQUtils.printf('response.headers ------>'); JQUtils.printf(response.headers); /// response是一个JSON对象 JQUtils.printf('-----------data----------'); /// 打印data JQUtils.printf('response.data ------>'); JQUtils.printf('json格式 == ' + json.encode(response.data)); if (completeCallback != null) { completeCallback(null, response.data); } /// 实际上返回的是response的data数据 return response.data; } on DioError catch (e) { /// 请求异常处理 /// 延时0.3秒执行返回，处理和loading的重合 Future.delayed(Duration(milliseconds: 300), () { /// error存在，底层封装统一显示提示 Fluttertoast.showToast( msg: "网络请求异常", gravity: ToastGravity.CENTER, ); JQUtils.printf('延时0.3s执行'); }); JQUtils.printf('网络请求异常======'); JQUtils.printf(e); JQUtils.printf('e.response===='); JQUtils.printf(e.response); JQUtils.printf('e.response.data'); JQUtils.printf(e.response?.data); if (completeCallback != null) { completeCallback(e, null); } /// 实际上返回的是response的data数据 return e.response?.data; } } } /// 文件下载 static httpDownload({ required String url, required String localSavePath, required JQHttpType type, Map<String, dynamic>? httpHeader, Map<String, dynamic>? params, CancelToken? cancelToken, ProgressCallback? progressCallback, CompleteCallback? completeCallback, }) async { JQUtils.printf('url-->$url'); JQUtils.printf('params-->$params'); /// 设置 Options Options option = Options(); /// 请求方式 option.method = (type != JQHttpType.post) ? 'GET' : 'POST'; /// 设置 headers Map<String, dynamic> headers = new Map(); if (httpHeader != null) { headers.addAll(httpHeader); } option.headers = headers; JQUtils.printf('option.headers---------->${option.headers}'); JQUtils.printf('params---------->${params}'); /// 超时时间 15000毫秒ms（15秒） /// 发送超时 option.sendTimeout = 15000; /// 接收超时 option.receiveTimeout = 15000; var connectivityResult = await (new Connectivity().checkConnectivity()); if (connectivityResult == ConnectivityResult.none) { /// 没有网络 RequestOptions requestOptions = RequestOptions(path: url); Response response = Response( data: {'status': kNoConnectivityCode, 'message': '当前网络不可用，请检查网络是否正常'}, requestOptions: requestOptions, statusCode: 3001, statusMessage: '当前网络不可用，请检查网络是否正常', ); DioError error = DioError( response: response, requestOptions: RequestOptions(path: url), type: DioErrorType.other, error: Error.safeToString('当前网络不可用，请检查网络是否正常'), ); completeCallback!(error, null); /// 实际上返回的是response的data数据 return response; } else { /// 有网络 Dio dio = new Dio(); try { Response response = await dio.download(url, localSavePath, queryParameters: params, options: option, onReceiveProgress: progressCallback == null ? null : (int count, int total) { if (total == -1) { /// 不知道进度的默认50% total = count * 2; } progressCallback(count, total); }, cancelToken: cancelToken); response.extra = <String, dynamic>{"localPath": localSavePath}; JQUtils.printf('网络请求成功'); JQUtils.printf('-----------response----------'); /// 打印headers JQUtils.printf('response.headers ------>'); JQUtils.printf(response.headers); /// response是一个JSON对象 JQUtils.printf('-----------data----------'); /// 打印data JQUtils.printf('response.data ------>'); JQUtils.printf(response.data); JQUtils.printf('localSavePath = ' + localSavePath); if (completeCallback != null) { // 下载文件这里，把文件的本地存储地址返回 completeCallback(null, localSavePath); } /// 实际上返回的是response的data数据 return response; } on DioError catch (e) { /// 请求异常处理 /// 延时0.3秒执行返回，处理和loading的重合 Future.delayed(Duration(milliseconds: 300), () { /// error存在，底层封装统一显示提示 Fluttertoast.showToast( msg: "网络请求异常", gravity: ToastGravity.CENTER, ); JQUtils.printf('延时0.3s执行'); }); JQUtils.printf('网络请求异常'); JQUtils.printf(e); JQUtils.printf(e.response); if (completeCallback != null) { completeCallback(e, null); } /// 实际上返回的是response的data数据 return e.response; } } } }
