diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index 6cdfb6115..4d4b3087f 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -651,16 +651,15 @@ func buildSetFinishHook(task tasksch.ITask, ctx *jxcontext.Context) { if len(task.GetFailedList()) > 10 { downloadURL, _, _ := WirteToExcelBySyncFailed(task) noticeMsg += fmt.Sprintf("[详情点我]%s/billshow/?normal=true&path=%s \n", globals.BackstageHost, downloadURL) - if authInfo, err := ctx.GetV2AuthInfo(); err == nil { - ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "同步错误返回", noticeMsg) - } } else if len(task.GetFailedList()) > 0 && len(task.GetFailedList()) <= 10 { if task.GetErr() != nil { noticeMsg += utils.Format4Output(buildErrMsgJson(task), true) } - if authInfo, err := ctx.GetV2AuthInfo(); err == nil { - ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "同步错误返回", noticeMsg) - } + } else { + noticeMsg = "您的同步任务执行完成,没有错误返回。" + } + if authInfo, err := ctx.GetV2AuthInfo(); err == nil { + ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "同步错误返回", noticeMsg) } } else { if time.Now().Hour() >= 20 || time.Now().Hour() < 7 { diff --git a/business/jxutils/tasksch/task.go b/business/jxutils/tasksch/task.go index a9735d88e..89f407e4a 100644 --- a/business/jxutils/tasksch/task.go +++ b/business/jxutils/tasksch/task.go @@ -475,7 +475,6 @@ func (t *BaseTask) run(taskHandler func()) { close(t.finishChan) if t.finishHook != nil { t.finishHook(t) - SendMessage(t) } else { SendMessage(t) }