fix ci

.github/workflows/main.yml

@@ -0,0 +1,34 @@
+name: PublishNugetPackage
+
+on: [create]
+
+jobs:
+  build:
+    name: Build Project
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@v1
+    - name: Setup .NET Core
+      uses: actions/setup-dotnet@v1
+      with:
+        dotnet-version: '5.0.100'
+    - name: Build
+      run: dotnet build
+  
+  publish:
+    needs: build
+    name: Publish Project to Nuget
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@v1
+    - name: Setup .NET Core
+      uses: actions/setup-dotnet@v1
+      with:
+        dotnet-version: '5.0.100'
+    - name: Publish
+      run: |
+        version=`git describe --tags`
+        dotnet pack --configuration release -p:PackageVersion=$version
+        dotnet nuget push bin/release/Simcu.SimApi.$version.nupkg -k ${NUGET_APIKEY} -s https://www.nuget.org/api/v2/package
+      env:
+        NUGET_APIKEY: ${{ secrets.NUGET_APIKEY }}

.github/workflows/nuget-publish.yml

@@ -1,24 +0,0 @@
-name: PublishNugetPackage
-
-on:
-  push:
-    tags:
-      - "*"
-
-jobs:
-  publish:
-    name: Publish Project to Nuget
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v1
-      - name: Setup .NET Core
-        uses: actions/setup-dotnet@v1
-        with:
-          dotnet-version: "7.0.100"
-      - name: Publish
-        run: |
-          version=`git describe --tags`
-          dotnet build --configuration release -p:PackageVersion=$version
-          dotnet nuget push bin/release/Simcu.SimApi.$version.nupkg -k ${NUGET_APIKEY} -s https://www.nuget.org/api/v2/package
-        env:
-          NUGET_APIKEY: ${{ secrets.NUGET_APIKEY }}

Attributes/SimApiAuthAttribute.cs

@@ -19,16 +19,13 @@ namespace SimApi.Attributes
         //默认是user登录类型
         public SimApiAuthAttribute()
         {
-            Types = new[]
+            Types = new[] { "user" };
-            {
-                "user"
-            };
         }
 
         //只检测一种用户类型的快捷方式
         public SimApiAuthAttribute(string type)
         {
-            Types = type.Split(",");
+            Types = new[] { type };
         }
 
         //设定特定类型的检测
@@ -40,10 +37,7 @@ namespace SimApi.Attributes
         //只检测一种用户类型的快捷方式
         public SimApiAuthAttribute(string type, string url)
         {
-            Types = new[]
+            Types = new[] { type };
-            {
-                type
-            };
             new HttpPostAttribute(url);
         }
 
@@ -56,7 +50,7 @@ namespace SimApi.Attributes
                 throw new SimApiException(401);
             }
             //检测用户类型
-            if (!Types.Intersect(loginInfo.Type).Any())
+            if (Types.Intersect(loginInfo.Type).Count() == 0)
             {
                 throw new SimApiException(403);
             }

Attributes/SynapseEventAttribute.cs

@@ -1,14 +0,0 @@
-using System;
-
-namespace SimApi.Attributes;
-
-[AttributeUsage(AttributeTargets.Method)]
-public class SynapseEventAttribute : Attribute
-{
-    public string Name { get; }
-
-    public SynapseEventAttribute(string name)
-    {
-        Name = name;
-    }
-}

Attributes/SynapseRpcAttribute.cs

@@ -1,19 +0,0 @@
-using System;
-
-namespace SimApi.Attributes;
-
-[AttributeUsage(AttributeTargets.Method)]
-public class SynapseRpcAttribute : Attribute
-{
-    public string Name { get; }
-
-    public SynapseRpcAttribute()
-    {
-        Name = null;
-    }
-
-    public SynapseRpcAttribute(string name)
-    {
-        Name = name;
-    }
-}

Communications/SimApiBaseRequest.cs

@@ -1,23 +1,20 @@
-namespace SimApi.Communications
+using System;
+namespace SimApi.Communications
 {
     /// <summary>
     /// 只有ID的请求
     /// </summary>
-    public record SimApiIdOnlyRequest(int Id);
+    public class SimApiIdOnlyRequest
-
+    {
-    /// <summary>
+        public int Id { get; set; }
-    /// 只有ID的请求(字符串)
+    }
-    /// </summary>
-    public record SimApiStringIdOnlyRequest(string Id);
-
-    /// <summary>
-    /// 动态类型单字段请求
-    /// </summary>
-    /// <typeparam name="T"></typeparam>
-    public record SimApiOneFieldRequest<T>(T Data);
 
     /// <summary>
     /// 基础分页请求
     /// </summary>
-    public record SimApiBasePageRequest(int Page, int Count);
+    public class SimApiBasePageRequest
+    {
+        public int Page { get; set; }
+        public int Count { get; set; }
+    }
 }

Communications/SimApiBaseResponse.cs

@@ -7,38 +7,82 @@ namespace SimApi.Communications
     /// <summary>
     /// 基础相应
     /// </summary>
-    public record SimApiBaseResponse(int Code = 200, string Message = "成功")
+    public class SimApiBaseResponse
     {
+        /// <summary>
+        /// 错误代码
+        /// </summary>
+        public int Code { get; set; }
+
+        /// <summary>
+        /// 错误描述
+        /// </summary>
+        public string Message { get; set; }
+
         /// <summary>
         /// 默认错误代码对应提示信息
         /// </summary>
-        private static readonly Dictionary<int, string> MsgBox = new()
+        private readonly Dictionary<int, string> MsgBox = new Dictionary<int, string>()
         {
-            {
+            {200, "成功"},
-                200, "成功"
+            {204, "没有数据"},
-            },
+            {400, "参数错误"},
-            {
+            {401, "需要登录"},
-                204, "没有数据"
+            {403, "无权访问"},
-            },
+            {404, "接口不存在"},
-            {
+            {500, "服务器错误"}
-                400, "参数错误"
-            },
-            {
-                401, "需要登录"
-            },
-            {
-                403, "无权访问"
-            },
-            {
-                404, "接口不存在"
-            },
-            {
-                500, "服务器错误"
-            }
         };
 
-        public SimApiBaseResponse(int code) : this(code, MsgBox.ContainsKey(code) ? MsgBox[code] : "未知错误")
+        /// <summary>
+        /// 返回一个成功的空结果
+        /// </summary>
+        public SimApiBaseResponse()
         {
+            SetCode(200);
+        }
+
+
+        /// <summary>
+        /// 返回指定代码的描述
+        /// </summary>
+        /// <param name="code">错误代码</param>
+        public SimApiBaseResponse(int code)
+        {
+            SetCode(code);
+        }
+
+        /// <summary>
+        /// 返回指定代码的结果,并自定义提示信息
+        /// </summary>
+        /// <param name="code">错误代码</param>
+        /// <param name="message">错误信息</param>
+        public SimApiBaseResponse(int code, string message)
+        {
+            SetCodeMsg(code, message);
+        }
+
+        /// <summary>
+        /// 设置响应结果的错误代码
+        /// </summary>
+        /// <param name="code">错误代码</param>
+        public void SetCode(int code)
+        {
+            Code = code;
+            Message = MsgBox.ContainsKey(code) ? MsgBox[code] : "未知错误";
+        }
+
+        /// <summary>
+        /// 设置响应结果的错误代码和错误描述
+        /// </summary>
+        /// <param name="code">错误代码</param>
+        /// <param name="message">错误描述</param>
+        public void SetCodeMsg(int code, string message)
+        {
+            SetCode(code);
+            if (!string.IsNullOrEmpty(message))
+            {
+                Message = message;
+            }
         }
 
         /// <summary>
@@ -51,10 +95,7 @@ namespace SimApi.Communications
             {
                 IgnoreReadOnlyProperties = true,
                 PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
-                Converters =
+                Converters = { new JsonStringEnumConverter() }
-                {
-                    new JsonStringEnumConverter()
-                }
             });
         }
     }
@@ -63,14 +104,29 @@ namespace SimApi.Communications
     /// 动态内容分页
     /// </summary>
     /// <typeparam name="T"></typeparam>
-    public record SimApiBasePageResponse<T>
+    public class SimApiBasePageResponse<T> : SimApiBaseResponse
-    (T List, int Page = 1, int Count = 1, int Total = 1, int Code = 200,
+    {
-        string Message = "成功") : SimApiBaseResponse(Code, Message);
+        /// <summary>
+        /// 动态内容列表
+        /// </summary>
+        public T List { get; set; }
+        //当前页码
+        public int Page { get; set; }
+        //每页条数
+        public int Count { get; set; }
+        //总计条数
+        public int Total { get; set; }
+    }
 
     /// <summary>
     /// 动态Data返回
     /// </summary>
     /// <typeparam name="T"></typeparam>
-    public record SimApiBaseResponse<T>(T Data, int Code = 200, string Message = "成功") : SimApiBaseResponse(Code,
+    public class SimApiBaseResponse<T> : SimApiBaseResponse
-        Message);
+    {
+        /// <summary>
+        /// 动态内容列表
+        /// </summary>
+        public T Data { get; set; }
+    }
 }

Communications/SimApiLoginItem.cs

