using BMA.EHR.Application.Repositories; using BMA.EHR.Application.Repositories.MessageQueue; using BMA.EHR.Application.Responses.Profiles; using BMA.EHR.Domain.Common; using BMA.EHR.Domain.Extensions; using BMA.EHR.Domain.Models.Retirement; using BMA.EHR.Domain.Shared; using BMA.EHR.Infrastructure.Persistence; using BMA.EHR.Retirement.Service.Requests; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; using Microsoft.EntityFrameworkCore; using Newtonsoft.Json; using Newtonsoft.Json.Linq; using Swashbuckle.AspNetCore.Annotations; using System.Net.Http.Headers; using System.Security.Claims; namespace BMA.EHR.Retirement.Service.Controllers { [Route("api/v{version:apiVersion}/retirement/other")] [ApiVersion("1.0")] [ApiController] [Produces("application/json")] [Authorize] [SwaggerTag("ระบบอื่นๆ")] public class RetirementOtherController : BaseController { private readonly RetirementRepository _repository; private readonly NotificationRepository _repositoryNoti; private readonly ApplicationDBContext _context; private readonly MinIOService _documentService; private readonly IHttpContextAccessor _httpContextAccessor; private readonly IConfiguration _configuration; private readonly UserProfileRepository _userProfileRepository; private readonly PermissionRepository _permission; public RetirementOtherController(RetirementRepository repository, NotificationRepository repositoryNoti, ApplicationDBContext context, MinIOService documentService, IHttpContextAccessor httpContextAccessor, IConfiguration configuration, UserProfileRepository userProfileRepository, PermissionRepository permission) { _repository = repository; _repositoryNoti = repositoryNoti; _context = context; _documentService = documentService; _httpContextAccessor = httpContextAccessor; _configuration = configuration; _userProfileRepository = userProfileRepository; _permission = permission; } #region " Properties " private string? UserId => _httpContextAccessor?.HttpContext?.User?.FindFirst(ClaimTypes.NameIdentifier)?.Value; private string? FullName => _httpContextAccessor?.HttpContext?.User?.FindFirst("name")?.Value; private string? token => _httpContextAccessor?.HttpContext?.Request.Headers["Authorization"]; private string? AccessToken => _httpContextAccessor?.HttpContext?.Request.Headers["Authorization"]; #endregion /// /// list รายการอื่นๆ /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpGet()] public async Task> GetListByAdmin(string? status = "ALL") // public async Task> GetListByAdmin(int page = 1, int pageSize = 10, string keyword = "") { var getPermission = await _permission.GetPermissionAPIAsync("LIST", "SYS_PLACEMENT_OTHER"); var jsonData = JsonConvert.DeserializeObject(getPermission); if (jsonData["status"]?.ToString() != "200") { return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden); } string role = jsonData["result"]?.ToString(); var nodeId = string.Empty; var profileAdmin = new GetUserOCAllDto(); profileAdmin = await _userProfileRepository.GetUserOCAll(Guid.Parse(UserId!), AccessToken); if (role == "NORMAL" || role == "CHILD") { nodeId = profileAdmin?.Node == 4 ? profileAdmin?.Child4DnaId : profileAdmin?.Node == 3 ? profileAdmin?.Child3DnaId : profileAdmin?.Node == 2 ? profileAdmin?.Child2DnaId : profileAdmin?.Node == 1 ? profileAdmin?.Child1DnaId : profileAdmin?.Node == 0 ? profileAdmin?.RootDnaId : ""; } else if (role == "BROTHER") { nodeId = profileAdmin?.Node == 4 ? profileAdmin?.Child3DnaId : profileAdmin?.Node == 3 ? profileAdmin?.Child2DnaId : profileAdmin?.Node == 2 ? profileAdmin?.Child1DnaId : profileAdmin?.Node == 1 || profileAdmin?.Node == 0 ? profileAdmin?.RootDnaId : ""; } else if (role == "ROOT" || role == "PARENT") { nodeId = profileAdmin?.RootDnaId; } var node = profileAdmin?.Node; var retirementOthers = await _context.RetirementOthers.AsQueryable() .OrderByDescending(x => x.CreatedAt) .Select(p => new { p.Id, p.citizenId, p.profileId, p.prefix, p.firstName, p.lastName, p.root, p.rootId, p.rootShortName, p.child1, p.child1Id, p.child1ShortName, p.child2, p.child2Id, p.child2ShortName, p.child3, p.child3Id, p.child3ShortName, p.child4, p.child4Id, p.child4ShortName, p.orgRevisionId, p.positionId, p.posMasterNo, p.position, p.PositionExecutive, p.positionField, p.posTypeId, p.posTypeName, p.posLevelId, p.posLevelName, node = p.root == null ? (int?)null : (p.child1 == null ? 0 : (p.child2 == null ? 1 : (p.child3 == null ? 2 : (p.child4 == null ? 3 : 4)))), nodeName = p.root == null ? null : (p.child1 == null ? p.root : (p.child2 == null ? p.child1 : (p.child3 == null ? p.child2 : (p.child4 == null ? p.child3 : p.child4)))), nodeId = p.rootId == null ? null : (p.child1Id == null ? p.rootId : (p.child2Id == null ? p.child1Id : (p.child3Id == null ? p.child2Id : (p.child4Id == null ? p.child3Id : p.child4Id)))), nodeShortName = p.rootShortName == null ? null : (p.child1ShortName == null ? p.rootShortName : (p.child2ShortName == null ? p.child1ShortName : (p.child3ShortName == null ? p.child2ShortName : (p.child4ShortName == null ? p.child3ShortName : p.child4ShortName)))), p.rootOld, p.rootOldId, p.rootShortNameOld, p.child1Old, p.child1OldId, p.child1ShortNameOld, p.child2Old, p.child2OldId, p.child2ShortNameOld, p.child3Old, p.child3OldId, p.child3ShortNameOld, p.child4Old, p.child4OldId, p.child4ShortNameOld, p.PositionOld, p.PositionExecutiveOld, p.posMasterNoOld, p.posTypeOldId, p.posTypeNameOld, p.posLevelOldId, p.posLevelNameOld, p.Status, p.Amount, p.ReportingDate, p.CreatedAt, p.Reason, p.MilitaryDate, p.EducationOld, p.AmountOld, p.PositionTypeOld, p.PositionLevelOld, p.PositionNumberOld, p.OrganizationPositionOld, p.posmasterId, p.PositionDate, CommandType = p.CommandType == null ? null : p.CommandType.Name, p.rootDnaOldId, p.child1DnaOldId, p.child2DnaOldId, p.child3DnaOldId, p.child4DnaOldId, }) .ToListAsync(); if (status != null && status.Trim().ToUpper() != "ALL") retirementOthers = retirementOthers.Where(x => x.Status.Contains(status.Trim().ToUpper())).ToList(); if (role == "OWNER") { node = null; } if (role == "OWNER" || role == "CHILD") { retirementOthers = retirementOthers .Where(x => node == 4 ? x.child4DnaOldId == nodeId : (node == 3 ? x.child3DnaOldId == nodeId : (node == 2 ? x.child2DnaOldId == nodeId : (node == 1 ? x.child1DnaOldId == nodeId : (node == 0 ? x.rootDnaOldId == nodeId : (node == null ? true : true)))))).ToList(); } else if (role == "BROTHER") { retirementOthers = retirementOthers .Where(x => node == 4 ? x.child3DnaOldId == nodeId : (node == 3 ? x.child2DnaOldId == nodeId : (node == 2 ? x.child1DnaOldId == nodeId : (node == 1 || node == 0 ? x.rootDnaOldId == nodeId : (node == null ? true : true))))).ToList(); } else if (role == "ROOT") { retirementOthers = retirementOthers .Where(x => x.rootDnaOldId == nodeId).ToList(); } else if (role == "PARENT") { retirementOthers = retirementOthers .Where(x => x.rootDnaOldId == nodeId && x.child1DnaOldId != null).ToList(); } else if (role == "NORMAL") { retirementOthers = retirementOthers.Where(x => node == 0 ? x.rootDnaOldId == nodeId && x.child1DnaOldId == null : node == 1 ? x.child1DnaOldId == nodeId && x.child2DnaOldId == null : node == 2 ? x.child2DnaOldId == nodeId && x.child3DnaOldId == null : node == 3 ? x.child3DnaOldId == nodeId && x.child4DnaOldId == null : node == 4 ? x.child4DnaOldId == nodeId : true ).ToList(); } return Success(retirementOthers); } /// /// get รายละเอียดอื่นๆ /// /// Id อื่นๆ /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpGet("{id:length(36)}")] public async Task> GetDetailByUser(Guid id) { var getWorkflow = await _permission.GetPermissionAPIWorkflowAsync(id.ToString(), "SYS_PLACEMENT_OTHER"); if (getWorkflow == false) { var getPermission = await _permission.GetPermissionAPIAsync("GET", "SYS_PLACEMENT_OTHER"); var jsonData = JsonConvert.DeserializeObject(getPermission); if (jsonData["status"]?.ToString() != "200") { return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden); } } var data = await _context.RetirementOthers.AsQueryable() .Where(x => x.Id == id) .Select(p => new { p.Id, p.profileId, p.prefix, p.firstName, p.lastName, p.root, p.rootId, p.rootShortName, p.child1, p.child1Id, p.child1ShortName, p.child2, p.child2Id, p.child2ShortName, p.child3, p.child3Id, p.child3ShortName, p.child4, p.child4Id, p.child4ShortName, node = p.root == null ? (int?)null : (p.child1 == null ? 0 : (p.child2 == null ? 1 : (p.child3 == null ? 2 : (p.child4 == null ? 3 : 4)))), nodeName = p.root == null ? null : (p.child1 == null ? p.root : (p.child2 == null ? p.child1 : (p.child3 == null ? p.child2 : (p.child4 == null ? p.child3 : p.child4)))), nodeId = p.rootId == null ? null : (p.child1Id == null ? p.rootId : (p.child2Id == null ? p.child1Id : (p.child3Id == null ? p.child2Id : (p.child4Id == null ? p.child3Id : p.child4Id)))), nodeShortName = p.rootShortName == null ? null : (p.child1ShortName == null ? p.rootShortName : (p.child2ShortName == null ? p.child1ShortName : (p.child3ShortName == null ? p.child2ShortName : (p.child4ShortName == null ? p.child3ShortName : p.child4ShortName)))), p.orgRevisionId, p.positionId, p.posMasterNo, p.position, p.PositionExecutive, p.positionField, p.posTypeId, p.posTypeName, p.posLevelId, p.posLevelName, p.rootOld, p.rootOldId, p.rootShortNameOld, p.child1Old, p.child1OldId, p.child1ShortNameOld, p.child2Old, p.child2OldId, p.child2ShortNameOld, p.child3Old, p.child3OldId, p.child3ShortNameOld, p.child4Old, p.child4OldId, p.child4ShortNameOld, nodeOld = p.rootOld == null ? (int?)null : (p.child1Old == null ? 0 : (p.child2Old == null ? 1 : (p.child3Old == null ? 2 : (p.child4Old == null ? 3 : 4)))), nodeNameOld = p.rootOld == null ? null : (p.child1Old == null ? p.root : (p.child2Old == null ? p.child1Old : (p.child3Old == null ? p.child2Old : (p.child4Old == null ? p.child3Old : p.child4Old)))), nodeOldId = p.rootOldId == null ? null : (p.child1OldId == null ? p.rootOldId : (p.child2OldId == null ? p.child1OldId : (p.child3OldId == null ? p.child2OldId : (p.child4OldId == null ? p.child3OldId : p.child4OldId)))), nodeShortNameOld = p.rootShortNameOld == null ? null : (p.child1ShortNameOld == null ? p.rootShortNameOld : (p.child2ShortNameOld == null ? p.child1ShortNameOld : (p.child3ShortNameOld == null ? p.child2ShortNameOld : (p.child4ShortNameOld == null ? p.child3ShortNameOld : p.child4ShortNameOld)))), p.posMasterNoOld, p.posTypeOldId, p.posTypeNameOld, p.posLevelOldId, p.posLevelNameOld, p.Status, p.Amount, p.ReportingDate, p.CreatedAt, p.Reason, p.MilitaryDate, p.EducationOld, p.AmountOld, p.PositionTypeOld, p.PositionLevelOld, p.PositionNumberOld, p.OrganizationPositionOld, p.PositionOld, p.PositionExecutiveOld, p.OrganizationOld, p.PositionDate, p.posmasterId, CommandType = p.CommandType == null ? null : p.CommandType.Name, }) .FirstOrDefaultAsync(); if (data == null) return Error(GlobalMessages.DataNotFound, 404); return Success(data); } /// /// สร้างอื่นๆ /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPost()] public async Task> Post([FromForm] RetirementAddProfileRequest req) { var getPermission = await _permission.GetPermissionAPIAsync("CREATE", "SYS_PLACEMENT_OTHER"); var jsonData = JsonConvert.DeserializeObject(getPermission); if (jsonData["status"]?.ToString() != "200") { return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden); } var retirementOther = new RetirementOther { Status = "WAITTING", CreatedFullName = FullName ?? "System Administrator", CreatedUserId = UserId ?? "", CreatedAt = DateTime.Now, LastUpdateFullName = FullName ?? "System Administrator", LastUpdateUserId = UserId ?? "", LastUpdatedAt = DateTime.Now, }; var apiUrl = string.Empty; if (req.profileType.Trim().ToUpper() == "EMPLOYEE") { apiUrl = $"{_configuration["API"]}/org/profile-employee/profileid/position/{req.Id}"; } else { apiUrl = $"{_configuration["API"]}/org/profile/profileid/position/{req.Id}"; } 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(); var org = JsonConvert.DeserializeObject(_result); if (org == null || org.result == null) return Error("ไม่พบหน่วยงานของผู้ใช้งานคนนี้", 404); retirementOther.profileId = org.result.profileId; retirementOther.prefix = org.result.prefix; retirementOther.firstName = org.result.firstName; retirementOther.lastName = org.result.lastName; retirementOther.citizenId = org.result.citizenId; retirementOther.rootOld = org.result.root; retirementOther.rootOldId = org.result.rootId; retirementOther.rootDnaOldId = org.result.rootDnaId; retirementOther.rootShortNameOld = org.result.rootShortName; retirementOther.child1Old = org.result.child1; retirementOther.child1OldId = org.result.child1Id; retirementOther.child1DnaOldId = org.result.child1DnaId; retirementOther.child1ShortNameOld = org.result.child1ShortName; retirementOther.child2Old = org.result.child2; retirementOther.child2OldId = org.result.child2Id; retirementOther.child2DnaOldId = org.result.child2DnaId; retirementOther.child2ShortNameOld = org.result.child2ShortName; retirementOther.child3Old = org.result.child3; retirementOther.child3OldId = org.result.child3Id; retirementOther.child3DnaOldId = org.result.child3DnaId; retirementOther.child3ShortNameOld = org.result.child3ShortName; retirementOther.child4Old = org.result.child4; retirementOther.child4OldId = org.result.child4Id; retirementOther.child4DnaOldId = org.result.child4DnaId; retirementOther.child4ShortNameOld = org.result.child4ShortName; retirementOther.posMasterNoOld = org.result.posMasterNo; retirementOther.posTypeOldId = org.result.posTypeId; retirementOther.posTypeNameOld = org.result.posTypeName; retirementOther.posLevelOldId = org.result.posLevelId; retirementOther.posLevelNameOld = org.result.posLevelName; retirementOther.LeaveDate = org.result.leaveDate; retirementOther.PositionOld = org.result.position; retirementOther.PositionExecutiveOld = org.result.posExecutiveName; retirementOther.positionExecutiveFieldOld = org.result.positionExecutiveField; retirementOther.positionAreaOld = org.result.positionArea; retirementOther.PositionLevelOld = org.result.posLevelName; retirementOther.PositionTypeOld = org.result.posTypeName; retirementOther.PositionNumberOld = org.result.nodeShortName + " " + org.result.posMasterNo; retirementOther.OrganizationOld = (org.result.child4 == null ? "" : org.result.child4 + "\n") + (org.result.child3 == null ? "" : org.result.child3 + "\n") + (org.result.child2 == null ? "" : org.result.child2 + "\n") + (org.result.child1 == null ? "" : org.result.child1 + "\n") + (org.result.root == null ? "" : org.result.root); retirementOther.OrganizationPositionOld = org.result.position + "\n" + (retirementOther.PositionExecutiveOld == null ? "" : (retirementOther.positionExecutiveField == null ? retirementOther.PositionExecutiveOld + "\n" : retirementOther.PositionExecutiveOld + "(" + retirementOther.positionExecutiveField + ")" + "\n")) + retirementOther.OrganizationOld; retirementOther.EducationOld = org.result.education; retirementOther.AmountOld = org.result.salary; } await _context.RetirementOthers.AddAsync(retirementOther); await _context.SaveChangesAsync(); // if (Request.Form.Files != null && Request.Form.Files.Count != 0) // { // foreach (var file in Request.Form.Files) // { // var fileExtension = Path.GetExtension(file.FileName); // var doc = await _documentService.UploadFileAsync(file, file.FileName); // var _doc = await _context.Documents.AsQueryable() // .FirstOrDefaultAsync(x => x.Id == doc.Id); // if (_doc != null) // { // var retirementOtherDoc = new RetirementOtherDoc // { // RetirementOther = retirementOther, // Document = _doc, // CreatedFullName = FullName ?? "System Administrator", // CreatedUserId = UserId ?? "", // CreatedAt = DateTime.Now, // LastUpdateFullName = FullName ?? "System Administrator", // LastUpdateUserId = UserId ?? "", // LastUpdatedAt = DateTime.Now, // }; // await _context.RetirementOtherDocs.AddAsync(retirementOtherDoc); // } // } // } // await _context.SaveChangesAsync(); return Success(); } /// /// เลือกหน่วยงาน /// /// Id อื่นๆ /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPut("position/{id:length(36)}")] public async Task> UpdatePositionRetirementOther([FromBody] PersonSelectPositionOtherRequest req, Guid id) { var uppdated = await _context.RetirementOthers .FirstOrDefaultAsync(x => x.Id == id); if (uppdated == null) return Error(GlobalMessages.RetirementOtherNotFound, 404); var apiUrl = $"{_configuration["API"]}/org/find/all"; 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.Post, apiUrl); var _res = await client.PostAsJsonAsync(apiUrl, new { node = req.node, nodeId = req.nodeId, }); var _result = await _res.Content.ReadAsStringAsync(); var org = JsonConvert.DeserializeObject(_result); if (org == null || org.result == null) return Error("ไม่พบหน่วยงานนี้ในระบบ", 404); uppdated.root = org.result.root; uppdated.rootId = org.result.rootId; uppdated.rootDnaId = org.result.rootDnaId; uppdated.rootShortName = org.result.rootShortName; uppdated.child1 = req.node <= 0 ? null : org.result.child1; uppdated.child1Id = req.node <= 0 ? null : org.result.child1Id; uppdated.child1DnaId = req.node <= 0 ? null : org.result.child1DnaId; uppdated.child1ShortName = req.node <= 0 ? null : org.result.child1ShortName; uppdated.child2 = req.node <= 1 ? null : org.result.child2; uppdated.child2Id = req.node <= 1 ? null : org.result.child2Id; uppdated.child2DnaId = req.node <= 1 ? null : org.result.child2DnaId; uppdated.child2ShortName = req.node <= 1 ? null : org.result.child2ShortName; uppdated.child3 = req.node <= 2 ? null : org.result.child3; uppdated.child3Id = req.node <= 2 ? null : org.result.child3Id; uppdated.child3DnaId = req.node <= 2 ? null : org.result.child3DnaId; uppdated.child3ShortName = req.node <= 2 ? null : org.result.child3ShortName; uppdated.child4 = req.node <= 3 ? null : org.result.child4; uppdated.child4Id = req.node <= 3 ? null : org.result.child4Id; uppdated.child4DnaId = req.node <= 3 ? null : org.result.child4DnaId; uppdated.child4ShortName = req.node <= 3 ? null : org.result.child4ShortName; } // var apiUrlUpdate = $"{_configuration["API"]}/org/pos/officer/master-old/book"; // using (var client = new HttpClient()) // { // client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); // client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); // var _resUpdate = await client.PostAsJsonAsync(apiUrlUpdate, new // { // posMasterOldId = uppdated.posmasterId, // posMasterId = req.posmasterId, // profileId = uppdated.profileId, // }); // } uppdated.posmasterId = req.posmasterId; uppdated.node = req.node; uppdated.nodeId = req.nodeId; uppdated.orgRevisionId = req.orgRevisionId; uppdated.positionId = req.positionId; uppdated.posMasterNo = req.posMasterNo; uppdated.position = req.positionName; uppdated.PositionExecutive = req.posExecutiveName; uppdated.positionExecutiveField = req.positionExecutiveField; uppdated.positionArea = req.positionArea; uppdated.positionField = req.positionField; uppdated.posTypeId = req.posTypeId; uppdated.posTypeName = req.posTypeName; uppdated.posLevelId = req.posLevelId; uppdated.posLevelName = req.posLevelName; uppdated.Amount = req.Amount; uppdated.ReportingDate = req.reportingDate; uppdated.Status = "PENDING"; uppdated.LastUpdateFullName = FullName ?? "System Administrator"; uppdated.LastUpdateUserId = UserId ?? ""; uppdated.LastUpdatedAt = DateTime.Now; await _context.SaveChangesAsync(); return Success(); } /// /// แก้ไขอื่นๆ /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPut("{id:length(36)}")] public async Task> Put([FromBody] RetirementOtherEditRequest req, Guid id) { var getPermission = await _permission.GetPermissionAPIAsync("UPDATE", "SYS_PLACEMENT_OTHER"); var jsonData = JsonConvert.DeserializeObject(getPermission); if (jsonData["status"]?.ToString() != "200") { return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden); } var uppdated = await _context.RetirementOthers .FirstOrDefaultAsync(x => x.Id == id); if (uppdated == null) return Error(GlobalMessages.RetirementOtherNotFound, 404); uppdated.EducationOld = req.EducationOld; uppdated.Reason = req.Reason; uppdated.MilitaryDate = req.MilitaryDate; uppdated.OrganizationPositionOld = req.OrganizationPositionOld; uppdated.PositionTypeOld = req.PositionTypeOld; uppdated.PositionLevelOld = req.PositionLevelOld; uppdated.PositionNumberOld = req.PositionNumberOld; uppdated.AmountOld = req.AmountOld; uppdated.PositionDate = req.PositionDate; uppdated.LastUpdateFullName = FullName ?? "System Administrator"; uppdated.LastUpdateUserId = UserId ?? ""; uppdated.LastUpdatedAt = DateTime.Now; await _context.SaveChangesAsync(); return Success(); } /// /// ลบอื่นๆ /// /// Id อื่นๆ /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpDelete("{id:length(36)}")] public async Task> Delete(Guid id) { var getPermission = await _permission.GetPermissionAPIAsync("DELETE", "SYS_PLACEMENT_OTHER"); var jsonData = JsonConvert.DeserializeObject(getPermission); if (jsonData["status"]?.ToString() != "200") { return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden); } var deleted = await _context.RetirementOthers.AsQueryable() .Include(x => x.RetirementOtherDocs) .ThenInclude(x => x.Document) .FirstOrDefaultAsync(x => x.Id == id); if (deleted == null) return NotFound(); var retirementOtherDocs = new List(); foreach (var doc in deleted.RetirementOtherDocs) { if (doc.Document != null) retirementOtherDocs.Add(doc.Document.Id); } _context.RetirementOtherDocs.RemoveRange(deleted.RetirementOtherDocs); await _context.SaveChangesAsync(); _context.RetirementOthers.Remove(deleted); foreach (var doc in retirementOtherDocs) { if (doc != null) await _documentService.DeleteFileAsync(doc); } await _context.SaveChangesAsync(); return Success(); } /// /// สั่งรายชื่อไปออกคำสั่ง /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPut("report/{commandTypeId:length(36)}")] public async Task> PostToReport([FromBody] RetirementProfileRequest req, Guid commandTypeId) { foreach (var item in req.Id) { var uppdated = await _context.RetirementOthers .FirstOrDefaultAsync(x => x.Id == item); if (uppdated == null) continue; uppdated.CommandType = await _context.CommandTypes.FindAsync(commandTypeId); uppdated.Status = "REPORT"; uppdated.LastUpdateFullName = FullName ?? "System Administrator"; uppdated.LastUpdateUserId = UserId ?? ""; uppdated.LastUpdatedAt = DateTime.Now; } await _context.SaveChangesAsync(); return Success(); } /// /// ส่งรายชื่อออกคำสั่ง C-PM-08 /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPost("appoint/report")] public async Task> PostReportAppoint([FromBody] ReportPersonRequest req) { var placementProfiles = await _context.RetirementOthers .Where(x => req.refIds.Contains(x.Id.ToString())) .ToListAsync(); placementProfiles.ForEach(profile => profile.Status = req.status.Trim().ToUpper()); await _context.SaveChangesAsync(); return Success(); } /// /// ลบรายชื่อออกคำสั่ง C-PM-08 /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPost("appoint/report/delete")] public async Task> PostReportDeleteAppoint([FromBody] ReportPersonRequest req) { var placementProfiles = await _context.RetirementOthers .Where(x => req.refIds.Contains(x.Id.ToString())) // .Where(x => x.Status.ToUpper() == "REPORT") .ToListAsync(); placementProfiles.ForEach(profile => profile.Status = "WAITTING"); await _context.SaveChangesAsync(); return Success(); } /// /// เอกสารแนบท้าย C-PM-08 /// /// Record Id ของคำสั่ง /// pdf, docx หรือ xlsx /// /// เมื่อทำการอ่านข้อมูลจาก Relational Database สำเร็จ /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPost("appoint/report/attachment")] [AllowAnonymous] [ProducesResponseType(StatusCodes.Status200OK)] [ProducesResponseType(StatusCodes.Status401Unauthorized)] [ProducesResponseType(StatusCodes.Status500InternalServerError)] public async Task> PostReportAppointAttachment([FromBody] ReportAttachmentRequest req) { try { var report_data = (from p in _context.RetirementOthers .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .ToList() join r in req.refIds on p.Id.ToString() equals r.refId orderby r.Sequence select new { No = r.Sequence.ToString().ToThaiNumber(), FullName = $"{r.Prefix}{r.FirstName} {r.LastName}", Education = p.EducationOld == null ? "-" : p.EducationOld, OldOc = p.OrganizationPositionOld == null ? "" : p.OrganizationPositionOld.ToThaiNumber(), OldPositionType = p.PositionTypeOld == null ? "-" : p.PositionTypeOld, OldPositionLevel = p.PositionLevelOld == null ? "-" : p.PositionLevelOld, OldPositionNumber = p.PositionNumberOld == null ? "-" : p.PositionNumberOld.ToThaiNumber(), OldSalary = p.AmountOld == null ? "-" : p.AmountOld.Value.ToNumericNoDecimalText().ToThaiNumber(), LeaveDate = p.LeaveDate == null ? "-" : p.LeaveDate.Value.ToThaiShortDate2().ToThaiNumber(), NewOc = (p.position == null ? "" : $"{p.position}\n") + (p.PositionExecutive == null ? "" : (p.positionArea == null ? $"{p.positionExecutiveField}\n" : $"{p.PositionExecutive}({p.positionExecutiveField})\n")) + (p.child4 == null ? "" : $"{p.child4}\n") + (p.child3 == null ? "" : $"{p.child3}\n") + (p.child2 == null ? "" : $"{p.child2}\n") + (p.child1 == null ? "" : $"{p.child1}\n") + (p.root == null ? "" : $"{p.root}").ToThaiNumber(), NewPositionType = p.posTypeName == null ? "-" : p.posTypeName, NewPositionLevel = p.posLevelName == null ? "-" : p.posLevelName, NewPositionNumber = p.rootShortName == null && p.posMasterNo == null ? null : $"{(p.child1ShortName == null ? p.rootShortName : (p.child2ShortName == null ? p.child1ShortName : (p.child3ShortName == null ? p.child2ShortName : (p.child4ShortName == null ? p.child3ShortName : p.child4ShortName))))}" + $" {p.posMasterNo?.ToString().ToThaiNumber()}", NewSalary = r.Amount == null ? "-" : r.Amount.Value.ToNumericNoDecimalText().ToThaiNumber(), AppointDate = p.PositionDate == null ? "-" : p.PositionDate.Value.ToThaiShortDate2().ToThaiNumber(), CommandExcecuteDate = string.IsNullOrEmpty(r.CommandExcecuteDate.ToString()) ? "-" : r.CommandExcecuteDate.Value.ToThaiShortDate2().ToThaiNumber(), RemarkHorizontal = r.RemarkHorizontal == null ? "-" : r.RemarkHorizontal.ToThaiNumber(), RemarkVertical = r.RemarkVertical == null ? "-" : r.RemarkVertical.ToThaiNumber() }).ToList(); var result = new List(); foreach (var r in report_data) { result.Add(r); string? _null = null; if (r.RemarkHorizontal != null && r.RemarkHorizontal != "") { result.Add(new { No = _null, FullName = r.RemarkHorizontal, Education = _null, OldOc = _null, OldPositionType = _null, OldPositionLevel = _null, OldPositionNumber = _null, OldSalary = _null, LeaveDate = _null, NewOc = _null, NewPositionType = _null, NewPositionLevel = _null, NewPositionNumber = _null, NewSalary = _null, AppointDate = _null, CommandExcecuteDate = _null, RemarkHorizontal = _null, RemarkVertical = _null, }); } } return Success(result); } catch { throw; } } /// /// ออกคำสั่ง C-PM-08 บรรจุและแต่งตั้งข้าราชการกลับเข้ารับราชการ /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPost("appoint/report/excecute")] public async Task> PostReportExecuteAppoint([FromBody] ReportExecuteRequest req) { var data = await _context.RetirementOthers .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .ToListAsync(); string? _null = null; var resultData = (from p in data join r in req.refIds on p.Id.ToString() equals r.refId select new { profileId = p.profileId, amount = r.amount, amountSpecial = r.amountSpecial, positionSalaryAmount = r.positionSalaryAmount, mouthSalaryAmount = r.mouthSalaryAmount, positionExecutive = p.PositionExecutiveOld, positionExecutiveField = p.positionExecutiveFieldOld, positionArea = p.positionAreaOld, positionType = p.PositionTypeOld, positionLevel = p.PositionLevelOld, isLeave = false, leaveReason = _null, dateLeave = _null, commandId = r.commandId, isGovernment = true, orgRoot = p.rootOld, orgChild1 = p.child1Old, orgChild2 = p.child2Old, orgChild3 = p.child3Old, orgChild4 = p.child4Old, commandNo = r.commandNo, commandYear = r.commandYear, posNo = p.posMasterNoOld?.ToString(), posNoAbb = p.child4ShortNameOld != null ? $"{p.child4ShortNameOld}" : p.child3ShortNameOld != null ? $"{p.child3ShortNameOld}" : p.child2ShortNameOld != null ? $"{p.child2ShortNameOld}" : p.child1ShortNameOld != null ? $"{p.child1ShortNameOld}" : p.rootShortNameOld != null ? $"{p.rootShortNameOld}" : "", commandDateAffect = r.commandDateAffect, commandDateSign = r.commandDateSign, positionName = p.PositionOld, commandCode = r.commandCode, commandName = r.commandName, remark = r.remark, positionTypeNew = p.posTypeId, positionLevelNew = p.posLevelId, positionNameNew = p.position, posmasterId = p.posmasterId, posTypeNameNew = p.posTypeName, posLevelNameNew = p.posLevelName, posNoNew = p.posMasterNo?.ToString(), posNoAbbNew = p.child4ShortName != null ? $"{p.child4ShortName}" : p.child3ShortName != null ? $"{p.child3ShortName}" : p.child2ShortName != null ? $"{p.child2ShortName}" : p.child1ShortName != null ? $"{p.child1ShortName}" : p.rootShortName != null ? $"{p.rootShortName}" : "", orgRootNew = p.root, orgChild1New = p.child1, orgChild2New = p.child2, orgChild3New = p.child3, orgChild4New = p.child4 }).ToList(); var baseAPIOrg = _configuration["API"]; var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave"; using (var client = new HttpClient()) { client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); var _res = await client.PostAsJsonAsync(apiUrlOrg, new { data = resultData, }); var _result = await _res.Content.ReadAsStringAsync(); if (_res.IsSuccessStatusCode) { data.ForEach(profile => profile.Status = "DONE"); await _context.SaveChangesAsync(); } } return Success(); } /// /// หน่วยงานที่ถูกเลือกไปแล้ว /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpGet("use")] public async Task> GetPositionUse() { var position = await _context.RetirementOthers .Where(x => x.posmasterId != null) .Where(x => x.Status != "DONE") .Select(x => x.posmasterId) .ToListAsync(); return Success(position); } /// /// ส่งรายชื่อออกคำสั่ง C-PM-09 /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPost("out/report")] public async Task> PostReportOut([FromBody] ReportPersonRequest req) { var placementProfiles = await _context.RetirementOthers .Where(x => req.refIds.Contains(x.Id.ToString())) .ToListAsync(); placementProfiles.ForEach(profile => profile.Status = req.status.Trim().ToUpper()); await _context.SaveChangesAsync(); return Success(); } /// /// ลบรายชื่อออกคำสั่ง C-PM-09 /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPost("out/report/delete")] public async Task> PostReportDeleteOut([FromBody] ReportPersonRequest req) { var placementProfiles = await _context.RetirementOthers .Where(x => req.refIds.Contains(x.Id.ToString())) // .Where(x => x.Status.ToUpper() == "REPORT") .ToListAsync(); placementProfiles.ForEach(profile => profile.Status = "WAITTING"); await _context.SaveChangesAsync(); return Success(); } /// /// เอกสารแนบท้าย C-PM-09 /// /// Record Id ของคำสั่ง /// pdf, docx หรือ xlsx /// /// เมื่อทำการอ่านข้อมูลจาก Relational Database สำเร็จ /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPost("out/report/attachment")] [AllowAnonymous] [ProducesResponseType(StatusCodes.Status200OK)] [ProducesResponseType(StatusCodes.Status401Unauthorized)] [ProducesResponseType(StatusCodes.Status500InternalServerError)] public async Task> PostReportOutAttachment([FromBody] ReportAttachmentRequest req) { try { var report_data = (from p in _context.RetirementOthers .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .ToList() join r in req.refIds on p.Id.ToString() equals r.refId orderby r.Sequence select new { No = r.Sequence.ToString().ToThaiNumber(), FullName = $"{r.Prefix}{r.FirstName} {r.LastName}", Education = p.EducationOld == null ? "-" : p.EducationOld, OldOc = p.OrganizationPositionOld == null ? "-" : p.OrganizationPositionOld.ToThaiNumber(), OldPositionType = p.PositionTypeOld == null ? "-" : p.PositionTypeOld, OldPositionLevel = p.PositionLevelOld == null ? "-" : p.PositionLevelOld, OldPositionNumber = p.PositionNumberOld == null ? "-" : p.PositionNumberOld.ToThaiNumber(), OldSalary = p.AmountOld == null ? "-" : p.AmountOld.Value.ToNumericNoDecimalText().ToThaiNumber(), LeaveDate = p.LeaveDate == null ? "-" : p.LeaveDate.Value.ToThaiShortDate2().ToThaiNumber(), MilitaryDate = p.MilitaryDate == null ? "-" : p.MilitaryDate.Value.ToThaiShortDate2().ToThaiNumber(), NewOc = (p.position == null ? "" : $"{p.position}\n") + (p.PositionExecutive == null ? "" : (p.positionExecutiveField == null ? $"{p.PositionExecutive}\n" : $"{p.PositionExecutive}({p.positionExecutiveField})\n")) + (p.child4 == null ? "" : $"{p.child4}\n") + (p.child3 == null ? "" : $"{p.child3}\n") + (p.child2 == null ? "" : $"{p.child2}\n") + (p.child1 == null ? "" : $"{p.child1}\n") + (p.root == null ? "" : $"{p.root}").ToThaiNumber(), NewPositionType = p.posTypeName == null ? "-" : p.posTypeName, NewPositionLevel = p.posLevelName == null ? "-" : p.posLevelName, NewPositionNumber = p.rootShortName == null && p.posMasterNo == null ? null : $"{(p.child1ShortName == null ? p.rootShortName : (p.child2ShortName == null ? p.child1ShortName : (p.child3ShortName == null ? p.child2ShortName : (p.child4ShortName == null ? p.child3ShortName : p.child4ShortName))))}" + $" {p.posMasterNo?.ToString().ToThaiNumber()}", NewSalary = r.Amount == null ? "-" : r.Amount.Value.ToNumericNoDecimalText().ToThaiNumber(), AppointDate = p.PositionDate == null ? "-" : p.PositionDate.Value.ToThaiShortDate2().ToThaiNumber(), CommandExcecuteDate = string.IsNullOrEmpty(r.CommandExcecuteDate.ToString()) ? "-" : r.CommandExcecuteDate.Value.ToThaiShortDate2().ToThaiNumber(), RemarkHorizontal = r.RemarkHorizontal == null ? "-" : r.RemarkHorizontal.ToThaiNumber(), RemarkVertical = r.RemarkVertical == null ? "-" : r.RemarkVertical.ToThaiNumber() }).ToList(); var result = new List(); foreach (var r in report_data) { result.Add(r); string? _null = null; if (r.RemarkHorizontal != null && r.RemarkHorizontal != "") { result.Add(new { No = _null, FullName = r.RemarkHorizontal, Education = _null, OldOc = _null, OldPositionType = _null, OldPositionLevel = _null, OldPositionNumber = _null, OldSalary = _null, LeaveDate = _null, MilitaryDate = _null, NewOc = _null, NewPositionType = _null, NewPositionLevel = _null, NewPositionNumber = _null, NewSalary = _null, AppointDate = _null, CommandExcecuteDate = _null, RemarkHorizontal = _null, RemarkVertical = _null, }); } } return Success(result); } catch { throw; } } /// /// ออกคำสั่ง C-PM-09 คำสั่งบรรจุและแต่งตั้งผู้ออกไปรับราชการทหารกลับเข้ารับราชการ /// /// /// /// ค่าตัวแปรที่ส่งมาไม่ถูกต้อง /// ไม่ได้ Login เข้าระบบ /// เมื่อเกิดข้อผิดพลาดในการทำงาน [HttpPost("out/report/excecute")] public async Task> PostReportExecuteOut([FromBody] ReportExecuteRequest req) { var data = await _context.RetirementOthers .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString())) .ToListAsync(); string? _null = null; var resultData = (from p in data join r in req.refIds on p.Id.ToString() equals r.refId select new { profileId = p.profileId, amount = r.amount, amountSpecial = r.amountSpecial, positionSalaryAmount = r.positionSalaryAmount, mouthSalaryAmount = r.mouthSalaryAmount, positionExecutive = p.PositionExecutiveOld, positionExecutiveField = p.positionExecutiveFieldOld, positionArea = p.positionAreaOld, positionType = p.PositionTypeOld, positionLevel = p.PositionLevelOld, isLeave = false, leaveReason = _null, dateLeave = _null, commandId = r.commandId, isGovernment = true, orgRoot = p.rootOld, orgChild1 = p.child1Old, orgChild2 = p.child2Old, orgChild3 = p.child3Old, orgChild4 = p.child4Old, commandNo = r.commandNo, commandYear = r.commandYear, posNo = p.posMasterNoOld?.ToString(), posNoAbb = p.child4ShortNameOld != null ? $"{p.child4ShortNameOld}" : p.child3ShortNameOld != null ? $"{p.child3ShortNameOld}" : p.child2ShortNameOld != null ? $"{p.child2ShortNameOld}" : p.child1ShortNameOld != null ? $"{p.child1ShortNameOld}" : p.rootShortNameOld != null ? $"{p.rootShortNameOld}" : "", commandDateAffect = r.commandDateAffect, commandDateSign = r.commandDateSign, positionName = p.PositionOld, commandCode = r.commandCode, commandName = r.commandName, remark = r.remark, positionTypeNew = p.posTypeId, positionLevelNew = p.posLevelId, positionNameNew = p.position, posmasterId = p.posmasterId, posTypeNameNew = p.posTypeName, posLevelNameNew = p.posLevelName, posNoNew = p.posMasterNo?.ToString(), posNoAbbNew = p.child4ShortName != null ? $"{p.child4ShortName}" : p.child3ShortName != null ? $"{p.child3ShortName}" : p.child2ShortName != null ? $"{p.child2ShortName}" : p.child1ShortName != null ? $"{p.child1ShortName}" : p.rootShortName != null ? $"{p.rootShortName}" : "", orgRootNew = p.root, orgChild1New = p.child1, orgChild2New = p.child2, orgChild3New = p.child3, orgChild4New = p.child4 }).ToList(); var baseAPIOrg = _configuration["API"]; var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave"; using (var client = new HttpClient()) { client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", "")); client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]); var _res = await client.PostAsJsonAsync(apiUrlOrg, new { data = resultData, }); var _result = await _res.Content.ReadAsStringAsync(); if (_res.IsSuccessStatusCode) { data.ForEach(profile => profile.Status = "DONE"); await _context.SaveChangesAsync(); } } return Success(); } } }