259 lines
9 KiB
C#
259 lines
9 KiB
C#
using BMA.EHR.Application;
|
|
using BMA.EHR.Leave.Service;
|
|
using BMA.EHR.Domain.Middlewares;
|
|
using BMA.EHR.Infrastructure;
|
|
using BMA.EHR.Infrastructure.Persistence;
|
|
using Microsoft.AspNetCore.Authentication.JwtBearer;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.AspNetCore.Mvc.ApiExplorer;
|
|
using Microsoft.AspNetCore.Mvc.Versioning;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Microsoft.IdentityModel.Logging;
|
|
using Microsoft.IdentityModel.Tokens;
|
|
using Serilog;
|
|
using Serilog.Exceptions;
|
|
using Serilog.Sinks.Elasticsearch;
|
|
using System.Reflection;
|
|
using System.Text;
|
|
using Hangfire;
|
|
using Hangfire.MySql;
|
|
using System.Transactions;
|
|
using BMA.EHR.Leave.Service.Filters;
|
|
using Hangfire.Common;
|
|
using BMA.EHR.Application.Repositories.Leaves.TimeAttendants;
|
|
using BMA.EHR.Leave.Service.Extensions;
|
|
using BMA.EHR.Leave.Service.Services;
|
|
|
|
var builder = WebApplication.CreateBuilder(args);
|
|
// ตั้ง TimeZone เป็น Asia/Bangkok ในโค้ด
|
|
var bangkokTimeZone = TimeZoneInfo.FindSystemTimeZoneById("Asia/Bangkok");
|
|
TimeZoneInfo.ClearCachedData();
|
|
|
|
|
|
var issuer = builder.Configuration["Jwt:Issuer"];
|
|
var key = builder.Configuration["Jwt:Key"];
|
|
|
|
|
|
IdentityModelEventSource.ShowPII = true;
|
|
|
|
builder.Services.AddHttpContextAccessor();
|
|
|
|
builder.Services.AddApiVersioning(opt =>
|
|
{
|
|
opt.DefaultApiVersion = new ApiVersion(1, 0);
|
|
opt.AssumeDefaultVersionWhenUnspecified = true;
|
|
opt.ReportApiVersions = true;
|
|
opt.ApiVersionReader = ApiVersionReader.Combine(new UrlSegmentApiVersionReader(),
|
|
new HeaderApiVersionReader("x-api-version"),
|
|
new MediaTypeApiVersionReader("x-api-version"));
|
|
});
|
|
|
|
builder.Services.AddVersionedApiExplorer(setup =>
|
|
{
|
|
setup.GroupNameFormat = "'v'VVV";
|
|
setup.SubstituteApiVersionInUrl = true;
|
|
});
|
|
|
|
builder.Services.AddEndpointsApiExplorer();
|
|
|
|
// Authorization
|
|
builder.Services.AddAuthentication(JwtBearerDefaults.AuthenticationScheme).AddJwtBearer(opt =>
|
|
{
|
|
opt.SaveToken = true;
|
|
opt.RequireHttpsMetadata = false; //false for dev
|
|
opt.Authority = issuer;
|
|
opt.TokenValidationParameters = new()
|
|
{
|
|
ValidateIssuer = true,
|
|
ValidateAudience = false,
|
|
ValidateLifetime = true,
|
|
ValidateIssuerSigningKey = true,
|
|
ValidIssuer = issuer,
|
|
IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(key))
|
|
};
|
|
});
|
|
builder.Services.AddAuthorization();
|
|
|
|
// use serilog
|
|
//ConfigureLogs();
|
|
//builder.Host.UseSerilog();
|
|
|
|
// Add config CORS
|
|
builder.Services.AddCors(options => options.AddDefaultPolicy(builder =>
|
|
{
|
|
builder
|
|
.AllowAnyOrigin()
|
|
.AllowAnyMethod()
|
|
.AllowAnyHeader()
|
|
.SetIsOriginAllowedToAllowWildcardSubdomains();
|
|
}));
|
|
|
|
|
|
// Add services to the container.
|
|
builder.Services.AddApplication();
|
|
builder.Services.AddLeaveApplication();
|
|
builder.Services.AddPersistence(builder.Configuration);
|
|
builder.Services.AddLeavePersistence(builder.Configuration);
|
|
builder.Services.AddTransient<HolidayService>();
|
|
|
|
// Configure HttpClient with increased timeout for long-running operations (e.g., RabbitMQ Management API)
|
|
builder.Services.AddHttpClient();
|
|
builder.Services.AddTransient(sp =>
|
|
{
|
|
var httpClient = sp.GetRequiredService<IHttpClientFactory>().CreateClient();
|
|
httpClient.Timeout = TimeSpan.FromMinutes(10); // Set timeout to 10 minutes
|
|
return httpClient;
|
|
});
|
|
|
|
builder.Services.AddControllers(options =>
|
|
{
|
|
options.SuppressAsyncSuffixInActionNames = false;
|
|
})
|
|
.AddNewtonsoftJson(x => x.SerializerSettings.ReferenceLoopHandling = Newtonsoft.Json.ReferenceLoopHandling.Ignore);
|
|
|
|
builder.Services.AddSwaggerGen();
|
|
builder.Services.ConfigureOptions<ConfigureSwaggerOptions>();
|
|
|
|
builder.Services.AddHealthChecks();
|
|
|
|
builder.Services.AddRabbitMqConnectionPooling(builder.Configuration);
|
|
|
|
// Add Hangfire services.
|
|
var hangfireConnection = builder.Configuration.GetConnectionString("defaultConnection");
|
|
|
|
builder.Services.AddHangfire(configuration => configuration
|
|
.SetDataCompatibilityLevel(CompatibilityLevel.Version_170)
|
|
.UseSimpleAssemblyNameTypeSerializer()
|
|
.UseRecommendedSerializerSettings()
|
|
.UseStorage(
|
|
new MySqlStorage(
|
|
hangfireConnection,
|
|
new MySqlStorageOptions
|
|
{
|
|
QueuePollInterval = TimeSpan.FromSeconds(15),
|
|
JobExpirationCheckInterval = TimeSpan.FromHours(1),
|
|
CountersAggregateInterval = TimeSpan.FromMinutes(5),
|
|
PrepareSchemaIfNecessary = true,
|
|
DashboardJobListLimit = 50000,
|
|
TransactionTimeout = TimeSpan.FromMinutes(1),
|
|
InvisibilityTimeout = TimeSpan.FromHours(3),
|
|
TablesPrefix = "Hangfire_Leave"
|
|
})));
|
|
builder.Services.AddHangfireServer(options =>
|
|
{
|
|
options.ServerName = "Leave-Server"; // ← ระบุชื่อ server
|
|
options.WorkerCount = 5; // ←
|
|
options.Queues = new[] { "leave","default" }; // ← worker จะรันเฉพาะ queue "leave"
|
|
});
|
|
|
|
|
|
var app = builder.Build();
|
|
|
|
var apiVersionDescriptionProvider = app.Services.GetRequiredService<IApiVersionDescriptionProvider>();
|
|
|
|
if (app.Environment.IsDevelopment())
|
|
{
|
|
app.UseSwagger();
|
|
app.UseSwaggerUI(options =>
|
|
{
|
|
foreach (var description in apiVersionDescriptionProvider.ApiVersionDescriptions)
|
|
{
|
|
options.SwaggerEndpoint($"/swagger/{description.GroupName}/swagger.json",
|
|
description.GroupName.ToUpperInvariant());
|
|
}
|
|
});
|
|
}
|
|
|
|
app.MapHealthChecks("/health");
|
|
|
|
|
|
app.UseHttpsRedirection();
|
|
app.UseCors();
|
|
|
|
app.UseMiddleware<CombinedErrorHandlerAndLoggingMiddleware>();
|
|
|
|
app.UseAuthentication();
|
|
app.UseAuthorization();
|
|
|
|
app.UseDefaultFiles();
|
|
app.UseStaticFiles();
|
|
app.MapControllers();
|
|
// app.UseMiddleware<ErrorHandlerMiddleware>();
|
|
// // Disable ก่อน เพื่อแก้ไขให้เรีบร้อยก่อนการใช้งาน
|
|
// app.UseMiddleware<RequestLoggingMiddleware>();
|
|
|
|
|
|
|
|
app.UseHangfireDashboard("/hangfire", new DashboardOptions()
|
|
{
|
|
Authorization = new[] { new CustomAuthorizeFilter() }
|
|
});
|
|
|
|
var manager = new RecurringJobManager();
|
|
if (manager != null)
|
|
{
|
|
manager.AddOrUpdate("ปรับปรุงรอบการลงเวลาทำงาน", Job.FromExpression<UserDutyTimeRepository>(x => x.UpdateUserDutyTime()), "0 1 * * *", bangkokTimeZone);
|
|
// ทำความสะอาดข้อมูล CheckIn Job Status ที่เก่ากว่า 30 วัน - รันทุกวันเวลา 02:00 น.
|
|
manager.AddOrUpdate("ทำความสะอาดข้อมูล CheckIn Job Status", Job.FromExpression<CheckInJobStatusRepository>(x => x.CleanupOldJobsAsync(30)), "0 2 * * *", bangkokTimeZone);
|
|
|
|
manager.AddOrUpdate("ประมวลผลงานที่ค้างอยู่ในสถานะ Pending หรือ Processing", Job.FromExpression<LeaveProcessJobStatusRepository>(x => x.ProcessPendingJobsAsync()), "0 3 * * *",
|
|
new RecurringJobOptions
|
|
{
|
|
TimeZone = bangkokTimeZone,
|
|
QueueName = "leave" // ← กำหนด queue
|
|
});
|
|
}
|
|
|
|
// apply migrations
|
|
await using var scope = app.Services.CreateAsyncScope();
|
|
await using var db = scope.ServiceProvider.GetRequiredService<LeaveDbContext>();
|
|
await db.Database.MigrateAsync();
|
|
|
|
// seed default data
|
|
await LeaveSeeder.SeedLeaveType(app);
|
|
|
|
app.Run();
|
|
|
|
|
|
void ConfigureLogs()
|
|
{
|
|
var environment = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
|
|
var configuration = new ConfigurationBuilder()
|
|
.AddJsonFile("appsettings.json", optional: false, reloadOnChange: true)
|
|
.AddJsonFile(
|
|
$"appsettings.{Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT")}.json",
|
|
optional: true)
|
|
.Build();
|
|
|
|
Log.Logger = new LoggerConfiguration()
|
|
.WriteTo.Console() // แสดง Log บน Console
|
|
.WriteTo.Elasticsearch(new ElasticsearchSinkOptions(new Uri("http://192.168.1.40:9200"))
|
|
{
|
|
AutoRegisterTemplate = true,
|
|
IndexFormat = "bma-ehr-log-test" // เก็บเป็น daily index
|
|
})
|
|
.CreateLogger();
|
|
|
|
Log.Information("Test Log to Elasticsearch");
|
|
|
|
//Log.Logger = new LoggerConfiguration()
|
|
// .Enrich.FromLogContext()
|
|
// .MinimumLevel.Error()
|
|
// .WriteTo.Console()
|
|
// .Enrich.WithExceptionDetails()
|
|
// .WriteTo.Elasticsearch(ConfigureElasticSink(configuration, environment ?? ""))
|
|
// .Enrich.WithProperty("Environment", environment)
|
|
// .ReadFrom.Configuration(configuration)
|
|
// .CreateLogger();
|
|
}
|
|
|
|
ElasticsearchSinkOptions ConfigureElasticSink(IConfigurationRoot configuration, string environment)
|
|
{
|
|
return new ElasticsearchSinkOptions(new Uri(configuration["ElasticConfiguration:Uri"] ?? ""))
|
|
{
|
|
AutoRegisterTemplate = true,
|
|
//IndexFormat = "bma-ehr-log-index-netS",
|
|
IndexFormat = $"{Assembly.GetExecutingAssembly()?.GetName()?.Name?.ToLower().Replace(".", "-")}-{environment?.ToLower().Replace(".", "-")}"
|
|
};
|
|
}
|
|
|