[WIP] Idea: One Handler rule both Asp.Net and Asp.Net-Core

PaySharp.sln

@@ -17,6 +17,10 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PaySharp.UnitTest", "test\P
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PaySharp.Demo", "sample\PaySharp.Demo\PaySharp.Demo.csproj", "{8A0208C0-7046-44A7-A67F-DA122AB280A3}"
 EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PaySharp.AspNetCore", "src\PaySharp.AspNetCore\PaySharp.AspNetCore.csproj", "{E649A330-1B5C-487B-99F7-208248161B8F}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "PaySharp.AspNet", "src\PaySharp.AspNet\PaySharp.AspNet.csproj", "{D20AC625-43A7-45A1-A111-81C3EDC7F6A5}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -51,6 +55,14 @@ Global
 		{8A0208C0-7046-44A7-A67F-DA122AB280A3}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{8A0208C0-7046-44A7-A67F-DA122AB280A3}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{8A0208C0-7046-44A7-A67F-DA122AB280A3}.Release|Any CPU.Build.0 = Release|Any CPU
+		{E649A330-1B5C-487B-99F7-208248161B8F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{E649A330-1B5C-487B-99F7-208248161B8F}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{E649A330-1B5C-487B-99F7-208248161B8F}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{E649A330-1B5C-487B-99F7-208248161B8F}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D20AC625-43A7-45A1-A111-81C3EDC7F6A5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D20AC625-43A7-45A1-A111-81C3EDC7F6A5}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D20AC625-43A7-45A1-A111-81C3EDC7F6A5}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D20AC625-43A7-45A1-A111-81C3EDC7F6A5}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

src/PaySharp.AspNet/HttpContextKeyValueProvider.cs

@@ -0,0 +1,82 @@
+using PaySharp.Abstractions;
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Web;
+
+namespace PaySharp.AspNetCore
+{
+    /// <summary>
+    /// Asp.Net 的键值提供器
+    /// </summary>
+    public class HttpContextKeyValueProvider : IKeyValueProvider
+    {
+        public HttpContextBase HttpContext { get; }
+
+        public IEnumerable<string> SupportedParts => _supportedParts;
+
+        private IEnumerable<string> _supportedParts = new[] { "QueryString", "Form" };
+
+        public HttpContextKeyValueProvider(HttpContextBase httpContext)
+        {
+            HttpContext = HttpContext;
+        }
+
+        /// <inheritdoc />
+        public byte[] Get()
+        {
+            using (var ms = new MemoryStream())
+            {
+                HttpContext.Request.GetBufferedInputStream().CopyTo(ms);
+                return ms.ToArray();
+            }
+
+        }
+
+        /// <inheritdoc />
+        public IEnumerable<string> GetKeys(string part = null)
+        {
+            var request = HttpContext.Request;
+            var result = new List<string>();
+            if (NullEq(part, "QueryString"))
+            {
+                result.AddRange(request.QueryString.AllKeys);
+
+            }
+            if (NullEq(part, "Form"))
+            {
+                result.AddRange(request.Form.AllKeys);
+            }
+
+            return result.Distinct();
+        }
+
+        /// <inheritdoc />
+        public string GetValue(string key, string part = null)
+        {
+            var request = HttpContext.Request;
+            if (NullEq(part, "QueryString"))
+            {
+                return request.QueryString[key];
+            }
+
+            if (NullEq(part, "Form"))
+            {
+                return request.Form[key];
+            }
+
+            return null;
+        }
+
+
+        private bool NullEq(string val, string compare)
+        {
+            return string.IsNullOrEmpty(val) || string.Equals(val, compare, StringComparison.OrdinalIgnoreCase);
+        }
+        private bool Eq(string str1, string str2)
+        {
+            return string.Equals(str1, str2, StringComparison.OrdinalIgnoreCase);
+        }
+    }
+}

src/PaySharp.AspNet/PaySharp.AspNet.csproj

@@ -0,0 +1,15 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net45</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\PaySharp.Core\PaySharp.Core.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Reference Include="System.Web" />
+  </ItemGroup>
+
+</Project>

src/PaySharp.AspNetCore/HttpContextKeyValueProvider.cs

@@ -0,0 +1,101 @@
+using PaySharp.Abstractions;
+using Microsoft.AspNetCore.Http;
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+
+namespace PaySharp.AspNetCore
+{
+    /// <summary>
+    /// Asp.Net-Core 的键值提供器
+    /// </summary>
+    public class HttpContextKeyValueProvider : IKeyValueProvider
+    {
+        public HttpContext HttpContext { get; }
+
+        public IEnumerable<string> SupportedParts => _supportedParts;
+
+        private IEnumerable<string> _supportedParts = new[] { "QueryString", "Form" };
+
+        public HttpContextKeyValueProvider(IHttpContextAccessor httpContextAccessor)
+        {
+            HttpContext = httpContextAccessor.HttpContext;
+        }
+
+        public HttpContextKeyValueProvider(HttpContext httpContext)
+        {
+            HttpContext = httpContext;
+        }
+
+        /// <inheritdoc />
+        public byte[] Get()
+        {
+            using(var ms = new MemoryStream())
+            {
+                HttpContext.Request.Body.CopyTo(ms);
+                return ms.ToArray();
+            }
+
+        }
+
+        /// <inheritdoc />
+        public IEnumerable<string> GetKeys(string part = null)
+        {
+            var request = HttpContext.Request;
+            var result = new List<string>();
+            if(NullEq(part,"QueryString"))
+            {
+                result.AddRange(request.Query.Keys);
+
+
+            }
+            if(NullEq(part, "Form"))
+            {
+                if (request.HasFormContentType && Eq("POST", request.Method))
+                {
+                    result.AddRange(request.Form.Keys);
+                }
+            }
+
+            return result.Distinct();
+        }
+
+        /// <inheritdoc />
+        public string GetValue(string key, string part = null)
+        {
+            var request = HttpContext.Request;
+            if (NullEq(part, "QueryString"))
+            {
+                if (request.Query.ContainsKey(key))
+                {
+                    return request.Query[key];
+                }
+            }
+
+            if (NullEq(part, "Form"))
+            {
+                if (request.HasFormContentType && Eq("POST", request.Method))
+                {
+                    if (request.Form.ContainsKey(key))
+                    {
+                        return request.Form[key];
+                    }
+                }
+
+            }
+
+            return null;
+        }
+
+
+        private bool NullEq(string val,string compare)
+        {
+            return string.IsNullOrEmpty(val) || string.Equals(val, compare, StringComparison.OrdinalIgnoreCase);
+        }
+        private bool Eq(string str1, string str2)
+        {
+            return string.Equals(str1, str2, StringComparison.OrdinalIgnoreCase);
+        }
+    }
+}

