[feat]代码优化

src/ServerApi/Services/Shared/Adnc.Shared.Application/Registrar/AbstractApplicationDependencyRegistrar.EventBus.cs

@@ -17,7 +17,7 @@ protected virtual void AddEventBusSubscribers<TSubscriber>(Action<IServiceCollec
         action?.Invoke(Services);
 
         var tableNamePrefix = "cap";
-        var groupName = $"cap.{ServiceInfo.ShortName}.{ASPNETCORE_ENVIRONMENT[..3]}".ToLower();
+        var groupName = $"cap.{ServiceInfo.ShortName}.{this.GetEnvShortName()}".ToLower();
 
         //add skyamp
         //Services.AddSkyApmExtensions().AddCap();

src/ServerApi/Services/Shared/Adnc.Shared.Application/Registrar/AbstractApplicationDependencyRegistrar.Repositories.cs

@@ -56,7 +56,7 @@ protected virtual void AddEfCoreContextWithRepositories(Action<IServiceCollectio
                                             .UseQuerySplittingBehavior(QuerySplittingBehavior.SplitQuery);
                 });
 
-                if (IsDevelopment)
+                if (this.IsDevelopment())
                 {
                     //options.AddInterceptors(new DefaultDbCommandInterceptor())
                     options.LogTo(Console.WriteLine)

src/ServerApi/Services/Shared/Adnc.Shared.Application/Registrar/AbstractApplicationDependencyRegistrar.cs

@@ -10,9 +10,6 @@ public abstract partial class AbstractApplicationDependencyRegistrar : IDependen
     public abstract Assembly ContractsLayerAssembly { get; }
     public abstract Assembly RepositoryOrDomainLayerAssembly { get; }
     protected List<AddressNode> RpcAddressInfo { get; init; }
-
-    public string ASPNETCORE_ENVIRONMENT => Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
-    public bool IsDevelopment => ASPNETCORE_ENVIRONMENT.EqualsIgnoreCase("Development");
     protected IServiceCollection Services { get; init; }
     protected IConfiguration Configuration { get; init; }
     protected IServiceInfo ServiceInfo { get; init; }

src/ServerApi/Services/Shared/Adnc.Shared.Application/Registrar/AbstractApplicationDependencyRegistrarExtension.cs

@@ -8,7 +8,7 @@ public static class AbstractApplicationDependencyRegistrarExtension
         /// default rest policies
         /// </summary>
         /// <returns></returns>
-        public static List<IAsyncPolicy<HttpResponseMessage>> GenerateDefaultRefitPolicies(this AbstractApplicationDependencyRegistrar registrar)
+        public static List<IAsyncPolicy<HttpResponseMessage>> GenerateDefaultRefitPolicies(this AbstractApplicationDependencyRegistrar _)
         {
             //隔离策略
             //var bulkheadPolicy = Policy.BulkheadAsync<HttpResponseMessage>(10, 100);
@@ -35,7 +35,7 @@ public static List<IAsyncPolicy<HttpResponseMessage>> GenerateDefaultRefitPolici
                                     TimeSpan.FromSeconds(5),
                                     });
             //超时策略
-            var timeoutPolicy = Policy.TimeoutAsync<HttpResponseMessage>(registrar.IsDevelopment ? 10 : 9);
+            var timeoutPolicy = Policy.TimeoutAsync<HttpResponseMessage>(IsDevelopment(_) ? 10 : 9);
 
             //熔断策略
             //如下，如果我们的业务代码连续失败50次，就触发熔断(onBreak),就不会再调用我们的业务代码，而是直接抛出BrokenCircuitException异常。
@@ -84,7 +84,24 @@ public static List<IAsyncPolicy<HttpResponseMessage>> GenerateDefaultRefitPolici
         /// </summary>
         /// <param name="registrar"></param>
         /// <returns></returns>
-        public static List<IAsyncPolicy<HttpResponseMessage>> GenerateDefaultGrpcPolicies(this AbstractApplicationDependencyRegistrar registrar)
-            => GenerateDefaultRefitPolicies(registrar);
+        public static List<IAsyncPolicy<HttpResponseMessage>> GenerateDefaultGrpcPolicies(this AbstractApplicationDependencyRegistrar registrar) => 
+            GenerateDefaultRefitPolicies(registrar);
+
+
+        public static string ASPNETCORE_ENVIRONMENT => Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
+
+        public static bool IsDevelopment(this AbstractApplicationDependencyRegistrar _) => ASPNETCORE_ENVIRONMENT.EqualsIgnoreCase("Development");
+
+        public static string GetEnvShortName(this AbstractApplicationDependencyRegistrar _)
+        {
+            return ASPNETCORE_ENVIRONMENT.ToLower() switch
+            {
+                "development" => "dev",
+                "test" => "test",
+                "staging" => $"stag",
+                "production" => $"prod",
+                _ => throw new NullReferenceException(nameof(ASPNETCORE_ENVIRONMENT))
+            };
+        }
     }
 }