liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- 异步任务消息格式

Browse Source
This commit is contained in:
gazebo
2019-03-22 18:44:24 +08:00
parent 7926baf59b
commit 753ce06d0b
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/jxutils/tasksch/task.go
View File

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