flutter
/
zhiying_comm
3
0
派生 0
代码 工单 0 合并请求 0 版本发布 95 百科 动态
基础库
163 提交
1 分支
6.6 MiB
 
 
 
 
 
目录树: d65d15584b
zhiying_comm/lib/util/net_util.dart

560 行
18 KiB
原始文件 Blame 文件历史 

  1. import 'dart:collection';

  2. import 'dart:convert';

  3. import 'dart:io';

  4. import 'dart:ui';

  5. 

  6. import 'package:device_info/device_info.dart';

  7. import 'package:dio/adapter.dart';

  8. import 'package:dio/dio.dart';

  9. import 'package:flutter/material.dart';

  10. import 'package:fluttertoast/fluttertoast.dart';

  11. import 'package:imei_plugin/imei_plugin.dart';

  12. import 'package:package_info/package_info.dart';

  13. import 'package:provider/provider.dart';

  14. import 'package:zhiying_comm/util/empty_util.dart';

  15. import 'package:zhiying_comm/zhiying_comm.dart';

  16. 

  17. import 'encode_util.dart';

  18. import 'global_config.dart';

  19. import 'shared_prefe_util.dart';

  20. import 'time_util.dart';

  21. 

  22. typedef OnSuccess = dynamic Function(dynamic data);

  23. typedef OnError = dynamic Function(String e);

  24. typedef OnCache = dynamic Function(dynamic data);

  25. 

  26. final GlobalKey<NavigatorState> navigatorKey = new GlobalKey<NavigatorState>();

  27. 

  28. enum NetMethod {

  29.   GET,

  30.   POST,

  31.   PUT,

  32.   DELETE,

  33.   OPTIONS,

  34.   PATCH,

  35.   UPDATE,

  36.   HEAD,

  37. }

  38. 

  39. class NetUtil {

  40.   Dio _dio;

  41. 

  42.   NetUtil._();

  43. 

  44.   static NetUtil _instance;

  45. 

  46.   static NetUtil getInstance() {

  47.     if (_instance == null) {

  48.       _instance = NetUtil._();

  49.     }

  50.     return _instance;

  51.   }

  52. 

  53.   get dio async {

  54.     if (_dio == null) {

  55.       var setting = await NativeUtil.getSetting();

  56.       String domain = setting['domain']; //'http://www.hairuyi.com/';

  57.       _config(domain, proxyUrl: ''); // 192.168.0.66:8866

  58.     }

  59.     return _dio;

  60.   }

  61. 

  62.   /// 配置网络请求，基础地址，代理地址,如：192.168.0.123:8888（代理地址生产环境无效）

  63.   /// apiVersion 接口版本

  64.   void _config(String baseUrl, {String proxyUrl}) {

  65.     _dio = Dio(BaseOptions(

  66.         method: "post",

  67.         baseUrl: baseUrl,

  68.         connectTimeout: 15000,

  69.         receiveTimeout: 15000,

  70.         contentType: Headers.jsonContentType,

  71.         followRedirects: true,

  72.         headers: {'device': 'wx_applet', 'Platform': 'wx_applet'},

  73.         validateStatus: (_) {

  74.           return true;

  75.         }));

  76.     _dio.interceptors.add(_NetInterceptors());

  77. //    _dio.interceptors.add(LogInterceptor());

  78. 

  79.     const bool inProduction = const bool.fromEnvironment("dart.vm.product");

  80.     if (proxyUrl != null && proxyUrl != '' && !inProduction) {

  81.       _setProxy(proxyUrl);

  82.     }

  83.   }

  84. 

  85.   /// 设置代理

  86.   void _setProxy(String proxyUrl) {

  87.     (_dio.httpClientAdapter as DefaultHttpClientAdapter).onHttpClientCreate = (HttpClient client) {

  88.       client.findProxy = (uri) {

  89.         return "PROXY $proxyUrl";

  90.       };

  91.       client.badCertificateCallback = (X509Certificate cert, String host, int port) => true;

  92.     };

  93.   }

  94. 

  95.   /// 同步请求

  96.   static Future<dynamic> post(String path,

  97.       {Map<String, dynamic> params, Map<String, dynamic> queryParameters, NetMethod method = NetMethod.POST, bool cache = false, bool showToast = true}) async {

  98. 

  99.     var paramsData = {

  100.       'postData': params ?? {},

  101.       'queryParameters': queryParameters ?? {}

  102.     };

  103. 

  104. 

  105.     // 根据请求参数，获取缓存的Key

  106.     String cacheKey = getRequestParamsCachedKey(paramsData, path);

  107.     // 参数签名 TODO 加密？

  108.     // post请求的参数

  109.     Map<String, dynamic> bodyParams = params;

  110.     // 请求头参数

  111.     Map<String, dynamic> headParam = await _getMustHeadParams();

  112. 

  113.     Response response;

  114.     try {

  115.       Dio dio = await NetUtil

  116.           .getInstance()

  117.           .dio;

  118.       response = await dio.request(

  119.         path,

  120.         data: !EmptyUtil.isEmpty(bodyParams) ? bodyParams : null,

  121.         options: Options(method: enumToString(method), headers: headParam),

  122.         queryParameters: !EmptyUtil.isEmpty(queryParameters) ? queryParameters : null,

  123.       );

  124.     } on DioError catch (e) {

  125.       _formatError(e);

  126.     }

  127. 

  128.     try {

  129.       var result = response.data is Map ? response.data : jsonDecode(response.data);

  130.       // TODO 解密？

  131.       if (isSuccess(result)) {

  132.         // 缓存成功的数据

  133.         if (cache) {

  134.           _setCallBackCacheData(cacheKey, response.data is Map ? jsonEncode(response.data) : response.data);

  135.         }

  136.         return result;

  137.         // 缓存返回的数据

  138.       } else {

  139.         Logger.error('error: ' + result[GlobalConfig.HTTP_RESPONSE_KEY_MSG]);

  140. 

  141.         ///

  142.         /// 401000 验证用户失败(不提示Toast)

  143.         /// 404004 没有找到对应模块(跳空页面，不提示toast)

  144.         ///

  145.         if (result[GlobalConfig.HTTP_RESPONSE_KEY_CODE] != 401000 && result[GlobalConfig.HTTP_RESPONSE_KEY_CODE] != 404004) {

  146.           if (showToast) {

  147.             Fluttertoast.showToast(

  148.               msg: result[GlobalConfig.HTTP_RESPONSE_KEY_MSG],

  149.               toastLength: Toast.LENGTH_SHORT,

  150.               gravity: ToastGravity.BOTTOM,

  151.             );

  152.           }

  153.         }

  154. 

  155.         ///

  156.         /// 401003 用户被逼下线

  157.         /// 退出登陆(清理token等用户信息)

  158.         ///

  159.         if (result[GlobalConfig.HTTP_RESPONSE_KEY_CODE]?.toString() == '401003') {

  160.           try {

  161.             Future.delayed(Duration(seconds: 0)).then((onValue) {

  162.               BuildContext context = navigatorKey.currentState.overlay.context;

  163.               Provider.of<UserInfoNotifier>(context, listen: false).unLogin();

  164.             });

  165.           } catch (e, s) {

  166.             Logger.error(e, s);

  167.           }

  168.         }

  169. 

  170.         ///

  171.         /// 403028 账号被冻结

  172.         /// 403029 账号被禁用

  173.         /// 提示并且退出登录

  174.         ///

  175.         if (result[GlobalConfig.HTTP_RESPONSE_KEY_CODE]?.toString() == '403028' || result[GlobalConfig.HTTP_RESPONSE_KEY_CODE]?.toString() == '403029') {

  176.           try {

  177.             // 提示

  178.             Fluttertoast.showToast(

  179.               msg: result[GlobalConfig.HTTP_RESPONSE_KEY_MSG],

  180.               toastLength: Toast.LENGTH_SHORT,

  181.               gravity: ToastGravity.BOTTOM,

  182.             );

  183.             // 退出登录

  184.             Future.delayed(Duration(seconds: 0)).then((onValue) {

  185.               BuildContext context = navigatorKey.currentState.overlay.context;

  186.               Provider.of<UserInfoNotifier>(context, listen: false).unLogin();

  187.             });

  188.           } catch (e, s) {

  189.             Logger.error(e, s);

  190.           }

  191.         }

  192. 

  193.         return result;

  194.       }

  195.     } catch (e) {

  196.       return null;

  197.     }

  198.   }

  199. 

  200.   /// 异步请求

  201.   static void request(String path, {NetMethod method = NetMethod.GET, Map<String, dynamic> params, Map<String,

  202.       dynamic> queryParameters, OnSuccess onSuccess, OnError onError, OnCache onCache, bool showToast = true}) async {

  203.     var paramsData = {

  204.       'postData': params ?? {},

  205.       'queryParameters': queryParameters ?? {}

  206.     };

  207. 

  208.     // 根据请求参数，获取缓存的Key

  209.     String cacheKey = getRequestParamsCachedKey(paramsData, path);

  210.     print("缓存Key"+cacheKey);

  211. //    // 读取缓存回调

  212.     if (onCache != null) {

  213.       await _onCallBackCacheData(onCache, cacheKey);

  214.     }

  215. 

  216.     try {

  217.       Map result = await NetUtil.post(path, method: method,

  218.           params: params,

  219.           queryParameters: queryParameters,

  220.           showToast: showToast,

  221.           cache: onCache != null);

  222.       // TODO 解密？

  223.       if (isSuccess(result)) {

  224.         if (onSuccess != null) {

  225.           onSuccess(result[GlobalConfig.HTTP_RESPONSE_KEY_DATA]);

  226.         }

  227.         return;

  228.       }

  229. 

  230.       if (onError != null) {

  231.         onError(!EmptyUtil.isEmpty(result) ? !EmptyUtil.isEmpty(result[GlobalConfig.HTTP_RESPONSE_KEY_MSG]) ? result[GlobalConfig.HTTP_RESPONSE_KEY_MSG] : '未知错误' : '未知错误');

  232.       }

  233.     } catch (e) {

  234.       Logger.error('error: ' + e.toString());

  235.       if (onError != null) {

  236.         onError(e?.toString() ?? '未知错误');

  237.       }

  238.     }

  239. 

  240.     return;

  241.   }

  242. 

  243.   /// 统一添加必要的参数

  244.   // static Future<Map<String, dynamic>> signParams(Map<String, dynamic> params) async {

  245.   //   // 应用信息

  246.   //   PackageInfo packageInfo = await PackageInfo.fromPlatform();

  247.   //   // 原生传的信息

  248.   //   Map setting = await NativeUtil.getSetting();

  249.   //

  250.   //   if (Platform.isIOS) {

  251.   //     IosDeviceInfo iosInfo = await DeviceInfoPlugin().iosInfo;

  252.   //     // 设备

  253.   //     params["platform"] = "ios";

  254.   //     // 设备系统版本

  255.   //     params["system_version"] = iosInfo?.systemVersion;

  256.   //     // 设备型号 如:iPhone 11pro

  257.   //     params['device_model'] = iosInfo?.name;

  258.   //     // 设备型号,如:MLMF2LL/A

  259.   //     //      params['device_number'] = iosInfo?.model;

  260.   //     // 设备ID

  261.   //     params['device_id'] = iosInfo?.identifierForVendor;

  262.   //   } else if (Platform.isAndroid) {

  263.   //     AndroidDeviceInfo androidInfo = await DeviceInfoPlugin().androidInfo;

  264.   //     // 设备

  265.   //     params["platform"] = "android";

  266.   //     // 设备系统版本

  267.   //     params["system_version"] = "Android ${androidInfo?.version?.release}";

  268.   //     // 设备型号 如:iPhone 11pro

  269.   //     params['device_model'] = androidInfo?.model;

  270.   //     // 设备型号,如:MLMF2LL/A

  271.   //     //      params['device_number'] = androidInfo?.id;

  272.   //     // 设备Id

  273.   //     params['device_id'] = androidInfo?.androidId;

  274.   //   }

  275.   //   // 应用版本号

  276.   //   params["app_version_name"] = packageInfo.version;

  277.   //   params["app_version"] = -1 ;// packageInfo.buildNumber;

  278.   //   // 分辨率

  279.   //   params["solution"] =

  280.   //       "${window.physicalSize.width.floor()}*${window.physicalSize.height.floor()}";

  281.   //

  282.   //   // 站长ID

  283.   //   String masterId = setting['master_id'];

  284.   //   if (null != masterId &&

  285.   //       masterId != '' &&

  286.   //       (!params.containsKey('master_id') || params['master_id'] == '')) {

  287.   //     params['master_id'] = masterId;

  288.   //   }

  289.   //

  290.   //   // secret_key

  291.   //   params['secret_key'] = setting['secret_key'];

  292.   //

  293.   //   // token 读取SP缓存中的用户token

  294.   //   String token = await SharedPreferencesUtil.getStringValue(

  295.   //       GlobalConfig.SHARED_KEY_TOKEN);

  296.   //   if (!EmptyUtil.isEmpty(token)) {

  297.   //     params['token'] = token;

  298.   //   }

  299.   //

  300.   //   // 当前时间戳：秒

  301.   //   params["time"] = TimeUtil.getNowTime();

  302.   //

  303.   //   // 过滤空字段，过滤首尾空格

  304.   //   Map<String, dynamic> filters = Map<String, dynamic>();

  305.   //   params.forEach((key, value) {

  306.   //     if (key != '' && value != '') {

  307.   //       filters[key] = (value is String) ? value.trim() : value;

  308.   //     }

  309.   //   });

  310.   //   params = filters;

  311.   //

  312.   //   List<String> list = List<String>();

  313.   //   params.forEach((key, value) {

  314.   //     list.add(key.toString() + value.toString());

  315.   //   });

  316.   //   params["sign"] = signWithArray(list);

  317.   //   return params;

  318.   // }

  319. 

  320.   /// 获取必须的请求参数(用于请求头部)

  321.   static Future<Map<String, String>> _getMustHeadParams() async {

  322.     Map<String, String> params = new HashMap<String, String>();

  323.     // 应用信息

  324.     PackageInfo packageInfo = await PackageInfo.fromPlatform();

  325.     // 原生传的信息

  326.     Map setting = await NativeUtil.getSetting();

  327. 

  328.     if (Platform.isIOS) {

  329.       IosDeviceInfo iosInfo = await DeviceInfoPlugin().iosInfo;

  330.       // 设备

  331.       params["platform"] = "ios";

  332.       // 设备系统版本

  333.       params["os_version"] = iosInfo?.systemVersion?.toString();

  334.       // 设备型号 如:iPhone 11pro

  335. 

  336.       params['device_model'] =

  337.           EncodeUtil.encodeBase64(iosInfo?.name?.toString() ?? '');

  338.       // 设备ID

  339.       params['device_id'] = iosInfo?.identifierForVendor?.toString();

  340. 

  341.       // idfa

  342.       params['idfa'] = iosInfo?.identifierForVendor?.toString();

  343.     } else if (Platform.isAndroid) {

  344.       AndroidDeviceInfo androidInfo = await DeviceInfoPlugin().androidInfo;

  345.       // 设备

  346.       params["platform"] = "android";

  347.       // 设备系统版本

  348.       params["os_version"] = "Android ${androidInfo?.version?.release}";

  349.       // 设备型号 如:iPhone 11pro

  350.       params['device_model'] = androidInfo?.model?.toString();

  351.       // 设备Id

  352.       params['device_id'] = androidInfo?.androidId?.toString();

  353. 

  354.       // imei

  355.       params['imei'] = await _getImei();

  356.     }

  357.     // 应用版本号

  358.     params["app_version_name"] = packageInfo.version?.toString();

  359.     params["app_version"] = packageInfo.buildNumber?.toString();

  360.     // 分辨率

  361.     params["solution"] = "${window.physicalSize.width.floor()}*${window.physicalSize.height.floor()}";

  362. 

  363.     // 站长ID

  364.     String masterId = setting['master_id'];

  365.     if (null != masterId && masterId != '' && (!params.containsKey('master_id') || params['master_id'] == '')) {

  366.       params['master_id'] = masterId; //!EmptyUtil.isEmpty(masterId) ? masterId : 'template_database';

  367.       params['MasterId'] = masterId; //!EmptyUtil.isEmpty(masterId) ? masterId : 'template_database';

  368.     }

  369. 

  370.     // token 读取SP缓存中的用户token

  371.     String token = await SharedPreferencesUtil.getStringValue(GlobalConfig.SHARED_KEY_TOKEN);

  372. 

  373.     if (EmptyUtil.isEmpty(token) && !bool.fromEnvironment("dart.vm.product")) {

  374.       try {

  375.         token = setting['token'];

  376.       } catch (e, s) {

  377.         print(s);

  378.         print(e);

  379.       }

  380.     }

  381.     if (!EmptyUtil.isEmpty(token)) {

  382.       // params['token'] = token;

  383.       params['Authorization'] = 'Bearer ' + token;

  384.     }

  385.     // secret_key

  386.     params['secret_key'] = setting['secret_key'] ?? '';

  387. 

  388.     // 当前时间戳：秒

  389.     params["time"] = TimeUtil.getNowTime();

  390. 

  391.     // 过滤空字段，过滤首尾空格

  392.     Map<String, String> filters = Map<String, String>();

  393.     params.forEach((key, value) {

  394.       if (key != '' && value != '') {

  395.         filters[key] = (value is String) ? value.trim() : value;

  396.       }

  397.     });

  398.     params = filters;

  399. 

  400.     List<String> list = List<String>();

  401.     params.forEach((key, value) {

  402.       list.add(key.toString() + '=' + value.toString() + '&');

  403.     });

  404. 

  405.     params["sign"] = signWithArray(list);

  406.     params.remove('secret_key');

  407.     return params;

  408.   }

  409. 

  410.   /// 获取Android imei

  411.   static Future<String> _getImei() async {

  412.     try {

  413.       return await ImeiPlugin.getImei(shouldShowRequestPermissionRationale: true);

  414.     } catch (e, s) {

  415.       Logger.error(e, s);

  416.     }

  417.     return null;

  418.   }

  419. 

  420.   /// 获取请求缓存成功的数据

  421.   static Future<void> _onCallBackCacheData(OnCache onCache, String cacheKey) async {

  422.     // 读取缓存

  423.     Map<String, dynamic> cacheMap = await SharedPreferencesUtil.getNetCacheResult(cacheKey);

  424. 

  425.     if (!EmptyUtil.isEmpty(cacheMap) &&

  426.         cacheMap.containsKey(GlobalConfig.HTTP_RESPONSE_KEY_CODE) &&

  427.         (cacheMap[GlobalConfig.HTTP_RESPONSE_KEY_CODE] == GlobalConfig.RESPONSE_SUCCESS_CODE ||

  428.             cacheMap[GlobalConfig.HTTP_RESPONSE_KEY_CODE] == '${GlobalConfig.RESPONSE_SUCCESS_CODE}') &&

  429.         !EmptyUtil.isEmpty(cacheMap[GlobalConfig.HTTP_RESPONSE_KEY_DATA])) {

  430.       onCache(cacheMap[GlobalConfig.HTTP_RESPONSE_KEY_DATA]);

  431.       return;

  432.     }

  433.     return;

  434.   }

  435. 

  436.   /// 缓存请求成功的数据

  437.   static void _setCallBackCacheData(String cacheKey, String value) async {

  438.     SharedPreferencesUtil.setNetCacheResult(cacheKey, value);

  439.   }

  440. 

  441.   /// 根据请求参数，获取缓存的数据

  442.   static Future<dynamic> getRequestCachedData(String url, {Map<String, dynamic> params,Map<String, dynamic> queryParameters}) async {

  443.     var paramsData = {

  444.       'postData': params ?? {},

  445.       'queryParameters': queryParameters ?? {}

  446.     };

  447.     Map<String, dynamic> cacheMap = await SharedPreferencesUtil.getNetCacheResult(getRequestParamsCachedKey(paramsData, url));

  448. 

  449.     if (!EmptyUtil.isEmpty(cacheMap) &&

  450.         cacheMap.containsKey(GlobalConfig.HTTP_RESPONSE_KEY_CODE) &&

  451.         (cacheMap[GlobalConfig.HTTP_RESPONSE_KEY_CODE] == GlobalConfig.RESPONSE_SUCCESS_CODE ||

  452.             cacheMap[GlobalConfig.HTTP_RESPONSE_KEY_CODE] == '${GlobalConfig.RESPONSE_SUCCESS_CODE}') &&

  453.         !EmptyUtil.isEmpty(cacheMap[GlobalConfig.HTTP_RESPONSE_KEY_DATA])) {

  454.       return cacheMap[GlobalConfig.HTTP_RESPONSE_KEY_DATA];

  455.     }

  456.     return null;

  457.   }

  458. 

  459.   /// 判断后台返回是否成功

  460.   static bool isSuccess(Map<String, dynamic> data) {

  461.     try {

  462.       if (!EmptyUtil.isEmpty(data) &&

  463.           (data[GlobalConfig.HTTP_RESPONSE_KEY_CODE] == GlobalConfig.RESPONSE_SUCCESS_CODE ||

  464.               data[GlobalConfig.HTTP_RESPONSE_KEY_CODE] == '${GlobalConfig.RESPONSE_SUCCESS_CODE}')) {

  465.         return true;

  466.       }

  467.     } catch (e) {

  468.       return false;

  469.     }

  470.     return false;

  471.   }

  472. 

  473.   /// 根据请求参数，获取缓存的Key

  474.   static String getRequestParamsCachedKey(Map<String, dynamic> map, String path) {

  475.     String key;

  476.     if (EmptyUtil.isEmpty(map)) {

  477.       key= EncodeUtil.generateMd5(path);

  478.     }else{

  479.       key= EncodeUtil.generateMd5(path + map.toString());

  480.     }

  481.    return key;

  482.   }

  483. 

  484.   // 七牛云文件上传

  485.   static Future uploadFile(String url, File file, {String method = 'POST', Map<String, dynamic> params, OnSuccess onSuccess, OnError onError}) async {

  486.     if (params == null) {

  487.       params = {};

  488.     }

  489.     Dio dio = Dio(BaseOptions(

  490.       method: "post",

  491.       connectTimeout: 15000,

  492.       receiveTimeout: 15000,

  493.       contentType: Headers.jsonContentType,

  494.       followRedirects: true,

  495.     ));

  496. 

  497.     params['file'] = await MultipartFile.fromFile(file.path);

  498.     FormData format = FormData.fromMap(params);

  499.     return dio.request(url, data: format, options: Options(method: method));

  500.   }

  501. 

  502.   /// 签名

  503.   static String signWithArray(List<String> params) {

  504.     // 字母升序

  505.     params.sort();

  506.     String result = "";

  507.     params.forEach((param) {

  508.       result += param;

  509.     });

  510.     result = result.substring(0, result.length - 1);

  511.     return EncodeUtil.generateMd5(result);

  512.   }

  513. 

  514.   /*

  515.    * error统一处理

  516.    */

  517.   static void _formatError(DioError e) {

  518.     if (e.type == DioErrorType.CONNECT_TIMEOUT) {

  519.       Logger.error('连接超时: ${e.toString()}');

  520.     } else if (e.type == DioErrorType.SEND_TIMEOUT) {

  521.       Logger.error('请求超时: ${e.toString()}');

  522.     } else if (e.type == DioErrorType.RECEIVE_TIMEOUT) {

  523.       Logger.error('响应超时: ${e.toString()}');

  524.     } else if (e.type == DioErrorType.RESPONSE) {

  525.       Logger.error('出现异常: ${e.toString()}');

  526.     } else if (e.type == DioErrorType.CANCEL) {

  527.       Logger.error('请求取消: ${e.toString()}');

  528.     } else {

  529.       Logger.error('未知错误: ${e.toString()}');

  530.     }

  531.   }

  532. }

  533. 

  534. /**

  535.  * @description: 网络请求拦截器

  536.  * @param {type}

  537.  * @return:

  538.  */

  539. class _NetInterceptors extends InterceptorsWrapper {

  540.   @override

  541.   Future onRequest(RequestOptions options) {

  542.     Logger.net(options?.uri?.toString(), data: options.data.toString());

  543.     // TODO 加密？

  544.     return super.onRequest(options);

  545.   }

  546. 

  547.   @override

  548.   Future onResponse(Response response) {

  549.     Logger.endNet(response?.request?.uri?.toString(), data: response?.data?.toString() ?? '');

  550.     // TODO 解密？

  551.     return super.onResponse(response);

  552.   }

  553. 

  554.   @override

  555.   Future onError(DioError err) {

  556. //    Logger.error(err);

  557.     return super.onError(err);

  558.   }

  559. }