Program.cs 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719
  1. using Microsoft.AspNetCore.Http.Connections;
  2. using Microsoft.AspNetCore.Http.Features;
  3. using Microsoft.AspNetCore.ResponseCompression;
  4. using Microsoft.AspNetCore.Server.Kestrel.Core;
  5. using Microsoft.Extensions.DependencyInjection.Extensions;
  6. using OASystem.API.Middlewares;
  7. using OASystem.API.OAMethodLib;
  8. using OASystem.API.OAMethodLib.AMapApi;
  9. using OASystem.API.OAMethodLib.APNs;
  10. using OASystem.API.OAMethodLib.DeepSeekAPI;
  11. using OASystem.API.OAMethodLib.GenericSearch;
  12. using OASystem.API.OAMethodLib.Hub.Hubs;
  13. using OASystem.API.OAMethodLib.JuHeAPI;
  14. using OASystem.API.OAMethodLib.QiYeWeChatAPI;
  15. using OASystem.API.OAMethodLib.Quartz.Jobs;
  16. using OASystem.API.OAMethodLib.SignalR.HubService;
  17. using OASystem.Infrastructure.Logging;
  18. using Quartz;
  19. using Quartz.Impl;
  20. using Quartz.Spi;
  21. using QuzrtzJob.Factory;
  22. using Serilog.Events;
  23. using System.IO.Compression;
  24. using static OASystem.API.Middlewares.RateLimitMiddleware;
  25. Console.Title = $"FMGJ OASystem Server";
  26. var builder = WebApplication.CreateBuilder(args);
  27. var basePath = AppContext.BaseDirectory;
  28. //引入配置文件
  29. var _config = new ConfigurationBuilder()
  30. .SetBasePath(basePath)
  31. .AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)
  32. .AddJsonFile("appsettings.Development.json", optional: true, reloadOnChange: true)
  33. .AddEnvironmentVariables()
  34. .Build();
  35. builder.Services.AddSingleton(new AppSettingsHelper(_config));
  36. //设置请求参数可不填
  37. builder.Services.AddControllers(options => options.SuppressImplicitRequiredAttributeForNonNullableReferenceTypes = true);
  38. //设置请求参数错误默认返回格式
  39. builder.Services.AddControllers()
  40. .ConfigureApiBehaviorOptions(options =>
  41. {
  42. options.InvalidModelStateResponseFactory = context =>
  43. {
  44. var errors = context.ModelState
  45. .Where(e => e.Value.Errors.Count > 0)
  46. .ToDictionary(
  47. kvp => kvp.Key,
  48. kvp => kvp.Value.Errors.Select(e => e.ErrorMessage).ToArray()
  49. );
  50. var result = new JsonView
  51. {
  52. Code = 400,
  53. Msg = errors.FirstOrDefault().Value.FirstOrDefault() ?? "",
  54. Data = errors
  55. };
  56. return new BadRequestObjectResult(result);
  57. };
  58. });
  59. // Add services to the container.
  60. builder.Services.AddControllersWithViews();
  61. builder.Services.AddControllers()
  62. .AddJsonOptions(options =>
  63. {
  64. //空字段不响应Response
  65. //options.JsonSerializerOptions.DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull;
  66. options.JsonSerializerOptions.Converters.Add(new NullJsonConverter());
  67. //时间格式化响应
  68. options.JsonSerializerOptions.Converters.Add(new DateTimeJsonConverter("yyyy-MM-dd HH:mm:ss"));
  69. //decimal 四位小数
  70. //options.JsonSerializerOptions.Converters.Add(new DecimalConverter(_decimalPlaces)); // 将保留小数位数参数传递给自定义序列化器
  71. });
  72. builder.Services.TryAddSingleton<IHttpContextAccessor, HttpContextAccessor>();
  73. #region 添加限流中间件服务注册
  74. // 添加内存缓存(限流需要)
  75. builder.Services.AddMemoryCache();
  76. // 配置限流设置
  77. builder.Services.Configure<RateLimitConfig>(
  78. builder.Configuration.GetSection("RateLimiting"));
  79. #endregion
  80. #region Gzip
  81. builder.Services.AddResponseCompression(options =>
  82. {
  83. options.EnableForHttps = true;
  84. options.Providers.Add<GzipCompressionProvider>();
  85. });
  86. builder.Services.Configure<GzipCompressionProviderOptions>(options =>
  87. {
  88. options.Level = CompressionLevel.Optimal;
  89. });
  90. #endregion
  91. #region Cors
  92. builder.Services.AddCors(policy =>
  93. {
  94. //policy.AddPolicy("Cors", opt => opt
  95. //.AllowAnyOrigin()
  96. //.AllowAnyHeader()
  97. //.AllowAnyMethod()
  98. //.WithExposedHeaders("X-Pagination"));
  99. policy.AddPolicy("Cors", opt => opt
  100. .SetIsOriginAllowed(origin =>
  101. {
  102. // 定义允许的来源列表
  103. var allowedOrigins = new List<string>
  104. {
  105. "http://132.232.92.186:9002"
  106. };
  107. // 检查请求的来源是否在允许的列表中
  108. return allowedOrigins.Contains(origin);
  109. })
  110. //.AllowAnyOrigin()
  111. .AllowAnyHeader()
  112. .WithMethods("GET", "POST", "HEAD", "PUT", "DELETE", "OPTIONS")
  113. .AllowCredentials());
  114. });
  115. #endregion
  116. #region 上传文件
  117. builder.Services.AddCors(policy =>
  118. {
  119. policy.AddPolicy("Cors", opt => opt
  120. .AllowAnyOrigin()
  121. .AllowAnyHeader()
  122. .AllowAnyMethod()
  123. .WithExposedHeaders("X-Pagination"));
  124. });
  125. builder.Services.Configure<FormOptions>(options =>
  126. {
  127. options.KeyLengthLimit = int.MaxValue;
  128. options.ValueLengthLimit = int.MaxValue;
  129. options.MultipartBodyLengthLimit = int.MaxValue;
  130. options.MultipartHeadersLengthLimit = int.MaxValue;
  131. });
  132. builder.Services.Configure<KestrelServerOptions>(options =>
  133. {
  134. options.Limits.MaxRequestBodySize = int.MaxValue;
  135. options.Limits.MaxRequestBufferSize = int.MaxValue;
  136. });
  137. #endregion
  138. #region 接口分组
  139. var groups = new List<Tuple<string, string>>
  140. {
  141. //new Tuple<string, string>("Group1","分组一"),
  142. //new Tuple<string, string>("Group2","分组二")
  143. };
  144. #endregion
  145. #region 注入数据库
  146. builder.Services.AddScoped(options =>
  147. {
  148. var cpuCount = Environment.ProcessorCount;
  149. var poolMin = Math.Max(5, cpuCount * 2);
  150. var poolMax = Math.Max(100, cpuCount * 20);
  151. return new SqlSugarClient(new List<ConnectionConfig>()
  152. {
  153. new() {
  154. ConfigId = DBEnum.OA2023DB,
  155. ConnectionString = _config.GetConnectionString("OA2023DB"),
  156. DbType = DbType.SqlServer,
  157. IsAutoCloseConnection = true,
  158. },
  159. new()
  160. {
  161. ConfigId = DBEnum.OA2014DB,
  162. ConnectionString = _config.GetConnectionString("OA2014DB"),
  163. DbType = DbType.SqlServer,
  164. IsAutoCloseConnection = true },
  165. }
  166. , db =>
  167. {
  168. //SQL执行完
  169. db.Aop.OnLogExecuted = (sql, pars) =>
  170. {
  171. //if (db.Ado.SqlExecutionTime.TotalSeconds > 1)
  172. //{
  173. //代码CS文件名
  174. var fileName = db.Ado.SqlStackTrace.FirstFileName;
  175. //代码行数
  176. var fileLine = db.Ado.SqlStackTrace.FirstLine;
  177. //方法名
  178. var FirstMethodName = db.Ado.SqlStackTrace.FirstMethodName;
  179. //执行完了可以输出SQL执行时间 (OnLogExecutedDelegate)
  180. Console.WriteLine("NowTime:" + DateTime.UtcNow.ToString("yyyy-MM-dd HH:mm:ss"));
  181. Console.WriteLine("MethodName:" + FirstMethodName);
  182. Console.WriteLine("ElapsedTime:" + db.Ado.SqlExecutionTime.ToString());
  183. Console.WriteLine("ExecuteSQL:" + sql);
  184. //}
  185. };
  186. //SQL执行前
  187. db.Aop.OnLogExecuting = (sql, pars) =>
  188. {
  189. //获取原生SQL推荐 5.1.4.63 性能OK
  190. UtilMethods.GetNativeSql(sql, pars);
  191. //获取无参数化SQL 影响性能只适合调试
  192. //UtilMethods.GetSqlString(DbType.SqlServer, sql, pars);
  193. if (pars != null || pars.Length > 0)
  194. {
  195. Console.WriteLine("============== 完整 SQL ==============");
  196. var resultSql = sql;
  197. foreach (var param in pars)
  198. {
  199. var par = param.Value;
  200. if (par != null)
  201. {
  202. var formattedValue = par switch
  203. {
  204. string str => $"'{str.Replace("'", "''")}'",
  205. DateTime date => $"'{date:yyyy-MM-dd HH:mm:ss}'",
  206. bool b => b ? "1" : "0",
  207. _ => par.ToString()
  208. };
  209. resultSql = resultSql.Replace(param.ParameterName, formattedValue);
  210. }
  211. }
  212. Console.WriteLine(resultSql);
  213. Console.WriteLine("=====================================");
  214. }
  215. };
  216. //SQL报错
  217. db.Aop.OnError = (exp) =>
  218. {
  219. //获取原生SQL推荐 5.1.4.63 性能OK
  220. //UtilMethods.GetNativeSql(exp.Sql, exp.Parametres);
  221. //获取无参数SQL对性能有影响,特别大的SQL参数多的,调试使用
  222. //UtilMethods.GetSqlString(DbType.SqlServer, exp.sql, exp.parameters);
  223. };
  224. //修改SQL和参数的值
  225. db.Aop.OnExecutingChangeSql = (sql, pars) =>
  226. {
  227. //sql=newsql
  228. //foreach(var p in pars) //修改
  229. return new KeyValuePair<string, SugarParameter[]>(sql, pars);
  230. };
  231. }
  232. );
  233. });
  234. #endregion
  235. //#region Identity 配置
  236. //builder.Services.AddDataProtection();
  237. ////不要用 AddIdentity , AddIdentity 是于MVC框架中的
  238. //builder.Services.AddIdentityCore<User>(opt =>
  239. //{
  240. // opt.Password.RequireDigit = false; //数字
  241. // opt.Password.RequireLowercase = false;//小写字母
  242. // opt.Password.RequireNonAlphanumeric = false;//特殊符号 例如 ¥#@!
  243. // opt.Password.RequireUppercase = false; //大写字母
  244. // opt.Password.RequiredLength = 6;//密码长度 6
  245. // opt.Password.RequiredUniqueChars = 1;//相同字符可以出现几次
  246. // opt.Lockout.MaxFailedAccessAttempts = 5; //允许最多输入五次用户名/密码错误
  247. // opt.Lockout.DefaultLockoutTimeSpan = new TimeSpan(0, 5, 0);//锁定五分钟
  248. // opt.Tokens.PasswordResetTokenProvider = TokenOptions.DefaultEmailProvider; // 修改密码使用邮件【验证码模式】
  249. // opt.Tokens.EmailConfirmationTokenProvider = TokenOptions.DefaultEmailProvider; ////
  250. //});
  251. //var idBuilder = new IdentityBuilder(typeof(User), typeof(UserRole), services);
  252. //idBuilder.AddEntityFrameworkStores<swapDbContext>().AddDefaultTokenProviders().AddRoleManager<RoleManager<UserRole>>().AddUserManager<UserManager<User>>();
  253. //#endregion
  254. #region 注入Swagger注释(启用)
  255. if (AppSettingsHelper.Get("UseSwagger").ToBool())
  256. {
  257. builder.Services.AddSwaggerGen(a =>
  258. {
  259. a.SwaggerDoc("v1", new OpenApiInfo
  260. {
  261. Version = "v1",
  262. Title = "Api",
  263. Description = "Api接口文档"
  264. });
  265. foreach (var item in groups)
  266. {
  267. a.SwaggerDoc(item.Item1, new OpenApiInfo { Version = item.Item1, Title = item.Item2, Description = $"{item.Item2}接口文档" });
  268. }
  269. a.DocumentFilter<SwaggerApi>();
  270. a.IncludeXmlComments(Path.Combine(basePath, "OASystem.Api.xml"), true);
  271. a.IncludeXmlComments(Path.Combine(basePath, "OASystem.Domain.xml"), true);
  272. a.AddSecurityDefinition("Bearer", new OpenApiSecurityScheme
  273. {
  274. Description = "Value: Bearer {token}",
  275. Name = "Authorization",
  276. In = ParameterLocation.Header,
  277. Type = SecuritySchemeType.ApiKey,
  278. Scheme = "Bearer"
  279. });
  280. a.AddSecurityRequirement(new OpenApiSecurityRequirement()
  281. {{
  282. new OpenApiSecurityScheme
  283. {
  284. Reference = new OpenApiReference
  285. {
  286. Type = ReferenceType.SecurityScheme,
  287. Id = "Bearer"
  288. }, Scheme = "oauth2", Name = "Bearer", In = ParameterLocation.Header }, new List<string>()
  289. }
  290. });
  291. });
  292. }
  293. #endregion
  294. #region 添加校验
  295. builder.Services.AddTransient<OASystemAuthentication>();
  296. builder.Services.AddAuthentication(JwtBearerDefaults.AuthenticationScheme)
  297. .AddJwtBearer(options =>
  298. {
  299. options.TokenValidationParameters = new TokenValidationParameters
  300. {
  301. ValidateIssuer = true,
  302. ValidateAudience = true,
  303. ValidateLifetime = true,
  304. ValidateIssuerSigningKey = true,
  305. ValidAudience = "OASystem.com",
  306. ValidIssuer = "OASystem.com",
  307. IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_config["JwtSecurityKey"])),
  308. ClockSkew = TimeSpan.FromSeconds(30), //过期时间容错值,解决服务器端时间不同步问题(秒)
  309. RequireExpirationTime = true,
  310. };
  311. options.Events = new JwtBearerEvents
  312. {
  313. OnMessageReceived = context =>
  314. {
  315. var path = context.HttpContext.Request.Path;
  316. //如果是signalr请求,需要将token转存,否则JWT获取不到token。OPTIONS请求需要过滤到,因为OPTIONS请求获取不到Token,用NGINX过滤掉OPTION请求.
  317. if (path.StartsWithSegments("/ChatHub"))
  318. {
  319. string accessToken = context.Request.Query["access_token"].ToString();
  320. if (string.IsNullOrWhiteSpace(accessToken))
  321. {
  322. accessToken = context.Request.Headers["Authorization"].ToString();
  323. }
  324. context.Token = accessToken.Replace("Bearer ", "").Trim();
  325. }
  326. return Task.CompletedTask;
  327. }
  328. };
  329. });
  330. #endregion
  331. #region 初始化日志
  332. var environment = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
  333. Log.Logger = new LoggerConfiguration()
  334. //不记录定时访问API
  335. .Filter.ByIncludingOnly(logEvent =>
  336. {
  337. if (logEvent.Properties.TryGetValue("RequestPath", out var pathValue))
  338. {
  339. var path = pathValue.ToString().Trim('"');
  340. return !path.StartsWith("/api/System/PotsMessageUnreadTotalCount");
  341. }
  342. return true;
  343. })
  344. .MinimumLevel.Information()
  345. .MinimumLevel.Override("Microsoft", LogEventLevel.Warning)
  346. .MinimumLevel.Override("System", LogEventLevel.Warning)
  347. .Enrich.FromLogContext()
  348. .WriteTo.Console()
  349. .WriteTo.File(Path.Combine("Logs", @"Log.txt"), rollingInterval: RollingInterval.Day)
  350. .CreateLogger();
  351. //
  352. #region 出入境费用明细 专用记录器
  353. // 指定磁盘绝对路径(示例:D盘的AppLogs文件夹)
  354. var logDirectory = @"D:\OASystem\Logs\EnterExitCost";
  355. // 自动创建目录(如果不存在)
  356. try
  357. {
  358. Directory.CreateDirectory(logDirectory);
  359. Log.Information($"日志目录已创建/确认存在: {logDirectory}");
  360. }
  361. catch (Exception ex)
  362. {
  363. Log.Fatal($"无法创建日志目录 {logDirectory}: {ex.Message}");
  364. throw;
  365. }
  366. var eec_TextLogger = new LoggerConfiguration()
  367. .MinimumLevel.Information()
  368. .WriteTo.File(Path.Combine(logDirectory, "text-records-.txt"), rollingInterval: RollingInterval.Month)
  369. .CreateLogger();
  370. #endregion
  371. #region 团组步骤操作 专用记录器
  372. // 指定磁盘绝对路径(示例:D盘的AppLogs文件夹)
  373. var groupLogDir = @"D:\OASystem\Logs\GroupStepOP";
  374. // 自动创建目录(如果不存在)
  375. try
  376. {
  377. Directory.CreateDirectory(groupLogDir);
  378. Log.Information($"日志目录已创建/确认存在: {groupLogDir}");
  379. }
  380. catch (Exception ex)
  381. {
  382. Log.Fatal($"无法创建日志目录 {groupLogDir}: {ex.Message}");
  383. throw;
  384. }
  385. var groupStepOP_TextLogger = new LoggerConfiguration()
  386. .MinimumLevel.Information()
  387. .WriteTo.File(Path.Combine(groupLogDir, "text-records-.txt"), rollingInterval: RollingInterval.Month)
  388. .CreateLogger();
  389. #endregion
  390. #region 任务分配操作 专用记录器
  391. // 指定磁盘绝对路径(示例:D盘的AppLogs文件夹)
  392. var taskLogDir = @"D:\OASystem\Logs\TaskAllocation";
  393. // 自动创建目录(如果不存在)
  394. try
  395. {
  396. Directory.CreateDirectory(taskLogDir);
  397. Log.Information($"日志目录已创建/确认存在: {taskLogDir}");
  398. }
  399. catch (Exception ex)
  400. {
  401. Log.Fatal($"无法创建日志目录 {taskLogDir}: {ex.Message}");
  402. throw;
  403. }
  404. var task_TextLogger = new LoggerConfiguration()
  405. .MinimumLevel.Information()
  406. .WriteTo.File(Path.Combine(taskLogDir, "text-records-.txt"), rollingInterval: RollingInterval.Month)
  407. .CreateLogger();
  408. #endregion
  409. // 配置Serilog为Log;
  410. builder.Host.UseSerilog();
  411. builder.Services.AddSingleton<ITextFileLogger>(new TextFileLogger(eec_TextLogger));
  412. builder.Services.AddSingleton<IGroupTextFileLogger>(new GroupTextFileLogger(groupStepOP_TextLogger));
  413. builder.Services.AddSingleton<ITaskTextFileLogger>(new TaskTextFileLogger(task_TextLogger));
  414. #endregion
  415. #region 引入注册Autofac Module
  416. builder.Host.UseServiceProviderFactory(new AutofacServiceProviderFactory());
  417. var hostBuilder = builder.Host.ConfigureContainer<ContainerBuilder>(builder =>
  418. {
  419. try
  420. {
  421. builder.RegisterModule(new AutofacRegister());
  422. }
  423. catch (Exception ex)
  424. {
  425. throw new Exception(ex.Message + "\n" + ex.InnerException);
  426. }
  427. });
  428. #endregion
  429. #region AutoMapper
  430. AutoMapper.IConfigurationProvider config = new MapperConfiguration(cfg =>
  431. {
  432. cfg.AddProfile<_baseMappingProfile>();
  433. });
  434. builder.Services.AddSingleton(config);
  435. builder.Services.AddScoped<IMapper, Mapper>();
  436. #endregion
  437. #region DeepSeek AI 服务
  438. // 配置HTTP客户端
  439. builder.Services.AddHttpClient<IDeepSeekService, DeepSeekService>();
  440. #endregion
  441. #region 聚合API 服务
  442. builder.Services.AddControllersWithViews();
  443. builder.Services.AddSingleton<IJuHeApiService, JuHeApiService>();
  444. builder.Services.AddHttpClient("PublicJuHeApi", c => c.BaseAddress = new Uri("http://web.juhe.cn"));
  445. builder.Services.AddHttpClient("PublicJuHeTranslateApi", c => c.BaseAddress = new Uri("http://apis.juhe.cn"));
  446. #endregion
  447. #region 企业微信API 服务
  448. builder.Services.AddControllersWithViews();
  449. builder.Services.AddSingleton<IQiYeWeChatApiService, QiYeWeChatApiService>();
  450. builder.Services.AddHttpClient("PublicQiYeWeChatApi", c => c.BaseAddress = new Uri("https://qyapi.weixin.qq.com"));
  451. #endregion
  452. #region 有道API 服务
  453. //builder.Services.AddControllersWithViews();
  454. //builder.Services.AddSingleton<IYouDaoApiService, YouDaoApiService>();
  455. //builder.Services.AddHttpClient("PublicYouDaoApi", c => c.BaseAddress = new Uri("https://openapi.youdao.com"));
  456. #endregion
  457. #region 高德地图API 服务
  458. builder.Services.AddHttpClient<GeocodeService>();
  459. #endregion
  460. #region 通用搜索服务
  461. builder.Services.AddScoped(typeof(DynamicSearchService<>));
  462. #endregion
  463. #region Quartz
  464. builder.Services.AddSingleton<ISchedulerFactory, StdSchedulerFactory>();
  465. builder.Services.AddSingleton<QuartzFactory>();
  466. builder.Services.AddSingleton<ALiYunPostMessageJob>();
  467. builder.Services.AddSingleton<TaskJob>();
  468. builder.Services.AddSingleton<TaskNewsFeedJob>();
  469. builder.Services.AddSingleton<PerformanceJob>();
  470. builder.Services.AddSingleton<GroupProcessNodeJob>();
  471. //# new business
  472. builder.Services.AddControllersWithViews();
  473. builder.Services.AddSingleton<IAPNsService, APNsService>();
  474. builder.Services.AddSingleton<IJobFactory, IOCJobFactory>();
  475. #endregion
  476. #region SignalR
  477. builder.Services.AddSignalR()
  478. .AddJsonProtocol(options =>
  479. {
  480. options.PayloadSerializerOptions.PropertyNamingPolicy = null;
  481. });
  482. builder.Services.TryAddSingleton(typeof(CommonService));
  483. #endregion
  484. var app = builder.Build();
  485. //// 1. 异常处理器应该在最早的位置(除了日志等)
  486. //app.UseExceptionHandler(new ExceptionHandlerOptions
  487. //{
  488. // ExceptionHandlingPath = "/Home/Error",
  489. // AllowStatusCode404Response = true
  490. //});
  491. //自定义异常中间件
  492. app.UseMiddleware<ExceptionHandlingMiddleware>();
  493. //serilog日志 请求中间管道
  494. app.UseSerilogRequestLogging(options =>
  495. {
  496. //options.MessageTemplate = "HTTP {RequestMethod} {RequestPath} from {ClientIP} (UA: {UserAgent}, Referer: {Referer}) - {StatusCode} in {Elapsed} ms";
  497. options.MessageTemplate = "HTTP {RequestMethod} {RequestPath} from {ClientIP} (UA: {UserAgent}) - {StatusCode} in {Elapsed} ms";
  498. // 自定义日志级别
  499. options.GetLevel = (httpContext, elapsed, ex) =>
  500. {
  501. if (ex != null) return LogEventLevel.Error;
  502. if (httpContext.Response.StatusCode > 499) return LogEventLevel.Error;
  503. // 对健康检查等端点使用更低级别
  504. if (httpContext.Request.Path.StartsWithSegments("/health"))
  505. return LogEventLevel.Debug;
  506. return LogEventLevel.Information;
  507. };
  508. // 丰富日志上下文
  509. options.EnrichDiagnosticContext = (diagnosticContext, httpContext) =>
  510. {
  511. // 获取客户端IP(处理代理情况)
  512. var ipAddress = CommonFun.GetClientIpAddress(httpContext);
  513. var userAgent = CommonFun.DetectOS(httpContext.Request.Headers.UserAgent.ToString());
  514. // 添加IP和其他有用信息到日志上下文
  515. diagnosticContext.Set("ClientIP", ipAddress);
  516. diagnosticContext.Set("RequestHost", httpContext.Request.Host.Value);
  517. diagnosticContext.Set("UserAgent", userAgent);
  518. diagnosticContext.Set("Referer", httpContext.Request.Headers.Referer.ToString());
  519. // 对于API请求添加额外信息
  520. if (httpContext.Request.Path.StartsWithSegments("/api"))
  521. {
  522. diagnosticContext.Set("RequestContentType", httpContext.Request.ContentType);
  523. diagnosticContext.Set("RequestContentLength", httpContext.Request.ContentLength ?? 0);
  524. }
  525. };
  526. });
  527. AutofacIocManager.Instance.Container = app.UseHostFiltering().ApplicationServices.GetAutofacRoot();//AutofacIocManager
  528. // Configure the HTTP request pipeline.
  529. if (!app.Environment.IsDevelopment())
  530. {
  531. app.UseExceptionHandler("/Home/Error");
  532. }
  533. app.UseStaticFiles();
  534. app.UseRouting();
  535. app.UseCors("Cors"); //Cors
  536. //app.UseMiddleware<FixedPromptMiddleware>();
  537. // 定义允许API的访问时间段
  538. //var startTime = DateTime.Parse(_config["ApiAccessTime:StartTime"]);
  539. //var endTime = DateTime.Parse(_config["ApiAccessTime:EndTime"]);
  540. //app.UseMiddleware<TimeRestrictionMiddleware>(startTime, endTime);
  541. //指定API操作记录信息
  542. app.UseMiddleware<RecordAPIOperationMiddleware>();
  543. app.UseAuthentication(); // 认证
  544. app.UseMiddleware<RateLimitMiddleware>();
  545. app.UseAuthorization(); // 授权
  546. app.UseWhen(context =>
  547. context.Request.Path.StartsWithSegments("/api/MarketCustomerResources/QueryNewClientData"),
  548. branch => branch.UseResponseCompression());
  549. // 授权路径
  550. //app.MapGet("generatetoken", c => c.Response.WriteAsync(JWTBearer.GenerateToken(c)));
  551. #region 启用swaggerUI
  552. if (AppSettingsHelper.Get("UseSwagger").ToBool())
  553. {
  554. app.UseSwagger();
  555. app.UseSwaggerUI(c =>
  556. {
  557. c.SwaggerEndpoint("/swagger/v1/swagger.json", "Ver0.1");
  558. foreach (var item in groups)
  559. {
  560. c.SwaggerEndpoint($"/swagger/{item.Item1}/swagger.json", item.Item2);
  561. }
  562. c.RoutePrefix = string.Empty;
  563. c.DocExpansion(Swashbuckle.AspNetCore.SwaggerUI.DocExpansion.None);
  564. c.DefaultModelsExpandDepth(-1);
  565. //c.EnableFilter();// 添加搜索功能
  566. //c.EnableDeepLinking(); // 启用深度链接
  567. });
  568. }
  569. #endregion
  570. #region Quartz
  571. //获取容器中的QuartzFactory
  572. var quartz = app.Services.GetRequiredService<QuartzFactory>();
  573. app.Lifetime.ApplicationStarted.Register(async () =>
  574. {
  575. await quartz.Start();
  576. });
  577. app.Lifetime.ApplicationStopped.Register(() =>
  578. {
  579. //Quzrtz关闭方法
  580. //quartz.Stop();
  581. });
  582. #endregion
  583. #region SignalR
  584. app.MapHub<ChatHub>("/ChatHub", options =>
  585. {
  586. options.Transports =
  587. HttpTransportType.WebSockets |
  588. HttpTransportType.LongPolling;
  589. });
  590. #endregion
  591. app.MapControllerRoute(
  592. name: "default",
  593. pattern: "{controller=Home}/{action=Index}/{id?}");
  594. app.Run();