You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

185 lines
5.2 KiB

// Dart imports:
import 'dart:io';
4 years ago
// Project imports:
import 'package:aku_community_manager/const/api.dart';
import 'package:aku_community_manager/provider/user_provider.dart';
import 'package:aku_community_manager/ui/login/login_page.dart';
4 years ago
import 'package:aku_community_manager/utils/network/base_file_model.dart';
import 'package:aku_community_manager/utils/network/base_list_model.dart';
import 'package:aku_community_manager/utils/network/base_model.dart';
3 years ago
// Package imports:
import 'package:bot_toast/bot_toast.dart';
import 'package:dio/dio.dart';
import 'package:get/get.dart' hide Response, FormData, MultipartFile;
import 'package:power_logger/power_logger.dart';
import 'package:provider/provider.dart';
4 years ago
class NetUtil {
Dio? _dio;
static final NetUtil _netUtil = NetUtil._internal();
factory NetUtil() => _netUtil;
Dio? get dio => _dio;
NetUtil._internal() {
BaseOptions options = BaseOptions(
baseUrl: API.baseURL,
connectTimeout: API.networkTimeOut,
receiveTimeout: API.networkTimeOut,
sendTimeout: API.networkTimeOut,
headers: {},
);
if (_dio == null) _dio = Dio(options);
dio!.interceptors.add(InterceptorsWrapper(
onRequest:
(RequestOptions options, RequestInterceptorHandler handler) async =>
handler.next(options),
onResponse:
(Response response, ResponseInterceptorHandler handler) async {
LoggerData.addData(response);
return handler.next(response);
},
onError: (DioError error, ErrorInterceptorHandler handler) async {
_parseErr(error);
return handler.next(error);
},
));
}
///call auth after login
auth(int token) {
_dio!.options.headers.putIfAbsent('butlerApp-admin-token', () => token);
}
logout() {
_dio!.options.headers.remove('butlerApp-admin-token');
}
/// ## alias of Dio().get
///
/// GET method
Future<BaseModel> get(
String path, {
Map<String, dynamic>? params,
bool showMessage = false,
}) async {
try {
Response res = await _dio!.get(path, queryParameters: params);
BaseModel baseModel = BaseModel.fromJson(res.data);
_parseRequestError(baseModel, showMessage: showMessage);
return baseModel;
} on DioError catch (e) {
_parseErr(e);
}
return BaseModel.err();
}
/// ## alias of Dio().post
///
/// POST method
///
/// only work with JSON.
Future<BaseModel> post(
String path, {
Map<String, dynamic>? params,
bool showMessage = false,
}) async {
try {
Response res = await _dio!.post(path, data: params);
BaseModel baseModel = BaseModel.fromJson(res.data);
_parseRequestError(baseModel, showMessage: showMessage);
return baseModel;
} on DioError catch (e) {
_parseErr(e);
}
return BaseModel.err();
}
Future<BaseListModel> getList(
String path, {
Map<String, dynamic>? params,
}) async {
try {
Response res = await _dio!.get(path, queryParameters: params);
if ((res.data as Map<String, dynamic>).containsKey('status') &&
(res.data as Map<String, dynamic>).containsKey('data') &&
(res.data as Map<String, dynamic>).containsKey('message')) {
BaseModel baseModel = BaseModel.fromJson(res.data);
_parseRequestError(baseModel);
} else {
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<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);
3 years ago
urls.add(model.url ?? '');
}
}
return urls;
}
_parseErr(DioError err) {
LoggerData.addData(err);
_makeToast(String message) {
BotToast.showText(text: '$message\_${err.response?.statusCode ?? ''}');
}
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.status! && model.message == '登录失效,请登录' && userProvider.isLogin) {
userProvider.logout();
3 years ago
Get.offAll(() => LoginPage());
}
if (!model.status! || showMessage) {
BotToast.showText(text: model.message!);
}
}
}