diff --git a/business/jxutils/tasksch/task.go b/business/jxutils/tasksch/task.go index 9850c908b..f663056bb 100644 --- a/business/jxutils/tasksch/task.go +++ b/business/jxutils/tasksch/task.go @@ -301,10 +301,14 @@ func (t *BaseTask) run(taskHandler func()) { if authInfo, err := t.ctx.GetV2AuthInfo(); err == nil { // 这里应该是不管登录类型,直接以可能的方式发消息 var content string taskDesc := fmt.Sprintf("你的异步任务[%s],ID[%s],开始于:%s,结束于:%s,", t.Name, t.ID, utils.Time2Str(t.CreatedAt), utils.Time2Str(t.TerminatedAt)) - if t.Status == TaskStatusFinished { - content = fmt.Sprintf("%s执行成功完成", taskDesc) + if t.Err == nil { + content = fmt.Sprintf("%s执行%s", taskDesc, TaskStatusName[t.Status]) } else { - content = fmt.Sprintf("%s执行失败,%s", taskDesc, t.Err.Error()) + if t.Status == TaskStatusFinished { + content = fmt.Sprintf("%s执行部分失败,%s", taskDesc, t.Err.Error()) + } else { + content = fmt.Sprintf("%s执行失败,%s", taskDesc, t.Err.Error()) + } } msg.SendUserMessage(authInfo.UserID, "异步任务完成", content) }