diff --git a/business/partner/purchase/yb/store_sku.go b/business/partner/purchase/yb/store_sku.go
index 32f5e1053..e75d866a9 100644
--- a/business/partner/purchase/yb/store_sku.go
+++ b/business/partner/purchase/yb/store_sku.go
@@ -37,9 +37,12 @@ func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, v
 			failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDYB], "创建商品")
 		} else {
 			storeSku.VendorSkuID = utils.Int64ToStr(result.UID)
-			uploadYbImage(vendorStoreID, storeSku.YbBarCode, storeSku.Img)
+			err = uploadYbImage(vendorStoreID, storeSku.YbBarCode, storeSku.Img)
 			if !flag {
-				updateYbSku(vendorStoreID, storeSku.YbBarCode, nil)
+				err = updateYbSku(vendorStoreID, storeSku.YbBarCode, nil)
+			}
+			if err != nil {
+				failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDYB], "创建商品")
 			}
 		}
 	}
@@ -52,8 +55,12 @@ func (p *PurchaseHandler) UpdateStoreSkus(ctx *jxcontext.Context, storeID int, v
 			saveProductParam := &yinbaoapi.SaveProductParam{
 				CategoryUid: v.VendorCatID,
 			}
-			checkYbSku(v)
-			updateYbSku(vendorStoreID, v.YbBarCode, saveProductParam)
+			_, err = checkYbSku(v)
+			if err != nil {
+				failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDYB], "修改商品")
+				return failedList, err
+			}
+			err = updateYbSku(vendorStoreID, v.YbBarCode, saveProductParam)
 			if err != nil {
 				failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDYB], "修改商品")
 			}