liuxm/flutter-picgo
1
0
Fork 0
forked from lxm_tools/flutter-picgo
Code Issues Pull Requests Projects Releases Wiki Activity

refactor：重构SM.MS请求

Browse Source
This commit is contained in:
hackycy
2020-06-27 00:56:35 +08:00
parent ddf74ef3c3
commit d9f64bce9f
5 changed files with 44 additions and 124 deletions
Download Patch File Download Diff File Expand all files Collapse all files

112
lib/utils/smms_net.dart
View File

@@ -1,112 +0,0 @@
import 'dart:async';
import 'dart:convert';
import 'package:dio/dio.dart';
import 'package:flutter_picgo/api/smms_api.dart';
import 'package:flutter_picgo/model/smms_config.dart';
import 'package:flutter_picgo/resources/pb_type_keys.dart';
import 'package:flutter_picgo/resources/table_name_keys.dart';
import 'package:flutter_picgo/utils/sql.dart';
const bool inProduction = const bool.fromEnvironment("dart.vm.product");
Map<String, dynamic> optHeader = {
// 'accept-language': 'zh-cn',
// 'content-type': 'application/json'
};
var dio = new Dio(BaseOptions(
connectTimeout: 30000,
receiveTimeout: 30000,
sendTimeout: 30000,
headers: optHeader,
baseUrl: SMMSApi.BASE_URL));
class SMMSNetUtils {
static Future get(String url, {Map<String, dynamic> params}) async {
// 拦截器
dio.interceptors.add(InterceptorsWrapper(
onRequest: (RequestOptions options) async {
var token = await oAuth();
options.headers["Authorization"] = '$token';
},
));
Response response;
if (params != null) {
response = await dio.get(url, queryParameters: params);
} else {
response = await dio.get(url);
}
// if (response.statusCode != 200) {
// dio.reject(response.data["message"] ?? '未知异常');
// }
return response.data;
}
static Future post(String url, Map<String, dynamic> data) async {
dio.interceptors.add(InterceptorsWrapper(
onRequest: (RequestOptions options) async {
var token = await oAuth();
options.headers["Authorization"] = '$token';
},
));
Response response = await dio.post(url, data: data);
return response.data;
}
static Future postForm(String url, FormData data) async {
dio.interceptors.add(InterceptorsWrapper(
onRequest: (RequestOptions options) async {
var token = await oAuth();
options.headers["Authorization"] = '$token';
},
));
Response response = await dio.post(url, data: data);
return response.data;
}
static Future put(String url, Map<String, dynamic> data) async {
dio.interceptors.add(InterceptorsWrapper(
onRequest: (RequestOptions options) async {
var token = await oAuth();
options.headers["Authorization"] = '$token';
},
));
if (!inProduction) {
dio.interceptors.add(LogInterceptor());
}
Response response = await dio.put(url, data: data);
return response.data;
}
static Future delete(String url, Map<String, dynamic> data) async {
dio.interceptors.add(InterceptorsWrapper(
onRequest: (RequestOptions options) async {
var token = await oAuth();
options.headers["Authorization"] = '$token';
},
));
if (!inProduction) {
dio.interceptors.add(LogInterceptor());
}
Response response = await dio.delete(url, data: data);
return response.data;
}
/// 获取配置中的Token
static Future oAuth() async {
try {
var sql = Sql.setTable(TABLE_NAME_PBSETTING);
var pbsettingRow =
(await sql.getBySql('type = ?', [PBTypeKeys.smms]))?.first;
if (pbsettingRow != null &&
pbsettingRow["config"] != null &&
pbsettingRow["config"] != '') {
SMMSConfig config =
SMMSConfig.fromJson(json.decode(pbsettingRow["config"]));
if (config != null && config.token != null && config.token != '') {
return config.token;
}
}
} catch (e) {}
}
}

6
lib/utils/strategy/impl/smms_image_upload.dart
View File

@@ -4,7 +4,6 @@ import 'package:flutter_picgo/api/smms_api.dart';
import 'package:flutter_picgo/model/uploaded.dart';
import 'package:flutter_picgo/resources/pb_type_keys.dart';
import 'package:flutter_picgo/utils/image_upload.dart';
import 'package:flutter_picgo/utils/smms_net.dart';
import 'dart:io';
import 'package:path/path.dart' as path;
import 'package:flutter_picgo/utils/strategy/image_upload_strategy.dart';
@@ -16,7 +15,7 @@ class SMMSImageUpload implements ImageUploadStrategy {
FormData formData = FormData.fromMap({
"smfile": await MultipartFile.fromFile(file.path, filename: renameImage),
});
var result = await SMMSNetUtils.postForm(SMMSApi.UPLOAD, formData);
var result = await SMMSApi.upload(formData);
var resultmap = json.decode(result);
if (resultmap["success"]) {
var uploaded = Uploaded(-1, resultmap["data"]["url"], PBTypeKeys.smms,
@@ -32,8 +31,7 @@ class SMMSImageUpload implements ImageUploadStrategy {
Future<Uploaded> delete(Uploaded uploaded) async {
String hash = await ImageUploadUtils.getUploadedItemInfo(uploaded.id);
if (!isBlank(hash)) {
String realUrl = path.joinAll([SMMSApi.DELETE, hash]);
var result = await SMMSNetUtils.get(realUrl);
var result = await SMMSApi.delete(hash);
var resultmap = json.decode(result);
if (resultmap["success"]) {
return uploaded;