GitHub/015
1
0
Fork 0
mirror of https://github.com/keven1024/015.git synced 2026-05-26 07:08:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(backend): enhance image compression task handling with retry logic and detailed status reporting

Browse Source
This commit is contained in:
keven1024
2025-06-02 11:52:25 +08:00
parent da58a46e72
commit 7b2462de29
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
backend/internal/controllers/image.go
View File

@@ -32,7 +32,7 @@ func GenCompressImage(c echo.Context) error {
if err != nil {
return utils.HTTPErrorHandler(c, err)
}
info, err := client.Enqueue(asynq.NewTask("image:compress", json))
info, err := client.Enqueue(asynq.NewTask("image:compress", json), asynq.MaxRetry(3))
if err != nil {
return utils.HTTPErrorHandler(c, err)
}
@@ -60,10 +60,23 @@ func GetCompressImage(c echo.Context) error {
if err != nil {
return utils.HTTPErrorHandler(c, errors.New("任务已过期"))
}
stateMap := map[asynq.TaskState]string{
asynq.TaskStateActive: "processing",
asynq.TaskStatePending: "pending",
asynq.TaskStateScheduled: "scheduled",
asynq.TaskStateRetry: "retry",
asynq.TaskStateArchived: "archived",
asynq.TaskStateCompleted: "completed",
}
if queneTaskInfo != nil {
return utils.HTTPSuccessHandler(c, map[string]any{
"status": "processing",
"status": stateMap[queneTaskInfo.State],
"state": queneTaskInfo.State,
"err": map[string]any{
"message": queneTaskInfo.LastErr,
"retry": queneTaskInfo.Retried,
"max_retry": queneTaskInfo.MaxRetry,
},
})
}
}