diff --git a/internal/service/cpdaily/cptask.go b/internal/service/cpdaily/cptask.go index ed8b24f..c2f16ef 100644 --- a/internal/service/cpdaily/cptask.go +++ b/internal/service/cpdaily/cptask.go @@ -5,7 +5,6 @@ import ( "context" "encoding/gob" "encoding/json" - "fmt" v1 "likedream-goframe/internal/api/v1" "likedream-goframe/internal/application/cpdaily/login" "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, "非法的今日校园账号")) } // 异步终止线程,不管是否成功 - 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) return utils.SuccessWithMsg("删除成功") } @@ -293,7 +292,7 @@ func (v CpTaskServiceV1) PauseTask(ctx context.Context, req *v1.PauseTaskReq) *u return utils.SuccessWithMsg("恢复成功") } 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) return utils.SuccessWithMsg("暂停成功") }