HttpGlobalExceptionInvoke.cs 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161
  1. 
  2. using Microsoft.AspNetCore.Http;
  3. using System;
  4. using System.Threading.Tasks;
  5. using TEAMModelOS.SDK.Context.Constant.Common;
  6. using TEAMModelOS.SDK.Context.Exception;
  7. using TEAMModelOS.SDK.Helper.Common.JsonHelper;
  8. namespace TEAMModelOS.SDK.Context.Filter
  9. {
  10. public class HttpGlobalExceptionInvoke
  11. {
  12. private readonly RequestDelegate _next;
  13. /// <summary>
  14. ///
  15. /// </summary>
  16. /// <param name="next"></param>
  17. public HttpGlobalExceptionInvoke(RequestDelegate next)
  18. {
  19. _next = next;
  20. }
  21. /// <summary>
  22. ///
  23. /// </summary>
  24. /// <param name="context"></param>
  25. /// <returns></returns>
  26. public async Task Invoke(HttpContext context)
  27. {
  28. int bizCode = 0;
  29. System.Exception exs = null;
  30. bool isCatched = false;
  31. try
  32. {
  33. await _next(context);
  34. }
  35. catch (System.Exception ex) //发生异常
  36. {
  37. exs = ex;
  38. //自定义业务异常
  39. if (ex is BizException)
  40. {
  41. bizCode = ((BizException)ex).code;
  42. if (bizCode == 401 || bizCode == 404 || bizCode == 502 || bizCode == 403)
  43. {
  44. context.Response.StatusCode = bizCode;
  45. }
  46. else {
  47. context.Response.StatusCode = 200;
  48. }
  49. // context.Response.StatusCode = ((BizException)ex).code;
  50. }
  51. //未知异常
  52. else
  53. {
  54. context.Response.StatusCode = 500;
  55. //LogHelper.SetLog(LogLevel.Error, ex);
  56. }
  57. await HandleExceptionAsync(context, bizCode, ex.Message, ex.StackTrace);
  58. isCatched = true;
  59. }
  60. finally
  61. {
  62. if (!isCatched && context.Response.StatusCode != 200)//未捕捉过并且状态码不为200
  63. {
  64. string msg = "";
  65. switch (context.Response.StatusCode)
  66. {
  67. case 401:
  68. msg = "Unauthorized";
  69. break;
  70. case 404:
  71. msg = "Service Not Found";
  72. break;
  73. case 502:
  74. msg = "Request Erro";
  75. break;
  76. case 500:
  77. msg = exs.Message;
  78. break;
  79. case 403:
  80. msg = exs.Message;
  81. break;
  82. default:
  83. msg = "Unknown Error";
  84. break;
  85. }
  86. await HandleExceptionAsync(context, bizCode, msg, exs == null ? "" : exs.StackTrace);
  87. }
  88. }
  89. }
  90. /// <summary>
  91. ///
  92. /// </summary>
  93. /// <param name="context"></param>
  94. ///
  95. ///
  96. /// <param name="statusCode"></param>
  97. /// <param name="msg"></param>
  98. /// <returns></returns>
  99. private static async Task HandleExceptionAsync(HttpContext context, int bizCode, string msg, string devmsg)
  100. {
  101. var data = new ErrorResponse<string>(bizCode, msg, devmsg);
  102. context.Response.ContentType = Constants.CONTENT_TYPE_JSON;
  103. await context.Response.WriteAsync(JsonNetHelper.ToJson(data));
  104. }
  105. /// <summary>
  106. /// 异常信息封装
  107. /// </summary>
  108. ///
  109. public class ErrorResponse<T>
  110. {
  111. public ErrorResponse()
  112. {
  113. error = new ErrorModel<T>();
  114. }
  115. public ErrorResponse(string message)
  116. {
  117. error = new ErrorModel<T>
  118. {
  119. message = message,
  120. devmsg = message
  121. };
  122. }
  123. public ErrorResponse(int code, string message)
  124. {
  125. error = new ErrorModel<T>
  126. {
  127. message = message,
  128. devmsg = message,
  129. code = code
  130. };
  131. }
  132. public ErrorResponse(int code, string message, string devMessage)
  133. {
  134. error = new ErrorModel<T>
  135. {
  136. message = message,
  137. devmsg = message,
  138. code = code
  139. };
  140. error.devmsg = devMessage;
  141. }
  142. public string jsonrpc { get; set; } = "2.0";
  143. public double id { get; set; } = 1;
  144. private object result { get; set; } = null;
  145. public ErrorModel<T> error { get; set; } = null;
  146. }
  147. }
  148. public class ErrorModel<E>
  149. {
  150. public long responseTime = DateTime.Now.Ticks;
  151. public float code { get; set; } = 1;
  152. public string message { get; set; }
  153. public string devmsg { get; set; }
  154. public E data { get; set; }
  155. }
  156. }