Program.cs 3.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485
  1. using DinkToPdf;
  2. using DinkToPdf.Contracts;
  3. using Microsoft.Extensions.Configuration;
  4. using Microsoft.Extensions.DependencyInjection;
  5. using Microsoft.Extensions.DependencyInjection.Extensions;
  6. using Microsoft.Extensions.Hosting;
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Diagnostics;
  10. using System.IO;
  11. using System.Linq;
  12. using System.Net.Http;
  13. using System.Runtime.InteropServices;
  14. using System.Text;
  15. using System.Text.Json;
  16. using System.Text.RegularExpressions;
  17. using System.Threading;
  18. using System.Threading.Tasks;
  19. using TEAMModelOS.FunctionV4;
  20. using TEAMModelOS.FunctionV4.ServiceBus;
  21. using TEAMModelOS.Models;
  22. using TEAMModelOS.SDK;
  23. using TEAMModelOS.SDK.DI;
  24. using TEAMModelOS.SDK.DI.Multiple;
  25. namespace TEAMModelOS.FunctionV4
  26. {
  27. public static class Program
  28. {
  29. public static async Task Main(string[] args)
  30. {
  31. #if DEBUG
  32. Debugger.Launch();
  33. #endif
  34. var host = new HostBuilder()
  35. .ConfigureFunctionsWorkerDefaults(funccontext => {
  36. funccontext.UseMiddleware<TimeMonitorMiddleware>();
  37. } )
  38. .ConfigureAppConfiguration((context, configure) =>
  39. {
  40. //configure.AddCommandLine(args);
  41. // configure.AddJsonFile("local.settings.json", optional: true, reloadOnChange: true).AddEnvironmentVariables();
  42. })
  43. .ConfigureServices((context, services) =>
  44. {
  45. //services.Configure<Option>(options => context. Configuration.GetSection("Option").Bind(options));
  46. services.AddHttpClient();
  47. services.AddHttpClient<DingDing>();
  48. services.AddHttpClient<HttpTrigger>();
  49. //services.AddCoreAPIHttpService(context.Configuration);
  50. services.AddHttpClient<CoreAPIHttpService>().ConfigureHttpMessageHandlerBuilder(builder =>
  51. {
  52. builder.PrimaryHandler = new HttpClientHandler
  53. {
  54. ServerCertificateCustomValidationCallback = (message, cert, chain, errors) => true
  55. };
  56. });
  57. services.AddAzureCosmos(context.Configuration.GetSection("Azure:Cosmos:ConnectionString").Get<string>());
  58. services.AddAzureServiceBus(context.Configuration.GetSection("Azure:ServiceBus:ConnectionString").Get<string>());
  59. services.AddAzureRedis(context.Configuration.GetSection("Azure:Redis:ConnectionString").Get<string>());
  60. services.AddSingleton(typeof(IConverter), new SynchronizedConverter(new PdfTools()));
  61. services.AddSnowflakeId(Convert.ToInt64(context.Configuration.GetSection("Option:LocationNum").Get<Int32>()), 1);
  62. List<(string name, string connectionString)> storageConnects = new();
  63. storageConnects.Add(("Default", context.Configuration.GetSection("Azure:Storage:ConnectionString").Get<string>()));
  64. string LogStorageConnectionString = context.Configuration.GetSection("Azure:LogStorage:ConnectionString").Get<string>(); //防火墙日志统计文件
  65. if (!string.IsNullOrWhiteSpace(LogStorageConnectionString)) {
  66. storageConnects.Add(("LogStorage", LogStorageConnectionString)); //防火墙日志统计文件
  67. }
  68. services.AddMultipleAzureStorage(storageConnects);
  69. services.AddHostedService<BlobRootServiceBusSub>();
  70. services.AddIPSearcher("");
  71. })
  72. .Build();
  73. await host.RunAsync();
  74. }
  75. }
  76. }