diff --git a/Services/ImportBackgroundService.cs b/Services/ImportBackgroundService.cs index cf33fd5..0d3de83 100644 --- a/Services/ImportBackgroundService.cs +++ b/Services/ImportBackgroundService.cs @@ -72,6 +72,7 @@ public class ImportBackgroundService : BackgroundService _tracker.UpdateStatus(job.JobId, ImportJobStatus.Completed, job.TotalCount); await notificationService.SendImportNotificationAsync(job.Token, false, "ระบบนำเข้าข้อมูลสำเร็จ"); + job.Token = null; // Clear token after notification sent } catch (Exception ex) { @@ -79,6 +80,7 @@ public class ImportBackgroundService : BackgroundService _tracker.UpdateStatus(job.JobId, ImportJobStatus.Failed, 0, ex.Message); try { await notificationService.SendImportNotificationAsync(job.Token, true, ex.Message); } catch { } + job.Token = null; // Clear token after notification sent // cleanup minio file on failure if (!string.IsNullOrEmpty(job.ImportDocId)) diff --git a/Services/ImportJobTracker.cs b/Services/ImportJobTracker.cs index d58a37c..eed3188 100644 --- a/Services/ImportJobTracker.cs +++ b/Services/ImportJobTracker.cs @@ -72,7 +72,6 @@ public class ImportJobTracker job.CompletedAt = DateTime.Now; // Clear request data to free memory for completed/failed jobs job.Request = null; - job.Token = null; } } }