同步错误

This commit is contained in:
苏尹岚
2020-01-07 14:37:24 +08:00
parent 6c935643ae
commit 68c9f17d73

View File

@@ -638,7 +638,24 @@ func (v *VendorSync) LoopStoresMap2(ctx *jxcontext.Context, db *dao.DaoDB, taskN
if !isAsync {
resultList, err2 := task.GetResult(0)
if err2 != nil {
err2 = errors.New(utils.Format4Output(task.GetErrMsg(), true))
var resultL []*SyncErrResult
failedList := task.GetErrMsg()
for _, v := range failedList {
for _, vv := range v.([]*partner.StoreSkuInfoWithErr) {
result := &SyncErrResult{
SkuID: vv.StoreSkuInfo.SkuID,
StoreID: vv.StoreID,
VendorID: vv.VendoreID,
VendorSkuID: vv.StoreSkuInfo.VendorSkuID,
NameID: vv.StoreSkuInfo.NameID,
VendorPrice: vv.StoreSkuInfo.VendorPrice,
SyncType: vv.SyncType,
ErrMsg: vv.ErrMsg,
}
resultL = append(resultL, result)
}
}
err2 = fmt.Errorf(utils.Format4Output(resultL, true))
}
if err = err2; err == nil {
if len(resultList) == 0 {