BMA.EHR.CheckInConsumer/.dockerignore

@@ -1,24 +0,0 @@
-# Build artifacts
-bin/
-obj/
-
-# IDE / tooling
-Properties/
-.vs/
-.vscode/
-.idea/
-
-# Source control
-.git/
-.gitignore
-
-# Documentation
-*.md
-
-# Docker
-Dockerfile
-.dockerignore
-
-# OS files
-.DS_Store
-Thumbs.db

BMA.EHR.CheckInConsumer/CHANGELOG-checkin-speedup.md

@@ -1,83 +0,0 @@
-# สรุปการปรับปรุงระบบลงเวลา (CheckInConsumer)
-
-วันที่แก้ไข: 23 มิถุนายน 2026
-
----
-
-## ปัญหาเดิม
-
-ตอนที่พนักงานลงเวลาพร้อมกันจำนวนมาก (ประมาณ 2,000 รายการ) ระบบประมวลผลทีละรายการ ทำให้ต้องรอคิวนานถึง **22 นาที** กว่าจะประมวลผลเสร็จทั้งหมด
-
-เปรียบเทียบเหมือน **โต๊ะบัญชี 1 คน รับคิวทีละคน** ทั้งที่มีคนรอ 2,000 คน → คิวยาวมาก
-
----
-
-## วิธีที่แก้ (เข้าใจง่าย ๆ)
-
-### 1. เพิ่มคนช่วยประมวลผลพร้อมกัน (Concurrency)
-- **ก่อน:** ประมวลผลทีละรายการ (เหมือนมีโต๊ะบัญชี 1 โต๊ะ)
-- **หลัง:** ประมวลผลพร้อมกันได้สูงสุด **5 รายการ** (เหมือนเปิดโต๊ะบัญชี 5 โต๊ะ)
-
-> ผลที่ได้: เวลารอคิวลดลงจาก **22 นาที → ประมาณ 4–5 นาที**
-
-### 2. จัดคิวล่วงหน้าให้ RabbitMQ (Prefetch)
-- **ก่อน:** ระบบดึงข้อมูลมาทีละชิ้น ทำให้เสียเวลารอส่งต่อ
-- **หลัง:** ระบบดึงข้อมูลมาเป็นชุด ๆ ละ 20 ชิ้นไว้เตรียมพร้อม → ลดเวลารอระหว่างรายการ
-
-### 3. ลดเวลารอเมื่อ API มีปัญหา (Timeout)
-- **ก่อน:** ถ้า API ค้าง ระบบจะรอนานถึง **5 นาที** ต่อรายการ
-- **หลัง:** ลดเหลือ **1 นาที** → รายการที่มีปัญหาจะถูกปฏิเสธเร็วขึ้น ไม่ทำให้คิวค้าง
-
-### 4. ปรับปรุงการเชื่อมต่อ HTTP
-- เปลี่ยนระบบเชื่อมต่อให้รองรับการส่งคำขอหลายรายการพร้อมกันโดยไม่สะดุด
-
----
-
-## ตัวเลขเปรียบเทียบ
-
-| รายการ | ก่อนแก้ | หลังแก้ |
-|---|---|---|
-| จำนวนรายการที่ประมวลผลพร้อมกัน | 1 | 5 |
-| เวลารอคิวสูงสุด (2,000 รายการ) | ~22 นาที | ~4–5 นาที |
-| เวลารอเมื่อ API มีปัญหา | 5 นาที | 1 นาที |
-
----
-
-## ไฟล์ที่แก้ไข
-
-1. **`Program.cs`** — โค้ดหลักของตัวประมวลผลคิว
-2. **`appsettings.json`** — ไฟล์ตั้งค่าระบบ
-
----
-
-## วิธีปรับความเร็วเพิ่มเติม (ไม่ต้องเขียนโค้ดใหม่)
-
-ถ้าหลังทดสอบแล้วเห็นว่าระบบรับได้ และอยากให้เร็วขึ้นอีก ให้แก้ไขไฟล์ `appsettings.json` แล้ว restart โปรแกรมได้เลย:
-
-```json
-{
-  "MaxConcurrency": 10,       ← เพิ่มจาก 5 เป็น 10 (ประมวลผลพร้อมกัน 10 รายการ)
-  "PrefetchCount": 50,        ← ควรตั้งเป็น ประมาณ MaxConcurrency × 2 ขึ้นไป
-  "HttpTimeoutSeconds": 60    ← เวลารอ API วินาที
-}
-```
-
-**ค่าที่ใช้และผลที่คาดการณ์:**
-- `MaxConcurrency = 5` → ใช้เวลา ~4–5 นาที (ค่าเริ่มต้นปลอดภัย)
-- `MaxConcurrency = 10` → ใช้เวลา ~2–3 นาที
-- `MaxConcurrency = 20` → ใช้เวลา ~1–2 นาที (ต้องตรวจสอบว่าระบบหลังบ้านรับไหวก่อน)
-
----
-
-## ข้อควรระวัง / คำแนะนำ
-
-1. **ควรทดสอบในระบบทดสอบก่อน** โดยดูว่า
-   - ไม่มี error ในระบบหลัก (API)
-   - ฐานข้อมูลไม่ช้าผิดปกติ
-   - ไม่พบปัญหาลงเวลาซ้ำซ้อน
-
-2. ถ้าพบปัญหา เช่น
-   - มี error ใน API → **ลด** `MaxConcurrency` เหลือ 2 หรือ 3
-   - ลงเวลาซ้ำ → แจ้งทีมเทคนิคเพื่อแก้ฝั่ง API เพิ่มเติม
-
-3. **ค่า `MaxConcurrency = 5` เป็นค่าปลอดภัย** เพราะระบบ API ด้านหลังยังมีข้อจำกัดอยู่บางส่วน หากต้องการเพิ่มให้สูงกว่านี้ (เช่น 20–50) ควรปรึกษาทีมเทคนิคเพื่อปรับปรุงฝั่ง API ก่อน

BMA.EHR.CheckInConsumer/Dockerfile

@@ -1,4 +1,4 @@
-## See https://aka.ms/customizecontainer to learn how to customize your debug container and how Visual Studio uses this Dockerfile to build your images for faster debugging.
+## See https://aka.ms/customizecontainer to learn how to customize your debug container and how Visual Studio uses this Dockerfile to build your images for faster debugging.
 #
 ## This stage is used when running from VS in fast mode (Default for Debug configuration)
 #FROM mcr.microsoft.com/dotnet/runtime:8.0 AS base
