直播货物添加

fs-company/src/main/java/com/fs/company/controller/live/LiveGoodsController.java

@@ -16,6 +16,7 @@ import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * 直播商品Controller
@@ -78,11 +79,11 @@ public class LiveGoodsController extends BaseController
     @PreAuthorize("@ss.hasPermi('live:liveGoods:add')")
     @Log(title = "直播商品", businessType = BusinessType.INSERT)
     @PostMapping
-    public AjaxResult add(@RequestBody LiveGoods liveGoods)
+    public AjaxResult add(@RequestBody Map<String, Object> payload)
     {
-        // 设置企业ID和企业用户ID
-        setCompanyId(liveGoods);
-        return toAjax(liveGoodsService.insertLiveGoods(liveGoods));
+        LoginUser loginUser = SecurityUtils.getLoginUser();
+        CompanyUser user = loginUser.getUser();
+        return toAjax(liveGoodsService.insertLiveGoods(payload,user));
     }
 
     /**

fs-live-app/src/main/java/com/fs/app/websocket/service/WebSocketServer.java

@@ -2,6 +2,7 @@ package com.fs.app.websocket.service;
 
 
 import com.alibaba.fastjson.JSONObject;
+import com.fs.app.config.ProductionWordFilter;
 import com.fs.app.websocket.auth.WebSocketConfigurator;
 import com.fs.app.websocket.bean.SendMsgVo;
 import com.fs.common.core.domain.R;

fs-service/src/main/java/com/fs/live/service/ILiveGoodsService.java

@@ -1,7 +1,10 @@
 package com.fs.live.service;
 
 import java.util.List;
+import java.util.Map;
+
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.fs.company.domain.CompanyUser;
 import com.fs.his.domain.FsStore;
 import com.fs.live.domain.LiveGoods;
 
@@ -60,5 +63,13 @@ public interface ILiveGoodsService extends IService<LiveGoods>{
      */
     int deleteLiveGoodsByGoodsId(Long goodsId);
 
+    /**
+     * 批量新增直播商品
+     *
+     * @param payload 包含 直播间和商品信息ids
+     * @return 结果
+     */
+    int insertLiveGoods(Map<String, Object> payload, CompanyUser user);
+
     FsStore getStoreByLiveId(Long liveId);
 }

fs-service/src/main/java/com/fs/live/service/impl/LiveGoodsServiceImpl.java

@@ -1,8 +1,12 @@
 package com.fs.live.service.impl;
 
 import java.util.List;
+import java.util.Map;
+
 import com.fs.common.utils.DateUtils;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fs.company.domain.CompanyUser;
+import com.fs.his.mapper.FsStoreProductMapper;
 import com.fs.his.domain.FsStore;
 import com.fs.his.service.IFsStoreService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -20,6 +24,10 @@ import com.fs.live.service.ILiveGoodsService;
 @Service
 public class LiveGoodsServiceImpl extends ServiceImpl<LiveGoodsMapper, LiveGoods> implements ILiveGoodsService {
 
+
+    @Autowired
+    private FsStoreProductMapper fsStoreProductMapper;
+
     @Autowired
     private IFsStoreService fsStoreService;
 
@@ -104,4 +112,18 @@ public class LiveGoodsServiceImpl extends ServiceImpl<LiveGoodsMapper, LiveGoods
         //获取店铺信息
         return fsStoreService.selectFsStoreByStoreId(storeId);
     }
+
+    /**
+     * 批量新增直播商品
+     *
+     * @param payload 包含 直播间和商品信息ids
+     * @return 结果
+     */
+    @Override
+    public int insertLiveGoods(Map<String, Object> payload, CompanyUser user) {
+        String liveId = (String) payload.get("liveId");
+        String goodsIds = (String) payload.get("goodsIds");
+//        fsStoreProductMapper.se
+        return 0;
+    }
 }