import 'dart:convert';
import 'dart:io';

import 'package:flutter/material.dart';
import 'package:image_picker/image_picker.dart';

import 'package:one_key/provider/upload_img_provider.dart';
import 'package:one_key/utils/utils.dart';

// import 'package:qiniu_flutter_sdk/qiniu_flutter_sdk.dart';
import 'package:qiniu_flutter_sdk_diox/qiniu_flutter_sdk_diox.dart';

import '../models/upload_img_model.dart';

enum UploadType {
  EnvironmentUploadType, //店铺环境
  ConsumptionUploadType, //消费清单
  StoreFrontUploadType, //门头
  HeadUploadType, //头像
  QrcodeUploadType, //二维码
  TableManagerType, //桌面照片管理
  FeastRemarkType, //宴会备注--意向
  FeastRemarkXtType, //宴会备注--选台
  FeastRemarkDjType, //宴会备注--定金
  FeastRemarkContractType, //宴会备注--合同
  FeastRemarkInvoiceType, //宴会备注--发票
  InvitationStoreType, //预订安排定制----店铺图片
  WineManageType //新建存酒

}

class UploadImageUtil {
  final picker = ImagePicker();

  // 用户输入的文件名
  String key;
  // 用户输入的 partSize
  int partSize = 4;
  // 用户输入的 token
  String token;

  /// storage 实例
  final Storage storage = Storage();
  // 控制器，可以用于取消任务、获取上述的状态，进度等信息
  //  PutController putController = PutController();
  // 当前的任务状态

