Client/server
5
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix(email): update task progress handling to use specific task ID for updates

Browse Source
This commit is contained in:
Chang lue Tsen
2025-09-08 12:53:28 -04:00
parent 31cdcd2cb9
commit f4c6bd919b
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/email/worker.go
+3 -2
View File
@@ -136,7 +136,8 @@ func (w *Worker) Start() {
taskInfo.Errors = string(text) taskInfo.Errors = string(text)
} }
count++ count++
if err := tx.Model(&task.EmailTask{}).Save(&taskInfo).Error; err != nil { taskInfo.Current = count
if err := tx.Model(&task.EmailTask{}).Where("`id` = ?", taskInfo.Id).Save(&taskInfo).Error; err != nil {
logger.Error("Batch Send Email", logger.Error("Batch Send Email",
logger.Field("message", "Failed to update task progress"), logger.Field("message", "Failed to update task progress"),
logger.Field("error", err.Error()), logger.Field("error", err.Error()),
@@ -148,7 +149,7 @@ func (w *Worker) Start() {
time.Sleep(intervalTime) time.Sleep(intervalTime)
} }
taskInfo.Status = 2 // 设置状态为已完成 taskInfo.Status = 2 // 设置状态为已完成
if err := tx.Model(&task.EmailTask{}).Save(&taskInfo).Error; err != nil { if err := tx.Model(&task.EmailTask{}).Where("`id` = ?", taskInfo.Id).Save(&taskInfo).Error; err != nil {
logger.Error("Batch Send Email", logger.Error("Batch Send Email",
logger.Field("message", "Failed to finalize task"), logger.Field("message", "Failed to finalize task"),
logger.Field("error", err.Error()), logger.Field("error", err.Error()),