80 lines
2.5 KiB
C#
80 lines
2.5 KiB
C#
|
using Microsoft.AspNetCore.Http;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Dynamic;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Text.Json;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
|
|||
|
|
namespace YD_AllHeartRates.Commons.Middlewares
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 自定义异常中间件，对于系统异常的处理， 超时异常，异常。
|
|||
|
|
/// 拦截Response输出流，进行统一异常处理
|
|||
|
|
/// </summary>
|
|||
|
|
public class SystemExceptionHandlerderMiddleware
|
|||
|
|
{
|
|||
|
|
private readonly RequestDelegate _next;
|
|||
|
|
|
|||
|
|
public SystemExceptionHandlerderMiddleware(RequestDelegate next)
|
|||
|
|
{
|
|||
|
|
this._next = next;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 执行异常处理(执行action无法拦截的异常)
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="httpContext"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task Invoke(HttpContext httpContext)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
// 1、执行下一个中间件
|
|||
|
|
await _next(httpContext);
|
|||
|
|
|
|||
|
|
/* var statusCode = httpContext.Response.StatusCode;
|
|||
|
|
var msg = "";
|
|||
|
|
if (statusCode == 401)
|
|||
|
|
{
|
|||
|
|
msg = "未授权";
|
|||
|
|
}
|
|||
|
|
else if (statusCode == 404)
|
|||
|
|
{
|
|||
|
|
msg = "未找到服务";
|
|||
|
|
}
|
|||
|
|
else if (statusCode == 502)
|
|||
|
|
{
|
|||
|
|
msg = "请求错误";
|
|||
|
|
}
|
|||
|
|
else if (statusCode != 200)
|
|||
|
|
{
|
|||
|
|
msg = httpContext.Response.Body.ToString();
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrWhiteSpace(msg))
|
|||
|
|
{
|
|||
|
|
await HandleExceptionAsync(httpContext, statusCode, msg);
|
|||
|
|
}*/
|
|||
|
|
}
|
|||
|
|
catch (System.Exception ex)
|
|||
|
|
{
|
|||
|
|
await HandleExceptionAsync(httpContext, httpContext.Response.StatusCode, ex.Message);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private async static Task HandleExceptionAsync(HttpContext context, int statusCode, string msg)
|
|||
|
|
{
|
|||
|
|
context.Response.ContentType = "application/json;charset=utf-8";
|
|||
|
|
|
|||
|
|
// 1、异常结果转换成json格式输出
|
|||
|
|
dynamic warpResult = new ExpandoObject();
|
|||
|
|
warpResult.ErrorCode = "-1";
|
|||
|
|
warpResult.ErrorMsg = msg;
|
|||
|
|
|
|||
|
|
// 2、异常json格式输出
|
|||
|
|
var stream = context.Response.Body;
|
|||
|
|
await JsonSerializer.SerializeAsync(stream, warpResult);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|