Program.cs 10 KB

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