@@ -21,7 +21,6 @@
 #ARG BUILD_CONFIGURATION=Release
 #RUN dotnet publish "BMA.EHR.CheckInConsumer.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
 #
-
 ## This stage is used in production or when running from VS in regular mode (Default when not using the Debug configuration)
 #FROM base AS final
 #WORKDIR /app
@@ -30,25 +29,30 @@
 
 
 # ใช้ official .NET SDK image สำหรับการ build
-# Note: Build context = repository root (ตามที่ GitHub Actions ใช้)
 FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
 
+# กำหนด working directory ภายใน container
 WORKDIR /src
 
-# copy เฉพาะ .csproj ก่อน เพื่อใช้ layer caching (restore เร็ว เก็บ cache นาน)
+# คัดลอกไฟล์ .csproj และ restore dependencies
-COPY BMA.EHR.CheckInConsumer/BMA.EHR.CheckInConsumer.csproj ./BMA.EHR.CheckInConsumer/
+# COPY *.csproj ./
-WORKDIR /src/BMA.EHR.CheckInConsumer
+COPY . ./
-RUN dotnet restore "BMA.EHR.CheckInConsumer.csproj"
+RUN dotnet restore
 
-# คัดลอก source ที่เหลือแล้ว publish
+# คัดลอกไฟล์ทั้งหมดและ build
-COPY BMA.EHR.CheckInConsumer/ ./
+COPY . ./
-RUN dotnet publish "BMA.EHR.CheckInConsumer.csproj" -c Release -o /app/publish /p:UseAppHost=false
+RUN dotnet build -c Release -o /app/build
+# WORKDIR "/src/BMA.EHR.CheckInConsumer"
+# RUN dotnet build "BMA.EHR.CheckInConsumer.csproj" -c Release -o /app/build
 
-# ใช้ stage ใหม่สำหรับ runtime (image เล็กลง)
+# ใช้ stage ใหม่สำหรับการ runtime
 FROM mcr.microsoft.com/dotnet/runtime:8.0 AS runtime
 
+# กำหนด working directory สำหรับ runtime
 WORKDIR /app
 
-COPY --from=build /app/publish .
+# คัดลอกไฟล์จาก build stage มายัง runtime stage
+COPY --from=build /app/build .
 
+# ระบุ entry point ของแอปพลิเคชัน
 ENTRYPOINT ["dotnet", "BMA.EHR.CheckInConsumer.dll"]

BMA.EHR.CheckInConsumer/Program.cs

@@ -18,13 +18,6 @@ var user = configuration["Rabbit:User"] ?? "";
 var pass = configuration["Rabbit:Password"] ?? "";
 var queue = configuration["Rabbit:Queue"] ?? "basic-queue";
 
-// Concurrency & prefetch (configurable via appsettings.json)
-var maxConcurrency = int.TryParse(configuration["MaxConcurrency"], out var c) && c > 0 ? c : 5;
-var prefetchCount = ushort.TryParse(configuration["PrefetchCount"], out var p) && p > 0 ? p : (ushort)20;
-var httpTimeoutSec = int.TryParse(configuration["HttpTimeoutSeconds"], out var t) && t > 0 ? t : 60;
-
-WriteToConsole($"Config -> MaxConcurrency: {maxConcurrency}, PrefetchCount: {prefetchCount}, HttpTimeout: {httpTimeoutSec}s");
-
 // create connection
 var factory = new ConnectionFactory()
 {
@@ -39,28 +32,13 @@ using var channel = connection.CreateModel();
 
 channel.QueueDeclare(queue: queue, durable: true, exclusive: false, autoDelete: false, arguments: null);
 
-// Prefetch: RabbitMQ จะส่ง message หลายตัวมาที่ consumer พร้อมกัน (ลด network round-trip)
+// Create a SINGLE static HttpClient instance to prevent socket exhaustion
-channel.BasicQos(prefetchSize: 0, prefetchCount: prefetchCount, global: false);
+using var httpClient = new HttpClient();
-
+httpClient.Timeout = TimeSpan.FromSeconds(300); // 5 นาที
-// HttpClient แบบ SocketsHttpHandler พร้อม connection pooling รองรับ concurrent requests
-var socketsHandler = new SocketsHttpHandler
-{
-    MaxConnectionsPerServer = maxConcurrency * 2,
-    PooledConnectionLifetime = TimeSpan.FromMinutes(2),
-    PooledConnectionIdleTimeout = TimeSpan.FromSeconds(30)
-};
-using var httpClient = new HttpClient(socketsHandler);
-httpClient.Timeout = TimeSpan.FromSeconds(httpTimeoutSec);
-
-// SemaphoreSlim คุมจำนวน message ที่ประมวลผลพร้อมกัน (เนื่องจาก API มีข้อจำกัดเรื่อง concurrency)
-using var semaphore = new SemaphoreSlim(maxConcurrency, maxConcurrency);
 
 var consumer = new AsyncEventingBasicConsumer(channel);
 
-consumer.Received += (model, ea) =>
+consumer.Received += async (model, ea) =>
-{
-    // รอ semaphore ก่อนเริ่มประมวลผล
-    semaphore.WaitAsync().ContinueWith(async _ =>
 {
     try
     {
@@ -87,13 +65,6 @@ consumer.Received += (model, ea) =>
         WriteToConsole($"Error processing message: {ex.Message}");
         channel.BasicNack(ea.DeliveryTag, multiple: false, requeue: false);
     }
-        finally
-        {
-            semaphore.Release();
-        }
-    }, TaskScheduler.Default).ConfigureAwait(false);
-
-    return Task.CompletedTask;
 };
 
 channel.BasicConsume(queue: queue, autoAck: false, consumer: consumer);

BMA.EHR.CheckInConsumer/appsettings.json

@@ -5,8 +5,5 @@
     "Password": "12345678",
     "Queue": "hrms-checkin-queue-dev"
   },
-  "API": "https://localhost:7283/api/v1",
+  "API": "https://localhost:7283/api/v1"
-  "MaxConcurrency": 5,
-  "PrefetchCount": 20,
-  "HttpTimeoutSeconds": 60
 }

BMA.EHR.Discipline.Service/Controllers/DisciplineResultController.cs

