using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.Text.RegularExpressions;

using System.Web;

using Qiniu.Auth;

using Qiniu.IO;

using Qiniu.IO.Resumable;

using Qiniu.RS;

/// <summary>

/// UploadHandler 的摘要说明

/// </summary>

public class UploadHandler : Handler

{

    public UploadConfig UploadConfig { get; private set; }

    public UploadResult Result { get; private set; }

    public UploadHandler(HttpContext context, UploadConfig config)

        : base(context)

    {

        this.UploadConfig = config;

        this.Result = new UploadResult() { State = UploadState.Unknown };

    }

    public override void Process()

    {

        byte[] uploadFileBytes = null;

        string uploadFileName = null;

        if (UploadConfig.Base64)

        {

            uploadFileName = UploadConfig.Base64Filename;

            uploadFileBytes = Convert.FromBase64String(Request[UploadConfig.UploadFieldName]);

        }

        else

        {

            var file = Request.Files[UploadConfig.UploadFieldName];

            uploadFileName = file.FileName;

            if (!CheckFileType(uploadFileName))

            {

                Result.State = UploadState.TypeNotAllow;

                WriteResult();

                return;

            }

            if (!CheckFileSize(file.ContentLength))

            {

                Result.State = UploadState.SizeLimitExceed;

                WriteResult();

                return;

            }

            uploadFileBytes = new byte[file.ContentLength];

            try

            {

                file.InputStream.Read(uploadFileBytes, , file.ContentLength);

            }

            catch (Exception)

            {

                Result.State = UploadState.NetworkError;

                WriteResult();

            }

        }

        Result.OriginFileName = uploadFileName;

        DateTime today = DateTime.Today;

        string qiNiuFileName =   "upload/" + today.Year + "/" + today.Month + "/" + today.Day + "/" + RuPengCommons.CommonHelper.CalcMD5(uploadFileBytes) + Path.GetExtension(uploadFileName);

    //    var savePath = PathFormatter.Format(uploadFileName, UploadConfig.PathFormat);

     //   var localPath = Server.MapPath(savePath);

        try

        {

        //    if (!Directory.Exists(Path.GetDirectoryName(localPath)))

        //    {

        //        Directory.CreateDirectory(Path.GetDirectoryName(localPath));

        //    }

        //    File.WriteAllBytes(localPath, uploadFileBytes);

        //    Result.Url = savePath;

        //    Result.State = UploadState.Success;

            Qiniu.Conf.Config.ACCESS_KEY = "MUahZ72rD1AMFaLqKBk0I382FSVVWib8ArK-7oKP";

            Qiniu.Conf.Config.SECRET_KEY = "mi3P4qzsfXiHJ7Rr9wwCBH7smRHQabpRnEFeDIuw";

             //上传域名为：上传到华东1区的域名为up.qiniu.com、up-z0.qiniu.com和upload.qiniu.com；上传到华北1区的域名为up-z1.qiniu.com和upload-z1.qiniu.com

            Qiniu.Conf.Config.UP_HOST = "http://up-z1.qiniu.com";

            IOClient target = new IOClient();

            PutExtra extra = new PutExtra();

            //设置上传的空间

            String bucket = "tupian";

            //设置上传的文件的key值

            String key = qiNiuFileName;

            //普通上传,只需要设置上传的空间名就可以了,第二个参数可以设定token过期时间

            PutPolicy put = new PutPolicy(bucket, );

            //调用Token()方法生成上传的Token

            string upToken = put.Token();

            //上传文件的路径

            MemoryStream ms = new MemoryStream(uploadFileBytes);

            //调用PutFile()方法上传

            // PutRet ret = target.PutFile(upToken, key, filePath, extra);

            PutRet ret = target.Put(upToken, key,ms, extra);

            Result.Url = "http://od6b842wn.bkt.clouddn.com/" + qiNiuFileName;

            Result.State = UploadState.Success;

        }

        catch (Exception e)

        {

            Result.State = UploadState.FileAccessError;

            Result.ErrorMessage = e.Message;

        }

        finally

        {

            WriteResult();

        }

    }

    private void WriteResult()

    {

        this.WriteJson(new

        {

            state = GetStateMessage(Result.State),

            url = Result.Url,

            title = Result.OriginFileName,

            original = Result.OriginFileName,

            error = Result.ErrorMessage

        });

    }

    private string GetStateMessage(UploadState state)

    {

        switch (state)

        {

            case UploadState.Success:

                return "SUCCESS";

            case UploadState.FileAccessError:

                return "文件访问出错，请检查写入权限";

            case UploadState.SizeLimitExceed:

                return "文件大小超出服务器限制";

            case UploadState.TypeNotAllow:

                return "不允许的文件格式";

            case UploadState.NetworkError:

                return "网络错误";

        }

        return "未知错误";

    }

    private bool CheckFileType(string filename)

    {

        var fileExtension = Path.GetExtension(filename).ToLower();

        return UploadConfig.AllowExtensions.Select(x => x.ToLower()).Contains(fileExtension);

    }

    private bool CheckFileSize(int size)

    {

        return size < UploadConfig.SizeLimit;

    }

}

public class UploadConfig

{

    /// <summary>

    /// 文件命名规则

    /// </summary>

    public string PathFormat { get; set; }

    /// <summary>

    /// 上传表单域名称

    /// </summary>

    public string UploadFieldName { get; set; }

    /// <summary>

    /// 上传大小限制

    /// </summary>

    public int SizeLimit { get; set; }

    /// <summary>

    /// 上传允许的文件格式

    /// </summary>

    public string[] AllowExtensions { get; set; }

    /// <summary>

    /// 文件是否以 Base64 的形式上传

    /// </summary>

    public bool Base64 { get; set; }

    /// <summary>

    /// Base64 字符串所表示的文件名

    /// </summary>

    public string Base64Filename { get; set; }

}

public class UploadResult

{

    public UploadState State { get; set; }

    public string Url { get; set; }

    public string OriginFileName { get; set; }

    public string ErrorMessage { get; set; }

}

public enum UploadState

{

    Success = ,

    SizeLimitExceed = -,

    TypeNotAllow = -,

    FileAccessError = -,

    NetworkError = -,

    Unknown = ,

}