hrms-api-backend/BMA.EHR.Leave.Service/Controllers/DutyTimeController.cs

using BMA.EHR.Application.Repositories;
using BMA.EHR.Application.Repositories.Leaves;
using BMA.EHR.Command.Service.DTOs.DutyTime;
using BMA.EHR.Domain.Common;
using BMA.EHR.Domain.Models.Leave;
using BMA.EHR.Domain.Shared;
using BMA.EHR.Infrastructure.Persistence;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Swashbuckle.AspNetCore.Annotations;
using System.Security.Claims;

namespace BMA.EHR.Command.Service.Controllers
{
    [Route("api/v{version:apiVersion}/leave/duty-time")]
    [ApiVersion("1.0")]
    [ApiController]
    [Produces("application/json")]
    [Authorize]
    [SwaggerTag("API ระบบจัดการรอบการลงเวลาทำงาน")]
    public class DutyTimeController : BaseController
    {
        #region " Fields "

        private readonly DutyTimeRepository _repository;
        private readonly LeaveDbContext _context;
        private readonly IHttpContextAccessor _httpContextAccessor;
        private readonly IWebHostEnvironment _hostingEnvironment;
        private readonly IConfiguration _configuration;
        private readonly UserProfileRepository _userProfileRepository;

        #endregion

        #region " Constuctor and Destructor "

        public DutyTimeController(DutyTimeRepository repository,
                                LeaveDbContext context,
                                IHttpContextAccessor httpContextAccessor,
                                IWebHostEnvironment hostingEnvironment,
                                IConfiguration configuration,
                                UserProfileRepository userProfileRepository)
        {
            _repository = repository;
            _context = context;
            _httpContextAccessor = httpContextAccessor;
            _hostingEnvironment = hostingEnvironment;
            _configuration = configuration;
            _userProfileRepository = userProfileRepository;
        }

        #endregion

        #region " Properties "

        private string? UserId => _httpContextAccessor?.HttpContext?.User?.FindFirst(ClaimTypes.NameIdentifier)?.Value;

        private string? FullName => _httpContextAccessor?.HttpContext?.User?.FindFirst("name")?.Value;

        private bool? PlacementAdmin => _httpContextAccessor?.HttpContext?.User?.IsInRole("placement1");

        private Guid OcId
        {
            get
            {
                if (UserId != null || UserId != "")
                    return _userProfileRepository.GetUserOCId(Guid.Parse(UserId!));
                else
                    return Guid.Empty;
            }
        }

        #endregion

        #region " Methods "

