完成错误中间件，统一返回结果

Yi.Framework.Net6/src/framework/Yi.Framework.AspNetCore/Microsoft/AspNetCore/Hosting/StratUrlsExtensions.cs

@@ -0,0 +1,19 @@
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Configuration;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace AspNetCore.Microsoft.AspNetCore.Hosting
+{
+    public static class StratUrlsExtensions
+    {
+        public static IWebHostBuilder UseStartUrlsServer(this IWebHostBuilder hostBuilder, IConfiguration configuration, string option = "StartUrl")
+        {
+            return hostBuilder.UseUrls(configuration.GetValue<string>(option));
+        }
+
+    }
+}

Yi.Framework.Net6/src/framework/Yi.Framework.Core/Extensions/AutoIocAddExtensions.cs

@@ -55,8 +55,9 @@ namespace Yi.Framework.Core.Extensions
                 //情况2 自动去找接口，如果存在就是接口，如果不存在就是本身
                 if (serviceType == null)
                 {
-                    //获取最靠近的接口
-                    var firstInter = type.GetInterfaces().LastOrDefault();
+                    //获取最远靠近的接口
+                    var p = type.GetInterfaces().ToList();
+                    var firstInter = type.GetInterfaces().Where(u => u.Name ==$"I{type.Name}").LastOrDefault();
                     if (firstInter is null)
                     {
                         serviceType = type;
@@ -89,7 +90,9 @@ namespace Yi.Framework.Core.Extensions
             if (serviceInterfaces is not null)
             {
                 var serviceType = type;
-                var firstInter = type.GetInterfaces().Where(u => u != typeof(ITransientDependency)).LastOrDefault();
+
+                //规范
+                var firstInter = type.GetInterfaces().Where(u => u != typeof(ITransientDependency) && u.Name == $"I{type.Name}").LastOrDefault();
 
                 if (firstInter is not null)
                 {
@@ -97,15 +100,15 @@ namespace Yi.Framework.Core.Extensions
                 }
                 if (serviceInterfaces.Contains(typeof(ITransientDependency)))
                 {
-                    services.AddTransient(serviceType,type);
+                    services.AddTransient(serviceType, type);
                 }
                 if (serviceInterfaces.Contains(typeof(IScopedDependency)))
                 {
-                    services.AddScoped(serviceType,type);
+                    services.AddScoped(serviceType, type);
                 }
                 if (serviceInterfaces.Contains(typeof(ISingletonDependency)))
                 {
-                    services.AddSingleton(serviceType,type);
+                    services.AddSingleton(serviceType, type);
                 }
             }
         }

Yi.Framework.Net6/src/framework/Yi.Framework.Core/Extensions/ErrorHandExtensions.cs

@@ -1,6 +1,7 @@
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Http;
 using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -10,6 +11,12 @@ using Yi.Framework.Core.Exceptions;
 
 namespace Yi.Framework.Core.Extensions
 {
+
+   internal class ExceptionModle
+    {
+        public string? Message { get; set; }
+        public string? Details { get; set; }
+    }
     public class ErrorHandMiddleware
     {
         private readonly RequestDelegate _next;
@@ -22,26 +29,46 @@ namespace Yi.Framework.Core.Extensions
         }
         public async Task InvokeAsync(HttpContext context)
         {
-            bool isNext = true;
             try
             {
                 await _next(context);
             }
             catch (BusinessException businessEx)
             {
-                var statusCode = 200;
-                //业务错误，不记录
-                await context.Response.WriteAsync($"你好世界:友好错误，已经被中间件拦截");
+                context.Response.ContentType = "application/json;charset=utf-8";
+                context.Response.StatusCode = businessEx.Code.GetHashCode();
+
+                var result = new ExceptionModle
+                {
+                    Message= businessEx.Message,
+                    Details= businessEx.Details,
+                };
+                //业务错误，不记录日志
+                await context.Response.WriteAsync(JsonConvert.SerializeObject(result, new JsonSerializerSettings()
+                {
+                    //设置首字母小写
+                    ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
+                }));
+
             }
             catch (Exception ex)
             {
-                isNext = false;
+                context.Response.ContentType = "application/json;charset=utf-8";
+                //系统错误，记录日志
                 _logger.LogError(ex, $"系统错误:{ex.Message}");
                 //await _errorHandle.Invoer(context, ex);
-                var statusCode = context.Response.StatusCode;
                 context.Response.StatusCode = 500;
                 //系统错误，需要记录
-                await context.Response.WriteAsync($"你好世界：系统错误，已经被中间件拦截");
+                var result = new ExceptionModle
+                {
+                    Message = ex.Message,
+                    Details = "系统错误",
+                };
+                await context.Response.WriteAsync(JsonConvert.SerializeObject(result, new JsonSerializerSettings()
+                {
+                    //设置首字母小写
+                    ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
+                }));
             }
         }
 

Yi.Framework.Net6/src/framework/Yi.Framework.Core/YiFrameworkCoreModule.cs

@@ -20,8 +20,8 @@ namespace Yi.Framework.Core
             //服务定位实例赋值
             ServiceLocatorModel.Instance = app.ApplicationServices;
 
-            //全局错误，需要靠前
-            app.UseErrorHandlingServer();
+            //全局错误，需要靠前，放在此处无效
+            //app.UseErrorHandlingServer();
         }
 
         public void ConfigureServices(IServiceCollection services, ConfigureServicesContext context)

Yi.Framework.Net6/src/framework/Yi.Framework.Ddd/Services/ApplicationService.cs

@@ -1,10 +1,6 @@
 using AutoMapper;
 using Microsoft.Extensions.DependencyInjection;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
+
 using Yi.Framework.Core.Model;
 
 namespace Yi.Framework.Ddd.Services

Yi.Framework.Net6/src/framework/Yi.Framework.Uow/IUnitOfWorK.cs

@@ -1,7 +0,0 @@
-namespace Yi.Framework.Uow
-{
-    public interface IUnitOfWorK
-    {
-        public IUnitOfWorK CreateContext();
-    }
-}

Yi.Framework.Net6/src/framework/Yi.Framework.Uow/IUnitOfWorkManager.cs

@@ -0,0 +1,94 @@
+//namespace Yi.Framework.Uow
+//{
+//    public interface IUnitOfWorkManager
+//    {
+//        SugarUnitOfWork CreateContext(bool isTran = true);
+//    }
+
+
+//    /// <summary>
+//    /// 这个放到实现类中
+//    /// </summary>
+//    public class SugarUnitOfWorkManager : IUnitOfWorkManager
+//    {
+//        public SugarUnitOfWorkManager(ISqlSugarClient db)
+//        {
+//            this.Db = db;
+//        }
+//        public SugarUnitOfWork Db { get; set; }
+//        public SugarUnitOfWork CreateContext(bool isTran = true)
+//        {
+//            return Db.CreateContext(isTran);
+//        }
+//    }
+
+
+//    /// <summary>
+//    /// 下面这个定死了
+//    /// </summary>
+//    public class SugarUnitOfWork : IDisposable
+//    {
+//        public ISqlSugarClient Db { get; internal set; }
+//        public ITenant Tenant { get; internal set; }
+//        public bool IsTran { get; internal set; }
+//        public bool IsCommit { get; internal set; }
+//        public bool IsClose { get; internal set; }
+
+//        public void Dispose()
+//        {
+
+//            if (this.IsTran && IsCommit == false)
+//            {
+//                this.Tenant.RollbackTran();
+//            }
+//            if (this.Db.Ado.Transaction == null && IsClose == false)
+//            {
+//                this.Db.Close();
+//            }
+//        }
+
+//        public SimpleClient<T> GetRepository<T>() where T : class, new()
+//        {
+//            TenantAttribute tenantAttribute = typeof(T).GetCustomAttribute<TenantAttribute>();
+//            if (tenantAttribute == null)
+//            {
+//                return new SimpleClient<T>(Db);
+//            }
+//            else
+//            {
+//                return new SimpleClient<T>(Db.AsTenant().GetConnection(tenantAttribute.configId));
+//            }
+//        }
+
+//        public RepositoryType GetMyRepository<RepositoryType>() where RepositoryType : ISugarRepository, new()
+//        {
+//            var result = new RepositoryType();
+//            var type = typeof(RepositoryType).GetGenericArguments()[0];
+//            TenantAttribute tenantAttribute = type.GetCustomAttribute<TenantAttribute>();
+//            if (tenantAttribute == null)
+//            {
+//                result.Context = this.Db;
+//            }
+//            else
+//            {
+//                result.Context = this.Db.AsTenant().GetConnection(tenantAttribute.configId);
+//            }
+//            return result;
+//        }
+
+//        public bool Commit()
+//        {
+//            if (this.IsTran && this.IsCommit == false)
+//            {
+//                this.Tenant.CommitTran();
+//                IsCommit = true;
+//            }
+//            if (this.Db.Ado.Transaction == null && this.IsClose == false)
+//            {
+//                this.Db.Close();
+//                IsClose = true;
+//            }
+//            return IsCommit;
+//        }
+//    }
+//}