StarEscort/DotNet/Hotfix/Helper/HttpHelper.cs

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Security.Cryptography;
using System.Text;
using Microsoft.Extensions.Primitives;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

namespace ET.Server
{
    public static class HttpHelper
    {
        public static async ETTask<string> GetBodyParameter(HttpListenerContext context)
        {
            return await new StreamReader(context.Request.InputStream).ReadToEndAsync();
        }

        public static void Response(HttpListenerContext context, object response)
        {
            byte[] bytes = JsonHelper.ToJson(response).ToUtf8();
            context.Response.StatusCode = 200;
            context.Response.ContentEncoding = Encoding.UTF8;
            context.Response.ContentLength64 = bytes.Length;
            context.Response.OutputStream.Write(bytes, 0, bytes.Length);
        }

        /// <summary>
        /// post请求抖音接口
        /// </summary>
        /// <param name="url"></param>
        /// <param name="heads"></param>
        /// <param name="param"></param>
        /// <returns></returns>
        public static string PostRequestByDouyin(string url, Dictionary<string, string> heads, JObject param)
        {
            if (string.IsNullOrEmpty(url) || param is not { Count: > 0 })
            {
                return null;
            }

            using HttpClient httpClient = new HttpClient();
            httpClient.DefaultRequestHeaders.Accept.TryParseAdd("application/json");
            // 设置请求头
            if (heads is { Count: >= 0 })
            {
                foreach (var head in heads)
                {
                    httpClient.DefaultRequestHeaders.Add(head.Key, head.Value);
                }
            }

            // post
            HttpContent content = new StringContent(JsonConvert.SerializeObject(param), Encoding.UTF8, "application/json");
            // response
            HttpResponseMessage response = httpClient.PostAsync(new Uri(url), content).Result;

            if (response.IsSuccessStatusCode)
            {
                return response.Content.ReadAsStringAsync().Result;
            }

            string statusCode = response.StatusCode.ToString();
            Log.Debug($"http请求错误...statusCode:{statusCode}, url:{url}");
            return null;
        }

        /// <summary>
        /// get请求抖音接口
        /// </summary>
        /// <param name="baseUrl"></param>
        /// <param name="heads"></param>
        /// <param name="param"></param>
        /// <returns></returns>
        public static string GetRequestByDouyin(string baseUrl, Dictionary<string, string> heads, Dictionary<string, string> param)
        {
            if (string.IsNullOrEmpty(baseUrl) || param is not { Count: > 0 })
            {
                return null;
            }

            using HttpClient httpClient = new HttpClient();
            httpClient.DefaultRequestHeaders.Accept.TryParseAdd("application/json");
            // 设置请求头
            if (heads is { Count: >= 0 })
            {
                foreach (var head in heads)
                {
                    httpClient.DefaultRequestHeaders.Add(head.Key, head.Value);
                }
            }

            StringBuilder url = new StringBuilder(baseUrl);

            if (param is { Count: >= 0 })
            {
                url.Append('?');

                List<string> keyList = new List<string>(param.Keys);

                for (int i = 0; i < param.Count; i++)
                {
                    url.Append(keyList[i]).Append('=').Append(param[keyList[i]]);

                    if (i < param.Count)
                    {
                        url.Append('&');
                    }
                }
            }

            HttpResponseMessage response = httpClient.GetAsync(new Uri(url.ToString())).Result;

            if (response.IsSuccessStatusCode)
            {
                return response.Content.ReadAsStringAsync().Result;
            }

            string statusCode = response.StatusCode.ToString();
            Log.Debug($"http请求错误...statusCode:{statusCode}, url:{url}");
            return null;
        }

        /// <summary>
        /// 签名验证
        /// </summary>
        /// <param name="header"> = {
        ///                             "x-nonce-str": "123456",
        ///                             "x-timestamp": "456789",
        ///                             "x-roomid":    "268",
        ///                             "x-msg-type":  "live_gift",
        ///                         } </param>
        /// <param name="bodyStr"> = "abc123你好"</param>
        /// <param name="secret"> = "oumuamua410"</param>
        /// <returns>PDcKhdlsrKEJif6uMKD2dw==</returns>
        public static string Signature(Dictionary<string, string> header, string bodyStr, string secret)
        {
            List<string> keyList = new List<string>(4);
            keyList.AddRange(header.Select(keyValuePair => keyValuePair.Key));
            keyList.Sort();
            List<string> kvList = new List<string>(4);
            kvList.AddRange(keyList.Select(key => key + "=" + header[key]));
            string urlParams = string.Join("&", kvList);
            string rawData = urlParams + bodyStr + secret;
            byte[] hashBytes = MD5.HashData(Encoding.UTF8.GetBytes(rawData));
            return Convert.ToBase64String(hashBytes);
        }
    }
}