From 00a0edeade0b9f3a0ec20df2fc29023acabb0ed1 Mon Sep 17 00:00:00 2001
From: lifenlong <pikachu1995@126.com>
Date: Mon, 24 May 2021 18:24:19 +0800
Subject: [PATCH] =?UTF-8?q?=E6=89=B9=E9=87=8F=E6=B7=BB=E5=8A=A0=E7=9B=B4?=
 =?UTF-8?q?=E6=92=AD=E5=95=86=E5=93=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../broadcast/service/CommodityService.java        |  4 +++-
 .../serviceimpl/CommodityServiceImpl.java          | 14 ++++++++------
 .../other/broadcast/CommodityController.java       |  6 ++++--
 3 files changed, 15 insertions(+), 9 deletions(-)

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);