From 970ed0f8df6a19e4e3dae062c4e2e2232a0b97d0 Mon Sep 17 00:00:00 2001 From: huanghongfa <huanghongfa123456> Date: 星期三, 21 四月 2021 11:06:45 +0800 Subject: [PATCH] 删除商家bug修复 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopGoodsServiceImpl.java | 91 +++++++++++++++++++++++++-------------------- 1 files changed, 51 insertions(+), 40 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 5d38b84..0b7e793 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,12 +1,9 @@ package com.panzhihua.service_community.service.impl; -import java.math.BigDecimal; - 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.google.common.collect.Lists; import com.panzhihua.common.exceptions.ServiceException; @@ -16,29 +13,20 @@ import com.panzhihua.common.model.vos.shop.AddShopGoodsAttrVO; import com.panzhihua.common.model.vos.shop.PageShopGoodsVO; import com.panzhihua.common.model.vos.shop.AddShopGoodsVO; +import com.panzhihua.common.utlis.StringUtils; import com.panzhihua.service_community.dao.ComShopGoodsAttrDAO; import com.panzhihua.common.model.vos.shop.ComShopGoodsAttrVO; import com.panzhihua.common.model.vos.shop.ComShopGoodsVO; import com.panzhihua.common.model.vos.shop.PageShopStoreVO; -import com.panzhihua.service_community.dao.ComShopGoodsAttrDAO; -import com.panzhihua.common.model.dtos.shop.PageComShopGoodsDTO; -import com.panzhihua.common.model.vos.shop.PageShopStoreVO; import com.panzhihua.service_community.dao.ComShopGoodsDAO; import com.panzhihua.service_community.model.dos.ComShopGoodsAttrDO; 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.Arrays; -import java.util.List; -import java.util.stream.Collectors; import javax.annotation.Resource; import java.util.ArrayList; @@ -64,15 +52,20 @@ if (addShopGoodsVO == null) { return R.ok("500", "数据为空!"); } + String[] images = addShopGoodsVO.getGoodsPic().split(","); ComShopGoodsDO shopGoodsDO = new ComShopGoodsDO(); BeanUtils.copyProperties(addShopGoodsVO, shopGoodsDO); + if (images.length > 1) { + shopGoodsDO.setGoodsPic(images[0]); + } + shopGoodsDO.setImages(addShopGoodsVO.getGoodsPic()); shopGoodsDO.setSale(0); + shopGoodsDO.setDetails(addShopGoodsVO.getDetails()); int goodsId = this.baseMapper.insert(shopGoodsDO); if (goodsId > 0) { ArrayList<ComShopGoodsAttrDO> goodsAttrDOS = Lists.newArrayList(); - addShopGoodsVO.getGoodsAttrVOList().forEach(goodsAttr -> { - ComShopGoodsDO goodDO = this.baseMapper.selectById(shopGoodsDO.getId()); - //维护商品规格表 + ComShopGoodsDO goodDO = this.baseMapper.selectById(shopGoodsDO.getId()); + addShopGoodsVO.getGoodsAttrVOList().forEach(goodsAttr -> {//维护商品规格表 if (goodDO == null) { throw new ServiceException("商家id不存在!"); } @@ -80,12 +73,23 @@ shopGoodsAttrDO.setGoodsId(shopGoodsDO.getId()); shopGoodsAttrDO.setStoreId(goodDO.getStoreId()); shopGoodsAttrDO.setGoodsName(goodDO.getName()); - //如果没有规格加默认 shopGoodsAttrDO.setGoodsAttr(goodsAttr.getGoodsAttr()); shopGoodsAttrDO.setIsDefault(1); shopGoodsAttrDO.setPrice(goodsAttr.getAttrPrice()); + shopGoodsAttrDO.setAttrPic(images[0]); goodsAttrDOS.add(shopGoodsAttrDO); }); + if (addShopGoodsVO.getGoodsAttrVOList().size() < 1) {//如果没有规格参数加默认 + ComShopGoodsAttrDO shopGoodsAttrDO = new ComShopGoodsAttrDO(); + shopGoodsAttrDO.setGoodsId(shopGoodsDO.getId()); + shopGoodsAttrDO.setStoreId(goodDO.getStoreId()); + shopGoodsAttrDO.setGoodsName(goodDO.getName()); + shopGoodsAttrDO.setGoodsAttr("默认"); + shopGoodsAttrDO.setIsDefault(1); + shopGoodsAttrDO.setPrice(goodDO.getPrice()); + shopGoodsAttrDO.setAttrPic(images[0]); + goodsAttrService.save(shopGoodsAttrDO); + } if (goodsAttrDOS.size() > 0) { goodsAttrService.saveBatch(goodsAttrDOS); } @@ -97,23 +101,20 @@ public R pageGoodsList(PageComShopGoodsDTO pageComShopGoodsDTO) { Page page = new Page<>(pageComShopGoodsDTO.getPageNum(), pageComShopGoodsDTO.getPageSize()); IPage<PageShopGoodsVO> comShopStoreVOIPage = this.baseMapper.pageShopGoods(page, pageComShopGoodsDTO); - List<PageShopGoodsVO> shopGoodsVOS = comShopStoreVOIPage.getRecords(); - List<Long> goodsIds = shopGoodsVOS.stream().map(PageShopGoodsVO::getId).collect(Collectors.toList()); - LambdaQueryWrapper<ComShopGoodsAttrDO> in = new LambdaQueryWrapper<ComShopGoodsAttrDO>().in(ComShopGoodsAttrDO::getGoodsId, goodsIds); - //分页查询商品规格,组装数据 - List<ComShopGoodsAttrDO> goodsAttrDOS = goodsAttrService.getBaseMapper().selectList(in); - comShopStoreVOIPage.getRecords().forEach(vo -> { - List<ComShopGoodsAttrDO> goodsAttrDOs = goodsAttrDOS.stream().filter(goodsAttr -> goodsAttr.getGoodsId().equals(vo.getId())).collect(Collectors.toList()); - ArrayList<AddShopGoodsAttrVO> goodsAttrVOList = Lists.newArrayList(); - for (ComShopGoodsAttrDO oneGoodsAttrDO : goodsAttrDOs) { - AddShopGoodsAttrVO goodsAttrVO = new AddShopGoodsAttrVO(); - goodsAttrVO.setGoodsAttrId(oneGoodsAttrDO.getId()); - goodsAttrVO.setGoodsAttr(oneGoodsAttrDO.getGoodsAttr()); - goodsAttrVO.setAttrPrice(oneGoodsAttrDO.getPrice()); - goodsAttrVOList.add(goodsAttrVO); - } - vo.setGoodsAttts(goodsAttrVOList); - }); + if (!comShopStoreVOIPage.getRecords().isEmpty()) { + comShopStoreVOIPage.getRecords().forEach(shopGoods -> { + List<ComShopGoodsAttrDO> goodsAttrDOs = shopGoodsAttrDAO.selectList(new QueryWrapper<ComShopGoodsAttrDO>().lambda().eq(ComShopGoodsAttrDO::getGoodsId, shopGoods.getId())); + ArrayList<AddShopGoodsAttrVO> goodsAttrVOList = Lists.newArrayList(); + for (ComShopGoodsAttrDO oneGoodsAttrDO : goodsAttrDOs) { + AddShopGoodsAttrVO goodsAttrVO = new AddShopGoodsAttrVO(); + goodsAttrVO.setGoodsAttrId(oneGoodsAttrDO.getId()); + goodsAttrVO.setGoodsAttr(oneGoodsAttrDO.getGoodsAttr()); + goodsAttrVO.setAttrPrice(oneGoodsAttrDO.getPrice()); + goodsAttrVOList.add(goodsAttrVO); + } + shopGoods.setGoodsAttts(goodsAttrVOList); + }); + } return R.ok(comShopStoreVOIPage); } @@ -136,15 +137,16 @@ } //先删除 ComShopGoodsAttrDO goodsAttrDO = goodsAttrService.getBaseMapper().selectById(goodsAttr.getGoodsAttrId()); - if (goodsAttrDO == null) { - throw new ServiceException("规格为空,请检查规格Id"); - } ComShopGoodsAttrDO shopGoodsAttrDO = new ComShopGoodsAttrDO(); shopGoodsAttrDO.setGoodsId(id); shopGoodsAttrDO.setStoreId(shopGoodsDO.getStoreId()); shopGoodsAttrDO.setGoodsName(shopGoodsDO.getName()); - //如果没有规格加默认 - shopGoodsAttrDO.setGoodsAttr(goodsAttr.getGoodsAttr()); + if (goodsAttrDO == null) { + //如果没有规格加默认 + shopGoodsAttrDO.setGoodsAttr(goodsAttr.getGoodsAttr()); + } else { + shopGoodsAttrDO.setGoodsAttr("默认"); + } shopGoodsAttrDO.setIsDefault(1); shopGoodsAttrDO.setPrice(goodsAttr.getAttrPrice()); goodsAttrDOS.add(shopGoodsAttrDO); @@ -189,7 +191,16 @@ @Override public R pageShopGoods(ComShopGoodsDTO comShopGoodsDTO) { Page page = new Page<>(comShopGoodsDTO.getPageNum(), comShopGoodsDTO.getPageSize()); - return R.ok(this.baseMapper.pageShopGoodByApps(page, comShopGoodsDTO)); + IPage<ComShopGoodsVO> goodsVOIPage = this.baseMapper.pageShopGoodByApps(page, comShopGoodsDTO); + if (!goodsVOIPage.getRecords().isEmpty()) { + goodsVOIPage.getRecords().forEach(goodsVo -> { + List<ComShopGoodsAttrVO> goodsAttrList = shopGoodsAttrDAO.getGoodsAttr(goodsVo.getId()); + if (!goodsAttrList.isEmpty()) { + goodsVo.setGoodsAttrList(goodsAttrList); + } + }); + } + return R.ok(goodsVOIPage); } /** -- Gitblit v1.7.1