@@ -1028,6 +1028,10 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                         .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                         .ToListAsync();
 
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
+            data.ForEach(profile => { profile.Status = "REPORTED"; profile.CommandTypeId = null; });
+            await _context.SaveChangesAsync();
+
             var resultData = (from p in data
                               join r in req.refIds
                               on p.Id.ToString() equals r.refId
@@ -1063,66 +1067,23 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
-            #region Old: Circular Flow
+            var baseAPIOrg = _configuration["API"];
-            // var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            using (var client = new HttpClient())
-            // using (var client = new HttpClient())
+            {
-            // {
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-            //     client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-            //     client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-            //     var _res = await client.PostAsJsonAsync(apiUrlOrg, new
+                {
-            //     {
+                    data = resultData,
-            //         data = resultData,
+                });
-            //     });
+                var _result = await _res.Content.ReadAsStringAsync();
-            //     var _result = await _res.Content.ReadAsStringAsync();
+                if (_res.IsSuccessStatusCode)
-            //     if (_res.IsSuccessStatusCode)
+                {
-            //     {
                     //// คำสั่งไล่ออก หรือ ปลดออก Status หลังออกคำสั่งใช้ "REPORTED" เพื่อไม่ให้ส่งรายชื่อไปออกคำสั่งซ้ำได้
                     // data.ForEach(profile => { profile.Status = "REPORTED"; profile.CommandTypeId = null; });
-            //         var _profile = new List<ProfileComplaintInvestigate>();
-            //         DateTime _date = DateTime.Now;
-            //         foreach (var item in data)
-            //         {
-            //             _profile.Add(new ProfileComplaintInvestigate
-            //             {
-            //                 PersonId = item.PersonId,
-            //                 Prefix = item.Prefix,
-            //                 FirstName = item.FirstName,
-            //                 LastName = item.LastName,
-            //                 CitizenId = item.CitizenId,
-            //                 rootDnaId = item.rootDnaId,
-            //                 child1DnaId = item.child1DnaId,
-            //                 child2DnaId = item.child2DnaId,
-            //                 child3DnaId = item.child3DnaId,
-            //                 child4DnaId = item.child4DnaId,
-            //                 profileType = item.profileType,
-            //                 commandType = "C-PM-19",
-            //                 CreatedAt = _date,
-            //                 CreatedUserId = UserId,
-            //                 CreatedFullName = FullName,
-            //                 LastUpdatedAt = _date,
-            //                 LastUpdateUserId = UserId,
-            //                 LastUpdateFullName = FullName,
-            //             });
-            //         }
-            //         _context.ProfileComplaintInvestigate.AddRange(_profile);
-            //         await _context.SaveChangesAsync();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
-            {
-                profile.Status = "REPORTED";
-                profile.CommandTypeId = null;
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
-
                     var _profile = new List<ProfileComplaintInvestigate>();
+                    DateTime _date = DateTime.Now;
                     foreach (var item in data)
                     {
                         _profile.Add(new ProfileComplaintInvestigate
@@ -1139,19 +1100,19 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                             child4DnaId = item.child4DnaId,
                             profileType = item.profileType,
                             commandType = "C-PM-19",
-                    CreatedAt = now,
+                            CreatedAt = _date,
-                    CreatedUserId = UserId ?? "",
+                            CreatedUserId = UserId,
-                    CreatedFullName = FullName ?? "System Administrator",
+                            CreatedFullName = FullName,
-                    LastUpdatedAt = now,
+                            LastUpdatedAt = _date,
-                    LastUpdateUserId = UserId ?? "",
+                            LastUpdateUserId = UserId,
-                    LastUpdateFullName = FullName ?? "System Administrator",
+                            LastUpdateFullName = FullName,
                         });
                     }
                     _context.ProfileComplaintInvestigate.AddRange(_profile);
                     await _context.SaveChangesAsync();
-
+                }
-            // Return resultData for Node to process directly (Linear Flow)
+            }
-            return Success(resultData);
+            return Success();
         }
 
         /// <summary>
@@ -1223,6 +1184,10 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                         .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                         .ToListAsync();
 
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
+            data.ForEach(profile => { profile.Status = "REPORTED"; profile.CommandTypeId = null; });
+            await _context.SaveChangesAsync();
+
             var resultData = (from p in data
                               join r in req.refIds
                               on p.Id.ToString() equals r.refId
@@ -1258,66 +1223,23 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
-            #region Old: Circular Flow
+            var baseAPIOrg = _configuration["API"];
-            // var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            using (var client = new HttpClient())
-            // using (var client = new HttpClient())
+            {
-            // {
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-            //     client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-            //     client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-            //     var _res = await client.PostAsJsonAsync(apiUrlOrg, new
+                {
-            //     {
+                    data = resultData,
-            //         data = resultData,
+                });
-            //     });
+                var _result = await _res.Content.ReadAsStringAsync();
-            //     var _result = await _res.Content.ReadAsStringAsync();
+                if (_res.IsSuccessStatusCode)
-            //     if (_res.IsSuccessStatusCode)
+                {
-            //     {
                     //// คำสั่งไล่ออก หรือ ปลดออก Status หลังออกคำสั่งใช้ "REPORTED" เพื่อไม่ให้ส่งรายชื่อไปออกคำสั่งซ้ำได้
                     // data.ForEach(profile => { profile.Status = "REPORTED"; profile.CommandTypeId = null; });
-            //         var _profile = new List<ProfileComplaintInvestigate>();
-            //         DateTime _date = DateTime.Now;
-            //         foreach (var item in data)
-            //         {
-            //             _profile.Add(new ProfileComplaintInvestigate
-            //             {
-            //                 PersonId = item.PersonId,
-            //                 Prefix = item.Prefix,
-            //                 FirstName = item.FirstName,
-            //                 LastName = item.LastName,
-            //                 CitizenId = item.CitizenId,
-            //                 rootDnaId = item.rootDnaId,
-            //                 child1DnaId = item.child1DnaId,
-            //                 child2DnaId = item.child2DnaId,
-            //                 child3DnaId = item.child3DnaId,
-            //                 child4DnaId = item.child4DnaId,
-            //                 profileType = item.profileType,
-            //                 commandType = "C-PM-20",
-            //                 CreatedAt = _date,
-            //                 CreatedUserId = UserId,
-            //                 CreatedFullName = FullName,
-            //                 LastUpdatedAt = _date,
-            //                 LastUpdateUserId = UserId,
-            //                 LastUpdateFullName = FullName,
-            //             });
-            //         }
-            //         _context.ProfileComplaintInvestigate.AddRange(_profile);
-            //         await _context.SaveChangesAsync();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
-            {
-                profile.Status = "REPORTED";
-                profile.CommandTypeId = null;
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
-
                     var _profile = new List<ProfileComplaintInvestigate>();
+                    DateTime _date = DateTime.Now;
                     foreach (var item in data)
                     {
                         _profile.Add(new ProfileComplaintInvestigate
@@ -1334,19 +1256,19 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                             child4DnaId = item.child4DnaId,
                             profileType = item.profileType,
                             commandType = "C-PM-20",
-                    CreatedAt = now,
+                            CreatedAt = _date,
-                    CreatedUserId = UserId ?? "",
+                            CreatedUserId = UserId,
-                    CreatedFullName = FullName ?? "System Administrator",
+                            CreatedFullName = FullName,
-                    LastUpdatedAt = now,
+                            LastUpdatedAt = _date,
-                    LastUpdateUserId = UserId ?? "",
+                            LastUpdateUserId = UserId,
-                    LastUpdateFullName = FullName ?? "System Administrator",
+                            LastUpdateFullName = FullName,
                         });
                     }
                     _context.ProfileComplaintInvestigate.AddRange(_profile);
                     await _context.SaveChangesAsync();
-
+                }
-            // Return resultData for Node to process directly (Linear Flow)
+            }
-            return Success(resultData);
+            return Success();
         }
 
         /// <summary>
