diff --git a/framework/src/main/java/cn/lili/modules/broadcast/service/CommodityService.java b/framework/src/main/java/cn/lili/modules/broadcast/service/CommodityService.java
index 310687be..8bde1e8b 100644
--- a/framework/src/main/java/cn/lili/modules/broadcast/service/CommodityService.java
+++ b/framework/src/main/java/cn/lili/modules/broadcast/service/CommodityService.java
@@ -3,6 +3,8 @@ package cn.lili.modules.broadcast.service;
 import cn.lili.modules.broadcast.entity.dos.Commodity;
 import com.baomidou.mybatisplus.extension.service.IService;
 
+import java.util.List;
+
 /**
  * 直播商品业务层
  *
@@ -15,7 +17,7 @@ public interface CommodityService extends IService<Commodity> {
      * 添加直播商品
      * @return 添加结果
      */
-    boolean addCommodity(Commodity commodity);
+    boolean addCommodity(List<Commodity> commodity);
 
     /**
      * 删除直播商品
diff --git a/framework/src/main/java/cn/lili/modules/broadcast/serviceimpl/CommodityServiceImpl.java b/framework/src/main/java/cn/lili/modules/broadcast/serviceimpl/CommodityServiceImpl.java
index 1e524984..baa954ce 100644
--- a/framework/src/main/java/cn/lili/modules/broadcast/serviceimpl/CommodityServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/broadcast/serviceimpl/CommodityServiceImpl.java
@@ -27,12 +27,14 @@ public class CommodityServiceImpl extends ServiceImpl<CommodityMapper, Commodity
     private WechatLivePlayerUtil wechatLivePlayerUtil;
 
     @Override
-    public boolean addCommodity(Commodity commodity) {
-        JSONObject json = wechatLivePlayerUtil.addGoods(commodity);
-        commodity.setLiveGoodsId(Convert.toInt(json.getStr("goodsId")));
-        commodity.setAuditId(json.getStr("auditId"));
-        commodity.setStoreId(UserContext.getCurrentUser().getStoreId());
-        return this.save(commodity);
+    public boolean addCommodity(List<Commodity> commodityList) {
+        for (Commodity commodity:commodityList) {
+            JSONObject json = wechatLivePlayerUtil.addGoods(commodity);
+            commodity.setLiveGoodsId(Convert.toInt(json.getStr("goodsId")));
+            commodity.setAuditId(json.getStr("auditId"));
+            commodity.setStoreId(UserContext.getCurrentUser().getStoreId());
+        }
+        return this.saveBatch(commodityList);
     }
 
     @Override
diff --git a/seller-api/src/main/java/cn/lili/controller/other/broadcast/CommodityController.java b/seller-api/src/main/java/cn/lili/controller/other/broadcast/CommodityController.java
index cb8a9b39..0e59756d 100644
--- a/seller-api/src/main/java/cn/lili/controller/other/broadcast/CommodityController.java
+++ b/seller-api/src/main/java/cn/lili/controller/other/broadcast/CommodityController.java
@@ -15,6 +15,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
+
 /**
  * 店铺端,直播商品接口
  *
@@ -37,8 +39,8 @@ public class CommodityController {
 
     @ApiOperation(value = "添加店铺直播商品")
     @PostMapping
-    public ResultMessage<Object> addCommodity(@Validated Commodity commodity) {
-        if (commodityService.addCommodity(commodity)) {
+    public ResultMessage<Object> addCommodity(@Validated List<Commodity> commodityList) {
+        if (commodityService.addCommodity(commodityList)) {
             return ResultUtil.success(ResultCode.SUCCESS);
         }
         throw new ServiceException(ResultCode.ERROR);