isas/test/FileUploadWpf/MainWindow.xaml.cs

using Microsoft.Win32;
using Newtonsoft.Json;
using System;
using System.IO;
using System.Net;
using System.Text;
using System.Threading;
using System.Windows;

namespace FileUploadWpf
{
    /// <summary>
    /// Interaction logic for MainWindow.xaml
    /// </summary>
    public partial class MainWindow : Window
    {
        /// <summary>
        /// 上传的文件路径。
        /// </summary>
        private string[] filePaths;

        /// <summary>
        /// 上传的文件续传点。
        /// </summary>
        private long startPoint;

        private string baseUrl = @"http://localhost:9091/api/services/isas/";

        private string relativePath = @"\InspectionItemResult\2020\03-03\测试二_test33_065148\";

        public MainWindow()

        {
            InitializeComponent();
        }

        /// <summary>
        /// 上传按钮点击事件。
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button1_Click(object sender, RoutedEventArgs e)
        {
            OpenFileDialog openFileDialog = new OpenFileDialog();
            openFileDialog.Multiselect = true;
            if (openFileDialog.ShowDialog() == true)
            {
                this.filePaths = openFileDialog.FileNames;
                ThreadStart ts = new ThreadStart(ResumeFileThread);
                Thread t = new Thread(ts);
                t.Start();
            }
        }

        public void ResumeFileThread()
        {
            this.Dispatcher.Invoke(() =>
            {
                this.lb_log.Items.Clear();
            });
            if (this.filePaths != null && this.filePaths.Length > 0)
            {
                foreach (string filePath in this.filePaths)
                {
                    string result = ResumeFile(filePath, relativePath, startPoint, 1024 * 128);
                    this.Dispatcher.Invoke(() =>
                    {
                        this.lb_log.Items.Add(filePath + ":" + result);
                    });
                }
            }
        }

        public string ResumeFile(string fromFileFullPath, string toRelativePath, long startPoint, int byteCount)
        {
            string hostUrl = baseUrl + "InspectionItemResult/FileUpload";
            string result = "上传成功！";
            byte[] data;
            string fileName = System.IO.Path.GetFileName(fromFileFullPath);
            FileStream fs = new FileStream(fromFileFullPath, FileMode.Open, FileAccess.Read);
            long fileLength = fs.Length;
            BinaryReader bReader = new BinaryReader(fs);
            try
            {
                #region 续传处理
                if (startPoint == fileLength)
                {
                    result = "文件秒传！";
                }
                if (startPoint >= 1 && startPoint <= fileLength - 1)
                {
                    fs.Seek(startPoint, SeekOrigin.Current);
                }
                #endregion 续传处理
                #region 分割文件上传
                for (; startPoint <= fileLength - 1; startPoint = startPoint + byteCount)
                {
                    int step = 0;
                    if (startPoint + byteCount > fileLength)
                    {
                        data = new byte[Convert.ToInt32(fileLength - startPoint)];
                        bReader.Read(data, 0, Convert.ToInt32(fileLength - startPoint));
                        step = Convert.ToInt32(fileLength - startPoint);
                    }
                    else
                    {
                        data = new byte[byteCount];
                        bReader.Read(data, 0, byteCount);
                        step = byteCount;
                    }
                    string contentRange = "bytes " + startPoint + "-" + (startPoint + step) + "/" + fs.Length;
                    RequestEasyResult rst = HttpHelper.HttpPostRequest<RequestEasyResult>(hostUrl + "?fileName=" + fileName + "&relativePath=" + toRelativePath, data, contentRange);
                    this.Dispatcher.Invoke(() =>
                    {
                        this.tb_filePath.Text = fromFileFullPath + "||" + rst.Message;
                        this.tb_uploadData.Text = (startPoint + step) + "/" + fileLength;
                    });
                }
                #endregion 分割文件上传
            }
            catch (Exception ex)
            {
                result = ex.Message;
            }
            bReader.Close();
            fs.Close();
            return result;
        }

