noti probation

BMA.EHR.Placement.Service/Program.cs

@@ -10,11 +10,17 @@ using Microsoft.AspNetCore.Mvc.Versioning;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.IdentityModel.Logging;
 using Microsoft.IdentityModel.Tokens;
+using Hangfire;
+using Hangfire.Common;
+using Hangfire.MySql;
 using Serilog;
 using Serilog.Exceptions;
 using Serilog.Sinks.Elasticsearch;
 using System.Reflection;
 using System.Text;
+using System.Transactions;
+using BMA.EHR.Placement.Service.Filters;
+using BMA.EHR.Application.Repositories.Reports;
 
 var builder = WebApplication.CreateBuilder(args);
 {
@@ -89,7 +95,31 @@ var builder = WebApplication.CreateBuilder(args);
     builder.Services.AddSwaggerGen();
     builder.Services.ConfigureOptions<ConfigureSwaggerOptions>();
 
+    // Register DbContext
+    var defaultConnection = builder.Configuration.GetConnectionString("DefaultConnection");
+    builder.Services.AddDbContext<ApplicationDBContext>(options =>
+                    options.UseMySql(defaultConnection, ServerVersion.AutoDetect(defaultConnection)));
     builder.Services.AddHealthChecks();
+    // Add Hangfire services.
+    builder.Services.AddHangfire(configuration => configuration
+        .SetDataCompatibilityLevel(CompatibilityLevel.Version_170)
+        .UseSimpleAssemblyNameTypeSerializer()
+        .UseRecommendedSerializerSettings()
+        .UseStorage(
+            new MySqlStorage(
+                defaultConnection,
+                new MySqlStorageOptions
+                {
+                    TransactionIsolationLevel = IsolationLevel.ReadCommitted,
+                    QueuePollInterval = TimeSpan.FromSeconds(15),
+                    JobExpirationCheckInterval = TimeSpan.FromHours(1),
+                    CountersAggregateInterval = TimeSpan.FromMinutes(5),
+                    PrepareSchemaIfNecessary = true,
+                    DashboardJobListLimit = 50000,
+                    TransactionTimeout = TimeSpan.FromMinutes(1),
+                    TablesPrefix = "Hangfire"
+                })));
+    builder.Services.AddHangfireServer();
 }
 
 var app = builder.Build();
@@ -111,7 +141,7 @@ var app = builder.Build();
 
     app.MapHealthChecks("/health");
 
-    
+
     app.UseHttpsRedirection();
     app.UseCors();
     app.UseAuthentication();
@@ -120,6 +150,15 @@ var app = builder.Build();
     app.UseStaticFiles();
     app.MapControllers();
     app.UseMiddleware<ErrorHandlerMiddleware>();
+    app.UseHangfireDashboard("/hangfire", new DashboardOptions()
+    {
+        Authorization = new[] { new CustomAuthorizeFilter() }
+    });
+    var manager = new RecurringJobManager();
+    if (manager != null)
+    {
+        manager.AddOrUpdate("แจ้งเตือนระบบทดลองงาน", Job.FromExpression<ProbationReportRepository>(x => x.NotifyProbation()), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
+    }
 
     // apply migrations
     await using var scope = app.Services.CreateAsyncScope();