feat: aliyun oss & avatar upload

Key
1 parent 37b78a15
Showing 10 changed files with 237 additions and 22 deletions
lib/common/request/apis.dart
lib/common/request/basic_config.dart
lib/generated/json/aliyun_oss_upload_sts_entity.g.dart
lib/generated/json/base/json_convert_content.dart
lib/generated/json/course_module_entity.g.dart
lib/models/aliyun_oss_upload_sts_entity.dart
lib/pages/user/modify/user_avatar_bloc/user_avatar_bloc.dart
lib/utils/aliyun_oss_util.dart
lib/utils/log_util.dart
pubspec.yaml
@@ -70,4 +70,7 @@ class Apis {
   /// 首页弹窗
   /// get
   static const String homePopup = 'home/popup';
+
+  /// 获取阿里云oss鉴权信息
+  static const String aliyunOssSts = 'oss/sts/upload';
 }
 class BasicConfig {
    bool isTestDev = true;
-}
 \ No newline at end of file
+}
+import 'package:wow_english/generated/json/base/json_convert_content.dart';
+import 'package:wow_english/models/aliyun_oss_upload_sts_entity.dart';
+
+AliyunOssUploadStsEntity $AliyunOssUploadStsEntityFromJson(Map<String, dynamic> json) {
+	final AliyunOssUploadStsEntity aliyunOssUploadStsEntity = AliyunOssUploadStsEntity();
+	final String? securityToken = jsonConvert.convert<String>(json['securityToken']);
+	if (securityToken != null) {
+		aliyunOssUploadStsEntity.securityToken = securityToken;
+	}
+	final String? expiration = jsonConvert.convert<String>(json['expiration']);
+	if (expiration != null) {
+		aliyunOssUploadStsEntity.expiration = expiration;
+	}
+	final String? endpoint = jsonConvert.convert<String>(json['endpoint']);
+	if (endpoint != null) {
+		aliyunOssUploadStsEntity.endpoint = endpoint;
+	}
+	final String? fileKey = jsonConvert.convert<String>(json['fileKey']);
+	if (fileKey != null) {
+		aliyunOssUploadStsEntity.fileKey = fileKey;
+	}
+	final String? accessKeyId = jsonConvert.convert<String>(json['accessKeyId']);
+	if (accessKeyId != null) {
+		aliyunOssUploadStsEntity.accessKeyId = accessKeyId;
+	}
+	final String? accessKeySecret = jsonConvert.convert<String>(json['accessKeySecret']);
+	if (accessKeySecret != null) {
+		aliyunOssUploadStsEntity.accessKeySecret = accessKeySecret;
+	}
+	final String? bucket = jsonConvert.convert<String>(json['bucket']);
+	if (bucket != null) {
+		aliyunOssUploadStsEntity.bucket = bucket;
+	}
+	final String? ossDomain = jsonConvert.convert<String>(json['ossDomain']);
+	if (ossDomain != null) {
+		aliyunOssUploadStsEntity.ossDomain = ossDomain;
+	}
+	final String? host = jsonConvert.convert<String>(json['host']);
+	if (host != null) {
+		aliyunOssUploadStsEntity.host = host;
+	}
+	final AliyunOssUploadStsCallbackParam? callbackParam = jsonConvert.convert<AliyunOssUploadStsCallbackParam>(json['callbackParam']);
+	if (callbackParam != null) {
+		aliyunOssUploadStsEntity.callbackParam = callbackParam;
+	}
+	return aliyunOssUploadStsEntity;
+}
+
+Map<String, dynamic> $AliyunOssUploadStsEntityToJson(AliyunOssUploadStsEntity entity) {
+	final Map<String, dynamic> data = <String, dynamic>{};
+	data['securityToken'] = entity.securityToken;
+	data['expiration'] = entity.expiration;
+	data['endpoint'] = entity.endpoint;
+	data['fileKey'] = entity.fileKey;
+	data['accessKeyId'] = entity.accessKeyId;
+	data['accessKeySecret'] = entity.accessKeySecret;
+	data['bucket'] = entity.bucket;
+	data['ossDomain'] = entity.ossDomain;
+	data['host'] = entity.host;
+	data['callbackParam'] = entity.callbackParam.toJson();
+	return data;
+}
+
+AliyunOssUploadStsCallbackParam $AliyunOssUploadStsCallbackParamFromJson(Map<String, dynamic> json) {
+	final AliyunOssUploadStsCallbackParam aliyunOssUploadStsCallbackParam = AliyunOssUploadStsCallbackParam();
+	final String? callbackBody = jsonConvert.convert<String>(json['callbackBody']);
+	if (callbackBody != null) {
+		aliyunOssUploadStsCallbackParam.callbackBody = callbackBody;
+	}
+	final String? callbackBodyType = jsonConvert.convert<String>(json['callbackBodyType']);
+	if (callbackBodyType != null) {
+		aliyunOssUploadStsCallbackParam.callbackBodyType = callbackBodyType;
+	}
+	final String? callbackUrl = jsonConvert.convert<String>(json['callbackUrl']);
+	if (callbackUrl != null) {
+		aliyunOssUploadStsCallbackParam.callbackUrl = callbackUrl;
+	}
+	return aliyunOssUploadStsCallbackParam;
+}
+
+Map<String, dynamic> $AliyunOssUploadStsCallbackParamToJson(AliyunOssUploadStsCallbackParam entity) {
+	final Map<String, dynamic> data = <String, dynamic>{};
+	data['callbackBody'] = entity.callbackBody;
+	data['callbackBodyType'] = entity.callbackBodyType;
+	data['callbackUrl'] = entity.callbackUrl;
+	return data;
+}
@@ -4,6 +4,7 @@
 // This file is automatically generated. DO NOT EDIT, all your changes would be lost.
 import 'package:flutter/material.dart' show debugPrint;
