From db7f51b20a98d58110db9d38b30caa95f0cbd21d Mon Sep 17 00:00:00 2001
From: CeDo <cedoogle@gmail.com>
Date: 星期六, 17 四月 2021 18:05:43 +0800
Subject: [PATCH] Default Changelist

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopGoodsServiceImpl.java |  115 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 115 insertions(+), 0 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopGoodsServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopGoodsServiceImpl.java
index 2cf8e20..c361400 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopGoodsServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopGoodsServiceImpl.java
@@ -1,11 +1,33 @@
 package com.panzhihua.service_community.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.panzhihua.common.model.dtos.shop.ComShopGoodsDTO;
+import com.panzhihua.common.model.vos.R;
+import com.panzhihua.common.model.vos.shop.ComShopGoodsAttrVO;
+import com.panzhihua.common.model.vos.shop.ComShopGoodsVO;
+import com.panzhihua.common.model.vos.shop.ComShopStoreVO;
+import com.panzhihua.service_community.dao.ComShopGoodsAttrDAO;
+import com.panzhihua.common.model.dtos.shop.PageComShopGoodsDTO;
+import com.panzhihua.common.model.vos.shop.ComShopStoreVO;
+import com.panzhihua.common.model.vos.shop.ShopGoodsVO;
 import com.panzhihua.service_community.dao.ComShopGoodsDAO;
+import com.panzhihua.service_community.dao.ComShopStoreDAO;
+import com.panzhihua.service_community.model.dos.ComShopGoodsAttrDO;
 import com.panzhihua.service_community.model.dos.ComShopGoodsDO;
+import com.panzhihua.service_community.model.dos.ComShopStoreDO;
 import com.panzhihua.service_community.service.ComShopGoodsService;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * @auther lyq
@@ -15,5 +37,98 @@
 @Slf4j
 @Service
 public class ComShopGoodsServiceImpl extends ServiceImpl<ComShopGoodsDAO, ComShopGoodsDO> implements ComShopGoodsService {
+    @Override
+    public R saveShopGoods(ShopGoodsVO shopGoodsVO) {
+        if (shopGoodsVO == null) {
+            return R.ok("500", "数据为空!");
+        }
+        ComShopGoodsDO shopGoodsDO = new ComShopGoodsDO();
+        BeanUtils.copyProperties(shopGoodsVO, shopGoodsDO);
+        shopGoodsDO.setSale(0);
+        this.baseMapper.insert(shopGoodsDO);
+        return R.ok();
+    }
 
+    @Override
+    public R pageStoreList(PageComShopGoodsDTO pageComShopGoodsDTO) {
+        Page page = new Page<>(pageComShopGoodsDTO.getPageNum(), pageComShopGoodsDTO.getPageSize());
+        IPage<ComShopStoreVO> comShopStoreVOIPage = this.baseMapper.pageShopGoods(page, pageComShopGoodsDTO);
+        return R.ok(comShopStoreVOIPage);
+    }
+
+    @Resource
+    private ComShopGoodsAttrDAO shopGoodsAttrDAO;
+    @Resource
+    private ComShopStoreDAO shopStoreDAO;
+
+    /**
+     * 分页查询商品列表
+     * @param comShopGoodsDTO   请求参数
+     * @return  商品列表
+     */
+    @Override
+    public R pageShopGoods(ComShopGoodsDTO comShopGoodsDTO){
+        Page page = new Page<>(comShopGoodsDTO.getPageNum(),comShopGoodsDTO.getPageSize());
+        return R.ok(this.baseMapper.pageShopGoods(page,comShopGoodsDTO));
+    }
+
+    /**
+     * 根据商品id查询商品信息
+     * @param goodsId   商品id
+     * @return  商品信息
+     */
+    @Override
+    public R shopGoodsDetail(Long goodsId){
+
+        //根据id查询商品信息
+        ComShopGoodsDO goodsDO = this.baseMapper.selectById(goodsId);
+        if(goodsDO == null || goodsDO.getDeleteStatus().equals(ComShopGoodsDO.deleteStatus.yes)){
+            return R.fail(403,"商品不存在");
+        }
+        if(!goodsDO.getStatus().equals(ComShopGoodsDO.status.sell)){
+            return R.fail(405,"商品已下架");
+        }
+
+        //根据商品id查询商品规格信息
+        List<ComShopGoodsAttrVO> goodsAttrList = new ArrayList<>();
+        List<ComShopGoodsAttrDO> goodsAttrDOS = shopGoodsAttrDAO.selectList(new QueryWrapper<ComShopGoodsAttrDO>().eq("goods_id",goodsId));
+        goodsAttrDOS.forEach(attrDO->{
+            ComShopGoodsAttrVO goodsAttrVO = new ComShopGoodsAttrVO();
+            BeanUtils.copyProperties(attrDO,goodsAttrVO);
+            goodsAttrList.add(goodsAttrVO);
+        });
+
+        //查询商品店铺信息
+        ComShopStoreDO shopStoreDO = shopStoreDAO.selectById(goodsDO.getStoreId());
+        ComShopStoreVO shopStoreVO = new ComShopStoreVO();
+        BeanUtils.copyProperties(shopStoreDO,shopStoreVO);
+
+        //设置值
+        ComShopGoodsVO shopGoods = new ComShopGoodsVO();
+        BeanUtils.copyProperties(goodsDO,shopGoods);
+        shopGoods.setGoodsAttrList(goodsAttrList);
+        shopGoods.setShopStoreVO(shopStoreVO);
+        return R.ok(shopGoods);
+    }
+
+    @Override
+    public R editShopGoods(Long id, ShopGoodsVO shopGoodsVO) {
+        if (shopGoodsVO == null) {
+            return R.ok("500", "数据为空!");
+        }
+        LambdaQueryWrapper<ComShopGoodsDO> query = new LambdaQueryWrapper<ComShopGoodsDO>().eq(ComShopGoodsDO::getId, id);
+        ComShopGoodsDO shopGoodsDO = new ComShopGoodsDO();
+        BeanUtils.copyProperties(shopGoodsVO,shopGoodsDO);
+        int update = this.baseMapper.update(shopGoodsDO, query);
+        return update > 0 ? R.ok() : R.fail();
+    }
+
+    @Override
+    public R deleteShopGoods(Long[] id) {
+        ComShopGoodsDO storeDO = new ComShopGoodsDO();
+        storeDO.setDeleteStatus(2);
+        LambdaQueryWrapper<ComShopGoodsDO> query = new LambdaQueryWrapper<ComShopGoodsDO>().eq(ComShopGoodsDO::getId, id);
+        int update = this.baseMapper.update(storeDO, query);
+        return update > 0 ? R.ok() : R.fail();
+    }
 }

--
Gitblit v1.7.1