hrms-api-exam/Controllers/DisableController.cs

2559 lines
149 KiB
C#
Raw Normal View History

2023-04-29 10:26:03 +07:00
using Amazon.S3.Model;
using BMA.EHR.Recurit.Exam.Service.Extensions;
2023-04-29 10:26:03 +07:00
using BMA.EHR.Recurit.Exam.Service.Controllers;
using BMA.EHR.Recurit.Exam.Service.Core;
using BMA.EHR.Recurit.Exam.Service.Data;
using BMA.EHR.Recurit.Exam.Service.Extensions;
using BMA.EHR.Recurit.Exam.Service.Models;
using BMA.EHR.Recurit.Exam.Service.Models.Disables;
using BMA.EHR.Recurit.Exam.Service.Request.Disables;
using BMA.EHR.Recurit.Exam.Service.Response;
using BMA.EHR.Recurit.Exam.Service.Responses;
using BMA.EHR.Recurit.Exam.Service.Services;
2023-05-02 03:57:51 +07:00
using BMA.EHR.Recurit.Exam.Service.Responses.Document;
2023-04-29 10:26:03 +07:00
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using MySqlConnector;
using OfficeOpenXml;
using Org.BouncyCastle.Ocsp;
using Sentry;
using Swashbuckle.AspNetCore.Annotations;
using System.Data;
using System.Net;
using System.Net.WebSockets;
using System.Security.Claims;
using System.Text;
2024-08-20 11:04:07 +07:00
using Newtonsoft.Json.Linq;
using Newtonsoft.Json;
2025-02-18 13:24:50 +07:00
using System.Net.Http.Headers;
2025-10-13 22:30:10 +07:00
using BMA.EHR.Recurit.Exam.Service.Request;
2023-04-29 10:26:03 +07:00
namespace BMA.EHR.Recurit.Exam.Service.Controllers
{
2023-05-04 12:53:19 +07:00
[Route("api/v{version:apiVersion}/candidate/disable-exam")]
2023-04-29 10:26:03 +07:00
[ApiVersion("1.0")]
[ApiController]
[Produces("application/json")]
[Authorize]
[SwaggerTag("จัดการข้อมูลการสอบคัดเลือกคนพิการ")]
public class DisableController : BaseController
{
#region " Fields "
private readonly ApplicationDbContext _context;
private readonly MetadataDbContext _contextMetadata;
2023-04-29 10:26:03 +07:00
private readonly MinIOService _minioService;
private readonly IWebHostEnvironment _webHostEnvironment;
private readonly DisableService _disableService;
private readonly PeriodExamService _periodExamService;
2024-08-20 11:04:07 +07:00
private readonly PermissionRepository _permission;
2023-04-29 10:26:03 +07:00
private readonly IHttpContextAccessor _httpContextAccessor;
private readonly ILogger<DisableController> _logger;
2025-02-18 13:24:50 +07:00
private readonly IConfiguration _configuration;
2023-04-29 10:26:03 +07:00
#endregion
#region " Constructor and Destructor "
public DisableController(ApplicationDbContext context,
MetadataDbContext contextMetadata,
2023-04-29 10:26:03 +07:00
MinIOService minioService,
IWebHostEnvironment webHostEnvironment,
DisableService disableService,
PeriodExamService periodExamService,
2023-04-29 10:26:03 +07:00
IHttpContextAccessor httpContextAccessor,
2024-08-20 11:04:07 +07:00
ILogger<DisableController> logger,
2025-02-18 13:24:50 +07:00
IConfiguration configuration,
2024-08-20 11:04:07 +07:00
PermissionRepository permission)
2023-04-29 10:26:03 +07:00
{
_context = context;
_contextMetadata = contextMetadata;
2023-04-29 10:26:03 +07:00
_minioService = minioService;
_webHostEnvironment = webHostEnvironment;
_disableService = disableService;
_periodExamService = periodExamService;
2023-04-29 10:26:03 +07:00
_httpContextAccessor = httpContextAccessor;
2025-02-18 13:24:50 +07:00
_configuration = configuration;
2023-04-29 10:26:03 +07:00
_logger = logger;
2024-08-20 11:04:07 +07:00
_permission = permission;
2023-04-29 10:26:03 +07:00
}
#endregion
#region " Properties "
private string? UserId => _httpContextAccessor?.HttpContext?.User?.FindFirst(ClaimTypes.NameIdentifier)?.Value;
private string? FullName => _httpContextAccessor?.HttpContext?.User?.FindFirst("name")?.Value;
2025-02-18 13:24:50 +07:00
private string? token => _httpContextAccessor.HttpContext.Request.Headers["Authorization"];
2023-04-29 10:26:03 +07:00
#endregion
#region " Methods "
#region " Private "
private int GetColumnIndex(string[] columns, string name, bool partial = false)
{
try
{
if (partial)
return Array.FindIndex(columns, x => x.Contains(name)) + 1;
else
return Array.FindIndex(columns, x => x == name) + 1;
}
catch
{
return 0;
}
}
private string CalculateDiff(DateTime d1, DateTime d2)
{
if (d1 > d2) return "ข้อมูลไม่ถูกต้อง";
TimeSpan sp = d2.Subtract(d1);
int yy = sp.Days / 365;
int mm = (sp.Days - (yy * 365)) / 30;
int dd = (sp.Days - (yy * 365) - (mm * 30));
var sb = new StringBuilder();
sb.Clear();
sb.Append(yy == 0 ? "" : $"{yy} ปี ");
sb.Append(mm == 0 ? "" : $"{mm} เดือน ");
//sb.Append(dd == 0 ? "" : $"{dd} วัน ");
return sb.ToString();
}
private async Task<int> GetExamCount(Guid exam)
{
try
{
return await _context.DisablePayments.AsQueryable()
.Include(x => x.Disable)
.ThenInclude(x => x.PeriodExam)
.Where(x => x.Disable.PeriodExam.Id == exam)
.Where(x => x.Disable.PeriodExam.CheckDisability == true)
.CountAsync();
}
catch
{
throw;
}
}
private async Task<int> GetPassExamCount(Guid exam)
{
try
{
return await _context.DisableScores.AsQueryable()
.Include(x => x.ScoreImport)
.Where(x => x.ScoreImport.Id == exam)
.Where(x => x.ExamStatus == "ผ่าน")
.CountAsync();
}
catch
{
throw;
}
}
private async Task<int> GetScoreCount(Guid exam)
{
try
{
return await _context.DisableScores.AsQueryable()
.Include(x => x.ScoreImport)
.Where(x => x.ScoreImport.Id == exam)
.CountAsync();
}
catch
{
throw;
}
}
#endregion
#region " Ex. Upload, Download and Delete file "
/// <summary>
/// ตัวอย่างในการเขียน api เพื่อทำการ upload file
/// </summary>
/// <returns></returns>
/// <response code="200">เมื่อทำการ upload สำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpPost("upload"), DisableRequestSizeLimit]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
[AllowAnonymous]
public async Task<ActionResult<ResponseObject>> UploadFile()
{
try
{
if (Request.Form.Files == null || Request.Form.Files.Count == 0)
{
return Error(GlobalMessages.NoFileToUpload);
}
var file = Request.Form.Files[0];
var doc = await _minioService.UploadFileAsync(file);
return Success(doc);
}
catch (Exception ex)
{
return Error(ex);
}
}
/// <summary>
/// ตัวอย่างในการเขียน api เพื่อทำการ delete file
/// </summary>
/// <param name="id">รหัสไฟล์ในฐานข้อมูล</param>
/// <returns></returns>
/// <response code="200">เมื่อทำการ delete file สำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpGet("delete/{id:length(36)}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
[AllowAnonymous]
public async Task<ActionResult<ResponseObject>> DeleteFile(Guid id)
{
try
{
await _minioService.DeleteFileAsync(id);
return Success();
}
catch (Exception ex)
{
return Error(ex);
}
}
/// <summary>
/// ตัวอย่างในการเขียน api เพื่อทำการ download file
/// </summary>
/// <param name="id">รหัสไฟล์ในฐานข้อมูล</param>
/// <returns></returns>
/// <response code="200">เมื่อทำการ download file สำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpGet("download/{id:length(36)}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
[AllowAnonymous]
public async Task<ActionResult<ResponseObject>> DownloadFile(Guid id)
{
try
{
var file_data = await _minioService.DownloadFileAsync(id);
Response.Headers["Content-Disposition"] = $"inline; filename={file_data.FileName}";
var ret = new FileContentResult(file_data.FileContent, file_data.FileType)
{
FileDownloadName = file_data.FileName
};
return ret;
}
catch (Exception ex)
{
return Error(ex);
}
}
#endregion
#region " จัดการรอบการสมัครสอบคัดเลือกผู้พิการ "
/// <summary>
/// แสดงข้อมูลรอบการสอบคัดเลือกผู้พิการ
/// </summary>
/// <returns></returns>
/// <response code="200">เมื่อทำการอ่านข้อมูลจาก Relational Database สำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpGet("period")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> GetPeriodsAsync()
{
try
{
var data = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.ImportFile)
.Include(x => x.Disables)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.ImportFile)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.Scores)
.OrderByDescending(x => x.Year)
.ThenByDescending(x => x.Round)
.Select(x => new
{
x.Id,
x.Year,
x.Name,
x.Round,
ImportDate = x.CreatedAt.Date.ToThaiShortDate(),
ExamCount = x.Disables.Count(),
Score = x.ScoreImport == null ? null :
new
{
ID = x.ScoreImport.Id,
ImportYear = x.ScoreImport.Year,
ImportDate = x.CreatedAt.Date.ToThaiShortDate(),
ScoreCount = x.ScoreImport.Scores.Count(),
}
})
.ToListAsync();
return Success(data);
}
catch (Exception ex)
{
return Error(ex);
}
}
/// <summary>
/// แสดงข้อมูลรอบการสอบคัดเลือกผู้พิการเป็นรายการ
/// </summary>
/// <param name="id">รหัสรอบการสอบคัดเลือกผู้พิการ</param>
/// <returns></returns>
/// <response code="200">เมื่อทำการอ่านข้อมูลจาก Relational Database สำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpGet("period/{id:length(36)}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> GetPeriodByIdAsync(Guid id)
{
try
{
2023-05-02 03:57:51 +07:00
// var data = await _context.PeriodExams.AsQueryable()
// .Where(x => x.CheckDisability == true)
// .Include(x => x.ImportFile)
// .Include(x => x.Disables)
// .ThenInclude(x => x.Addresses)
// .Include(x => x.Disables)
// .ThenInclude(x => x.Occupations)
// .Include(x => x.Disables)
// .ThenInclude(x => x.Certificates)
// .Include(x => x.Disables)
// .ThenInclude(x => x.Educations)
// .Include(x => x.Disables)
// .ThenInclude(x => x.Payments)
// .Include(x => x.Disables)
// .ThenInclude(x => x.Documents)
// .ThenInclude(x => x.DocumentFile)
// .FirstOrDefaultAsync(x => x.Id == id);
var periodExam = await _context.PeriodExams.AsQueryable()
.Select(x => new PeriodExamCandidateResponseItem
2023-05-02 03:57:51 +07:00
{
ExamDate = x.ExamDate,
AnnouncementEndDate = x.AnnouncementEndDate,
AnnouncementStartDate = x.AnnouncementStartDate,
AnnouncementDate = x.AnnouncementDate,
CheckDisability = x.CheckDisability,
CheckDocument = x.CheckDocument,
Detail = x.Detail,
Fee = x.Fee,
Id = x.Id,
IsActive = x.IsActive,
Name = x.Name,
Note = x.Note,
// OrganizationCodeId = x.OrganizationCodeId,
// OrganizationCodeName = x.OrganizationCodeName,
// OrganizationId = x.OrganizationId,
// OrganizationName = x.OrganizationName,
PaymentEndDate = x.PaymentEndDate,
// PaymentKrungThai = x.PaymentKrungThai,
AnnouncementExam = x.AnnouncementExam,
Category = x.Category,
PaymentStartDate = x.PaymentStartDate,
RegisterEndDate = x.RegisterEndDate,
RegisterStartDate = x.RegisterStartDate,
Round = x.Round,
// SetSeat = x.SetSeat,
Year = x.Year,
// BankExam = x.BankExam.OrderBy(o => o.CreatedAt).Select(b => new BankExam
// {
// Id = b.Id,
// AccountName = b.AccountName,
// AccountNumber = b.AccountNumber,
// BankName = b.BankName,
// }).ToList(),
// PositionExam = x.PositionExam.OrderBy(o => o.CreatedAt).Select(b => new PositionExam
// {
// Id = b.Id,
// TypeId = b.TypeId,
// TypeName = b.TypeName,
// PositionId = b.PositionId,
// PositionName = b.PositionName,
// }).ToList(),
Documents = x.PeriodExamDocuments.OrderBy(o => o.CreatedAt).Select(b => new FileListResponse
{
Id = b.Document == null ? "" : b.Document.Id.ToString(),
FileName = b.Document == null ? "" : b.Document.FileName,
FileSize = b.Document == null ? 0 : b.Document.FileSize,
FileType = b.Document == null ? "" : b.Document.FileType,
Detail = b.Document == null ? "" : b.Document.Id.ToString(),
}).ToList(),
Images = x.PeriodExamImages.OrderBy(o => o.CreatedAt).Select(b => new FileListResponse
{
Id = b.Document == null ? "" : b.Document.Id.ToString(),
FileName = b.Document == null ? "" : b.Document.FileName,
FileSize = b.Document == null ? 0 : b.Document.FileSize,
FileType = b.Document == null ? "" : b.Document.FileType,
Detail = b.Document == null ? "" : b.Document.Id.ToString(),
}).ToList(),
})
.FirstOrDefaultAsync(x => x.Id == id);
if (periodExam == null)
throw new Exception(GlobalMessages.ExamNotFound);
2023-05-02 03:57:51 +07:00
return Success(periodExam);
2023-04-29 10:26:03 +07:00
}
catch (Exception ex)
{
return Error(ex);
}
}
/// <summary>
/// เพิ่มข้อมูลรอบการจัดสอบคัดเลือกผู้พิการ
/// </summary>
/// <param name="req">Request parameters</param>
/// <returns></returns>
/// <response code="200">เมื่อทำการเพิ่มข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpPost("period")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> PostPeriodAsync([FromBody] PostDisableImportRequest req)
{
try
{
if (req == null)
return Error(GlobalMessages.InvalidRequestParam, (int)HttpStatusCode.BadRequest);
var periodExam = new PeriodExam
2023-04-29 10:26:03 +07:00
{
Year = req.Year,
Name = req.Name,
Round = req.Round,
Detail = req.Detail,
Fee = req.Fee,
AnnouncementStartDate = req.AnnouncementStartDate,
AnnouncementEndDate = req.AnnouncementEndDate,
RegisterStartDate = req.RegisterStartDate,
RegisterEndDate = req.RegisterEndDate,
ExamDate = req.ExamDate,
PaymentStartDate = req.PaymentStartDate,
PaymentEndDate = req.PaymentEndDate,
Note = req.Note,
AnnouncementDate = req.AnnouncementDate,
CheckDisability = true,
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
};
2025-09-15 16:02:57 +07:00
var apiUrl = $"{_configuration["API"]}/org/find/head/officer";
using (var client = new HttpClient())
{
client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
client.DefaultRequestHeaders.Add("api_key", _configuration["API_KEY"]);
var _req = new HttpRequestMessage(HttpMethod.Get, apiUrl);
var _res = await client.SendAsync(_req);
var _result = await _res.Content.ReadAsStringAsync();
if (_res.IsSuccessStatusCode)
{
var org = JsonConvert.DeserializeObject<dynamic>(_result);
periodExam.AuthName = org.result.name == null ? "" : org.result.name;
periodExam.AuthPosition = org.result.position == null ? "" : org.result.position;
}
}
await _context.PeriodExams.AddAsync(periodExam);
2023-04-29 10:26:03 +07:00
await _context.SaveChangesAsync();
2025-07-09 16:50:57 +07:00
return Success(periodExam.Id);
2023-04-29 10:26:03 +07:00
}
catch (Exception ex)
{
return Error(ex);
}
}
/// <summary>
/// แก้ไขข้อมูลรอบการจัดสอบคัดเลือกผู้พิการ
/// </summary>
/// <param name="id">รหัสรอบการสอบคัดเลือกผู้พิการ</param>
/// <param name="req">Request parameters</param>
/// <returns></returns>
/// <response code="200">เมื่อทำการเพิ่มข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpPut("period/{id:length(36)}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> PutPeriodAsync(Guid id, [FromBody] PostDisableImportRequest req)
{
try
{
2026-02-27 22:30:41 +07:00
var getPermission = await _permission.GetPermissionAPIAsync("UPDATE", "SYS_EXAM_SELECT_PERIOD_DIS");
2024-08-20 11:04:07 +07:00
var jsonData = JsonConvert.DeserializeObject<JObject>(getPermission);
if (jsonData["status"]?.ToString() != "200")
{
return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden);
}
2023-04-29 10:26:03 +07:00
var data = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.FirstOrDefaultAsync(x => x.Id == id);
if (data == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
data.Name = req.Name;
data.Year = req.Year;
data.Round = req.Round;
data.Detail = req.Detail;
data.Fee = req.Fee;
data.AnnouncementEndDate = req.AnnouncementEndDate;
data.AnnouncementStartDate = req.AnnouncementStartDate;
data.RegisterStartDate = req.RegisterStartDate;
data.RegisterEndDate = req.RegisterEndDate;
data.PaymentEndDate = req.PaymentEndDate;
data.PaymentStartDate = req.PaymentStartDate;
data.ExamDate = req.ExamDate;
data.Note = req.Note;
data.AnnouncementDate = req.AnnouncementDate;
data.LastUpdatedAt = DateTime.Now;
data.LastUpdateUserId = UserId ?? "";
data.LastUpdateFullName = FullName ?? "System Administrator";
2023-04-29 10:26:03 +07:00
await _context.SaveChangesAsync();
return Success();
}
catch (Exception ex)
{
return Error(ex);
}
}
/// <summary>
/// ลบข้อมูลรอบการจัดสอบคัดเลือกผู้พิการ
/// </summary>
/// <param name="id">รหัสรอบการสอบคัดเลือกผู้พิการ</param>
/// <returns></returns>
/// <response code="200">เมื่อทำการลบข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpDelete("period/{id:length(36)}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> DeletePeriodAsync(Guid id)
{
try
{
2026-02-27 22:30:41 +07:00
var getPermission = await _permission.GetPermissionAPIAsync("DELETE", "SYS_EXAM_SELECT_PERIOD_DIS");
2024-08-20 11:04:07 +07:00
var jsonData = JsonConvert.DeserializeObject<JObject>(getPermission);
if (jsonData["status"]?.ToString() != "200")
{
return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden);
}
2023-04-29 10:26:03 +07:00
var data = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.ImportFile)
.Include(x => x.Disables)
.ThenInclude(x => x.Addresses)
.Include(x => x.Disables)
.ThenInclude(x => x.Occupations)
.Include(x => x.Disables)
.ThenInclude(x => x.Certificates)
.Include(x => x.Disables)
.ThenInclude(x => x.Educations)
.Include(x => x.Disables)
.ThenInclude(x => x.Payments)
.Include(x => x.Disables)
.ThenInclude(x => x.Documents)
.ThenInclude(x => x.DocumentFile)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.ImportFile)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.Scores)
.FirstOrDefaultAsync(x => x.Id == id);
_context.PeriodExams.Remove(data);
await _context.SaveChangesAsync();
return Success();
}
catch (Exception ex)
{
return Error(ex);
}
}
#endregion
#region " Candidate Files "
/// <summary>
/// แสดงข้อมูลสำหรับหน้าจอ รายการนำเข้าข้อมูลผู้สมัครสอบคัดเลือกผู้พิการ
/// </summary>
/// <returns></returns>
/// <response code="200">เมื่อแสดงรายการข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpGet("candidate")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> GetCandidateFilesAsync()
{
try
{
2026-02-27 22:30:41 +07:00
var getPermission = await _permission.GetPermissionAPIAsync("LIST", "SYS_EXAM_SELECT_PERIOD_DIS");
2024-08-22 17:39:23 +07:00
var jsonData = JsonConvert.DeserializeObject<JObject>(getPermission);
if (jsonData["status"]?.ToString() != "200")
{
return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden);
}
2023-04-29 10:26:03 +07:00
var data = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.ImportFile)
.Include(x => x.Disables)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.ImportFile)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.Scores)
.OrderByDescending(x => x.Year)
.ThenByDescending(x => x.Round)
.ThenByDescending(x => x.LastUpdatedAt)
2023-04-29 10:26:03 +07:00
.Select(x => new
{
x.Id,
x.Year,
x.Name,
x.Round,
ImportDate = x.CreatedAt.Date.ToThaiShortDate(),
ExamCount = x.Disables.Count(),
Score = x.ScoreImport == null || x.ScoreImport.Scores.Count == 0 ? null :
2023-04-29 10:26:03 +07:00
new
{
ID = x.ScoreImport.Id,
ImportYear = x.ScoreImport.Year,
ImportDate = x.CreatedAt.Date.ToThaiShortDate(),
ScoreCount = x.ScoreImport.Scores.Count(),
ResultCount = x.ScoreImport.Scores.Count(x => !string.IsNullOrEmpty(x.Number))
},
x.CreatedUserId,
2023-04-29 10:26:03 +07:00
})
.ToListAsync();
var roles = _httpContextAccessor?.HttpContext?.User?.FindAll(ClaimTypes.Role)?.Select(c => c.Value).ToList();
2025-01-05 21:59:15 +07:00
return Success(data);
2023-04-29 10:26:03 +07:00
}
catch (Exception ex)
{
return Error(ex);
}
}
/// <summary>
/// นำเข้ารายชื่อผู้สมัครสอบคัดเลือกผู้พิการ
/// </summary>
/// <returns></returns>
/// <response code="200">เมื่อทำนำเข้าข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpPost("candidate"), DisableRequestSizeLimit]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> ImportCandidateFileAsync([FromForm] PostDisableImportRequest req)
{
var tmpDir = Path.Combine(_webHostEnvironment.ContentRootPath, "tmp");
if (!Directory.Exists(tmpDir))
Directory.CreateDirectory(tmpDir);
var importFile = Path.Combine(tmpDir, $"c_{DateTime.Now.ToString("ddMMyyyyHHmmss")}.xlsx");
var import_doc_id = "";
try
{
if (Request.Form.Files == null || Request.Form.Files.Count == 0)
{
return Error(GlobalMessages.NoFileToUpload);
}
var file = Request.Form.Files[0];
var doc = await _minioService.UploadFileAsync(file);
import_doc_id = doc.Id.ToString("D");
var fileContent = (await _minioService.DownloadFileAsync(doc.Id)).FileContent;
// สร้างรอบการบรรจุ โดยเอาเข้ามูลมาใส่จาก Request
var imported = new PeriodExam
{
Year = req.Year,
Round = req.Round,
Name = req.Name,
ImportFile = doc,
CheckDisability = true,
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
ImportHostories = new List<DisableImportHistory>
{
new DisableImportHistory
{
Description = "นำเข้าข้อมูลผู้สมัครสอบคัดเลือกผู้พิการ",
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
}
}
};
await _context.PeriodExams.AddAsync(imported);
// import datafile
System.IO.File.WriteAllBytes(importFile, fileContent);
using (var c_package = new ExcelPackage(new FileInfo(importFile)))
{
// loop from sheet2 to end
2025-04-21 16:14:05 +07:00
for (int i = 0; i < c_package.Workbook.Worksheets.Count; i++)
2023-04-29 10:26:03 +07:00
{
var workSheet = c_package.Workbook.Worksheets[i];
var totalRows = workSheet.Dimension.Rows;
var cols = workSheet.GetHeaderColumns();
int row = 2;
while (row <= totalRows)
{
var cell1 = workSheet?.Cells[row, 1]?.GetValue<string>();
if (cell1 == "" || cell1 == null) break;
var r = new Recurit.Exam.Service.Models.Disables.Disable();
r.ExamId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ExamID)]?.GetValue<string>();
r.CitizenId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PersonalID)]?.GetValue<string>();
r.Prefix = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Prefix)]?.GetValue<string>();
r.FirstName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.FirstName)]?.GetValue<string>();
r.LastName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.LastName)]?.GetValue<string>();
r.Gendor = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Gender)]?.GetValue<string>();
r.National = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.National)]?.GetValue<string>().IsNull("");
r.Race = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Race)]?.GetValue<string>().IsNull("");
r.Religion = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Religion)]?.GetValue<string>().IsNull("");
r.DateOfBirth = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.DateOfBirth)]?.GetValue<string>().ToDateTime(DateTimeFormat.Ymd, "-"));
r.Marry = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Marry)]?.GetValue<string>();
r.Isspecial = "N";
r.CitizenCardIssuer = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PersonalCardIssue)]?.GetValue<string>();
r.CitizenCardExpireDate = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PersonalCardExpireDate)]?.GetValue<string>().ToDateTime(DateTimeFormat.Ymd, "-"));
r.ApplyDate = (DateTime)workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ApplyDate)]?.GetValue<DateTime>();
r.PositionName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PositionName)]?.GetValue<string>().IsNull("");
2025-01-05 21:59:15 +07:00
r.PositionType = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PositionType)]?.GetValue<string>().IsNull("");
r.PositionLevel = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PositionLevel)]?.GetValue<string>().IsNull("");
2023-04-29 10:26:03 +07:00
// address
r.Addresses.Add(new DisableAddress()
{
Address = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Address)]?.GetValue<string>() ?? "",
Moo = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Moo)]?.GetValue<string>() ?? "",
Soi = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Soi)]?.GetValue<string>() ?? "",
Road = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Road)]?.GetValue<string>() ?? "",
District = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.District)]?.GetValue<string>() ?? "",
Amphur = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Amphur)]?.GetValue<string>() ?? "",
Province = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Province)]?.GetValue<string>() ?? "",
ZipCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ZipCode)]?.GetValue<string>() ?? "",
Telephone = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Telephone)]?.GetValue<string>() ?? "",
Mobile = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Mobile)]?.GetValue<string>() ?? "",
Address1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Address1)]?.GetValue<string>() ?? "",
Moo1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Moo1)]?.GetValue<string>() ?? "",
Soi1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Soi1)]?.GetValue<string>() ?? "",
Road1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Road1)]?.GetValue<string>() ?? "",
District1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.District1)]?.GetValue<string>() ?? "",
Amphur1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Amphur1)]?.GetValue<string>() ?? "",
Province1 = "",
ZipCode1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ZipCode1)]?.GetValue<string>() ?? "",
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
});
// payment
r.Payments.Add(new DisablePayment()
{
PaymentId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PaymentID)]?.GetValue<string>() ?? "",
CompanyCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CompanyCode)]?.GetValue<string>() ?? "",
TextFile = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TextFile)]?.GetValue<string>() ?? "",
BankCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.BankCode)]?.GetValue<string>() ?? "",
AccountNumber = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.AccouontNumer)]?.GetValue<string>() ?? "",
TransDate = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TransDate)]?.GetValue<string>() ?? "",
TransTime = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TransTime)]?.GetValue<string>() ?? "",
CustomerName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CustomerName)]?.GetValue<string>() ?? "",
RefNo1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.RefNo1)]?.GetValue<string>() ?? "",
TermBranch = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TermBranch)]?.GetValue<string>() ?? "",
TellerId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TellerID)]?.GetValue<string>() ?? "",
CreditDebit = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CreditDebit)]?.GetValue<string>() ?? "",
PaymentType = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Type)]?.GetValue<string>(),
ChequeNo = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ChequeNo)]?.GetValue<string>() ?? "",
Amount = (decimal)workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Amount)]?.GetValue<decimal>(),
ChqueBankCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ChqBankCode)]?.GetValue<string>() ?? "",
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
});
// occupation
r.Occupations.Add(new DisableOccupation()
{
Occupation = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Occupation)]?.GetValue<string>() ?? "",
Position = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Position)]?.GetValue<string>() ?? "",
Workplace = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Workplace)]?.GetValue<string>() ?? "",
Telephone = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.WorkplaceTelephone)]?.GetValue<string>() ?? "",
WorkAge = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.WorkAge)]?.GetValue<string>() ?? "",
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
});
// certificate
r.Certificates.Add(new DisableCertificate()
{
CertificateNo = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateNo)]?.GetValue<string>() ?? "",
Description = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateDesc)]?.GetValue<string>() ?? "",
IssueDate = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateIssueDate)]?.GetValue<string>().ToDateTime(DateTimeFormat.Ymd, "-")),
ExpiredDate = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateExpireDate)]?.GetValue<string>().ToDateTime(DateTimeFormat.Ymd, "-")),
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
});
r.Educations.Add(new DisableEducation()
{
Degree = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Degree)]?.GetValue<string>() ?? "",
Major = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Major)]?.GetValue<string>() ?? "",
MajorGroupId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.MajorGroupID)]?.GetValue<string>() ?? "",
MajorGroupName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.MajorGroupName)]?.GetValue<string>() ?? "",
University = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.University)]?.GetValue<string>() ?? "",
GPA = (double)workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.GPA)]?.GetValue<double>(),
Specialist = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.SpecialList)]?.GetValue<string>() ?? "",
HighDegree = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.HighDegree)]?.GetValue<string>() ?? "",
BachelorDate = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.BachelorDate)]?.GetValue<string>().ToDateTime(DateTimeFormat.Ymd, "-")),
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
});
r.PeriodExam = imported;
_context.Disables.Add(r);
//imported.Disables.Add(r);
row++;
}
}
}
// finally save to database
_context.SaveChanges();
return Success();
}
catch (Exception ex)
{
await _minioService.DeleteFileAsync(Guid.Parse(import_doc_id));
return Error(ex);
}
finally
{
if (System.IO.File.Exists(importFile))
System.IO.File.Delete(importFile);
}
}
/// <summary>
/// ลบข้อมูลนำข้อมูลผู้สมัครสอบคัดเลือกผู้พิการ
/// </summary>
/// <param name="id">รหัสรอบการสอบคัดเลือกผู้พิการ</param>
/// <returns></returns>
/// <response code="200">เมื่อทำนำเข้าข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpDelete("candidate/{id:length(36)}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> DeleteCandidateFileAsync(Guid id)
{
try
{
var data = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.ImportHostories)
.Include(x => x.ImportFile)
//.Include(x => x.Disables)
//.ThenInclude(x => x.Addresses)
//.Include(x => x.Disables)
//.ThenInclude(x => x.Occupations)
//.Include(x => x.Disables)
//.ThenInclude(x => x.Certificates)
//.Include(x => x.Disables)
//.ThenInclude(x => x.Educations)
//.Include(x => x.Disables)
//.ThenInclude(x => x.Payments)
//.Include(x => x.Disables)
//.ThenInclude(x => x.Documents)
//.ThenInclude(x => x.DocumentFile)
2023-04-29 10:26:03 +07:00
.Include(x => x.ScoreImport)
.ThenInclude(x => x.ImportFile)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.Scores)
.FirstOrDefaultAsync(x => x.Id == id);
if (data == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
var rec_import_id = data.ImportFile.Id.ToString("D");
var score_import_id = data.ScoreImport != null ? data.ScoreImport.ImportFile.Id.ToString("D") : "-";
_context.PeriodExams.Remove(data);
await _context.SaveChangesAsync();
// delete upload candidate file
await _minioService.DeleteFileAsync(Guid.Parse(rec_import_id));
// delete score file
if (score_import_id != "-")
await _minioService.DeleteFileAsync(Guid.Parse(score_import_id));
return Success();
}
catch (Exception ex)
{
return Error(ex);
}
}
/// <summary>
/// แสดงประวัติการนำเข้าข้อมูลการสอบคัดเลือกผู้พิการ
/// </summary>
/// <param name="id">รหัสรอบการสอบคัดเลือกผู้พิการ</param>
/// <returns></returns>
/// <response code="200">เมื่อทำนำเข้าข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpGet("history/{id:length(36)}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> GetImportHistoryAsync(Guid id)
{
try
{
2026-02-27 22:30:41 +07:00
var getPermission = await _permission.GetPermissionAPIAsync("GET", "SYS_EXAM_SELECT_PERIOD_DIS");
2024-08-22 17:39:23 +07:00
var jsonData = JsonConvert.DeserializeObject<JObject>(getPermission);
if (jsonData["status"]?.ToString() != "200")
{
return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden);
}
2023-04-29 10:26:03 +07:00
var data = await _context.DisableImportHistories.AsQueryable()
.Include(x => x.PeriodExam)
.Where(x => x.PeriodExam.Id == id)
.Where(x => x.PeriodExam.CheckDisability == true)
.OrderByDescending(x => x.CreatedAt)
.ToListAsync();
return Success(data);
}
catch (Exception ex)
{
return Error(ex);
}
}
/// <summary>
/// นำเข้ารายชื่อผู้สมัครสอบคัดเลือกผู้พิการ (ข้อมูลผู้สมัครสอบ)
2023-04-29 10:26:03 +07:00
/// </summary>
/// <param name="id">รหัสรอบการสอบคัดเลือกผู้พิการ</param>
/// <returns></returns>
/// <response code="200">เมื่อทำนำเข้าข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpPost("candidate/{id:length(36)}"), DisableRequestSizeLimit]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> ImportCandidateFileByIdAsync(Guid id)
{
2026-02-27 22:30:41 +07:00
var getPermission = await _permission.GetPermissionAPIAsync("CREATE", "SYS_EXAM_SELECT_PERIOD_DIS");
2024-08-20 11:04:07 +07:00
var jsonData = JsonConvert.DeserializeObject<JObject>(getPermission);
if (jsonData["status"]?.ToString() != "200")
{
return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden);
}
2023-04-29 10:26:03 +07:00
var tmpDir = Path.Combine(_webHostEnvironment.ContentRootPath, "tmp");
if (!Directory.Exists(tmpDir))
Directory.CreateDirectory(tmpDir);
var importFile = Path.Combine(tmpDir, $"c_{DateTime.Now.ToString("ddMMyyyyHHmmss")}.xlsx");
var import_doc_id = "";
try
{
if (Request.Form.Files == null || Request.Form.Files.Count == 0)
{
return Error(GlobalMessages.NoFileToUpload);
}
var imported = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.ImportHostories)
.Include(x => x.ImportFile)
.Include(x => x.Disables)
.ThenInclude(x => x.Addresses)
.Include(x => x.Disables)
.ThenInclude(x => x.Occupations)
.Include(x => x.Disables)
.ThenInclude(x => x.Certificates)
.Include(x => x.Disables)
.ThenInclude(x => x.Educations)
.Include(x => x.Disables)
.ThenInclude(x => x.Payments)
.Include(x => x.Disables)
.FirstOrDefaultAsync(x => x.Id == id);
if (imported == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
if (imported.Disables != null)
{
// remove old score data
_context.Disables.RemoveRange(imported.Disables);
await _context.SaveChangesAsync();
}
var file = Request.Form.Files[0];
var doc = await _minioService.UploadFileAsync(file);
import_doc_id = doc.Id.ToString("D");
var fileContent = (await _minioService.DownloadFileAsync(doc.Id)).FileContent;
// สร้างรอบการบรรจุ โดยเอาเข้ามูลมาใส่จาก Request
imported.ImportHostories.Add(new DisableImportHistory
{
Description = "นำเข้าข้อมูลผู้สมัครสอบคัดเลือกผู้พิการ",
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
});
//await _context.DisableImports.AddAsync(imported);
// import datafile
System.IO.File.WriteAllBytes(importFile, fileContent);
using (var c_package = new ExcelPackage(new FileInfo(importFile)))
{
// loop from sheet2 to end
2025-04-21 16:14:05 +07:00
for (int i = 0; i < c_package.Workbook.Worksheets.Count; i++)
2023-04-29 10:26:03 +07:00
{
var workSheet = c_package.Workbook.Worksheets[i];
var totalRows = workSheet.Dimension.Rows;
var cols = workSheet.GetHeaderColumns();
int row = 2;
while (row <= totalRows)
{
var cell1 = workSheet?.Cells[row, 1]?.GetValue<string>();
if (cell1 == "" || cell1 == null) break;
# region old
////var r = new Recurit.Exam.Service.Models.Disables.Disable();
////r.ExamId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ExamID)]?.GetValue<string>();
////r.CitizenId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PersonalID)]?.GetValue<string>();
////r.Prefix = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Prefix)]?.GetValue<string>();
////r.FirstName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.FirstName)]?.GetValue<string>();
////r.LastName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.LastName)]?.GetValue<string>();
////r.Gendor = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Gender)]?.GetValue<string>();
////r.National = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.National)]?.GetValue<string>().IsNull("");
////r.Race = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Race)]?.GetValue<string>().IsNull("");
////r.Religion = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Religion)]?.GetValue<string>().IsNull("");
//////r.DateOfBirth = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.DateOfBirth)]?.GetValue<string>().ToDateTime(DateTimeFormat.Ymd, "-"));k
////r.DateOfBirth = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.DateOfBirth)]?.GetValue<string>()) ? _disableService.CheckDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.DateOfBirth)]?.GetValue<string>() ?? "", "yyyy-MM-dd") : DateTime.MinValue;
////r.Marry = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Marry)]?.GetValue<string>();
////r.Isspecial = "N";
////r.CitizenCardIssuer = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PersonalCardIssue)]?.GetValue<string>();
////r.CitizenCardExpireDate = Convert.ToDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PersonalCardExpireDate)]?.GetValue<string>().ToDateTime(DateTimeFormat.Ymd, "-"));
////r.ApplyDate = (DateTime)workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ApplyDate)]?.GetValue<DateTime>();
////r.PositionName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PositionName)]?.GetValue<string>().IsNull("");
////r.PositionType = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PositionType)]?.GetValue<string>().IsNull("");
////r.PositionLevel = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PositionLevel)]?.GetValue<string>().IsNull("");
////// address
////r.Addresses.Add(new DisableAddress()
////{
//// Address = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Address)]?.GetValue<string>() ?? "",
//// Moo = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Moo)]?.GetValue<string>() ?? "",
//// Soi = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Soi)]?.GetValue<string>() ?? "",
//// Road = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Road)]?.GetValue<string>() ?? "",
//// District = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.District)]?.GetValue<string>() ?? "",
//// Amphur = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Amphur)]?.GetValue<string>() ?? "",
//// Province = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Province)]?.GetValue<string>() ?? "",
//// ZipCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ZipCode)]?.GetValue<string>() ?? "",
//// Telephone = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Telephone)]?.GetValue<string>() ?? "",
//// Mobile = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Mobile)]?.GetValue<string>() ?? "",
//// Address1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Address1)]?.GetValue<string>() ?? "",
//// Moo1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Moo1)]?.GetValue<string>() ?? "",
//// Soi1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Soi1)]?.GetValue<string>() ?? "",
//// Road1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Road1)]?.GetValue<string>() ?? "",
//// District1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.District1)]?.GetValue<string>() ?? "",
//// Amphur1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Amphur1)]?.GetValue<string>() ?? "",
//// Province1 = "",
//// ZipCode1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ZipCode1)]?.GetValue<string>() ?? "",
//// CreatedAt = DateTime.Now,
//// CreatedUserId = UserId ?? "",
//// CreatedFullName = FullName ?? "System Administrator",
//// LastUpdatedAt = DateTime.Now,
//// LastUpdateUserId = UserId ?? "",
//// LastUpdateFullName = FullName ?? "System Administrator",
////});
////// payment
////r.Payments.Add(new DisablePayment()
////{
//// PaymentId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.PaymentID)]?.GetValue<string>() ?? "",
//// CompanyCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CompanyCode)]?.GetValue<string>() ?? "",
//// TextFile = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TextFile)]?.GetValue<string>() ?? "",
//// BankCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.BankCode)]?.GetValue<string>() ?? "",
//// AccountNumber = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.AccouontNumer)]?.GetValue<string>() ?? "",
//// TransDate = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TransDate)]?.GetValue<string>() ?? "",
//// TransTime = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TransTime)]?.GetValue<string>() ?? "",
//// CustomerName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CustomerName)]?.GetValue<string>() ?? "",
//// RefNo1 = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.RefNo1)]?.GetValue<string>() ?? "",
//// TermBranch = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TermBranch)]?.GetValue<string>() ?? "",
//// TellerId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.TellerID)]?.GetValue<string>() ?? "",
//// CreditDebit = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CreditDebit)]?.GetValue<string>() ?? "",
//// PaymentType = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Type)]?.GetValue<string>(),
//// ChequeNo = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ChequeNo)]?.GetValue<string>() ?? "",
//// Amount = (decimal)workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Amount)]?.GetValue<decimal>(),
//// ChqueBankCode = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.ChqBankCode)]?.GetValue<string>() ?? "",
//// CreatedAt = DateTime.Now,
//// CreatedUserId = UserId ?? "",
//// CreatedFullName = FullName ?? "System Administrator",
//// LastUpdatedAt = DateTime.Now,
//// LastUpdateUserId = UserId ?? "",
//// LastUpdateFullName = FullName ?? "System Administrator",
////});
////// occupation
////r.Occupations.Add(new DisableOccupation()
////{
//// Occupation = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Occupation)]?.GetValue<string>() ?? "",
//// Position = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Position)]?.GetValue<string>() ?? "",
//// Workplace = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Workplace)]?.GetValue<string>() ?? "",
//// Telephone = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.WorkplaceTelephone)]?.GetValue<string>() ?? "",
//// WorkAge = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.WorkAge)]?.GetValue<string>() ?? "",
//// CreatedAt = DateTime.Now,
//// CreatedUserId = UserId ?? "",
//// CreatedFullName = FullName ?? "System Administrator",
//// LastUpdatedAt = DateTime.Now,
//// LastUpdateUserId = UserId ?? "",
//// LastUpdateFullName = FullName ?? "System Administrator",
////});
////// certificate
////r.Certificates.Add(new DisableCertificate()
////{
//// CertificateNo = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateNo)]?.GetValue<string>() ?? "",
//// Description = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateDesc)]?.GetValue<string>() ?? "",
//// IssueDate = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateIssueDate)]?.GetValue<string>()) ? _disableService.CheckDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateIssueDate)]?.GetValue<string>() ?? "", "yyyy-MM-dd") : DateTime.MinValue,
//// ExpiredDate = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateExpireDate)]?.GetValue<string>()) ? _disableService.CheckDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.CertificateExpireDate)]?.GetValue<string>() ?? "", "yyyy-MM-dd") : DateTime.MinValue,
//// CreatedAt = DateTime.Now,
//// CreatedUserId = UserId ?? "",
//// CreatedFullName = FullName ?? "System Administrator",
//// LastUpdatedAt = DateTime.Now,
//// LastUpdateUserId = UserId ?? "",
//// LastUpdateFullName = FullName ?? "System Administrator",
////});
////r.Educations.Add(new DisableEducation()
////{
//// Degree = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Degree)]?.GetValue<string>() ?? "",
//// Major = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.Major)]?.GetValue<string>() ?? "",
//// MajorGroupId = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.MajorGroupID)]?.GetValue<string>() ?? "",
//// MajorGroupName = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.MajorGroupName)]?.GetValue<string>() ?? "",
//// University = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.University)]?.GetValue<string>() ?? "",
//// GPA = (double)workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.GPA)]?.GetValue<double>(),
//// Specialist = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.SpecialList)]?.GetValue<string>() ?? "",
//// HighDegree = workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.HighDegree)]?.GetValue<string>() ?? "",
//// BachelorDate = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.BachelorDate)]?.GetValue<string>()) ? _disableService.CheckDateTime(workSheet?.Cells[row, GetColumnIndex(cols, CandidateFileHeader.BachelorDate)]?.GetValue<string>() ?? "", "yyyy-MM-dd") : DateTime.MinValue,
//// CreatedAt = DateTime.Now,
//// CreatedUserId = UserId ?? "",
//// CreatedFullName = FullName ?? "System Administrator",
//// LastUpdatedAt = DateTime.Now,
//// LastUpdateUserId = UserId ?? "",
//// LastUpdateFullName = FullName ?? "System Administrator",
////});
# endregion
var r = new Models.Disables.Disable();
r.ExamId = workSheet?.Cells[row, 1]?.GetValue<string>() ?? "";
r.PositionName = workSheet?.Cells[row, 3]?.GetValue<string>() ?? "";
r.HddPosition = workSheet?.Cells[row, 4]?.GetValue<string>() ?? "";
r.Prefix = workSheet?.Cells[row, 5]?.GetValue<string>() == "อื่น ๆ" ? workSheet?.Cells[row, 6]?.GetValue<string>() ?? "" : workSheet?.Cells[row, 5]?.GetValue<string>() ?? "";
r.FirstName = workSheet?.Cells[row, 7]?.GetValue<string>() ?? "";
r.LastName = workSheet?.Cells[row, 8]?.GetValue<string>() ?? "";
r.Gendor = workSheet?.Cells[row, 98]?.GetValue<string>() ?? "";
r.National = workSheet?.Cells[row, 9]?.GetValue<string>() ?? "";
r.Race = "";
r.Religion = workSheet?.Cells[row, 10]?.GetValue<string>() ?? "";
r.DateOfBirth = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, 11]?.GetValue<string>()) ? _disableService.CheckDateTime(workSheet?.Cells[row, 11]?.GetValue<string>() ?? "", "dd/MM/yyyy") : null;
r.CitizenId = workSheet?.Cells[row, 12]?.GetValue<string>() ?? "";
r.typeTest = workSheet?.Cells[row, 13]?.GetValue<string>() ?? "";
r.Marry = "";
2023-04-29 10:26:03 +07:00
r.Isspecial = "N";
r.CitizenCardIssuer = "";
r.CitizenCardExpireDate = null;
r.ModifiedDate = null;
r.ApplyDate = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, 87]?.GetValue<string>()) ? _disableService.CheckDateTime(workSheet?.Cells[row, 87]?.GetValue<string>() ?? "", "dd/MM/yyyy") : null;
r.PositionType = "";
r.PositionLevel = "";
r.CreatedAt = DateTime.Now;
r.CreatedUserId = UserId ?? "";
r.CreatedFullName = FullName ?? "System Administrator";
r.LastUpdatedAt = DateTime.Now;
r.LastUpdateUserId = UserId ?? "";
r.LastUpdateFullName = FullName ?? "System Administrator";
2023-04-29 10:26:03 +07:00
// education
r.Educations.Add(new DisableEducation()
2023-04-29 10:26:03 +07:00
{
Degree = workSheet?.Cells[row, 18]?.GetValue<string>() ?? "",
Major = workSheet?.Cells[row, 19]?.GetValue<string>() == "อื่น ๆ" ? workSheet?.Cells[row, 20]?.GetValue<string>() ?? "" : workSheet?.Cells[row, 19]?.GetValue<string>() ?? "",
MajorGroupId = "",
MajorGroupName = "",
University = workSheet?.Cells[row, 21]?.GetValue<string>() == "อื่น ๆ" ? workSheet?.Cells[row, 22]?.GetValue<string>() ?? "" : workSheet?.Cells[row, 21]?.GetValue<string>() ?? "",
GPA = (double)workSheet?.Cells[row, 26]?.GetValue<double>(),
Specialist = "",
HighDegree = workSheet?.Cells[row, 27]?.GetValue<string>() ?? "",
BachelorDate = !string.IsNullOrWhiteSpace(workSheet?.Cells[row, 25]?.GetValue<string>()) ? _disableService.CheckDateTime(workSheet?.Cells[row, 25]?.GetValue<string>() ?? "", "dd/MM/yyyy") : null,
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator"
2023-04-29 10:26:03 +07:00
});
// occupation
r.Occupations.Add(new DisableOccupation()
2023-04-29 10:26:03 +07:00
{
Occupation = workSheet?.Cells[row, 33]?.GetValue<string>() == "อื่น ๆ" ? workSheet?.Cells[row, 34]?.GetValue<string>() ?? "" : workSheet?.Cells[row, 33]?.GetValue<string>() ?? "",
Position = workSheet?.Cells[row, 37]?.GetValue<string>() ?? "",
Workplace = $"{(workSheet?.Cells[row, 36]?.GetValue<string>() ?? "")} {(workSheet?.Cells[row, 35]?.GetValue<string>() ?? "")}",
Telephone = "",
WorkAge = "",
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator"
2023-04-29 10:26:03 +07:00
});
// address
r.Addresses.Add(new DisableAddress()
2023-04-29 10:26:03 +07:00
{
Address = $"{(workSheet?.Cells[row, 49]?.GetValue<string>() ?? "")} {(workSheet?.Cells[row, 50]?.GetValue<string>() ?? "")}",
Moo = workSheet?.Cells[row, 51]?.GetValue<string>() ?? "",
Soi = workSheet?.Cells[row, 52]?.GetValue<string>() ?? "",
Road = workSheet?.Cells[row, 53]?.GetValue<string>() ?? "",
District = workSheet?.Cells[row, 54]?.GetValue<string>() ?? "",
Amphur = workSheet?.Cells[row, 55]?.GetValue<string>() ?? "",
Province = workSheet?.Cells[row, 56]?.GetValue<string>() ?? "",
ZipCode = (workSheet?.Cells[row, 57]?.GetValue<string>() ?? "").Trim(),
Telephone = workSheet?.Cells[row, 58]?.GetValue<string>() ?? "",
Mobile = "",
Address1 = $"{(workSheet?.Cells[row, 61]?.GetValue<string>() ?? "")} {(workSheet?.Cells[row, 62]?.GetValue<string>() ?? "")}",
Moo1 = workSheet?.Cells[row, 63]?.GetValue<string>() ?? "",
Soi1 = workSheet?.Cells[row, 64]?.GetValue<string>() ?? "",
Road1 = workSheet?.Cells[row, 65]?.GetValue<string>() ?? "",
District1 = workSheet?.Cells[row, 66]?.GetValue<string>() ?? "",
Amphur1 = workSheet?.Cells[row, 67]?.GetValue<string>() ?? "",
Province1 = workSheet?.Cells[row, 68]?.GetValue<string>() ?? "",
ZipCode1 = (workSheet?.Cells[row, 69]?.GetValue<string>() ?? "").Trim(),
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator"
2023-04-29 10:26:03 +07:00
});
// payment
r.Payments.Add(new DisablePayment()
2023-04-29 10:26:03 +07:00
{
PaymentId = workSheet?.Cells[row, 104]?.GetValue<string>() ?? "",
CompanyCode = workSheet?.Cells[row, 105]?.GetValue<string>() ?? "",
TextFile = workSheet?.Cells[row, 106]?.GetValue<string>() ?? "",
BankCode = workSheet?.Cells[row, 107]?.GetValue<string>() ?? "",
AccountNumber = workSheet?.Cells[row, 108]?.GetValue<string>() ?? "",
TransDate = workSheet?.Cells[row, 109]?.GetValue<string>() ?? "",
TransTime = workSheet?.Cells[row, 110]?.GetValue<string>() ?? "",
CustomerName = workSheet?.Cells[row, 111]?.GetValue<string>() ?? "",
RefNo1 = workSheet?.Cells[row, 112]?.GetValue<string>() ?? "",
TermBranch = workSheet?.Cells[row, 113]?.GetValue<string>() ?? "",
TellerId = workSheet?.Cells[row, 114]?.GetValue<string>() ?? "",
CreditDebit = workSheet?.Cells[row, 115]?.GetValue<string>() ?? "",
PaymentType = workSheet?.Cells[row, 116]?.GetValue<string>() ?? "",
ChequeNo = workSheet?.Cells[row, 117]?.GetValue<string>() ?? "",
Amount = (decimal)workSheet?.Cells[row, 118]?.GetValue<decimal>(),
ChqueBankCode = workSheet?.Cells[row, 119]?.GetValue<string>() ?? "",
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator"
2023-04-29 10:26:03 +07:00
});
/* Comment ข้อมูลใบประกอบวิชาชีพ เพราะใน template ยังไม่มีคอลัมน์ที่ระบุข้อมูลส่วนนี้ */
//// certificate
//r.Certificates.Add(new DisableCertificate()
//{
// CertificateNo = "",//workSheet?.Cells[row, 9999]?.GetValue<string>() ?? "",
// Description = "",//workSheet?.Cells[row, 9999]?.GetValue<string>() ?? "",
// IssueDate = DateTime.MinValue,//Convert.ToDateTime(workSheet?.Cells[row, 9999]?.GetValue<string>().ToDateTime(DateTimeFormat.Ymd, "-")),
// ExpiredDate = DateTime.MinValue,//Convert.ToDateTime(workSheet?.Cells[row, 9999]?.GetValue<string>().ToDateTime(DateTimeFormat.Ymd, "-")),
// CreatedAt = DateTime.Now,
// CreatedUserId = UserId ?? "",
// CreatedFullName = FullName ?? "System Administrator",
// LastUpdatedAt = DateTime.Now,
// LastUpdateUserId = UserId ?? "",
// LastUpdateFullName = FullName ?? "System Administrator"
//});
2023-04-29 10:26:03 +07:00
r.PeriodExam = imported;
_context.Disables.Add(r);
//imported.Disables.Add(r);
row++;
}
}
}
// finally save to database
_context.SaveChanges();
return Success();
}
catch (Exception ex)
{
await _minioService.DeleteFileAsync(Guid.Parse(import_doc_id));
return Error(ex);
}
finally
{
if (System.IO.File.Exists(importFile))
System.IO.File.Delete(importFile);
}
}
#endregion
#region " Score File "
/// <summary>
/// นำเข้าผลคะแนนสอบคัดเลือกผู้พิการ (บัญชีรวมคะแนน)
/// </summary>
/// <param name="id">รหัสรอบการสอบคัดเลือกผู้พิการ</param>
/// <returns></returns>
/// <response code="200">เมื่อทำนำเข้าข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
2023-04-29 10:26:03 +07:00
[HttpPost("score/{id:length(36)}"), DisableRequestSizeLimit]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
2023-04-29 10:26:03 +07:00
public async Task<ActionResult<ResponseObject>> ImportScoreFileAsync(Guid id)
{
2026-02-27 22:30:41 +07:00
var getPermission = await _permission.GetPermissionAPIAsync("CREATE", "SYS_EXAM_SELECT_PERIOD_DIS");
2024-08-20 11:04:07 +07:00
var jsonData = JsonConvert.DeserializeObject<JObject>(getPermission);
if (jsonData["status"]?.ToString() != "200")
{
return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden);
}
2023-04-29 10:26:03 +07:00
var tmpDir = Path.Combine(_webHostEnvironment.ContentRootPath, "tmp");
if (!Directory.Exists(tmpDir))
Directory.CreateDirectory(tmpDir);
var importFile = Path.Combine(tmpDir, $"s_{DateTime.Now.ToString("ddMMyyyyHHmmss")}.xlsx");
var import_doc_id = "";
try
{
if (Request.Form.Files == null || Request.Form.Files.Count == 0)
{
return Error(GlobalMessages.NoFileToUpload);
}
var rec_import = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.Scores)
.Include(x => x.ImportHostories)
.FirstOrDefaultAsync(x => x.Id == id);
if (rec_import == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
if (rec_import.ScoreImport != null)
{
// remove old score data
if (rec_import.ScoreImport.Scores != null)
{
_context.DisableScores.RemoveRange(rec_import.ScoreImport.Scores);
await _context.SaveChangesAsync();
}
}
var file = Request.Form.Files[0];
var doc = await _minioService.UploadFileAsync(file);
import_doc_id = doc.Id.ToString("D");
var fileContent = (await _minioService.DownloadFileAsync(doc.Id)).FileContent;
// create import history
rec_import.ImportHostories.Add(new DisableImportHistory
{
Description = "นำเข้าข้อมูลผลคะแนนสอบ",
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
});
// create new file import
var imported = new ScoreImport
{
Year = rec_import.Year,
ImportFile = doc,
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
2023-04-29 10:26:03 +07:00
Scores = new List<DisableScore>()
};
// preload disables ทั้งหมดของครั้งเดียว และ Group ExamId เอาเฉพาะ key ที่ไม่ซ้ำ
var recruitsDict = await _context.Disables
.Where(x => x.PeriodExam.Id == rec_import.Id)
.GroupBy(x => x.ExamId)
.Where(g => g.Count() == 1)
.Select(g => g.First())
.ToDictionaryAsync(x => x.ExamId, x => x);
2023-04-29 10:26:03 +07:00
// import datafile
System.IO.File.WriteAllBytes(importFile, fileContent);
using (var c_package = new ExcelPackage(new FileInfo(importFile)))
{
// loop from sheet2 to end
2025-04-21 16:14:05 +07:00
for (int i = 0; i < c_package.Workbook.Worksheets.Count; i++)
2023-04-29 10:26:03 +07:00
{
var workSheet = c_package.Workbook.Worksheets[i];
//var totalRows = workSheet.Dimension.Rows;
2023-04-29 10:26:03 +07:00
var cols = workSheet.GetHeaderColumns();
int row = 8;
var endRow = workSheet.Dimension.End.Row; // แถวสุดท้ายที่มีข้อมูล
while (row <= endRow)
2023-04-29 10:26:03 +07:00
{
var cell1 = workSheet?.Cells[row, 1]?.GetValue<string>();
if (cell1 == "" || cell1 == null) break;
var r = new DisableScore();
#region old
2023-04-29 10:26:03 +07:00
////r.ExamId = workSheet?.Cells[row, 2]?.GetValue<string>();
2023-04-29 10:26:03 +07:00
////r.FullA = (int)workSheet?.Cells[7, 7]?.GetValue<string>().Replace("(", "").Replace(")", "").Replace("คะแนน", "").Trim().ToInteger();
////r.SumA = workSheet?.Cells[row, 7]?.GetValue<string>() == "ขส." ? 0 : (int)workSheet?.Cells[row, 7]?.GetValue<string>().Replace(".00", "").ToInteger();
////r.PercentageA = workSheet?.Cells[row, 8]?.GetValue<string>() == "ขส." ? 0.0 : (double)workSheet?.Cells[row, 8]?.GetValue<double>();
////r.AStatus = workSheet?.Cells[row, 9]?.GetValue<string>();
2023-04-29 10:26:03 +07:00
////r.FullB = (int)workSheet?.Cells[7, 12]?.GetValue<string>().Replace("(", "").Replace(")", "").Replace("คะแนน", "").Trim().ToInteger();
////r.SumB = workSheet?.Cells[row, 12]?.GetValue<string>() == "ขส." ? 0 : (int)workSheet?.Cells[row, 12]?.GetValue<string>().Replace(".00", "").ToInteger();
////r.PercentageB = workSheet?.Cells[row, 13]?.GetValue<string>() == "ขส." ? 0.0 : (double)workSheet?.Cells[row, 13]?.GetValue<double>();
////r.BStatus = workSheet?.Cells[row, 14]?.GetValue<string>();
2023-04-29 10:26:03 +07:00
////r.SumAB = workSheet?.Cells[row, 15]?.GetValue<string>() == "ขส." ? 0 : (int)workSheet?.Cells[row, 15]?.GetValue<string>().Replace(".00", "").ToInteger();
////r.ABStatus = workSheet?.Cells[row, 17]?.GetValue<string>();
2023-04-29 10:26:03 +07:00
////r.FullC = (int)workSheet?.Cells[7, 20]?.GetValue<string>().Replace("(", "").Replace(")", "").Replace("คะแนน", "").Trim().ToInteger();
////r.SumC = workSheet?.Cells[row, 20]?.GetValue<string>() == "ขส." ? 0 : (int)workSheet?.Cells[row, 20]?.GetValue<string>().Replace(".00", "").ToInteger();
////r.PercentageC = workSheet?.Cells[row, 21]?.GetValue<string>() == "ขส." ? 0.0 : (double)workSheet?.Cells[row, 21]?.GetValue<double>();
////r.CStatus = workSheet?.Cells[row, 22]?.GetValue<string>();
////r.ExamStatus = workSheet?.Cells[row, 24]?.GetValue<string>();
////r.Number = workSheet?.Cells[row, 25]?.GetValue<string>() ?? "";
////r.Major = workSheet.Name;
#endregion
r.ExamId = workSheet?.Cells[row, 2]?.GetValue<string>();
// ใช้ dictionary lookup แทน query DB ทีละรอบ
if (!string.IsNullOrEmpty(r.ExamId) && recruitsDict.TryGetValue(r.ExamId, out var recruit))
2025-02-18 13:24:50 +07:00
{
r.CitizenId = workSheet?.Cells[row, 3]?.GetValue<string>()?.Trim();
// ภาคความรู้ความสามารถที่ใช้เฉพาะตำแหน่ง
r.FullA = 200;
r.SumA = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 5]?.GetValue<string>()) ? 0.00 : Math.Round(workSheet.Cells[row, 5].GetValue<double>(), 2);
r.PercentageA = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 6]?.GetValue<string>()) ? 0.00 : Math.Round(workSheet.Cells[row, 6].GetValue<double>(), 2);
r.AStatus = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 7]?.GetValue<string>()) ? "" : workSheet?.Cells[row, 7]?.GetValue<string>();
r.SumAB = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 5]?.GetValue<string>()) ? 0.00 : Math.Round(workSheet.Cells[row, 5].GetValue<double>(), 2);
r.ABStatus = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 7]?.GetValue<string>()) ? "" : workSheet?.Cells[row, 7]?.GetValue<string>();
// ภาคความเหมาะสมกับตำแหน่ง
r.FullC = 50;
r.SumC = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 8]?.GetValue<string>()) ? 0.00 : Math.Round(workSheet.Cells[row, 8].GetValue<double>(), 2);
r.FullD = 50;
r.SumD = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 9]?.GetValue<string>()) ? 0.00 : Math.Round(workSheet.Cells[row, 9].GetValue<double>(), 2);
r.SumCD = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 10]?.GetValue<string>()) ? 0.00 : Math.Round(workSheet.Cells[row, 10].GetValue<double>(), 2);
r.PercentageC = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 11]?.GetValue<string>()) ? 0.00 : Math.Round(workSheet.Cells[row, 11].GetValue<double>(), 2);
r.CStatus = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 12]?.GetValue<string>()) ? "" : workSheet?.Cells[row, 12]?.GetValue<string>();
r.FullScore = 300;
r.TotalScore = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 13]?.GetValue<string>()) ? 0.00 : Math.Round(workSheet.Cells[row, 13].GetValue<double>(), 2);
var examStatusCol7 = workSheet?.Cells[row, 7]?.GetValue<string>()?.Trim();
var examStatusCol14 = workSheet?.Cells[row, 14]?.GetValue<string>()?.Trim();
r.ExamStatus =
examStatusCol7 == "ขาดสอบ" ? "ขส." :
examStatusCol14 == "ได้" ? "ผ่าน" :
examStatusCol14 == "ตก" ? "ไม่ผ่าน" : "-";
r.RemarkScore = string.IsNullOrWhiteSpace(workSheet?.Cells[row, 15]?.GetValue<string>()) ? string.Empty : workSheet?.Cells[row, 15]?.GetValue<string>();
var examAttr = workSheet?.Cells[row, 16]?.GetValue<string>()?.Trim();
r.ExamAttribute =
examAttr == "ผ่าน" ? "มีคุณสมบัติ" :
examAttr == "ไม่ผ่าน" ? "ไม่มีคุณสมบัติ" : "";
r.Major = workSheet.Name;
r.CreatedAt = DateTime.Now;
r.CreatedUserId = UserId ?? "";
r.CreatedFullName = FullName ?? "System Administrator";
r.LastUpdatedAt = DateTime.Now;
r.LastUpdateUserId = UserId ?? "";
r.LastUpdateFullName = FullName ?? "System Administrator";
imported.Scores.Add(r);
2025-02-18 13:24:50 +07:00
}
2025-09-14 23:05:26 +07:00
row++;
2025-09-14 23:05:26 +07:00
} // end of sheet loop
} // end of all file loop
2023-04-29 10:26:03 +07:00
}
// finally save to database
rec_import.ScoreImport = imported;
await _context.SaveChangesAsync();
return Success();
}
catch (Exception ex)
{
await _minioService.DeleteFileAsync(Guid.Parse(import_doc_id));
return Error(ex);
}
finally
{
if (System.IO.File.Exists(importFile))
System.IO.File.Delete(importFile);
}
}
#endregion
#region " Result File "
/// <summary>
/// นำเข้าผลการสอบคัดเลือกผู้พิการ (ผลการสอบ)
/// </summary>
/// <param name="id">รหัสรอบการสอบคัดเลือกผู้พิการ </param>
/// <returns></returns>
/// <response code="200">เมื่อทำนำเข้าข้อมูลสำเร็จ</response>
/// <response code="400">ค่าตัวแปรที่ส่งมาไม่ถูกต้อง</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpPost("result/{id:length(36)}"), DisableRequestSizeLimit]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status400BadRequest)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> ImportResultFileAsync(Guid id)
{
2026-02-27 22:30:41 +07:00
var getPermission = await _permission.GetPermissionAPIAsync("CREATE", "SYS_EXAM_SELECT_PERIOD_DIS");
var jsonData = JsonConvert.DeserializeObject<JObject>(getPermission);
if (jsonData["status"]?.ToString() != "200")
{
return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden);
}
try
{
if (Request.Form.Files == null || Request.Form.Files.Count == 0)
{
return Error(GlobalMessages.NoFileToUpload);
}
var rec_import = await _context.PeriodExams.AsQueryable()
.Include(x => x.ScoreImport)
.ThenInclude(x => x.Scores)
.FirstOrDefaultAsync(x => x.Id == id);
if (rec_import == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
// update ฟิลด์ลำดับที่สอบได้และหมายเหตุจากลำดับที่สอบได้อันเก่าก่อน
if (rec_import.ScoreImport != null && rec_import.ScoreImport.Scores != null)
{
var _oldScores = rec_import.ScoreImport.Scores
.Where(x => !string.IsNullOrEmpty(x.Number))
.ToList();
if (_oldScores.Count > 0)
{
foreach (var x in _oldScores)
{
x.Number = string.Empty;
x.RemarkExamOrder = string.Empty;
}
await _context.SaveChangesAsync();
}
}
// create import history
rec_import.ImportHostories.Add(new DisableImportHistory
{
Description = "นำเข้าข้อมูลผลการสอบ",
CreatedAt = DateTime.Now,
CreatedUserId = UserId ?? "",
CreatedFullName = FullName ?? "System Administrator",
LastUpdatedAt = DateTime.Now,
LastUpdateUserId = UserId ?? "",
LastUpdateFullName = FullName ?? "System Administrator",
});
// preload score
var score = rec_import.ScoreImport.Scores
.Where(s => !string.IsNullOrEmpty(s.ExamId))
2025-09-09 14:18:00 +07:00
.GroupBy(x => x.ExamId)
.Where(g => g.Count() == 1)
.Select(g => g.First())
.ToDictionary(s => s.ExamId, s => s);
// ถ้าไม่มีผลคะแนนสอบคัดเลือกผู้พิการให้จบการทำงาน
if (score.Count == 0) return Success();
var file = Request.Form.Files[0];
using (var stream = file.OpenReadStream())
using (var c_package = new ExcelPackage(stream))
{
foreach (var workSheet in c_package.Workbook.Worksheets)
{
//var totalRows = workSheet.Dimension.Rows;
int row = 7; // เริ่มที่ row 7 ตามตัวอย่างไฟล์
var endRow = workSheet.Dimension.End.Row; // แถวสุดท้ายที่มีข้อมูล
while (row <= endRow)
{
var examId = workSheet?.Cells[row, 2]?.GetValue<string>();
if (string.IsNullOrWhiteSpace(examId))
{
row++;
continue;
}
if (score.TryGetValue(examId, out var existingScore))
{
existingScore.Number = workSheet?.Cells[row, 1]?.GetValue<string>();
existingScore.RemarkExamOrder = workSheet?.Cells[row, 4]?.GetValue<string>() ?? string.Empty;
existingScore.LastUpdatedAt = DateTime.Now;
existingScore.LastUpdateUserId = UserId ?? "";
existingScore.LastUpdateFullName = FullName ?? "System Administrator";
}
row++;
}
}
}
await _context.SaveChangesAsync();
return Success();
}
catch (Exception ex)
{
return Error(ex);
}
}
#endregion
2023-04-29 10:26:03 +07:00
#region " Exam Information "
/// <summary>
/// แสดงข้อมูลสำหรับหน้าจอ : รายการข้อมูลผู้สมัครสอบ
/// </summary>
[HttpGet("exam")]
public async Task<ActionResult<ResponseObject>> GetExamResultAsync()
{
try
{
var data = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.OrderByDescending(x => x.Year)
.ThenByDescending(x => x.Round)
.Select(x => new
{
x.Id,
ExamYear = x.Year == null ? 0 : x.Year.Value.ToThaiYear(),
ExamOrder = x.Round,
Description = x.Name,
})
.ToListAsync();
var result = new List<dynamic>();
foreach (var d in data)
{
result.Add(new
{
ExamYear = d.ExamYear,
Decription = d.Description,
ExamCount = await GetExamCount(d.Id),
PassCount = await GetPassExamCount(d.Id),
NotPassCount = (await GetExamCount(d.Id) - await GetPassExamCount(d.Id))
});
}
return Success(result);
}
catch (Exception ex)
{
return Error(ex);
}
}
2025-09-23 19:35:49 +07:00
//[HttpPost("exam/{id:length(36)}")]
//public ActionResult<ResponseObject> GetExamResultById([FromBody] DisableExamRequest req, Guid id)
//{
// try
// {
// var periodExam = _context.PeriodExams.AsQueryable()
// .Where(x => x.CheckDisability == true)
// .FirstOrDefault(x => x.Id == id);
// if (periodExam == null)
// return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
// var p_Id = new MySqlParameter("@id", id);
// var data = new List<dynamic>();
// using (var cmd = _context.Database.GetDbConnection().CreateCommand())
// {
// cmd.CommandTimeout = 0;
// var sb = new StringBuilder();
// cmd.Parameters.Clear();
// sb.Clear();
// sb.Append(" SELECT * ");
// sb.Append(" FROM exam_info ");
// sb.Append(" WHERE disable_import_id = @id ");
// cmd.Parameters.Add(p_Id);
// if (req.ExamAttribute != null && req.ExamAttribute != "")
// {
// sb.Append(" AND examAttribute = @a ");
// cmd.Parameters.Add(new MySqlParameter("@a", req.ExamAttribute));
// }
// if (req.ExamResult != null && req.ExamResult != "")
// {
// sb.Append(" AND result = @r ");
// cmd.Parameters.Add(new MySqlParameter("@r", req.ExamResult));
// }
// sb.Append(" ORDER BY examID ");
// sb.Append(" LIMIT @PageSize OFFSET @Offset ");
// cmd.Parameters.Add(new MySqlParameter("@PageSize", req.PageSize));
// cmd.Parameters.Add(new MySqlParameter("@Offset", ((req.Page - 1) * req.PageSize)));
// cmd.CommandText = sb.ToString();
// _context.Database.OpenConnection();
// var da = new MySqlDataAdapter(cmd as MySqlCommand);
// var dt = new DataTable();
// da.Fill(dt);
// foreach (DataRow dr in dt.Rows)
// {
// data.Add(new
// {
// examID = dr["examID"].ToString(),
// profileID = dr["profileID"].ToString(),
// prefix = dr["prefix"].ToString(),
// fullName = dr["fullName"].ToString(),
// dateOfBirth = dr["dateofbirth"] == null || Convert.ToDateTime(dr["dateofbirth"]) == DateTime.MinValue ? "" : Convert.ToDateTime(dr["dateofbirth"]).ToThaiShortDate(),
// gender = dr["gender"].ToString(),
// degree = dr["degree"].ToString(),
// major = dr["major"].ToString(),
// majorgroup = dr["majorgroup"].ToString(),
// certificateNo = dr["certificateno"].ToString(),
// certificateIssueDate = dr["certificateIssueDate"] == null || Convert.ToDateTime(dr["certificateIssueDate"]) == DateTime.MinValue ? "" : Convert.ToDateTime(dr["certificateIssueDate"]).ToThaiShortDate(),
// ExamScore = dr["score"] == null ? 0 : dr["score"].ToString().ToInteger(),
// ExamResult = dr["result"].ToString(),
// ExamAttribute = dr["examAttribute"].ToString(),
// Remark = dr["remark"].ToString(),
// IsSpecial = dr["isspecial"].ToString(),
// applyDate = dr["applydate"] == null || Convert.ToDateTime(dr["applydate"]) == DateTime.MinValue ? "" : Convert.ToDateTime(dr["applydate"]).ToThaiShortDate(),
// university = dr["university"].ToString(),
// position_name = dr["position_name"].ToString(),
// hddPosition = dr["hddPosition"].ToString(),
// typeTest = dr["typeTest"].ToString(),
// position_level = dr["position_level"].ToString(),
// position_type = dr["position_type"].ToString(),
// exam_name = dr["exam_name"].ToString(),
// exam_order = dr["exam_order"].ToString(),
// score_year = Convert.ToInt32(dr["score_year"]).ToThaiYear().ToString(),
// });
// }
// }
// //if (data != null && data.Count > 0)
// // data = data.Skip((req.Page - 1) * req.PageSize).Take(req.PageSize).ToList();
// dynamic header = null;
// using (var cmd = _context.Database.GetDbConnection().CreateCommand())
// {
// var sb = new StringBuilder();
// cmd.CommandTimeout = 0;
// cmd.Parameters.Clear();
// sb.Clear();
// sb.Append(" SELECT * ");
// sb.Append(" FROM sum_exam_info ");
// sb.Append(" WHERE disable_import_id = @id ");
// cmd.Parameters.Add(p_Id);
// cmd.CommandText = sb.ToString();
// _context.Database.OpenConnection();
// MySqlDataAdapter da = new MySqlDataAdapter(cmd as MySqlCommand);
// DataTable dt = new DataTable();
// da.Fill(dt);
// if (dt.Rows.Count == 0)
// {
// header = new
// {
// count = 0,
// pass = 0,
// notpass = 0,
// missed_exam = 0,
// other = 0
// };
// }
// else
// {
// var dr = dt.Rows[0];
// header = new
// {
// count = dr["count"].ToString().ToInteger(),
// pass = dr["pass"].ToString().ToInteger(),
// notpass = dr["notpass"].ToString().ToInteger(),
// missed_exam = dr["missed_exam"].ToString().ToInteger(),
// other = dr["other"].ToString().ToInteger()
// };
// }
// }
// return Success(new
// {
// data = data,
// header = header,
// round = periodExam.Round,
// year = periodExam.Year
// });
// }
// catch (Exception ex)
// {
// return Error(ex);
// }
//}
2023-04-29 10:26:03 +07:00
[HttpPost("exam/{id:length(36)}")]
2025-09-23 19:35:49 +07:00
public async Task<ActionResult<ResponseObject>> GetNewExamResultById([FromBody] DisableExamRequest req, Guid id)
2023-04-29 10:26:03 +07:00
{
try
{
var periodExam = _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.FirstOrDefault(x => x.Id == id);
if (periodExam == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
var query = _context.Disables
.Include(x => x.PeriodExam)
.Include(x => x.Educations)
.Include(x => x.Certificates)
.OrderBy(x => x.ExamId)
.Where(x => x.PeriodExam != null && x.PeriodExam.Id == id);
var keywordParam = req.keyword?.Trim();
if (!string.IsNullOrWhiteSpace(keywordParam))
2023-04-29 10:26:03 +07:00
{
query = query.Where(x =>
x.ExamId.Contains(keywordParam) ||
x.CitizenId.Contains(keywordParam) ||
(x.Prefix + x.FirstName + " " + x.LastName).Contains(keywordParam) ||
x.HddPosition.Contains(keywordParam) ||
x.PositionName.Contains(keywordParam)
);
}
2023-04-29 10:26:03 +07:00
// join กับ DisableScores ก่อน เพื่อ filter ตาม ExamStatus
var queryWithScores = query
.GroupJoin(
_context.DisableScores.Include(x => x.ScoreImport),
rc => new { rc.PeriodExam!.Id, rc.ExamId },
sc => new { Id = sc.ScoreImport!.PeriodExamId, sc.ExamId },
(disable, scores) => new { disable, scores }
)
.SelectMany(
x => x.scores.DefaultIfEmpty(),
(x, sr) => new { x.disable, score = sr }
);
// filter ตาม req.ExamResult
if (!string.IsNullOrWhiteSpace(req.ExamResult))
{
switch (req.ExamResult.ToLower())
{
case "missed_exam":
queryWithScores = queryWithScores.Where(x => x.score != null && x.score.ExamStatus == "ขส.");
break;
case "pass":
queryWithScores = queryWithScores.Where(x => x.score != null && x.score.ExamStatus == "ผ่าน");
break;
case "notpass":
queryWithScores = queryWithScores.Where(x => x.score != null && x.score.ExamStatus == "ไม่ผ่าน");
break;
}
}
// total count หลังกรอง
int total = await queryWithScores.CountAsync();
// pagination
queryWithScores = queryWithScores
.Skip((req.Page - 1) * req.PageSize)
.Take(req.PageSize);
// mapping
var data = await queryWithScores
.Select(x => new
{
examID = x.disable.ExamId,
profileID = x.disable.CitizenId,
prefix = x.disable.Prefix,
fullName = $"{x.disable.FirstName} {x.disable.LastName}",
dateOfBirth = x.disable.DateOfBirth.HasValue && x.disable.DateOfBirth.Value != DateTime.MinValue
? x.disable.DateOfBirth.Value.ToThaiShortDate()
: "",
gender = x.disable.Gendor,
degree = x.disable.Educations.Any() ? x.disable.Educations.First().Degree : "",
major = x.disable.Educations.Any() ? x.disable.Educations.First().Major : "",
certificateNo = x.disable.Certificates.Any() ? x.disable.Certificates.First().CertificateNo ?? "" : "",
certificateIssueDate = x.disable.Certificates.Any() && x.disable.Certificates.First().IssueDate != null && x.disable.Certificates.First().IssueDate != DateTime.MinValue
? x.disable.Certificates.First().IssueDate.ToThaiShortDate()
: "",
examScore = x.score == null ? 0.0 : x.score.TotalScore,
examResult = x.score == null ? "" : x.score.ExamStatus,
//examAttribute = x.disable.Certificates.Any() && x.disable.Certificates.First().IssueDate != null
// ? _disableService.CheckValidCertificate(x.disable.Certificates.First().IssueDate, 5)
// ? "มีคุณสมบัติ" : "ไม่มีคุณสมบัติ"
// : "ไม่มีคุณสมบัติ",
examAttribute = x.score != null && !string.IsNullOrEmpty(x.score.ExamAttribute) &&
(x.score.ExamAttribute == "มีคุณสมบัติ" || x.score.ExamAttribute == "ไม่มีคุณสมบัติ")
? x.score.ExamAttribute : "",
remark = x.disable.Remark,
isSpecial = x.disable.Isspecial == "Y" ? x.disable.Isspecial : "",
applyDate = x.disable.ApplyDate.HasValue && x.disable.ApplyDate.Value != DateTime.MinValue
? x.disable.ApplyDate.Value.ToThaiShortDate()
: "",
university = x.disable.Educations.Any() ? x.disable.Educations.First().University : "",
position_name = x.disable.PositionName,
hddPosition = x.disable.HddPosition ?? "",
typeTest = x.disable.typeTest ?? "",
position_level = x.disable.PositionLevel ?? "",
position_type = x.disable.PositionType ?? "",
exam_name = x.disable.PeriodExam!.Name,
exam_order = x.disable.PeriodExam != null && x.disable.PeriodExam.Round != null
? x.disable.PeriodExam.Round.ToString()
: "",
score_year = x.disable.PeriodExam != null && x.disable.PeriodExam.Year != null
? (x.disable.PeriodExam.Year > 2500 ? x.disable.PeriodExam.Year : x.disable.PeriodExam.Year + 543).ToString()
: "",
number = x.score == null ? "" : x.score.Number,
})
.ToListAsync();
2023-04-29 10:26:03 +07:00
2025-09-23 19:35:49 +07:00
// ---------------------------
// 3. ดึงสรุปคะแนน
// ---------------------------
2023-04-29 10:26:03 +07:00
dynamic header = null;
2025-10-13 22:30:10 +07:00
int _count = await _context.Disables.Where(x => x.PeriodExam.Id == id).CountAsync();
2025-11-05 17:02:41 +07:00
if (_count > 0)
2023-04-29 10:26:03 +07:00
{
2025-09-23 19:35:49 +07:00
header = await _context.DisableScores
.Include(x => x.ScoreImport)
.Where(x => x.ScoreImport.PeriodExamId == id)
.GroupBy(x => 1)
.Select(g => new
{
count = _count,
pass = g.Count(x => x.ExamStatus == "ผ่าน"),
notpass = g.Count(x => x.ExamStatus == "ไม่ผ่าน"),
missed_exam = g.Count(x => x.ExamStatus == "ขส."),
other = g.Count(x =>
string.IsNullOrEmpty(x.ExamStatus) ||
!new[] { "ผ่าน", "ไม่ผ่าน", "ขส." }.Contains(x.ExamStatus)
)
})
.FirstOrDefaultAsync()
?? new // ใช้ null-coalescing กันกรณีไม่มีข้อมูล (แทน else เดิม)
{
count = _count,
pass = 0,
notpass = 0,
missed_exam = 0,
other = 0
};
}
else
{
header = new
2023-04-29 10:26:03 +07:00
{
2025-09-23 19:35:49 +07:00
count = _count,
pass = 0,
notpass = 0,
missed_exam = 0,
other = 0
};
2023-04-29 10:26:03 +07:00
}
2025-09-23 19:35:49 +07:00
2023-04-29 10:26:03 +07:00
return Success(new
{
data = data,
2025-09-24 11:35:58 +07:00
total = total,
2023-04-29 10:26:03 +07:00
header = header,
round = periodExam.Round,
year = periodExam.Year.Value.ToThaiYear()
2023-04-29 10:26:03 +07:00
});
}
catch (Exception ex)
{
return Error(ex);
}
}
[HttpGet("exam/{id:length(36)}/{examId}")]
public async Task<ActionResult<ResponseObject>> GetExamResultByPersonAsync(Guid id, string examId)
{
try
{
var data = await _context.Disables.AsQueryable()
.Include(x => x.PeriodExam)
.Include(x => x.Documents)
.ThenInclude(x => x.DocumentFile)
.Where(x => x.PeriodExam.Id == id)
.Where(x => x.PeriodExam.CheckDisability == true)
.Where(x => x.ExamId == examId)
.Join(_context.DisableScores.AsQueryable()
.Include(x => x.ScoreImport),
rc => new { /*rc.PeriodExam.Year,*/ rc.ExamId },
sc => new { /*sc.ScoreImport.Year,*/ sc.ExamId },
2023-04-29 10:26:03 +07:00
(p, sr) => new
{
ExamID = p.ExamId,
ProfileID = p.CitizenId,
p.Prefix,
FullName = $"{p.FirstName} {p.LastName}",
DateOfBirth = p.DateOfBirth.HasValue && p.DateOfBirth.Value != DateTime.MinValue
? p.DateOfBirth.Value.ToThaiShortDate()
: "",
2023-04-29 10:26:03 +07:00
Gender = p.Gendor,
Degree = p.Educations.First().Degree,
Major = p.Educations.First().Major,
CertificateNo = p.Certificates.Count > 0
? p.Certificates.First().CertificateNo ?? ""
: "",
2025-09-14 23:05:26 +07:00
CertificateIssueDate = p.Certificates.Count > 0
? p.Certificates.First().IssueDate != DateTime.MinValue
? p.Certificates.First().IssueDate.ToThaiShortDate()
: ""
: "",
2023-04-29 10:26:03 +07:00
ExamResult = sr == null ? "" : sr.ExamStatus,
// ExamAttribute = p.Certificates.Count > 0 ?
// _disableService.CheckValidCertificate(p.Certificates.First().IssueDate, 5)
// ? "มีคุณสมบัติ"
// : "ไม่มีคุณสมบัติ"
// : "ไม่มีคุณสมบัติ",
ExamAttribute = sr != null && !string.IsNullOrEmpty(sr.ExamAttribute) &&
(sr.ExamAttribute == "มีคุณสมบัติ" || sr.ExamAttribute == "ไม่มีคุณสมบัติ")
? sr.ExamAttribute : "",
2023-04-29 10:26:03 +07:00
IsSpecial = p.Isspecial,
Remark = p.Remark,
University = p.Educations.First().University,
PositionName = p.PositionName,
2025-01-05 21:59:15 +07:00
PositionType = p.PositionType,
PositionLevel = p.PositionLevel,
ExamName = p.PeriodExam!.Name,
2023-04-29 10:26:03 +07:00
ExamOrder = p.PeriodExam.Round,
ExamYear = p.PeriodExam.Year == null ? 0 : p.PeriodExam.Year.Value.ToThaiYear(),
Score = sr == null ? 0.0 : sr.TotalScore,
2023-04-29 10:26:03 +07:00
Number = sr == null ? "" : sr.Number,
2025-02-18 13:24:50 +07:00
ExamCount = _disableService.GetExamCount(p.CitizenId),
ScoreExpire = p.PeriodExam.AnnouncementDate == null
? ""
: p.PeriodExam.AnnouncementDate != DateTime.MinValue
? p.PeriodExam.AnnouncementDate.Value.AddYears(2).ToThaiShortDate()
: "",
typeTest = p.typeTest,
2023-04-29 10:26:03 +07:00
ScoreResult = sr == null ? null : new
{
ScoreAFull = sr.FullA,
ScoreA = sr.SumA,
ScoreBFull = sr.FullB,
ScoreB = sr.SumB,
ScoreAB = sr.SumAB,
2023-04-29 10:26:03 +07:00
ScoreCFull = sr.FullC,
ScoreC = sr.SumC,
ScoreDFull = sr.FullD,
ScoreD = sr.SumD,
ScoreCD = sr.SumCD,
ScoreSumFull = sr.FullScore,
ScoreSum = sr.TotalScore,
2023-04-29 10:26:03 +07:00
ExamResult = sr.ExamStatus
},
Attachments = p.Documents.Select(a => new
{
FileName = a.DocumentFile.FileName,
DocumentId = a.DocumentFile.Id
})
})
.FirstOrDefaultAsync();
return Success(data);
2023-04-29 10:26:03 +07:00
}
catch (Exception ex)
{
return Error(ex);
}
}
#endregion
#region " For CMS "
[HttpGet("competitive")]
[AllowAnonymous]
public IActionResult GetPeriodForCMS()
{
try
{
var periods = _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Select(r => new
{
id = r.Id,
title = $"{r.Name} ครั้งที่ {r.Round}/{r.Year.Value.ToThaiYear()}",
category = "สำนักงาน ก.ก.",
category_id = 1,
announcement_startDate = r.AnnouncementStartDate == null ? "" : r.AnnouncementStartDate.ToString("yyyy-mm-dd"),
announcement_endDate = r.AnnouncementEndDate == null ? "" : r.AnnouncementEndDate.ToString("yyyy-MM-dd"),
announcementExam = true,
register_startDate = r.RegisterStartDate == null ? "" : r.RegisterStartDate.Value.ToString("yyyy-MM-dd"),
register_endDate = r.RegisterEndDate == null ? "" : r.RegisterEndDate.Value.ToString("yyyy-MM-dd"),
payment_startDate = r.PaymentStartDate == null ? "" : r.PaymentStartDate.Value.ToString("yyyy-MM-dd"),
payment_endDate = r.PaymentEndDate == null ? "" : r.PaymentEndDate.Value.ToString("yyyy-MM-dd"),
exam_date = r.ExamDate == null ? "" : r.ExamDate.Value.ToString("yyyy-MM-dd")
2023-04-29 10:26:03 +07:00
})
.ToList();
return Ok(periods);
}
catch (Exception ex)
{
return StatusCode(500, ex.Message);
}
}
#endregion
#region " Export Excel "
[HttpGet("export/exam/{id:length(36)}")]
public async Task<ActionResult<ResponseObject>> ExportExamAsync(Guid id)
{
var data = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.Disables)
.FirstOrDefaultAsync(x => x.Id == id);
if (data == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
var header = $"{data.Name} ครั้งที่ {data.Round}/{data.Year.Value.ToThaiYear()}";
var disables = data.Disables
.OrderBy(x => x.ExamId)
.Select(x => new
{
ExamId = x.ExamId,
CitizenId = x.CitizenId,
Fullname = $"{x.Prefix}{x.FirstName} {x.LastName}",
2025-01-05 21:59:15 +07:00
PositionName = x.PositionName,
PositionType = x.PositionType,
PositionLevel = x.PositionLevel
})
.ToList();
var _data = new
2023-04-29 10:26:03 +07:00
{
template = "ExamList",
reportName = $"ExamList_{DateTime.Now.ToString("yyyyMMddHHmmss")}",
data = new
2023-04-29 10:26:03 +07:00
{
header = header,
data = disables
2023-04-29 10:26:03 +07:00
}
};
return Success(_data);
2023-04-29 10:26:03 +07:00
}
[HttpGet("export/pass-exam/{id:length(36)}")]
public async Task<ActionResult<ResponseObject>> ExportPassExamAsync(Guid id)
{
var data = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.Disables)
.FirstOrDefaultAsync(x => x.Id == id);
var data_pass = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.Scores)
.FirstOrDefaultAsync(x => x.Id == id);
if (data == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
if (data_pass == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
var header = $"{data.Name} ครั้งที่ {data.Round}/{data.Year.Value.ToThaiYear()}";
var result = (from r in data.Disables.ToList()
join s in data_pass.ScoreImport.Scores.Where(x => x.AStatus == "ผ่าน").ToList() on r.ExamId equals s.ExamId
orderby r.ExamId ascending, s.SumA descending
select new
{
r.ExamId,
r.CitizenId,
2025-01-05 21:59:15 +07:00
Fullname = $"{r.Prefix}{r.FirstName} {r.LastName}",
s.FullA,
s.SumA,
s.AStatus,
}).ToList();
var _data = new
2023-04-29 10:26:03 +07:00
{
template = "PassAExamList",
reportName = $"PassAExamList_{DateTime.Now.ToString("yyyyMMddHHmmss")}",
data = new
2023-04-29 10:26:03 +07:00
{
header = header,
data = result
2023-04-29 10:26:03 +07:00
}
};
return Success(_data);
2023-04-29 10:26:03 +07:00
}
[HttpGet("export/pass/{id:length(36)}")]
public async Task<ActionResult<ResponseObject>> ExportPassExamResultAsync(Guid id)
{
var data = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.Disables)
.FirstOrDefaultAsync(x => x.Id == id);
var data_pass = await _context.PeriodExams.AsQueryable()
.Where(x => x.CheckDisability == true)
.Include(x => x.ScoreImport)
.ThenInclude(x => x.Scores)
.FirstOrDefaultAsync(x => x.Id == id);
if (data == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
if (data_pass == null)
return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
var header = $"{data.Name} ครั้งที่ {data.Round}/{data.Year.Value.ToThaiYear()}";
var result = (from r in data.Disables.ToList()
join s in data_pass.ScoreImport.Scores.Where(x => x.ExamStatus == "ผ่าน").ToList() on r.ExamId equals s.ExamId
select new
{
ExamId = r.ExamId,
CitizenId = r.CitizenId,
Fullname = $"{r.Prefix}{r.FirstName} {r.LastName}",
Full = s.FullScore != null ? s.FullScore : 0,
Sum = s.TotalScore != null ? s.TotalScore : 0,
Status = s.ExamStatus,
2025-01-05 21:59:15 +07:00
s.Number,
r.PositionName,
r.PositionType,
r.PositionLevel,
}).ToList()
.OrderBy(x => x.ExamId)
.ThenBy(x => x.PositionName)
.ThenByDescending(x => x.Sum)
.ToList();
var _data = new
2023-04-29 10:26:03 +07:00
{
template = "PassExamList",
reportName = $"PassExamList_{DateTime.Now.ToString("yyyyMMddHHmmss")}",
data = new
2023-04-29 10:26:03 +07:00
{
header = header,
data = result
2023-04-29 10:26:03 +07:00
}
};
return Success(_data);
2023-04-29 10:26:03 +07:00
}
/// <summary>
/// โอนคนสรรหาไปบรรจุ
/// </summary>
/// <param name="examId">รหัสรอบสมัคร</param>
/// <returns></returns>
/// <response code="200">เมื่อโอนคนสรรหาไปบรรจุสำเร็จ</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
2025-10-13 22:30:10 +07:00
[HttpPost("placement/{examId:length(36)}")]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
2025-10-13 22:30:10 +07:00
public async Task<ActionResult<ResponseObject>> UpdateAsyncDisableToPlacement(Guid examId, [FromBody] RecruitDateRequest req)
{
try
{
2025-10-13 22:30:10 +07:00
await _periodExamService.UpdateAsyncDisableToPlacement(examId, req.AccountStartDate);
return Success();
}
catch (Exception ex)
{
return Error(ex);
}
}
2023-04-29 10:26:03 +07:00
#endregion
#region " Report "
/// <summary>
/// ผลคะแนนผู้สมัครสอบ
/// </summary>
/// <param name="id">รหัสรอบการสอบคัดเลือกผู้พิการ</param>
/// <param name="examId">เลขประจำตัวสอบ</param>
/// <returns></returns>
/// <response code="200">เมื่อทำการอ่านข้อมูลจำนวนผู้สอบผ่านแข่งขันเพื่อบรรจุเข้ารับราชการเป็นข้าราชการ กทม. สามัญสำเร็จ</response>
/// <response code="401">ไม่ได้ Login เข้าระบบ</response>
/// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
[HttpGet("report/exam/{id:length(36)}/{examId}"), DisableRequestSizeLimit]
[ProducesResponseType(StatusCodes.Status200OK)]
[ProducesResponseType(StatusCodes.Status401Unauthorized)]
[ProducesResponseType(StatusCodes.Status500InternalServerError)]
public async Task<ActionResult<ResponseObject>> GetReportExamResultByPersonAsync(Guid id, string examId)
{
try
{
var data = await _context.Disables.AsQueryable()
.Include(x => x.PeriodExam)
.Where(x => x.PeriodExam!.Id == id)
.Where(x => x.ExamId == examId)
.Join(_context.DisableScores.AsQueryable()
.Include(x => x.ScoreImport),
rc => new { rc.PeriodExam!.Id, rc.ExamId },
sc => new { Id = sc.ScoreImport!.PeriodExamId, sc.ExamId },
(p, sr) => new
{
ExamID = p.ExamId != null ? p.ExamId.ToThaiNumber() : "",
CitizenId = p.CitizenId != null ? p.CitizenId.ToThaiNumber() : "",
FullName = $"{p.Prefix}{p.FirstName} {p.LastName}",
DateOfBirth = p.DateOfBirth.HasValue && p.DateOfBirth.Value != DateTime.MinValue
? p.DateOfBirth.Value.ToThaiShortDate().ToThaiNumber()
: "",
Gender = p.Gendor,
Degree = p.Educations.First().Degree,
Major = p.Educations.First().Major,
University = p.Educations.First().University,
PositionName = p.PositionName,
2025-09-14 23:05:26 +07:00
ExamName = $"{p.PeriodExam!.Name} ครั้งที่ {p.PeriodExam.Round}/{(p.PeriodExam.Year > 2500 ? p.PeriodExam.Year : (p.PeriodExam.Year + 543))}".ToThaiNumber(),
ExamCount = _disableService.GetExamCount(p.CitizenId).ToString().ToThaiNumber(),
type = p.typeTest == "bangkok" ? "กทม." : p.typeTest == "ocsc" ? "ก.พ." : "",
FA = sr.FullA != null ? sr.FullA.ToString().ToThaiNumber() : "",
SA = sr.SumA != null ? sr.SumA.ToString().ToThaiNumber() : "",
FC = sr.FullC != null ? sr.FullC.ToString().ToThaiNumber() : "",
SC = sr.SumC != null ? sr.SumC.ToString().ToThaiNumber() : "",
FD = sr.FullD != null ? sr.FullD.ToString().ToThaiNumber() : "",
SD = sr.SumD != null ? sr.SumD.ToString().ToThaiNumber() : "",
F = sr.FullScore != null ? sr.FullScore.ToString().ToThaiNumber() : "",
T = sr.TotalScore != null ? sr.TotalScore.ToString().ToThaiNumber() : "",
Result = sr.ExamStatus,
Number = sr.Number != null ? sr.Number.ToString().ToThaiNumber() : "",
Expire = p.PeriodExam.AnnouncementDate == null
? ""
: p.PeriodExam.AnnouncementDate != DateTime.MinValue
? p.PeriodExam.AnnouncementDate.Value.AddYears(2).ToThaiShortDate().ToString().ToThaiNumber()
: "",
})
.FirstOrDefaultAsync();
var result = new
{
template = "recruit-exam",
reportName = "recruit-exam",
data = data
};
return Success(result);
}
catch (Exception ex)
{
return Error(ex);
}
}
#endregion
2023-04-29 10:26:03 +07:00
#endregion
}
}