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

排除每天自动同步

Browse Source
This commit is contained in:
苏尹岚
2020-01-13 15:14:15 +08:00
parent 36fbaadb97
commit a403f4bf09
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
business/jxstore/cms/sync.go
View File

@@ -634,16 +634,18 @@ func (v *VendorSync) LoopStoresMap2(ctx *jxcontext.Context, parentTask tasksch.I
if isAsync { if isAsync {
task.SetFinishHook(func(task tasksch.ITask) { task.SetFinishHook(func(task tasksch.ITask) {
var noticeMsg string var noticeMsg string
if len(task.GetFailedList()) > 10 { if ctx.GetUserName() != "jxadmin" {
downloadURL, _, _ := WirteToExcelBySyncFailed(task) if len(task.GetFailedList()) > 10 {
noticeMsg = fmt.Sprintf("[详情点我]path1=%s\n", downloadURL) downloadURL, _, _ := WirteToExcelBySyncFailed(task)
} else if len(task.GetFailedList()) > 0 && len(task.GetFailedList()) <= 10 { noticeMsg = fmt.Sprintf("[详情点我]path1=%s\n", downloadURL)
if task.GetErr() != nil { } else if len(task.GetFailedList()) > 0 && len(task.GetFailedList()) <= 10 {
noticeMsg = utils.Format4Output(buildErrMsgJson(task), true) if task.GetErr() != nil {
noticeMsg = utils.Format4Output(buildErrMsgJson(task), true)
}
}
if authInfo, err := ctx.GetV2AuthInfo(); err == nil {
ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "同步错误返回", noticeMsg)
} }
}
if authInfo, err := ctx.GetV2AuthInfo(); err == nil {
ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "同步错误返回", noticeMsg)
} }
}) })
} }