HostedProtalServer.cs 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133
  1. using EVCB_OCPP.Domain.Extensions;
  2. using EVCB_OCPP.WSServer.Helper;
  3. using EVCB_OCPP.WSServer.Jobs;
  4. using EVCB_OCPP.WSServer.Message;
  5. using EVCB_OCPP.WSServer.Service;
  6. using EVCB_OCPP.WSServer.Service.WsService;
  7. using Microsoft.Extensions.Configuration;
  8. using Microsoft.Extensions.DependencyInjection;
  9. using Quartz;
  10. namespace EVCB_OCPP.WSServer
  11. {
  12. public static class HostedProtalServer
  13. {
  14. public static void AddProtalServer(this IServiceCollection services, IConfiguration configuration)
  15. {
  16. services.AddMemoryCache();
  17. //services.AddSingleton<IMemoryCache, DummyMemoryCache>();
  18. services.AddPortalServerDatabase(configuration);
  19. services.AddBusinessServiceFactory();
  20. services.AddSingleton<WebsocketService<WsClientData>>();
  21. services.AddSingleton<ServerMessageService>();
  22. services.AddSingleton<LoadingBalanceService>();
  23. services.AddSingleton<MeterValueDbService>();
  24. services.AddSingleton<WebDbService>();
  25. services.AddSingleton<IMainDbService, MainDbService>();
  26. services.AddSingleton<IConnectionLogdbService, ConnectionLogdbService>();
  27. services.AddTransient<ProfileHandler>();
  28. services.AddSingleton<ProtalServer>();
  29. services.AddHostedService<ProtalServer>(p => p.GetRequiredService<ProtalServer>());
  30. services.AddProtalServerJob();
  31. }
  32. internal static void AddPortalServerDatabase(this IServiceCollection services, IConfiguration configuration)
  33. {
  34. services
  35. .AddMainDbContext(configuration)
  36. .AddMeterValueDbContext(configuration)
  37. .AddConnectionLogDbContext(configuration)
  38. .AddWebDBConetext(configuration);
  39. }
  40. public static void AddProtalServerJob(this IServiceCollection services)
  41. {
  42. services.AddQuartz(q => {
  43. q.UseMicrosoftDependencyInjectionJobFactory();
  44. q.ScheduleJob<ServerUpdateJob>(trigger =>
  45. trigger
  46. .WithIdentity("ServerUpdateJobTrigger")
  47. .StartNow()
  48. .WithSimpleSchedule(x => x
  49. .WithIntervalInMinutes(3)
  50. .RepeatForever())
  51. );
  52. q.ScheduleJob<ServerSetFeeJob>(trigger =>
  53. trigger
  54. .WithIdentity("ServerSetFeeJobTrigger")
  55. .StartNow()
  56. .WithSimpleSchedule(x => x
  57. .WithIntervalInMinutes(1)
  58. .RepeatForever())
  59. );
  60. q.ScheduleJob<ServerMessageJob>(trigger =>
  61. trigger
  62. .WithIdentity("ServerMessageJobTrigger")
  63. .StartNow()
  64. .WithSimpleSchedule(x => x
  65. .WithInterval(TimeSpan.FromMilliseconds(500))
  66. .RepeatForever())
  67. );
  68. q.ScheduleJob<HeartBeatCheckJob>(trigger =>
  69. trigger
  70. .WithIdentity("HeartBeatCheckJobTrigger")
  71. .StartNow()
  72. .WithSimpleSchedule(x => x
  73. .WithIntervalInSeconds(30)
  74. .RepeatForever())
  75. );
  76. q.ScheduleJob<HealthCheckTriggerJob>(trigger =>
  77. trigger
  78. .WithIdentity("HealthCheckTriggerJobTrigger")
  79. .StartNow()
  80. .WithSimpleSchedule(x => x
  81. .WithIntervalInMinutes(1)
  82. .RepeatForever())
  83. );
  84. q.ScheduleJob<SmartChargingJob>(trigger =>
  85. trigger
  86. .WithIdentity("SmartChargingJobTrigger")
  87. .StartNow()
  88. .WithSimpleSchedule(x => x
  89. .WithIntervalInMinutes(1)
  90. .RepeatForever())
  91. );
  92. q.ScheduleJob<DenyModelCheckJob>(trigger =>
  93. trigger
  94. .WithIdentity("DenyModelCheckJobTrigger")
  95. .StartNow()
  96. .WithSimpleSchedule(x => x
  97. .WithIntervalInMinutes(5)
  98. .RepeatForever())
  99. );
  100. //q.ScheduleJob<GoogleCheckJob>(trigger =>
  101. // trigger
  102. // .WithIdentity("GoogleCheckJobTrigger")
  103. // .StartNow()
  104. // .WithSimpleSchedule(x => x
  105. // .WithIntervalInSeconds(5)
  106. // .RepeatForever())
  107. //);
  108. });
  109. services.AddQuartzHostedService(opt =>
  110. {
  111. opt.WaitForJobsToComplete = true;
  112. });
  113. }
  114. }
  115. }