Program.cs 3.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182
  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.ServiceBus;
  20. using TEAMModelOS.Models;
  21. using TEAMModelOS.SDK;
  22. using TEAMModelOS.SDK.DI;
  23. using TEAMModelOS.SDK.DI.Multiple;
  24. namespace TEAMModelOS.FunctionV4
  25. {
  26. public static class Program
  27. {
  28. public static async Task Main(string[] args)
  29. {
  30. #if DEBUG
  31. Debugger.Launch();
  32. #endif
  33. var host = new HostBuilder()
  34. .ConfigureFunctionsWorkerDefaults()
  35. .ConfigureAppConfiguration((context, configure) =>
  36. {
  37. //configure.AddCommandLine(args);
  38. // configure.AddJsonFile("local.settings.json", optional: true, reloadOnChange: true).AddEnvironmentVariables();
  39. })
  40. .ConfigureServices((context, services) =>
  41. {
  42. //services.Configure<Option>(options => context. Configuration.GetSection("Option").Bind(options));
  43. services.AddHttpClient();
  44. services.AddHttpClient<DingDing>();
  45. //services.AddCoreAPIHttpService(context.Configuration);
  46. services.AddHttpClient<CoreAPIHttpService>().ConfigureHttpMessageHandlerBuilder(builder =>
  47. {
  48. builder.PrimaryHandler = new HttpClientHandler
  49. {
  50. ServerCertificateCustomValidationCallback = (message, cert, chain, errors) => true
  51. };
  52. });
  53. services.AddAzureCosmos(context.Configuration.GetSection("Azure:Cosmos:ConnectionString").Get<string>());
  54. services.AddAzureServiceBus(context.Configuration.GetSection("Azure:ServiceBus:ConnectionString").Get<string>());
  55. services.AddAzureRedis(context.Configuration.GetSection("Azure:Redis:ConnectionString").Get<string>());
  56. services.AddSingleton(typeof(IConverter), new SynchronizedConverter(new PdfTools()));
  57. services.AddSnowflakeId(Convert.ToInt64(context.Configuration.GetSection("Option:LocationNum").Get<Int32>()), 1);
  58. List<(string name, string connectionString)> storageConnects = new();
  59. storageConnects.Add(("Default", context.Configuration.GetSection("Azure:Storage:ConnectionString").Get<string>()));
  60. string LogStorageConnectionString = context.Configuration.GetSection("Azure:LogStorage:ConnectionString").Get<string>(); //防火墙日志统计文件
  61. if (!string.IsNullOrWhiteSpace(LogStorageConnectionString)) {
  62. storageConnects.Add(("LogStorage", LogStorageConnectionString)); //防火墙日志统计文件
  63. }
  64. services.AddMultipleAzureStorage(storageConnects);
  65. services.AddHostedService<BlobRootServiceBusSub>();
  66. services.AddIPSearcher("");
  67. })
  68. .Build();
  69. ThreadPool.SetMinThreads(200, 200);
  70. await host.RunAsync();
  71. }
  72. }
  73. }