@@ -1,7 +1,14 @@
-namespace SimApi.Communications
+using System;
+namespace SimApi.Communications
 {
     /// <summary>
     /// 登录信息中间件
     /// </summary>
-    public record SimApiLoginItem(string Id, string[] Type);
+    public class SimApiLoginItem
+    {
+        //登录用户的ID
+        public int Id { get; set; }
+        //登录用户来源
+        public string[] Type { get; set; }
+    }
 }

Configurations/SimApiDocOptions.cs

@@ -1,73 +0,0 @@
-using System;
-using System.Collections.Generic;
-using Swashbuckle.AspNetCore.SwaggerUI;
-
-namespace SimApi.Configs
-{
-    /// <summary>
-    /// 文档组配置
-    /// </summary>
-    public class SimApiDocGroupOption
-    {
-        /// <summary>
-        /// 文档标识
-        /// </summary>
-        public string Id { get; set; }
-
-        /// <summary>
-        /// 文档名称
-        /// </summary>
-        public string Name { get; set; }
-
-        /// <summary>
-        /// 文档描述
-        /// </summary>
-        public string Description { get; set; }
-    }
-
-    /// <summary>
-    /// 授权配置, Type支持 "SimApiAuth","ClientCredentials","Implicit","AuthorizationCode"
-    /// </summary>
-    public class SimApiAuthOption
-    {
-        public string[] Type { get; set; } = new[] {"SimApiAuth"};
-        public string Description { get; set; } = "认证服务器颁发的AccessToken";
-        public string AuthorizationUrl { get; set; }
-        public string TokenUrl { get; set; }
-        public Dictionary<string, string> Scopes { get; set; }
-    }
-
-    /// <summary>
-    /// 文档配置
-    /// </summary>
-    public class SimApiDocOptions
-    {
-        /// <summary>
-        /// 文档组配置
-        /// </summary>
-        public SimApiDocGroupOption[] ApiGroups { get; set; } = new[]
-        {
-            new SimApiDocGroupOption
-            {
-                Id = "api",
-                Name = "Api",
-                Description = "Api接口文档"
-            }
-        };
-
-        /// <summary>
-        /// 授权配置
-        /// </summary>
-        public SimApiAuthOption ApiAuth { get; set; } = new SimApiAuthOption();
-
-        /// <summary>
-        /// 文档页面标题
-        /// </summary>
-        public string DocumentTitle { get; set; } = "API接口文档";
-        
-        /// <summary>
-        /// 接口支持的调用方式
-        /// </summary>
-        public SubmitMethod[] SupportedMethod { get; set; } = new[] {SubmitMethod.Post};
-    }
-}

Configurations/SimApiOptions.cs

@@ -1,93 +0,0 @@
-using System;
-
-namespace SimApi.Configs
-{
-    public class SimApiOptions
-    {
-        /// <summary>
-        /// 启用全部Cors，对于开发前后分离的时候很有用。
-        /// default: true
-        /// </summary>
-        public bool EnableCors { get; set; } = true;
-
-        /// <summary>
-        /// 启用SimapiAuth，一个简单的基于Header Token的认证方式。
-        /// default: false
-        /// </summary>
-        public bool EnableSimApiAuth { get; set; } = false;
-
-        /// <summary>
-        /// 启用在线文档，启用后 访问 /swagger 可以查看对应的api文档。
-        /// default: false
-        /// </summary>
-        public bool EnableSimApiDoc { get; set; } = false;
-
-        /// <summary>
-        /// 启用异常拦截,启用后，所有的异常将被通过json反馈。
-        /// default: true
-        /// </summary>
-        public bool EnableSimApiException { get; set; } = true;
-
-        /// <summary>
-        /// 开启S3兼容的存储系统。
-        /// default: false
-        /// </summary>
-        public bool EnableSimApiStorage { get; set; } = false;
-
-        /// <summary>
-        /// 开启ForwardHeaders,开启后可以透传负载均衡的Headers
-        /// default: true
-        /// </summary>
-        public bool EnableForwardHeaders { get; set; } = true;
-
-        /// <summary>
-        /// 将所有的url都格式化为小写字母
-        /// default: true
-        /// </summary>
-        public bool EnableLowerUrl { get; set; } = true;
-
-        /// <summary>
-        /// 启用格式化的 Console Logger
-        /// default: false
-        /// </summary>
-        public bool EnableLogger { get; set; } = false;
-
-        /// <summary>
-        /// 是否启用Synapse
-        /// </summary>
-        public bool EnableSynapse { get; set; } = false;
-
-
-        /// <summary>
-        /// Swagger文档相关配置，需要启用 EnableSimApiDoc
-        /// </summary>
-        public SimApiDocOptions SimApiDocOptions { get; set; } = new SimApiDocOptions();
-
-        /// <summary>
-        /// S3兼容的存储系统配置，需要启用 EnableSimApiStorage
-        /// </summary>
-        public SimApiStorageOptions SimApiStorageOptions { get; set; } = new SimApiStorageOptions();
-
-        public SimApiSynapseOptions SimApiSynapseOptions { get; set; } = new SimApiSynapseOptions();
-
-        public void ConfigureSimApiSynapse(Action<SimApiSynapseOptions> options = null)
-        {
-            options?.Invoke(SimApiSynapseOptions);
-        }
-
-        public void ConfigureSimApiSynapse(SimApiSynapseOptions options)
-        {
-            SimApiSynapseOptions = options;
-        }
-
-        public void ConfigureSimApiDoc(Action<SimApiDocOptions> options = null)
-        {
-            options?.Invoke(SimApiDocOptions);
-        }
-
-        public void ConfigureSimApiStorage(Action<SimApiStorageOptions> options = null)
-        {
-            options?.Invoke(SimApiStorageOptions);
-        }
-    }
-}

Configurations/SimApiStorageOptions.cs

@@ -1,24 +0,0 @@
-namespace SimApi.Configs
-{
-    public class SimApiStorageOptions
-    {
-        /// <summary>
-        /// S3 服务器入口地址
-        /// </summary>
-        public string Endpoint { get; set; }
-
-        /// <summary>
-        /// S3 服务器文件访问地址
-        /// </summary>
-        public string ServeUrl { get; set; }
-
-        /// <summary>
-        /// S3服务 Bucket
-        /// </summary>
-        public string Bucket { get; set; }
-
-        public string AccessKey { get; set; }
-
-        public string SecretKey { get; set; }
-    }
-}

Configurations/SimApiSynapseOptions.cs

@@ -1,30 +0,0 @@
-namespace SimApi.Configs;
-
-public class SimApiSynapseOptions
-{
-    public string MqHost { get; set; }
-
-    public int MqPort { get; set; }
-
-    public string MqUser { get; set; }
-
-    public string MqPass { get; set; }
-
-    public string MqVHost { get; set; } = "/";
-
-    public string SysName { get; set; }
-
-    public string AppName { get; set; }
-
-    public string AppId { get; set; }
-
-    public int RpcTimeout { get; set; } = 3;
-
-    public ushort EventProcessorNum { get; set; } = 20;
-
-    public ushort RpcProcessorNum { get; set; } = 20;
-
-    public bool DisableEventClient { get; set; } = false;
-
-    public bool DisableRpcClient { get; set; } = false;
-}

Controllers/SimApiBaseController.cs

@@ -29,14 +29,16 @@ namespace SimApi.Controllers
         {
             if (!context.ModelState.IsValid)
             {
-                foreach (var item in context.ModelState.Values.Where(item =>
+                foreach (var item in context.ModelState.Values)
-                             item.ValidationState == ModelValidationState.Invalid))
+                {
+                    if (item.ValidationState == ModelValidationState.Invalid)
                     {
                         Error(400, item.Errors.First().ErrorMessage);
                         break;
                     }
                 }
             }
+        }
 
 
         /// <summary>
@@ -45,7 +47,7 @@ namespace SimApi.Controllers
         /// <param name="code">错误代码</param>
         /// <param name="message">错误描述(若是常规错误,代码可自动带取描述)</param>
         /// <returns></returns>
-        protected static void Error(int code = 500, string message = "")
+        protected static void Error(int code = 500, string message = "服务器错误")
         {
             throw new SimApiException(code, message);
         }
@@ -56,7 +58,7 @@ namespace SimApi.Controllers
         /// <param name="condition">检测条件</param>
         /// <param name="code">错误代码</param>
         /// <param name="message">错误描述</param>
-        protected static void ErrorWhen(bool condition, int code = 500, string message = "")
+        protected static void ErrorWhen(bool condition, int code = 500, string message = "服务器错误")
         {
             if (condition)
             {
@@ -70,7 +72,7 @@ namespace SimApi.Controllers
         /// <param name="condition">检测条件</param>
         /// <param name="code">错误代码</param>
         /// <param name="message">错误描述</param>
-        protected static void ErrorWhenNull(object condition, int code = 404, string message = "")
+        protected static void ErrorWhenNull(object condition, int code = 404, string message = "资源不存在")
         {
             ErrorWhen(condition == null, code, message);
         }
@@ -81,7 +83,9 @@ namespace SimApi.Controllers
         /// <returns></returns>
         protected SimApiBaseResponse<string> UploadFile()
         {
-            return new SimApiBaseResponse<string>(null);
+            return new SimApiBaseResponse<string>();
         }
+
+
     }
 }

Controllers/SimApiCommonController.cs

