- 处理BatchUpdateVendibility和BatchUpdateCurrentQtys可能部分失败的情况

business/partner/purchase/jd/store_sku.go

@@ -103,6 +103,9 @@ func (p *PurchaseHandler) syncStoreSkus(ctx *jxcontext.Context, parentTask tasks
 						if _, err = api.JdAPI.BatchUpdateVendibility("", stationNo, skuVendibilityList, ctx.GetUserName()); err == nil {
 							syncMask |= model.SyncFlagSaleMask
 						} else {
+							if !isPartialFailed {
+								isPartialFailed = isErrPartialFailed(err)
+							}
 							errList = append(errList, err)
 						}
 					}
@@ -110,6 +113,9 @@ func (p *PurchaseHandler) syncStoreSkus(ctx *jxcontext.Context, parentTask tasks
 						if _, err = api.JdAPI.BatchUpdateCurrentQtys("", stationNo, skuStockList, ctx.GetUserName()); err == nil {
 							syncMask |= model.SyncFlagNewMask | model.SyncFlagDeletedMask
 						} else {
+							if !isPartialFailed {
+								isPartialFailed = isErrPartialFailed(err)
+							}
 							errList = append(errList, err)
 						}
 					}
@@ -117,7 +123,9 @@ func (p *PurchaseHandler) syncStoreSkus(ctx *jxcontext.Context, parentTask tasks
 						if _, err = api.JdAPI.UpdateVendorStationPrice("", stationNo, skuPriceInfoList); err == nil {
 							syncMask |= model.SyncFlagPriceMask
 						} else {
-							isPartialFailed = isErrPartialFailed(err)
+							if !isPartialFailed {
+								isPartialFailed = isErrPartialFailed(err)
+							}
 							// errList = append(errList, partner.NewErrorCode(err.Error(), partner.ErrCodeChangePriceFailed, model.VendorIDJD))
 							errList = append(errList, err)
 						}