@@ -1496,6 +1418,10 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                             .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                                             .ToListAsync();
 
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
+            data.ForEach(profile => profile.Status = "DONE");
+            await _context.SaveChangesAsync();
+
             var resultData = (from p in data
                               join r in req.refIds
                               on p.Id.ToString() equals r.refId
@@ -1531,39 +1457,24 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
-            #region Old: Circular Flow
+            var baseAPIOrg = _configuration["API"];
-            // var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            using (var client = new HttpClient())
-            // 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();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
             {
-                profile.Status = "DONE";
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-                profile.LastUpdateUserId = UserId ?? "";
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-                profile.LastUpdatedAt = now;
+                {
+                    data = resultData,
                 });
-            await _context.SaveChangesAsync();
+                //// var _result = await _res.Content.ReadAsStringAsync();
-
+                //// if (_res.IsSuccessStatusCode)
-            // Return resultData for Node to process directly (Linear Flow)
+                //// {
-            return Success(resultData);
+                ////     data.ForEach(profile => profile.Status = "DONE");
+                ////     await _context.SaveChangesAsync();
+                //// }
+            }
+            return Success();
         }
 
         /// <summary>
@@ -1651,6 +1562,10 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                         .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                         .ToListAsync();
 
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
+            data.ForEach(profile => profile.Status = "DONE");
+            await _context.SaveChangesAsync();
+
             var resultData = (from p in data
                               join r in req.refIds
                               on p.Id.ToString() equals r.refId
@@ -1686,39 +1601,24 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
-            #region Old: Circular Flow
+            var baseAPIOrg = _configuration["API"];
-            // var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            using (var client = new HttpClient())
-            // 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();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
             {
-                profile.Status = "DONE";
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-                profile.LastUpdateUserId = UserId ?? "";
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-                profile.LastUpdatedAt = now;
+                {
+                    data = resultData,
                 });
-            await _context.SaveChangesAsync();
+                //// var _result = await _res.Content.ReadAsStringAsync();
-
+                //// if (_res.IsSuccessStatusCode)
-            // Return resultData for Node to process directly (Linear Flow)
+                //// {
-            return Success(resultData);
+                ////     data.ForEach(profile => profile.Status = "DONE");
+                ////     await _context.SaveChangesAsync();
+                //// }
+            }
+            return Success();
         }
 
         /// <summary>
@@ -1804,6 +1704,10 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                         .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                         .ToListAsync();
 
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
+            data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+            await _context.SaveChangesAsync();
+
             string? _null = null;
             var resultData = (from p in data
                               join r in req.refIds
@@ -1839,40 +1743,24 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
-            #region Old: Circular Flow
+            var baseAPIOrg = _configuration["API"];
-            // var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            using (var client = new HttpClient())
-            // 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 = "NEW"; profile.CommandTypeId = null; });
-            //         await _context.SaveChangesAsync();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
             {
-                profile.Status = "NEW";
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-                profile.CommandTypeId = null;
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-                profile.LastUpdateUserId = UserId ?? "";
+                {
-                profile.LastUpdatedAt = now;
+                    data = resultData,
                 });
-            await _context.SaveChangesAsync();
+                //// var _result = await _res.Content.ReadAsStringAsync();
-
+                //// if (_res.IsSuccessStatusCode)
-            // Return resultData for Node to process directly (Linear Flow)
+                //// {
-            return Success(resultData);
+                ////     data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+                ////     await _context.SaveChangesAsync();
+                //// }
+            }
+            return Success();
         }
 
         /// <summary>
@@ -1958,6 +1846,10 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                         .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                         .ToListAsync();
 
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
+            data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+            await _context.SaveChangesAsync();
+
             string? _null = null;
             var resultData = (from p in data
                               join r in req.refIds
@@ -1993,40 +1885,24 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
-            #region Old: Circular Flow
+            var baseAPIOrg = _configuration["API"];
-            // var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            using (var client = new HttpClient())
-            // 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 = "NEW"; profile.CommandTypeId = null; });
-            //         await _context.SaveChangesAsync();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
             {
-                profile.Status = "NEW";
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-                profile.CommandTypeId = null;
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-                profile.LastUpdateUserId = UserId ?? "";
+                {
-                profile.LastUpdatedAt = now;
+                    data = resultData,
                 });
-            await _context.SaveChangesAsync();
+                //// var _result = await _res.Content.ReadAsStringAsync();
-
+                //// if (_res.IsSuccessStatusCode)
-            // Return resultData for Node to process directly (Linear Flow)
+                //// {
-            return Success(resultData);
+                ////     data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+                ////     await _context.SaveChangesAsync();
+                //// }
+            }
+            return Success();
         }
 
         /// <summary>
