Program.cs 9.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326
  1. using StackExchange.Redis;
  2. using Autofac.Core;
  3. using OASystem.API;
  4. using OASystem.RedisRepository.RedisAsyncHelper;
  5. using OASystem.RedisRepository.Config;
  6. using OASystem.API.OAMethodLib;
  7. using Microsoft.AspNetCore.Http.Features;
  8. using Microsoft.AspNetCore.Server.Kestrel.Core;
  9. using OASystem.API.OAMethodLib.JuHeAPI;
  10. using OASystem.API.OAMethodLib.YouDaoAPI;
  11. using Quartz.Impl;
  12. using Quartz.Spi;
  13. using Quartz;
  14. using QuzrtzJob.Factory;
  15. using System.Runtime.CompilerServices;
  16. var builder = WebApplication.CreateBuilder(args);
  17. var basePath = AppContext.BaseDirectory;
  18. //引入配置文件
  19. var _config = new ConfigurationBuilder()
  20. .SetBasePath(basePath)
  21. .AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)
  22. .Build();
  23. builder.Services.AddSingleton(new AppSettingsHelper(_config));
  24. // Add services to the container.
  25. builder.Services.AddControllersWithViews();
  26. builder.Services.AddControllers()
  27. .AddJsonOptions(options =>
  28. {
  29. //空字段不响应Response
  30. //options.JsonSerializerOptions.DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull;
  31. options.JsonSerializerOptions.Converters.Add(new NullJsonConverter());
  32. //时间格式化响应
  33. options.JsonSerializerOptions.Converters.Add(new DateTimeJsonConverter("yyyy-MM-dd HH:mm:ss"));
  34. ////decimal 四位小数
  35. //options.JsonSerializerOptions.Converters.Add(new JsonConverterDecimal(0.0000M));
  36. });
  37. #region Cors
  38. builder.Services.AddCors(policy =>
  39. {
  40. policy.AddPolicy("Cors", opt => opt
  41. .AllowAnyOrigin()
  42. .AllowAnyHeader()
  43. .AllowAnyMethod()
  44. .WithExposedHeaders("X-Pagination"));
  45. });
  46. #endregion
  47. #region 上传文件
  48. builder.Services.AddCors(policy =>
  49. {
  50. policy.AddPolicy("Cors", opt => opt
  51. .AllowAnyOrigin()
  52. .AllowAnyHeader()
  53. .AllowAnyMethod()
  54. .WithExposedHeaders("X-Pagination"));
  55. });
  56. builder.Services.Configure<FormOptions>(options =>
  57. {
  58. options.KeyLengthLimit = int.MaxValue;
  59. options.ValueLengthLimit = int.MaxValue;
  60. options.MultipartBodyLengthLimit = int.MaxValue;
  61. options.MultipartHeadersLengthLimit = int.MaxValue;
  62. });
  63. builder.Services.Configure<KestrelServerOptions>(options =>
  64. {
  65. options.Limits.MaxRequestBodySize = int.MaxValue;
  66. options.Limits.MaxRequestBufferSize = int.MaxValue;
  67. });
  68. #endregion
  69. #region 接口分组
  70. var groups = new List<Tuple<string, string>>
  71. {
  72. //new Tuple<string, string>("Group1","分组一"),
  73. //new Tuple<string, string>("Group2","分组二")
  74. };
  75. #endregion
  76. #region 注入数据库
  77. builder.Services.AddScoped(options =>
  78. {
  79. return new SqlSugarClient(new List<ConnectionConfig>()
  80. {
  81. new ConnectionConfig() {
  82. ConfigId = DBEnum.OA2023DB,
  83. ConnectionString = _config.GetConnectionString("OA2023DB"),
  84. DbType = DbType.SqlServer, IsAutoCloseConnection = true },
  85. new ConnectionConfig()
  86. {
  87. ConfigId = DBEnum.OA2014DB,
  88. ConnectionString = _config.GetConnectionString("OA2014DB"),
  89. DbType = DbType.SqlServer, IsAutoCloseConnection = true },
  90. });
  91. });
  92. #endregion
  93. #region 注入Swagger注释(启用)
  94. if (AppSettingsHelper.Get("UseSwagger").ToBool())
  95. {
  96. builder.Services.AddSwaggerGen(a =>
  97. {
  98. a.SwaggerDoc("v1", new OpenApiInfo
  99. {
  100. Version = "v1",
  101. Title = "Api",
  102. Description = "Api接口文档"
  103. });
  104. foreach (var item in groups)
  105. {
  106. a.SwaggerDoc(item.Item1, new OpenApiInfo { Version = item.Item1, Title = item.Item2, Description = $"{item.Item2}接口文档" });
  107. }
  108. a.DocumentFilter<SwaggerApi>();
  109. a.IncludeXmlComments(Path.Combine(basePath, "OASystem.Api.xml"), true);
  110. a.IncludeXmlComments(Path.Combine(basePath, "OASystem.Domain.xml"), true);
  111. a.AddSecurityDefinition("Bearer", new OpenApiSecurityScheme
  112. {
  113. Description = "Value: Bearer {token}",
  114. Name = "Authorization",
  115. In = ParameterLocation.Header,
  116. Type = SecuritySchemeType.ApiKey,
  117. Scheme = "Bearer"
  118. });
  119. a.AddSecurityRequirement(new OpenApiSecurityRequirement()
  120. {{
  121. new OpenApiSecurityScheme
  122. {
  123. Reference = new OpenApiReference
  124. {
  125. Type = ReferenceType.SecurityScheme,
  126. Id = "Bearer"
  127. }, Scheme = "oauth2", Name = "Bearer", In = ParameterLocation.Header }, new List<string>()
  128. }
  129. });
  130. });
  131. }
  132. #endregion
  133. #region 添加swagger注释
  134. //if (AppSettingsHelper.Get("UseSwagger").ToBool())
  135. //{
  136. // builder.Services.AddSwaggerGen(c =>
  137. // {
  138. // c.SwaggerDoc("v1", new OpenApiInfo
  139. // {
  140. // Version = "v1",
  141. // Title = "文华商旅支付测试接口",
  142. // Description = "请先从Auth鉴权=>login获取token进行认证,输入:token进行认证(Bearer)"
  143. // });
  144. // c.DocumentFilter<SwaggerApi>();
  145. // var xmlPath = Path.Combine(basePath, "OASystem.API.xml");
  146. // c.IncludeXmlComments(xmlPath, true);
  147. // var xmlDomainPath = Path.Combine(basePath, "OASystem.Domain.xml");
  148. // c.IncludeXmlComments(xmlDomainPath, true);
  149. // c.AddSecurityDefinition("Bearer", new OpenApiSecurityScheme
  150. // {
  151. // Description = "Value: Bearer {token}",
  152. // Name = "Authorization",
  153. // In = ParameterLocation.Header,
  154. // Type = SecuritySchemeType.ApiKey,
  155. // Scheme = "Bearer"
  156. // });
  157. // c.AddSecurityRequirement(new OpenApiSecurityRequirement()
  158. // {
  159. // {
  160. // new OpenApiSecurityScheme
  161. // {
  162. // Reference = new OpenApiReference
  163. // {
  164. // Type = ReferenceType.SecurityScheme,
  165. // Id = "Bearer"
  166. // },Scheme = "oauth2",Name = "Bearer",In = ParameterLocation.Header,
  167. // },new List<string>()
  168. // }
  169. // });
  170. // });
  171. //}
  172. #endregion
  173. #region 添加校验
  174. //builder.Services.AddTransient<OASystemAuthentication>();
  175. builder.Services.AddAuthentication(JwtBearerDefaults.AuthenticationScheme)
  176. .AddJwtBearer(options =>
  177. {
  178. options.TokenValidationParameters = new TokenValidationParameters
  179. {
  180. ValidateIssuer = true,
  181. ValidateAudience = true,
  182. ValidateLifetime = true,
  183. ValidateIssuerSigningKey = true,
  184. ValidAudience = "OASystem.com",
  185. ValidIssuer = "OASystem.com",
  186. IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_config["JwtSecurityKey"])),
  187. ClockSkew = TimeSpan.FromSeconds(30), //过期时间容错值,解决服务器端时间不同步问题(秒)
  188. RequireExpirationTime = true,
  189. };
  190. });
  191. #endregion
  192. #region 初始化日志
  193. Log.Logger = new LoggerConfiguration()
  194. .MinimumLevel.Debug()
  195. .WriteTo.File(Path.Combine("Logs", @"Log.txt"), rollingInterval: RollingInterval.Day)
  196. .CreateLogger();
  197. #endregion
  198. #region 引入注册Autofac Module
  199. builder.Host.UseServiceProviderFactory(new AutofacServiceProviderFactory());
  200. var hostBuilder = builder.Host.ConfigureContainer<ContainerBuilder>(builder =>
  201. {
  202. try
  203. {
  204. builder.RegisterModule(new AutofacRegister());
  205. }
  206. catch (Exception ex)
  207. {
  208. throw new Exception(ex.Message + "\n" + ex.InnerException);
  209. }
  210. });
  211. #endregion
  212. #region AutoMapper
  213. AutoMapper.IConfigurationProvider config = new MapperConfiguration(cfg =>
  214. {
  215. cfg.AddProfile<_baseMappingProfile>();
  216. });
  217. builder.Services.AddSingleton(config);
  218. builder.Services.AddScoped<IMapper, Mapper>();
  219. #endregion
  220. #region 聚合API 服务
  221. builder.Services.AddControllersWithViews();
  222. builder.Services.AddSingleton<IJuHeApiService, JuHeApiService>();
  223. builder.Services.AddHttpClient("PublicJuHeApi", c => c.BaseAddress = new Uri("http://web.juhe.cn"));
  224. #endregion
  225. #region 有道API 服务
  226. //builder.Services.AddControllersWithViews();
  227. //builder.Services.AddSingleton<IYouDaoApiService, YouDaoApiService>();
  228. //builder.Services.AddHttpClient("PublicYouDaoApi", c => c.BaseAddress = new Uri("https://openapi.youdao.com"));
  229. #endregion
  230. #region Quartz
  231. builder.Services.AddSingleton<ISchedulerFactory, StdSchedulerFactory>();
  232. builder.Services.AddSingleton<QuartzFactory>();
  233. builder.Services.AddSingleton<ALiYunPostMessageJob>();
  234. //# new business
  235. builder.Services.AddSingleton<IJobFactory, IOCJobFactory>();
  236. #endregion
  237. var app = builder.Build();
  238. AutofacIocManager.Instance.Container = app.UseHostFiltering().ApplicationServices.GetAutofacRoot();//AutofacIocManager
  239. // Configure the HTTP request pipeline.
  240. if (!app.Environment.IsDevelopment())
  241. {
  242. app.UseExceptionHandler("/Home/Error");
  243. }
  244. app.UseStaticFiles();
  245. app.UseRouting();
  246. app.UseAuthentication(); // 认证
  247. app.UseAuthorization(); // 授权
  248. app.UseCors("Cors"); //Cors
  249. //app.UseCors("AllowSpecificOrigin"); //Cors
  250. #region 启用swaggerUI
  251. if (AppSettingsHelper.Get("UseSwagger").ToBool())
  252. {
  253. app.UseSwagger();
  254. app.UseSwaggerUI(c =>
  255. {
  256. c.SwaggerEndpoint("/swagger/v1/swagger.json", "Ver0.1");
  257. foreach (var item in groups)
  258. {
  259. c.SwaggerEndpoint($"/swagger/{item.Item1}/swagger.json", item.Item2);
  260. }
  261. c.RoutePrefix = string.Empty;
  262. c.DocExpansion(Swashbuckle.AspNetCore.SwaggerUI.DocExpansion.None);
  263. c.DefaultModelsExpandDepth(-1);
  264. });
  265. }
  266. #endregion
  267. #region Quartz
  268. //获取容器中的QuartzFactory
  269. var quartz = app.Services.GetRequiredService<QuartzFactory>();
  270. app.Lifetime.ApplicationStarted.Register(async () =>
  271. {
  272. await quartz.Start();
  273. });
  274. app.Lifetime.ApplicationStopped.Register(() =>
  275. {
  276. //Quzrtz关闭方法
  277. //quartz.Stop();
  278. });
  279. #endregion
  280. app.MapControllerRoute(
  281. name: "default",
  282. pattern: "{controller=Home}/{action=Index}/{id?}");
  283. app.Run();