        public string ResumeFile_old(string fromFileFullPath, string toRelativePath, long startPoint, int byteCount)
        {
            string hostUrl = baseUrl + "InspectionItemResult/FileUpload";
            string result = "上传成功！";
            byte[] data;
            string fileName = System.IO.Path.GetFileName(fromFileFullPath);
            WebClient webClient = new WebClient();
            FileStream fs = new FileStream(fromFileFullPath, FileMode.Open, FileAccess.Read);
            long fileLength = fs.Length;
            BinaryReader bReader = new BinaryReader(fs);
            try
            {
                #region 续传处理
                if (startPoint == fileLength)
                {
                    result = "文件秒传！";
                }
                if (startPoint >= 1 && startPoint <= fileLength - 1)
                {
                    fs.Seek(startPoint, SeekOrigin.Current);
                }
                #endregion 续传处理
                #region 分割文件上传
                for (; startPoint <= fileLength - 1; startPoint = startPoint + byteCount)
                {
                    int step = 0;
                    if (startPoint + byteCount > fileLength)
                    {
                        data = new byte[Convert.ToInt32(fileLength - startPoint)];
                        bReader.Read(data, 0, Convert.ToInt32(fileLength - startPoint));
                        step = Convert.ToInt32(fileLength - startPoint);
                    }
                    else
                    {
                        data = new byte[byteCount];
                        bReader.Read(data, 0, byteCount);
                        step = byteCount;
                    }
                    webClient.Headers.Remove(HttpRequestHeader.ContentRange);
                    webClient.Headers.Add(HttpRequestHeader.ContentRange, "bytes " + startPoint + "-" + (startPoint + step) + "/" + fs.Length);
                    byte[] rstBytes = webClient.UploadData(hostUrl + "?fileName=" + fileName + "&relativePath=" + toRelativePath, "POST", data);
                    string rstStr = Encoding.UTF8.GetString(rstBytes);
                    this.Dispatcher.Invoke(() =>
                    {
                        this.tb_filePath.Text = fromFileFullPath + "||" + rstStr;
                        this.tb_uploadData.Text = (startPoint + step) + "/" + fileLength;
                    });
                }
                #endregion 分割文件上传
            }
            catch (Exception ex)
            {
                result = ex.Message;
            }
            bReader.Close();
            fs.Close();
            return result;
        }

        #region

        /// <summary>
        /// 允许拖拽。
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Form1_Load(object sender, RoutedEventArgs e)
        {
            this.AllowDrop = true;
        }

        #endregion
    }

    public class HttpHelper
    {
        /// <summary>
        /// http请求，POST方式
        /// </summary>
        /// <param name="url">请求连接</param>
        /// <param name="dicParams">请求参数</param>
        /// <returns>根据泛型返回响应值</returns>
        public static T HttpPostRequest<T>(string url, byte[] buffer, string contentRange = null, string accessToken = null)
        {
            try
            {
                HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);//webrequest请求api地址
                request.Method = "POST";
                //request.Accept = "text/html, application/xhtml+xml, */*";  //"text/html, application/xhtml+xml, */*";
                request.ContentType = "multipart/form-data";
                if (!string.IsNullOrWhiteSpace(contentRange))
                    request.Headers.Add("Content-Range", contentRange);
                if (!string.IsNullOrEmpty(accessToken))
                    request.Headers.Add("Authorization", "Bearer" + " " + accessToken);
                if (buffer != null)
                {
                    request.ContentLength = buffer.Length;
                    request.GetRequestStream().Write(buffer, 0, buffer.Length);
                }
                return GetResponseValue<T>(request);
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        private static T GetResponseValue<T>(HttpWebRequest request)
        {
            try
            {
                T rstObj = default(T);
                HttpWebResponse response = (HttpWebResponse)request.GetResponse();
                using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8))
                {
                    rstObj = JsonConvert.DeserializeObject<T>(reader.ReadToEnd());
                    reader.Close();
                    reader.Dispose();
                }
                response.Close();
                return rstObj;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
    }

    public class RequestEasyResult
    {
        private bool _flag;
        private string _msg;

        public bool Flag
        {
            get
            {
                return _flag;
            }

            set
            {
                _flag = value;
            }
        }

        public string Message
        {
            get
            {
                return _msg;
            }

            set
            {
                _msg = value;
            }
        }
    }
}