diff --git a/.claude/settings.local.json b/.claude/settings.local.json deleted file mode 100644 index a8da82e..0000000 --- a/.claude/settings.local.json +++ /dev/null @@ -1,11 +0,0 @@ -{ - "permissions": { - "allow": [ - "Bash(dotnet build:*)", - "WebSearch", - "Bash(dotnet add:*)" - ], - "deny": [], - "ask": [] - } -} diff --git a/BMA.EHR.Recruit.Service.csproj.user b/BMA.EHR.Recruit.Service.csproj.user new file mode 100644 index 0000000..96e63d6 --- /dev/null +++ b/BMA.EHR.Recruit.Service.csproj.user @@ -0,0 +1,9 @@ + + + + https + + + ProjectDebugger + + \ No newline at end of file diff --git a/BMA.EHR.Recruit.csproj b/BMA.EHR.Recruit.csproj index c148fa1..eca7d61 100644 --- a/BMA.EHR.Recruit.csproj +++ b/BMA.EHR.Recruit.csproj @@ -22,10 +22,7 @@ - - - diff --git a/CLAUDE.md b/CLAUDE.md deleted file mode 100644 index 273523d..0000000 --- a/CLAUDE.md +++ /dev/null @@ -1,76 +0,0 @@ -# CLAUDE.md - -This file provides guidance to Claude Code (claude.ai/code) when working with code in this repository. - -## Build & Run - -```bash -dotnet build BMA.EHR.Recruit.Service.sln -dotnet build BMA.EHR.Recruit.Service.sln -c Release -dotnet publish -c Release -o /app/publish /p:UseAppHost=false -``` - -No test projects exist in this solution. - -## Architecture - -**Stack:** ASP.NET Core 7.0 Web API / EF Core 7.0 / MySQL (Pomelo) / MinIO (S3) / Keycloak (JWT) - -**Pattern:** Controllers → Services → EF Core DbContext (no repository layer for main data) - -### Multiple DbContexts -Three separate MySQL databases, each with its own `DbContext`: -- `ApplicationDbContext` — Recruitment data (Recruits, Scores, Imports) -- `OrgDbContext` — Organization data -- `MetadataDbContext` — Metadata - -All registered as `Transient` lifetime. Auto-migration runs on startup. - -### Controllers -- `BaseController` provides standardized `Success()` / `Error()` response methods returning `ResponseObject` (Status, Message, Result) -- `RecruitController` is the sole business controller (route: `api/v{version}/recruit`) -- API versioning enabled via `Microsoft.AspNetCore.Mvc.Versioning` - -### Background Import System -Excel file imports run asynchronously through a Channel-based queue: -- `ImportBackgroundService` (BackgroundService) — dequeues and processes jobs -- `ImportJobQueue` — bounded Channel (capacity 100) -- `ImportJobTracker` — in-memory ConcurrentDictionary tracking - -Four import types: `CandidateFile`, `CandidateFileById`, `ScoreFile`, `ResultFile` - -All imports use `EFCore.BulkExtensions.MySql` (v6.7.16) for bulk operations to handle 50,000+ rows without memory issues. Pattern: -1. Insert parent/history entities via `SaveChangesAsync` (small operations) -2. `ChangeTracker.Clear()` to release references -3. Collect entities into separate `List` per table -4. `BulkInsertAsync` with `SetOutputIdentity = true` for parent entities -5. Assign generated Ids to child entities -6. `BulkInsertAsync` for each child entity table separately -7. Batch size: 500 - -### Entity Models -All entities inherit from `EntityBase` (Guid `Id` PK, audit fields: `CreatedAt`, `CreatedUserId`, `LastUpdatedAt`, etc.). Models are in `Models/` with subdirectories: `Recruits/`, `Documents/`, `HR/`, `MetaData/`, `Placement/`. - -Key relationships use navigation properties without explicit FK properties (EF shadow properties). Configured via fluent API in `OnModelCreating`. - -### External Services -- **Authentication:** Keycloak JWT Bearer (`hrmsbkk-id.case-collection.com/realms/hrms`) -- **File Storage:** MinIO via `MinIOService` (AWS S3 SDK) -- **Search/Logging:** Elasticsearch (NEST client) -- **Excel:** EPPlus for reading import files - -## Key Files - -- `Program.cs` — Service registration, middleware pipeline, auto-migration -- `Data/ApplicationDbContext.cs` — EF Core fluent API relationship configuration -- `Services/ImportBackgroundService.cs` — All bulk import logic (4 import methods) -- `Services/RecruitService.cs` — Core business logic -- `Controllers/BaseController.cs` — Standard response helpers -- `Responses/ResponseObject.cs` — Standard API response envelope - -## Conventions - -- Language: C# with nullable reference types enabled -- Naming: PascalCase properties, `_camelCase` parameters in service methods -- API responses: Always wrapped in `ResponseObject` -- Authorization: `[Authorize]` on controllers, user context from JWT claims diff --git a/Controllers/RecruitController.cs b/Controllers/RecruitController.cs index 7d246ff..bbf38c3 100644 --- a/Controllers/RecruitController.cs +++ b/Controllers/RecruitController.cs @@ -377,7 +377,6 @@ namespace BMA.EHR.Recruit.Controllers try { var data = await _context.RecruitImports.AsQueryable() - .AsNoTracking() .Include(x => x.RecruitImages) .ThenInclude(x => x.Document) .Include(x => x.RecruitDocuments) @@ -718,11 +717,9 @@ namespace BMA.EHR.Recruit.Controllers var doc = await _minioService.UploadFileAsync(file); var import_doc_id = doc.Id.ToString("D"); - // Write file to disk directly from IFormFile instead of downloading back from MinIO - using (var stream = new FileStream(importFile, FileMode.Create)) - { - await file.CopyToAsync(stream); - } + var fileContent = (await _minioService.DownloadFileAsync(doc.Id)).FileContent; + System.IO.File.WriteAllBytes(importFile, fileContent); + fileContent = null; // สร้างรอบการบรรจุ var imported = new RecruitImport @@ -758,7 +755,6 @@ namespace BMA.EHR.Recruit.Controllers ImportDocId = import_doc_id, UserId = UserId, FullName = FullName, - Token = token, Request = req, }); await _importJobQueue.EnqueueAsync(job); @@ -934,11 +930,9 @@ namespace BMA.EHR.Recruit.Controllers var doc = await _minioService.UploadFileAsync(file); var import_doc_id = doc.Id.ToString("D"); - // Write file to disk directly from IFormFile instead of downloading back from MinIO - using (var stream = new FileStream(importFile, FileMode.Create)) - { - await file.CopyToAsync(stream); - } + var fileContent = (await _minioService.DownloadFileAsync(doc.Id)).FileContent; + System.IO.File.WriteAllBytes(importFile, fileContent); + fileContent = null; // Enqueue background job var job = _importJobTracker.CreateJob(new ImportJobInfo @@ -949,7 +943,6 @@ namespace BMA.EHR.Recruit.Controllers ImportDocId = import_doc_id, UserId = UserId, FullName = FullName, - Token = token, }); await _importJobQueue.EnqueueAsync(job); @@ -1020,7 +1013,6 @@ namespace BMA.EHR.Recruit.Controllers ImportDocId = import_doc_id, UserId = UserId, FullName = FullName, - Token = token, }); await _importJobQueue.EnqueueAsync(job); @@ -1090,7 +1082,6 @@ namespace BMA.EHR.Recruit.Controllers RecruitImportId = id, UserId = UserId, FullName = FullName, - Token = token, }); await _importJobQueue.EnqueueAsync(job); @@ -2010,7 +2001,6 @@ namespace BMA.EHR.Recruit.Controllers public async Task> ExportExamAsync(Guid id) { var data = await _context.RecruitImports.AsQueryable() - .AsNoTracking() .Include(x => x.Recruits) .FirstOrDefaultAsync(x => x.Id == id); @@ -2519,7 +2509,6 @@ namespace BMA.EHR.Recruit.Controllers public async Task GetCandidateNewListReportAsync(Guid id) { var data = await _context.Recruits.AsQueryable() - .AsNoTracking() .Include(x => x.RecruitImport) .Where(x => x.RecruitImport.Id == id) .OrderBy(x => x.ExamId) diff --git a/Data/ApplicationDbContext.cs b/Data/ApplicationDbContext.cs index d386d19..81e4fd6 100644 --- a/Data/ApplicationDbContext.cs +++ b/Data/ApplicationDbContext.cs @@ -20,7 +20,6 @@ namespace BMA.EHR.Recruit.Data modelBuilder.Entity().HasMany(x => x.Addresses).WithOne(x => x.Recruit).OnDelete(DeleteBehavior.Cascade); modelBuilder.Entity().HasMany(x => x.Certificates).WithOne(x => x.Recruit).OnDelete(DeleteBehavior.Cascade); modelBuilder.Entity().HasMany(x => x.Payments).WithOne(x => x.Recruit).OnDelete(DeleteBehavior.Cascade); - modelBuilder.Entity().HasMany(x => x.Scores).WithOne(x => x.ScoreImport).HasForeignKey(x => x.ScoreImportId).OnDelete(DeleteBehavior.Cascade); } public DbSet Documents { get; set; } diff --git a/Dockerfile b/Dockerfile index 0ee996f..ea318e6 100644 --- a/Dockerfile +++ b/Dockerfile @@ -20,9 +20,4 @@ RUN dotnet publish "BMA.EHR.Recruit.csproj" -c Release -o /app/publish /p:UseApp FROM base AS final WORKDIR /app COPY --from=publish /app/publish . - -# GC configuration for better memory management in containers -#ENV DOTNET_GCHeapHardLimit=1073741824 -#ENV DOTNET_GCConserveMemory=9 - ENTRYPOINT ["dotnet", "BMA.EHR.Recruit.dll"] \ No newline at end of file diff --git a/Migrations/20260519102256_fix relation.Designer.cs b/Migrations/20260519102256_fix relation.Designer.cs deleted file mode 100644 index 770f155..0000000 --- a/Migrations/20260519102256_fix relation.Designer.cs +++ /dev/null @@ -1,1605 +0,0 @@ -// -using System; -using BMA.EHR.Recruit.Data; -using Microsoft.EntityFrameworkCore; -using Microsoft.EntityFrameworkCore.Infrastructure; -using Microsoft.EntityFrameworkCore.Migrations; -using Microsoft.EntityFrameworkCore.Storage.ValueConversion; - -#nullable disable - -namespace BMA.EHR.Recruit.Migrations -{ - [DbContext(typeof(ApplicationDbContext))] - [Migration("20260519102256_fix relation")] - partial class fixrelation - { - /// - protected override void BuildTargetModel(ModelBuilder modelBuilder) - { -#pragma warning disable 612, 618 - modelBuilder - .HasAnnotation("ProductVersion", "7.0.3") - .HasAnnotation("Relational:MaxIdentifierLength", 64); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Documents.Document", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)"); - - b.Property("CreatedDate") - .HasColumnType("datetime(6)"); - - b.Property("Detail") - .IsRequired() - .HasColumnType("text"); - - b.Property("FileName") - .IsRequired() - .HasMaxLength(255) - .HasColumnType("varchar(255)"); - - b.Property("FileSize") - .HasColumnType("int"); - - b.Property("FileType") - .IsRequired() - .HasMaxLength(128) - .HasColumnType("varchar(128)"); - - b.Property("ObjectRefId") - .HasColumnType("char(36)"); - - b.HasKey("Id"); - - b.ToTable("Documents"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.Recruit", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("ApplyDate") - .HasColumnType("datetime(6)"); - - b.Property("CitizenCardExpireDate") - .HasColumnType("datetime(6)"); - - b.Property("CitizenCardIssuer") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("CitizenId") - .IsRequired() - .HasMaxLength(13) - .HasColumnType("varchar(13)") - .HasComment("เลขประจำตัวประชาชน"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedDate") - .HasColumnType("datetime(6)"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("DateOfBirth") - .HasColumnType("datetime(6)"); - - b.Property("ExamId") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("FirstName") - .IsRequired() - .HasMaxLength(150) - .HasColumnType("varchar(150)"); - - b.Property("Gendor") - .IsRequired() - .HasMaxLength(20) - .HasColumnType("varchar(20)"); - - b.Property("HddPosition") - .HasColumnType("longtext") - .HasComment("บัญชีสอบ"); - - b.Property("Isspecial") - .IsRequired() - .HasMaxLength(1) - .HasColumnType("varchar(1)"); - - b.Property("LastName") - .IsRequired() - .HasMaxLength(150) - .HasColumnType("varchar(150)"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("Marry") - .IsRequired() - .HasMaxLength(20) - .HasColumnType("varchar(20)"); - - b.Property("ModifiedDate") - .HasColumnType("datetime(6)"); - - b.Property("National") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("PositionLevel") - .HasColumnType("longtext"); - - b.Property("PositionName") - .HasColumnType("longtext"); - - b.Property("PositionType") - .HasColumnType("longtext"); - - b.Property("Prefix") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("Qualified") - .IsRequired() - .HasMaxLength(1) - .HasColumnType("varchar(1)"); - - b.Property("Race") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("RecruitImportId") - .HasColumnType("char(36)"); - - b.Property("RefNo") - .IsRequired() - .HasMaxLength(20) - .HasColumnType("varchar(20)"); - - b.Property("Religion") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Remark") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("typeTest") - .HasColumnType("longtext") - .HasComment("ประเภทการสอบภาค ก."); - - b.HasKey("Id"); - - b.HasIndex("RecruitImportId"); - - b.ToTable("Recruits"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitAddress", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("Address") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Address1") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Amphur") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Amphur1") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("District") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("District1") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("Mobile") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Moo") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Moo1") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Province") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Province1") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("RecruitId") - .HasColumnType("char(36)"); - - b.Property("Road") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Road1") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Soi") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Soi1") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Telephone") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("ZipCode") - .IsRequired() - .HasMaxLength(10) - .HasColumnType("varchar(10)"); - - b.Property("ZipCode1") - .IsRequired() - .HasMaxLength(10) - .HasColumnType("varchar(10)"); - - b.HasKey("Id"); - - b.HasIndex("RecruitId"); - - b.ToTable("RecruitAddresses"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitCertificate", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("CertificateNo") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("Description") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("ExpiredDate") - .HasColumnType("datetime(6)"); - - b.Property("IssueDate") - .HasColumnType("datetime(6)"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("RecruitId") - .HasColumnType("char(36)"); - - b.HasKey("Id"); - - b.HasIndex("RecruitId"); - - b.ToTable("RecruitCertificates"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitDocument", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedDate") - .HasColumnType("datetime(6)"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("DocumentFileId") - .HasColumnType("char(36)"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("RecruitId") - .HasColumnType("char(36)"); - - b.HasKey("Id"); - - b.HasIndex("DocumentFileId"); - - b.HasIndex("RecruitId"); - - b.ToTable("RecruitDocuments"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitEducation", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("BachelorDate") - .HasColumnType("datetime(6)"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("Degree") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("GPA") - .HasColumnType("double"); - - b.Property("HighDegree") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("Major") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("MajorGroupId") - .IsRequired() - .HasMaxLength(20) - .HasColumnType("varchar(20)"); - - b.Property("MajorGroupName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("RecruitId") - .HasColumnType("char(36)"); - - b.Property("Specialist") - .IsRequired() - .HasMaxLength(1000) - .HasColumnType("varchar(1000)"); - - b.Property("University") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.HasKey("Id"); - - b.HasIndex("RecruitId"); - - b.ToTable("RecruitEducations"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitImport", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("AnnouncementDate") - .HasColumnType("datetime(6)") - .HasColumnOrder(14) - .HasComment("วันที่ประกาศผลสอบ"); - - b.Property("AnnouncementEndDate") - .HasColumnType("datetime(6)") - .HasColumnOrder(7) - .HasComment("วันสิ้นสุดประกาศ"); - - b.Property("AnnouncementStartDate") - .HasColumnType("datetime(6)") - .HasColumnOrder(6) - .HasComment("วันเริ่มประกาศ"); - - b.Property("AuthName") - .HasColumnType("longtext"); - - b.Property("AuthPosition") - .HasColumnType("longtext"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("Detail") - .HasColumnType("longtext") - .HasColumnOrder(4) - .HasComment("รายละเอียด"); - - b.Property("ExamDate") - .HasColumnType("datetime(6)") - .HasColumnOrder(12) - .HasComment("วันที่สอบ"); - - b.Property("Fee") - .HasColumnType("int") - .HasColumnOrder(5) - .HasComment("ค่าธรรมเนียม"); - - b.Property("ImportFileId") - .HasColumnType("char(36)"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("Name") - .IsRequired() - .HasMaxLength(250) - .HasColumnType("varchar(250)") - .HasColumnOrder(2) - .HasComment("รอบการสอบ"); - - b.Property("Note") - .HasColumnType("text") - .HasColumnOrder(13) - .HasComment("หมายเหตุ"); - - b.Property("Order") - .HasColumnType("int") - .HasColumnOrder(3) - .HasComment("ครั้งที่"); - - b.Property("PaymentEndDate") - .HasColumnType("datetime(6)") - .HasColumnOrder(9) - .HasComment("วันสิ้นสุดชำระเงิน"); - - b.Property("PaymentStartDate") - .HasColumnType("datetime(6)") - .HasColumnOrder(8) - .HasComment("วันเริ่มชำระเงิน"); - - b.Property("RegisterEndDate") - .HasColumnType("datetime(6)") - .HasColumnOrder(11) - .HasComment("วันสิ้นสุดสมัครสอบ"); - - b.Property("RegisterStartDate") - .HasColumnType("datetime(6)") - .HasColumnOrder(10) - .HasComment("วันเริ่มสมัครสอบ"); - - b.Property("Year") - .HasColumnType("int") - .HasColumnOrder(1) - .HasComment("ปีงบประมาณที่จัดสอบ"); - - b.HasKey("Id"); - - b.HasIndex("ImportFileId"); - - b.ToTable("RecruitImports"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitImportDocument", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("DocumentId") - .HasColumnType("char(36)") - .HasComment("Id เอกสาร"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("RecruitImportId") - .HasColumnType("char(36)") - .HasComment("Id รอบสมัครสอบ"); - - b.HasKey("Id"); - - b.HasIndex("DocumentId"); - - b.HasIndex("RecruitImportId"); - - b.ToTable("RecruitImportDocuments"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitImportHistory", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("Description") - .IsRequired() - .HasColumnType("longtext") - .HasColumnOrder(1) - .HasComment("รายละเอียดการนำเข้า"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("RecruitImportId") - .HasColumnType("char(36)"); - - b.HasKey("Id"); - - b.HasIndex("RecruitImportId"); - - b.ToTable("RecruitImportHistories"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitImportImage", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("DocumentId") - .HasColumnType("char(36)") - .HasComment("Id ไฟล์รูป"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("RecruitImportId") - .HasColumnType("char(36)") - .HasComment("Id รอบสมัครสอบ"); - - b.HasKey("Id"); - - b.HasIndex("DocumentId"); - - b.HasIndex("RecruitImportId"); - - b.ToTable("RecruitImportImages"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitOccupation", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("Occupation") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Position") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("RecruitId") - .HasColumnType("char(36)"); - - b.Property("Telephone") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("WorkAge") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Workplace") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.HasKey("Id"); - - b.HasIndex("RecruitId"); - - b.ToTable("RecruitOccupations"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitPayment", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("AccountNumber") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("Amount") - .HasColumnType("decimal(65,30)"); - - b.Property("BankCode") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("ChequeNo") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("ChqueBankCode") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("CompanyCode") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("CreditDebit") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("CustomerName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("PaymentId") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("PaymentType") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("RecruitId") - .HasColumnType("char(36)"); - - b.Property("RefNo1") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("TellerId") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("TermBranch") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("TextFile") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("TransDate") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("TransTime") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.HasKey("Id"); - - b.HasIndex("RecruitId"); - - b.ToTable("RecruitPayments"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitScore", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("ABStatus") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)") - .HasComment("ภาคความรู้ความสามารถที่ใช้เฉพาะตำแหน่ง ผลประเมิน"); - - b.Property("AStatus") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)") - .HasComment("ภาคความรู้ความสามารถที่ใช้เฉพาะตำแหน่ง ผลประเมิน"); - - b.Property("BStatus") - .HasMaxLength(50) - .HasColumnType("varchar(50)"); - - b.Property("CStatus") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)") - .HasComment("ภาคความเหมาะสมกับตำแหน่ง ผลประเมิน"); - - b.Property("CitizenId") - .IsRequired() - .HasMaxLength(13) - .HasColumnType("varchar(13)") - .HasComment("เลขประจำตัวประชาชน"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("ExamAttribute") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)") - .HasComment("สถานะคัดกรองคุณสมบัติ"); - - b.Property("ExamId") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)") - .HasComment("เลขประจำตัวสอบ"); - - b.Property("ExamStatus") - .IsRequired() - .HasMaxLength(50) - .HasColumnType("varchar(50)") - .HasComment("สอบได้ / ตก / ขาดสอบ"); - - b.Property("FullA") - .HasColumnType("int") - .HasComment("ภาคความรู้ความสามารถที่ใช้เฉพาะตำแหน่ง คะแนนเต็ม"); - - b.Property("FullB") - .HasColumnType("int"); - - b.Property("FullC") - .HasColumnType("int") - .HasComment("ภาคความเหมาะสมกับตำแหน่ง ทดสอบสมรรถนะ+ทดสอบจิตวิทยาฯ คะแนนเต็ม"); - - b.Property("FullD") - .HasColumnType("int") - .HasComment("ภาคความเหมาะสมกับตำแหน่ง สัมภาษณ์ คะแนนเต็ม"); - - b.Property("FullScore") - .HasColumnType("int") - .HasComment("คะแนนเต็ม"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("Major") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)"); - - b.Property("Number") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasComment("ลำดับที่สอบได้"); - - b.Property("PercentageA") - .HasColumnType("double") - .HasComment("ภาคความรู้ความสามารถที่ใช้เฉพาะตำแหน่ง ร้อยละ"); - - b.Property("PercentageB") - .HasColumnType("double"); - - b.Property("PercentageC") - .HasColumnType("double") - .HasComment("ภาคความเหมาะสมกับตำแหน่ง ร้อยละ"); - - b.Property("RemarkExamOrder") - .IsRequired() - .HasColumnType("longtext") - .HasComment("หมายเหตุจากลำดับที่สอบได้"); - - b.Property("RemarkScore") - .IsRequired() - .HasColumnType("longtext") - .HasComment("หมายเหตุจากบัญชีรวมคะแนน"); - - b.Property("ScoreImportId") - .HasColumnType("char(36)"); - - b.Property("SumA") - .HasColumnType("double") - .HasComment("ภาคความรู้ความสามารถที่ใช้เฉพาะตำแหน่ง คะแนนรวม"); - - b.Property("SumAB") - .HasColumnType("double") - .HasComment("ภาคความรู้ความสามารถที่ใช้เฉพาะตำแหน่ง คะแนนรวม"); - - b.Property("SumB") - .HasColumnType("double"); - - b.Property("SumC") - .HasColumnType("double") - .HasComment("ภาคความเหมาะสมกับตำแหน่ง ทดสอบสมรรถนะ+ทดสอบจิตวิทยาฯ คะแนนรวม"); - - b.Property("SumCD") - .HasColumnType("double") - .HasComment("ภาคความเหมาะสมกับตำแหน่ง คะแนนรวมทดสอบสมรรถนะ+ทดสอบจิตวิทยาฯ และสัมภาษณ์"); - - b.Property("SumD") - .HasColumnType("double") - .HasComment("ภาคความเหมาะสมกับตำแหน่ง สัมภาษณ์ คะแนนรวม"); - - b.Property("TotalScore") - .HasColumnType("double") - .HasComment("คะแนนรวม"); - - b.HasKey("Id"); - - b.HasIndex("ScoreImportId"); - - b.ToTable("RecruitScores"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.ScoreImport", b => - { - b.Property("Id") - .ValueGeneratedOnAdd() - .HasColumnType("char(36)") - .HasColumnOrder(0) - .HasComment("PrimaryKey") - .HasAnnotation("Relational:JsonPropertyName", "id"); - - b.Property("CreatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(100) - .HasComment("สร้างข้อมูลเมื่อ"); - - b.Property("CreatedFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(104) - .HasComment("ชื่อ User ที่สร้างข้อมูล"); - - b.Property("CreatedUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(101) - .HasComment("User Id ที่สร้างข้อมูล"); - - b.Property("ImportFileId") - .HasColumnType("char(36)"); - - b.Property("LastUpdateFullName") - .IsRequired() - .HasMaxLength(200) - .HasColumnType("varchar(200)") - .HasColumnOrder(105) - .HasComment("ชื่อ User ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdateUserId") - .IsRequired() - .HasMaxLength(40) - .HasColumnType("varchar(40)") - .HasColumnOrder(103) - .HasComment("User Id ที่แก้ไขข้อมูลล่าสุด"); - - b.Property("LastUpdatedAt") - .HasColumnType("datetime(6)") - .HasColumnOrder(102) - .HasComment("แก้ไขข้อมูลล่าสุดเมื่อ"); - - b.Property("RecruitImportId") - .HasColumnType("char(36)"); - - b.Property("Year") - .HasColumnType("int"); - - b.HasKey("Id"); - - b.HasIndex("ImportFileId"); - - b.HasIndex("RecruitImportId") - .IsUnique(); - - b.ToTable("ScoreImports"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.Recruit", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Recruits.RecruitImport", "RecruitImport") - .WithMany("Recruits") - .HasForeignKey("RecruitImportId") - .OnDelete(DeleteBehavior.Cascade); - - b.Navigation("RecruitImport"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitAddress", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Recruits.Recruit", "Recruit") - .WithMany("Addresses") - .HasForeignKey("RecruitId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("Recruit"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitCertificate", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Recruits.Recruit", "Recruit") - .WithMany("Certificates") - .HasForeignKey("RecruitId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("Recruit"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitDocument", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Documents.Document", "DocumentFile") - .WithMany() - .HasForeignKey("DocumentFileId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.HasOne("BMA.EHR.Recruit.Models.Recruits.Recruit", "Recruit") - .WithMany("Documents") - .HasForeignKey("RecruitId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("DocumentFile"); - - b.Navigation("Recruit"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitEducation", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Recruits.Recruit", "Recruit") - .WithMany("Educations") - .HasForeignKey("RecruitId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("Recruit"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitImport", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Documents.Document", "ImportFile") - .WithMany() - .HasForeignKey("ImportFileId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("ImportFile"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitImportDocument", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Documents.Document", "Document") - .WithMany() - .HasForeignKey("DocumentId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.HasOne("BMA.EHR.Recruit.Models.Recruits.RecruitImport", "RecruitImport") - .WithMany("RecruitDocuments") - .HasForeignKey("RecruitImportId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("Document"); - - b.Navigation("RecruitImport"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitImportHistory", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Recruits.RecruitImport", "RecruitImport") - .WithMany("ImportHostories") - .HasForeignKey("RecruitImportId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("RecruitImport"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitImportImage", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Documents.Document", "Document") - .WithMany() - .HasForeignKey("DocumentId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.HasOne("BMA.EHR.Recruit.Models.Recruits.RecruitImport", "RecruitImport") - .WithMany("RecruitImages") - .HasForeignKey("RecruitImportId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("Document"); - - b.Navigation("RecruitImport"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitOccupation", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Recruits.Recruit", "Recruit") - .WithMany("Occupations") - .HasForeignKey("RecruitId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("Recruit"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitPayment", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Recruits.Recruit", "Recruit") - .WithMany("Payments") - .HasForeignKey("RecruitId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("Recruit"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitScore", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Recruits.ScoreImport", "ScoreImport") - .WithMany("Scores") - .HasForeignKey("ScoreImportId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("ScoreImport"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.ScoreImport", b => - { - b.HasOne("BMA.EHR.Recruit.Models.Documents.Document", "ImportFile") - .WithMany() - .HasForeignKey("ImportFileId"); - - b.HasOne("BMA.EHR.Recruit.Models.Recruits.RecruitImport", "RecruitImport") - .WithOne("ScoreImport") - .HasForeignKey("BMA.EHR.Recruit.Models.Recruits.ScoreImport", "RecruitImportId") - .OnDelete(DeleteBehavior.Cascade) - .IsRequired(); - - b.Navigation("ImportFile"); - - b.Navigation("RecruitImport"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.Recruit", b => - { - b.Navigation("Addresses"); - - b.Navigation("Certificates"); - - b.Navigation("Documents"); - - b.Navigation("Educations"); - - b.Navigation("Occupations"); - - b.Navigation("Payments"); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.RecruitImport", b => - { - b.Navigation("ImportHostories"); - - b.Navigation("RecruitDocuments"); - - b.Navigation("RecruitImages"); - - b.Navigation("Recruits"); - - b.Navigation("ScoreImport") - .IsRequired(); - }); - - modelBuilder.Entity("BMA.EHR.Recruit.Models.Recruits.ScoreImport", b => - { - b.Navigation("Scores"); - }); -#pragma warning restore 612, 618 - } - } -} diff --git a/Migrations/20260519102256_fix relation.cs b/Migrations/20260519102256_fix relation.cs deleted file mode 100644 index bf91e02..0000000 --- a/Migrations/20260519102256_fix relation.cs +++ /dev/null @@ -1,64 +0,0 @@ -using System; -using Microsoft.EntityFrameworkCore.Migrations; - -#nullable disable - -namespace BMA.EHR.Recruit.Migrations -{ - /// - public partial class fixrelation : Migration - { - /// - protected override void Up(MigrationBuilder migrationBuilder) - { - migrationBuilder.DropForeignKey( - name: "FK_ScoreImports_Documents_ImportFileId", - table: "ScoreImports"); - - migrationBuilder.AlterColumn( - name: "ImportFileId", - table: "ScoreImports", - type: "char(36)", - nullable: true, - collation: "ascii_general_ci", - oldClrType: typeof(Guid), - oldType: "char(36)") - .OldAnnotation("Relational:Collation", "ascii_general_ci"); - - migrationBuilder.AddForeignKey( - name: "FK_ScoreImports_Documents_ImportFileId", - table: "ScoreImports", - column: "ImportFileId", - principalTable: "Documents", - principalColumn: "Id"); - } - - /// - protected override void Down(MigrationBuilder migrationBuilder) - { - migrationBuilder.DropForeignKey( - name: "FK_ScoreImports_Documents_ImportFileId", - table: "ScoreImports"); - - migrationBuilder.AlterColumn( - name: "ImportFileId", - table: "ScoreImports", - type: "char(36)", - nullable: false, - defaultValue: new Guid("00000000-0000-0000-0000-000000000000"), - collation: "ascii_general_ci", - oldClrType: typeof(Guid), - oldType: "char(36)", - oldNullable: true) - .OldAnnotation("Relational:Collation", "ascii_general_ci"); - - migrationBuilder.AddForeignKey( - name: "FK_ScoreImports_Documents_ImportFileId", - table: "ScoreImports", - column: "ImportFileId", - principalTable: "Documents", - principalColumn: "Id", - onDelete: ReferentialAction.Cascade); - } - } -} diff --git a/Migrations/ApplicationDbContextModelSnapshot.cs b/Migrations/ApplicationDbContextModelSnapshot.cs index 94e7f07..d849857 100644 --- a/Migrations/ApplicationDbContextModelSnapshot.cs +++ b/Migrations/ApplicationDbContextModelSnapshot.cs @@ -1353,7 +1353,7 @@ namespace BMA.EHR.Recruit.Migrations .HasColumnOrder(101) .HasComment("User Id ที่สร้างข้อมูล"); - b.Property("ImportFileId") + b.Property("ImportFileId") .HasColumnType("char(36)"); b.Property("LastUpdateFullName") @@ -1550,7 +1550,9 @@ namespace BMA.EHR.Recruit.Migrations { b.HasOne("BMA.EHR.Recruit.Models.Documents.Document", "ImportFile") .WithMany() - .HasForeignKey("ImportFileId"); + .HasForeignKey("ImportFileId") + .OnDelete(DeleteBehavior.Cascade) + .IsRequired(); b.HasOne("BMA.EHR.Recruit.Models.Recruits.RecruitImport", "RecruitImport") .WithOne("ScoreImport") diff --git a/Models/Recruits/RecruitScore.cs b/Models/Recruits/RecruitScore.cs index 93024f1..9698b3f 100644 --- a/Models/Recruits/RecruitScore.cs +++ b/Models/Recruits/RecruitScore.cs @@ -1,6 +1,5 @@ using Microsoft.EntityFrameworkCore; using System.ComponentModel.DataAnnotations; -using System.ComponentModel.DataAnnotations.Schema; namespace BMA.EHR.Recruit.Models.Recruits { @@ -84,9 +83,6 @@ namespace BMA.EHR.Recruit.Models.Recruits [MaxLength(50), Comment("สถานะคัดกรองคุณสมบัติ")] public string ExamAttribute { get; set; } = string.Empty; - [ForeignKey("ScoreImport")] - public Guid ScoreImportId { get; set; } - public ScoreImport ScoreImport { get; set; } } } diff --git a/Models/Recruits/ScoreImport.cs b/Models/Recruits/ScoreImport.cs index 413f3f2..badee62 100644 --- a/Models/Recruits/ScoreImport.cs +++ b/Models/Recruits/ScoreImport.cs @@ -7,9 +7,7 @@ namespace BMA.EHR.Recruit.Models.Recruits { public int Year { get; set; } - public Guid? ImportFileId { get; set; } - - public Document ImportFile { get; set; } + public Document ImportFile { get; set; } = new Document(); public virtual List Scores { get; set; } = new List(); diff --git a/Program.cs b/Program.cs index 3475b74..f39a56c 100644 --- a/Program.cs +++ b/Program.cs @@ -69,7 +69,6 @@ builder.Services.AddAuthorization(); // Register Services builder.Services.AddTransient(); builder.Services.AddTransient(); -builder.Services.AddTransient(); builder.Services.AddTransient(); builder.Services.AddSingleton(); builder.Services.AddSingleton(); diff --git a/Services/ImportBackgroundService.cs b/Services/ImportBackgroundService.cs index 7628ad0..3c2c0c2 100644 --- a/Services/ImportBackgroundService.cs +++ b/Services/ImportBackgroundService.cs @@ -4,13 +4,12 @@ using BMA.EHR.Recruit.Services; using Microsoft.AspNetCore.Http; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.Logging; +using OfficeOpenXml; using System.Net.Http.Headers; using BMA.EHR.Recruit.Data; using BMA.EHR.Recruit.Extensions; -using EFCore.BulkExtensions; using BMA.EHR.Recruit.Models.Recruits; using BMA.EHR.Recruit.Requests.Recruits; -using ExcelDataReader; namespace BMA.EHR.Recruit.Services; @@ -41,63 +40,59 @@ public class ImportBackgroundService : BackgroundService { var job = await _queue.DequeueAsync(stoppingToken); - using var scope = _scopeFactory.CreateScope(); - var context = scope.ServiceProvider.GetRequiredService(); - var minioService = scope.ServiceProvider.GetRequiredService(); - var recruitService = scope.ServiceProvider.GetRequiredService(); - var notificationService = scope.ServiceProvider.GetRequiredService(); - var webHostEnv = scope.ServiceProvider.GetRequiredService(); - var logger = scope.ServiceProvider.GetRequiredService>(); - - try + _ = Task.Run(async () => { - _tracker.UpdateStatus(job.JobId, ImportJobStatus.Running); + using var scope = _scopeFactory.CreateScope(); + var context = scope.ServiceProvider.GetRequiredService(); + var minioService = scope.ServiceProvider.GetRequiredService(); + var recruitService = scope.ServiceProvider.GetRequiredService(); + var webHostEnv = scope.ServiceProvider.GetRequiredService(); + var logger = scope.ServiceProvider.GetRequiredService>(); - switch (job.JobType) - { - case ImportJobType.CandidateFile: - await ProcessCandidateFileAsync(context, minioService, webHostEnv, job); - break; - case ImportJobType.CandidateFileById: - await ProcessCandidateFileByIdAsync(context, minioService, recruitService, webHostEnv, job); - break; - case ImportJobType.ScoreFile: - await ProcessScoreFileAsync(context, minioService, recruitService, job); - break; - case ImportJobType.ResultFile: - await ProcessResultFileAsync(context, recruitService, job); - break; - } - - _tracker.UpdateStatus(job.JobId, ImportJobStatus.Completed, job.TotalCount); - - await notificationService.SendImportNotificationAsync(job.Token, false, "ระบบนำเข้าข้อมูลสำเร็จ"); - job.Token = null; // Clear token after notification sent - } - catch (Exception ex) - { - logger.LogError(ex, "Import job {JobId} failed: {Message}", job.JobId, ex.Message); - _tracker.UpdateStatus(job.JobId, ImportJobStatus.Failed, 0, ex.Message); - - try { await notificationService.SendImportNotificationAsync(job.Token, true, ex.Message); } catch { } - job.Token = null; // Clear token after notification sent - - // cleanup minio file on failure - if (!string.IsNullOrEmpty(job.ImportDocId)) - { - try { await minioService.DeleteFileAsync(Guid.Parse(job.ImportDocId)); } catch { } - } - } - finally - { - // cleanup temp file try { - if (System.IO.File.Exists(job.ImportFile)) - System.IO.File.Delete(job.ImportFile); + _tracker.UpdateStatus(job.JobId, ImportJobStatus.Running); + + switch (job.JobType) + { + case ImportJobType.CandidateFile: + await ProcessCandidateFileAsync(context, minioService, webHostEnv, job); + break; + case ImportJobType.CandidateFileById: + await ProcessCandidateFileByIdAsync(context, minioService, recruitService, webHostEnv, job); + break; + case ImportJobType.ScoreFile: + await ProcessScoreFileAsync(context, minioService, recruitService, job); + break; + case ImportJobType.ResultFile: + await ProcessResultFileAsync(context, recruitService, job); + break; + } + + _tracker.UpdateStatus(job.JobId, ImportJobStatus.Completed, job.TotalCount); } - catch { } - } + catch (Exception ex) + { + logger.LogError(ex, "Import job {JobId} failed: {Message}", job.JobId, ex.Message); + _tracker.UpdateStatus(job.JobId, ImportJobStatus.Failed, 0, ex.InnerException?.Message ?? ex.Message); + + // cleanup minio file on failure + if (!string.IsNullOrEmpty(job.ImportDocId)) + { + try { await minioService.DeleteFileAsync(Guid.Parse(job.ImportDocId)); } catch { } + } + } + finally + { + // cleanup temp file + try + { + if (System.IO.File.Exists(job.ImportFile)) + System.IO.File.Delete(job.ImportFile); + } + catch { } + } + }, stoppingToken); } } @@ -108,203 +103,138 @@ public class ImportBackgroundService : BackgroundService var imported = await _context.RecruitImports.FindAsync(job.RecruitImportId); if (imported == null) throw new Exception("RecruitImport not found"); - System.Text.Encoding.RegisterProvider(System.Text.CodePagesEncodingProvider.Instance); - using var stream = System.IO.File.OpenRead(job.ImportFile); - using var reader = ExcelReaderFactory.CreateReader(stream); - - do + using var c_package = new ExcelPackage(new FileInfo(job.ImportFile)); + for (int i = 0; i < c_package.Workbook.Worksheets.Count; i++) { - // Read header row (row 1) to build column index map - if (!reader.Read()) continue; - var cols = new string[reader.FieldCount]; - for (int c = 0; c < reader.FieldCount; c++) - cols[c] = reader.GetValue(c)?.ToString() ?? ""; + var workSheet = c_package.Workbook.Worksheets[i]; + var totalRows = workSheet.Dimension.Rows; + var cols = workSheet.GetHeaderColumns(); + int row = 2; int batchCount = 0; - const int batchSize = 500; + const int batchSize = 100; int totalProcessed = 0; - var batchRecruits = new List(); - var batchEducations = new List(); - var batchOccupations = new List(); - var batchAddresses = new List(); - var batchPayments = new List(); - var batchCertificates = new List(); - - while (reader.Read()) + while (row <= totalRows) { - var cell1 = reader.GetValue(0)?.ToString(); - if (string.IsNullOrEmpty(cell1)) break; + var cell1 = workSheet?.Cells[row, 1]?.GetValue(); + if (cell1 == "" || cell1 == null) break; var r = new Models.Recruits.Recruit(); - r.ExamId = GetCellValue(reader, cols, CandidateFileHeader.ExamID); - r.CitizenId = GetCellValue(reader, cols, CandidateFileHeader.PersonalID); - r.Prefix = GetCellValue(reader, cols, CandidateFileHeader.Prefix); - r.FirstName = GetCellValue(reader, cols, CandidateFileHeader.FirstName); - r.LastName = GetCellValue(reader, cols, CandidateFileHeader.LastName); - r.Gendor = GetCellValue(reader, cols, CandidateFileHeader.Gender); - r.National = GetCellValue(reader, cols, CandidateFileHeader.National).IsNull(""); - r.Race = GetCellValue(reader, cols, CandidateFileHeader.Race).IsNull(""); - r.Religion = GetCellValue(reader, cols, CandidateFileHeader.Religion).IsNull(""); - r.DateOfBirth = Convert.ToDateTime(GetCellValue(reader, cols, CandidateFileHeader.DateOfBirth).ToDateTime(DateTimeFormat.Ymd, "-")); - r.Marry = GetCellValue(reader, cols, CandidateFileHeader.Marry); + r.ExamId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ExamID)]?.GetValue(); + r.CitizenId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PersonalID)]?.GetValue(); + r.Prefix = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Prefix)]?.GetValue(); + r.FirstName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.FirstName)]?.GetValue(); + r.LastName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.LastName)]?.GetValue(); + r.Gendor = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Gender)]?.GetValue(); + r.National = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.National)]?.GetValue().IsNull(""); + r.Race = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Race)]?.GetValue().IsNull(""); + r.Religion = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Religion)]?.GetValue().IsNull(""); + r.DateOfBirth = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.DateOfBirth)]?.GetValue().ToDateTime(DateTimeFormat.Ymd, "-")); + r.Marry = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Marry)]?.GetValue(); r.Isspecial = "N"; - r.CitizenCardIssuer = GetCellValue(reader, cols, CandidateFileHeader.PersonalCardIssue); - r.CitizenCardExpireDate = Convert.ToDateTime(GetCellValue(reader, cols, CandidateFileHeader.PersonalCardExpireDate).ToDateTime(DateTimeFormat.Ymd, "-")); - r.ApplyDate = GetCellDateTime(reader, cols, CandidateFileHeader.ApplyDate) ?? DateTime.MinValue; - r.PositionName = GetCellValue(reader, cols, CandidateFileHeader.PositionName).IsNull(""); - r.PositionType = GetCellValue(reader, cols, CandidateFileHeader.PositionType).IsNull(""); - r.PositionLevel = GetCellValue(reader, cols, CandidateFileHeader.PositionLevel).IsNull(""); + r.CitizenCardIssuer = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PersonalCardIssue)]?.GetValue(); + r.CitizenCardExpireDate = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PersonalCardExpireDate)]?.GetValue().ToDateTime(DateTimeFormat.Ymd, "-")); + r.ApplyDate = (DateTime)workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ApplyDate)]?.GetValue(); + r.PositionName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PositionName)]?.GetValue().IsNull(""); + r.PositionType = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PositionType)]?.GetValue().IsNull(""); + r.PositionLevel = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PositionLevel)]?.GetValue().IsNull(""); // address - var address = new RecruitAddress() + r.Addresses.Add(new RecruitAddress() { - Address = GetCellValue(reader, cols, CandidateFileHeader.Address), - Moo = GetCellValue(reader, cols, CandidateFileHeader.Moo), - Soi = GetCellValue(reader, cols, CandidateFileHeader.Soi), - Road = GetCellValue(reader, cols, CandidateFileHeader.Road), - District = GetCellValue(reader, cols, CandidateFileHeader.District), - Amphur = GetCellValue(reader, cols, CandidateFileHeader.Amphur), - Province = GetCellValue(reader, cols, CandidateFileHeader.Province), - ZipCode = GetCellValue(reader, cols, CandidateFileHeader.ZipCode), - Telephone = GetCellValue(reader, cols, CandidateFileHeader.Telephone), - Mobile = GetCellValue(reader, cols, CandidateFileHeader.Mobile), - Address1 = GetCellValue(reader, cols, CandidateFileHeader.Address1), - Moo1 = GetCellValue(reader, cols, CandidateFileHeader.Moo1), - Soi1 = GetCellValue(reader, cols, CandidateFileHeader.Soi1), - Road1 = GetCellValue(reader, cols, CandidateFileHeader.Road1), - District1 = GetCellValue(reader, cols, CandidateFileHeader.District1), - Amphur1 = GetCellValue(reader, cols, CandidateFileHeader.Amphur1), - Province1 = GetCellValue(reader, cols, CandidateFileHeader.Province1), - ZipCode1 = GetCellValue(reader, cols, CandidateFileHeader.ZipCode1), - }; + Address = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Address)]?.GetValue() ?? "", + Moo = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Moo)]?.GetValue() ?? "", + Soi = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Soi)]?.GetValue() ?? "", + Road = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Road)]?.GetValue() ?? "", + District = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.District)]?.GetValue() ?? "", + Amphur = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Amphur)]?.GetValue() ?? "", + Province = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Province)]?.GetValue() ?? "", + ZipCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ZipCode)]?.GetValue() ?? "", + Telephone = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Telephone)]?.GetValue() ?? "", + Mobile = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Mobile)]?.GetValue() ?? "", + Address1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Address1)]?.GetValue() ?? "", + Moo1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Moo1)]?.GetValue() ?? "", + Soi1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Soi1)]?.GetValue() ?? "", + Road1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Road1)]?.GetValue() ?? "", + District1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.District1)]?.GetValue() ?? "", + Amphur1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Amphur1)]?.GetValue() ?? "", + Province1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Province1)]?.GetValue() ?? "", + ZipCode1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ZipCode1)]?.GetValue() ?? "", + }); // payment - var payment = new RecruitPayment() + r.Payments.Add(new RecruitPayment() { - PaymentId = GetCellValue(reader, cols, CandidateFileHeader.PaymentID), - CompanyCode = GetCellValue(reader, cols, CandidateFileHeader.CompanyCode), - TextFile = GetCellValue(reader, cols, CandidateFileHeader.TextFile), - BankCode = GetCellValue(reader, cols, CandidateFileHeader.BankCode), - AccountNumber = GetCellValue(reader, cols, CandidateFileHeader.AccouontNumer), - TransDate = GetCellValue(reader, cols, CandidateFileHeader.TransDate), - TransTime = GetCellValue(reader, cols, CandidateFileHeader.TransTime), - CustomerName = GetCellValue(reader, cols, CandidateFileHeader.CustomerName), - RefNo1 = GetCellValue(reader, cols, CandidateFileHeader.RefNo1), - TermBranch = GetCellValue(reader, cols, CandidateFileHeader.TermBranch), - TellerId = GetCellValue(reader, cols, CandidateFileHeader.TellerID), - CreditDebit = GetCellValue(reader, cols, CandidateFileHeader.CreditDebit), - PaymentType = GetCellValue(reader, cols, CandidateFileHeader.Type), - ChequeNo = GetCellValue(reader, cols, CandidateFileHeader.ChequeNo), - Amount = GetCellDecimal(reader, cols, CandidateFileHeader.Amount), - ChqueBankCode = GetCellValue(reader, cols, CandidateFileHeader.ChqBankCode) - }; + PaymentId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PaymentID)]?.GetValue() ?? "", + CompanyCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CompanyCode)]?.GetValue() ?? "", + TextFile = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TextFile)]?.GetValue() ?? "", + BankCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.BankCode)]?.GetValue() ?? "", + AccountNumber = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.AccouontNumer)]?.GetValue() ?? "", + TransDate = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TransDate)]?.GetValue() ?? "", + TransTime = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TransTime)]?.GetValue() ?? "", + CustomerName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CustomerName)]?.GetValue() ?? "", + RefNo1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.RefNo1)]?.GetValue() ?? "", + TermBranch = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TermBranch)]?.GetValue() ?? "", + TellerId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TellerID)]?.GetValue() ?? "", + CreditDebit = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CreditDebit)]?.GetValue() ?? "", + PaymentType = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Type)]?.GetValue(), + ChequeNo = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ChequeNo)]?.GetValue() ?? "", + Amount = (decimal)workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Amount)]?.GetValue(), + ChqueBankCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ChqBankCode)]?.GetValue() ?? "" + }); // occupation - var occupation = new RecruitOccupation() + r.Occupations.Add(new RecruitOccupation() { - Occupation = GetCellValue(reader, cols, CandidateFileHeader.Occupation), - Position = GetCellValue(reader, cols, CandidateFileHeader.Position), - Workplace = GetCellValue(reader, cols, CandidateFileHeader.Workplace), - Telephone = GetCellValue(reader, cols, CandidateFileHeader.WorkplaceTelephone), - WorkAge = GetCellValue(reader, cols, CandidateFileHeader.WorkAge), - }; + Occupation = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Occupation)]?.GetValue() ?? "", + Position = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Position)]?.GetValue() ?? "", + Workplace = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Workplace)]?.GetValue() ?? "", + Telephone = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.WorkplaceTelephone)]?.GetValue() ?? "", + WorkAge = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.WorkAge)]?.GetValue() ?? "", + }); // certificate - var certificate = new RecruitCertificate() + r.Certificates.Add(new RecruitCertificate() { - CertificateNo = GetCellValue(reader, cols, CandidateFileHeader.CertificateNo), - Description = GetCellValue(reader, cols, CandidateFileHeader.CertificateDesc), - IssueDate = Convert.ToDateTime(GetCellValue(reader, cols, CandidateFileHeader.CertificateIssueDate).ToDateTime(DateTimeFormat.Ymd, "-")), - ExpiredDate = Convert.ToDateTime(GetCellValue(reader, cols, CandidateFileHeader.CertificateExpireDate).ToDateTime(DateTimeFormat.Ymd, "-")) - }; + CertificateNo = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateNo)]?.GetValue() ?? "", + Description = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateDesc)]?.GetValue() ?? "", + IssueDate = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateIssueDate)]?.GetValue().ToDateTime(DateTimeFormat.Ymd, "-")), + ExpiredDate = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateExpireDate)]?.GetValue().ToDateTime(DateTimeFormat.Ymd, "-")) + }); - var education = new RecruitEducation() + r.Educations.Add(new RecruitEducation() { - Degree = GetCellValue(reader, cols, CandidateFileHeader.Degree), - Major = GetCellValue(reader, cols, CandidateFileHeader.Major), - MajorGroupId = GetCellValue(reader, cols, CandidateFileHeader.MajorGroupID), - MajorGroupName = GetCellValue(reader, cols, CandidateFileHeader.MajorGroupName), - University = GetCellValue(reader, cols, CandidateFileHeader.University), - GPA = GetCellDouble(reader, cols, CandidateFileHeader.GPA), - Specialist = GetCellValue(reader, cols, CandidateFileHeader.SpecialList), - HighDegree = GetCellValue(reader, cols, CandidateFileHeader.HighDegree), - BachelorDate = Convert.ToDateTime(GetCellValue(reader, cols, CandidateFileHeader.BachelorDate).ToDateTime(DateTimeFormat.Ymd, "-")) - }; - - r.Addresses.Add(address); - r.Payments.Add(payment); - r.Occupations.Add(occupation); - r.Certificates.Add(certificate); - r.Educations.Add(education); + Degree = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Degree)]?.GetValue() ?? "", + Major = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Major)]?.GetValue() ?? "", + MajorGroupId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.MajorGroupID)]?.GetValue() ?? "", + MajorGroupName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.MajorGroupName)]?.GetValue() ?? "", + University = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.University)]?.GetValue() ?? "", + GPA = (double)workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.GPA)]?.GetValue(), + Specialist = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.SpecialList)]?.GetValue() ?? "", + HighDegree = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.HighDegree)]?.GetValue() ?? "", + BachelorDate = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.BachelorDate)]?.GetValue().ToDateTime(DateTimeFormat.Ymd, "-")) + }); r.RecruitImport = imported; - batchRecruits.Add(r); - batchAddresses.Add(address); - batchPayments.Add(payment); - batchOccupations.Add(occupation); - batchCertificates.Add(certificate); - batchEducations.Add(education); + _context.Recruits.Add(r); + row++; batchCount++; totalProcessed++; if (batchCount >= batchSize) { - await _context.BulkInsertAsync(batchRecruits, options => { options.SetOutputIdentity = true; }); - - for (int j = 0; j < batchRecruits.Count; j++) - { - batchAddresses[j].Recruit = batchRecruits[j]; - batchPayments[j].Recruit = batchRecruits[j]; - batchOccupations[j].Recruit = batchRecruits[j]; - batchCertificates[j].Recruit = batchRecruits[j]; - batchEducations[j].Recruit = batchRecruits[j]; - } - - await _context.BulkInsertAsync(batchAddresses); - await _context.BulkInsertAsync(batchPayments); - await _context.BulkInsertAsync(batchOccupations); - await _context.BulkInsertAsync(batchCertificates); - await _context.BulkInsertAsync(batchEducations); - + _context.SaveChanges(); _context.ChangeTracker.Clear(); - - batchRecruits.Clear(); - batchAddresses.Clear(); - batchPayments.Clear(); - batchOccupations.Clear(); - batchCertificates.Clear(); - batchEducations.Clear(); + _context.Entry(imported).State = EntityState.Unchanged; batchCount = 0; _tracker.UpdateStatus(job.JobId, ImportJobStatus.Running, totalProcessed); } } + } - // Process remaining records - if (batchRecruits.Count > 0) - { - await _context.BulkInsertAsync(batchRecruits, options => { options.SetOutputIdentity = true; }); - - for (int j = 0; j < batchRecruits.Count; j++) - { - batchAddresses[j].Recruit = batchRecruits[j]; - batchPayments[j].Recruit = batchRecruits[j]; - batchOccupations[j].Recruit = batchRecruits[j]; - batchCertificates[j].Recruit = batchRecruits[j]; - batchEducations[j].Recruit = batchRecruits[j]; - } - - await _context.BulkInsertAsync(batchAddresses); - await _context.BulkInsertAsync(batchPayments); - await _context.BulkInsertAsync(batchOccupations); - await _context.BulkInsertAsync(batchCertificates); - await _context.BulkInsertAsync(batchEducations); - - _context.ChangeTracker.Clear(); - } - } while (reader.NextResult()); - + _context.SaveChanges(); job.TotalCount = _tracker.GetJob(job.JobId)?.ProcessedCount ?? 0; } @@ -314,10 +244,23 @@ public class ImportBackgroundService : BackgroundService private async Task ProcessCandidateFileByIdAsync(ApplicationDbContext _context, MinIOService _minioService, RecruitService _recruitService, IWebHostEnvironment _webHostEnv, ImportJobInfo job) { - var imported = await _context.RecruitImports.FindAsync(job.RecruitImportId); + var imported = await _context.RecruitImports.AsQueryable() + .Include(x => x.ImportHostories) + .Include(x => x.ImportFile) + .Include(x => x.Recruits) + .ThenInclude(x => x.Addresses) + .Include(x => x.Recruits) + .ThenInclude(x => x.Occupations) + .Include(x => x.Recruits) + .ThenInclude(x => x.Certificates) + .Include(x => x.Recruits) + .ThenInclude(x => x.Educations) + .Include(x => x.Recruits) + .ThenInclude(x => x.Payments) + .FirstOrDefaultAsync(x => x.Id == job.RecruitImportId); + if (imported == null) throw new Exception("RecruitImport not found"); - // Save import history using regular SaveChanges (small operation) imported.ImportHostories.Add(new RecruitImportHistory { Description = "นำเข้าข้อมูลผู้สมัครสอบแข่งขัน", @@ -328,176 +271,146 @@ public class ImportBackgroundService : BackgroundService LastUpdateUserId = job.UserId ?? "", LastUpdateFullName = job.FullName ?? "System Administrator", }); - await _context.SaveChangesAsync(); - _context.ChangeTracker.Clear(); - var importId = imported.Id; - var importRef = _context.Attach(new RecruitImport { Id = importId }).Entity; - - System.Text.Encoding.RegisterProvider(System.Text.CodePagesEncodingProvider.Instance); - using var stream = System.IO.File.OpenRead(job.ImportFile); - using var reader = ExcelReaderFactory.CreateReader(stream); - - do + using var c_package = new ExcelPackage(new FileInfo(job.ImportFile)); + for (int i = 0; i < c_package.Workbook.Worksheets.Count; i++) { - // Skip header row - if (!reader.Read()) continue; + var workSheet = c_package.Workbook.Worksheets[i]; + var totalRows = workSheet.Dimension.Rows; + var cols = workSheet.GetHeaderColumns(); int row = 2; int batchCount = 0; - const int batchSize = 500; + const int batchSize = 100; int totalProcessed = 0; - var batchRecruits = new List(); - var batchEducations = new List(); - var batchOccupations = new List(); - var batchAddresses = new List(); - var batchPayments = new List(); - - while (reader.Read()) + while (row <= totalRows) { - var cell1 = reader.GetValue(0)?.ToString(); - if (string.IsNullOrEmpty(cell1)) break; + var cell1 = workSheet?.Cells[row, 1]?.GetValue(); + if (cell1 == "" || cell1 == null) break; - try + var r = new Models.Recruits.Recruit(); + r.ExamId = workSheet?.Cells[row, 1]?.GetValue() ?? ""; + r.PositionName = workSheet?.Cells[row, 3]?.GetValue() ?? ""; + r.HddPosition = workSheet?.Cells[row, 4]?.GetValue() ?? ""; + r.Prefix = workSheet?.Cells[row, 5]?.GetValue() == "อื่น ๆ" ? workSheet?.Cells[row, 6]?.GetValue() ?? "" : workSheet?.Cells[row, 5]?.GetValue() ?? ""; + r.FirstName = workSheet?.Cells[row, 7]?.GetValue() ?? ""; + r.LastName = workSheet?.Cells[row, 8]?.GetValue() ?? ""; + r.Gendor = workSheet?.Cells[row, 98]?.GetValue() ?? ""; + r.National = workSheet?.Cells[row, 9]?.GetValue() ?? ""; + r.Race = ""; + r.Religion = workSheet?.Cells[row, 10]?.GetValue() ?? ""; + r.DateOfBirth = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, 11]?.GetValue()) ? _recruitService.CheckDateTime(workSheet?.Cells[row, 11]?.GetValue() ?? "", "dd/MM/yyyy") : null; + r.CitizenId = workSheet?.Cells[row, 12]?.GetValue() ?? ""; + r.typeTest = workSheet?.Cells[row, 13]?.GetValue() ?? ""; + r.Marry = ""; + r.Isspecial = "N"; + r.CitizenCardExpireDate = null; + r.ModifiedDate = null; + r.ApplyDate = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, 87]?.GetValue()) ? _recruitService.CheckDateTime(workSheet?.Cells[row, 87]?.GetValue() ?? "", "dd/MM/yyyy") : null; + r.PositionType = ""; + r.PositionLevel = ""; + r.CreatedAt = DateTime.Now; + r.CreatedUserId = job.UserId ?? ""; + r.CreatedFullName = job.FullName ?? "System Administrator"; + r.LastUpdatedAt = DateTime.Now; + r.LastUpdateUserId = job.UserId ?? ""; + r.LastUpdateFullName = job.FullName ?? "System Administrator"; + + // education + r.Educations.Add(new RecruitEducation() { - var r = new Models.Recruits.Recruit(); - r.Id = Guid.NewGuid(); - r.ExamId = reader.GetValue(0)?.ToString() ?? ""; - r.PositionName = reader.GetValue(2)?.ToString() ?? ""; - r.HddPosition = reader.GetValue(3)?.ToString() ?? ""; - r.Prefix = reader.GetValue(4)?.ToString() == "อื่น ๆ" ? reader.GetValue(5)?.ToString() ?? "" : reader.GetValue(4)?.ToString() ?? ""; - r.FirstName = reader.GetValue(6)?.ToString() ?? ""; - r.LastName = reader.GetValue(7)?.ToString() ?? ""; - r.Gendor = reader.GetValue(97)?.ToString() ?? ""; - r.National = reader.GetValue(8)?.ToString() ?? ""; - r.Race = ""; - r.Religion = reader.GetValue(9)?.ToString() ?? ""; - r.DateOfBirth = !string.IsNullOrWhiteSpace(reader.GetValue(10)?.ToString()) ? _recruitService.CheckDateTime(reader.GetValue(10)?.ToString() ?? "", "dd/MM/yyyy") : null; - r.CitizenId = reader.GetValue(11)?.ToString() ?? ""; - r.typeTest = reader.GetValue(12)?.ToString() ?? ""; - r.Marry = ""; - r.Isspecial = "N"; - r.CitizenCardExpireDate = null; - r.ModifiedDate = null; - r.ApplyDate = !string.IsNullOrWhiteSpace(reader.GetValue(86)?.ToString()) ? _recruitService.CheckDateTime(reader.GetValue(86)?.ToString() ?? "", "dd/MM/yyyy") : null; - r.PositionType = ""; - r.PositionLevel = ""; - r.CreatedAt = DateTime.Now; - r.CreatedUserId = job.UserId ?? ""; - r.CreatedFullName = job.FullName ?? "System Administrator"; - r.LastUpdatedAt = DateTime.Now; - r.LastUpdateUserId = job.UserId ?? ""; - r.LastUpdateFullName = job.FullName ?? "System Administrator"; - r.RecruitImport = importRef; + Degree = workSheet?.Cells[row, 18]?.GetValue() ?? "", + Major = workSheet?.Cells[row, 19]?.GetValue() == "อื่น ๆ" ? workSheet?.Cells[row, 20]?.GetValue() ?? "" : workSheet?.Cells[row, 19]?.GetValue() ?? "", + MajorGroupId = "", + MajorGroupName = "", + University = workSheet?.Cells[row, 21]?.GetValue() == "อื่น ๆ" ? workSheet?.Cells[row, 22]?.GetValue() ?? "" : workSheet?.Cells[row, 21]?.GetValue() ?? "", + GPA = (double)workSheet?.Cells[row, 26]?.GetValue(), + Specialist = "", + HighDegree = workSheet?.Cells[row, 27]?.GetValue() ?? "", + BachelorDate = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, 25]?.GetValue()) ? _recruitService.CheckDateTime(workSheet?.Cells[row, 25]?.GetValue() ?? "", "dd/MM/yyyy") : null, + CreatedAt = DateTime.Now, + CreatedUserId = job.UserId ?? "", + CreatedFullName = job.FullName ?? "System Administrator", + LastUpdatedAt = DateTime.Now, + LastUpdateUserId = job.UserId ?? "", + LastUpdateFullName = job.FullName ?? "System Administrator" + }); - // Store child entities in separate lists for bulk insert - var education = new RecruitEducation() - { - Id = Guid.NewGuid(), - Degree = reader.GetValue(17)?.ToString() ?? "", - Major = reader.GetValue(18)?.ToString() == "อื่น ๆ" ? reader.GetValue(19)?.ToString() ?? "" : reader.GetValue(18)?.ToString() ?? "", - MajorGroupId = "", - MajorGroupName = "", - University = reader.GetValue(20)?.ToString() == "อื่น ๆ" ? reader.GetValue(21)?.ToString() ?? "" : reader.GetValue(20)?.ToString() ?? "", - GPA = GetReaderDouble(reader, 25), - Specialist = "", - HighDegree = reader.GetValue(26)?.ToString() ?? "", - BachelorDate = !string.IsNullOrWhiteSpace(reader.GetValue(24)?.ToString()) ? _recruitService.CheckDateTime(reader.GetValue(24)?.ToString() ?? "", "dd/MM/yyyy") : null, - Recruit = r, - CreatedAt = DateTime.Now, - CreatedUserId = job.UserId ?? "", - CreatedFullName = job.FullName ?? "System Administrator", - LastUpdatedAt = DateTime.Now, - LastUpdateUserId = job.UserId ?? "", - LastUpdateFullName = job.FullName ?? "System Administrator" - }; - - var occupation = new RecruitOccupation() - { - Id = Guid.NewGuid(), - Occupation = reader.GetValue(32)?.ToString() == "อื่น ๆ" ? reader.GetValue(33)?.ToString() ?? "" : reader.GetValue(32)?.ToString() ?? "", - Position = reader.GetValue(36)?.ToString() ?? "", - Workplace = $"{(reader.GetValue(35)?.ToString() ?? "")} {(reader.GetValue(34)?.ToString() ?? "")}", - Telephone = "", - WorkAge = "", - Recruit = r, - CreatedAt = DateTime.Now, - CreatedUserId = job.UserId ?? "", - CreatedFullName = job.FullName ?? "System Administrator", - LastUpdatedAt = DateTime.Now, - LastUpdateUserId = job.UserId ?? "", - LastUpdateFullName = job.FullName ?? "System Administrator" - }; - - var address = new RecruitAddress() - { - Id = Guid.NewGuid(), - Address = $"{(reader.GetValue(48)?.ToString() ?? "")} {(reader.GetValue(49)?.ToString() ?? "")}", - Moo = reader.GetValue(50)?.ToString() ?? "", - Soi = reader.GetValue(51)?.ToString() ?? "", - Road = reader.GetValue(52)?.ToString() ?? "", - District = reader.GetValue(53)?.ToString() ?? "", - Amphur = reader.GetValue(54)?.ToString() ?? "", - Province = reader.GetValue(55)?.ToString() ?? "", - ZipCode = (reader.GetValue(56)?.ToString() ?? "").Trim(), - Telephone = reader.GetValue(57)?.ToString() ?? "", - Mobile = "", - Address1 = $"{(reader.GetValue(60)?.ToString() ?? "")} {(reader.GetValue(61)?.ToString() ?? "")}", - Moo1 = reader.GetValue(62)?.ToString() ?? "", - Soi1 = reader.GetValue(63)?.ToString() ?? "", - Road1 = reader.GetValue(64)?.ToString() ?? "", - District1 = reader.GetValue(65)?.ToString() ?? "", - Amphur1 = reader.GetValue(66)?.ToString() ?? "", - Province1 = reader.GetValue(67)?.ToString() ?? "", - ZipCode1 = (reader.GetValue(68)?.ToString() ?? "").Trim(), - Recruit = r, - CreatedAt = DateTime.Now, - CreatedUserId = job.UserId ?? "", - CreatedFullName = job.FullName ?? "System Administrator", - LastUpdatedAt = DateTime.Now, - LastUpdateUserId = job.UserId ?? "", - LastUpdateFullName = job.FullName ?? "System Administrator" - }; - - var payment = new RecruitPayment() - { - Id = Guid.NewGuid(), - PaymentId = reader.GetValue(103)?.ToString() ?? "", - CompanyCode = reader.GetValue(104)?.ToString() ?? "", - TextFile = reader.GetValue(105)?.ToString() ?? "", - BankCode = reader.GetValue(106)?.ToString() ?? "", - AccountNumber = reader.GetValue(107)?.ToString() ?? "", - TransDate = reader.GetValue(108)?.ToString() ?? "", - TransTime = reader.GetValue(109)?.ToString() ?? "", - CustomerName = reader.GetValue(110)?.ToString() ?? "", - RefNo1 = reader.GetValue(111)?.ToString() ?? "", - TermBranch = reader.GetValue(112)?.ToString() ?? "", - TellerId = reader.GetValue(113)?.ToString() ?? "", - CreditDebit = reader.GetValue(114)?.ToString() ?? "", - PaymentType = reader.GetValue(115)?.ToString() ?? "", - ChequeNo = reader.GetValue(116)?.ToString() ?? "", - Amount = GetReaderDecimal(reader, 117), - ChqueBankCode = reader.GetValue(118)?.ToString() ?? "", - Recruit = r, - CreatedAt = DateTime.Now, - CreatedUserId = job.UserId ?? "", - CreatedFullName = job.FullName ?? "System Administrator", - LastUpdatedAt = DateTime.Now, - LastUpdateUserId = job.UserId ?? "", - LastUpdateFullName = job.FullName ?? "System Administrator" - }; - - batchRecruits.Add(r); - batchEducations.Add(education); - batchOccupations.Add(occupation); - batchAddresses.Add(address); - batchPayments.Add(payment); - } - catch (Exception ex) + // occupation + r.Occupations.Add(new RecruitOccupation() { - throw new Exception($"Row {row}: {ex.Message}", ex); - } + Occupation = workSheet?.Cells[row, 33]?.GetValue() == "อื่น ๆ" ? workSheet?.Cells[row, 34]?.GetValue() ?? "" : workSheet?.Cells[row, 33]?.GetValue() ?? "", + Position = workSheet?.Cells[row, 37]?.GetValue() ?? "", + Workplace = $"{(workSheet?.Cells[row, 36]?.GetValue() ?? "")} {(workSheet?.Cells[row, 35]?.GetValue() ?? "")}", + Telephone = workSheet?.Cells[row, 9999]?.GetValue() ?? "", + WorkAge = workSheet?.Cells[row, 9999]?.GetValue() ?? "", + CreatedAt = DateTime.Now, + CreatedUserId = job.UserId ?? "", + CreatedFullName = job.FullName ?? "System Administrator", + LastUpdatedAt = DateTime.Now, + LastUpdateUserId = job.UserId ?? "", + LastUpdateFullName = job.FullName ?? "System Administrator" + }); + + // address + r.Addresses.Add(new RecruitAddress() + { + Address = $"{(workSheet?.Cells[row, 49]?.GetValue() ?? "")} {(workSheet?.Cells[row, 50]?.GetValue() ?? "")}", + Moo = workSheet?.Cells[row, 51]?.GetValue() ?? "", + Soi = workSheet?.Cells[row, 52]?.GetValue() ?? "", + Road = workSheet?.Cells[row, 53]?.GetValue() ?? "", + District = workSheet?.Cells[row, 54]?.GetValue() ?? "", + Amphur = workSheet?.Cells[row, 55]?.GetValue() ?? "", + Province = workSheet?.Cells[row, 56]?.GetValue() ?? "", + ZipCode = (workSheet?.Cells[row, 57]?.GetValue() ?? "").Trim(), + Telephone = workSheet?.Cells[row, 58]?.GetValue() ?? "", + Mobile = "", + Address1 = $"{(workSheet?.Cells[row, 61]?.GetValue() ?? "")} {(workSheet?.Cells[row, 62]?.GetValue() ?? "")}", + Moo1 = workSheet?.Cells[row, 63]?.GetValue() ?? "", + Soi1 = workSheet?.Cells[row, 64]?.GetValue() ?? "", + Road1 = workSheet?.Cells[row, 65]?.GetValue() ?? "", + District1 = workSheet?.Cells[row, 66]?.GetValue() ?? "", + Amphur1 = workSheet?.Cells[row, 67]?.GetValue() ?? "", + Province1 = workSheet?.Cells[row, 68]?.GetValue() ?? "", + ZipCode1 = (workSheet?.Cells[row, 69]?.GetValue() ?? "").Trim(), + CreatedAt = DateTime.Now, + CreatedUserId = job.UserId ?? "", + CreatedFullName = job.FullName ?? "System Administrator", + LastUpdatedAt = DateTime.Now, + LastUpdateUserId = job.UserId ?? "", + LastUpdateFullName = job.FullName ?? "System Administrator" + }); + + // payment + r.Payments.Add(new RecruitPayment() + { + PaymentId = workSheet?.Cells[row, 104]?.GetValue() ?? "", + CompanyCode = workSheet?.Cells[row, 105]?.GetValue() ?? "", + TextFile = workSheet?.Cells[row, 106]?.GetValue() ?? "", + BankCode = workSheet?.Cells[row, 107]?.GetValue() ?? "", + AccountNumber = workSheet?.Cells[row, 108]?.GetValue() ?? "", + TransDate = workSheet?.Cells[row, 109]?.GetValue() ?? "", + TransTime = workSheet?.Cells[row, 110]?.GetValue() ?? "", + CustomerName = workSheet?.Cells[row, 111]?.GetValue() ?? "", + RefNo1 = workSheet?.Cells[row, 112]?.GetValue() ?? "", + TermBranch = workSheet?.Cells[row, 113]?.GetValue() ?? "", + TellerId = workSheet?.Cells[row, 114]?.GetValue() ?? "", + CreditDebit = workSheet?.Cells[row, 115]?.GetValue() ?? "", + PaymentType = workSheet?.Cells[row, 116]?.GetValue() ?? "", + ChequeNo = workSheet?.Cells[row, 117]?.GetValue() ?? "", + Amount = (decimal)workSheet?.Cells[row, 118]?.GetValue(), + ChqueBankCode = workSheet?.Cells[row, 119]?.GetValue() ?? "", + CreatedAt = DateTime.Now, + CreatedUserId = job.UserId ?? "", + CreatedFullName = job.FullName ?? "System Administrator", + LastUpdatedAt = DateTime.Now, + LastUpdateUserId = job.UserId ?? "", + LastUpdateFullName = job.FullName ?? "System Administrator" + }); + + r.RecruitImport = imported; + _context.Recruits.Add(r); row++; batchCount++; @@ -505,54 +418,16 @@ public class ImportBackgroundService : BackgroundService if (batchCount >= batchSize) { - try - { - await _context.BulkInsertAsync(batchRecruits); - await _context.BulkInsertAsync(batchEducations); - await _context.BulkInsertAsync(batchOccupations); - await _context.BulkInsertAsync(batchAddresses); - await _context.BulkInsertAsync(batchPayments); - } - catch (Exception ex) - { - var batchStartRow = row - batchCount + 1; - throw new Exception($"BulkInsert failed (rows {batchStartRow}-{row - 1}, {batchRecruits.Count} records): {ex.InnerException?.Message ?? ex.Message}", ex); - } - + _context.SaveChanges(); _context.ChangeTracker.Clear(); - - // Clear all lists for next batch - batchRecruits.Clear(); - batchEducations.Clear(); - batchOccupations.Clear(); - batchAddresses.Clear(); - batchPayments.Clear(); + _context.Entry(imported).State = EntityState.Unchanged; batchCount = 0; _tracker.UpdateStatus(job.JobId, ImportJobStatus.Running, totalProcessed); } } + } - // Process remaining records - if (batchRecruits.Count > 0) - { - try - { - await _context.BulkInsertAsync(batchRecruits); - await _context.BulkInsertAsync(batchEducations); - await _context.BulkInsertAsync(batchOccupations); - await _context.BulkInsertAsync(batchAddresses); - await _context.BulkInsertAsync(batchPayments); - } - catch (Exception ex) - { - var batchStartRow = row - batchCount + 1; - throw new Exception($"BulkInsert failed (rows {batchStartRow}-{row - 1}, {batchRecruits.Count} records): {ex.InnerException?.Message ?? ex.Message}", ex); - } - - _context.ChangeTracker.Clear(); - } - } while (reader.NextResult()); - + _context.SaveChanges(); job.TotalCount = _tracker.GetJob(job.JobId)?.ProcessedCount ?? 0; } @@ -570,30 +445,13 @@ public class ImportBackgroundService : BackgroundService if (rec_import == null) throw new Exception("RecruitImport not found"); - var rec_import_id = rec_import.Id; - var rec_import_year = rec_import.Year; - var existingScoreImport = rec_import.ScoreImport; - - if (existingScoreImport != null) + if (rec_import.ScoreImport != null && rec_import.ScoreImport.Scores != null) { - var existingScores = existingScoreImport.Scores?.ToList() ?? new List(); - if (existingScores.Count > 0) - await _context.BulkDeleteAsync(existingScores); - // Also delete the ScoreImport row itself (has unique index on RecruitImportId) - // Use Remove+SaveChanges instead of BulkDelete since BulkDelete fails with detached entities - var scoreImportToDelete = existingScoreImport; - _context.ChangeTracker.Clear(); - var deleteStub = new ScoreImport { Id = scoreImportToDelete.Id }; - _context.ScoreImports.Attach(deleteStub); - _context.ScoreImports.Remove(deleteStub); + _context.RecruitScores.RemoveRange(rec_import.ScoreImport.Scores); await _context.SaveChangesAsync(); } - // Clear tracker to avoid stale references after BulkDelete (which bypasses EF tracking) - _context.ChangeTracker.Clear(); - - // Add history record — set FK shadow property directly to avoid Attach side-effects - var historyEntry = _context.RecruitImportHistories.Add(new RecruitImportHistory + rec_import.ImportHostories.Add(new RecruitImportHistory { Description = "นำเข้าข้อมูลผลคะแนนสอบ", CreatedAt = DateTime.Now, @@ -603,104 +461,83 @@ public class ImportBackgroundService : BackgroundService LastUpdateUserId = job.UserId ?? "", LastUpdateFullName = job.FullName ?? "System Administrator", }); - historyEntry.Property("RecruitImportId").CurrentValue = rec_import_id; - // get doc from minio (MinIOService already saves Document to its own context) + // get doc from minio var doc = await _minioService.UploadFileAsync(new DummyFormFile(job.ImportFile)); - var scoreImport_id = Guid.NewGuid(); // Pre-generate Id to use as FK - var imported = new ScoreImport(); - imported.Id = scoreImport_id; - imported.Year = rec_import_year; - imported.RecruitImportId = rec_import_id; - imported.CreatedAt = DateTime.Now; - imported.CreatedUserId = job.UserId ?? ""; - imported.CreatedFullName = job.FullName ?? "System Administrator"; - imported.LastUpdatedAt = DateTime.Now; - imported.LastUpdateUserId = job.UserId ?? ""; - imported.LastUpdateFullName = job.FullName ?? "System Administrator"; - imported.Scores = new List(); + var imported = new ScoreImport + { + Year = rec_import.Year, + ImportFile = doc, + CreatedAt = DateTime.Now, + CreatedUserId = job.UserId ?? "", + CreatedFullName = job.FullName ?? "System Administrator", + LastUpdatedAt = DateTime.Now, + LastUpdateUserId = job.UserId ?? "", + LastUpdateFullName = job.FullName ?? "System Administrator", + Scores = new List() + }; - // Save ScoreImport — set ImportFileId FK directly (explicit property, not shadow) - imported.ImportFileId = doc.Id; - _context.ScoreImports.Add(imported); - await _context.SaveChangesAsync(); - _context.ChangeTracker.Clear(); - - // preload recruits using AsNoTracking to avoid EF tracking overhead + // preload recruits var recruitsDict = await _context.Recruits - .AsNoTracking() .Where(x => x.RecruitImport.Id == rec_import.Id) .GroupBy(x => x.ExamId) .Where(g => g.Count() == 1) .Select(g => g.First()) .ToDictionaryAsync(x => x.ExamId, x => x); - System.Text.Encoding.RegisterProvider(System.Text.CodePagesEncodingProvider.Instance); - using var stream = System.IO.File.OpenRead(job.ImportFile); - using var reader = ExcelReaderFactory.CreateReader(stream); - - do + using var c_package = new ExcelPackage(new FileInfo(job.ImportFile)); + for (int i = 0; i < c_package.Workbook.Worksheets.Count; i++) { - // Read header rows (rows 1-7), then data starts at row 8 - // Skip 7 rows: first 7 are header/metadata - for (int skip = 0; skip < 7; skip++) - { - if (!reader.Read()) break; - } - - var cols = new string[reader.FieldCount]; - // Use current row (row 7) as header reference — not actually used for ScoreFile column mapping - // ScoreFile uses hardcoded column indices - + var workSheet = c_package.Workbook.Worksheets[i]; + var cols = workSheet.GetHeaderColumns(); + int row = 8; int batchCount = 0; - const int batchSize = 500; + const int batchSize = 100; int totalProcessed = 0; + var endRow = workSheet.Dimension.End.Row; - var batchScores = new List(); - - while (reader.Read()) + while (row <= endRow) { - var cell1 = reader.GetValue(0)?.ToString(); - if (string.IsNullOrEmpty(cell1)) break; + var cell1 = workSheet?.Cells[row, 1]?.GetValue(); + if (cell1 == "" || cell1 == null) break; var r = new RecruitScore(); - r.Id = Guid.NewGuid(); - r.ExamId = reader.GetValue(1)?.ToString(); + r.ExamId = workSheet?.Cells[row, 2]?.GetValue(); if (!string.IsNullOrEmpty(r.ExamId) && recruitsDict.TryGetValue(r.ExamId, out var recruit)) { - r.CitizenId = reader.GetValue(2)?.ToString()?.Trim(); + r.CitizenId = workSheet?.Cells[row, 3]?.GetValue()?.Trim(); r.FullA = 200; - r.SumA = string.IsNullOrWhiteSpace(reader.GetValue(4)?.ToString()) ? 0.00 : Math.Round(Convert.ToDouble(reader.GetValue(4)), 2); - r.PercentageA = string.IsNullOrWhiteSpace(reader.GetValue(5)?.ToString()) ? 0.00 : Math.Round(Convert.ToDouble(reader.GetValue(5)), 2); - r.AStatus = string.IsNullOrWhiteSpace(reader.GetValue(6)?.ToString()) ? "" : reader.GetValue(6)?.ToString(); - r.SumAB = string.IsNullOrWhiteSpace(reader.GetValue(4)?.ToString()) ? 0.00 : Math.Round(Convert.ToDouble(reader.GetValue(4)), 2); - r.ABStatus = string.IsNullOrWhiteSpace(reader.GetValue(6)?.ToString()) ? "" : reader.GetValue(6)?.ToString(); + r.SumA = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 5]?.GetValue()) ? 0.00 : Math.Round(workSheet.Cells[row, 5].GetValue(), 2); + r.PercentageA = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 6]?.GetValue()) ? 0.00 : Math.Round(workSheet.Cells[row, 6].GetValue(), 2); + r.AStatus = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 7]?.GetValue()) ? "" : workSheet?.Cells[row, 7]?.GetValue(); + r.SumAB = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 5]?.GetValue()) ? 0.00 : Math.Round(workSheet.Cells[row, 5].GetValue(), 2); + r.ABStatus = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 7]?.GetValue()) ? "" : workSheet?.Cells[row, 7]?.GetValue(); r.FullC = 50; - r.SumC = string.IsNullOrWhiteSpace(reader.GetValue(7)?.ToString()) ? 0.00 : Math.Round(Convert.ToDouble(reader.GetValue(7)), 2); + r.SumC = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 8]?.GetValue()) ? 0.00 : Math.Round(workSheet.Cells[row, 8].GetValue(), 2); r.FullD = 50; - r.SumD = string.IsNullOrWhiteSpace(reader.GetValue(8)?.ToString()) ? 0.00 : Math.Round(Convert.ToDouble(reader.GetValue(8)), 2); - r.SumCD = string.IsNullOrWhiteSpace(reader.GetValue(9)?.ToString()) ? 0.00 : Math.Round(Convert.ToDouble(reader.GetValue(9)), 2); - r.PercentageC = string.IsNullOrWhiteSpace(reader.GetValue(10)?.ToString()) ? 0.00 : Math.Round(Convert.ToDouble(reader.GetValue(10)), 2); - r.CStatus = string.IsNullOrWhiteSpace(reader.GetValue(11)?.ToString()) ? "" : reader.GetValue(11)?.ToString(); + r.SumD = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 9]?.GetValue()) ? 0.00 : Math.Round(workSheet.Cells[row, 9].GetValue(), 2); + r.SumCD = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 10]?.GetValue()) ? 0.00 : Math.Round(workSheet.Cells[row, 10].GetValue(), 2); + r.PercentageC = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 11]?.GetValue()) ? 0.00 : Math.Round(workSheet.Cells[row, 11].GetValue(), 2); + r.CStatus = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 12]?.GetValue()) ? "" : workSheet?.Cells[row, 12]?.GetValue(); r.FullScore = 300; - r.TotalScore = string.IsNullOrWhiteSpace(reader.GetValue(12)?.ToString()) ? 0.00 : Math.Round(Convert.ToDouble(reader.GetValue(12)), 2); + r.TotalScore = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 13]?.GetValue()) ? 0.00 : Math.Round(workSheet.Cells[row, 13].GetValue(), 2); - var examStatusCol7 = reader.GetValue(6)?.ToString()?.Trim(); - var examStatusCol14 = reader.GetValue(13)?.ToString()?.Trim(); + var examStatusCol7 = workSheet?.Cells[row, 7]?.GetValue()?.Trim(); + var examStatusCol14 = workSheet?.Cells[row, 14]?.GetValue()?.Trim(); r.ExamStatus = examStatusCol7 == "ขาดสอบ" ? "ขส." : examStatusCol14 == "ได้" ? "ผ่าน" : examStatusCol14 == "ตก" ? "ไม่ผ่าน" : "-"; - r.RemarkScore = string.IsNullOrWhiteSpace(reader.GetValue(14)?.ToString()) ? string.Empty : reader.GetValue(14)?.ToString(); + r.RemarkScore = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 15]?.GetValue()) ? string.Empty : workSheet?.Cells[row, 15]?.GetValue(); - var examAttr = reader.GetValue(15)?.ToString()?.Trim(); + var examAttr = workSheet?.Cells[row, 16]?.GetValue()?.Trim(); r.ExamAttribute = examAttr == "ผ่าน" ? "มีคุณสมบัติ" : examAttr == "ไม่ผ่าน" ? "ไม่มีคุณสมบัติ" : ""; - r.Major = reader.Name; // worksheet name + r.Major = workSheet.Name; r.CreatedAt = DateTime.Now; r.CreatedUserId = job.UserId ?? ""; r.CreatedFullName = job.FullName ?? "System Administrator"; @@ -708,37 +545,32 @@ public class ImportBackgroundService : BackgroundService r.LastUpdateUserId = job.UserId ?? ""; r.LastUpdateFullName = job.FullName ?? "System Administrator"; - batchScores.Add(r); + imported.Scores.Add(r); } + row++; batchCount++; totalProcessed++; if (batchCount >= batchSize) { - // Set ScoreImportId FK for all scores in batch - foreach (var score in batchScores) - { - score.ScoreImportId = scoreImport_id; - } - await _context.BulkInsertAsync(batchScores); - batchScores.Clear(); + rec_import.ScoreImport = imported; + await _context.SaveChangesAsync(); + _context.ChangeTracker.Clear(); + _context.Attach(rec_import); + _context.Attach(imported); + imported.Scores.Clear(); batchCount = 0; _tracker.UpdateStatus(job.JobId, ImportJobStatus.Running, totalProcessed); } } + } - // Process remaining records - if (batchScores.Count > 0) - { - foreach (var score in batchScores) - { - score.ScoreImportId = scoreImport_id; - } - await _context.BulkInsertAsync(batchScores); - } - } while (reader.NextResult()); - + if (imported.Scores.Count > 0) + { + rec_import.ScoreImport = imported; + await _context.SaveChangesAsync(); + } job.TotalCount = _tracker.GetJob(job.JobId)?.ProcessedCount ?? 0; } @@ -769,7 +601,7 @@ public class ImportBackgroundService : BackgroundService x.Number = string.Empty; x.RemarkExamOrder = string.Empty; } - await _context.BulkUpdateAsync(oldScores); + await _context.SaveChangesAsync(); } } @@ -783,68 +615,58 @@ public class ImportBackgroundService : BackgroundService LastUpdateUserId = job.UserId ?? "", LastUpdateFullName = job.FullName ?? "System Administrator", }); - await _context.SaveChangesAsync(); - _context.ChangeTracker.Clear(); - // preload scores using AsNoTracking to avoid EF tracking overhead - var scoreList = await _context.RecruitScores - .AsNoTracking() - .Where(s => s.ScoreImport.RecruitImportId == rec_import.Id && !string.IsNullOrEmpty(s.ExamId)) + // preload scores + var score = rec_import.ScoreImport.Scores + .Where(s => !string.IsNullOrEmpty(s.ExamId)) .GroupBy(x => x.ExamId) .Where(g => g.Count() == 1) .Select(g => g.First()) - .ToListAsync(); - var score = scoreList.ToDictionary(s => s.ExamId!, s => s); + .ToDictionary(s => s.ExamId, s => s); - System.Text.Encoding.RegisterProvider(System.Text.CodePagesEncodingProvider.Instance); + // Read from saved file (ResultFile uses stream from Form, but we saved to disk) using var stream = System.IO.File.OpenRead(job.ImportFile); - using var reader = ExcelReaderFactory.CreateReader(stream); + using var c_package = new ExcelPackage(stream); - do + foreach (var workSheet in c_package.Workbook.Worksheets) { - // Skip 6 header rows, data starts at row 7 - for (int skip = 0; skip < 6; skip++) - { - if (!reader.Read()) break; - } - + int row = 7; int batchCount = 0; - const int batchSize = 500; - var batchUpdates = new List(); + const int batchSize = 100; + var endRow = workSheet.Dimension.End.Row; - while (reader.Read()) + while (row <= endRow) { - var examId = reader.GetValue(1)?.ToString(); + var examId = workSheet?.Cells[row, 2]?.GetValue(); if (string.IsNullOrWhiteSpace(examId)) { + row++; continue; } if (score.TryGetValue(examId, out var existingScore)) { - existingScore.Number = reader.GetValue(0)?.ToString(); - existingScore.RemarkExamOrder = reader.GetValue(3)?.ToString() ?? string.Empty; + existingScore.Number = workSheet?.Cells[row, 1]?.GetValue(); + existingScore.RemarkExamOrder = workSheet?.Cells[row, 4]?.GetValue() ?? string.Empty; existingScore.LastUpdatedAt = DateTime.Now; existingScore.LastUpdateUserId = job.UserId ?? ""; existingScore.LastUpdateFullName = job.FullName ?? "System Administrator"; - batchUpdates.Add(existingScore); batchCount++; } + row++; + if (batchCount >= batchSize) { - await _context.BulkUpdateAsync(batchUpdates); - batchUpdates.Clear(); + await _context.SaveChangesAsync(); + _context.ChangeTracker.Clear(); + _context.Entry(rec_import).State = EntityState.Unchanged; batchCount = 0; } } + } - // Process remaining records - if (batchUpdates.Count > 0) - { - await _context.BulkUpdateAsync(batchUpdates); - } - } while (reader.NextResult()); + await _context.SaveChangesAsync(); } #endregion @@ -866,81 +688,6 @@ public class ImportBackgroundService : BackgroundService } } - /// - /// Get string value from ExcelDataReader by header column name - /// - private static string GetCellValue(IExcelDataReader reader, string[] cols, string headerName) - { - var idx = GetColumnIndex(cols, headerName); - if (idx <= 0 || idx > reader.FieldCount) return ""; - return reader.GetValue(idx - 1)?.ToString() ?? ""; - } - - /// - /// Get DateTime value from ExcelDataReader by header column name - /// - private static DateTime? GetCellDateTime(IExcelDataReader reader, string[] cols, string headerName) - { - var idx = GetColumnIndex(cols, headerName); - if (idx <= 0 || idx > reader.FieldCount) return null; - var val = reader.GetValue(idx - 1); - if (val is DateTime dt) return dt; - if (val != null && DateTime.TryParse(val.ToString(), out var parsed)) return parsed; - return null; - } - - /// - /// Get double value from ExcelDataReader by header column name - /// - private static double GetCellDouble(IExcelDataReader reader, string[] cols, string headerName) - { - var idx = GetColumnIndex(cols, headerName); - if (idx <= 0 || idx > reader.FieldCount) return 0.0; - var val = reader.GetValue(idx - 1); - if (val is double d) return d; - if (val != null && double.TryParse(val.ToString(), out var parsed)) return parsed; - return 0.0; - } - - /// - /// Get decimal value from ExcelDataReader by header column name - /// - private static decimal GetCellDecimal(IExcelDataReader reader, string[] cols, string headerName) - { - var idx = GetColumnIndex(cols, headerName); - if (idx <= 0 || idx > reader.FieldCount) return 0m; - var val = reader.GetValue(idx - 1); - if (val is decimal dec) return dec; - if (val is double dbl) return (decimal)dbl; - if (val != null && decimal.TryParse(val.ToString(), out var parsed)) return parsed; - return 0m; - } - - /// - /// Get double value from ExcelDataReader by 0-based column index - /// - private static double GetReaderDouble(IExcelDataReader reader, int index) - { - if (index < 0 || index >= reader.FieldCount) return 0.0; - var val = reader.GetValue(index); - if (val is double d) return d; - if (val != null && double.TryParse(val.ToString(), out var parsed)) return parsed; - return 0.0; - } - - /// - /// Get decimal value from ExcelDataReader by 0-based column index - /// - private static decimal GetReaderDecimal(IExcelDataReader reader, int index) - { - if (index < 0 || index >= reader.FieldCount) return 0m; - var val = reader.GetValue(index); - if (val is decimal dec) return dec; - if (val is double dbl) return (decimal)dbl; - if (val != null && decimal.TryParse(val.ToString(), out var parsed)) return parsed; - return 0m; - } - #endregion } diff --git a/Services/ImportJobTracker.cs b/Services/ImportJobTracker.cs index eed3188..fcefd8b 100644 --- a/Services/ImportJobTracker.cs +++ b/Services/ImportJobTracker.cs @@ -36,7 +36,6 @@ public class ImportJobInfo public string ImportDocId { get; set; } = ""; public string? UserId { get; set; } public string? FullName { get; set; } - public string? Token { get; set; } // For CandidateFile public PostRecruitImportRequest? Request { get; set; } @@ -45,11 +44,9 @@ public class ImportJobInfo public class ImportJobTracker { private readonly ConcurrentDictionary _jobs = new(); - private readonly TimeSpan _evictionAge = TimeSpan.FromHours(1); public ImportJobInfo CreateJob(ImportJobInfo job) { - EvictOldJobs(); _jobs[job.JobId] = job; return job; } @@ -68,23 +65,7 @@ public class ImportJobTracker if (errorMessage != null) job.ErrorMessage = errorMessage; if (status == ImportJobStatus.Completed || status == ImportJobStatus.Failed) - { job.CompletedAt = DateTime.Now; - // Clear request data to free memory for completed/failed jobs - job.Request = null; - } - } - } - - private void EvictOldJobs() - { - var cutoff = DateTime.Now - _evictionAge; - foreach (var kvp in _jobs) - { - if (kvp.Value.CompletedAt.HasValue && kvp.Value.CompletedAt.Value < cutoff) - { - _jobs.TryRemove(kvp.Key, out _); - } } } } diff --git a/Services/MinIOService.cs b/Services/MinIOService.cs index cf231b2..a56eba2 100644 --- a/Services/MinIOService.cs +++ b/Services/MinIOService.cs @@ -72,13 +72,14 @@ namespace BMA.EHR.Recruit.Services { var id = Guid.NewGuid(); file.CopyTo(ms); - ms.Position = 0; // Reset stream position for reading + var fileBytes = ms.ToArray(); + System.IO.MemoryStream filestream = new System.IO.MemoryStream(fileBytes); var request = new PutObjectRequest { BucketName = _bucketName, Key = id.ToString("D"), - InputStream = ms, + InputStream = filestream, ContentType = file.ContentType, CannedACL = S3CannedACL.PublicRead }; diff --git a/Services/NotificationService.cs b/Services/NotificationService.cs deleted file mode 100644 index 9f142e7..0000000 --- a/Services/NotificationService.cs +++ /dev/null @@ -1,59 +0,0 @@ -using Microsoft.Extensions.Logging; -using Newtonsoft.Json; -using System.Net.Http.Headers; -using System.Text; - -namespace BMA.EHR.Recruit.Services; - -public class NotificationService -{ - private readonly IHttpClientFactory _httpClientFactory; - private readonly ILogger _logger; - private readonly IConfiguration _configuration; - - private string NotifyEndpoint = "https://hrmsbkk.case-collection.com/api/v1/org/through-socket/notify-from-token"; - - public NotificationService(IHttpClientFactory httpClientFactory, ILogger logger, IConfiguration configuration) - { - _httpClientFactory = httpClientFactory; - _logger = logger; - _configuration = configuration; - NotifyEndpoint = $"{_configuration["API"]}/org/through-socket/notify-from-token"; - } - - public async Task SendImportNotificationAsync(string? token, bool error, string message) - { - if (string.IsNullOrEmpty(token)) - { - _logger.LogWarning("Cannot send import notification: token is null or empty."); - return; - } - - try - { - var client = _httpClientFactory.CreateClient("default"); - client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); - - var payload = new - { - error, - message - }; - - var json = JsonConvert.SerializeObject(payload); - var content = new StringContent(json, Encoding.UTF8, "application/json"); - - var response = await client.PostAsync(NotifyEndpoint, content); - - if (!response.IsSuccessStatusCode) - { - var responseBody = await response.Content.ReadAsStringAsync(); - _logger.LogWarning("Import notification failed with status {StatusCode}: {Body}", response.StatusCode, responseBody); - } - } - catch (Exception ex) - { - _logger.LogError(ex, "Failed to send import notification: {Message}", ex.Message); - } - } -} diff --git a/appsettings.json b/appsettings.json index 4585fbe..869e914 100644 --- a/appsettings.json +++ b/appsettings.json @@ -18,7 +18,7 @@ "MongoConnection": "mongodb://admin:adminVM123@127.0.0.1:27017", "DefaultConnection": "Server=192.168.1.63;User ID=root;Password=12345678;Port=3306;database=hrms;Convert Zero Datetime=True;Allow User Variables=true;Pooling=True;SslMode=None", "OrgConnection": "Server=192.168.1.63;User ID=root;Password=12345678;Port=3306;database=hrms_organization;Convert Zero Datetime=True;Allow User Variables=true;Pooling=True;SslMode=None", - "RecruitConnection": "Server=192.168.1.63;User ID=root;Password=12345678;Port=3306;database=hrms_recruit;Convert Zero Datetime=True;Allow User Variables=true;Pooling=True;SslMode=None;AllowLoadLocalInfile=true;" + "RecruitConnection": "Server=192.168.1.63;User ID=root;Password=12345678;Port=3306;database=hrms_recruit;Convert Zero Datetime=True;Allow User Variables=true;Pooling=True;SslMode=None" }, "Jwt": { "Key": "j7C9RO_p4nRtuwCH4z9Db_A_6We42tkD_p4lZtDrezc", diff --git a/bin/Debug/net7.0/appsettings.json b/bin/Debug/net7.0/appsettings.json index 4585fbe..869e914 100644 --- a/bin/Debug/net7.0/appsettings.json +++ b/bin/Debug/net7.0/appsettings.json @@ -18,7 +18,7 @@ "MongoConnection": "mongodb://admin:adminVM123@127.0.0.1:27017", "DefaultConnection": "Server=192.168.1.63;User ID=root;Password=12345678;Port=3306;database=hrms;Convert Zero Datetime=True;Allow User Variables=true;Pooling=True;SslMode=None", "OrgConnection": "Server=192.168.1.63;User ID=root;Password=12345678;Port=3306;database=hrms_organization;Convert Zero Datetime=True;Allow User Variables=true;Pooling=True;SslMode=None", - "RecruitConnection": "Server=192.168.1.63;User ID=root;Password=12345678;Port=3306;database=hrms_recruit;Convert Zero Datetime=True;Allow User Variables=true;Pooling=True;SslMode=None;AllowLoadLocalInfile=true;" + "RecruitConnection": "Server=192.168.1.63;User ID=root;Password=12345678;Port=3306;database=hrms_recruit;Convert Zero Datetime=True;Allow User Variables=true;Pooling=True;SslMode=None" }, "Jwt": { "Key": "j7C9RO_p4nRtuwCH4z9Db_A_6We42tkD_p4lZtDrezc", diff --git a/obj/project.assets.json b/obj/project.assets.json index 82551d3..424a2d0 100644 --- a/obj/project.assets.json +++ b/obj/project.assets.json @@ -155,43 +155,6 @@ } } }, - "dotMorten.Microsoft.SqlServer.Types/1.4.0": { - "type": "package", - "dependencies": { - "System.Data.SqlClient": "4.8.3", - "System.Memory": "4.5.4" - }, - "compile": { - "lib/netstandard2.0/Microsoft.SqlServer.Types.dll": { - "related": ".pdb;.xml" - } - }, - "runtime": { - "lib/netstandard2.0/Microsoft.SqlServer.Types.dll": { - "related": ".pdb;.xml" - } - } - }, - "EFCore.BulkExtensions.MySql/6.7.16": { - "type": "package", - "dependencies": { - "EntityFrameworkCore.SqlServer.HierarchyId": "3.0.1", - "MedallionTopologicalSort": "1.0.0", - "Microsoft.EntityFrameworkCore.SqlServer.NetTopologySuite": "6.0.21", - "Pomelo.EntityFrameworkCore.MySql": "6.0.2", - "StrongNamer": "0.2.5" - }, - "compile": { - "lib/net6.0/EFCore.BulkExtensions.MySql.dll": { - "related": ".pdb;.xml" - } - }, - "runtime": { - "lib/net6.0/EFCore.BulkExtensions.MySql.dll": { - "related": ".pdb;.xml" - } - } - }, "Elasticsearch.Net/7.17.5": { "type": "package", "dependencies": { @@ -210,42 +173,6 @@ } } }, - "EntityFrameworkCore.SqlServer.HierarchyId/3.0.1": { - "type": "package", - "dependencies": { - "EntityFrameworkCore.SqlServer.HierarchyId.Abstractions": "3.0.1", - "Microsoft.EntityFrameworkCore.SqlServer": "6.0.1" - }, - "compile": { - "lib/net6.0/EntityFrameworkCore.SqlServer.HierarchyId.dll": { - "related": ".xml" - } - }, - "runtime": { - "lib/net6.0/EntityFrameworkCore.SqlServer.HierarchyId.dll": { - "related": ".xml" - } - }, - "build": { - "build/net6.0/_._": {} - } - }, - "EntityFrameworkCore.SqlServer.HierarchyId.Abstractions/3.0.1": { - "type": "package", - "dependencies": { - "dotMorten.Microsoft.SqlServer.Types": "1.4.0" - }, - "compile": { - "lib/netstandard2.0/EntityFrameworkCore.SqlServer.HierarchyId.Abstractions.dll": { - "related": ".xml" - } - }, - "runtime": { - "lib/netstandard2.0/EntityFrameworkCore.SqlServer.HierarchyId.Abstractions.dll": { - "related": ".xml" - } - } - }, "EPPlus/6.1.3": { "type": "package", "dependencies": { @@ -289,35 +216,6 @@ "lib/net7.0/EPPlus.System.Drawing.dll": {} } }, - "ExcelDataReader/3.8.0": { - "type": "package", - "compile": { - "lib/netstandard2.1/ExcelDataReader.dll": { - "related": ".pdb;.xml" - } - }, - "runtime": { - "lib/netstandard2.1/ExcelDataReader.dll": { - "related": ".pdb;.xml" - } - } - }, - "ExcelDataReader.DataSet/3.8.0": { - "type": "package", - "dependencies": { - "ExcelDataReader": "3.8.0" - }, - "compile": { - "lib/netstandard2.1/ExcelDataReader.DataSet.dll": { - "related": ".pdb;.xml" - } - }, - "runtime": { - "lib/netstandard2.1/ExcelDataReader.DataSet.dll": { - "related": ".pdb;.xml" - } - } - }, "Google.Protobuf/3.19.4": { "type": "package", "compile": { @@ -406,19 +304,6 @@ } } }, - "MedallionTopologicalSort/1.0.0": { - "type": "package", - "compile": { - "lib/netstandard2.0/MedallionTopologicalSort.dll": { - "related": ".xml" - } - }, - "runtime": { - "lib/netstandard2.0/MedallionTopologicalSort.dll": { - "related": ".xml" - } - } - }, "Microsoft.AspNetCore.Antiforgery/2.2.0": { "type": "package", "dependencies": { @@ -1697,27 +1582,6 @@ } } }, - "Microsoft.EntityFrameworkCore.SqlServer.NetTopologySuite/6.0.21": { - "type": "package", - "dependencies": { - "Microsoft.EntityFrameworkCore.SqlServer": "6.0.21", - "NetTopologySuite": "2.3.0", - "NetTopologySuite.IO.SqlServerBytes": "2.0.0" - }, - "compile": { - "lib/net6.0/Microsoft.EntityFrameworkCore.SqlServer.NetTopologySuite.dll": { - "related": ".xml" - } - }, - "runtime": { - "lib/net6.0/Microsoft.EntityFrameworkCore.SqlServer.NetTopologySuite.dll": { - "related": ".xml" - } - }, - "build": { - "build/net6.0/_._": {} - } - }, "Microsoft.EntityFrameworkCore.Tools/7.0.3": { "type": "package", "dependencies": { @@ -2763,38 +2627,6 @@ "System.Xml.XDocument": "4.3.0" } }, - "NetTopologySuite/2.3.0": { - "type": "package", - "dependencies": { - "System.Memory": "4.5.3" - }, - "compile": { - "lib/netstandard2.0/NetTopologySuite.dll": { - "related": ".xml" - } - }, - "runtime": { - "lib/netstandard2.0/NetTopologySuite.dll": { - "related": ".xml" - } - } - }, - "NetTopologySuite.IO.SqlServerBytes/2.0.0": { - "type": "package", - "dependencies": { - "NetTopologySuite": "[2.0.0, 3.0.0-A)" - }, - "compile": { - "lib/netstandard2.0/NetTopologySuite.IO.SqlServerBytes.dll": { - "related": ".xml" - } - }, - "runtime": { - "lib/netstandard2.0/NetTopologySuite.IO.SqlServerBytes.dll": { - "related": ".xml" - } - } - }, "Newtonsoft.Json/13.0.3": { "type": "package", "compile": { @@ -3504,12 +3336,6 @@ } } }, - "StrongNamer/0.2.5": { - "type": "package", - "build": { - "build/_._": {} - } - }, "Swashbuckle.AspNetCore/6.5.0": { "type": "package", "dependencies": { @@ -5551,38 +5377,6 @@ "lib/netstandard2.1/DnsClient.xml" ] }, - "dotMorten.Microsoft.SqlServer.Types/1.4.0": { - "sha512": "MYxVbuBguObk8QFNTuBZ+ZEC/m1zbvG774FbFvwiDZjc0RYq/co27THrHN5Dyd52ie0R5bt2uxSZj4tIb3lYFg==", - "type": "package", - "path": "dotmorten.microsoft.sqlserver.types/1.4.0", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "README.md", - "dotmorten.microsoft.sqlserver.types.1.4.0.nupkg.sha512", - "dotmorten.microsoft.sqlserver.types.nuspec", - "lib/netstandard2.0/Microsoft.SqlServer.Types.dll", - "lib/netstandard2.0/Microsoft.SqlServer.Types.pdb", - "lib/netstandard2.0/Microsoft.SqlServer.Types.xml" - ] - }, - "EFCore.BulkExtensions.MySql/6.7.16": { - "sha512": "XJbeYxAKeRrI/gVXw08Nx9ZJiP2aRDyqJgW7GRTmxIUUVyp8hgVqasLUaBh0LA6PmtQr+eCg8LzyUYvSF4U9hA==", - "type": "package", - "path": "efcore.bulkextensions.mysql/6.7.16", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "EFCoreBulk.png", - "LICENSE.txt", - "README.md", - "efcore.bulkextensions.mysql.6.7.16.nupkg.sha512", - "efcore.bulkextensions.mysql.nuspec", - "lib/net6.0/EFCore.BulkExtensions.MySql.dll", - "lib/net6.0/EFCore.BulkExtensions.MySql.pdb", - "lib/net6.0/EFCore.BulkExtensions.MySql.xml" - ] - }, "Elasticsearch.Net/7.17.5": { "sha512": "orChsQi1Ceho/NyIylNOn6y4vuGcsbCfMZnCueNN0fzqYEGQmQdPfcVmsR5+3fwpXTgxCdjTUVmqOwvHpCSB+Q==", "type": "package", @@ -5605,33 +5399,6 @@ "nuget-icon.png" ] }, - "EntityFrameworkCore.SqlServer.HierarchyId/3.0.1": { - "sha512": "NDN8PwDIyuWfOR6nV0muaCEvCDuAFYPEtKOku+/TIzOWMmvPNqqLF0WF0BQpk4cVuvQ2fr5/9F7aZk4DkVTq4g==", - "type": "package", - "path": "entityframeworkcore.sqlserver.hierarchyid/3.0.1", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "build/net6.0/EntityFrameworkCore.SqlServer.HierarchyId.targets", - "entityframeworkcore.sqlserver.hierarchyid.3.0.1.nupkg.sha512", - "entityframeworkcore.sqlserver.hierarchyid.nuspec", - "lib/net6.0/EntityFrameworkCore.SqlServer.HierarchyId.dll", - "lib/net6.0/EntityFrameworkCore.SqlServer.HierarchyId.xml" - ] - }, - "EntityFrameworkCore.SqlServer.HierarchyId.Abstractions/3.0.1": { - "sha512": "x0Y3QtTLd1oyQMHTpXmUnuXabAs44kZBlP0suVQjlreF76e55x2D9YDiXRwUekvtI+X+b0NLkYfsnAqf9W/58w==", - "type": "package", - "path": "entityframeworkcore.sqlserver.hierarchyid.abstractions/3.0.1", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "entityframeworkcore.sqlserver.hierarchyid.abstractions.3.0.1.nupkg.sha512", - "entityframeworkcore.sqlserver.hierarchyid.abstractions.nuspec", - "lib/netstandard2.0/EntityFrameworkCore.SqlServer.HierarchyId.Abstractions.dll", - "lib/netstandard2.0/EntityFrameworkCore.SqlServer.HierarchyId.Abstractions.xml" - ] - }, "EPPlus/6.1.3": { "sha512": "1NEgW7wMxHWz7k3hN6D7PPkCCKR24LK86EIIEwfKrBy+yyWQM/fsCrngt+DPAjVgGLOThVmXInSFJqD15X7OCQ==", "type": "package", @@ -5699,56 +5466,6 @@ "readme.md" ] }, - "ExcelDataReader/3.8.0": { - "sha512": "kbUsldc5Fn9IKgzL2nr4VvN/mKqPqn8zGXUZpA7uL6svCA4psF+qMK519EhMvderpU4pAJoqk9DWpiSIkiZtXA==", - "type": "package", - "path": "exceldatareader/3.8.0", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "ExcelDataReader.png", - "README.md", - "exceldatareader.3.8.0.nupkg.sha512", - "exceldatareader.nuspec", - "lib/net462/ExcelDataReader.dll", - "lib/net462/ExcelDataReader.pdb", - "lib/net462/ExcelDataReader.xml", - "lib/net8.0/ExcelDataReader.dll", - "lib/net8.0/ExcelDataReader.pdb", - "lib/net8.0/ExcelDataReader.xml", - "lib/netstandard2.0/ExcelDataReader.dll", - "lib/netstandard2.0/ExcelDataReader.pdb", - "lib/netstandard2.0/ExcelDataReader.xml", - "lib/netstandard2.1/ExcelDataReader.dll", - "lib/netstandard2.1/ExcelDataReader.pdb", - "lib/netstandard2.1/ExcelDataReader.xml" - ] - }, - "ExcelDataReader.DataSet/3.8.0": { - "sha512": "+eQg5oinHir7ayE/rF4dedvy8J6FBDG8RDyKFQsS/VZG9ygrnNgW6U8JSlrfGfe3DxYgbVoVwYV9Hbk63JQJFQ==", - "type": "package", - "path": "exceldatareader.dataset/3.8.0", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "ExcelDataReader.png", - "README.md", - "exceldatareader.dataset.3.8.0.nupkg.sha512", - "exceldatareader.dataset.nuspec", - "lib/net462/ExcelDataReader.DataSet.dll", - "lib/net462/ExcelDataReader.DataSet.pdb", - "lib/net462/ExcelDataReader.DataSet.xml", - "lib/net8.0/ExcelDataReader.DataSet.dll", - "lib/net8.0/ExcelDataReader.DataSet.pdb", - "lib/net8.0/ExcelDataReader.DataSet.xml", - "lib/netstandard2.0/ExcelDataReader.DataSet.dll", - "lib/netstandard2.0/ExcelDataReader.DataSet.pdb", - "lib/netstandard2.0/ExcelDataReader.DataSet.xml", - "lib/netstandard2.1/ExcelDataReader.DataSet.dll", - "lib/netstandard2.1/ExcelDataReader.DataSet.pdb", - "lib/netstandard2.1/ExcelDataReader.DataSet.xml" - ] - }, "Google.Protobuf/3.19.4": { "sha512": "fd07/ykL4O4FhqrZIELm5lmiyOHfdPg9+o+hWr6tcfRdS7tHXnImg/2wtogLzlW2eEmr0J7j6ZrZvaWOLiJbxQ==", "type": "package", @@ -5869,21 +5586,6 @@ "litedb.nuspec" ] }, - "MedallionTopologicalSort/1.0.0": { - "sha512": "dcAqM8TcyZQ/T466CvqNMUUn/G0FQE+4R7l62ngXH7hLFP9yA7yoP/ySsLgiXx3pGUQC3J+cUvXmJOOR/eC+oQ==", - "type": "package", - "path": "medalliontopologicalsort/1.0.0", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "lib/net45/MedallionTopologicalSort.dll", - "lib/net45/MedallionTopologicalSort.xml", - "lib/netstandard2.0/MedallionTopologicalSort.dll", - "lib/netstandard2.0/MedallionTopologicalSort.xml", - "medalliontopologicalsort.1.0.0.nupkg.sha512", - "medalliontopologicalsort.nuspec" - ] - }, "Microsoft.AspNetCore.Antiforgery/2.2.0": { "sha512": "fVQsSXNZz38Ysx8iKwwqfOLHhLrAeKEMBS5Ia3Lh7BJjOC2vPV28/yk08AovOMsB3SNQPGnE7bv+lsIBTmAkvw==", "type": "package", @@ -6980,21 +6682,6 @@ "microsoft.entityframeworkcore.sqlserver.nuspec" ] }, - "Microsoft.EntityFrameworkCore.SqlServer.NetTopologySuite/6.0.21": { - "sha512": "D6c+WWg6GIcpuHKxHVr6hJ5RFVfwPlgK/PQ0vV+z7f8haRY7l3tlK/xhJeYZvXCpPluyijM4KRRPi/qbUFxROA==", - "type": "package", - "path": "microsoft.entityframeworkcore.sqlserver.nettopologysuite/6.0.21", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "Icon.png", - "build/net6.0/Microsoft.EntityFrameworkCore.SqlServer.NetTopologySuite.targets", - "lib/net6.0/Microsoft.EntityFrameworkCore.SqlServer.NetTopologySuite.dll", - "lib/net6.0/Microsoft.EntityFrameworkCore.SqlServer.NetTopologySuite.xml", - "microsoft.entityframeworkcore.sqlserver.nettopologysuite.6.0.21.nupkg.sha512", - "microsoft.entityframeworkcore.sqlserver.nettopologysuite.nuspec" - ] - }, "Microsoft.EntityFrameworkCore.Tools/7.0.3": { "sha512": "yHFlYPZS3Jx7JMCQnGKfJzv95rJWVcmcUn/OW5cbCyWgQk81JJpTZ9Q6kkvwquYjFRfvYHBGuXNIYhAJokOBTQ==", "type": "package", @@ -8625,33 +8312,6 @@ "netstandard.library.nuspec" ] }, - "NetTopologySuite/2.3.0": { - "sha512": "Y+YOvA5um+75Wm9NKE+EhUNCvLYWiPhPW5Q5eBNi6kVNbxsX60/nvIJtve5iRcbrAl38W9h2w2yBjU81cjDO5g==", - "type": "package", - "path": "nettopologysuite/2.3.0", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "icon.png", - "lib/netstandard2.0/NetTopologySuite.dll", - "lib/netstandard2.0/NetTopologySuite.xml", - "nettopologysuite.2.3.0.nupkg.sha512", - "nettopologysuite.nuspec" - ] - }, - "NetTopologySuite.IO.SqlServerBytes/2.0.0": { - "sha512": "TuyMB0VSlRJx86UrWeQ+SGgOMudvhIL1qJJdWJw78nWsXIzKRP4ooQAhhhCCH7n8q1lvd0/NW3ByaLlHxxNSPQ==", - "type": "package", - "path": "nettopologysuite.io.sqlserverbytes/2.0.0", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "lib/netstandard2.0/NetTopologySuite.IO.SqlServerBytes.dll", - "lib/netstandard2.0/NetTopologySuite.IO.SqlServerBytes.xml", - "nettopologysuite.io.sqlserverbytes.2.0.0.nupkg.sha512", - "nettopologysuite.io.sqlserverbytes.nuspec" - ] - }, "Newtonsoft.Json/13.0.3": { "sha512": "HrC5BXdl00IP9zeV+0Z848QWPAoCr9P3bDEZguI+gkLcBKAOxix/tLEAAHC+UvDNPv4a2d18lOReHMOagPa+zQ==", "type": "package", @@ -9490,29 +9150,6 @@ "snappier.nuspec" ] }, - "StrongNamer/0.2.5": { - "sha512": "1IWl8gYnsTC6NXHz63iDpXL8r0y5x0M/Cnq/Ju5uM17gTOQYSeclMkgQsvmGglJEqAwVxayY1sIUR3bb2MAy5Q==", - "type": "package", - "path": "strongnamer/0.2.5", - "files": [ - ".nupkg.metadata", - ".signature.p7s", - "build/SharedKey.snk", - "build/StrongNamer.targets", - "build/net461/Mono.Cecil.Mdb.dll", - "build/net461/Mono.Cecil.Pdb.dll", - "build/net461/Mono.Cecil.Rocks.dll", - "build/net461/Mono.Cecil.dll", - "build/net461/StrongNamer.dll", - "build/netcoreapp2.1/Mono.Cecil.Mdb.dll", - "build/netcoreapp2.1/Mono.Cecil.Pdb.dll", - "build/netcoreapp2.1/Mono.Cecil.Rocks.dll", - "build/netcoreapp2.1/Mono.Cecil.dll", - "build/netcoreapp2.1/StrongNamer.dll", - "strongnamer.0.2.5.nupkg.sha512", - "strongnamer.nuspec" - ] - }, "Swashbuckle.AspNetCore/6.5.0": { "sha512": "FK05XokgjgwlCI6wCT+D4/abtQkL1X1/B9Oas6uIwHFmYrIO9WUD5aLC9IzMs9GnHfUXOtXZ2S43gN1mhs5+aA==", "type": "package", @@ -14073,10 +13710,7 @@ "net7.0": [ "AWSSDK.S3 >= 3.7.103.35", "CoreAdmin >= 2.7.0", - "EFCore.BulkExtensions.MySql >= 6.7.16", "EPPlus >= 6.1.3", - "ExcelDataReader >= 3.8.0", - "ExcelDataReader.DataSet >= 3.8.0", "Microsoft.AspNetCore.Authentication.JwtBearer >= 7.0.20", "Microsoft.AspNetCore.Mvc.NewtonsoftJson >= 7.0.3", "Microsoft.AspNetCore.Mvc.Versioning >= 5.0.0", @@ -14162,22 +13796,10 @@ "target": "Package", "version": "[2.7.0, )" }, - "EFCore.BulkExtensions.MySql": { - "target": "Package", - "version": "[6.7.16, )" - }, "EPPlus": { "target": "Package", "version": "[6.1.3, )" }, - "ExcelDataReader": { - "target": "Package", - "version": "[3.8.0, )" - }, - "ExcelDataReader.DataSet": { - "target": "Package", - "version": "[3.8.0, )" - }, "Microsoft.AspNetCore.Authentication.JwtBearer": { "target": "Package", "version": "[7.0.20, )" diff --git a/obj/project.nuget.cache b/obj/project.nuget.cache index 4529909..e8d0055 100644 --- a/obj/project.nuget.cache +++ b/obj/project.nuget.cache @@ -1,6 +1,6 @@ { "version": 2, - "dgSpecHash": "++tptrWNc3M=", + "dgSpecHash": "D0RTCj18huw=", "success": true, "projectFilePath": "/Users/suphonchaip/Develop/hrms/hrms-api-recruit/BMA.EHR.Recruit.csproj", "expectedPackageFiles": [ @@ -13,23 +13,16 @@ "/Users/suphonchaip/.nuget/packages/coreadmin/2.7.0/coreadmin.2.7.0.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/dapper/2.0.123/dapper.2.0.123.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/dnsclient/1.6.1/dnsclient.1.6.1.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/dotmorten.microsoft.sqlserver.types/1.4.0/dotmorten.microsoft.sqlserver.types.1.4.0.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/efcore.bulkextensions.mysql/6.7.16/efcore.bulkextensions.mysql.6.7.16.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/elasticsearch.net/7.17.5/elasticsearch.net.7.17.5.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/entityframeworkcore.sqlserver.hierarchyid/3.0.1/entityframeworkcore.sqlserver.hierarchyid.3.0.1.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/entityframeworkcore.sqlserver.hierarchyid.abstractions/3.0.1/entityframeworkcore.sqlserver.hierarchyid.abstractions.3.0.1.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/epplus/6.1.3/epplus.6.1.3.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/epplus.interfaces/6.1.1/epplus.interfaces.6.1.1.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/epplus.system.drawing/6.1.1/epplus.system.drawing.6.1.1.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/exceldatareader/3.8.0/exceldatareader.3.8.0.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/exceldatareader.dataset/3.8.0/exceldatareader.dataset.3.8.0.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/google.protobuf/3.19.4/google.protobuf.3.19.4.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/humanizer.core/2.14.1/humanizer.core.2.14.1.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/k4os.compression.lz4/1.2.6/k4os.compression.lz4.1.2.6.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/k4os.compression.lz4.streams/1.2.6/k4os.compression.lz4.streams.1.2.6.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/k4os.hash.xxhash/1.0.6/k4os.hash.xxhash.1.0.6.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/litedb/5.0.11/litedb.5.0.11.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/medalliontopologicalsort/1.0.0/medalliontopologicalsort.1.0.0.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/microsoft.aspnetcore.antiforgery/2.2.0/microsoft.aspnetcore.antiforgery.2.2.0.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/microsoft.aspnetcore.authentication.abstractions/2.2.0/microsoft.aspnetcore.authentication.abstractions.2.2.0.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/microsoft.aspnetcore.authentication.core/2.2.0/microsoft.aspnetcore.authentication.core.2.2.0.nupkg.sha512", @@ -100,7 +93,6 @@ "/Users/suphonchaip/.nuget/packages/microsoft.entityframeworkcore.relational/7.0.3/microsoft.entityframeworkcore.relational.7.0.3.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/microsoft.entityframeworkcore.relational.design/1.1.1/microsoft.entityframeworkcore.relational.design.1.1.1.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/microsoft.entityframeworkcore.sqlserver/7.0.3/microsoft.entityframeworkcore.sqlserver.7.0.3.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/microsoft.entityframeworkcore.sqlserver.nettopologysuite/6.0.21/microsoft.entityframeworkcore.sqlserver.nettopologysuite.6.0.21.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/microsoft.entityframeworkcore.tools/7.0.3/microsoft.entityframeworkcore.tools.7.0.3.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/microsoft.extensions.apidescription.server/6.0.5/microsoft.extensions.apidescription.server.6.0.5.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/microsoft.extensions.caching.abstractions/7.0.0/microsoft.extensions.caching.abstractions.7.0.0.nupkg.sha512", @@ -159,8 +151,6 @@ "/Users/suphonchaip/.nuget/packages/mysqlconnector/2.2.5/mysqlconnector.2.2.5.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/nest/7.17.5/nest.7.17.5.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/netstandard.library/1.6.1/netstandard.library.1.6.1.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/nettopologysuite/2.3.0/nettopologysuite.2.3.0.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/nettopologysuite.io.sqlserverbytes/2.0.0/nettopologysuite.io.sqlserverbytes.2.0.0.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/newtonsoft.json/13.0.3/newtonsoft.json.13.0.3.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/newtonsoft.json.bson/1.0.2/newtonsoft.json.bson.1.0.2.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/nonfactors.grid.core.mvc6/7.1.0/nonfactors.grid.core.mvc6.7.1.0.nupkg.sha512", @@ -207,7 +197,6 @@ "/Users/suphonchaip/.nuget/packages/serilog.sinks.periodicbatching/3.1.0/serilog.sinks.periodicbatching.3.1.0.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/sharpcompress/0.30.1/sharpcompress.0.30.1.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/snappier/1.0.0/snappier.1.0.0.nupkg.sha512", - "/Users/suphonchaip/.nuget/packages/strongnamer/0.2.5/strongnamer.0.2.5.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/swashbuckle.aspnetcore/6.5.0/swashbuckle.aspnetcore.6.5.0.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/swashbuckle.aspnetcore.annotations/6.5.0/swashbuckle.aspnetcore.annotations.6.5.0.nupkg.sha512", "/Users/suphonchaip/.nuget/packages/swashbuckle.aspnetcore.swagger/6.5.0/swashbuckle.aspnetcore.swagger.6.5.0.nupkg.sha512",