@@ -2112,6 +1988,10 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                         .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                         .ToListAsync();
 
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
+            data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+            await _context.SaveChangesAsync();
+
             string? _null = null;
             var resultData = (from p in data
                               join r in req.refIds
@@ -2147,40 +2027,24 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
-            #region Old: Circular Flow
+            var baseAPIOrg = _configuration["API"];
-            // var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            using (var client = new HttpClient())
-            // 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 = "NEW"; profile.CommandTypeId = null; });
-            //         await _context.SaveChangesAsync();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
             {
-                profile.Status = "NEW";
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-                profile.CommandTypeId = null;
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-                profile.LastUpdateUserId = UserId ?? "";
+                {
-                profile.LastUpdatedAt = now;
+                    data = resultData,
                 });
-            await _context.SaveChangesAsync();
+                //// var _result = await _res.Content.ReadAsStringAsync();
-
+                //// if (_res.IsSuccessStatusCode)
-            // Return resultData for Node to process directly (Linear Flow)
+                //// {
-            return Success(resultData);
+                ////     data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+                ////     await _context.SaveChangesAsync();
+                //// }
+            }
+            return Success();
         }
 
         /// <summary>
@@ -2266,6 +2130,10 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                             .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                                             .ToListAsync();
 
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
+            data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+            await _context.SaveChangesAsync();
+
             string? _null = null;
             var resultData = (from p in data
                               join r in req.refIds
@@ -2301,40 +2169,24 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
-            #region Old: Circular Flow
+            var baseAPIOrg = _configuration["API"];
-            // var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            using (var client = new HttpClient())
-            // 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 = "NEW"; profile.CommandTypeId = null; });
-            //         await _context.SaveChangesAsync();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
             {
-                profile.Status = "NEW";
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-                profile.CommandTypeId = null;
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-                profile.LastUpdateUserId = UserId ?? "";
+                {
-                profile.LastUpdatedAt = now;
+                    data = resultData,
                 });
-            await _context.SaveChangesAsync();
+                //// var _result = await _res.Content.ReadAsStringAsync();
-
+                //// if (_res.IsSuccessStatusCode)
-            // Return resultData for Node to process directly (Linear Flow)
+                //// {
-            return Success(resultData);
+                ////     data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+                ////     await _context.SaveChangesAsync();
+                //// }
+            }
+            return Success();
         }
 
         /// <summary>
@@ -2420,6 +2272,10 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                             .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                                             .ToListAsync();
 
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
+            data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+            await _context.SaveChangesAsync();
+
             string? _null = null;
             var resultData = (from p in data
                               join r in req.refIds
@@ -2455,40 +2311,24 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
-            #region Old: Circular Flow
+            var baseAPIOrg = _configuration["API"];
-            // var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            using (var client = new HttpClient())
-            // 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 = "NEW"; profile.CommandTypeId = null; });
-            //         await _context.SaveChangesAsync();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
             {
-                profile.Status = "NEW";
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-                profile.CommandTypeId = null;
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-                profile.LastUpdateUserId = UserId ?? "";
+                {
-                profile.LastUpdatedAt = now;
+                    data = resultData,
                 });
-            await _context.SaveChangesAsync();
+                //// var _result = await _res.Content.ReadAsStringAsync();
-
+                //// if (_res.IsSuccessStatusCode)
-            // Return resultData for Node to process directly (Linear Flow)
+                //// {
-            return Success(resultData);
+                ////     data.ForEach(profile => { profile.Status = "NEW"; profile.CommandTypeId = null; });
+                ////     await _context.SaveChangesAsync();
+                //// }
+            }
+            return Success();
         }
 
         /// <summary>
@@ -2584,21 +2424,15 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
         [HttpPost("command32/report/excecute")]
         public async Task<ActionResult<ResponseObject>> PostReportCommand32Execute([FromBody] ReportExecuteRequest req)
         {
-            // C-PM-32 (คำสั่งยุติเรื่อง) ต้องยุติงานใน 2 track ที่เก็บอยู่คนละตาราง:
-            //   - data  / resultData  = ฝั่ง "การสอบสวน"         (DisciplineInvestigate_ProfileComplaint)
-            //   - data1 / resultData1 = ฝั่ง "การพิจารณาลงโทษ"  (DisciplineDisciplinary_ProfileComplaintInvestigate)
-            // บุคคลเดียวกัน (profileId เดียวกัน) อาจอยู่ในทั้ง 2 track จึงต้องส่งให้ org แยก 2 ครั้ง (ห้าม merge รวมครั้งเดียว)
             var data = await _context.DisciplineInvestigate_ProfileComplaints
                                             .Include(x => x.DisciplineInvestigate)
                                             // .Where(x => x.IsReport == "REPORT")
                                             .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
                                             .ToListAsync();
 
-            var data1 = await _context.DisciplineDisciplinary_ProfileComplaintInvestigates
+            // Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-                                        .Include(x => x.DisciplineDisciplinary)
+            data.ForEach(profile => profile.IsReport = "DONE");
-                                        // .Where(x => x.IsReport == "REPORT")
+            await _context.SaveChangesAsync();
-                                        .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
-                                        .ToListAsync();
 
             string? _null = null;
             var resultData = (from p in data
@@ -2635,6 +2469,29 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                   posNoAbb = 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 : "")))),
                               }).ToList();
 
+            var baseAPIOrg = _configuration["API"];
+            var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
+            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.IsReport = "DONE");
+                ////     await _context.SaveChangesAsync();
+                //// }
+            }
+
+            var data1 = await _context.DisciplineDisciplinary_ProfileComplaintInvestigates
+                                        .Include(x => x.DisciplineDisciplinary)
+                                        // .Where(x => x.IsReport == "REPORT")
+                                        .Where(x => req.refIds.Select(x => x.refId).Contains(x.Id.ToString()))
+                                        .ToListAsync();
             var resultData1 = (from p in data1
                                join r in req.refIds
                                on p.Id.ToString() equals r.refId
@@ -2668,69 +2525,23 @@ namespace BMA.EHR.DisciplineResult.Service.Controllers
                                    posNo = p.posMasterNo != null ? p.posMasterNo.ToString() : null,
                                    posNoAbb = 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 : "")))),
                                }).ToList();
-
+            using (var client = new HttpClient())
-            #region Old: Circular Flow
-            // var baseAPIOrg = _configuration["API"];
-            // var apiUrlOrg = $"{baseAPIOrg}/org/command/excexute/salary-leave-discipline";
-            // 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.IsReport = "DONE");
-            //         await _context.SaveChangesAsync();
-            //     }
-            // }
-            // 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 = resultData1,
-            //     });
-            //     var _result = await _res.Content.ReadAsStringAsync();
-            //     if (_res.IsSuccessStatusCode)
-            //     {
-            //         data1.ForEach(profile => profile.IsReport = "DONE");
-            //         await _context.SaveChangesAsync();
-            //     }
-            // }
-            #endregion
-
-            // New: Linear Flow
-            var now = DateTime.Now;
-            data.ForEach(profile =>
             {
-                profile.IsReport = "DONE";
+                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token.Replace("Bearer ", ""));
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
+                client.DefaultRequestHeaders.Add("api-key", _configuration["API_KEY"]);
-                profile.LastUpdateUserId = UserId ?? "";
+                var _res = await client.PostAsJsonAsync(apiUrlOrg, new
-                profile.LastUpdatedAt = now;
-            });
-            data1.ForEach(profile =>
                 {
-                profile.IsReport = "DONE";
+                    data = resultData1,
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
                 });
