0
0

Startup.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313
  1. using System;
  2. using System.IO;
  3. using System.Text;
  4. using System.Linq;
  5. using System.Reflection;
  6. using System.Collections.Generic;
  7. using Microsoft.AspNetCore.Http;
  8. using Microsoft.AspNetCore.Builder;
  9. using Microsoft.AspNetCore.Hosting;
  10. using Microsoft.AspNetCore.Authentication;
  11. using Microsoft.AspNetCore.Authentication.JwtBearer;
  12. using Microsoft.OpenApi.Models;
  13. using Microsoft.IdentityModel.Tokens;
  14. using Microsoft.Extensions.Hosting;
  15. using Microsoft.Extensions.DependencyInjection;
  16. using Microsoft.Extensions.DependencyInjection.Extensions;
  17. using Newtonsoft.Json;
  18. using Newtonsoft.Json.Serialization;
  19. using Autofac;
  20. using Autofac.Extras.DynamicProxy;
  21. using AutoMapper;
  22. //using FluentValidation;
  23. //using FluentValidation.AspNetCore;
  24. using Admin.Core.Common.Helpers;
  25. using Admin.Core.Common.Configs;
  26. using Admin.Core.Common.Auth;
  27. using Admin.Core.Auth;
  28. using Admin.Core.Enums;
  29. using Admin.Core.Filters;
  30. using Admin.Core.Db;
  31. using Admin.Core.Common.Cache;
  32. using Admin.Core.Aop;
  33. using Admin.Core.Logs;
  34. using PermissionHandler = Admin.Core.Auth.PermissionHandler;
  35. using Admin.Core.Extensions;
  36. using Admin.Core.Common.Attributes;
  37. namespace Admin.Core
  38. {
  39. public class Startup
  40. {
  41. private readonly IHostEnvironment _env;
  42. private static string basePath => AppContext.BaseDirectory;
  43. private readonly AppConfig _appConfig;
  44. public Startup(IWebHostEnvironment env)
  45. {
  46. _env = env;
  47. _appConfig = new ConfigHelper().Get<AppConfig>("appconfig", env.EnvironmentName) ?? new AppConfig();
  48. }
  49. public void ConfigureServices(IServiceCollection services)
  50. {
  51. //应用配置
  52. services.AddSingleton(_appConfig);
  53. //上传配置
  54. var uploadConfig = new ConfigHelper().Load("uploadconfig", _env.EnvironmentName, true);
  55. services.Configure<UploadConfig>(uploadConfig);
  56. #region AutoMapper 自动映射
  57. var serviceAssembly = Assembly.Load("Admin.Core.Service");
  58. services.AddAutoMapper(serviceAssembly);
  59. #endregion
  60. #region Cors 跨域
  61. services.AddCors(c =>
  62. {
  63. c.AddPolicy("Limit", policy =>
  64. {
  65. policy
  66. .WithOrigins(_appConfig.Urls)
  67. .AllowAnyHeader()
  68. .AllowAnyMethod();
  69. });
  70. });
  71. #endregion
  72. #region Swagger Api文档
  73. if (_env.IsDevelopment() || _appConfig.Swagger)
  74. {
  75. services.AddSwaggerGen(c =>
  76. {
  77. typeof(ApiVersion).GetEnumNames().ToList().ForEach(version =>
  78. {
  79. c.SwaggerDoc(version, new OpenApiInfo
  80. {
  81. Version = version,
  82. Title = "Admin.Core"
  83. });
  84. //c.OrderActionsBy(o => o.RelativePath);
  85. });
  86. var xmlPath = Path.Combine(basePath, "Admin.Core.xml");
  87. c.IncludeXmlComments(xmlPath, true);
  88. var xmlModelPath = Path.Combine(basePath, "Admin.Core.Model.xml");
  89. c.IncludeXmlComments(xmlModelPath);
  90. var xmlServicesPath = Path.Combine(basePath, "Admin.Core.Service.xml");
  91. c.IncludeXmlComments(xmlServicesPath);
  92. //添加设置Token的按钮
  93. c.AddSecurityDefinition("Bearer", new OpenApiSecurityScheme
  94. {
  95. Description = "Value: Bearer {token}",
  96. Name = "Authorization",
  97. In = ParameterLocation.Header,
  98. Type = SecuritySchemeType.ApiKey,
  99. Scheme = "Bearer"
  100. });
  101. //添加Jwt验证设置
  102. c.AddSecurityRequirement(new OpenApiSecurityRequirement()
  103. {
  104. {
  105. new OpenApiSecurityScheme
  106. {
  107. Reference = new OpenApiReference
  108. {
  109. Type = ReferenceType.SecurityScheme,
  110. Id = "Bearer"
  111. },
  112. Scheme = "oauth2",
  113. Name = "Bearer",
  114. In = ParameterLocation.Header,
  115. },
  116. new List<string>()
  117. }
  118. });
  119. });
  120. }
  121. #endregion
  122. #region Jwt身份认证
  123. var jwtConfig = new ConfigHelper().Get<JwtConfig>("jwtconfig", _env.EnvironmentName);
  124. services.TryAddSingleton(jwtConfig);
  125. services.AddSingleton<IHttpContextAccessor, HttpContextAccessor>();
  126. services.TryAddSingleton<IUser, User>();
  127. services.TryAddSingleton<IUserToken, UserToken>();
  128. services.AddScoped<IPermissionHandler, PermissionHandler>();
  129. services.AddAuthentication(options =>
  130. {
  131. options.DefaultScheme = JwtBearerDefaults.AuthenticationScheme;
  132. options.DefaultChallengeScheme = nameof(ResponseAuthenticationHandler); //401
  133. options.DefaultForbidScheme = nameof(ResponseAuthenticationHandler); //403
  134. })
  135. .AddJwtBearer(options =>
  136. {
  137. options.TokenValidationParameters = new TokenValidationParameters
  138. {
  139. ValidateIssuer = true,
  140. ValidateAudience = true,
  141. ValidateLifetime = true,
  142. ValidateIssuerSigningKey = true,
  143. ValidIssuer = jwtConfig.Issuer,
  144. ValidAudience = jwtConfig.Audience,
  145. IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(jwtConfig.SecurityKey)),
  146. ClockSkew = TimeSpan.Zero
  147. };
  148. })
  149. .AddScheme<AuthenticationSchemeOptions, ResponseAuthenticationHandler>(nameof(ResponseAuthenticationHandler), o => { }); ;
  150. #endregion
  151. #region 控制器
  152. if (_appConfig.Log.Operation)
  153. {
  154. services.AddSingleton<ILogHandler, LogHandler>();
  155. }
  156. services.AddControllers(options =>
  157. {
  158. options.Filters.Add<AdminExceptionFilter>();
  159. if (_appConfig.Log.Operation)
  160. {
  161. options.Filters.Add<LogActionFilter>();
  162. }
  163. })
  164. //.AddFluentValidation(config =>
  165. //{
  166. // var assembly = Assembly.LoadFrom(Path.Combine(basePath, "Admin.Core.dll"));
  167. // config.RegisterValidatorsFromAssembly(assembly);
  168. //})
  169. .AddNewtonsoftJson(options =>
  170. {
  171. //忽略循环引用
  172. options.SerializerSettings.ReferenceLoopHandling = ReferenceLoopHandling.Ignore;
  173. //使用驼峰 首字母小写
  174. options.SerializerSettings.ContractResolver = new CamelCasePropertyNamesContractResolver();
  175. //设置时间格式
  176. options.SerializerSettings.DateFormatString = "yyyy-MM-dd HH:mm:ss";
  177. });
  178. #endregion
  179. //数据库
  180. services.AddDb(_env,_appConfig);
  181. #region 缓存
  182. var cacheConfig = new ConfigHelper().Get<CacheConfig>("cacheconfig", _env.EnvironmentName);
  183. if (cacheConfig.Type == CacheType.Redis)
  184. {
  185. var csredis = new CSRedis.CSRedisClient(cacheConfig.Redis.ConnectionString);
  186. RedisHelper.Initialization(csredis);
  187. services.AddSingleton<ICache, RedisCache>();
  188. }
  189. else
  190. {
  191. services.AddMemoryCache();
  192. services.AddSingleton<ICache, MemoryCache>();
  193. }
  194. #endregion
  195. //阻止NLog接收状态消息
  196. services.Configure<ConsoleLifetimeOptions>(opts => opts.SuppressStatusMessages = true);
  197. }
  198. public void ConfigureContainer(ContainerBuilder builder)
  199. {
  200. #region AutoFac IOC容器
  201. try
  202. {
  203. #region Aop
  204. var interceptorServiceTypes = new List<Type>();
  205. if (_appConfig.Aop.Transaction)
  206. {
  207. builder.RegisterType<TransactionInterceptor>();
  208. interceptorServiceTypes.Add(typeof(TransactionInterceptor));
  209. }
  210. #endregion
  211. #region Service
  212. var assemblyServices = Assembly.Load("Admin.Core.Service");
  213. builder.RegisterAssemblyTypes(assemblyServices)
  214. .AsImplementedInterfaces()
  215. .InstancePerDependency()
  216. .EnableInterfaceInterceptors()
  217. .InterceptedBy(interceptorServiceTypes.ToArray());
  218. #endregion
  219. #region Repository
  220. var assemblyRepository = Assembly.Load("Admin.Core.Repository");
  221. builder.RegisterAssemblyTypes(assemblyRepository)
  222. .AsImplementedInterfaces()
  223. .InstancePerDependency();
  224. #endregion
  225. #region SingleInstance
  226. var assemblyCore = Assembly.Load("Admin.Core");
  227. var assemblyCommon = Assembly.Load("Admin.Core.Common");
  228. builder.RegisterAssemblyTypes(assemblyCore, assemblyCommon)
  229. .Where(t => t.GetCustomAttribute<SingleInstanceAttribute>() != null)
  230. .SingleInstance();
  231. #endregion
  232. }
  233. catch (Exception ex)
  234. {
  235. throw new Exception(ex.Message + "\n" + ex.InnerException);
  236. }
  237. #endregion
  238. }
  239. public void Configure(IApplicationBuilder app)
  240. {
  241. //启动事件
  242. //, IHostApplicationLifetime lifetime
  243. //lifetime.ApplicationStarted.Register(() =>
  244. //{
  245. // Console.WriteLine($"{_appConfig.Urls}\r\n");
  246. //});
  247. #region app配置
  248. //异常
  249. app.UseExceptionHandler("/Error");
  250. //静态文件
  251. app.UseUploadConfig();
  252. //路由
  253. app.UseRouting();
  254. //跨域
  255. app.UseCors("Limit");
  256. //认证
  257. app.UseAuthentication();
  258. //授权
  259. app.UseAuthorization();
  260. //配置端点
  261. app.UseEndpoints(endpoints =>
  262. {
  263. endpoints.MapControllers();
  264. });
  265. #endregion
  266. #region Swagger Api文档
  267. if (_env.IsDevelopment() || _appConfig.Swagger)
  268. {
  269. app.UseSwagger();
  270. app.UseSwaggerUI(c =>
  271. {
  272. typeof(ApiVersion).GetEnumNames().OrderByDescending(e => e).ToList().ForEach(version =>
  273. {
  274. c.SwaggerEndpoint($"/swagger/{version}/swagger.json", $"Admin.Core {version}");
  275. });
  276. c.RoutePrefix = "";//直接根目录访问
  277. });
  278. }
  279. #endregion
  280. }
  281. }
  282. }