fix cronjob

BMA.EHR.Application/Repositories/Reports/InsigniaReportRepository.cs

@@ -1488,6 +1488,49 @@ namespace BMA.EHR.Application.Repositories.Reports
         }
 
         //คำนวนผู้ได้รับเครื่องราชฯ
+        public async Task CalInsigniaRequestBkkByType(string type = "officer")
+        {
+            var insigniaPeriods = await _dbContext.Set<InsigniaPeriod>()
+                                    .Include(x => x.InsigniaRequests)
+                                    .AsQueryable()
+                                    .ToListAsync();
+            insigniaPeriods = insigniaPeriods
+                .Where(x => x.StartDate < DateTime.Now.Date || x.InsigniaRequests.Count == 0).ToList();
+
+            foreach (var insigniaPeriod in insigniaPeriods)
+            {
+                if (insigniaPeriod.StartDate >= DateTime.Now.Date || insigniaPeriod.InsigniaRequests.Count > 0)
+                    continue;
+                var organizations = await _userProfileRepository.GetActiveRootLatestAsync(AccessToken);
+                if (organizations == null)
+                    continue;
+                insigniaPeriod.RevisionId = Guid.Parse(organizations[0].OrgRevisionId);
+                foreach (var organization in organizations)
+                {
+                    if (organization == null)
+                        continue;
+
+                    var result = await _repositoryInsignia.GetInsigniaRequestByTypeAsync(insigniaPeriod.Id, organization.Id, type);
+                    if (result != null)
+                    {
+                        Guid period = result.PeriodId;
+                        string requestStatus = result.RequestStatus;
+                        var candidate = await _repositoryInsignia.GetInsigniaCandidateBKKByTypeAsync(insigniaPeriod.Id, organization.Id, type);
+                        // ตรวจสอบว่ารายการอยู่ใน table insignia_request_new
+                        if (requestStatus == null)
+                        {
+                            // บันทึกรายชื่อ
+                            if (candidate != null)
+                                await _repositoryInsignia.InsertCandidate(period, organization.Id, organization.OrgRootName, candidate, type);
+                        }
+
+
+                    }
+                }
+            }
+        }
+
+
         public async Task CalInsignaiRequestBkk()
         {
             var insigniaPeriods = await _dbContext.Set<InsigniaPeriod>()
@@ -1528,6 +1571,8 @@ namespace BMA.EHR.Application.Repositories.Reports
                 }
             }
         }
+
+
         public async Task<dynamic> GetKhr5TotalReport(Guid id, string type = null, int node = -1, Guid nodeId = default)
         {
             var period = await _dbContext.Set<InsigniaNote>()

BMA.EHR.Insignia/Program.cs

@@ -180,7 +180,8 @@ var app = builder.Build();
     {
         manager.AddOrUpdate("แจ้งเตือนรอบเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.NotifyInsignia()), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
         manager.AddOrUpdate("ล็อกข้อมูลรอบเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.LockInsignia()), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
-        manager.AddOrUpdate("คำนวนผู้ได้รับเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.CalInsignaiRequestBkk()), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
+        manager.AddOrUpdate("คำนวนผู้ได้รับเครื่องราชฯ", Job.FromExpression<InsigniaReportRepository>(x => x.CalInsigniaRequestBkkByType("officer")), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
+        manager.AddOrUpdate("คำนวนผู้ได้รับเครื่องราชฯ Employee", Job.FromExpression<InsigniaReportRepository>(x => x.CalInsigniaRequestBkkByType("employee")), Cron.Daily(Int32.Parse(builder.Configuration["KeycloakCron:Hour"]), Int32.Parse(builder.Configuration["KeycloakCron:Minute"])), TimeZoneInfo.Local);
     }
 
     // apply migrations