flutter-picgo/lib/utils/strategy/impl/qiniu_image_upload.dart

import 'dart:convert';
import 'package:dio/dio.dart';
import 'package:path/path.dart' as path;
import 'package:flutter_picgo/api/qiniu_api.dart';
import 'package:flutter_picgo/model/qiniu_config.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 'dart:io';
import 'package:flutter_picgo/utils/strategy/image_upload_strategy.dart';
import 'package:flutter_picgo/utils/strings.dart';

class QiniuImageUpload extends ImageUploadStrategy {
  @override
  Future<Uploaded> delete(Uploaded uploaded) async {
    try {
      QiniuUploadedInfo info;
      try {
        info = QiniuUploadedInfo.fromJson(json.decode(uploaded.info));
      } catch (e) {}
      if (info != null) {
        String encodedEntryURI = QiniuApi.urlSafeBase64Encode(
            utf8.encode('${info.bucket}:${info.key}'));
        String url = '${QiniuApi.BASE_URL}/delete/$encodedEntryURI';
        var result = await QiniuApi.delete(url, info.accessKey, info.secretKey);
        if (isBlank(result.toString())) {
          return uploaded;
        } else {
          throw new QiniuError(error: '${result['error']}');
        }
      }
      return uploaded;
    } on DioError catch (e) {
      if (e.type == DioErrorType.response &&
          e.error.toString().indexOf('400') > 0) {
        throw QiniuError(error: '400 请求报文格式错误');
      } else if (e.type == DioErrorType.response &&
          e.error.toString().indexOf('401') > 0) {
        throw QiniuError(error: '401 管理凭证无效');
      } else if (e.type == DioErrorType.response &&
          e.error.toString().indexOf('599') > 0) {
        throw QiniuError(error: '599 服务端操作失败');
      } else if (e.type == DioErrorType.response &&
          e.error.toString().indexOf('612') > 0) {
        throw QiniuError(error: '612 待删除资源不存在');
      } else {
        throw e;
      }
    }
  }

  /// 七牛云上传同个文件名会直接覆盖
  @override
  Future<Uploaded> upload(File file, String renameImage) async {
    try {
      String configStr = await ImageUploadUtils.getPBConfig(PBTypeKeys.qiniu);
      if (isBlank(configStr)) {
        throw QiniuError(error: '读取配置文件错误！请重试');
      }
      QiniuConfig config = QiniuConfig.fromJson(json.decode(configStr));
      // putPolicy
      String resourceKey = path.joinAll([config.path ?? '', renameImage]);
      String putPolicy = QiniuApi.generatePutPolicy(config.bucket, resourceKey);
      String upToken = QiniuApi.generateUpToken(
          config.accessKey, config.secretKey, putPolicy);
      var result = await QiniuApi.upload(
          config.area,
          FormData.fromMap({
            "key": resourceKey,
            "token": upToken,
            "fileName": renameImage,
            "file":
                await MultipartFile.fromFile(file.path, filename: renameImage),
          }),
          {
            "Authorization": 'UpToken $upToken',
          });
      var uploadedItem = Uploaded(
          -1,
          '${path.join(config.url, result["key"])}${config.options ?? ''}',
          PBTypeKeys.qiniu,
          info: json.encode(QiniuUploadedInfo(
              hash: result["hash"],
              key: result["key"],
              accessKey: config.accessKey,
              secretKey: config.secretKey,
              bucket: config.bucket)));
      await ImageUploadUtils.saveUploadedItem(uploadedItem);
      return uploadedItem;
    } on DioError catch (e) {
      if (e.type == DioErrorType.response &&
          e.error.toString().indexOf('400') > 0) {
        throw QiniuError(error: '400 请求报文格式错误');
      } else if (e.type == DioErrorType.response &&
          e.error.toString().indexOf('401') > 0) {
        throw QiniuError(error: '401 管理凭证无效');
      } else if (e.type == DioErrorType.response &&
          e.error.toString().indexOf('599') > 0) {
        throw QiniuError(error: '599 服务端操作失败');
      } else if (e.type == DioErrorType.response &&
          e.error.toString().indexOf('612') > 0) {
        throw QiniuError(error: '612 待删除资源不存在');
      } else {
        throw e;
      }
    }
  }
}

/// QiniuError describes the error info  when request failed.
class QiniuError implements Exception {
  QiniuError({
    this.error,
  });

  dynamic error;

  String get message => (error?.toString() ?? '');

  @override
  String toString() {
    var msg = 'QiniuError $message';
    if (error is Error) {
      msg += '\n${error.stackTrace}';
    }
    return msg;
  }
}

class QiniuUploadedInfo {
  String hash;
  String key;
  String accessKey;
  String secretKey;
  String bucket;

  QiniuUploadedInfo(
      {this.hash, this.key, this.accessKey, this.secretKey, this.bucket});

  QiniuUploadedInfo.fromJson(Map<String, dynamic> json) {
    hash = json['hash'];
    key = json['key'];
    accessKey = json['accessKey'];
    secretKey = json['secretKey'];
    bucket = json['bucket'];
  }

  Map<String, dynamic> toJson() {
    final Map<String, dynamic> data = new Map<String, dynamic>();
    data['hash'] = this.hash;
    data['key'] = this.key;
    data['accessKey'] = this.accessKey;
    data['secretKey'] = this.secretKey;
    data['bucket'] = this.bucket;
    return data;
  }
}