STATION_COLLECT/Common/HttpClients/HttpPost.cs

using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using System.Text;

namespace AmrControl.Common.HttpClients
{
    /// <summary>
    /// post请求客户端
    /// </summary>
    public class HttpPost : BaseHttpClient
    {
        /// <summary>
        /// 设置传输类型，请在请求时注意类型，
        /// </summary>
        private MediaType mediaType = MediaType.APPLICATION_JSON_VALUE;

        public HttpPost(HttpClient httpClient, string baseUri) : base(httpClient, baseUri)
        {
        }

        public void setMediaType(MediaType type)
        {
            this.mediaType = type;
        }

        protected override HttpMethod getMethod()
        {
            return HttpMethod.Post;
        }

        protected override HttpContent? handleData<T>(T data)
        {
            if(mediaType == MediaType.APPLICATION_JSON_VALUE)
            {
                //请求内容在请求体中时使用
                return new StringContent(JsonConvert.SerializeObject(data, new IsoDateTimeConverter() { DateTimeFormat = "yyyy-MM-dd HH:mm:ss" }), Encoding.UTF8, "application/json");
            } else
            {
                return new FormUrlEncodedContent(convertObj2Dict(data));
            }
        }
        /// <summary>
        /// 下载文件
        /// </summary>
        /// <param name="url"></param>
        /// <param name="filePath"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public HttpRespResult downloadFile<T>(string url, string filePath, T data)
        {
            return downloadFile(url, filePath, new(), data);
        }
        /// <summary>
        /// 下载文件
        /// </summary>
        /// <param name="url"></param>
        /// <param name="filePath"></param>
        /// <param name="headers"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public HttpRespResult downloadFile<T>(string url, string filePath, Dictionary<string, string> headers, T data)
        {
            setMediaType(MediaType.APPLICATION_FORM_URLENCODED_VALUE);
            var response = _httpClient.SendAsync(createRequest(reHandleUrl(url, data), headers, getMethod(), handleData(data))).Result;
            using var fs = new FileStream(filePath, FileMode.OpenOrCreate, FileAccess.Write);
            response.Content.CopyToAsync(fs);
            return handleResult(response, filePath);
        }
        /// <summary>
        /// 下载文件
        /// </summary>
        /// <param name="url"></param>
        /// <param name="filePath"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public HttpRespResult downloadFileForJson<T>(string url, string filePath, T data)
        {
            return downloadFileForJson(url, filePath, new(), data);
        }
        /// <summary>
        /// 下载文件
        /// </summary>
        /// <param name="url"></param>
        /// <param name="filePath"></param>
        /// <param name="headers"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public HttpRespResult downloadFileForJson<T>(string url, string filePath, Dictionary<string, string> headers, T data)
        {
            setMediaType(MediaType.APPLICATION_JSON_VALUE);
            var response = _httpClient.SendAsync(createRequest(reHandleUrl(url, data), headers, getMethod(), handleData(data))).Result;
            using var fs = new FileStream(filePath, FileMode.OpenOrCreate, FileAccess.Write);
            response.Content.CopyToAsync(fs);
            return handleResult(response, filePath);
        }
        /// <summary>
        /// 上传文件
        /// </summary>
        /// <param name="url"></param>
        /// <param name="data"></param>
        /// <param name="filePath"></param>
        /// <returns></returns>
        public HttpRespResult uploadFile<T>(string url, T? data, string filePath)
        {
            if (string.IsNullOrEmpty(filePath))
            {
                return sendRequest(url, data);
            }
            return uploadFile(url, new(), data, filePath);
        }
        /// <summary>
        /// 上传文件
        /// </summary>
        /// <param name="url"></param>
        /// <param name="headers"></param>
        /// <param name="data"></param>
        /// <param name="filePath"></param>
        /// <returns></returns>
        public HttpRespResult uploadFile<T>(string url, Dictionary<string, string> headers, T? data, string filePath)
        {
            if (string.IsNullOrEmpty(filePath))
            {
                return sendRequest(url, headers, data);
            }
            var content = new MultipartFormDataContent();
            if (data != null)
            {
                Dictionary<string, string> dict = convertObj2Dict(data);
                foreach (var item in dict)
                {
                    if (string.IsNullOrEmpty(item.Value) || string.IsNullOrWhiteSpace(item.Value))
                    {
                        continue;
                    }
                    content.Add(new StringContent(item.Value), item.Key);
                }
            }
            content.Add(new ByteArrayContent(System.IO.File.ReadAllBytes(filePath)), "file", filePath.IndexOf("/") > 0 ? filePath.Substring(filePath.LastIndexOf("/")) : filePath);
            setMediaType(MediaType.APPLICATION_FORM_URLENCODED_VALUE);
            var response = _httpClient.SendAsync(createRequest(reHandleUrl(url, data), headers, HttpMethod.Post, content)).Result;
            var rs = response.Content.ReadAsStringAsync().Result;
            return handleResult(response, rs);
        }

    }
}