+                var _result = await _res.Content.ReadAsStringAsync();
+                if (_res.IsSuccessStatusCode)
+                {
+                    data1.ForEach(profile => profile.IsReport = "DONE");
                     await _context.SaveChangesAsync();
+                }
+            }
 
-            // Return resultData for Node to process directly (Linear Flow)
+            return Success();
-            //
-            // NOTE สำหรับฝั่ง Node (C-PM-32 เท่านั้น):
-            //   - response.result เป็น object { data, data1 } (ไม่ใช่ array เหมือนคำสั่งอื่น)
-            //       data  = รายการฝั่ง "การสอบสวน"         → ยิง POST {API}/org/command/excexute/salary-leave-discipline ครั้งที่ 1
-            //       data1 = รายการฝั่ง "การพิจารณาลงโทษ"  → ยิง POST {API}/org/command/excexute/salary-leave-discipline ครั้งที่ 2
-            //   - ต้องยิง 2 ครั้งตามลำดับ data ก่อน → data1 (ห้าม merge รวมในครั้งเดียว เพราะ profileId อาจซ้ำข้าม 2 track)
-            //   - คำสั่งอื่น (C-PM-19/20/25/26/27/28/29/30/31) response.result เป็น array → ยิง org 1 ครั้ง
-            return Success(new { data = resultData, data1 = resultData1 });
         }
 
         /// <summary>

BMA.EHR.Leave/Controllers/LeaveController.cs

@@ -3818,148 +3818,6 @@ namespace BMA.EHR.Leave.Service.Controllers
             return Success();
         }
 
-
-        [HttpPut("admin/edit/approve-list")]
-        [ProducesResponseType(StatusCodes.Status200OK)]
-        [ProducesResponseType(StatusCodes.Status401Unauthorized)]
-        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
-        public async Task<ActionResult<ResponseObject>> ApproveRequestListAsync([FromBody] List<ApproveRequestListItemDto> reqs)
-        {
-            var getPermission = await _permission.GetPermissionAPIAsync("UPDATE", "SYS_CHECKIN_SPECIAL");
-            var jsonData = JsonConvert.DeserializeObject<JObject>(getPermission);
-            if (jsonData["status"]?.ToString() != "200")
-            {
-                return Error(jsonData["message"]?.ToString(), StatusCodes.Status403Forbidden);
-            }
-
-            foreach (var req in reqs)
-            {
-                if (req.Reason == null || req.Reason == string.Empty)
-                {
-                    return Error("กรุณากรอกเหตุผล", StatusCodes.Status400BadRequest);
-                }
-
-                var requestData = await _additionalCheckRequestRepository.GetByIdAsync(req.RecId);
-                if (requestData == null)
-                {
-                    return Error(GlobalMessages.DataNotFound, StatusCodes.Status404NotFound);
-                }
-
-                requestData.Status = "APPROVE";
-                requestData.Comment = req.Reason;
-                await _additionalCheckRequestRepository.UpdateAsync(requestData);
-
-                // change user timestamp
-                var processTimeStamp = await _processUserTimeStampRepository.GetTimestampByDateAsync(requestData.KeycloakUserId, requestData.CheckDate.Date);
-
-                var profile = await _userProfileRepository.GetProfileByKeycloakIdNew2Async(requestData.KeycloakUserId, AccessToken);
-
-                if (processTimeStamp == null)
-                {
-                    processTimeStamp = new ProcessUserTimeStamp
-                    {
-                        KeycloakUserId = requestData.KeycloakUserId,
-                        CheckIn = DateTime.Parse($"{requestData.CheckDate.Date.ToString("yyyy-MM-dd")} {req.CheckInTime}"),
-                        CheckOut = DateTime.Parse($"{requestData.CheckDate.Date.ToString("yyyy-MM-dd")} {req.CheckOutTime}"),
-                        CheckInRemark = req.Reason,
-                        CheckOutRemark = req.Reason,
-
-                        CheckInLat = 0,
-                        CheckInLon = 0,
-                        CheckOutLat = 0,
-                        CheckOutLon = 0,
-                        CheckInPOI = "",
-                        CheckOutPOI = "",
-                        CheckInStatus = req.CheckInStatus,
-                        CheckOutStatus = req.CheckOutStatus,
-
-                        Prefix = profile.Prefix,
-                        FirstName = profile.FirstName,
-                        LastName = profile.LastName,
-
-                        // Add ข้อมูลจาก profile
-                        CitizenId = profile.CitizenId,
-                        ProfileType = profile.ProfileType,
-                        Root = profile.Root,
-                        RootId = profile.RootId,
-                        Child1 = profile.Child1,
-                        Child1Id = profile.Child1Id,
-                        Child2 = profile.Child2,
-                        Child2Id = profile.Child2Id,
-                        Child3 = profile.Child3,
-                        Child3Id = profile.Child3Id,
-                        Child4 = profile.Child4,
-                        Child4Id = profile.Child4Id,
-                        Gender = profile.Gender,
-                        ProfileId = profile.Id,
-
-
-                    };
-
-                    processTimeStamp.EditStatus = "APPROVE";
-                    processTimeStamp.EditReason = req.Reason;
-
-                    if (requestData.CheckInEdit)
-                    {
-                        processTimeStamp.CheckInPOI = requestData.POI ?? "";
-                        processTimeStamp.CheckInLat = requestData.Latitude ?? 0;
-                        processTimeStamp.CheckInLon = requestData.Longitude ?? 0;
-                    }
-
-                    if (requestData.CheckOutEdit)
-                    {
-                        processTimeStamp.CheckOutPOI = requestData.POI ?? "";
-                        processTimeStamp.CheckOutLat = requestData.Latitude ?? 0;
-                        processTimeStamp.CheckOutLon = requestData.Longitude ?? 0;
-                    }
-
-                    await _processUserTimeStampRepository.AddAsync(processTimeStamp);
-                }
-                else
-                {
-                    if (requestData.CheckInEdit)
-                    {
-                        processTimeStamp.CheckIn = DateTime.Parse($"{requestData.CheckDate.Date.ToString("yyyy-MM-dd")} {req.CheckInTime}");
-                        processTimeStamp.CheckInRemark = req.Reason;
-                        //processTimeStamp.CheckInLat = 0;
-                        //processTimeStamp.CheckInLon = 0;
-                        //processTimeStamp.CheckInPOI = "ลงเวลากรณีพิเศษ";
-                        processTimeStamp.CheckInStatus = req.CheckInStatus;
-
-                        processTimeStamp.CheckInPOI = requestData.POI ?? "";
-                        processTimeStamp.CheckInLat = requestData.Latitude ?? 0;
-                        processTimeStamp.CheckInLon = requestData.Longitude ?? 0;
-                    }
-
-                    if (requestData.CheckOutEdit)
-                    {
-                        processTimeStamp.CheckOut = DateTime.Parse($"{requestData.CheckDate.Date.ToString("yyyy-MM-dd")} {req.CheckOutTime}");
-                        processTimeStamp.CheckOutRemark = req.Reason;
-                        //processTimeStamp.CheckOutLat = 0;
-                        //processTimeStamp.CheckOutLon = 0;
-                        //processTimeStamp.CheckOutPOI = "ลงเวลากรณีพิเศษ";
-                        processTimeStamp.CheckOutStatus = req.CheckOutStatus;
-
-                        processTimeStamp.CheckOutPOI = requestData.POI ?? "";
-                        processTimeStamp.CheckOutLat = requestData.Latitude ?? 0;
-                        processTimeStamp.CheckOutLon = requestData.Longitude ?? 0;
-                    }
-
-
-                    processTimeStamp.EditStatus = "APPROVE";
-                    processTimeStamp.EditReason = req.Reason;
-
-                    await _processUserTimeStampRepository.UpdateAsync(processTimeStamp);
-                }
-
-                var recvId = new List<Guid> { profile.Id };
-                await _notificationRepository.PushNotificationsAsync(recvId.ToArray(), "ลงเวลากรณีพิเศษ",
-                    "การขอลงเวลากรณีพิเศษของคุณได้รับการอนุมัติ", "", "", true, false);
-            }
-            return Success();
-        }
-        
-        
         /// <summary>
         /// LV1_020 - ไม่อนุมัติลงเวลากรณีพิเศษ (ADMIN) 
         /// </summary>