@@ -6,7 +6,6 @@ using SimApi.Helpers;
 
 namespace SimApi.Controllers
 {
-    [ApiExplorerSettings(GroupName = "api")]
     public class YYCommonController : SimApiBaseController
     {
         private SimApiAuth Auth { get; }
@@ -25,7 +24,9 @@ namespace SimApi.Controllers
         [ApiExplorerSettings(IgnoreApi = true)]
         public SimApiBaseResponse ExceptionHandler(int code)
         {
-            return new SimApiBaseResponse(code);
+            var response = new SimApiBaseResponse();
+            response.SetCode(code);
+            return response;
         }
 
         /// <summary>
@@ -33,10 +34,10 @@ namespace SimApi.Controllers
         /// </summary>
         /// <returns></returns>
         [HttpPost("/auth/check"), SimApiDoc("认证", "检测登陆")]
-        public SimApiBaseResponse<string> CheckLogin()
+        public SimApiBaseResponse<int> CheckLogin()
         {
             ErrorWhenNull(LoginInfo, 401);
-            return new SimApiBaseResponse<string>(LoginInfo.Id);
+            return new SimApiBaseResponse<int> { Data = LoginInfo.Id };
         }
 
         /// <summary>
@@ -52,7 +53,6 @@ namespace SimApi.Controllers
             {
                 token = Request.Headers["Token"];
             }
-
             Auth.Logout(token);
             return new SimApiBaseResponse();
         }

Helpers/SimApiAuth.cs

@@ -23,12 +23,9 @@ namespace SimApi.Helpers
         /// </summary>
         /// <param name="id"></param>
         /// <returns></returns>
-        public string Login(string id, string type = "user", string token = null)
+        public string Login(int id, string type = "user", string token = null)
         {
-            return Login(id, new[]
+            return Login(id, new[] { type }, token);
-            {
-                type
-            }, token);
         }
 
         /// <summary>
@@ -37,10 +34,17 @@ namespace SimApi.Helpers
         /// <param name="id"></param>
         /// <param name="type"></param>
         /// <returns></returns>
-        public string Login(string id, string[] type, string uuid = null)
+        public string Login(int id, string[] type, string uuid = null)
         {
-            uuid ??= Guid.NewGuid().ToString();
+            if (uuid == null)
-            var loginItem = new SimApiLoginItem(id, type);
+            {
+                uuid = Guid.NewGuid().ToString();
+            }
+            var loginItem = new SimApiLoginItem
+            {
+                Id = id,
+                Type = type
+            };
             Cache.SetString(uuid, JsonSerializer.Serialize(loginItem));
             return uuid;
         }
@@ -56,5 +60,6 @@ namespace SimApi.Helpers
                 Cache.Remove(uuid);
             }
         }
+
     }
 }

Helpers/SimApiStorage.cs

@@ -1,103 +0,0 @@
-using System;
-using System.IO;
-using Microsoft.AspNetCore.Http;
-using Minio;
-using Minio.Exceptions;
-using SimApi.Configs;
-
-namespace SimApi.Helpers
-{
-    public class SimApiStorage
-    {
-        private MinioClient Mc { get; }
-
-        public MinioClient Client => Mc;
-
-        private string ServeUrl { get; }
-
-        public string Bucket { get; }
-
-        private IHttpContextAccessor HttpContextAccessor { get; }
-
-        public SimApiStorage(SimApiOptions apiOptions, IHttpContextAccessor httpContextAccessor)
-        {
-            var options = apiOptions.SimApiStorageOptions;
-            HttpContextAccessor = httpContextAccessor;
-            var useSsl = false;
-            string endpoint;
-            if (options.Endpoint.StartsWith("http://"))
-            {
-                endpoint = options.Endpoint.Replace("http://", string.Empty);
-            }
-            else if (options.Endpoint.StartsWith("https://"))
-            {
-                endpoint = options.Endpoint.Replace("https://", string.Empty);
-                useSsl = true;
-            }
-            else
-            {
-                throw new Exception("SimApiStorage: Error Endpoint");
-            }
-
-            ServeUrl = options.ServeUrl;
-            Bucket = options.Bucket;
-            var mcb = new MinioClient().WithEndpoint(endpoint)
-                .WithCredentials(options.AccessKey, options.SecretKey);
-            if (useSsl)
-            {
-                mcb = mcb.WithSSL();
-            }
-            Mc = mcb.Build();
-
-            var found = Mc.BucketExistsAsync(new BucketExistsArgs().WithBucket(Bucket)).Result;
-            if (!found)
-            {
-                Mc.MakeBucketAsync(new MakeBucketArgs().WithBucket(Bucket)).Wait();
-            }
-        }
-
-        /// <summary>
-        /// 获取上传的URL
-        /// </summary>
-        /// <param name="path"></param>
-        /// <param name="expire"></param>
-        /// <returns></returns>
-        public string GetUploadUrl(string path, int expire = 7200)
-        {
-            return Mc.PresignedPutObjectAsync(new PresignedPutObjectArgs().WithBucket(Bucket)
-                .WithObject(path).WithExpiry(expire)).Result;
-        }
-
-        /// <summary>
-        /// 获取下载的URL
-        /// </summary>
-        /// <param name="path"></param>
-        /// <param name="expire"></param>
-        /// <returns></returns>
-        public string GetDownloadUrl(string path, int expire = 600)
-        {
-            return Mc.PresignedGetObjectAsync(new PresignedGetObjectArgs().WithBucket(Bucket).WithObject(path)
-                .WithExpiry(expire)).Result;
-        }
-
-
-        public string UploadFile(string path, Stream stream, string contentType = "image/png")
-        {
-            Mc.PutObjectAsync(new PutObjectArgs().WithBucket(Bucket).WithObject(path).WithObjectSize(stream.Length)
-                .WithStreamData(stream).WithContentType(contentType)).Wait();
-            return null;
-        }
-
-        public string FullUrl(string path)
-        {
-            var httpRequest = HttpContextAccessor.HttpContext?.Request;
-            var url = $"{httpRequest?.Scheme}://{httpRequest?.Host}";
-            if (string.IsNullOrEmpty(path))
-            {
-                return path;
-            }
-
-            return path.StartsWith("~") ? url + path.Substring(1, path.Length - 1) : $"{ServeUrl}{path}";
-        }
-    }
-}

Helpers/SimApiUpload.cs

@@ -0,0 +1,103 @@
+using System;
+using System.IO;
+using Microsoft.AspNetCore.Hosting;
+
+namespace SimApi.Helpers
+{
+    public class SimApiUpload
+    {
+        private string FilePathFolder = "/uploads/";
+        public string FilePath
+        {
+            set
+            {
+                if (!value.StartsWith("/"))
+                {
+                    FilePathFolder = $"/{value}";
+                }
+                if (!FilePathFolder.EndsWith("/"))
+                {
+                    FilePathFolder += "/";
+                }
+            }
+            get
+            {
+                return FilePathFolder;
+            }
+        }
+
+        private IWebHostEnvironment Env { get; }
+
+        public SimApiUpload(IWebHostEnvironment env)
+        {
+            Env = env;
+        }
+
+        public class SimApiUploadInfo
+        {
+            public string Path { get; set; }
+            public int Size { get; set; }
+        }
+
+        /// <summary>
+        /// 保存base64文件,如果有标头按照标头自动识别
+        /// </summary>
+        /// <param name="base64"></param>
+        /// <param name="ext">扩展名</param>
+        /// <param name="path">存放路径</param>
+        /// <param name="fileName">文件名</param>
+        /// <returns></returns>
+        public SimApiUploadInfo SaveFile(string base64, string ext = null, string path = null, string fileName = null)
+        {
+            byte[] bt;
+            var filePath = FilePath + path;
+            if (fileName == null)
+            {
+                fileName = Guid.NewGuid().ToString();
+            }
+            var baseArr = base64.Split(";");
+            if (baseArr.Length == 2)
+            {
+                var info = baseArr[0].Split(":")[1].Split("/");
+                if (path == null)
+                {
+                    filePath += $"{info[0]}/";
+                }
+                if (ext == null)
+                {
+                    ext = info[1];
+                }
+                var data = baseArr[1].Split(",");
+                bt = Convert.FromBase64String(data[1]);
+            }
+            else
+            {
+                bt = Convert.FromBase64String(base64);
+            }
+            var fn = fileName + (string.IsNullOrEmpty(ext) ? string.Empty : $".{ext}");
+            return WriteFile(filePath, fn, bt);
+        }
+
+        /// <summary>
+        /// 把数据写入文件
+        /// </summary>
+        /// <param name="filePath"></param>
+        /// <param name="fileName"></param>
+        /// <param name="data"></param>
+        /// <returns></returns>
+        public SimApiUploadInfo WriteFile(string filePath, string fileName, byte[] data)
+        {
+            var realPath = Directory.GetCurrentDirectory() + "/wwwroot" + filePath;
+            if (!Directory.Exists(realPath))
+            {
+                Directory.CreateDirectory(realPath);
+            }
+            File.WriteAllBytes(realPath + fileName, data);
+            return new SimApiUploadInfo
+            {
+                Path = filePath + fileName,
+                Size = data.Length
+            };
+        }
+    }
+}

Helpers/SimApiUtil.cs

@@ -1,31 +1,12 @@
 using System;
 using System.Security.Cryptography;
 using System.Text;
-using System.Text.Encodings.Web;
-using System.Text.Json;
 using System.Text.RegularExpressions;
