This commit is contained in:
parent
36aea81d54
commit
2187142668
2 changed files with 40 additions and 2 deletions
|
|
@ -286,6 +286,14 @@ namespace BMA.EHR.Insignia.Service.Controllers
|
||||||
|
|
||||||
#endregion
|
#endregion
|
||||||
|
|
||||||
|
[HttpGet("test")]
|
||||||
|
[AllowAnonymous]
|
||||||
|
public async Task<ActionResult<ResponseObject>> Test()
|
||||||
|
{
|
||||||
|
await _insigniaReportRepository.CalInsigniaRequestBkkByType("officer");
|
||||||
|
return Success();
|
||||||
|
}
|
||||||
|
|
||||||
#region " จัดทำรายชื่อครูที่มีสิทธิในการยืนขอเครื่องราชฯ "
|
#region " จัดทำรายชื่อครูที่มีสิทธิในการยืนขอเครื่องราชฯ "
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
|
|
||||||
|
|
@ -184,10 +184,26 @@ var app = builder.Build();
|
||||||
{
|
{
|
||||||
manager.AddOrUpdate("แจ้งเตือนรอบเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.NotifyInsignia()), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
|
manager.AddOrUpdate("แจ้งเตือนรอบเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.NotifyInsignia()), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
|
||||||
manager.AddOrUpdate("ล็อกข้อมูลรอบเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.LockInsignia()), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
|
manager.AddOrUpdate("ล็อกข้อมูลรอบเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.LockInsignia()), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
|
||||||
manager.AddOrUpdate("คำนวนผู้ได้รับเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.CalInsigniaRequestBkkByType("officer")), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
|
//manager.AddOrUpdate("คำนวนผู้ได้รับเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.CalInsigniaRequestBkkByType("officer")), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
|
||||||
manager.AddOrUpdate("คำนวนผู้ได้รับเครื่องราชฯ Employee", Job.FromExpression<InsigniaReportRepository>(x => x.CalInsigniaRequestBkkByType("employee")), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
|
//manager.AddOrUpdate("คำนวนผู้ได้รับเครื่องราชฯ Employee", Job.FromExpression<InsigniaReportRepository>(x => x.CalInsigniaRequestBkkByType("employee")), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
RecurringJob.AddOrUpdate<InsigniaReportRepository>(
|
||||||
|
"คำนวนผู้ได้รับเครื่องราชฯ",
|
||||||
|
x => x.CalInsigniaRequestBkkByType("officer"),
|
||||||
|
Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]),
|
||||||
|
Int32.Parse(builder.Configuration["KeycloakCron:Minute"])),
|
||||||
|
TimeZoneInfo.Local
|
||||||
|
);
|
||||||
|
|
||||||
|
RecurringJob.AddOrUpdate<InsigniaReportRepository>(
|
||||||
|
"คำนวนผู้ได้รับเครื่องราชฯ Employee",
|
||||||
|
x => x.CalInsigniaRequestBkkByType("employee"),
|
||||||
|
Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]) + 2,
|
||||||
|
Int32.Parse(builder.Configuration["KeycloakCron:Minute"])),
|
||||||
|
TimeZoneInfo.Local
|
||||||
|
);
|
||||||
|
|
||||||
// apply migrations
|
// apply migrations
|
||||||
await using var scope = app.Services.CreateAsyncScope();
|
await using var scope = app.Services.CreateAsyncScope();
|
||||||
await using var db = scope.ServiceProvider.GetRequiredService<ApplicationDBContext>();
|
await using var db = scope.ServiceProvider.GetRequiredService<ApplicationDBContext>();
|
||||||
|
|
@ -196,9 +212,23 @@ var app = builder.Build();
|
||||||
//var rabbitMQConsumer = app.Services.GetRequiredService<RabbitMQConsumer>();
|
//var rabbitMQConsumer = app.Services.GetRequiredService<RabbitMQConsumer>();
|
||||||
//rabbitMQConsumer.StartReceiving();
|
//rabbitMQConsumer.StartReceiving();
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
app.Run();
|
app.Run();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// เพิ่ม helper method
|
||||||
|
static async Task ExecuteJobWithScope(string type)
|
||||||
|
{
|
||||||
|
// ใช้ HttpContext current service provider
|
||||||
|
var scopeFactory = new HttpContextAccessor().HttpContext?
|
||||||
|
.RequestServices.GetRequiredService<IServiceScopeFactory>();
|
||||||
|
|
||||||
|
using var scope = scopeFactory.CreateScope();
|
||||||
|
var repo = scope.ServiceProvider.GetRequiredService<InsigniaReportRepository>();
|
||||||
|
await repo.CalInsigniaRequestBkkByType(type);
|
||||||
|
}
|
||||||
|
|
||||||
void ConfigureLogs()
|
void ConfigureLogs()
|
||||||
{
|
{
|
||||||
var environment = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
|
var environment = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue