using System;
using System.Collections.Generic;
using System.IO;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading;
using System.Threading.Tasks;
using System.IO.Compression;

/// <summary>上傳進(jìn)度回調(diào)：當(dāng)前字節(jié)、總字節(jié)</summary>
public delegate void UploadProgressDelegate(long currentBytes, long totalBytes);
public static class HttpFileUploadHelper
{
    // 全局HttpClient靜態(tài)實(shí)例，復(fù)用連接（禁止每次new HttpClient）
    private static readonly HttpClient _httpClient = new HttpClient()
    {
        Timeout = TimeSpan.FromMinutes(5) // 大文件5分鐘超時(shí)
    };
    #region 場(chǎng)景1：?jiǎn)挝募苯由蟼鳎–SV/圖片/壓縮包通用）
    /// <summary>
    /// 單文件HTTP上傳
    /// </summary>
    /// <param name="apiUrl">后端上傳接口地址</param>
    /// <param name="filePath">本地文件完整路徑</param>
    /// <param name="businessParams">自定義業(yè)務(wù)參數(shù) 如設(shè)備Id、工位</param>
    /// <param name="progress">上傳進(jìn)度回調(diào)</param>
    /// <param name="cancellationToken">取消上傳</param>
    /// <returns>后端返回的JSON字符串</returns>
    public static async Task<string> UploadSingleFileAsync(
        string apiUrl,
        string filePath,
        Dictionary<string, string> businessParams = null,
        UploadProgressDelegate progress = null,
        CancellationToken cancellationToken = default)
    {
        if (!File.Exists(filePath))
            throw new FileNotFoundException("文件不存在", filePath);
        var fileInfo = new FileInfo(filePath);
        long totalLength = fileInfo.Length;
        // 構(gòu)造multipart/form-data表單
        using var content = new MultipartFormDataContent();
        // 1. 添加業(yè)務(wù)自定義參數(shù)
        if (businessParams != null)
        {
            foreach (var kv in businessParams)
            {
                content.Add(new StringContent(kv.Value), kv.Key);
            }
        }
        // 2. 創(chuàng)建帶進(jìn)度監(jiān)聽的文件流
        using var fileStream = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.Read, 4096, true);
        var progressStream = new ProgressStream(fileStream, progress, totalLength);
        var streamContent = new StreamContent(progressStream);
        // 設(shè)置文件MIME類型
        string mimeType = GetMimeType(fileInfo.Extension);
        streamContent.Headers.ContentType = MediaTypeHeaderValue.Parse(mimeType);
        content.Add(streamContent, "uploadFile", fileInfo.Name);
        // 3. 發(fā)起POST請(qǐng)求
        using var response = await _httpClient.PostAsync(apiUrl, content, cancellationToken);
        response.EnsureSuccessStatusCode(); // 非200直接拋異常
        return await response.Content.ReadAsStringAsync(cancellationToken);
    }
    #endregion
    #region 場(chǎng)景2：多文件分別批量上傳（多次HTTP請(qǐng)求）
    /// <summary>批量逐個(gè)上傳多個(gè)獨(dú)立文件</summary>
    public static async Task<List<string>> UploadMultiFilesSeparateAsync(
        string apiUrl,
        List<string> filePaths,
        Dictionary<string, string> businessParams = null,
        UploadProgressDelegate singleFileProgress = null,
        CancellationToken cancellationToken = default)
    {
        var resultList = new List<string>();
        foreach (var file in filePaths)
        {
            var res = await UploadSingleFileAsync(apiUrl, file, businessParams, singleFileProgress, cancellationToken);
            resultList.Add(res);
        }
        return resultList;
    }
    #endregion
    #region 場(chǎng)景3：多文件本地打包ZIP后只上傳一個(gè)壓縮包（推薦大量文件場(chǎng)景）
    /// <summary>
    /// 多個(gè)文件先壓縮成臨時(shí)ZIP，再上傳壓縮包，上傳完成自動(dòng)刪除臨時(shí)zip
    /// </summary>
    public static async Task<string> UploadFilesAsZipAsync(
        string apiUrl,
        List<string> sourceFilePaths,
        string tempZipSavePath = null,
        Dictionary<string, string> businessParams = null,
        UploadProgressDelegate progress = null,
        CancellationToken cancellationToken = default)
    {
        // 生成臨時(shí)壓縮包路徑（不傳則自動(dòng)放系統(tǒng)臨時(shí)目錄）
        if (string.IsNullOrEmpty(tempZipSavePath))
        {
            tempZipSavePath = Path.Combine(Path.GetTempPath(), $"upload_{Guid.NewGuid():N}.zip");
        }
        // 本地打包所有文件到zip
        CreateZipFromFiles(sourceFilePaths, tempZipSavePath);
        try
        {
            // 上傳生成的zip壓縮包
            var result = await UploadSingleFileAsync(apiUrl, tempZipSavePath, businessParams, progress, cancellationToken);
            return result;
        }
        finally
        {
            // 上傳成功/失敗都刪除臨時(shí)壓縮文件
            if (File.Exists(tempZipSavePath))
                File.Delete(tempZipSavePath);
        }
    }
    /// <summary>將多個(gè)本地文件打包成ZIP</summary>
    private static void CreateZipFromFiles(List<string> fileList, string zipPath)
    {
        if (File.Exists(zipPath)) File.Delete(zipPath);
        using var zipFile = ZipFile.Open(zipPath, ZipArchiveMode.Create);
        foreach (var file in fileList)
        {
            if (!File.Exists(file)) continue;
            var fileName = Path.GetFileName(file);
            zipFile.CreateEntryFromFile(file, fileName, CompressionLevel.Optimal);
        }
    }
    #endregion
    #region 輔助工具：MIME類型映射 + 進(jìn)度監(jiān)聽流
    /// <summary>文件后綴對(duì)應(yīng)MIME類型</summary>
    private static string GetMimeType(string ext)
    {
        return ext.ToLower() switch
        {
            ".csv" => "text/csv",
            ".jpg" or ".jpeg" => "image/jpeg",
            ".png" => "image/png",
            ".bmp" => "image/bmp",
            ".gif" => "image/gif",
            ".zip" => "application/zip",
            ".rar" => "application/x-rar-compressed",
            ".txt" => "text/plain",
            ".xlsx" => "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet",
            _ => "application/octet-stream" // 未知二進(jìn)制文件通用
        };
    }
    /// <summary>包裝文件流，讀取時(shí)觸發(fā)上傳進(jìn)度回調(diào)</summary>
    private class ProgressStream : Stream
    {
        private readonly Stream _innerStream;
        private readonly UploadProgressDelegate _progressCallback;
        private readonly long _totalLength;
        private long _readBytes;
        public ProgressStream(Stream inner, UploadProgressDelegate callback, long totalLen)
        {
            _innerStream = inner;
            _progressCallback = callback;
            _totalLength = totalLen;
            _readBytes = 0;
        }
        public override int Read(byte[] buffer, int offset, int count)
        {
            var read = _innerStream.Read(buffer, offset, count);
            if (read > 0)
            {
                _readBytes += read;
                _progressCallback?.Invoke(_readBytes, _totalLength);
            }
            return read;
        }
        // 下面簡(jiǎn)單轉(zhuǎn)發(fā)所有Stream虛方法
        public override bool CanRead => _innerStream.CanRead;
        public override bool CanSeek => _innerStream.CanSeek;
        public override bool CanWrite => _innerStream.CanWrite;
        public override long Length => _innerStream.Length;
        public override long Position { get; set; }
        public override void Flush() => _innerStream.Flush();
        public override long Seek(long offset, SeekOrigin origin) => _innerStream.Seek(offset, origin);
        public override void SetLength(long value) => _innerStream.SetLength(value);
        public override void Write(byte[] buffer, int offset, int count) => _innerStream.Write(buffer, offset, count);
        protected override void Dispose(bool disposing) => _innerStream.Dispose();
    }
    #endregion
}