-using System.Text.Unicode;
 
 namespace SimApi.Helpers
 {
     public static class SimApiUtil
     {
-        /// <summary>
-        /// 当前CST时间
-        /// </summary>
-        public static DateTime CstNow
-        {
-            get => DateTime.UtcNow.AddHours(8);
-        }
-
-        /// <summary>
-        /// 当前秒级时间戳
-        /// </summary>
-        public static double TimestampNow
-        {
-            get => (DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0)).TotalSeconds;
-        }
-
         /// <summary>
         /// 检测手机号是否正确
         /// </summary>
@@ -33,7 +14,7 @@ namespace SimApi.Helpers
         /// <returns></returns>
         public static bool CheckCell(string cell)
         {
-            var regex = new Regex("^1[3456789]\\d{9}$");
+            var regex = new Regex("^1[34578]\\d{9}$");
             return regex.IsMatch(cell);
         }
 
@@ -56,18 +37,5 @@ namespace SimApi.Helpers
 
             return strbul.ToString();
         }
-
-        /// <summary>
-        /// 将对象序列化成JSON （控制台输出中文不会被编码）
-        /// </summary>
-        /// <param name="obj"></param>
-        /// <returns></returns>
-        public static string Json(object obj)
-        {
-            return JsonSerializer.Serialize(obj, new JsonSerializerOptions
-            {
-                Encoder = JavaScriptEncoder.Create(UnicodeRanges.All)
-            });
-        }
     }
 }

Logger/SimApiLogger.cs

@@ -1,41 +0,0 @@
-using System;
-using Microsoft.Extensions.Logging;
-using SimApi.Helpers;
-
-namespace SimApi.Logger
-{
-    public class SimApiLogger : ILogger
-    {
-        private string Name { get; }
-
-        public SimApiLogger(string name)
-        {
-            Name = name;
-        }
-
-        public IDisposable BeginScope<TState>(TState state) => default!;
-
-        public bool IsEnabled(LogLevel logLevel) => true;
-
-        public void Log<TState>(LogLevel logLevel, EventId eventId, TState state, Exception exception,
-            Func<TState, Exception, string> formatter)
-        {
-            Console.ForegroundColor = logLevel switch
-            {
-                LogLevel.Debug => ConsoleColor.DarkMagenta,
-                LogLevel.Information => ConsoleColor.DarkCyan,
-                LogLevel.Warning => ConsoleColor.Yellow,
-                LogLevel.Error => ConsoleColor.Red,
-                LogLevel.Critical => ConsoleColor.DarkRed,
-                _ => ConsoleColor.White
-            };
-            var message =
-                $"[ {Name} ][ {SimApiUtil.CstNow.ToString("yyyy-MM-dd HH:mm:ss:ffff")} ][ {logLevel.ToString()} ]\n{state}\n";
-            if (exception != null)
-            {
-                message += $"{exception}\n";
-            }
-            Console.WriteLine(message);
-        }
-    }
-}

Logger/SimApiLoggerConfiguration.cs

@@ -1,15 +0,0 @@
-using System;
-using System.Collections.Generic;
-using Microsoft.Extensions.Logging;
-
-namespace SimApi.Logger;
-
-public class SimApiLoggerConfiguration
-{
-    public int EventId { get; set; }
-
-    public Dictionary<LogLevel, ConsoleColor> LogLevels { get; set; } = new()
-    {
-        [LogLevel.Information] = ConsoleColor.Green
-    };
-}

Logger/SimApiLoggerProvider.cs

@@ -1,22 +0,0 @@
-using System.Collections.Concurrent;
-using Microsoft.Extensions.Logging;
-
-namespace SimApi.Logger
-{
-    public class SimApiLoggerProvider : ILoggerProvider
-    {
-        private readonly ConcurrentDictionary<string, SimApiLogger> _loggers =
-            new ConcurrentDictionary<string, SimApiLogger>();
-
-
-        public ILogger CreateLogger(string categoryName)
-        {
-            return _loggers.GetOrAdd(categoryName, name => new SimApiLogger(name));
-        }
-
-        public void Dispose()
-        {
-            _loggers.Clear();
-        }
-    }
-}

Middlewares/SimApiExceptionMiddleware.cs

@@ -1,5 +1,4 @@
 using System;
-using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Http;
 using SimApi.Communications;
@@ -14,7 +13,6 @@ namespace SimApi.Middlewares
     public class SimApiExceptionMiddleware
     {
         private RequestDelegate Next { get; }
-
         private ILogger<SimApiExceptionMiddleware> Log { get; }
 
         public SimApiExceptionMiddleware(RequestDelegate next, ILogger<SimApiExceptionMiddleware> log)
@@ -34,30 +32,24 @@ namespace SimApi.Middlewares
             try
             {
                 await Next(context);
-                if (context.Response.StatusCode != 200)
-                {
-                    if (!new[]
-                        {
-                            301, 302
-                        }.Contains(context.Response.StatusCode))
-                    {
-                        throw new SimApiException(context.Response.StatusCode);
-                    }
-                }
             }
             catch (SimApiException ex)
             {
-                response = string.IsNullOrEmpty(ex.Message)
+                if (string.IsNullOrEmpty(ex.Message))
-                    ? new SimApiBaseResponse(ex.Code)
+                {
-                    : new SimApiBaseResponse(ex.Code, ex.Message);
+                    response.SetCode(ex.Code);
-
+                }
+                else
+                {
+                    response.SetCodeMsg(ex.Code, ex.Message);
+                }
                 ErrorResponse(context, response);
             }
             catch (Exception ex)
             {
                 Log.LogError(ex.Message);
                 Log.LogError(ex.StackTrace);
-                response = new SimApiBaseResponse(500, ex.Message);
+                response.SetCodeMsg(500, ex.Message);
                 ErrorResponse(context, response);
             }
         }
@@ -68,13 +60,10 @@ namespace SimApi.Middlewares
         /// <param name="context"></param>
         /// <param name="response"></param>
         private void ErrorResponse(HttpContext context, SimApiBaseResponse response)
-        {
-            if (!context.Response.HasStarted)
         {
             context.Response.StatusCode = 200;
             context.Response.Headers.Add("Content-Type", "application/json");
             context.Response.WriteAsync(response.ToString());
         }
     }
-    }
 }

Models/SimApiBaseModel.cs

@@ -1,84 +0,0 @@
-using System;
-using System.Linq;
-using System.Text.Json;
-using SimApi.Helpers;
-
-namespace SimApi.Models
-{
-    public class SimApiBaseModel
-    {
-        protected virtual string[] MapperIgnoreField { get; set; } =
-        {
-            "Id", "CreatedAt", "UpdatedAt"
-        };
-
-        protected virtual string UpdatedTimeField { get; set; } = "UpdatedAt";
-
-        public void MapData<TS>(TS source, bool mapAll = false)
-        {
-            //获取要赋值的源数据不为null的项目
-            var sourceProps = source.GetType().GetProperties().Where(x => x.GetValue(source) != null)
-                .Select(x => new
-                {
-                    x.Name,
-                    x.PropertyType
-                })
-                .ToDictionary(x => x.Name, x => x.PropertyType);
-
-            //获取目标对象的属性信息
-            var targetProps = GetType().GetProperties().Select(x => new
-                {
-                    x.Name,
-                    x.PropertyType
-                })
-                .ToDictionary(x => x.Name, x => x.PropertyType);
-            foreach (var sp in sourceProps.Where(sp =>
-                         targetProps.ContainsKey(sp.Key) && sp.Value == targetProps[sp.Key] &&
-                         (!MapperIgnoreField.Contains(sp.Key) || mapAll)))
-            {
-                GetType().GetProperty(sp.Key)?
-                    .SetValue(this, source.GetType().GetProperty(sp.Key)?.GetValue(source));
-            }
-
-            UpdateTime();
-        }
-
-        public void MapData<TS>(TS source, string[] mapFields)
-        {
-            //获取要赋值的源数据不为null的项目
-            var sourceProps = source.GetType().GetProperties().Where(x => x.GetValue(source) != null)
-                .Select(x => new
-                {
-                    x.Name,
-                    x.PropertyType
-                })
-                .ToDictionary(x => x.Name, x => x.PropertyType);
-
-            //获取目标对象的属性信息
-            var targetProps = GetType().GetProperties().Select(x => new
-                {
-                    x.Name,
-                    x.PropertyType
-                })
-                .ToDictionary(x => x.Name, x => x.PropertyType);
-            foreach (var sp in sourceProps.Where(sp =>
-                         targetProps.ContainsKey(sp.Key) && sp.Value == targetProps[sp.Key] &&
-                         mapFields.Contains(sp.Key)))
-            {
-                GetType().GetProperty(sp.Key)?
-                    .SetValue(this, source.GetType().GetProperty(sp.Key)?.GetValue(source));
-            }
-
-            UpdateTime();
-        }
-
-        /// <summary>
-        /// 更新update时间
-        /// </summary>
-        /// <returns></returns>
-        public void UpdateTime()
-        {
-            GetType().GetProperty(UpdatedTimeField)?.SetValue(this, SimApiUtil.CstNow);
-        }
-    }
-}

Properties/launchSettings.json