  ///上传到七牛云
  void startUpload(
      BuildContext context,
      File selectedFile,
      int index,
      bool needInit,
      UploadImageProvider uploadImageProvider,
      UploadType uploadType,
      {int countAll,
      List<UploadImgModel> imageList,
      VoidCallback callback,
      List<UploadImgModel> feastRemarkXtImageList}) async {
    final PutController putController = PutController();
    print(index);

    // 添加状态监听
    putController.addStatusListener((StorageStatus status) {
      print('状态变化: 当前任务状态：${status.toString()}');
    });
    // 添加整体进度监听
    putController.addProgressListener((percent) {
      print('${index}任务进度变化：进度：${percent.toStringAsFixed(4)}');
      if (uploadType == UploadType.StoreFrontUploadType) {
        //门头
        uploadImageProvider.imageListFront[index].process = percent;
      } else if (uploadType == UploadType.EnvironmentUploadType) {
        uploadImageProvider.imageListDenvironment[index].process = percent;
      } else if (uploadType == UploadType.ConsumptionUploadType) {
        //消费清单
        uploadImageProvider.imageList[index].process = percent;
      } else if (uploadType == UploadType.TableManagerType) {
        //桌面照片管理
        uploadImageProvider.tableImageList[index].process = percent;
      } else if (uploadType == UploadType.FeastRemarkType) {
        //宴会备注 ---意向
        uploadImageProvider.feastRemarkImageList[index].process = percent;
      } else if (uploadType == UploadType.FeastRemarkXtType) {
        //宴会备注 ---选台
        feastRemarkXtImageList[index].process = percent;
      } else if (uploadType == UploadType.FeastRemarkDjType) {
        //宴会备注 ---定金
        uploadImageProvider.feastRemarkDjImageList[index].process = percent;
      } else if (uploadType == UploadType.FeastRemarkContractType) {
        //宴会备注 ---合同
        uploadImageProvider.feastRemarkContractImageList[index].process =
            percent;
      } else if (uploadType == UploadType.FeastRemarkInvoiceType) {
        //宴会备注 ---发票
        uploadImageProvider.feastRemarkInvoiceImageList[index].process =
            percent;
      } else if (uploadType == UploadType.InvitationStoreType) {
        //宴会备注 ---发票
        uploadImageProvider.feastRemarkInvoiceImageList[index].process =
            percent;
      } else if (uploadType == UploadType.WineManageType) {
        //新建存酒
        imageList[index].process = percent;
      }

      uploadImageProvider.notifyListeners();
    });
    // 添加实际发送进度订阅
    putController.addSendProgressListener((percent) {
      // _onlineCheckEditProvider.imageList[index].process = percent;
      // setState(() {});
      print('${index}实际发送变化：进度：${percent.toStringAsFixed(4)}');
    });
    if (token == null || token == '') {
      await uploadImageProvider.getQiniuInfo(context, {});
    }
    var usedToken = uploadImageProvider.qiniuInfoSunModel.token;
    if (usedToken == null || usedToken == '') {
      print('token 不能为空');
      return;
    }
    print('开始上传文件');
    storage.putFile(
      selectedFile,
      usedToken,
      options: PutOptions(
        // forceBySingle:
        key: key,
        partSize: partSize,
        controller: putController,
      ),
    )
      ..then((PutResponse response) {
        print('${index}上传已完成: 原始响应数据: ${jsonEncode(response.rawData)}');
        print('------------------------');
        String imgUrl = uploadImageProvider.qiniuInfoSunModel.domain +
            '/' +
            response.rawData['key'];
        if (uploadType == UploadType.StoreFrontUploadType) {
          //门头
          uploadImageProvider.imageListFront[index].process = 1;
          uploadImageProvider.imageListFront[index].qiniuUrl = imgUrl;
        } else if (uploadType == UploadType.EnvironmentUploadType) {
          uploadImageProvider.imageListDenvironment[index].process = 1;
          uploadImageProvider.imageListDenvironment[index].qiniuUrl = imgUrl;
        } else if (uploadType == UploadType.ConsumptionUploadType) {
          //消费清单
          uploadImageProvider.imageList[index].process = 1;
          uploadImageProvider.imageList[index].qiniuUrl = imgUrl;
        } else if (uploadType == UploadType.TableManagerType) {
          //桌面照片管理
          uploadImageProvider.tableImageList[index].process = 1;
          uploadImageProvider.tableImageList[index].qiniuUrl = imgUrl;
          uploadImageProvider.tableImageList[index].isUpload = false;
          uploadImageProvider.countUpload++;
          if (uploadImageProvider.countUpload == countAll) {
            //所有图片上传完成，可以绑定桌位
            uploadImageProvider.countUpload = 0;
            callback();
          }
        } else if (uploadType == UploadType.FeastRemarkType) {
          //宴会备注---意向
          uploadImageProvider.feastRemarkImageList[index].process = 1;
          uploadImageProvider.feastRemarkImageList[index].qiniuUrl = imgUrl;
        } else if (uploadType == UploadType.FeastRemarkXtType) {
          //宴会备注---选台
          feastRemarkXtImageList[index].process = 1;
          feastRemarkXtImageList[index].qiniuUrl = imgUrl;
        } else if (uploadType == UploadType.FeastRemarkDjType) {
          //宴会备注---定金
          uploadImageProvider.feastRemarkDjImageList[index].process = 1;
          uploadImageProvider.feastRemarkDjImageList[index].qiniuUrl = imgUrl;
        } else if (uploadType == UploadType.FeastRemarkContractType) {
          //宴会备注 ---合同
          uploadImageProvider.feastRemarkContractImageList[index].process = 1;
          uploadImageProvider.feastRemarkContractImageList[index].qiniuUrl =
              imgUrl;
        } else if (uploadType == UploadType.FeastRemarkInvoiceType) {
          //宴会备注 ---发票
          uploadImageProvider.feastRemarkInvoiceImageList[index].process = 1;
          uploadImageProvider.feastRemarkInvoiceImageList[index].qiniuUrl =
              imgUrl;
        } else if (uploadType == UploadType.InvitationStoreType) {
          //宴会备注 ---发票
          uploadImageProvider.feastRemarkInvoiceImageList[index].process = 1;
          uploadImageProvider.feastRemarkInvoiceImageList[index].qiniuUrl =
              imgUrl;
        } else if (uploadType == UploadType.WineManageType) {
          //新建存酒
          imageList[index].process = 1;
          imageList[index].qiniuUrl = imgUrl;
        }

        // 取消当前任务
        // putController.cancel();
        // _image
        uploadImageProvider.notifyListeners();
      })
      ..catchError((dynamic error) {
        if (uploadType == UploadType.StoreFrontUploadType) {
          //门头
          uploadImageProvider.imageListFront.removeAt(index);
        } else if (uploadType == UploadType.EnvironmentUploadType) {
          uploadImageProvider.imageListDenvironment.removeAt(index);
        } else if (uploadType == UploadType.ConsumptionUploadType) {
          //消费清单
          uploadImageProvider.imageList.removeAt(index);
        } else if (uploadType == UploadType.TableManagerType) {
          //桌面照片管理
          uploadImageProvider.tableImageList.removeAt(index);
        } else if (uploadType == UploadType.FeastRemarkType) {
          //宴会备注---意向
          uploadImageProvider.feastRemarkImageList.removeAt(index);
        } else if (uploadType == UploadType.FeastRemarkXtType) {
          //宴会备注---选台
          feastRemarkXtImageList.removeAt(index);
        } else if (uploadType == UploadType.FeastRemarkDjType) {
          //宴会备注---定金
          uploadImageProvider.feastRemarkDjImageList.removeAt(index);
        } else if (uploadType == UploadType.FeastRemarkContractType) {
          //宴会备注 ---合同
          uploadImageProvider.feastRemarkContractImageList.removeAt(index);
        } else if (uploadType == UploadType.FeastRemarkInvoiceType) {
          //宴会备注 ---发票
          uploadImageProvider.feastRemarkInvoiceImageList.removeAt(index);
        } else if (uploadType == UploadType.InvitationStoreType) {
          //宴会备注 ---发票
          uploadImageProvider.feastRemarkInvoiceImageList.removeAt(index);
        } else if (uploadType == UploadType.WineManageType) {
          //新建存酒
          imageList.removeAt(index);
        }

        // 取消当前任务
        putController.cancel();
        uploadImageProvider.notifyListeners();
        if (error is StorageError) {
          switch (error.type) {
            case StorageErrorType.CONNECT_TIMEOUT:
              Utils.showToast('发生错误: 连接超时');
              break;
            case StorageErrorType.SEND_TIMEOUT:
              print('发生错误: 发送数据超时');
              Utils.showToast('发生错误: 发送数据超时');
              break;
            case StorageErrorType.RECEIVE_TIMEOUT:
              print('发生错误: 响应数据超时');
              Utils.showToast('发生错误: 响应数据超时');
              break;
            case StorageErrorType.RESPONSE:
              print('发生错误: ${error.message}');
              Utils.showToast('发生错误: ${error.message}');
              // Utils.showToast('发生错误000: ${error}');
              // Utils.showToast('发生错误000: ${error.code}');
              // Utils.showToast('发生错误000: ${error.message}');
              break;
            case StorageErrorType.CANCEL:
              print('发生错误: 请求取消');
              Utils.showToast('发生错误: 请求取消');
              break;
            case StorageErrorType.UNKNOWN:
              print('发生错误: ');
              Utils.showToast('发生错误: 未知错误');
              break;
            case StorageErrorType.NO_AVAILABLE_HOST:
              print('发生错误: 无可用 Host');
              Utils.showToast('发生错误:  无可用 Host');
              break;
            case StorageErrorType.IN_PROGRESS:
              print('发生错误: 已在队列中');
              Utils.showToast('发生错误:  已在队列中');
              break;
          }
        } else {
          print('发生错误: ${error.toString()}');
          Utils.showToast('发生错误: ${error.toString()}');
        }

        print('------------------------');
      });
  }

