同步错误返回,修改

This commit is contained in:
苏尹岚
2020-01-21 18:18:49 +08:00
parent 35f1a12a16
commit 85a2e42ea6
3 changed files with 8 additions and 5 deletions

View File

@@ -654,7 +654,8 @@ func buildSetFinishHook(task tasksch.ITask, ctx *jxcontext.Context) {
noticeMsg += fmt.Sprintf("[详情点我]%s/billshow/?normal=true&path=%s \n", globals.BackstageHost, downloadURL) noticeMsg += fmt.Sprintf("[详情点我]%s/billshow/?normal=true&path=%s \n", globals.BackstageHost, downloadURL)
} else if len(task.GetFailedList()) > 0 && len(task.GetFailedList()) <= 10 { } else if len(task.GetFailedList()) > 0 && len(task.GetFailedList()) <= 10 {
if task.GetErr() != nil { if task.GetErr() != nil {
noticeMsg = utils.Format4Output(buildErrMsgJson(task), true) noticeMsg = "您此次的同步任务错误详情返回如下: "
noticeMsg += utils.Format4Output(buildErrMsgJson(task), true)
} }
} }
if authInfo, err := ctx.GetV2AuthInfo(); err == nil { if authInfo, err := ctx.GetV2AuthInfo(); err == nil {

View File

@@ -700,11 +700,13 @@ func buildFailedListAndErr(failedList []*partner.StoreSkuInfoWithErr, err error,
} }
return failedList, err return failedList, err
} else if err == nil && len(failedList) > 0 { } else if err == nil && len(failedList) > 0 {
var errMsg = "" var errMsgList []string
for _, v := range failedList { for _, v := range failedList {
errMsg += v.ErrMsg errMsgList = append(errMsgList, utils.Int2Str(v.StoreSkuInfo.SkuID))
errMsgList = append(errMsgList, utils.Int2Str(storeID))
errMsgList = append(errMsgList, v.ErrMsg)
} }
err2 := errors.New(errMsg) err2 := errors.New(strings.Join(errMsgList, ","))
return failedList, err2 return failedList, err2
} }
return failedList, err return failedList, err

View File

@@ -89,7 +89,7 @@ var (
"00:01:00", "00:01:00",
} }
sendSecKillWarnList = []string{ sendSecKillWarnList = []string{
"8:30:00", "9:00:00",
} }
autoSaleStoreSkuTimeList = []string{ autoSaleStoreSkuTimeList = []string{