@@ -4,7 +4,7 @@
     "anonymousAuthentication": true
   },
   "profiles": {
-    "SimApi": {
+    "YYApi": {
       "commandName": "Project",
       "launchBrowser": true,
       "environmentVariables": {

README.md

@@ -1,6 +1,7 @@
-# YYApi 基于Asp.net Core 3/5的一个基础辅助包
+# YYApi 基于Asp.net Core 3的一个基础辅助包
+
+![CI](https://github.com/YY-Tech/YYApi/workflows/CI/badge.svg)
 
-[![PublishNugetPackage](https://github.com/simcu/simapi-net/actions/workflows/nuget-publish.yml/badge.svg)](https://github.com/simcu/simapi-net/actions/workflows/nuget-publish.yml)
 ### 包含了以下组件:
 
 1. 统一的参数检测,基础认证服务
@@ -22,33 +23,43 @@ namespace Controllers
 }
 ```
 
+2. 基于Swagger的API文档服务
 
-统一配置，现在只需要进行AddSimApi的配置， Configure中直接 UseSimApi即可。
 ```C#
-services.AddSimApi(options =>
+#Startup.cs
-{
+
-   options.ConfigureSimApiDoc(options =>
+	services.AddSimApiDoc("文档名称", "文档描述");
-   {
+
-     options.ApiGroups = new[]
+	app.UseSimApiDoc("名称",SubmitMethod[])
-     {
+
-        new SimApiDocGroupOption
+#控制器中可以直接使用特性
-            {Id = "admin", Name = "后台管理接口", Description = "本接口调用需要Scope：sac.api.admin"},
+
-        new SimApiDocGroupOption
+	[SimApiDoc("分组","名称")]
-            {Id = "user-v1", Name = "用户中心接口", Description = "本接口调用需要Scope：sac.api.user"}
+```
-     };
+
-     options.ApiAuth = new SimApiAuthOption
+3. 简单的基于Redis的登录TOKEN服务
-       {
+
-         Type = new[] {"ClientCredentials", "Implicit", "AuthorizationCode"},
+```C#
-         Scopes = new Dictionary<string, string>
+#Startup.cs
-            {
+service.AddSimApiAuth();
-              {"sac.api.user", "用户信息接口权限"},
+```
-              {"sac.api.admin", "后台管理API"}
+添加时候, 可以从DI中获取 Auth 类,调用 Auth.Set(int,string) 将用户ID/类型和生成的Token绑定,本方法返回缓存中的Key名称
-            },
+
-         AuthorizationUrl = "/connect/authorize",
+```C#
-         TokenUrl = "/connect/token"
+#Startup.cs
-       };
+app.UseSimApiAuth();
-     });
+```
-     options.EnableSimApiStorage = true;
+调用本中间件,然后再需要登录认证的地方,使用 [YYAuth] 特性,即可完成检测登录相关的操作,
-     options.SimApiStorageOptions = Configuration.GetSection("S3").Get<SimApiStorageOptions>();
+如果需要获取用户的ID, 只需要 直接使用 LoginId 属性即可获取
-});
+
+4. 统一返回
+所有Response 均需要继承 SimApiBaseResponse类
+
+
+5. 异常处理
+本异常中间件封装了API错误的异常处理,控制器可以使用 Error(int,string) 直接返回API错误
+
+```C#
+#Startup.cs
+app.UseSimApiException();
 ```

SimApi.csproj

@@ -1,6 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk.Web">
 
   <PropertyGroup>
+    <TargetFramework>net5.0</TargetFramework>
     <OutputType>Library</OutputType>
     <PackOnBuild>true</PackOnBuild>
     <Version>0.2.3</Version>
@@ -12,23 +13,20 @@
     <IncludeSymbols>true</IncludeSymbols>
     <ReleaseVersion>5.0.0</ReleaseVersion>
     <SynchReleaseVersion>false</SynchReleaseVersion>
-    <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
-    <PackageVersion>5.0.2</PackageVersion>
-    <TargetFramework>net7.0</TargetFramework>
   </PropertyGroup>
 
+  <PropertyGroup Condition=" '$(RunConfiguration)' == 'YYApi' " />
   <ItemGroup>
     <Folder Include="Helpers\" />
     <Folder Include="Communications\" />
     <Folder Include="Controllers\" />
     <Folder Include="Middlewares\" />
+    <Folder Include="Attributes\" />
     <Folder Include="Exceptions\" />
   </ItemGroup>
   <ItemGroup>
-    <PackageReference Include="Minio" Version="4.0.7" />
+    <PackageReference Include="Swashbuckle.AspNetCore.Annotations" Version="5.6.3" />
-    <PackageReference Include="RabbitMQ.Client" Version="6.6.0" />
+    <PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="5.6.3" />
-    <PackageReference Include="Swashbuckle.AspNetCore.Annotations" Version="6.5.0" />
-    <PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="6.5.0" />
   </ItemGroup>
   <ProjectExtensions>
     <MonoDevelop>

SimApiExtensions.cs

@@ -3,263 +3,178 @@ using SimApi.Helpers;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.OpenApi.Models;
+using Swashbuckle.AspNetCore.SwaggerUI;
 using SimApi.Middlewares;
-using Microsoft.AspNetCore.HttpOverrides;
-using Microsoft.Extensions.Logging;
-using SimApi.Configs;
-using SimApi.Logger;
 
 namespace SimApi
 {
     /// <summary>
     /// 加入系统的扩展信息
     /// </summary>
-    public static class SimApiExtensions
+    public static class Extensions
     {
+        public static string DocumentTitle = "";
+        public static string DocumentDescription = "";
+
         //**********快捷添加**************
-        public static IServiceCollection AddSimApi(this IServiceCollection builder,
-            Action<SimApiOptions> options = null)
-        {
-            var simApiOptions = new SimApiOptions();
-            options?.Invoke(simApiOptions);
-            if (simApiOptions.EnableLogger)
-            {
-                builder.AddLogging(logger =>
-                {
-                    logger.ClearProviders();
-                    logger.AddProvider(new SimApiLoggerProvider());
-                });
-            }
-            // 是否使用 AUTH
-            if (simApiOptions.EnableSimApiAuth)
-            {
-                builder.AddScoped<SimApiAuth>();
-            }
 
-            if (simApiOptions.EnableCors)
+        /// <summary>
+        /// 添加整个SimAPI,同时增加CORS规则
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <param name="title"></param>
+        /// <param name="description"></param>
+        /// <returns></returns>
+        public static IServiceCollection AddSimApi(this IServiceCollection builder, string title,
+            string description = null)
         {
-                builder.AddCors(cors => cors.AddPolicy("any",
+            return builder.AddSimApiAuth().AddSimApiDoc(title, description).AddCors().AddSimApiUpload();
-                    policy => { policy.AllowAnyHeader().AllowAnyMethod().AllowAnyOrigin(); }));
-            }
-
-            if (simApiOptions.EnableSynapse)
-            {
-                builder.AddSingleton<Synapse>();
-            }
-
-            // 使用SimApiDoc
-            if (simApiOptions.EnableSimApiDoc)
-            {
-                var docOptions = simApiOptions.SimApiDocOptions;
-                builder.AddSwaggerGen(x =>
-                {
-                    foreach (var group in docOptions.ApiGroups)
-                    {
-                        x.SwaggerDoc(group.Id, new OpenApiInfo
-                        {
-                            Title = group.Name,
-                            Description = group.Description
-                        });
-                    }
-
-                    x.EnableAnnotations();
-                    var haveOauth = false;
-                    var haveSimApiAuth = false;
-                    var oauthFlows = new OpenApiOAuthFlows();
-                    foreach (var auth in docOptions.ApiAuth.Type)
-                    {
-                        switch (auth)
-                        {
-                            case "SimApiAuth":
-                                x.AddSecurityRequirement(new OpenApiSecurityRequirement
-                                {
-                                    {
-                                        new OpenApiSecurityScheme
-                                        {
-                                            Reference = new OpenApiReference
-                                            {
-                                                Type = ReferenceType.SecurityScheme,
-                                                Id = "HeaderToken"
-                                            }
-                                        },
-                                        new[] { "readAccess", "writeAccess" }
-                                    }
-                                });
-                                haveSimApiAuth = true;
-                                break;
-                            case "ClientCredentials":
-                                oauthFlows.ClientCredentials = new OpenApiOAuthFlow
-                                {
-                                    TokenUrl = new Uri(docOptions.ApiAuth.TokenUrl, UriKind.RelativeOrAbsolute),
-                                    Scopes = docOptions.ApiAuth.Scopes
-                                };
-                                haveOauth = true;
-                                break;
-                            case "Implicit":
-                                oauthFlows.Implicit = new OpenApiOAuthFlow
-                                {
-                                    AuthorizationUrl = new Uri(docOptions.ApiAuth.AuthorizationUrl,
-                                        UriKind.RelativeOrAbsolute),
-                                    Scopes = docOptions.ApiAuth.Scopes
-                                };
-                                haveOauth = true;
-                                break;
-                            case "AuthorizationCode":
-                                oauthFlows.AuthorizationCode = new OpenApiOAuthFlow
-                                {
-                                    TokenUrl = new Uri(docOptions.ApiAuth.TokenUrl, UriKind.RelativeOrAbsolute),
-                                    AuthorizationUrl = new Uri(docOptions.ApiAuth.AuthorizationUrl,
-                                        UriKind.RelativeOrAbsolute),
-                                    Scopes = docOptions.ApiAuth.Scopes
-                                };
-                                haveOauth = true;
-                                break;
-                            case "Password":
-                                oauthFlows.Password = new OpenApiOAuthFlow
-                                {
-                                    TokenUrl = new Uri(docOptions.ApiAuth.TokenUrl, UriKind.RelativeOrAbsolute),
-                                    Scopes = docOptions.ApiAuth.Scopes
-                                };
-                                haveOauth = true;
-                                break;
-                        }
-                    }
-
-                    if (haveOauth)
-                    {
-                        x.AddSecurityDefinition("oauth2", new OpenApiSecurityScheme
-                        {
-                            Type = SecuritySchemeType.OAuth2,
-                            Flows = oauthFlows,
-                            Description = docOptions.ApiAuth.Description,
-                            In = ParameterLocation.Header
-                        });
-                        x.AddSecurityRequirement(new OpenApiSecurityRequirement
-                        {
-                            {
-                                new OpenApiSecurityScheme
-                                {
-                                    Reference = new OpenApiReference
-                                    {
-                                        Type = ReferenceType.SecurityScheme,
-                                        Id = "oauth2"
-                                    }
-                                },
-                                new[] { "SimApiAuth" }
-                            }
-                        });
-                    }
-
-                    if (haveSimApiAuth)
-                    {
-                        x.AddSecurityDefinition("HeaderToken",
-                            new OpenApiSecurityScheme
-                            {
-                                Name = "Token",
-                                In = ParameterLocation.Header
-                            });
-                    }
-                });
-            }
-
-            // 使用Header转发，应对代理后获取真实ip
-            if (simApiOptions.EnableForwardHeaders)
-            {
-                builder.Configure<ForwardedHeadersOptions>(fwOptions =>
-                {
-                    fwOptions.ForwardedHeaders = ForwardedHeaders.All;
-                    fwOptions.KnownNetworks.Clear();
-                    fwOptions.KnownProxies.Clear();
-                });
-            }
-
-            if (simApiOptions.EnableLowerUrl)
-            {
-                builder.AddRouting(rOptions => rOptions.LowercaseUrls = true);
-            }
-
-            if (simApiOptions.EnableSimApiStorage)
-            {
-                builder.AddHttpContextAccessor();
-                builder.AddSingleton<SimApiStorage>();
-            }
-
-            builder.AddSingleton(simApiOptions);
-            return builder;
         }
 
         /// <summary>
         ///  使用所有SimApi自定义中间件
         /// </summary>
         /// <param name="builder"></param>
+        /// <param name="title"></param>
+        /// <param name="staticFileroot"></param>
+        /// <param name="submitMethods"></param>
         /// <returns></returns>
-        public static IApplicationBuilder UseSimApi(this IApplicationBuilder builder)
+        public static IApplicationBuilder UseSimApi(this IApplicationBuilder builder, params SubmitMethod[] submitMethods)
         {
-            var options = builder.ApplicationServices.GetRequiredService<SimApiOptions>();
+            return builder.UseSimApiException().UseSimApiDoc(submitMethods).UseMiddleware<SimApiAuthMiddleware>().UseCors(x => x.AllowAnyHeader().AllowAnyMethod().AllowAnyOrigin()).UseSimApiUpload();
-
-            var logger = builder.ApplicationServices.GetRequiredService<ILogger<SimApiOptions>>();
-
-            if (options.EnableForwardHeaders)
-            {
-                logger.LogInformation("开始配置ForwardedHeaders...");
-                builder.UseForwardedHeaders();
         }
 
-            if (options.EnableCors)
+
+
+        //*********组件快捷方式*************
+
+        /// <summary>
+        /// 添加自定义授权认证中间价
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <returns></returns>
+        public static IServiceCollection AddSimApiAuth(this IServiceCollection builder)
         {
-                logger.LogInformation("开始配置Cors全部允许...");
+            return builder.AddScoped<SimApiAuth>();
-                builder.UseCors("any");
         }
 
-            if (options.EnableSimApiAuth)
+        /// <summary>
+        /// 添加Base64上传组件
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <returns></returns>
+        public static IServiceCollection AddSimApiUpload(this IServiceCollection builder)
         {
-                logger.LogInformation("开始配置SimApiAuth...");
+            return builder.AddSingleton<SimApiUpload>();
-                builder.UseMiddleware<SimApiAuthMiddleware>();
         }
 
-            if (options.EnableSimApiDoc)
+        /// <summary>
+        /// 添加Api文档服务
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <param name="title">文档标题</param>
+        /// <param name="description">文档描述</param>
+        /// <returns></returns>
+        public static IServiceCollection AddSimApiDoc(this IServiceCollection builder, string title,
+            string description = null)
         {
-                logger.LogInformation("开始配置SimApiDoc...");
+            DocumentTitle = title;
-                var docOptions = options.SimApiDocOptions;
+            DocumentDescription = description;
-                builder.UseSwagger(x => x.RouteTemplate = "/swagger/{documentName}.json").UseSwaggerUI(x =>
+            return builder.AddSwaggerGen(x =>
             {
-                    x.DocumentTitle = docOptions.DocumentTitle;
+                x.SwaggerDoc("api", new OpenApiInfo { Title = DocumentTitle, Description = DocumentDescription });
-                    foreach (var group in docOptions.ApiGroups)
+                x.EnableAnnotations();
+                x.AddSecurityRequirement(new OpenApiSecurityRequirement
                 {
-                        x.SwaggerEndpoint($"/swagger/{group.Id}.json", name: group.Name);
+                    {
+                        new OpenApiSecurityScheme
+                        {
+                            Reference = new OpenApiReference {Type = ReferenceType.SecurityScheme, Id = "HeaderToken"}
+                        },
+                        new[] {"readAccess", "writeAccess"}
+                    }
+                });
+                x.AddSecurityDefinition("HeaderToken",
+                    new OpenApiSecurityScheme { Name = "Token", In = ParameterLocation.Header });
+            });
         }
 
+
+        /// <summary>
+        /// 使用异常中间价扩展
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <returns></returns>
+        public static IApplicationBuilder UseSimApiException(this IApplicationBuilder builder)
+        {
+            return builder.UseMiddleware<SimApiExceptionMiddleware>();
+        }
+
+        /// <summary>
+        /// 配置上传组件必须
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <returns></returns>
+        public static IApplicationBuilder UseSimApiUpload(this IApplicationBuilder builder)
+        {
+            return builder.UseStaticFiles(new StaticFileOptions
+            {
+                DefaultContentType = "application/x-msdownload",
+                ServeUnknownFileTypes = true
+            });
+        }
+
+        /// <summary>
+        /// 使用文档UI
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <param name="title">文档标题</param>
+        /// <param name="submitMethods">文档支持的提交方式(如果不指定,默认使用POST)</param>
+        /// <returns></returns>
+        public static IApplicationBuilder UseSimApiDoc(this IApplicationBuilder builder, params SubmitMethod[] submitMethods)
+        {
+            return builder.UseSwagger(x => x.RouteTemplate = "docs/{documentName}.json").UseSwaggerUI(x =>
+            {
+                x.RoutePrefix = "docs";
+                x.DocumentTitle = DocumentTitle;
+                x.SwaggerEndpoint("/docs/api.json", name: DocumentTitle);
                 x.EnableValidator();
-                    x.SupportedSubmitMethods(docOptions.SupportedMethod);
+                if (submitMethods.Length > 0)
+                {
+                    x.SupportedSubmitMethods(submitMethods);
+                }
+                else
+                {
+                    x.SupportedSubmitMethods(SubmitMethod.Post);
+                }
+
                 x.DisplayRequestDuration();
             });
         }
 
-            if (options.EnableSimApiException)
+
+        /// <summary>
+        /// 同时使用Api文档和异常处理中间件
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <param name="title">文档标题</param>
+        /// <param name="submitMethods">API提交方式定义</param>
+        /// <returns></returns>
+        public static IApplicationBuilder UseSimApiDocEx(this IApplicationBuilder builder, params SubmitMethod[] submitMethods)
         {
-                logger.LogInformation("开始配置SimApiException...");
+            return builder.UseSimApiException().UseSimApiDoc(submitMethods);
-                builder.UseMiddleware<SimApiExceptionMiddleware>();
         }
 
-            //请求一下检测存储错误
+        /// <summary>
-            if (options.EnableSimApiStorage)
+        /// 使用自定义认证中间件（依赖IDistributedCache）
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <returns></returns>
+        public static IApplicationBuilder UseSimApiAuth(this IApplicationBuilder builder)
         {
-                logger.LogInformation("开始配置SimApiStorage...");
+            return builder.UseMiddleware<SimApiAuthMiddleware>();
-                builder.ApplicationServices.GetService<SimApiStorage>();
         }
 
-            if (options.EnableLowerUrl)
-            {
-                logger.LogInformation("开始配置使用URL小写...");
-            }
 
-            if (options.EnableSynapse)
-            {
-                var synapse = builder.ApplicationServices.GetRequiredService<Synapse>();
-                synapse.Init();
-            }
-
-            return builder;
-        }
     }
 }

Synapse/EventClient.cs

@@ -1,34 +0,0 @@
-using System;
-using System.Text;
-using System.Text.Encodings.Web;
-using System.Text.Json;
-using System.Text.Unicode;
-using Microsoft.Extensions.Logging;
-
-namespace SimApi;
-
-public partial class Synapse
-{
-    private void RunEventClient()
-    {
-        EventClientChannel = CreateChannel(0, "EventClient");
-    }
-
-    private void FireEvent(string eventName, object param)
-    {
-        var paramJson = JsonSerializer.Serialize(param, new JsonSerializerOptions
-        {
-            Encoder = JavaScriptEncoder.Create(UnicodeRanges.All),
-            PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
-        });
-        var router = $"event.{Options.AppName}.{eventName}";
-        var props = EventClientChannel.CreateBasicProperties();
-        props.AppId = Options.AppId;
-        props.MessageId = Guid.NewGuid().ToString();
-        props.ReplyTo = Options.AppName;
-        props.Type = eventName;
-        EventClientChannel.BasicPublish(Options.SysName, router, false, props, Encoding.UTF8.GetBytes(paramJson));
-        Logger.LogDebug("Event Publish: {OptionsAppName}.{EventName}\n{ParamJson}", Options.AppName, eventName,
-            paramJson);
-    }
-}

Synapse/EventServer.cs

@@ -1,55 +0,0 @@
-using System;
-using System.Linq;
-using System.Text;
-using System.Text.Json;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Logging;
-using RabbitMQ.Client.Events;
-
-namespace SimApi;
-
-public partial class Synapse
-{
-    private void RunEventServer()
-    {
-        EventServerChannel = CreateChannel(Options.EventProcessorNum, "EventServer");
-        var queue = $"{Options.SysName}_{Options.AppName}_event";
-        EventServerChannel.QueueDeclare(queue, true, false, true, null);
-        foreach (var ev in EventRegistry.Where(ev => !ev.Key.Contains('*') && !ev.Key.Contains('#')))
-        {
-            EventServerChannel.QueueBind(queue, Options.SysName, $"event.{ev.Key}", null);
-        }
-        var consumer = new EventingBasicConsumer(EventServerChannel);
-        consumer.Received += (ch, ea) =>
-        {
-            var reqBody = Encoding.UTF8.GetString(ea.Body.ToArray());
-            Logger.LogDebug("Event Receive: {BasicPropertiesReplyTo}.{BasicPropertiesType}\n{S}",
-                ea.BasicProperties.ReplyTo, ea.BasicProperties.Type, reqBody);
-
-            var key = ea.RoutingKey.Replace("event.", string.Empty);
-            var method = EventRegistry.FirstOrDefault(x => x.Key == key);
-            var callClass = Sp.CreateScope().ServiceProvider.GetRequiredService(method.Class);
-            var mt = callClass.GetType().GetMethod(method.Method);
-            var pt = mt.GetParameters()[0].ParameterType;
-            try
-            {
-                mt.Invoke(callClass, pt == typeof(string)
-                    ? new object[] { reqBody }
-                    : new[]
-                    {
-                        JsonSerializer.Deserialize(reqBody, pt, new JsonSerializerOptions
-                        {
-                            PropertyNamingPolicy = JsonNamingPolicy.CamelCase
-                        })
-                    });
-                EventServerChannel.BasicAck(ea.DeliveryTag, false);
-            }
-            catch (Exception e)
-            {
-                Logger.LogError("Event Processor Error: {Err}", e.Message);
-                EventServerChannel.BasicNack(ea.DeliveryTag, false, false);
-            }
-        };
-        EventServerChannel.BasicConsume(queue, false, "", false, false, null, consumer);
-    }
-}

Synapse/RpcClient.cs

@@ -1,79 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Text;
-using System.Text.Encodings.Web;
-using System.Text.Json;
-using System.Text.Unicode;
-using Microsoft.Extensions.Logging;
-using Newtonsoft.Json.Serialization;
-using RabbitMQ.Client.Events;
-using SimApi.Communications;
-using SimApi.Helpers;
-
-namespace SimApi;
-
-public partial class Synapse
-{
-    private Dictionary<string, byte[]> ResponseCache { get; } = new();
-
-    private void RunRpcClient()
-    {
-        RpcClientChannel = CreateChannel(0, "RpcClient");
-        var queue = $"{Options.SysName}_{Options.AppName}_client_{Options.AppId}";
-        var router = $"client.{Options.AppName}.{Options.AppId}";
-        RpcClientChannel.QueueDeclare(queue, true, false, true, null);
-        RpcClientChannel.QueueBind(queue, Options.SysName, router, null);
-        var consumer = new EventingBasicConsumer(RpcClientChannel);
-        consumer.Received += (ch, ea) =>
-        {
-            ResponseCache.Add(ea.BasicProperties.CorrelationId, ea.Body.ToArray());
-            RpcClientChannel.BasicAck(ea.DeliveryTag, false);
-            Logger.LogDebug(
-                "RPC Response: ({BasicPropertiesCorrelationId}) {BasicPropertiesType}@{BasicPropertiesReplyTo} -> {OptionsAppName}\n{S}",
-                ea.BasicProperties.CorrelationId, ea.BasicProperties.Type, ea.BasicProperties.ReplyTo, Options.AppName,
-                Encoding.UTF8.GetString(ea.Body.ToArray()));
-        };
-        RpcClientChannel.BasicConsume(queue, false, "", false, false, null, consumer);
-    }
-
-    private object FireRpc(string app, string action, object param)
-    {
-        var paramJson = JsonSerializer.Serialize(param, new JsonSerializerOptions
-        {
-            Encoder = JavaScriptEncoder.Create(UnicodeRanges.All),
-            PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
-        });
-        var router = $"server.{app}";
-        SimApiBaseResponse response;
-        var props = RpcClientChannel.CreateBasicProperties();
-        props.AppId = Options.AppId;
-        props.MessageId = Guid.NewGuid().ToString();
-        props.Type = action;
-        props.ReplyTo = Options.AppName;
-        RpcClientChannel.BasicPublish(Options.SysName, router, false, props, Encoding.UTF8.GetBytes(paramJson));
-        Logger.LogDebug("RPC Request: ({PropsMessageId}) {OptionsAppName} -> {Action}@{App}\n{ParamJson}",
-            props.MessageId,
-            Options.AppName, action, app, paramJson);
-        var ts = SimApiUtil.TimestampNow;
-        while (true)
-        {
-            if (SimApiUtil.TimestampNow - ts > Options.RpcTimeout)
-            {
-                response = new SimApiBaseResponse(502, "timeout");
-                break;
-            }
-            if (ResponseCache.TryGetValue(props.MessageId, out var value))
-            {
-                response = JsonSerializer.Deserialize<SimApiBaseResponse<object>>(
-                    Encoding.UTF8.GetString(value), new JsonSerializerOptions
-                    {
-                        PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
-                        Encoder = JavaScriptEncoder.Create(UnicodeRanges.All)
-                    });
-                ResponseCache.Remove(props.MessageId);
-                break;
-            }
-        }
-        return response;
-    }
-}

Synapse/RpcServer.cs

@@ -1,92 +0,0 @@
-using System;
-using System.Linq;
-using System.Text;
-using System.Text.Encodings.Web;
-using System.Text.Json;
-using System.Text.Unicode;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Logging;
-using RabbitMQ.Client.Events;
-using SimApi.Communications;
-using SimApi.Exceptions;
-using SimApi.Helpers;
-using JsonSerializer = System.Text.Json.JsonSerializer;
-
-namespace SimApi;
-
-public partial class Synapse
-{
-    private void RunRpcServer()
-    {
-        RpcServerChannel = CreateChannel(Options.RpcProcessorNum, "RpcServer");
-        var queue = $"{Options.SysName}_{Options.AppName}_server";
-        var router = $"server.{Options.AppName}";
-        RpcServerChannel.QueueDeclare(queue, true, false, true, null);
-        RpcServerChannel.QueueBind(queue, Options.SysName, router, null);
-        var consumer = new EventingBasicConsumer(RpcServerChannel);
-        consumer.Received += (ch, ea) =>
-        {
-            var reqBody = Encoding.UTF8.GetString(ea.Body.ToArray());
-            Logger.LogDebug(
-                "RPC Receive: ({BasicPropertiesMessageId}) {BasicPropertiesReplyTo} -> {BasicPropertiesType}@{OptionsAppName}\n{S}",
-                ea.BasicProperties.MessageId, ea.BasicProperties.ReplyTo, ea.BasicProperties.Type, Options.AppName,
-                reqBody);
-            var res = new SimApiBaseResponse(404, "method not found");
-            var method = RpcRegistry.FirstOrDefault(x => x.Key == ea.BasicProperties.Type);
-            if (method != null)
-            {
-                var callClass = Sp.CreateScope().ServiceProvider.GetRequiredService(method.Class);
-                var mt = callClass.GetType().GetMethod(method.Method);
-                try
-                {
-                    var pt = mt.GetParameters()[0].ParameterType;
-                    if (pt == typeof(string))
-                    {
-                        var ret = mt.Invoke(callClass, new[] { reqBody });
-                        res = new SimApiBaseResponse<object>(ret);
-                    }
-                    else
-                    {
-                        var paramObj = JsonSerializer.Deserialize(reqBody, pt, new JsonSerializerOptions
-                        {
-                            PropertyNamingPolicy = JsonNamingPolicy.CamelCase
-                        });
-                        var ret = mt.Invoke(callClass, new[] { paramObj });
-                        res = new SimApiBaseResponse<object>(ret);
-                    }
-                }
-                catch (SimApiException e)
-                {
-                    Logger.LogDebug("RPC错误: {Err}", e.Message);
-                    res = new SimApiBaseResponse(e.Code, e.Message);
-                }
-                catch (Exception e)
-                {
-                    Logger.LogDebug("RPC调用失败: {Err}", e.Message);
-                    res = new SimApiBaseResponse(500, e.Message);
-                }
-            }
-
-
-            var returnJson = JsonSerializer.Serialize((object)res, new JsonSerializerOptions
-            {
-                Encoder = JavaScriptEncoder.Create(UnicodeRanges.All),
-                PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
-            });
-            Console.WriteLine(returnJson);
-            var reply = $"client.{ea.BasicProperties.ReplyTo}.{ea.BasicProperties.AppId}";
-            var props = RpcServerChannel.CreateBasicProperties();
-            props.AppId = Options.AppId;
-            props.CorrelationId = ea.BasicProperties.MessageId;
-            props.MessageId = Guid.NewGuid().ToString();
-            props.ReplyTo = Options.AppName;
-            props.Type = ea.BasicProperties.Type;
-            RpcServerChannel.BasicPublish(Options.SysName, reply, false, props, Encoding.UTF8.GetBytes(returnJson));
-            Logger.LogDebug(
-                "Rpc Return: ({BasicPropertiesMessageId}) {BasicPropertiesType}@{OptionsAppName} -> {BasicPropertiesReplyTo}\n{ReturnJson}",
-                ea.BasicProperties.MessageId, ea.BasicProperties.Type, Options.AppName, ea.BasicProperties.ReplyTo,
-                returnJson);
-        };
-        RpcServerChannel.BasicConsume(queue, true, "", false, false, null, consumer);
-    }
-}

Synapse/Synapse.cs

@@ -1,237 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Diagnostics;
-using System.Linq;
-using System.Text.Json;
-using Microsoft.Extensions.Logging;
-using RabbitMQ.Client;
-using RabbitMQ.Client.Exceptions;
-using SimApi.Attributes;
-using SimApi.Communications;
-using SimApi.Configs;
-using SimApi.Helpers;
-
-namespace SimApi;
-
-public partial class Synapse
-{
-    private IServiceProvider Sp { get; }
-
-    private SimApiSynapseOptions Options { get; }
-
-    private ILogger<Synapse> Logger { get; }
-
-    private IConnection Connection { get; set; }
-
-    private IModel EventClientChannel { get; set; }
-
-    private IModel EventServerChannel { get; set; }
-
-    private IModel RpcClientChannel { get; set; }
-
-    private IModel RpcServerChannel { get; set; }
-
-    private List<RegisterItem> EventRegistry { get; set; }
-
-    private List<RegisterItem> RpcRegistry { get; set; }
-
-    public Synapse(SimApiOptions simApiOptions, ILogger<Synapse> logger, IServiceProvider sp)
-    {
-        Logger = logger;
-        Sp = sp;
-        Options = simApiOptions.SimApiSynapseOptions;
-    }
-
-    public void Init()
-    {
-        ProcessAttribute();
-        Logger.LogDebug("Synapse初始化配置信息: {Json}", SimApiUtil.Json(Options));
-        if (string.IsNullOrEmpty(Options.AppName) || string.IsNullOrEmpty(Options.SysName))
-        {
-            Logger.LogCritical("Synapse初始化失败: AppName or SysName 错误");
-        }
-        Options.AppId ??= Guid.NewGuid().ToString();
-        Logger.LogInformation("System Name: {SysName}\nApp Name: {AppName}\nAppId: {AppId}", Options.SysName,
-            Options.AppName, Options.AppId);
-        CreateConnection();
-        CheckAndCreateExchange();
-        //事件客户端
-        if (Options.DisableEventClient)
-        {
-            Logger.LogWarning("Event Client Disabled: DisableEventClient set true");
-        }
-        else
-        {
-            RunEventClient();
-            Logger.LogInformation("Event Client Ready");
-        }
-
-        //RPC客户端
-        if (Options.DisableRpcClient)
-        {
-            Logger.LogWarning("Rpc Client Disabled: DisableEventClient set true");
-        }
-        else
-        {
-            RunRpcClient();
-            Logger.LogInformation("Rpc Client Ready, Client Timeout: {OptionsRpcTimeout}s", Options.RpcTimeout);
-        }
-        if (RpcRegistry.Count > 0)
-        {
-            RunRpcServer();
-        }
-        if (EventRegistry.Count > 0)
-        {
-            RunEventServer();
-        }
-    }
-
-
-    public SimApiBaseResponse<T> Rpc<T>(string appName, string method, dynamic param)
-    {
-        var res = new SimApiBaseResponse(500, "Rpc Client Disabled!");
-        if (Options.DisableRpcClient)
-        {
-            Logger.LogError("Rpc Client Disabled!");
-        }
-        else
-        {
-            res = FireRpc(appName, method, param);
-        }
-        return res as SimApiBaseResponse<T>;
-    }
-
-    public SimApiBaseResponse<object> Rpc(string appName, string method, dynamic param)
-    {
-        return Rpc<object>(appName, method, param);
-    }
-
-    public void Event(string eventName, dynamic param)
-    {
-        if (Options.DisableEventClient)
-        {
-            Logger.LogError("Event Client Disabled!");
-        }
-        else
-        {
-            FireEvent(eventName, param);
-        }
-    }
-
-    private void CreateConnection()
-    {
-        var factory = new ConnectionFactory
-        {
-            HostName = Options.MqHost,
-            Port = Options.MqPort,
-            VirtualHost = Options.MqVHost,
-            UserName = Options.MqUser,
-            Password = Options.MqPass
-        };
-        try
-        {
-            Connection = factory.CreateConnection();
-            Logger.LogInformation("连接RabbitMQ服务器成功");
-        }
-        catch (BrokerUnreachableException e)
-        {
-            Logger.LogError("连接RabbitMQ失败: \n{Err}", e);
-        }
-    }
-
-    private IModel CreateChannel(ushort processNum = 0, string desc = "unknow")
-    {
-        IModel channel = null;
-        try
-        {
-            var log = $"Channel [{desc}] 创建成功...";
-            channel = Connection.CreateModel();
-            if (processNum != 0)
-            {
-                channel.BasicQos(0, processNum, false);
-                log += $"最大处理器数量: {processNum}";
-            }
-            Logger.LogInformation(log);
-        }
-        catch (ConnectFailureException e)
-        {
-            Logger.LogError("Channel [{{Desc}}] 创建失败...\n {0}", e);
-        }
-        return channel;
-    }
-
-    private void CheckAndCreateExchange()
-    {
-        var channel = CreateChannel(0, "Exchange");
-        try
-        {
-            channel.ExchangeDeclare(Options.SysName, ExchangeType.Topic, true, true, null);
-            Logger.LogDebug("Register Exchange Success");
-        }
-        catch (ConnectFailureException e)
-        {
-            Logger.LogError("Failed to declare Exchange.\n {Err}", e);
-        }
-        channel.Close();
-        Logger.LogDebug("Exchange Channel Closed");
-    }
-
-    private void ProcessAttribute()
-    {
-        EventRegistry = new List<RegisterItem>();
-        RpcRegistry = new List<RegisterItem>();
-        var stackTrace = new StackTrace();
-        var callingMethod = stackTrace.GetFrame(stackTrace.FrameCount - 1).GetMethod();
-        var assembly = callingMethod.DeclaringType.Assembly;
-        var types = assembly.GetTypes(); // 获取程序集中的所有类型
-        foreach (var type in types)
-        {
-            var methods = type.GetMethods(); // 获取类型中的所有方法
-            foreach (var method in methods)
-            {
-                if (method.IsDefined(typeof(SynapseEventAttribute), false))
-                {
-                    var attribute =
-                        (SynapseEventAttribute)Attribute.GetCustomAttribute(method, typeof(SynapseEventAttribute));
-                    if (attribute != null)
-                    {
-                        EventRegistry.Add(new RegisterItem
-                        {
-                            Key = attribute.Name ?? method.Name,
-                            Class = type,
-                            Method = method.Name
-                        });
-                    }
-                }
-                if (method.IsDefined(typeof(SynapseRpcAttribute), false))
-                {
-                    var attribute =
-                        (SynapseRpcAttribute)Attribute.GetCustomAttribute(method, typeof(SynapseRpcAttribute));
-                    if (attribute != null)
-                    {
-                        RpcRegistry.Add(new RegisterItem
-                        {
-                            Key = attribute.Name ?? $"{type.Name}.{method.Name}",
-                            Class = type,
-                            Method = method.Name
-                        });
-                    }
-                }
-            }
-        }
-        var events = EventRegistry.Aggregate(string.Empty,
-            (current, ev) => current + $"\n |- {ev.Key} -> {ev.Method}@{ev.Class.Name}");
-        var rpcList = RpcRegistry.Aggregate(string.Empty,
-            (current, ev) => current + $"\n |- {ev.Key} -> {ev.Method}@{ev.Class.Name}");
-        Logger.LogInformation(">>> Synapse System 读取Event方法:{Event}\n>>>Synapse System 读取RPC方法:{Rpc}", events, rpcList);
-    }
-}
-
-public class RegisterItem
-{
-    public string Key { get; set; }
-
-    public Type Class { get; set; }
-
-    public string Method { get; set; }
-}