ยกเลิกลูกจ้าง

BMA.EHR.Application/Repositories/RetirementEmployeeRepository.cs

@@ -191,7 +191,7 @@ namespace BMA.EHR.Application.Repositories
             await _dbContext.SaveChangesAsync();
         }
 
-        public async Task CommanderApproveRetirementResignEmployee(Guid id, string reason, DateTime date)
+        public async Task CommanderApproveRetirementResignEmployee(Guid id, string reason, DateTime? date)
         {
             // Get UserId from token
             var userId = UserId == null ? Guid.Empty : Guid.Parse(UserId);
@@ -307,7 +307,7 @@ namespace BMA.EHR.Application.Repositories
             }
         }
 
-        public async Task CommanderRejectRetirementResignEmployee(Guid id, string reason, DateTime date)
+        public async Task CommanderRejectRetirementResignEmployee(Guid id, string reason, DateTime? date)
         {
             // Get UserId from token
             var userId = UserId == null ? Guid.Empty : Guid.Parse(UserId);
@@ -398,7 +398,7 @@ namespace BMA.EHR.Application.Repositories
 
         }
 
-        public async Task ApproveRetirementResignEmployee(Guid id, string reason, DateTime date)
+        public async Task ApproveRetirementResignEmployee(Guid id, string reason, DateTime? date)
         {
             // Get UserId from token
             var userId = UserId == null ? Guid.Empty : Guid.Parse(UserId);
@@ -482,7 +482,7 @@ namespace BMA.EHR.Application.Repositories
 
         }
 
-        public async Task RejectRetirementResignEmployee(Guid id, string reason, DateTime date)
+        public async Task RejectRetirementResignEmployee(Guid id, string reason, DateTime? date)
         {
             // Get UserId from token
             var userId = UserId == null ? Guid.Empty : Guid.Parse(UserId);
@@ -565,5 +565,434 @@ namespace BMA.EHR.Application.Repositories
             }
         }
 