using System.Windows.Forms;
private async void button_SelectSingle_Click(object sender, EventArgs e)
{
    using var dialog = new OpenFileDialog
    {
        Filter = "所有文件|*.*|CSV文件|*.csv|圖片|*.jpg;*.png;*.bmp|壓縮包|*.zip;*.rar",
        Multiselect = false
    };
    if (dialog.ShowDialog() != DialogResult.OK) return;
    string filePath = dialog.FileName;
    string api = textBox_ApiUrl.Text.Trim();
    // 業(yè)務(wù)參數(shù)：上位機(jī)設(shè)備信息
    var param = new Dictionary<string, string>()
    {
        {"DeviceId", "MACHINE_001"},
        {"Station", "裝配工位3"},
        {"UploadTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}
    };
    // 進(jìn)度回調(diào)（UI線程安全，Invoke更新控件）
    void ProgressUpdate(long curr, long total)
    {
        double percent = curr * 100.0 / total;
        this.Invoke(new Action(() =>
        {
            progressBar1.Maximum = (int)total / 1024; // KB單位
            progressBar1.Value = (int)curr / 1024;
            label_ProgressText.Text = $"已上傳 {curr / 1024}KB / {total / 1024}KB  {percent:F1}%";
        }));
    }
    try
    {
        string result = await HttpFileUploadHelper.UploadSingleFileAsync(api, filePath, param, ProgressUpdate);
        MessageBox.Show($"上傳成功！服務(wù)端返回：\n{result}");
    }
    catch (Exception ex)
    {
        MessageBox.Show($"上傳失敗：{ex.Message}");
    }
}
// 多選文件打包ZIP上傳
private async void button_SelectMultiZip_Click(object sender, EventArgs e)
{
    using var dialog = new OpenFileDialog
    {
        Multiselect = true,
        Filter = "所有文件|*.*"
    };
    if (dialog.ShowDialog() != DialogResult.OK) return;
    List<string> files = dialog.FileNames.ToList();
    string api = textBox_ApiUrl.Text.Trim();
    var param = new Dictionary<string, string>() { {"DeviceId", "MACHINE_001"} };
    void ProgressUpdate(long curr, long total)
    {
        double percent = curr * 100.0 / total;
        this.Invoke(new Action(() =>
        {
            progressBar1.Maximum = (int)total / 1024;
            progressBar1.Value = (int)curr / 1024;
            label_ProgressText.Text = $"壓縮包上傳進(jìn)度 {percent:F1}%";
        }));
    }
    try
    {
        string res = await HttpFileUploadHelper.UploadFilesAsZipAsync(api, files, null, param, ProgressUpdate);
        MessageBox.Show($"打包上傳完成：{res}");
    }
    catch (Exception ex)
    {
        MessageBox.Show($"打包上傳異常：{ex.Message}");
    }
}

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using System;
using System.IO;
using System.IO.Compression;
namespace UploadServer.Controllers
{
    [ApiController]
    [Route("api/[controller]")]
    public class FileUploadController : ControllerBase
    {
        // 文件根存儲(chǔ)目錄
        private readonly string _saveRoot = Path.Combine(AppContext.BaseDirectory, "UploadFiles");
        public FileUploadController()
        {
            // 不存在自動(dòng)創(chuàng)建目錄
            if (!Directory.Exists(_saveRoot))
                Directory.CreateDirectory(_saveRoot);
        }
        /// <summary>統(tǒng)一上傳接口：接收單文件/zip壓縮包</summary>
        [HttpPost("Upload")]
        public IActionResult Upload([FromForm] UploadModel model)
        {
            // 1. 獲取上位機(jī)傳的業(yè)務(wù)參數(shù)
            string deviceId = model.DeviceId ?? "UnknownDevice";
            string station = model.Station ?? "Default";
            string uploadTime = model.UploadTime ?? DateTime.Now.ToString("yyyyMMddHHmmss");
            if (model.uploadFile == null || model.uploadFile.Length == 0)
                return BadRequest(new { code = -1, msg = "未檢測(cè)到上傳文件" });
            // 按設(shè)備+日期分目錄存儲(chǔ)
            string dateDir = DateTime.Now.ToString("yyyy-MM-dd");
            string targetDir = Path.Combine(_saveRoot, deviceId, dateDir);
            Directory.CreateDirectory(targetDir);
            // 原始文件名，重命名防止覆蓋
            string fileName = Path.GetFileName(model.uploadFile.FileName);
            string saveFullPath = Path.Combine(targetDir, $"{uploadTime}_{fileName}");
            // 保存文件到磁盤
            using var stream = new FileStream(saveFullPath, FileMode.Create);
            model.uploadFile.CopyTo(stream);
            // 2. 如果是zip壓縮包，自動(dòng)解壓到同目錄unzip文件夾
            if (Path.GetExtension(fileName).ToLower() == ".zip")
            {
                string unzipDir = Path.Combine(targetDir, $"unzip_{Path.GetFileNameWithoutExtension(fileName)}");
                Directory.CreateDirectory(unzipDir);
                ZipFile.ExtractToDirectory(saveFullPath, unzipDir, true); // true覆蓋重名
            }
            // 3. 返回成功JSON給上位機(jī)
            return Ok(new
            {
                code = 0,
                msg = "文件接收處理完成",
                data = new
                {
                    DeviceId = deviceId,
                    SavePath = saveFullPath,
                    FileSize = model.uploadFile.Length,
                    IsZip = Path.GetExtension(fileName).ToLower() == ".zip",
                    UnzipFolder = Path.GetDirectoryName(saveFullPath) + $"/unzip_{Path.GetFileNameWithoutExtension(fileName)}"
                }
            });
        }
    }
    /// <summary>接收表單參數(shù)綁定模型</summary>
    public class UploadModel
    {
        public IFormFile uploadFile { get; set; }
        // 上位機(jī)自定義業(yè)務(wù)參數(shù)
        public string DeviceId { get; set; }
        public string Station { get; set; }
        public string UploadTime { get; set; }
    }
}

var builder = WebApplication.CreateBuilder(args);

// 放開文件上傳最大尺寸 100MB
builder.Services.Configure<FormOptions>(options =>
{
    options.MultipartBodyLengthLimit = 100 * 1024 * 1024;
});

builder.Services.AddControllers();
var app = builder.Build();
app.MapControllers();
app.Run("http://localhost:5000");