三元财务API

HttpMethods.cs 22KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594
  1. using System;
  2. using System.Collections;
  3. using System.Collections.Generic;
  4. using System.IO;
  5. using System.Net;
  6. using System.Net.Http;
  7. using System.Net.Security;
  8. using System.Security.Cryptography.X509Certificates;
  9. using System.Text;
  10. namespace CallCenter.Utility
  11. {
  12. public class HttpMethods
  13. {
  14. #region POST
  15. /// <summary>
  16. /// HTTP POST方式请求数据
  17. /// </summary>
  18. /// <param name="url">URL.</param>
  19. /// <param name="param">POST的数据</param>
  20. /// <returns></returns>
  21. public static string HttpPost(string url, string param = null)
  22. {
  23. HttpWebRequest request;
  24. //如果是发送HTTPS请求
  25. if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
  26. {
  27. ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
  28. request = WebRequest.Create(url) as HttpWebRequest;
  29. request.ProtocolVersion = HttpVersion.Version10;
  30. }
  31. else
  32. {
  33. request = WebRequest.Create(url) as HttpWebRequest;
  34. }
  35. request.Method = "POST";
  36. request.ContentType = "application/x-www-form-urlencoded";
  37. request.Accept = "*/*";
  38. request.Timeout = 15000;
  39. request.AllowAutoRedirect = false;
  40. StreamWriter requestStream = null;
  41. WebResponse response = null;
  42. string responseStr = null;
  43. try
  44. {
  45. requestStream = new StreamWriter(request.GetRequestStream());
  46. requestStream.Write(param);
  47. requestStream.Close();
  48. response = request.GetResponse();
  49. if (response != null)
  50. {
  51. StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
  52. responseStr = reader.ReadToEnd();
  53. reader.Close();
  54. }
  55. }
  56. catch (Exception)
  57. {
  58. throw;
  59. }
  60. finally
  61. {
  62. request = null;
  63. requestStream = null;
  64. response = null;
  65. }
  66. return responseStr;
  67. }
  68. /// <summary>
  69. /// HTTP POST方式带头部请求数据
  70. /// </summary>
  71. /// <param name="url"></param>
  72. /// <param name="whc">头部</param>
  73. /// <param name="param"></param>
  74. /// <returns></returns>
  75. public static string HttpPost(string url, WebHeaderCollection whc, string param = null)
  76. {
  77. HttpWebRequest request;
  78. //如果是发送HTTPS请求
  79. if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
  80. {
  81. ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
  82. request = WebRequest.Create(url) as HttpWebRequest;
  83. request.ProtocolVersion = HttpVersion.Version10;
  84. }
  85. else
  86. {
  87. request = WebRequest.Create(url) as HttpWebRequest;
  88. }
  89. request.Method = "POST";
  90. //request.ContentType = "application/x-www-form-urlencoded";
  91. request.ContentType = "application/json";
  92. request.Accept = "*/*";
  93. request.Timeout = 15000;
  94. request.AllowAutoRedirect = false;
  95. request.Headers.Add(whc);
  96. StreamWriter requestStream = null;
  97. WebResponse response = null;
  98. string responseStr = null;
  99. try
  100. {
  101. requestStream = new StreamWriter(request.GetRequestStream());
  102. requestStream.Write(param);
  103. requestStream.Close();
  104. response = request.GetResponse();
  105. if (response != null)
  106. {
  107. StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
  108. responseStr = reader.ReadToEnd();
  109. reader.Close();
  110. }
  111. }
  112. catch (Exception)
  113. {
  114. throw;
  115. }
  116. finally
  117. {
  118. request = null;
  119. requestStream = null;
  120. response = null;
  121. }
  122. return responseStr;
  123. }
  124. private static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors)
  125. {
  126. return true; //总是接受
  127. }
  128. public static string BuildRequest(string strUrl, Dictionary<string, string> dicPara, string fileName)
  129. {
  130. string contentType = "image/jpeg";
  131. //待请求参数数组
  132. FileStream Pic = new FileStream(fileName, FileMode.Open, FileAccess.Read, FileShare.ReadWrite);
  133. byte[] PicByte = new byte[Pic.Length];
  134. Pic.Read(PicByte, 0, PicByte.Length);
  135. int lengthFile = PicByte.Length;
  136. //构造请求地址
  137. //设置HttpWebRequest基本信息
  138. HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(strUrl);
  139. //设置请求方式:get、post
  140. request.Method = "POST";
  141. //设置boundaryValue
  142. string boundaryValue = DateTime.Now.Ticks.ToString("x");
  143. string boundary = "--" + boundaryValue;
  144. request.ContentType = "\r\nmultipart/form-data; boundary=" + boundaryValue;
  145. //设置KeepAlive
  146. request.KeepAlive = true;
  147. //设置请求数据,拼接成字符串
  148. StringBuilder sbHtml = new StringBuilder();
  149. foreach (KeyValuePair<string, string> key in dicPara)
  150. {
  151. sbHtml.Append(boundary + "\r\nContent-Disposition: form-data; name=\"" + key.Key + "\"\r\n\r\n" + key.Value + "\r\n");
  152. }
  153. sbHtml.Append(boundary + "\r\nContent-Disposition: form-data; name=\"pic\"; filename=\"");
  154. sbHtml.Append(fileName);
  155. sbHtml.Append("\"\r\nContent-Type: " + contentType + "\r\n\r\n");
  156. string postHeader = sbHtml.ToString();
  157. //将请求数据字符串类型根据编码格式转换成字节流
  158. Encoding code = Encoding.GetEncoding("UTF-8");
  159. byte[] postHeaderBytes = code.GetBytes(postHeader);
  160. byte[] boundayBytes = Encoding.ASCII.GetBytes("\r\n" + boundary + "--\r\n");
  161. //设置长度
  162. long length = postHeaderBytes.Length + lengthFile + boundayBytes.Length;
  163. request.ContentLength = length;
  164. //请求远程HTTP
  165. Stream requestStream = request.GetRequestStream();
  166. Stream myStream = null;
  167. try
  168. {
  169. //发送数据请求服务器
  170. requestStream.Write(postHeaderBytes, 0, postHeaderBytes.Length);
  171. requestStream.Write(PicByte, 0, lengthFile);
  172. requestStream.Write(boundayBytes, 0, boundayBytes.Length);
  173. HttpWebResponse HttpWResp = (HttpWebResponse)request.GetResponse();
  174. myStream = HttpWResp.GetResponseStream();
  175. }
  176. catch (WebException e)
  177. {
  178. //LogResult(e.Message);
  179. return "";
  180. }
  181. finally
  182. {
  183. if (requestStream != null)
  184. {
  185. requestStream.Close();
  186. }
  187. }
  188. //读取处理结果
  189. StreamReader reader = new StreamReader(myStream, code);
  190. StringBuilder responseData = new StringBuilder();
  191. String line;
  192. while ((line = reader.ReadLine()) != null)
  193. {
  194. responseData.Append(line);
  195. }
  196. myStream.Close();
  197. Pic.Close();
  198. return responseData.ToString();
  199. }
  200. #endregion
  201. #region Put
  202. /// <summary>
  203. /// HTTP Put方式请求数据.
  204. /// </summary>
  205. /// <param name="url">URL.</param>
  206. /// <returns></returns>
  207. public static string HttpPut(string url, string param = null)
  208. {
  209. HttpWebRequest request;
  210. //如果是发送HTTPS请求
  211. if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
  212. {
  213. ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
  214. request = WebRequest.Create(url) as HttpWebRequest;
  215. request.ProtocolVersion = HttpVersion.Version10;
  216. }
  217. else
  218. {
  219. request = WebRequest.Create(url) as HttpWebRequest;
  220. }
  221. request.Method = "PUT";
  222. request.ContentType = "application/x-www-form-urlencoded";
  223. request.Accept = "*/*";
  224. request.Timeout = 15000;
  225. request.AllowAutoRedirect = false;
  226. StreamWriter requestStream = null;
  227. WebResponse response = null;
  228. string responseStr = null;
  229. try
  230. {
  231. requestStream = new StreamWriter(request.GetRequestStream());
  232. requestStream.Write(param);
  233. requestStream.Close();
  234. response = request.GetResponse();
  235. if (response != null)
  236. {
  237. StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
  238. responseStr = reader.ReadToEnd();
  239. reader.Close();
  240. }
  241. }
  242. catch (Exception)
  243. {
  244. throw;
  245. }
  246. finally
  247. {
  248. request = null;
  249. requestStream = null;
  250. response = null;
  251. }
  252. return responseStr;
  253. }
  254. #endregion
  255. #region Delete
  256. /// <summary>
  257. /// HTTP Delete方式请求数据.
  258. /// </summary>
  259. /// <param name="url">URL.</param>
  260. /// <returns></returns>
  261. public static string HttpDelete(string url, string param = null)
  262. {
  263. HttpWebRequest request;
  264. //如果是发送HTTPS请求
  265. if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
  266. {
  267. ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
  268. request = WebRequest.Create(url) as HttpWebRequest;
  269. request.ProtocolVersion = HttpVersion.Version10;
  270. }
  271. else
  272. {
  273. request = WebRequest.Create(url) as HttpWebRequest;
  274. }
  275. request.Method = "Delete";
  276. request.ContentType = "application/x-www-form-urlencoded";
  277. request.Accept = "*/*";
  278. request.Timeout = 15000;
  279. request.AllowAutoRedirect = false;
  280. StreamWriter requestStream = null;
  281. WebResponse response = null;
  282. string responseStr = null;
  283. try
  284. {
  285. requestStream = new StreamWriter(request.GetRequestStream());
  286. requestStream.Write(param);
  287. requestStream.Close();
  288. response = request.GetResponse();
  289. if (response != null)
  290. {
  291. StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
  292. responseStr = reader.ReadToEnd();
  293. reader.Close();
  294. }
  295. }
  296. catch (Exception)
  297. {
  298. throw;
  299. }
  300. return responseStr;
  301. }
  302. #endregion
  303. #region Get
  304. /// <summary>
  305. /// HTTP GET方式请求数据.
  306. /// </summary>
  307. /// <param name="url">URL.</param>
  308. /// <returns></returns>
  309. public static string HttpGet(string url, Hashtable headht = null)
  310. {
  311. HttpWebRequest request;
  312. //如果是发送HTTPS请求
  313. if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
  314. {
  315. ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
  316. request = WebRequest.Create(url) as HttpWebRequest;
  317. request.ProtocolVersion = HttpVersion.Version10;
  318. }
  319. else
  320. {
  321. request = WebRequest.Create(url) as HttpWebRequest;
  322. }
  323. request.Method = "GET";
  324. //request.ContentType = "application/x-www-form-urlencoded";
  325. request.Accept = "*/*";
  326. request.Timeout = 15000;
  327. request.AllowAutoRedirect = false;
  328. WebResponse response = null;
  329. string responseStr = null;
  330. if (headht != null)
  331. {
  332. foreach (DictionaryEntry item in headht)
  333. {
  334. request.Headers.Add(item.Key.ToString(), item.Value.ToString());
  335. }
  336. }
  337. try
  338. {
  339. response = request.GetResponse();
  340. if (response != null)
  341. {
  342. StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
  343. responseStr = reader.ReadToEnd();
  344. reader.Close();
  345. }
  346. }
  347. catch (Exception)
  348. {
  349. throw;
  350. }
  351. return responseStr;
  352. }
  353. public static string HttpGet(string url, Encoding encodeing, Hashtable headht = null)
  354. {
  355. HttpWebRequest request;
  356. //如果是发送HTTPS请求
  357. if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
  358. {
  359. ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(CheckValidationResult);
  360. request = WebRequest.Create(url) as HttpWebRequest;
  361. request.ProtocolVersion = HttpVersion.Version10;
  362. }
  363. else
  364. {
  365. request = WebRequest.Create(url) as HttpWebRequest;
  366. }
  367. request.Method = "GET";
  368. //request.ContentType = "application/x-www-form-urlencoded";
  369. request.Accept = "*/*";
  370. request.Timeout = 15000;
  371. request.AllowAutoRedirect = false;
  372. WebResponse response = null;
  373. string responseStr = null;
  374. if (headht != null)
  375. {
  376. foreach (DictionaryEntry item in headht)
  377. {
  378. request.Headers.Add(item.Key.ToString(), item.Value.ToString());
  379. }
  380. }
  381. try
  382. {
  383. response = request.GetResponse();
  384. if (response != null)
  385. {
  386. StreamReader reader = new StreamReader(response.GetResponseStream(), encodeing);
  387. responseStr = reader.ReadToEnd();
  388. reader.Close();
  389. }
  390. }
  391. catch (Exception)
  392. {
  393. throw;
  394. }
  395. return responseStr;
  396. }
  397. #endregion
  398. #region Post With Pic
  399. private string HttpPost(string url, IDictionary<object, object> param, string filePath)
  400. {
  401. string boundary = "---------------------------" + DateTime.Now.Ticks.ToString("x");
  402. byte[] boundarybytes = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "\r\n");
  403. HttpWebRequest wr = (HttpWebRequest)WebRequest.Create(url);
  404. wr.ContentType = "multipart/form-data; boundary=" + boundary;
  405. wr.Method = "POST";
  406. wr.KeepAlive = true;
  407. wr.Credentials = System.Net.CredentialCache.DefaultCredentials;
  408. Stream rs = wr.GetRequestStream();
  409. string responseStr = null;
  410. string formdataTemplate = "Content-Disposition: form-data; name=\"{0}\"\r\n\r\n{1}";
  411. foreach (string key in param.Keys)
  412. {
  413. rs.Write(boundarybytes, 0, boundarybytes.Length);
  414. string formitem = string.Format(formdataTemplate, key, param[key]);
  415. byte[] formitembytes = System.Text.Encoding.UTF8.GetBytes(formitem);
  416. rs.Write(formitembytes, 0, formitembytes.Length);
  417. }
  418. rs.Write(boundarybytes, 0, boundarybytes.Length);
  419. string headerTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\nContent-Type: {2}\r\n\r\n";
  420. string header = string.Format(headerTemplate, "pic", filePath, "text/plain");
  421. byte[] headerbytes = System.Text.Encoding.UTF8.GetBytes(header);
  422. rs.Write(headerbytes, 0, headerbytes.Length);
  423. FileStream fileStream = new FileStream(filePath, FileMode.Open, FileAccess.Read);
  424. byte[] buffer = new byte[4096];
  425. int bytesRead = 0;
  426. while ((bytesRead = fileStream.Read(buffer, 0, buffer.Length)) != 0)
  427. {
  428. rs.Write(buffer, 0, bytesRead);
  429. }
  430. fileStream.Close();
  431. byte[] trailer = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "--\r\n");
  432. rs.Write(trailer, 0, trailer.Length);
  433. rs.Close();
  434. WebResponse wresp = null;
  435. try
  436. {
  437. wresp = wr.GetResponse();
  438. Stream stream2 = wresp.GetResponseStream();
  439. StreamReader reader2 = new StreamReader(stream2);
  440. responseStr = reader2.ReadToEnd();
  441. //logger.Debug(string.Format("File uploaded, server response is: {0}", responseStr));
  442. }
  443. catch (Exception ex)
  444. {
  445. //logger.Error("Error uploading file", ex);
  446. if (wresp != null)
  447. {
  448. wresp.Close();
  449. wresp = null;
  450. }
  451. throw;
  452. }
  453. return responseStr;
  454. }
  455. #endregion
  456. #region Post With Pic
  457. /// <summary>
  458. /// HTTP POST方式请求数据(带图片)
  459. /// </summary>
  460. /// <param name="url">URL</param>
  461. /// <param name="param">POST的数据</param>
  462. /// <param name="fileByte">图片</param>
  463. /// <returns></returns>
  464. public static string HttpPost(string url, IDictionary<object, object> param, byte[] fileByte)
  465. {
  466. string boundary = "---------------------------" + DateTime.Now.Ticks.ToString("x");
  467. byte[] boundarybytes = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "\r\n");
  468. HttpWebRequest wr = (HttpWebRequest)WebRequest.Create(url);
  469. wr.ContentType = "multipart/form-data; boundary=" + boundary;
  470. wr.Method = "POST";
  471. wr.KeepAlive = true;
  472. wr.Credentials = System.Net.CredentialCache.DefaultCredentials;
  473. Stream rs = wr.GetRequestStream();
  474. string responseStr = null;
  475. string formdataTemplate = "Content-Disposition: form-data; name=\"{0}\"\r\n\r\n{1}";
  476. foreach (string key in param.Keys)
  477. {
  478. rs.Write(boundarybytes, 0, boundarybytes.Length);
  479. string formitem = string.Format(formdataTemplate, key, param[key]);
  480. byte[] formitembytes = System.Text.Encoding.UTF8.GetBytes(formitem);
  481. rs.Write(formitembytes, 0, formitembytes.Length);
  482. }
  483. rs.Write(boundarybytes, 0, boundarybytes.Length);
  484. string headerTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\nContent-Type: {2}\r\n\r\n";
  485. string header = string.Format(headerTemplate, "pic", fileByte, "text/plain");//image/jpeg
  486. byte[] headerbytes = System.Text.Encoding.UTF8.GetBytes(header);
  487. rs.Write(headerbytes, 0, headerbytes.Length);
  488. rs.Write(fileByte, 0, fileByte.Length);
  489. byte[] trailer = System.Text.Encoding.ASCII.GetBytes("\r\n--" + boundary + "--\r\n");
  490. rs.Write(trailer, 0, trailer.Length);
  491. rs.Close();
  492. WebResponse wresp = null;
  493. try
  494. {
  495. wresp = wr.GetResponse();
  496. Stream stream2 = wresp.GetResponseStream();
  497. StreamReader reader2 = new StreamReader(stream2);
  498. responseStr = reader2.ReadToEnd();
  499. // logger.Error(string.Format("File uploaded, server response is: {0}", responseStr));
  500. }
  501. catch (Exception ex)
  502. {
  503. //logger.Error("Error uploading file", ex);
  504. if (wresp != null)
  505. {
  506. wresp.Close();
  507. wresp = null;
  508. }
  509. throw;
  510. }
  511. return responseStr;
  512. }
  513. #endregion
  514. #region HttpsClient
  515. /// <summary>
  516. /// 创建HttpClient
  517. /// </summary>
  518. /// <returns></returns>
  519. public static HttpClient CreateHttpClient(string url)
  520. {
  521. HttpClient httpclient;
  522. //如果是发送HTTPS请求
  523. if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
  524. {
  525. ServicePointManager.ServerCertificateValidationCallback += (sender, cert, chain, sslPolicyErrors) => true;
  526. httpclient = new HttpClient();
  527. }
  528. else
  529. {
  530. httpclient = new HttpClient();
  531. }
  532. return httpclient;
  533. }
  534. #endregion
  535. }
  536. }