becomer/likedream
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🐛 没有任务id了，因此没法删除asynq里的任务了

Browse Source
This commit is contained in:
sugarBecomer
2025-11-18 16:05:03 +08:00
parent 7469813e37
commit 526e4ac198
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/service/cpdaily/cptask.go
+2 -3
View File
@@ -5,7 +5,6 @@ import (
"context" "context"
"encoding/gob" "encoding/gob"
"encoding/json" "encoding/json"
"fmt"
v1 "likedream-goframe/internal/api/v1" v1 "likedream-goframe/internal/api/v1"
"likedream-goframe/internal/application/cpdaily/login" "likedream-goframe/internal/application/cpdaily/login"
"likedream-goframe/internal/application/cpdaily/school" "likedream-goframe/internal/application/cpdaily/school"
@@ -221,7 +220,7 @@ func (v CpTaskServiceV1) Delete(ctx context.Context, req *v1.DeleteTaskReq) *uti
utils.OkOrPanic(errors2.NewBusinessError(400, "非法的今日校园账号")) utils.OkOrPanic(errors2.NewBusinessError(400, "非法的今日校园账号"))
} }
// 异步终止线程，不管是否成功 // 异步终止线程，不管是否成功
go schedule.StopTask(context.Background(), cst2.TaskQueueCpdaily, fmt.Sprintf(cst2.TaskCpdailyId, req.Id)) //go schedule.StopTask(context.Background(), cst2.TaskQueueCpdaily, fmt.Sprintf(cst2.TaskCpdailyId, req.Id))
db2.Global.CpTask.DeleteOne(cpTask).ExecX(ctx) db2.Global.CpTask.DeleteOne(cpTask).ExecX(ctx)
return utils.SuccessWithMsg("删除成功") return utils.SuccessWithMsg("删除成功")
} }
@@ -293,7 +292,7 @@ func (v CpTaskServiceV1) PauseTask(ctx context.Context, req *v1.PauseTaskReq) *u
return utils.SuccessWithMsg("恢复成功") return utils.SuccessWithMsg("恢复成功")
} else { } else {
go schedule.StopTask(context.Background(), cst2.TaskQueueCpdaily, fmt.Sprintf(cst2.TaskCpdailyId, req.Id)) //go schedule.StopTask(context.Background(), cst2.TaskQueueCpdaily, fmt.Sprintf(cst2.TaskCpdailyId, req.Id))
db2.Global.CpTask.UpdateOne(cpTask).SetTaskStatus(cptask.TaskStatusPause).SetNextExecuteTime(-1).ExecX(ctx) db2.Global.CpTask.UpdateOne(cpTask).SetTaskStatus(cptask.TaskStatusPause).SetNextExecuteTime(-1).ExecX(ctx)
return utils.SuccessWithMsg("暂停成功") return utils.SuccessWithMsg("暂停成功")
} }