同步错误返回修改:从task中获取failedList才返回新的同步错

This commit is contained in:
苏尹岚
2020-01-10 14:38:25 +08:00
parent c6f3e49be8
commit 279e71a2ea

View File

@@ -457,9 +457,7 @@ func (v *VendorSync) SyncStoresSkus2(ctx *jxcontext.Context, db *dao.DaoDB, vend
return nil, partner.AddVendorInfo2Err(err, loopMapInfo.VendorID) return nil, partner.AddVendorInfo2Err(err, loopMapInfo.VendorID)
}, isContinueWhenError) }, isContinueWhenError)
if task != nil { if task != nil {
if err != nil { err = makeSyncError(err)
err = makeSyncError(err)
}
} }
return hint, err return hint, err
} }
@@ -652,7 +650,7 @@ func (v *VendorSync) LoopStoresMap2(ctx *jxcontext.Context, db *dao.DaoDB, taskN
tasksch.HandleTask(task, nil, isManageIt).Run() tasksch.HandleTask(task, nil, isManageIt).Run()
if !isAsync { if !isAsync {
resultList, err2 := task.GetResult(0) resultList, err2 := task.GetResult(0)
if err2 != nil { if len(task.GetFailedList()) > 0 {
err2 = buildErrMsg(task) err2 = buildErrMsg(task)
} }
if err = err2; err == nil { if err = err2; err == nil {