优化部分日志和未使用代码

kazelee

2 天以前 74ca5a83f24c53c48ad7e6f5b7739649fb411546

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
 
namespace HH.WCS.Mobox3.DSZSH.util {
    // 尝试优化HttpHelper
    public class WebHelper : IDisposable {
        private readonly HttpClient _httpClient;
        private readonly int _timeoutSeconds;
 
        public WebHelper(int timeoutSeconds = 3) {
            _httpClient = new HttpClient();
            _timeoutSeconds = timeoutSeconds;
            _httpClient.Timeout = TimeSpan.FromSeconds(_timeoutSeconds);
        }
 
        #region 异步方法
        public async Task<string> GetAsync(string url, Dictionary<string, string> headers = null) {
            try {
                using (var request = new HttpRequestMessage(HttpMethod.Get, url)) {
                    AddHeaders(request, headers);
 
                    var response = await _httpClient.SendAsync(request);
                    response.EnsureSuccessStatusCode();
 
                    return await response.Content.ReadAsStringAsync();
                }
            }
            catch (Exception e) {
                LogHelper.Info($"GET request failed: {e.Message}", "API");
                return string.Empty;
            }
        }
 
        public async Task<string> PostAsync(string url, string content, string contentType = "application/json", Dictionary<string, string> headers = null) {
            try {
                using (var request = new HttpRequestMessage(HttpMethod.Post, url)) {
                    AddHeaders(request, headers);
 
                    request.Content = new StringContent(content, Encoding.UTF8, contentType);
                    var response = await _httpClient.SendAsync(request);
                    response.EnsureSuccessStatusCode();
 
                    return await response.Content.ReadAsStringAsync();
                }
            }
            catch (Exception e) {
                LogHelper.Info($"POST request failed: {e.Message}", "API");
                return string.Empty;
            }
        }
 
        public async Task<string> PutAsync(string url, string content, string contentType = "application/json", Dictionary<string, string> headers = null) {
            try {
                using (var request = new HttpRequestMessage(HttpMethod.Put, url)) {
                    AddHeaders(request, headers);
 
                    request.Content = new StringContent(content, Encoding.UTF8, contentType);
                    var response = await _httpClient.SendAsync(request);
                    response.EnsureSuccessStatusCode();
 
                    return await response.Content.ReadAsStringAsync();
                }
            }
            catch (Exception e) {
                LogHelper.Info($"PUT request failed: {e.Message}", "API");
                return string.Empty;
            }
        }
 
        public async Task<string> DeleteAsync(string url, Dictionary<string, string> headers = null) {
            try {
                using (var request = new HttpRequestMessage(HttpMethod.Delete, url)) {
                    AddHeaders(request, headers);
 
                    var response = await _httpClient.SendAsync(request);
                    response.EnsureSuccessStatusCode();
 
                    return await response.Content.ReadAsStringAsync();
                }
            }
            catch (Exception e) {
                LogHelper.Info($"DELETE request failed: {e.Message}", "API");
                return string.Empty;
            }
        }
        #endregion
 
        #region 同步方法
        public string WebGet(string url, Dictionary<string, string> headers = null) {
            try {
                using (var request = new HttpRequestMessage(HttpMethod.Get, url)) {
                    AddHeaders(request, headers);
 
                    var response = _httpClient.SendAsync(request).GetAwaiter().GetResult();
                    response.EnsureSuccessStatusCode();
 
                    return response.Content.ReadAsStringAsync().GetAwaiter().GetResult();
                }
            }
            catch (Exception e) {
                LogHelper.Info($"GET request failed: {e.Message}", "API");
                return string.Empty;
            }
        }
 
        public string WebPost(string url, string postData, string contentType = "application/json", Dictionary<string, string> headers = null) {
            try {
                using (var request = new HttpRequestMessage(HttpMethod.Post, url)) {
                    AddHeaders(request, headers);
 
                    request.Content = new StringContent(postData, Encoding.UTF8, contentType);
                    var response = _httpClient.SendAsync(request).GetAwaiter().GetResult();
                    response.EnsureSuccessStatusCode();
 
                    return response.Content.ReadAsStringAsync().GetAwaiter().GetResult();
                }
            }
            catch (Exception e) {
                LogHelper.Info($"POST request failed: {e.Message}", "API");
                return string.Empty;
            }
        }
 
        public string WebPut(string url, string putData, string contentType = "application/json", Dictionary<string, string> headers = null) {
            try {
                using (var request = new HttpRequestMessage(HttpMethod.Put, url)) {
                    AddHeaders(request, headers);
 
                    request.Content = new StringContent(putData, Encoding.UTF8, contentType);
                    var response = _httpClient.SendAsync(request).GetAwaiter().GetResult();
                    response.EnsureSuccessStatusCode();
 
                    return response.Content.ReadAsStringAsync().GetAwaiter().GetResult();
                }
            }
            catch (Exception e) {
                LogHelper.Info($"PUT request failed: {e.Message}", "API");
                return string.Empty;
            }
        }
 
        public string WebDelete(string url, Dictionary<string, string> headers = null) {
            try {
                using (var request = new HttpRequestMessage(HttpMethod.Delete, url)) {
                    AddHeaders(request, headers);
 
                    var response = _httpClient.SendAsync(request).GetAwaiter().GetResult();
                    response.EnsureSuccessStatusCode();
 
                    return response.Content.ReadAsStringAsync().GetAwaiter().GetResult();
                }
            }
            catch (Exception e) {
                LogHelper.Info($"DELETE request failed: {e.Message}", "API");
                return string.Empty;
            }
        }
        #endregion
 
        private void AddHeaders(HttpRequestMessage request, Dictionary<string, string> headers) {
            if (headers != null) {
                foreach (var header in headers) {
                    request.Headers.TryAddWithoutValidation(header.Key, header.Value);
                }
            }
        }
 
        public void Dispose() {
            _httpClient?.Dispose();
        }
    }
}