aliyun_oss_util.dart
2.7 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
import 'package:dio/dio.dart';
import 'package:flutter_oss_aliyun/flutter_oss_aliyun.dart';
import 'package:wow_english/common/request/api_response/api_response_entity.dart';
import 'package:wow_english/common/request/request_client.dart';
import 'package:wow_english/models/aliyun_oss_upload_sts_entity.dart';
import 'package:wow_english/utils/log_util.dart';
/// 阿里云 oss 工具类，服务端给的鉴权一次有效
/// 这个库的Client是个单例，如果并发使用请注意所调用的Client归属，Client.init会生成一个新的_instance
class AliyunOssUtil {
static Future<String> uploadFile(String filePath) async {
// 取出文件名
//String fileName = filePath.substring(filePath.lastIndexOf("/") + 1, filePath.length);
String fileName = filePath.split('/').last;
Log.d("待上传文件: [$filePath], 截取的fileName: [$fileName]");
// 获取鉴权信息
AliyunOssUploadStsEntity? stsEntity = await _getSts(fileName);
if (stsEntity == null) {
// 为空的情况抛出错误
throw 'STS为空';
}
//Log.d('鉴权信息: $stsEntity');
// 鉴权
Client.init(
ossEndpoint: stsEntity.endpoint,
bucketName: stsEntity.bucket,
authGetter: stsEntity.authGetter,
);
// 上传文件
final Response<dynamic> resp = await Client().putObjectFile(
filePath,
fileKey: stsEntity.fileKey,
option: PutRequestOption(
onSendProgress: (count, total) {
Log.d("send: $count/$total");
},
onReceiveProgress: (count, total) {
Log.d("receive: $count/$total");
},
aclModel: AclMode.inherited,
callback: Callback(
callbackUrl: stsEntity.callbackParam.callbackUrl,
callbackBody: stsEntity.callbackParam.callbackBody,
calbackBodyType: CalbackBodyType.json,
),
),
);
var url = '${stsEntity.host}/${stsEntity.fileKey}';
// 正确返回时，是我们自己服务器的回调，所以使用我们的格式解析
var result = ApiResponse.fromJson(resp.data);
Log.d('上传结果: $result, url: $url');
if (result.code != 200) {
// 上传失败抛出错误
throw result.msg ?? '未知错误';
}
return url;
}
/// 获取鉴权信息
static Future<AliyunOssUploadStsEntity?> _getSts(String fileName) async {
var result =
await requestClient.get<AliyunOssUploadStsEntity>(Apis.aliyunOssSts, queryParameters: {'fileName': fileName});
return result;
}
}
extension StsExtension on AliyunOssUploadStsEntity {
Auth authGetter() {
return Auth(
accessKey: accessKeyId,
accessSecret: accessKeySecret,
expire: expiration,
secureToken: securityToken,
);
}
}