src/PaySharp.AspNetCore/PaySharp.AspNetCore.csproj

@@ -0,0 +1,11 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>netstandard2.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\PaySharp.Core\PaySharp.Core.csproj" />
+  </ItemGroup>
+
+</Project>

src/PaySharp.AspNetCore/ServiceCollectionExtensions.cs

@@ -0,0 +1,48 @@
+using PaySharp.Internal;
+using Microsoft.Extensions.DependencyInjection.Extensions;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using PaySharp.Abstractions;
+using System.ComponentModel;
+using PaySharp.AspNetCore;
+
+namespace Microsoft.Extensions.DependencyInjection
+{
+    /// <summary>
+    /// PaySharp 对 <see cref="IServiceCollection"/> 的扩展方法
+    /// </summary>
+    public static class ServiceCollectionExtensions
+    {
+        [EditorBrowsable(EditorBrowsableState.Never)]//先不要让其他人访问
+        public static IServiceCollection AddPaySharp(this IServiceCollection services)
+        {
+            services = services ?? throw new ArgumentNullException(nameof(services));
+            AddPaySharp(services, null);
+            return services;
+        }
+
+        /// <summary>
+        /// 添加PaySharp相关服务
+        /// </summary>
+        /// <param name="services"></param>
+        /// <param name="buildAction"></param>
+        /// <returns></returns>
+        public static IServiceCollection AddPaySharp(this IServiceCollection services,Action<IGatewayBuilder> buildAction)
+        {
+            services.TryAddSingleton<IGatewayBuilder, GatewayBuilder>();
+            services.TryAddScoped<IKeyValueProvider, HttpContextKeyValueProvider>();
+            services.TryAddScoped(svcs =>
+            {
+                var builder = svcs.GetRequiredService<IGatewayBuilder>();
+                if (builder != null)
+                {
+                    buildAction(builder);
+                }
+                return builder.Build();
+            });
+
+            return services;
+        }
+    }
+}

src/PaySharp.Core/Abstractions/HubOrder.cs

@@ -0,0 +1,61 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace PaySharp.Abstractions
+{
+    /// <summary>
+    /// 通用的处理数据
+    /// </summary>
+    public class HubOrder
+    {
+        /// <summary>
+        /// 支付机构订单Id
+        /// </summary>
+        public virtual string GatewayOrderId { get; set; }
+
+        /// <summary>
+        /// 业务逻辑的订单Id
+        /// </summary>
+        public virtual string BusinessOrderId { get; set; }
+
+        /// <summary>
+        /// 支付机构此次处理的时间
+        /// </summary>
+        public virtual DateTimeOffset ProcessTime { get; set; }
+
+        /// <summary>
+        /// 支付处理器给的类型
+        /// </summary>
+        /// <remarks>可以利用此值决定 <see cref="RawData"/>的类型</remarks>
+        public virtual string GatewayType { get; set; }
+
+        /// <summary>
+        /// 原本的数据
+        /// </summary>
+        public virtual object RawData { get; set; }
+
+        /// <summary>
+        /// 状态， 当为 null 时，为未知
+        /// </summary>
+        public virtual HubHandlerDataStatus? Status { get; set; }
+    }
+
+    /// <summary>
+    /// 支付数据状态
+    /// </summary>
+    public enum HubHandlerDataStatus
+    {
+        /// <summary>
+        /// 支付成功
+        /// </summary>
+        Success,
+
+        /// <summary>
+        /// 支付失败
+        /// </summary>
+        Fail
+    }
+}

src/PaySharp.Core/Abstractions/IGatewayBuilder.cs

@@ -0,0 +1,27 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace PaySharp.Abstractions
+{
+    /// <summary>
+    /// 网关提供器的构造器
+    /// </summary>
+    public interface IGatewayBuilder
+    {
+        /// <summary>
+        /// 添加一个命名的网关
+        /// </summary>
+        /// <typeparam name="T">网关的类型</typeparam>
+        /// <param name="name">网关的名字</param>
+        /// <param name="gateway">网关</param>
+        /// <returns></returns>
+        bool TryAdd<T>(string name,T gateway) where T:class;
+
+        /// <summary>
+        /// 返回一个 <see cref="IGatewayBuilder"/> 的实例
+        /// </summary>
+        /// <returns></returns>
+        IGatewayProvider Build();
+    }
+}

src/PaySharp.Core/Abstractions/IGatewayProvider.cs

@@ -0,0 +1,12 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace PaySharp.Abstractions
+{
+    public interface IGatewayProvider
+    {
+        T GetGateway<T>() where T : class;
+        T GetGateway<T>(string gatewayName) where T : class;
+    }
+}