+
+
+        public async Task<RetirementResignEmployeeCancel?> GetByIdCancelAsync(Guid id)
+        {
+            try
+            {
+                var data = await _dbContext.Set<RetirementResignEmployeeCancel>().AsQueryable()
+                                .Include(x => x.Approvers)
+                                .FirstOrDefaultAsync(x => x.Id == id);
+
+                return data;
+            }
+            catch
+            {
+                throw;
+            }
+
+        }
+        public async Task OfficerApproveRetirementResignEmployeeCancel(Guid id)
+        {
+            var rawData = await GetByIdCancelAsync(id);
+            if (rawData == null)
+            {
+                throw new Exception(GlobalMessages.DataNotFound);
+            }
+
+            rawData.Status = "PENDING";
+            if (rawData.ApproveStep == "st1")
+            {
+                rawData.ApproveStep = "st2";
+            }
+            else if (rawData.ApproveStep == "st3")
+            {
+                rawData.ApproveStep = "st4";
+            }
+
+            await _dbContext.SaveChangesAsync();
+
+            // TODO: Send notification to 1st Commander
+            var firstCommander = rawData.Approvers
+                            .Where(x => x.ApproveType!.ToUpper() == "COMMANDER")
+                            .OrderBy(x => x.Seq)
+                            .FirstOrDefault();
+            // Send Notification
+            var noti1 = new Notification
+            {
+                Body = $"การขอลาออกของคุณ {rawData.firstName} {rawData.lastName} รอรับการอนุมัติจากคุณ",
+                ReceiverUserId = firstCommander!.ProfileId,
+                Type = "",
+                Payload = $"{URL}/retirement/resign-employee-detail/{id}",
+            };
+            _dbContext.Set<Notification>().Add(noti1);
+            await _dbContext.SaveChangesAsync();
+        }
+
+        public async Task CommanderApproveRetirementResignEmployeeCancel(Guid id, string reason, DateTime? date)
+        {
+            // Get UserId from token
+            var userId = UserId == null ? Guid.Empty : Guid.Parse(UserId);
+
+
+            var rawData = await GetByIdCancelAsync(id);
+            if (rawData == null)
+            {
+                throw new Exception(GlobalMessages.DataNotFound);
+            }
+
+            // if (rawData.ApproveStep != "st2")
+            // {
+            //     throw new Exception("คำขอนี้ยังไม่ได้อยู่ในขั้นตอนที่สามารถอนุมัติได้ ไม่สามารถทำรายการได้");
+            // }
+
+            // check commander approve
+            //var approvers = await _dbContext.Set<RetirementResignEmployeeCancelApprover>()
+            //                        //.AsNoTracking()
+            //                        .Include(x => x.RetirementResignEmployeeCancel)
+            //                        .Where(x => x.RetirementResignEmployeeCancel.Id == id && x.ApproveType == "COMMANDER")
+            //                        .OrderBy(x => x.Seq)
+            //                        .ToListAsync();
+
+            var approvers = rawData.Approvers.Where(x => x.ApproveType!.ToUpper() == "COMMANDER").OrderBy(x => x.Seq).ToList();
+
+            var approver = approvers.FirstOrDefault(x => x.KeycloakId == userId);
+            if (approver == null)
+            {
+                throw new Exception("คุณไม่มีสิทธิ์อนุมัติการลาออกในขั้นตอนนี้");
+            }
+
+            // check prev approver มี action แล้วหรือไม่?
+            var prevApprover = approvers.FirstOrDefault(x => x.Seq == approver.Seq - 1);
+
+            if (prevApprover != null)
+            {
+                if (prevApprover.ApproveStatus == "PENDING")
+                {
+                    throw new Exception("ไม่สามารถทำการอนุมัติได้ เนื่องจากยังอยู่ระหว่างการพิจารณาโดยผู้บังคับบัญชารายก่อนหน้า");
+                }
+            }
+
+            var maxSeq = approvers.Max(x => x.Seq);
+
+            //var data = await _dbContext.Set<RetirementResignEmployeeCancelApprover>()
+            //                    .AsNoTracking()
+            //                    .Include(x => x.RetirementResignEmployeeCancel)
+            //                    .Where(x => x.RetirementResignEmployeeCancel.Id == id && x.KeycloakId == userId && x.ApproveType == "COMMANDER")
+            //                    .FirstOrDefaultAsync();
+
+            //if(data != null)
+            //{
+            //    data.ApproveStatus = "APPROVE";
+            //    data.Comment = reason;
+
+            //    data.LastUpdatedAt = DateTime.Now;
+            //    data.LastUpdateUserId = userId.ToString("D");
+            //    data.LastUpdateFullName = FullName ?? "";
+
+            //    await _dbContext.SaveChangesAsync();
+            //}
+
+            approver.ApproveStatus = "APPROVE";
+            approver.Comment = reason;
+            approver.RejectDate = date;
+
+            //await _dbContext.SaveChangesAsync();
+
+            if (approver.Seq != maxSeq)
+            {
+                rawData.Status = "PENDING";
+
+                var nextApprover = approvers.FirstOrDefault(x => x.Seq == approver.Seq + 1);
+
+                // Send Noti
+                var noti = new Notification
+                {
+                    Body = $"การขอลาออกของคุณ {rawData.firstName} {rawData.lastName} รอรับการอนุมัติจากคุณ",
+                    ReceiverUserId = nextApprover!.ProfileId,
+                    Type = "",
+                    Payload = $"{URL}/retirement/resign-employee-detail/{id}",
+                };
+                _dbContext.Set<Notification>().Add(noti);
+                await _dbContext.SaveChangesAsync();
+            }
+            else
+            {
+                rawData.Status = "PENDING";
+                // rawData.LeaveComment = reason;
+                // if (rawData.Group != "1.1")
+                // {
+                rawData.ApproveStep = "st3";
+                // }
+
+
+                // TODO: Send notification to 1st Approver
+                var firstCommander = rawData.Approvers
+                           .Where(x => x.ApproveType!.ToUpper() == "APPROVER")
+                           .OrderBy(x => x.Seq)
+                           .FirstOrDefault();
+
+                // Send Notification
+                var noti1 = new Notification
+                {
+                    Body = $"การขอลาออกของคุณ {rawData.firstName} {rawData.lastName} รอรับการอนุมัติจากคุณ",
+                    ReceiverUserId = firstCommander!.ProfileId,
+                    Type = "",
+                    Payload = $"{URL}/retirement/resign-employee-detail/{id}",
+                };
+                _dbContext.Set<Notification>().Add(noti1);
+                await _dbContext.SaveChangesAsync();
+            }
+        }
+
+        public async Task CommanderRejectRetirementResignEmployeeCancel(Guid id, string reason, DateTime? date)
+        {
+            // Get UserId from token
+            var userId = UserId == null ? Guid.Empty : Guid.Parse(UserId);
+
+
+            var rawData = await GetByIdCancelAsync(id);
+            if (rawData == null)
+            {
+                throw new Exception(GlobalMessages.DataNotFound);
+            }
+
+            // if (rawData.ApproveStep != "st2")
+            // {
+            //     throw new Exception("คำขอนี้ยังไม่ได้อยู่ในขั้นตอนที่สามารถอนุมัติได้ ไม่สามารถทำรายการได้");
+            // }
+
+            // check commander approve
+            var approvers = rawData.Approvers.Where(x => x.ApproveType!.ToUpper() == "COMMANDER").OrderBy(x => x.Seq).ToList();
+
+            var approver = approvers.FirstOrDefault(x => x.KeycloakId == userId);
+            if (approver == null)
+            {
+                throw new Exception("คุณไม่มีสิทธิ์อนุมัติการลาออกในขั้นตอนนี้");
+            }
+
+            // check prev approver มี action แล้วหรือไม่?
+            var prevApprover = approvers.FirstOrDefault(x => x.Seq == approver.Seq - 1);
+
+            if (prevApprover != null)
+            {
+                if (prevApprover.ApproveStatus == "PENDING")
+                {
+                    throw new Exception("ไม่สามารถทำการอนุมัติได้ เนื่องจากยังอยู่ระหว่างการพิจารณาโดยผู้บังคับบัญชารายก่อนหน้า");
+                }
+            }
+
+
+            var maxSeq = approvers.Max(x => x.Seq);
+
+            approver.ApproveStatus = "REJECT";
+            approver.Comment = reason;
+            approver.RejectDate = date;
+
+            if (approver.Seq != maxSeq)
+            {
+
+
+                var nextApprover = approvers.FirstOrDefault(x => x.Seq == approver.Seq + 1);
+                // Send Noti
+                var noti = new Notification
+                {
+                    Body = $"การขอลาออกของคุณ {rawData.firstName} {rawData.lastName} รอรับการอนุมัติจากคุณ",
+                    ReceiverUserId = nextApprover!.ProfileId,
+                    Type = "",
+                    Payload = $"{URL}/retirement/resign-employee-detail/{id}",
+                };
+                _dbContext.Set<Notification>().Add(noti);
+
+                rawData.Status = "PENDING";
+                await _dbContext.SaveChangesAsync();
+            }
+            else
+            {
+                rawData.Status = "PENDING";
+                // rawData.LeaveComment = reason;
+                // if (rawData.Group != "1.1")
+                // {
+                rawData.ApproveStep = "st3";
+                // }
+
+
+                // TODO: Send notification to 1st Approver
+                var firstCommander = rawData.Approvers
+                           .Where(x => x.ApproveType!.ToUpper() == "APPROVER")
+                           .OrderBy(x => x.Seq)
+                           .FirstOrDefault();
+                // Send Notification
+                var noti1 = new Notification
+                {
+                    Body = $"การขอลาออกของคุณ {rawData.firstName} {rawData.lastName} รอรับการอนุมัติจากคุณ",
+                    ReceiverUserId = firstCommander!.ProfileId,
+                    Type = "",
+                    Payload = $"{URL}/retirement/resign-employee-detail/{id}",
+                };
+                _dbContext.Set<Notification>().Add(noti1);
+                await _dbContext.SaveChangesAsync();
+            }
+
+        }
+
+        public async Task ApproveRetirementResignEmployeeCancel(Guid id, string reason, DateTime? date)
+        {
+            // Get UserId from token
+            var userId = UserId == null ? Guid.Empty : Guid.Parse(UserId);
+
+            var rawData = await GetByIdCancelAsync(id);
+            if (rawData == null)
+            {
+                throw new Exception(GlobalMessages.DataNotFound);
+            }
+
+            // if (rawData.ApproveStep != "st3")
+            // {
+            //     throw new Exception("คำขอนี้ยังไม่ได้อยู่ในขั้นตอนที่สามารถอนุมัติได้ ไม่สามารถทำรายการได้");
+            // }
+
+            // check commander approve
+            var approvers = rawData.Approvers.Where(x => x.ApproveType!.ToUpper() == "APPROVER").OrderBy(x => x.Seq).ToList();
+
+            var approver = approvers.FirstOrDefault(x => x.KeycloakId == userId);
+            if (approver == null)
+            {
+                throw new Exception("คุณไม่มีสิทธิ์อนุมัติการลาออกในขั้นตอนนี้");
+            }
+
+            // check prev approver มี action แล้วหรือไม่?
+            var prevApprover = approvers.FirstOrDefault(x => x.Seq == approver.Seq - 1);
+
+            if (prevApprover != null)
+            {
+                if (prevApprover.ApproveStatus == "PENDING")
+                {
+                    throw new Exception("ไม่สามารถทำการอนุมัติได้ เนื่องจากยังอยู่ระหว่างการพิจารณาโดยผู้บังคับบัญชารายก่อนหน้า");
+                }
+            }
+
+
+            var maxSeq = approvers.Max(x => x.Seq);
+
+            approver.ApproveStatus = "APPROVE";
+            approver.Comment = reason;
+            approver.RejectDate = date;
+
+            if (approver.Seq != maxSeq)
+            {
+                var nextApprover = approvers.FirstOrDefault(x => x.Seq == approver.Seq + 1);
+                // Send Noti
+                var noti1 = new Notification
+                {
+                    Body = $"การขอลาออกของคุณ {rawData.firstName} {rawData.lastName} รอรับการอนุมัติจากคุณ",
+                    ReceiverUserId = nextApprover!.ProfileId,
+                    Type = "",
+                    Payload = "",
+                };
+                _dbContext.Set<Notification>().Add(noti1);
+                await _dbContext.SaveChangesAsync();
+            }
+            else
+            {
+                rawData.Status = "APPROVE";
+                // rawData.LeaveDirectorComment = reason;
+                if (rawData.Group != "1.1")
+                {
+                    rawData.ApproveStep = "st5";
+                }
+                else
+                {
+                    rawData.ApproveStep = "st4";
+                }
+
+                // Send Noti
+                var noti = new Notification
+                {
+                    Body = $"การขอลาออกของคุณได้รับการอนุมัติ",
+                    ReceiverUserId = Guid.Parse(rawData.profileId),
+                    Type = "",
+                    Payload = "",
+                };
+                _dbContext.Set<Notification>().Add(noti);
+                await _dbContext.SaveChangesAsync();
+            }
+
+        }
+
+        public async Task RejectRetirementResignEmployeeCancel(Guid id, string reason, DateTime? date)
+        {
+            // Get UserId from token
+            var userId = UserId == null ? Guid.Empty : Guid.Parse(UserId);
+
+            var rawData = await GetByIdCancelAsync(id);
+            if (rawData == null)
+            {
+                throw new Exception(GlobalMessages.DataNotFound);
+            }
+
+            // if (rawData.ApproveStep != "st3")
+            // {
+            //     throw new Exception("คำขอนี้ยังไม่ได้อยู่ในขั้นตอนที่สามารถอนุมัติได้ ไม่สามารถทำรายการได้");
+            // }
+
+            // check commander approve
+            var approvers = rawData.Approvers.Where(x => x.ApproveType!.ToUpper() == "APPROVER").OrderBy(x => x.Seq).ToList();
+
+            var approver = approvers.FirstOrDefault(x => x.KeycloakId == userId);
+            if (approver == null)
+            {
+                throw new Exception("คุณไม่มีสิทธิ์อนุมัติการลาออกในขั้นตอนนี้");
+            }
+
+            // check prev approver มี action แล้วหรือไม่?
+            var prevApprover = approvers.FirstOrDefault(x => x.Seq == approver.Seq - 1);
+
+            if (prevApprover != null)
+            {
+                if (prevApprover.ApproveStatus == "PENDING")
+                {
+                    throw new Exception("ไม่สามารถทำการอนุมัติได้ เนื่องจากยังอยู่ระหว่างการพิจารณาโดยผู้บังคับบัญชารายก่อนหน้า");
+                }
+            }
+
+
+            var maxSeq = approvers.Max(x => x.Seq);
+
+            approver.ApproveStatus = "REJECT";
+            approver.Comment = reason;
+            approver.RejectDate = date;
+
+            if (approver.Seq != maxSeq)
+            {
+                var nextApprover = approvers.FirstOrDefault(x => x.Seq == approver.Seq + 1);
+                // Send Noti
+                var noti1 = new Notification
+                {
+                    Body = $"การขอลาออกของคุณ {rawData.firstName} {rawData.lastName} รอรับการอนุมัติจากคุณ",
+                    ReceiverUserId = nextApprover!.ProfileId,
+                    Type = "",
+                    Payload = "",
+                };
+                _dbContext.Set<Notification>().Add(noti1);
+                await _dbContext.SaveChangesAsync();
+            }
+            else
+            {
+                rawData.Status = "REJECT";
+                // rawData.LeaveDirectorComment = reason;
+                if (rawData.Group != "1.1")
+                {
+                    rawData.ApproveStep = "st5";
+                }
+                else
+                {
+                    rawData.ApproveStep = "st4";
+                }
+
+                // Send Noti
+                var noti = new Notification
+                {
+                    Body = $"การขอลาออกของคุณไม่ได้รับการอนุมัติ \r\nเนื่องจาก{reason}",
+                    ReceiverUserId = Guid.Parse(rawData.profileId),
+                    Type = "",
+                    Payload = "",
+                };
+                _dbContext.Set<Notification>().Add(noti);
+                await _dbContext.SaveChangesAsync();
+            }
+        }
+
     }
 }