Program.cs 10 KB

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