ThirdApisService.cs 2.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. using System;
  2. using System.Collections.Generic;
  3. using System.IO;
  4. using System.Net;
  5. using System.Net.Http;
  6. using System.Net.Http.Headers;
  7. using System.Net.Http.Json;
  8. using System.Text;
  9. using System.Threading.Tasks;
  10. using TEAMModelOS.SDK;
  11. using TEAMModelOS.SDK.Extension;
  12. using TEAMModelOS.SDK.Models;
  13. namespace TEAMModelOS.SDK
  14. {
  15. public class ThirdApisService
  16. {
  17. private readonly HttpClient _httpClient;
  18. public ThirdApisService(HttpClient httpClient)
  19. {
  20. _httpClient = httpClient;
  21. }
  22. public async Task<ScsResult> Post(string url, string Code, string PassKey,string privateKey, Dictionary<string ,object> data)
  23. {
  24. HttpResponseMessage response=null;
  25. try {
  26. string Content = AESHelper.AESEncrypt(data.ToJsonString(), privateKey);
  27. string paramStr = "Code={0}&PassKey={1}&Content={2}";
  28. string sendMsg = string.Format(paramStr, Code, PassKey, Content);
  29. #region 签名 Signature
  30. SortedDictionary<string, string> signatureDC = new SortedDictionary<string, string>();
  31. var timeSpan = (DateTime.Now - new DateTime(1970, 1, 1, 0, 0, 0));
  32. signatureDC["t"] = timeSpan.TotalMilliseconds.ToString();
  33. signatureDC["Code"] = Code;
  34. signatureDC["PassKey"] = PassKey;
  35. string signatureStr = signatureDC.ToJsonString();
  36. string signature = AESHelper.AESEncrypt(signatureStr, privateKey);
  37. #endregion
  38. string result = "";
  39. _httpClient.DefaultRequestHeaders.Add("Signature", signature);
  40. using (var request = new HttpRequestMessage())
  41. {
  42. request.Method = new HttpMethod("POST");
  43. request.RequestUri = new Uri(url);
  44. request.Content = new StringContent(sendMsg);
  45. request.Content.Headers.ContentType = new MediaTypeHeaderValue("application/x-www-form-urlencoded");
  46. response = await _httpClient.SendAsync(request);
  47. result = await response.Content.ReadAsStringAsync();
  48. }
  49. ScsResult scsResult = result.ToObject<ScsResult>();
  50. if (scsResult.result)
  51. {
  52. scsResult.content = AESHelper.AESDecrypt(scsResult.content, privateKey);
  53. }
  54. else {
  55. scsResult.content = AESHelper.AESDecrypt(scsResult.content, privateKey);
  56. }
  57. return scsResult;
  58. } catch (Exception ex ) {
  59. throw new Exception($"{ex.Message}\n{ex.StackTrace}\n{data.ToJsonString()}\n{url}\n {Code}\n{PassKey}\n{privateKey}\n{response?.StatusCode}\n{response?.Content}");
  60. }
  61. }
  62. }
  63. }