BMA.EHR.Leave/Controllers/LeaveReportController.cs

@@ -169,7 +169,7 @@ namespace BMA.EHR.Leave.Service.Controllers
             if (toDay >= new DateTime(toDay.Year, 10, 1) && toDay <= new DateTime(toDay.Year, 12, 31))
                 thisYear = thisYear + 1;
             var leaveData = await _leaveBeginningRepository.GetByYearAndTypeIdForUser2Async(thisYear, data.Type.Id, data.KeycloakUserId);
-            var sumLeave = await _leaveRequestRepository.GetSumApproveLeaveTotalByTypeAndRangeForUserBefore(data.KeycloakUserId, data.Type.Id, fiscalStart, fiscalEnd, sendLeaveDate);
+            var sumLeave = await _leaveRequestRepository.GetSumApproveLeaveTotalByTypeAndRangeForUserBefore(data.KeycloakUserId, data.Type.Id, fiscalStart, endFiscalYear, sendLeaveDate);
             if (leaveData != null)
             {
                 sumLeave += leaveData.BeginningLeaveDays;
@@ -358,7 +358,7 @@ namespace BMA.EHR.Leave.Service.Controllers
 
             var sendLeaveDate = data.DateSendLeave ?? data.CreatedAt;
             
-            var sumLeave = await _leaveRequestRepository.GetSumApproveLeaveTotalByTypeAndRangeForUserBefore(data.KeycloakUserId, data.Type.Id, fiscalStart, fiscalEnd, sendLeaveDate);
+            var sumLeave = await _leaveRequestRepository.GetSumApproveLeaveTotalByTypeAndRangeForUserBefore(data.KeycloakUserId, data.Type.Id, fiscalStart, endFiscalYear, sendLeaveDate);
             if (leaveData != null)
             {
                 sumLeave += leaveData.BeginningLeaveDays;

BMA.EHR.Leave/Controllers/LeaveRequestController.cs

@@ -2925,8 +2925,8 @@ namespace BMA.EHR.Leave.Service.Controllers
             var leaveSummary = await _leaveRequestRepository.GetSumApproveLeaveTotalByTypeAndRangeForUser2(rawData.KeycloakUserId, rawData.Type.Id, fiscalStart, fiscalEnd, sendLeaveDate);
             
             // วันลาแบบร่างและที่ยื่นลาไปแล้ว
-            var leaveDraftSummary = await _leaveRequestRepository.GetSumDraftLeaveTotalByTypeAndRangeForUser2(rawData.KeycloakUserId, rawData.Type.Id, fiscalStart, fiscalEnd, fiscalEnd.AddDays(1));
+            var leaveDraftSummary = await _leaveRequestRepository.GetSumDraftLeaveTotalByTypeAndRangeForUser2(rawData.KeycloakUserId, rawData.Type.Id, fiscalStart, fiscalEnd, sendLeaveDate);
-            var leaveWaitingSummary = await _leaveRequestRepository.GetSumNewLeaveTotalByTypeAndRangeForUser2(rawData.KeycloakUserId, rawData.Type.Id, fiscalStart, fiscalEnd, fiscalEnd.AddDays(1));
+            var leaveWaitingSummary = await _leaveRequestRepository.GetSumNewLeaveTotalByTypeAndRangeForUser2(rawData.KeycloakUserId, rawData.Type.Id, fiscalStart, fiscalEnd, sendLeaveDate);
             
             //var leaveSummary = leaveData == null ? 0.0 : leaveData.LeaveDaysUsed;
             if (leaveData != null)

BMA.EHR.Leave/DTOs/AdditionalCheck/ApproveRequestDto.cs

@@ -12,21 +12,4 @@
 
         public string Reason { get; set; }
     }
-    
-    public class ApproveRequestListItemDto
-    {
-        /// <summary>
-        /// id ของ record รายการคำขอลงเวลาพิเศษนั้นๆ
-        /// </summary>
-        public Guid RecId { get; set; }
-        public string CheckInTime { get; set; }
-
-        public string CheckOutTime { get; set; }
-
-        public string CheckInStatus { get; set; }
-
-        public string CheckOutStatus { get; set; }
-
-        public string Reason { get; set; }
-    }
 }

