import 'dart:io';
import 'package:flutter_picgo/model/uploaded.dart';
import 'package:flutter_picgo/resources/table_name_keys.dart';
import 'package:flutter_picgo/utils/shared_preferences.dart';
import 'package:flutter_picgo/utils/sql.dart';
import 'package:flutter_picgo/utils/strategy/image_upload_strategy.dart';

/// 图像上传类
class ImageUploadUtils {
  ImageUploadStrategy _strategy;

  ImageUploadUtils(this._strategy);

  Future<Uploaded> delete(Uploaded uploaded) async {
    var sp = await SpUtil.getInstance();
    var isForceDelete =
        sp.getBool(SharedPreferencesKeys.settingIsForceDelete) ?? false;
    // 关闭仅关闭本地图片，则需要根据对应策略来删除图片
    if (!isForceDelete) {
      var upTmp = await _strategy.delete(uploaded);
      if (upTmp == null) {
        throw Exception('delete remote error');
      }
    }
    // 删除本地项
    var raw = await deleteUploadedItem(uploaded);
    if (raw > 0) {
      return uploaded;
    } else {
      throw Exception('delete local error');
    }
  }

  Future<Uploaded> upload(File file, String renameImage) {
    return _strategy.upload(file, renameImage);
  }

  /// 获取默认图床类型
  static Future<String> getDefaultPB() async {
    var sp = await SpUtil.getInstance();
    String pbType = sp.getDefaultPB();
    return pbType;
  }

  /// 设置默认图床
  static Future setDefaultPB(String type) async {
    var sp = await SpUtil.getInstance();
    if (sp.getDefaultPB() != type) {
      sp.setDefaultPB(type);
    }
  }

  /// 保存图床配置
  static Future<int> savePBConfig(String type, String config) async {
    var sql = Sql.setTable(TABLE_NAME_PBSETTING);
    int row = await sql.rawUpdate('config = ? WHERE type = ?', [config, type]);
    return row;
  }

  /// 获取当前图床配置
  static Future<String> getPBConfig(String type) async {
    var sql = Sql.setTable(TABLE_NAME_PBSETTING);
    var pbsettingRow = await sql.getBySql('type = ?', [type]);
    if (pbsettingRow != null && pbsettingRow.length > 0) {
      return pbsettingRow.first["config"];
    }
    return null;
  }

  /// 获取图床名称
  static Future<String> getPBName(String type) async {
    var sql = Sql.setTable(TABLE_NAME_PBSETTING);
    var pbsettingRow = (await sql.getBySql('type = ?', [type]));
    if (pbsettingRow != null && pbsettingRow.length > 0) {
      return pbsettingRow.first["name"];
    }
    return null;
  }

  /// 保存已上传项
  static Future<int> saveUploadedItem(Uploaded item) async {
    var sql = Sql.setTable(TABLE_NAME_UPLOADED);
    return await sql.rawInsert('(path, type, info)  VALUES(?, ?, ?)',
        [item.path, item.type, item.info]);
  }

  /// 删除已上传的本地数据库项
  static Future<int> deleteUploadedItem(Uploaded item) async {
    var sql = Sql.setTable(TABLE_NAME_UPLOADED);
    var result = await sql.rawDelete('id = ?', [item.id]);
    return result;
  }

  /// 获取已上传项的信息
  static Future<String> getUploadedItemInfo(int id) async {
    var sql = Sql.setTable(TABLE_NAME_UPLOADED);
    return (await sql.getBySql('id = ?', [id]))?.first["info"];
  }

  /// 获取已上传列表
  static Future<List<Uploaded>> getUploadeds() async {
    var sql = Sql.setTable(TABLE_NAME_UPLOADED);
    var result = await sql.get();
    List<Uploaded> uploadeds = result.map((v) {
      return Uploaded.fromMap(v);
    }).toList();
    return uploadeds;
  }
}