        /// <summary>
        /// LV1_004 - ข้อมูลทั้งหมดของรอบการปฏิบัติงาน (ADMIN)
        /// </summary>
        /// <returns>
        /// </returns>
        /// <response code="200">เมื่อทำรายการสำเร็จ</response>
        /// <response code="401">ไม่ได้ Login เข้าระบบ</response>
        /// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
        [HttpGet]
        [ProducesResponseType(StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status401Unauthorized)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<ActionResult<ResponseObject>> GetAllAsync()
        {
            var data = await _repository.GetAllAsync();

            return Success(data);
        }

        /// <summary>
        /// ข้อมูลของรอบการปฏิบัติงาน (ADMIN)
        /// </summary>
        /// <returns>
        /// </returns>
        /// <response code="200">เมื่อทำรายการสำเร็จ</response>
        /// <response code="401">ไม่ได้ Login เข้าระบบ</response>
        /// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
        [HttpGet("{id:guid}")]
        [ProducesResponseType(StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status401Unauthorized)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<ActionResult<ResponseObject>> GetByIdAsync(Guid id)
        {
            var data = await _repository.GetByIdAsync(id);

            return Success(data);
        }

        /// <summary>
        /// LV1_001 - สร้างรอบการปฏิบัติงาน (ADMIN)
        /// </summary>
        /// <returns>
        /// </returns>
        /// <response code="200">เมื่อทำรายการสำเร็จ</response>
        /// <response code="401">ไม่ได้ Login เข้าระบบ</response>
        /// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
        [HttpPost]
        [ProducesResponseType(StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status401Unauthorized)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<ActionResult<ResponseObject>> PostAsync([FromBody] CreateDutyTimeDto data)
        {
            // validate
            var startMorning = TimeOnly.Parse(data.StartTimeMorning);
            var endMorning = TimeOnly.Parse(data.EndTimeMorning);
            var startAfternoon = TimeOnly.Parse(data.StartTimeAfternoon);
            var endAfternoon = TimeOnly.Parse(data.EndTimeAfternoon);

            if (startMorning >= endMorning)
            {
                throw new Exception(GlobalMessages.StartTimeGreaterEnd);
            }

            if (startAfternoon >= endAfternoon)
            {
                throw new Exception(GlobalMessages.StartTimeGreaterEnd);
            }

            var oldData = await _repository.GetAllAsync();
            if (oldData == null || oldData.Count == 0)
            {
                var inserted = new DutyTime
                {
                    Id = Guid.NewGuid(),
                    Description = data.Description,
                    StartTimeMorning = data.StartTimeMorning,
                    EndTimeMorning = data.EndTimeMorning,
                    StartTimeAfternoon = data.StartTimeAfternoon,
                    EndTimeAfternoon = data.EndTimeAfternoon,
                    IsActive = true,
                    IsDefault = true,
                };

                var ret = await _repository.AddAsync(inserted);

                return Success(ret);
            }
            else
            {
                if (data.IsDefault)
                {
                    foreach (var d in oldData)
                    {
                        d.IsDefault = false;
                        await _repository.UpdateAsync(d);
                    }
                }

                var inserted = new DutyTime
                {
                    Id = Guid.NewGuid(),
                    Description = data.Description,
                    StartTimeMorning = data.StartTimeMorning,
                    EndTimeMorning = data.EndTimeMorning,
                    StartTimeAfternoon = data.StartTimeAfternoon,
                    EndTimeAfternoon = data.EndTimeAfternoon,
                    IsActive = true,
                    IsDefault = data.IsDefault,
                };

                var ret = await _repository.AddAsync(inserted);

                return Success(ret);
            }
        }


        /// <summary>
        /// LV1_002 - แก้ไขรอบการปฏิบัติงาน (ADMIN)
        /// </summary>
        /// <returns>
        /// </returns>
        /// <response code="200">เมื่อทำรายการสำเร็จ</response>
        /// <response code="401">ไม่ได้ Login เข้าระบบ</response>
        /// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
        [HttpPut("{id:guid}")]
        [ProducesResponseType(StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status401Unauthorized)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<ActionResult<ResponseObject>> PutAsync(Guid id, [FromBody] UpdateDutyTimeDto data)
        {
            var oldData = await _repository.GetByIdAsync(id);
            if (oldData == null)
            {
                throw new Exception(GlobalMessages.DataNotFound);
            }
            else
            {             
                var oldDataList = await _repository.GetAllAsync();
                if (data.IsDefault)
                {
                    foreach (var d in oldDataList)
                    {
                        d.IsDefault = false;
                        await _repository.UpdateAsync(d);
                    }
                }

                oldData.Description = data.Description;
                oldData.IsDefault = data.IsDefault;
                oldData.IsActive = data.IsActive;

                await _repository.UpdateAsync(oldData);

                return Success(oldData);

            }
        }


        /// <summary>
        /// LV1_003 - ลบรอบการปฏิบัติงาน (ADMIN)
        /// </summary>
        /// <returns>
        /// </returns>
        /// <response code="200">เมื่อทำรายการสำเร็จ</response>
        /// <response code="401">ไม่ได้ Login เข้าระบบ</response>
        /// <response code="500">เมื่อเกิดข้อผิดพลาดในการทำงาน</response>
        [HttpDelete("{id:guid}")]
        [ProducesResponseType(StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status401Unauthorized)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<ActionResult<ResponseObject>> DeleteAsync(Guid id)
        {
            var oldData = await _repository.GetByIdAsync(id);
            if (oldData == null)
            {
                throw new Exception(GlobalMessages.DataNotFound);
            }
            else
            {
                if (oldData.IsActive || oldData.IsDefault)
                {
                    throw new Exception("ไม่สามารถลบรอบการปฏิบัติงานที่ยังใช้งานอยู่ได้");
                }

                await _repository.DeleteAsync(oldData);
                return Success();
            }
        }

        #endregion
    }
}