BMA.EHR.Placement.Service/Controllers/PlacementAppointmentController.cs

@@ -1062,14 +1062,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -1293,14 +1286,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -1508,14 +1494,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -1728,14 +1707,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -1971,14 +1943,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -2074,7 +2039,7 @@ namespace BMA.EHR.Placement.Service.Controllers
         }
 
         /// <summary>
-        /// ออกคำสั่ง C-PM-47 โปรดเกล้าฯ แต่งตั้งให้ดำรงตำแหน่ง
+        /// ออกคำสั่ง C-PM-47 
         /// </summary>
         /// <returns></returns>
         /// <response code="200"></response>
@@ -2149,14 +2114,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)

BMA.EHR.Placement.Service/Controllers/PlacementController.cs

@@ -2032,13 +2032,9 @@ namespace BMA.EHR.Placement.Service.Controllers
                 #endregion
                 
                 // New: Linear Flow
-                var now = DateTime.Now;
                 placementProfile.ForEach(profile =>
                 {
                     profile.PlacementStatus = "DONE";
-                    profile.LastUpdateFullName = FullName ?? "System Administrator";
-                    profile.LastUpdateUserId = UserId ?? "";
-                    profile.LastUpdatedAt = now;
                     if (req.refIds.Length > 0)
                     {
                         profile.commandId = req.refIds[0].commandId;
@@ -2442,13 +2438,9 @@ namespace BMA.EHR.Placement.Service.Controllers
                 #endregion
 
                 // New: Linear Flow
-                var now = DateTime.Now;
                 placementProfile.ForEach(profile =>
                 {
                     profile.PlacementStatus = "DONE";
-                    profile.LastUpdateFullName = FullName ?? "System Administrator";
-                    profile.LastUpdateUserId = UserId ?? "";
-                    profile.LastUpdatedAt = now;
                     if (req.refIds.Length > 0)
                     {
                         profile.commandId = req.refIds[0].commandId;
@@ -2718,14 +2710,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.PlacementStatus = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.PlacementStatus = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -2975,14 +2960,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.PlacementStatus = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.PlacementStatus = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -3215,14 +3193,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.PlacementStatus = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.PlacementStatus = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)

BMA.EHR.Placement.Service/Controllers/PlacementOfficerController.cs

@@ -828,14 +828,10 @@ namespace BMA.EHR.Placement.Service.Controllers
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
             var firstRef = req.refIds.FirstOrDefault();
             var commandNoText = firstRef != null ? $"{firstRef.commandNo}/{firstRef.commandYear.ToThaiYear()}" : null;
-            var now = DateTime.Now;
             data.ForEach(profile =>
             {
                 profile.Status = "DONE";
                 profile.commandNo = commandNoText;
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
             });
             await _context.SaveChangesAsync();
 

BMA.EHR.Placement.Service/Controllers/PlacementReceiveController.cs

@@ -1306,14 +1306,7 @@ namespace BMA.EHR.Placement.Service.Controllers
                 #endregion
 
                 // New: Linear Flow
-                var now = DateTime.Now;
+                data.ForEach(profile => profile.Status = "DONE");
-                data.ForEach(profile =>
-                {
-                    profile.Status = "DONE";
-                    profile.LastUpdateFullName = FullName ?? "System Administrator";
-                    profile.LastUpdateUserId = UserId ?? "";
-                    profile.LastUpdatedAt = now;
-                });
                 Console.WriteLine($"[ReceiveReportExcecute] Saving changes to database for {data.Count} profiles");
                 await _context.SaveChangesAsync();
                 Console.WriteLine($"[ReceiveReportExcecute] Process completed successfully at {DateTime.Now}");

BMA.EHR.Placement.Service/Controllers/PlacementRepatriationController.cs

@@ -686,14 +686,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)

BMA.EHR.Placement.Service/Controllers/PlacementTransferController.cs

@@ -1212,14 +1212,7 @@ namespace BMA.EHR.Placement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
 
             // Return resultData for Node to process directly (Linear Flow)
             return Success(resultData);

BMA.EHR.Retirement.Service/Controllers/RetirementOtherController.cs

@@ -926,14 +926,7 @@ namespace BMA.EHR.Retirement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -1190,14 +1183,7 @@ namespace BMA.EHR.Retirement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)

BMA.EHR.Retirement.Service/Controllers/RetirementOutController.cs

@@ -629,7 +629,7 @@ namespace BMA.EHR.Retirement.Service.Controllers
         }
 
         /// <summary>
-        /// ออกคำสั่ง C-PM-18 ให้ออกจากราชการ && C-PM-43 ให้ลูกจ้างออกจากราชการ
+        /// ออกคำสั่ง C-PM-18 คำสั่งให้ออกจากราชการ
         /// </summary>
         /// <returns></returns>
         /// <response code="200"></response>
@@ -712,14 +712,7 @@ namespace BMA.EHR.Retirement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)

BMA.EHR.Retirement.Service/Controllers/RetirementResignController.cs

@@ -2972,14 +2972,7 @@ namespace BMA.EHR.Retirement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -3171,14 +3164,7 @@ namespace BMA.EHR.Retirement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -3413,14 +3399,7 @@ namespace BMA.EHR.Retirement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             data.ForEach(profile => profile.RetirementResign.Status = "CANCEL");
             await _context.SaveChangesAsync();
 

BMA.EHR.Retirement.Service/Controllers/RetirementResignEmployeeController.cs

@@ -2468,14 +2468,7 @@ namespace BMA.EHR.Retirement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             await _context.SaveChangesAsync();
 
             // Return resultData for Node to process directly (Linear Flow)
@@ -2707,14 +2700,7 @@ namespace BMA.EHR.Retirement.Service.Controllers
             #endregion
 
             // New: Linear Flow - Task #224 ปรับให้เป็น process ที่ควรบันทึกตามลำดับ
-            var now = DateTime.Now;
+            data.ForEach(profile => profile.Status = "DONE");
-            data.ForEach(profile =>
-            {
-                profile.Status = "DONE";
-                profile.LastUpdateFullName = FullName ?? "System Administrator";
-                profile.LastUpdateUserId = UserId ?? "";
-                profile.LastUpdatedAt = now;
-            });
             data.ForEach(profile => profile.RetirementResignEmployee.Status = "CANCEL");
             await _context.SaveChangesAsync();