aku_new_community/lib/utils/network/net_util.dart

import 'dart:io';
import 'dart:typed_data';

import 'package:aku_new_community/constants/sars_api.dart';
import 'package:aku_new_community/pages/sign/login/login_page.dart';
import 'package:aku_new_community/provider/user_provider.dart';
import 'package:aku_new_community/utils/developer_util.dart';
import 'package:aku_new_community/utils/network/base_file_model.dart';
import 'package:aku_new_community/utils/network/base_list_model.dart';
import 'package:aku_new_community/utils/network/base_model.dart';
import 'package:bot_toast/bot_toast.dart';
import 'package:dio/dio.dart';
import 'package:flustars/flustars.dart';
import 'package:get/get.dart' hide Response, FormData, MultipartFile;
import 'package:power_logger/power_logger.dart';
import 'package:provider/provider.dart';

class NetUtil {
  Dio? _dio;
  static final NetUtil _netUtil = NetUtil._internal();

  factory NetUtil() => _netUtil;

  Dio? get dio => _dio;

  NetUtil._internal() {
    BaseOptions options = BaseOptions(
      baseUrl: SARSAPI.baseURL,
      connectTimeout: SARSAPI.networkTimeOut,
      receiveTimeout: SARSAPI.networkTimeOut,
      sendTimeout: SARSAPI.networkTimeOut,
      headers: {},
    );
    if (_dio == null) _dio = Dio(options);
    dio!.interceptors.add(InterceptorsWrapper(
      onRequest: (options, handler) async => handler.next(options),
      onResponse: (response, handler) async {
        LoggerData.addData(response);
        return handler.next(response);
      },
      onError: (error, handler) async {
        _parseErr(error);
        return handler.next(error);
      },
    ));
  }

  ///call auth after login
  auth(String token) {
    _dio!.options.headers['app-login-token'] = token;
  }

  static String getDate(DateTime date) =>
      DateUtil.formatDate(date, format: 'yyyy-MM-dd HH:mm:ss');

  /// ## alias of Dio().get
  ///
  /// GET method
  Future<BaseModel> get(
    String path, {
    Map<String, dynamic>? params,
    bool showMessage = false,
  }) async {
    var _baseModel;
    try {
      Response res = await _dio!.get(path, queryParameters: params);
      if (!res.data['success']) {
        _baseModel = BaseModel.error(res.data['msg'], res.data['success'],
            res.data['data'], res.data['code']);
        _parseRequestError(_baseModel, showMessage: showMessage);
      } else {
        _baseModel = BaseModel.fromJson(res.data);
      }
    } on DioError catch (e) {
      _parseErr(e);
      _baseModel = BaseModel(code: 0, msg: '未知错误', success: false, data: null);
    }
    return _baseModel;
  }

  /// ## alias of Dio().post
  ///
  /// POST method
  ///
  /// only work with JSON.
  Future<BaseModel> post(
    String path, {
    Map<String, dynamic>? params,
    bool showMessage = false,
  }) async {
    var _baseModel;
    try {
      Response res = await _dio!.post(path, data: params);
      if (!res.data['success']) {
        _baseModel = BaseModel.error(res.data['msg'], res.data['success'],
            res.data['data'], res.data['code']);
        _parseRequestError(_baseModel, showMessage: showMessage);
      } else {
        _baseModel = BaseModel.fromJson(res.data);
      }
    } on DioError catch (e) {
      _parseErr(e);
      _baseModel = BaseModel(code: 0, msg: '未知错误', success: false, data: null);
    }

    return _baseModel;
  }

  Future<BaseListModel> getList(
    String path, {
    Map<String, dynamic>? params,
  }) async {
    try {
      Response res = await _dio!.get(path, queryParameters: params);
      BaseListModel baseListModel = BaseListModel.fromJson(res.data);
      return baseListModel;
    } on DioError catch (e) {
      _parseErr(e);
    }
    return BaseListModel.err();
  }

  Future<BaseFileModel> upload(String path, File file) async {
    try {
      Response res = await _dio!.post(path,
          data: FormData.fromMap({
            'file': await MultipartFile.fromFile(file.path),
          }));
      BaseFileModel baseListModel = BaseFileModel.fromJson(res.data);
      return baseListModel;
    } on DioError catch (e) {
      print(e);
    }
    return BaseFileModel.err();
  }

  Future<BaseFileModel> uploadUnit8List(String path, Uint8List bytes) async {
    try {
      Response res = await _dio!.post(path,
          data: FormData.fromMap({
            'file':
                await MultipartFile.fromBytes(bytes, filename: 'signName.png'),
          }));
      BaseFileModel baseListModel = BaseFileModel.fromJson(res.data);
      return baseListModel;
    } on DioError catch (e) {
      print(e);
    }
    return BaseFileModel.err();
  }

  Future<List<String>> uploadFiles(List<File> files, String api) async {
    List<String> urls = [];
    if (files.isEmpty) {
      return [];
    } else {
      for (var item in files) {
        BaseFileModel model = await NetUtil().upload(api, item);
        if (model.url != null) {
          urls.add(model.url!);
        }
      }
    }

    return urls;
  }

  _parseErr(DioError err) {
    LoggerData.addData(err);
    _makeToast(String message) {
      if (DeveloperUtil.dev)
        BotToast.showText(text: '$message\_${err.response?.statusCode ?? ''}');
      else
        BotToast.showText(text: '网络出现问题');
    }

    switch (err.type) {
      case DioErrorType.connectTimeout:
      case DioErrorType.sendTimeout:
      case DioErrorType.receiveTimeout:
        _makeToast('连接超时');
        break;
      case DioErrorType.response:
        _makeToast('服务器出错');
        break;
      case DioErrorType.cancel:
        break;
      case DioErrorType.other:
        _makeToast('未知错误');
        break;
    }
  }

  _parseRequestError(BaseModel model, {bool showMessage = false}) {
    final userProvider = Provider.of<UserProvider>(Get.context!, listen: false);
    if (!model.success &&
        (model.code == 10010 || model.msg == '登录失效，请重新登录') &&
        userProvider.isLogin) {
      userProvider.logout();
      Get.offAll(() => LoginPage());
    }
    if (!model.success && showMessage) {
      BotToast.showText(text: model.msg);
    }
  }
}