+import 'package:wow_english/models/aliyun_oss_upload_sts_entity.dart';
 import 'package:wow_english/models/course_entity.dart';
 import 'package:wow_english/models/course_module_entity.dart';
 import 'package:wow_english/models/course_process_entity.dart';
@@ -18,6 +19,8 @@ typedef EnumConvertFunction&lt;T&gt; = T Function(String value);
 class JsonConvert {
 	static final Map<String, JsonConvertFunction> convertFuncMap = {
+		(AliyunOssUploadStsEntity).toString(): AliyunOssUploadStsEntity.fromJson,
+		(AliyunOssUploadStsCallbackParam).toString(): AliyunOssUploadStsCallbackParam.fromJson,
 		(CourseEntity).toString(): CourseEntity.fromJson,
 		(CourseCourseLessons).toString(): CourseCourseLessons.fromJson,
 		(CourseModuleEntity).toString(): CourseModuleEntity.fromJson,
@@ -108,6 +111,12 @@ List&lt;T&gt;? convertListNotNull&lt;T&gt;(dynamic value, {EnumConvertFunction? enumConvert}
 	//list is returned by type
 	static M? _getListChildType<M>(List<Map<String, dynamic>> data) {
+		if(<AliyunOssUploadStsEntity>[] is M){
+			return data.map<AliyunOssUploadStsEntity>((Map<String, dynamic> e) => AliyunOssUploadStsEntity.fromJson(e)).toList() as M;
+		}
+		if(<AliyunOssUploadStsCallbackParam>[] is M){
+			return data.map<AliyunOssUploadStsCallbackParam>((Map<String, dynamic> e) => AliyunOssUploadStsCallbackParam.fromJson(e)).toList() as M;
+		}
 		if(<CourseEntity>[] is M){
 			return data.map<CourseEntity>((Map<String, dynamic> e) => CourseEntity.fromJson(e)).toList() as M;
 		}
@@ -146,7 +155,7 @@ List&lt;T&gt;? convertListNotNull&lt;T&gt;(dynamic value, {EnumConvertFunction? enumConvert}
 		}
 		debugPrint("${M.toString()} not found");
-	
+
 		return null;
 }
@@ -157,4 +166,4 @@ List&lt;T&gt;? convertListNotNull&lt;T&gt;(dynamic value, {EnumConvertFunction? enumConvert}
 			return jsonConvert.convert<M>(json);
 		}
 	}
-}
 \ No newline at end of file
+}
@@ -59,7 +59,6 @@ CourseModuleEntity $CourseModuleEntityFromJson(Map&lt;String, dynamic&gt; json) {
 	if (status != null) {
 		courseModuleEntity.status = status;
 	}
-
 	final String? courseModuleThemeColor = jsonConvert.convert<String>(json['courseModuleThemeColor']);
 	if (courseModuleThemeColor != null) {
 		courseModuleEntity.courseModuleThemeColor = courseModuleThemeColor;
@@ -85,4 +84,4 @@ Map&lt;String, dynamic&gt; $CourseModuleEntityToJson(CourseModuleEntity entity) {
 	data['status'] = entity.status;
 	data['courseModuleThemeColor'] = entity.courseModuleThemeColor;
 	return data;
-}
 \ No newline at end of file
+}
+import 'dart:convert';
+
+import 'package:wow_english/generated/json/aliyun_oss_upload_sts_entity.g.dart';
+import 'package:wow_english/generated/json/base/json_field.dart';
+
+@JsonSerializable()
+class AliyunOssUploadStsEntity {
+	late String securityToken;
+	late String expiration;
+	late String endpoint;
+	late String fileKey;
+	late String accessKeyId;
+	late String accessKeySecret;
+	late String bucket;
+	late String ossDomain;
+	late String host;
+	late AliyunOssUploadStsCallbackParam callbackParam;
+
+	AliyunOssUploadStsEntity();
+
+	factory AliyunOssUploadStsEntity.fromJson(Map<String, dynamic> json) => $AliyunOssUploadStsEntityFromJson(json);
+
+	Map<String, dynamic> toJson() => $AliyunOssUploadStsEntityToJson(this);
+
+	@override
+	String toString() {
+		return jsonEncode(this);
+	}
+}
+
+@JsonSerializable()
+class AliyunOssUploadStsCallbackParam {
+	late String callbackBody;
+	late String callbackBodyType;
+	late String callbackUrl;
+
+	AliyunOssUploadStsCallbackParam();
+
+	factory AliyunOssUploadStsCallbackParam.fromJson(Map<String, dynamic> json) => $AliyunOssUploadStsCallbackParamFromJson(json);
+
+	Map<String, dynamic> toJson() => $AliyunOssUploadStsCallbackParamToJson(this);
+
+	@override
+	String toString() {
+		return jsonEncode(this);
+	}
+}
@@ -4,13 +4,15 @@ import &#39;package:image_picker/image_picker.dart&#39;;
 import 'package:permission_handler/permission_handler.dart';
 import 'package:wow_english/common/core/assets_const.dart';
 import 'package:wow_english/common/core/user_util.dart';
+import 'package:wow_english/common/request/dao/user_dao.dart';
+import 'package:wow_english/utils/aliyun_oss_util.dart';
+import 'package:wow_english/utils/log_util.dart';
 part 'user_avatar_event.dart';
 part 'user_avatar_state.dart';
 class UserAvatarBloc extends Bloc<UserAvatarEvent, UserAvatarState> {
-
-  String _imageUrl =  UserUtil.getUser()!.avatarUrl??AssetsConst.wowLogo;
+  String _imageUrl = UserUtil.getUser()!.avatarUrl ?? AssetsConst.wowLogo;
   String get imageUrl => _imageUrl;
@@ -18,27 +20,34 @@ class UserAvatarBloc extends Bloc&lt;UserAvatarEvent, UserAvatarState&gt; {
   XFile? get file => _file;
-  bool _canInsertApp =false;
+  bool _canInsertApp = false;
   bool get canInsertApp => _canInsertApp;
   final ImagePicker picker = ImagePicker();
-
   UserAvatarBloc() : super(UserAvatarInitial()) {
     on<ChangeImageEvent>(_changeImage);
     on<GetImageFromPhotoEvent>(_getImageFromPhoto);
     on<GetImageFromCameraEvent>(_getImageFromCamera);
   }
-  void _changeImage(ChangeImageEvent event,Emitter<UserAvatarState> emitter) async {
+  void _changeImage(ChangeImageEvent event, Emitter<UserAvatarState> emitter) async {
     _imageUrl = event.imagePath;
-    emitter(ChangeImageState());
+    try {
+      // todo 加个loading UI
+      String avatarUrl = await AliyunOssUtil.uploadFile(event.imagePath);
+      // 上传服务器
+      await UserDao.updateUserInfoField(avatarUrl: avatarUrl);
+      emitter(ChangeImageState());
+    } catch (e) {
+      Log.e('上传头像失败：$e');
+    }
   }
-  void _getImageFromPhoto(GetImageFromPhotoEvent event,Emitter<UserAvatarState> emitter) async {
+  void _getImageFromPhoto(GetImageFromPhotoEvent event, Emitter<UserAvatarState> emitter) async {
     await getPhotoPermissionStatus().then((value) async {
-      if (!value){
+      if (!value) {
         debugPrint('失败$value');
         return;
       }
@@ -47,9 +56,9 @@ class UserAvatarBloc extends Bloc&lt;UserAvatarEvent, UserAvatarState&gt; {
     });
   }
-  void _getImageFromCamera(GetImageFromCameraEvent event,Emitter<UserAvatarState> emitter) async {
+  void _getImageFromCamera(GetImageFromCameraEvent event, Emitter<UserAvatarState> emitter) async {
     await getCameraPermissionStatus().then((value) async {
-      if (!value){
+      if (!value) {
         debugPrint('失败$value');
         return;
       }
@@ -71,9 +80,7 @@ class UserAvatarBloc extends Bloc&lt;UserAvatarEvent, UserAvatarState&gt; {
       openAppSettings();
     } else if (status.isRestricted) {
       _requestPermission(permission);
-    } else {
-
-    }
+    } else {}
     return false;
   }
@@ -89,9 +96,7 @@ class UserAvatarBloc extends Bloc&lt;UserAvatarEvent, UserAvatarState&gt; {
       openAppSettings();
     } else if (status.isRestricted) {
       _requestPermission(permission);
-    } else {
-
-    }
+    } else {}
     return false;
   }
+import 'package:dio/dio.dart';
+import 'package:flutter_oss_aliyun/flutter_oss_aliyun.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);
+    Log.d("待上传文件fileName: $fileName");
+    // 获取鉴权信息
+    AliyunOssUploadStsEntity stsEntity = await _getSts(fileName);
+    // 鉴权
+    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 = $count, and total = $total");
+        },
+        onReceiveProgress: (count, total) {
+          Log.d("receive: count = $count, and total = $total");
+        },
+        aclModel: AclMode.private,
+        callback: Callback(
+          callbackUrl: stsEntity.callbackParam.callbackUrl,
+          callbackBody: stsEntity.callbackParam.callbackBody,
+          calbackBodyType: CalbackBodyType.json,
+        ),
+      ),
+    );
+    return '${stsEntity.host}/${stsEntity.fileKey}';
+  }
+
+  /// 获取鉴权信息
+  static Future<AliyunOssUploadStsEntity> _getSts(String fileName) async {
+    var result = await requestClient.get(Apis.aliyunOssSts, queryParameters: {'fileName': fileName});
+    return result;
+  }
+}
+
+extension StsExtension on AliyunOssUploadStsEntity {
+  Auth authGetter() {
+    return Auth(
+      accessKey: accessKeyId,
+      accessSecret: accessKeySecret,
+      expire: expiration,
+      secureToken: securityToken,
+    );
+  }
+}
+import 'package:wow_english/common/request/basic_config.dart';
+
 enum LogLevel { debug, info, warning, error }
 class Log {
-  static LogLevel level = LogLevel.debug;
+  static LogLevel level = BasicConfig().isTestDev ? LogLevel.debug : LogLevel.error;
   /// debug
   static void d(Object? object) {
@@ -97,6 +97,8 @@ dependencies:
   flutter_sound: ^9.2.13
   # 文件管理 https://pub.dev/packages/path_provider
   path_provider: ^2.0.15
+  # 阿里云oss https://pub.dev/packages/flutter_oss_aliyun
+  flutter_oss_aliyun: ^6.2.7
 dev_dependencies:
   build_runner: ^2.4.4