using Microsoft.AspNetCore.Http;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Text;
|
using WIDESEA_Core.Enums;
|
|
namespace WIDESEA_Core.Extensions
|
{
|
public static class HttpContextExtension
|
{
|
|
public static T GetService<T>(this HttpContext context) where T : class
|
{
|
return context.RequestServices.GetService(typeof(T)) as T;
|
}
|
public static string GetUserIp(this HttpContext context)
|
{
|
string realIP = null;
|
string forwarded = null;
|
string remoteIpAddress = context.Connection.RemoteIpAddress.ToString();
|
if (context.Request.Headers.ContainsKey("X-Real-IP"))
|
{
|
realIP = context.Request.Headers["X-Real-IP"].ToString();
|
if (realIP != remoteIpAddress)
|
{
|
remoteIpAddress = realIP;
|
}
|
}
|
if (context.Request.Headers.ContainsKey("X-Forwarded-For"))
|
{
|
forwarded = context.Request.Headers["X-Forwarded-For"].ToString();
|
if (forwarded != remoteIpAddress)
|
{
|
remoteIpAddress = forwarded;
|
}
|
}
|
return remoteIpAddress;
|
}
|
|
/// <summary>
|
/// 获取Request值
|
/// </summary>
|
/// <param name="context"></param>
|
/// <param name="parameter"></param>
|
/// <returns></returns>
|
public static string Request(this HttpContext context, string parameter)
|
{
|
try
|
{
|
if (context == null)
|
return null;
|
if (context.Request.Method == "POST")
|
return context.Request.Form[parameter].ToString();
|
else
|
return context.Request.Query[parameter].ToString();
|
}
|
catch (System.Exception ex)
|
{
|
Console.Write(ex.Message + ex.InnerException);
|
return context.RequestString(parameter);
|
}
|
}
|
|
public static T Request<T>(this HttpContext context, string parameter) where T : class
|
{
|
return context.RequestString(parameter)?.DeserializeObject<T>();
|
}
|
public static string RequestString(this HttpContext context, string parameter)
|
{
|
string requestParam = context.GetRequestParameters();
|
if (string.IsNullOrEmpty(requestParam)) return null;
|
Dictionary<string, object> keyValues = requestParam.DeserializeObject<Dictionary<string, object>>();
|
if (keyValues == null || keyValues.Count == 0) return null;
|
if (keyValues.TryGetValue(parameter, out object value))
|
{
|
if (value == null) return null;
|
if (value.GetType() == typeof(string))
|
{
|
return value?.ToString();
|
}
|
return value.Serialize();
|
}
|
return null;
|
}
|
/// <summary>
|
/// 是否为ajax请求
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public static bool IsAjaxRequest(this HttpContext context)
|
{
|
return context.Request("X-Requested-With") == "XMLHttpRequest"
|
|| (context.Request.Headers != null
|
&& context.Request.Headers["X-Requested-With"] == "XMLHttpRequest");
|
}
|
|
public static UserAgent GetAgentType(this HttpContext context)
|
{
|
string agent = context.Request.Headers["User-Agent"].ToString().ToLower();
|
|
if (agent.Contains("ios") || agent.Contains("ipod") || agent.Contains("ipad"))
|
{
|
return UserAgent.IOS;
|
}
|
if (agent.Contains("windows"))
|
{
|
return UserAgent.Windows;
|
}
|
return UserAgent.Android;
|
|
}
|
|
/// <summary>
|
/// 获取请求的参数
|
/// net core 2.0已增加回读方法 context.Request.EnableRewind();
|
///
|
/// </summary>
|
/// <param name="context"></param>
|
/// <returns></returns>
|
|
public static string GetRequestParameters(this HttpContext context)
|
{
|
if (context.Request.Body == null || !context.Request.Body.CanRead || !context.Request.Body.CanSeek)
|
return null;
|
if (context.Request.Body.Length == 0)
|
return null;
|
if (context.Request.Body.Position > 0)
|
context.Request.Body.Position = 0;
|
|
string prarameters = null;
|
var bodyStream = context.Request.Body;
|
|
using (var buffer = new MemoryStream())
|
{
|
bodyStream.CopyToAsync(buffer);
|
buffer.Position = 0L;
|
bodyStream.Position = 0L;
|
using (var reader = new StreamReader(buffer, Encoding.UTF8))
|
{
|
buffer.Seek(0, SeekOrigin.Begin);
|
prarameters = reader.ReadToEnd();
|
}
|
}
|
return prarameters;
|
}
|
}
|
}
|
