From 8c6fd742db249ad4cc819cf041eb98d880a3ef73 Mon Sep 17 00:00:00 2001 From: hutongqing <hutongqing@hnkhzn.com> Date: 星期四, 02 一月 2025 15:09:07 +0800 Subject: [PATCH] 1 --- WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs | 71 +++++++++++++++++++++++++---------- 1 files changed, 50 insertions(+), 21 deletions(-) diff --git a/WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs b/WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs index dd89d76..6d22011 100644 --- a/WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs +++ b/WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs @@ -4,6 +4,7 @@ using System.Net.Http.Headers; using System.Text; using System.Threading.Tasks; +using WIDESEAWCS_Core.LogHelper; namespace WIDESEAWCS_Core.Helper { @@ -11,38 +12,49 @@ { public static async Task<string> GetAsync(string serviceAddress, string contentType = "application/json", Dictionary<string, string>? headers = null) { + string result = string.Empty; + DateTime beginDate = DateTime.Now; try { - string result = string.Empty; using HttpClient httpClient = new HttpClient(); httpClient.Timeout = new TimeSpan(0, 0, 60); - foreach (var header in headers) - httpClient.DefaultRequestHeaders.Add(header.Key, header.Value); + if (headers != null) + { + foreach (var header in headers) + httpClient.DefaultRequestHeaders.Add(header.Key, header.Value); + } result = await httpClient.GetAsync(serviceAddress).Result.Content.ReadAsStringAsync(); return result; } catch (Exception e) { - Console.WriteLine(e.Message); + throw new Exception(e.Message); } - return null; + finally + { + Logger.Add(serviceAddress, "", result, beginDate); + } } - public static async Task<string> PostAsync(string serviceAddress, string requestJson = null, string contentType = "application/json", Dictionary<string, string>? headers = null) + public static async Task<string?> PostAsync(string serviceAddress, string requestJson = null, string contentType = "application/json", Dictionary<string, string>? headers = null) { + string result = string.Empty; + DateTime beginDate = DateTime.Now; try { - string result = string.Empty; using (HttpContent httpContent = new StringContent(requestJson)) { httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/json"); using HttpClient httpClient = new HttpClient(); httpClient.Timeout = new TimeSpan(0, 0, 60); - foreach (var header in headers) - httpClient.DefaultRequestHeaders.Add(header.Key, header.Value); + if (headers != null) + { + foreach (var header in headers) + httpClient.DefaultRequestHeaders.Add(header.Key, header.Value); + } result = await httpClient.PostAsync(serviceAddress, httpContent).Result.Content.ReadAsStringAsync(); } @@ -50,45 +62,59 @@ } catch (Exception e) { - Console.WriteLine(e.Message); + throw new Exception(e.Message); } - return null; + finally + { + Logger.Add(serviceAddress, requestJson == null ? "": requestJson, result, beginDate); + } } public static string Get(string serviceAddress, string contentType = "application/json", Dictionary<string, string>? headers = null) { + string result = string.Empty; + DateTime beginDate = DateTime.Now; try { - string result = string.Empty; using HttpClient httpClient = new HttpClient(); httpClient.Timeout = new TimeSpan(0, 0, 60); - foreach (var header in headers) - httpClient.DefaultRequestHeaders.Add(header.Key, header.Value); + if (headers != null) + { + foreach (var header in headers) + httpClient.DefaultRequestHeaders.Add(header.Key, header.Value); + } result = httpClient.GetStringAsync(serviceAddress).Result; return result; } catch (Exception e) { - Console.WriteLine(e.Message); + throw new Exception(e.Message); } - return null; + finally + { + Logger.Add(serviceAddress, "", result, beginDate); + } } public static string Post(string serviceAddress, string requestJson = null, string contentType = "application/json", Dictionary<string, string>? headers = null) { + string result = string.Empty; + DateTime beginDate = DateTime.Now; try { - string result = string.Empty; using (HttpContent httpContent = new StringContent(requestJson)) { httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/json"); using HttpClient httpClient = new HttpClient(); httpClient.Timeout = new TimeSpan(0, 0, 60); - foreach (var header in headers) - httpClient.DefaultRequestHeaders.Add(header.Key, header.Value); + if (headers != null) + { + foreach (var header in headers) + httpClient.DefaultRequestHeaders.Add(header.Key, header.Value); + } result = httpClient.PostAsync(serviceAddress, httpContent).Result.Content.ReadAsStringAsync().Result; } @@ -96,9 +122,12 @@ } catch (Exception e) { - Console.WriteLine(e.Message); + throw new Exception(e.Message); } - return null; + finally + { + Logger.Add(serviceAddress, requestJson == null ? "" : requestJson, result, beginDate); + } } } } -- Gitblit v1.9.3