  ///上传到七牛云
  void startUploadOnly(BuildContext context, File selectedFile, int index,
      bool needInit, UploadImageProvider uploadImageProvider) async {
    final PutController putController = PutController();
    print(index);

    // 添加状态监听
    putController.addStatusListener((StorageStatus status) {
      print('状态变化: 当前任务状态：${status.toString()}');
    });
    // 添加整体进度监听
    putController.addProgressListener((percent) {
      print('${index}任务进度变化：进度：${percent.toStringAsFixed(4)}');
      if (index == 0) {
        //0 头像
        uploadImageProvider.touxiang.process = percent;
      } else if (index == 2) {
        //2 门头
        uploadImageProvider.mentou.process = percent;
      } else if (index == 3) {
        //3 菜品
        uploadImageProvider.dish.process = percent;
      } else if (index == 4) {
        //4 预订安排首图
        uploadImageProvider.firstImage.process = percent;
      } else if (index == 5) {
        //4 预订安排首图
        uploadImageProvider.storeImage1.process = percent;
      } else if (index == 6) {
        //4 预订安排首图
        uploadImageProvider.storeImage2.process = percent;
      } else if (index == 7) {
        //4 预订安排首图
        uploadImageProvider.storeImage3.process = percent;
      } else if (index == 8) {
        //4 预订安排首图
        uploadImageProvider.storeImage4.process = percent;
      } else {
        //1 二维码
        uploadImageProvider.erweima.process = percent;
      }
      uploadImageProvider.notifyListeners();
    });
    // 添加实际发送进度订阅
    putController.addSendProgressListener((percent) {
      // _onlineCheckEditProvider.imageList[index].process = percent;
      // setState(() {});
      print('${index}实际发送变化：进度：${percent.toStringAsFixed(4)}');
    });
    if (token == null || token == '') {
      await uploadImageProvider.getQiniuInfo(context, {});
    }
    var usedToken = uploadImageProvider.qiniuInfoSunModel.token;
    if (usedToken == null || usedToken == '') {
      print('token 不能为空');
      return;
    }
    print('开始上传文件');
    storage.putFile(
      selectedFile,
      usedToken,
      options: PutOptions(
        key: key,
        partSize: partSize,
        controller: putController,
      ),
    )
      ..then((PutResponse response) {
        print('${index}上传已完成: 原始响应数据: ${jsonEncode(response.rawData)}');
        print('------------------------');
        String imgUrl = uploadImageProvider.qiniuInfoSunModel.domain +
            '/' +
            response.rawData['key'];

        // 取消当前任务
        // putController.cancel();
        if (index == 0) {
          uploadImageProvider.touxiang.process = 1;
          uploadImageProvider.touxiang.qiniuUrl = imgUrl;
          uploadImageProvider.touxiang.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 1) {
          uploadImageProvider.erweima.process = 1;
          uploadImageProvider.erweima.qiniuUrl = imgUrl;
          uploadImageProvider.erweima.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 2) {
          uploadImageProvider.mentou.process = 1;
          uploadImageProvider.mentou.qiniuUrl = imgUrl;
          uploadImageProvider.mentou.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 3) {
          uploadImageProvider.dish.process = 1;
          uploadImageProvider.dish.qiniuUrl = imgUrl;
          uploadImageProvider.dish.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 4) {
          uploadImageProvider.firstImage.process = 1;
          uploadImageProvider.firstImage.qiniuUrl = imgUrl;
          uploadImageProvider.firstImage.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 5) {
          uploadImageProvider.storeImage1.process = 1;
          uploadImageProvider.storeImage1.qiniuUrl = imgUrl;
          uploadImageProvider.storeImage1.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 6) {
          uploadImageProvider.storeImage2.process = 1;
          uploadImageProvider.storeImage2.qiniuUrl = imgUrl;
          uploadImageProvider.storeImage2.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 7) {
          uploadImageProvider.storeImage3.process = 1;
          uploadImageProvider.storeImage3.qiniuUrl = imgUrl;
          uploadImageProvider.storeImage3.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 8) {
          uploadImageProvider.storeImage4.process = 1;
          uploadImageProvider.storeImage4.qiniuUrl = imgUrl;
          uploadImageProvider.storeImage4.file = null;
          uploadImageProvider.notifyListeners();
        }
      })
      ..catchError((dynamic error) {
        if (index == 0) {
          uploadImageProvider.touxiang.process = 0;
          uploadImageProvider.touxiang.qiniuUrl = null;
          uploadImageProvider.touxiang.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 1) {
          uploadImageProvider.erweima.process = 0;
          uploadImageProvider.erweima.qiniuUrl = null;
          uploadImageProvider.erweima.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 2) {
          uploadImageProvider.mentou.process = 0;
          uploadImageProvider.mentou.qiniuUrl = null;
          uploadImageProvider.mentou.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 3) {
          uploadImageProvider.dish.process = 0;
          uploadImageProvider.dish.qiniuUrl = null;
          uploadImageProvider.dish.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 4) {
          uploadImageProvider.firstImage.process = 0;
          uploadImageProvider.firstImage.qiniuUrl = null;
          uploadImageProvider.firstImage.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 5) {
          uploadImageProvider.storeImage1.process = 0;
          uploadImageProvider.storeImage1.qiniuUrl = null;
          uploadImageProvider.storeImage1.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 6) {
          uploadImageProvider.storeImage2.process = 0;
          uploadImageProvider.storeImage2.qiniuUrl = null;
          uploadImageProvider.storeImage2.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 7) {
          uploadImageProvider.storeImage3.process = 0;
          uploadImageProvider.storeImage3.qiniuUrl = null;
          uploadImageProvider.storeImage3.file = null;
          uploadImageProvider.notifyListeners();
        } else if (index == 8) {
          uploadImageProvider.storeImage4.process = 0;
          uploadImageProvider.storeImage4.qiniuUrl = null;
          uploadImageProvider.storeImage4.file = null;
          uploadImageProvider.notifyListeners();
        }
        // 取消当前任务
        putController.cancel();
        uploadImageProvider.notifyListeners();
        if (error is StorageError) {
          switch (error.type) {
            case StorageErrorType.CONNECT_TIMEOUT:
              Utils.showToast('发生错误: 连接超时');
              break;
            case StorageErrorType.SEND_TIMEOUT:
              print('发生错误: 发送数据超时');
              Utils.showToast('发生错误: 发送数据超时');
              break;
            case StorageErrorType.RECEIVE_TIMEOUT:
              print('发生错误: 响应数据超时');
              Utils.showToast('发生错误: 响应数据超时');
              break;
            case StorageErrorType.RESPONSE:
              print('发生错误: ${error.message}');
              // Utils.showToast('发生错误000: ${error}');
              // Utils.showToast('发生错误000: ${error.code}');
              Utils.showToast('发生错误: ${error.message}');
              break;
            case StorageErrorType.CANCEL:
              print('发生错误: 请求取消');
              Utils.showToast('发生错误: 请求取消');
              break;
            case StorageErrorType.UNKNOWN:
              print('发生错误: ');
              Utils.showToast('发生错误: 未知错误');
              break;
            case StorageErrorType.NO_AVAILABLE_HOST:
              print('发生错误: 无可用 Host');
              Utils.showToast('发生错误:  无可用 Host');
              break;
            case StorageErrorType.IN_PROGRESS:
              print('发生错误: 已在队列中');
              Utils.showToast('发生错误:  已在队列中');
              break;
          }
        } else {
          print('发生错误: ${error.toString()}');
          Utils.showToast('发生错误: ${error.toString()}');
        }

        print('------------------------');
      });
  }
}