TopUtils.cs 7.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226
  1. using System.Security.Cryptography;
  2. using System.Text;
  3. using System.Text.Json;
  4. using System.Text.Json.Nodes;
  5. using System.Text.Json.Serialization;
  6. namespace Topsdk.Util
  7. {
  8. /// <summary>
  9. /// TOP系统工具类。
  10. /// </summary>
  11. public abstract class TopUtils
  12. {
  13. private static JsonSerializerOptions options = new JsonSerializerOptions()
  14. {
  15. WriteIndented = true,
  16. NumberHandling = JsonNumberHandling.AllowReadingFromString,
  17. Converters = { new DateTimeJsonConverter("yyyy-MM-dd HH:mm:ss") }
  18. };
  19. /// <summary>
  20. /// 给TOP请求签名。
  21. /// </summary>
  22. /// <param name="parameters">所有字符型的TOP请求参数</param>
  23. /// <param name="secret">签名密钥</param>
  24. /// <param name="signMethod">签名方法,可选值:md5, hmac</param>
  25. /// <returns>签名</returns>
  26. public static string SignTopRequest(IDictionary<string, string> parameters, string secret, string signMethod)
  27. {
  28. return SignTopRequestWithBody(parameters, null, secret, signMethod);
  29. }
  30. /// <summary>
  31. /// 给TOP请求签名。
  32. /// </summary>
  33. /// <param name="publicParam"></param>
  34. /// <param name="requestParam"></param>
  35. /// <param name="secret"></param>
  36. /// <param name="signMethod"></param>
  37. /// <returns></returns>
  38. public static string SignTopRequest(IDictionary<string, string> publicParam,IDictionary<string,string> requestParam, string secret, string signMethod)
  39. {
  40. IDictionary<string, string> parameters = new Dictionary<string, string>(publicParam);
  41. foreach (KeyValuePair<string,string> item in requestParam)
  42. {
  43. parameters.Add(item);
  44. }
  45. return SignTopRequest(parameters, secret, signMethod);
  46. }
  47. /// <summary>
  48. /// 给TOP请求签名。
  49. /// </summary>
  50. /// <param name="parameters">所有字符型的TOP请求参数</param>
  51. /// <param name="body">请求主体内容</param>
  52. /// <param name="secret">签名密钥</param>
  53. /// <param name="signMethod">签名方法,可选值:md5, hmac</param>
  54. /// <returns>签名</returns>
  55. public static string SignTopRequestWithBody(IDictionary<string, string> parameters, string body, string secret, string signMethod)
  56. {
  57. // 第一步:把字典按Key的字母顺序排序
  58. IDictionary<string, string> sortedParams = new SortedDictionary<string, string>(parameters, StringComparer.Ordinal);
  59. // 第二步:把所有参数名和参数值串在一起
  60. StringBuilder query = new StringBuilder();
  61. if(Constants.SIGN_METHOD_MD5.Equals(signMethod))
  62. {
  63. query.Append(secret);
  64. }
  65. foreach (KeyValuePair<string, string> kv in sortedParams)
  66. {
  67. if (!string.IsNullOrEmpty(kv.Key) && !string.IsNullOrEmpty(kv.Value))
  68. {
  69. query.Append(kv.Key).Append(kv.Value);
  70. }
  71. }
  72. // 第三步:把请求主体拼接在参数后面
  73. if (!string.IsNullOrEmpty(body))
  74. {
  75. query.Append(body);
  76. }
  77. // 第四步:使用MD5/HMAC加密
  78. byte[] bytes;
  79. if (Constants.SIGN_METHOD_HMAC.Equals(signMethod))
  80. {
  81. HMACMD5 hmac = new HMACMD5(Encoding.UTF8.GetBytes(secret));
  82. bytes = hmac.ComputeHash(Encoding.UTF8.GetBytes(query.ToString()));
  83. }
  84. else if (Constants.SIGN_METHOD_HMAC_SHA256.Equals(signMethod))
  85. {
  86. HMACSHA256 hmac = new HMACSHA256(Encoding.UTF8.GetBytes(secret));
  87. bytes = hmac.ComputeHash(Encoding.UTF8.GetBytes(query.ToString()));
  88. }
  89. else
  90. {
  91. query.Append(secret);
  92. MD5 md5 = MD5.Create();
  93. bytes = md5.ComputeHash(Encoding.UTF8.GetBytes(query.ToString()));
  94. }
  95. // 第五步:把二进制转化为大写的十六进制
  96. StringBuilder result = new StringBuilder();
  97. for (int i = 0; i < bytes.Length; i++)
  98. {
  99. result.Append(bytes[i].ToString("X2"));
  100. }
  101. return result.ToString();
  102. }
  103. /// <summary>
  104. /// 清除字典中值为空的项。
  105. /// </summary>
  106. /// <param name="dict">待清除的字典</param>
  107. /// <returns>清除后的字典</returns>
  108. public static IDictionary<string, T> CleanupDictionary<T>(IDictionary<string, T> dict)
  109. {
  110. IDictionary<string, T> newDict = new Dictionary<string, T>(dict.Count);
  111. foreach (KeyValuePair<string, T> kv in dict)
  112. {
  113. if (kv.Value != null)
  114. {
  115. newDict.Add(kv.Key, kv.Value);
  116. }
  117. }
  118. return newDict;
  119. }
  120. /// <summary>
  121. /// 获取从1970年1月1日到现在的毫秒总数。
  122. /// </summary>
  123. /// <returns>毫秒数</returns>
  124. public static long GetCurrentTimeMillis()
  125. {
  126. return (long)DateTime.UtcNow.Subtract(new DateTime(1970, 1, 1)).TotalMilliseconds;
  127. }
  128. /// <summary>
  129. /// 复杂对象列表转json
  130. /// </summary>
  131. /// <param name="list"></param>
  132. /// <returns></returns>
  133. public static string ConvertStructList(object? list)
  134. {
  135. if (list == null)
  136. {
  137. return "[]";
  138. }
  139. if (list is string)
  140. {
  141. return (string)list;
  142. }
  143. return JsonSerializer.Serialize(list,options);
  144. }
  145. public static string ConvertStruct(object? obj)
  146. {
  147. if (obj == null)
  148. {
  149. return "{}";
  150. }
  151. if (obj is string)
  152. {
  153. return (string)obj;
  154. }
  155. return JsonSerializer.Serialize(obj);
  156. }
  157. public static string ConvertBasicList<T>(IList<T> list)
  158. {
  159. if (list == null)
  160. {
  161. return "";
  162. }
  163. return string.Join(",",list);
  164. }
  165. public static string ConvertBasicType(object? obj)
  166. {
  167. if (obj == null)
  168. {
  169. return "";
  170. }
  171. if (obj is DateTime)
  172. {
  173. return ((DateTime)obj).ToString(Constants.DATE_TIME_FORMAT);
  174. }
  175. if (obj is bool)
  176. {
  177. return ((bool)obj).ToString().ToLower();
  178. }
  179. return obj.ToString();
  180. }
  181. public static T parseResultJson<T>(string jsonStr)
  182. {
  183. try
  184. {
  185. var jsonNode = JsonObject.Parse(jsonStr);
  186. if (jsonNode[Constants.ERROR_RESPONSE] != null)
  187. {
  188. return jsonNode[Constants.ERROR_RESPONSE].Deserialize<T>(options);
  189. }
  190. return jsonNode.Deserialize<T>(options);
  191. }
  192. catch (Exception e)
  193. {
  194. throw new TopException("ApiResult is not json", e);
  195. }
  196. }
  197. }
  198. }