net_utils.dart

import 'dart:async';
import 'package:dio/dio.dart';
import 'package:flutter_app/api/api.dart';
import 'package:flutter_app/api/result_data.dart';
import 'package:flutter_app/api/code.dart';
import 'package:flutter_app/api/common_result.dart';

///
/// <pre>
///     author : Wp
///     e-mail : 1101313414@qq.com
///     time   : 2019/7/7 8:35 PM
///     desc   : 网络请求工具类
///     version: 1.0
/// </pre>
///

Map<String,dynamic> optHeader = {
  'accept-language':'zh-cn',
  'content-type':'application/json; charset=utf-8',
  'sessionId':'eyJhbGciOiJIUzI1NiJ9.eyJ1c2VySWQiOjF9.Gk6hf4iX_CKm264-o8GWhO4LjIoPtWHdJcppTgaRnEw'
};

var dio = new Dio(BaseOptions(connectTimeout: 30000,headers: optHeader));

class NetUtils {

  static Future get(String url, Map<String, dynamic> params , CancelToken cancelToken) async {
    var response;

    if (params != null) {
      response = await dio.get(Api.BASE_URL+url, queryParameters: params,cancelToken:cancelToken);
    } else {
      response = await dio.get(Api.BASE_URL+url);
    }
    return response.data;
  }

  static  post(String url, Map<String, dynamic> params , CancelToken cancelToken) async {

    print("\n--------------------------------------------请求start--------------------------------------------\n\n");
    print("请求url：${Api.BASE_URL+url}\n");
    print("请求参数：$params\n");
    Response response;
    try {
       response = await dio.post(Api.BASE_URL+url, data: params ,cancelToken:cancelToken);
    } on DioError catch (e) {
      Response errorResponse;
      if (e.response != null) {
        errorResponse = e.response;
      } else {
        errorResponse = new Response(statusCode: 666);
      }
      if (e.type == DioErrorType.CONNECT_TIMEOUT || e.type == DioErrorType.RECEIVE_TIMEOUT) {
        errorResponse.statusCode = -2;//NETWORK_TIMEOUT
      }
      print("抛出异常：${e.message}\n");
      print("\n--------------------------------------------请求end--------------------------------------------\n\n");
      return new ResultData(Code.errorHandleFunction(errorResponse.statusCode, e.message), false, errorResponse.statusCode);

    }
    print("请求结果：$response\n");
    print("\n--------------------------------------------请求end--------------------------------------------\n\n");
    // 过滤器
    CommonResult result = new CommonResult.fromJson(response.data);
    if(result.code == '200'){
      return new ResultData(response.data, true, int.parse(result.code));
    }else{
      return new ResultData(response.data, false, int.parse(result.code));
    }
  }


  ///下载文件
  downloadFile(urlPath, savePath) async {
    Response response;
    try {
      response = await dio.download(urlPath, savePath,onReceiveProgress: (int count, int total){
        //进度
        print("$count $total");
      });
      print('downloadFile success---------${response.data}');
    } on DioError catch (e) {
      print('downloadFile error---------$e');
    }
    return response.data;
  }
  ///取消网络请求
  void cancelRequests(CancelToken token) {
    token.cancel();
  }
}