From b22df417e0bc423c788b013feaad686531d69eed Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期三, 08 一月 2025 09:51:37 +0800 Subject: [PATCH] 修改bug --- ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/GoodsServiceImpl.java | 293 ++++++++++++++++++++++++++++++++++++++++++++------------- 1 files changed, 224 insertions(+), 69 deletions(-) diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/GoodsServiceImpl.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/GoodsServiceImpl.java index 11aedc6..05f7de5 100644 --- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/GoodsServiceImpl.java +++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/GoodsServiceImpl.java @@ -1,18 +1,27 @@ package com.ruoyi.other.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; 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.ruoyi.account.api.feignClient.AppUserClient; import com.ruoyi.account.api.model.AppUser; +import com.ruoyi.common.core.constant.TokenConstants; import com.ruoyi.common.core.domain.R; +import com.ruoyi.common.core.utils.ServletUtils; import com.ruoyi.common.core.utils.StringUtils; import com.ruoyi.common.core.utils.bean.BeanUtils; +import com.ruoyi.common.core.web.page.PageInfo; import com.ruoyi.common.security.service.TokenService; +import com.ruoyi.common.security.utils.SecurityUtils; +import com.ruoyi.order.feignClient.OrderClient; import com.ruoyi.order.feignClient.RemoteOrderGoodsClient; import com.ruoyi.order.vo.Price; import com.ruoyi.other.api.domain.*; +import com.ruoyi.other.api.vo.GetGoodsBargainPrice; +import com.ruoyi.other.api.vo.GetSeckillActivityInfo; import com.ruoyi.other.enums.GoodsStatus; import com.ruoyi.other.mapper.GoodsAreaMapper; import com.ruoyi.other.mapper.GoodsMapper; @@ -28,10 +37,7 @@ import javax.annotation.Resource; import java.math.BigDecimal; -import java.util.ArrayList; -import java.util.List; -import java.util.Map; -import java.util.Objects; +import java.util.*; import java.util.stream.Collectors; import java.util.stream.Stream; @@ -69,30 +75,46 @@ private GoodsAreaService goodsAreaService; @Resource private RemoteOrderGoodsClient remoteOrderGoodsClient; + @Resource + private SeckillActivityInfoService seckillActivityInfoService; + @Resource + private GoodsSeckillService goodsSeckillService; + @Resource + private GoodsBargainPriceService goodsBargainPriceService; + @Resource + private GoodsBargainPriceDetailService goodsBargainPriceDetailService; + @Resource + private OrderClient orderClient; + + @Override - public List<GoodsVO> goodsList(Goods search) { - List<Goods> goodsList = this.list(new LambdaQueryWrapper<Goods>() - .eq(Goods::getStatus, GoodsStatus.UP.getCode()) - .eq(Objects.nonNull(search.getGoodsCategoryId()), Goods::getGoodsCategoryId, search.getGoodsCategoryId()) - .like(StringUtils.isNotEmpty(search.getName()), Goods::getName, search.getName())); - - List<GoodsVO> result = new ArrayList<>(); - LoginUser loginUserApplet = tokenService.getLoginUserApplet(); - for (Goods goods : goodsList) { - GoodsVO goodsVO = new GoodsVO(); - BeanUtils.copyBeanProp(goodsVO, goods); - goodsVO.setGoodsId(goods.getId()); - goodsVO.setGoodsName(goods.getName()); - R<Price> r = remoteOrderGoodsClient.getGoodsPrice(loginUserApplet.getUserid(), goods.getId(), null); - if (null != r.getData()){ - Price price = r.getData(); - goodsVO.setSellingPrice(price.getCash()); - goodsVO.setIntegral(price.getPoint()); - } - result.add(goodsVO); + public PageInfo<GoodsVO> goodsList(Goods search) { + PageInfo<GoodsVO> pageInfo = new PageInfo(search.getPageCurr(), search.getPageSize()); + Integer vipId = 0; + String provinceCode = null; + String cityCode = null; + String districtCode = null; + String token = SecurityUtils.getToken(ServletUtils.getRequest()); + if(StringUtils.isNotEmpty(token)){ + Long userid = tokenService.getLoginUserApplet().getUserid(); + AppUser appUser = appUserClient.getAppUserById(userid); + vipId = appUser.getVipId(); + provinceCode = appUser.getProvinceCode(); + cityCode = appUser.getCityCode(); + districtCode = appUser.getDistrictCode(); } - return result; + List<GoodsVO> list = this.baseMapper.goodsList(pageInfo, search.getGoodsCategoryId(), search.getName(), vipId); + for (GoodsVO goods : list) { + Price price = getPrice(vipId, goods.getGoodsId(), null, 1, provinceCode, cityCode, districtCode); + if(null != price){ + goods.setCashPayment(price.getCashPayment() ? 1 : 0); + goods.setPointPayment(price.getPointPayment() ? 1 : 0); + goods.setSellingPrice(price.getCash()); + goods.setIntegral(price.getPoint()); + } + } + return pageInfo.setRecords(list); } @Override @@ -101,29 +123,18 @@ throw new NullPointerException("商品ID不能为空"); } - LoginUser loginUserApplet = tokenService.getLoginUserApplet(); - AppUser appUser = appUserClient.getAppUserById(loginUserApplet.getUserid()); - BigDecimal sellingPrice = BigDecimal.ZERO; - Integer integral = 0; - - GoodsArea goodsArea = goodsAreaMapper.selectOne(new LambdaQueryWrapper<GoodsArea>() - .eq(GoodsArea::getGoodsId, goodsId) - .eq(GoodsArea::getProvinceCode, appUser.getProvinceCode()) - .eq(StringUtils.isNotEmpty(appUser.getCityCode()), GoodsArea::getCityCode, appUser.getCityCode()) - .eq(StringUtils.isNotEmpty(appUser.getDistrictCode()), GoodsArea::getDistrictsCode, appUser.getDistrictCode())); - - if (Objects.nonNull(goodsArea)){ - sellingPrice = goodsArea.getSellingPrice(); - integral = goodsArea.getIntegral(); - }else { - VipSetting vipSetting = vipSettingService.getVipSettingByUserId(loginUserApplet.getUserid()); - GoodsVip goodsVip = goodsVipService.getOne(new LambdaQueryWrapper<GoodsVip>() - .eq(GoodsVip::getVip, vipSetting.getId()) - .eq(GoodsVip::getGoodsId, goodsId)); - if(null != goodsVip){ - sellingPrice = goodsVip.getSellingPrice(); - integral = goodsVip.getIntegral(); - } + Integer vipId = 0; + String provinceCode = null; + String cityCode = null; + String districtCode = null; + String token = SecurityUtils.getToken(ServletUtils.getRequest()); + if(StringUtils.isNotEmpty(token)){ + Long userid = tokenService.getLoginUserApplet().getUserid(); + AppUser appUser = appUserClient.getAppUserById(userid); + vipId = appUser.getVipId(); + provinceCode = appUser.getProvinceCode(); + cityCode = appUser.getCityCode(); + districtCode = appUser.getDistrictCode(); } Goods goods = this.getById(goodsId); @@ -131,32 +142,66 @@ BeanUtils.copyBeanProp(goodsVO, goods); goodsVO.setGoodsId(goods.getId()); goodsVO.setGoodsName(goods.getName()); - goodsVO.setSellingPrice(sellingPrice); - goodsVO.setIntegral(integral); + Price price = getPrice(vipId, goods.getId(), 1, null, provinceCode, cityCode, districtCode); + if(null != price){ + goodsVO.setPointPayment(price.getPointPayment() ? 1 : 0); + goodsVO.setCashPayment(price.getCashPayment() ? 1 : 0); + goodsVO.setSellingPrice(price.getCash()); + goodsVO.setIntegral(price.getPoint()); + } - if(goods.getAppointStore() == 2){ + if(goods.getType() == 1){ + if(goods.getAppointStore() == 2){ + List<Shop> shopList = shopMapper.selectList(new LambdaQueryWrapper<Shop>() + .in(Shop::getDelFlag, 0)); + goodsVO.setShopList(shopList); + }else{ + List<GoodsShop> goodsShopList = goodsShopMapper.selectList(new LambdaQueryWrapper<GoodsShop>() + .eq(GoodsShop::getGoodsId, goodsId)); + if (!CollectionUtils.isEmpty(goodsShopList)){ + List<Integer> shopIds = goodsShopList.stream().map(GoodsShop::getShopId).collect(Collectors.toList()); + List<Shop> shopList = shopMapper.selectList(new LambdaQueryWrapper<Shop>() + .in(Shop::getId, shopIds)); + goodsVO.setShopList(shopList); + } + } + }else{ List<Shop> shopList = shopMapper.selectList(new LambdaQueryWrapper<Shop>() .in(Shop::getDelFlag, 0)); goodsVO.setShopList(shopList); - }else{ - List<GoodsShop> goodsShopList = goodsShopMapper.selectList(new LambdaQueryWrapper<GoodsShop>() - .eq(GoodsShop::getGoodsId, goodsId)); - if (!CollectionUtils.isEmpty(goodsShopList)){ - List<Integer> shopIds = goodsShopList.stream().map(GoodsShop::getShopId).collect(Collectors.toList()); - List<Shop> shopList = shopMapper.selectList(new LambdaQueryWrapper<Shop>() - .in(Shop::getId, shopIds)); - goodsVO.setShopList(shopList); - } } + Integer integer = orderClient.getGoodsSaleNum(goods.getId(), 1).getData(); + goodsVO.setSaleNum(integer); return goodsVO; } @Override - public List<Goods> getGoodsListByShopId(Integer shopId) { - LoginUser loginUserApplet = tokenService.getLoginUserApplet(); - VipSetting vipSetting = vipSettingService.getVipSettingByUserId(loginUserApplet.getUserid()); - return goodsMapper.selectListByShopId(shopId, vipSetting.getId()); + public List<Goods> getGoodsListByShopId(PageInfo<Goods> pageInfo, Integer shopId) { + Integer vipId = 0; + String provinceCode = null; + String cityCode = null; + String districtCode = null; + String token = SecurityUtils.getToken(ServletUtils.getRequest()); + if(StringUtils.isNotEmpty(token)){ + Long userid = tokenService.getLoginUserApplet().getUserid(); + AppUser appUser = appUserClient.getAppUserById(userid); + vipId = appUser.getVipId(); + provinceCode = appUser.getProvinceCode(); + cityCode = appUser.getCityCode(); + districtCode = appUser.getDistrictCode(); + } + List<Goods> goods = goodsMapper.selectListByShopId(pageInfo, shopId, vipId); + for (Goods good : goods) { + Price price = getPrice(vipId, good.getId(), shopId, 1, provinceCode, cityCode, districtCode); + if(null != price){ + good.setCashPayment(price.getCashPayment() ? 1 : 0); + good.setPointPayment(price.getPointPayment() ? 1 : 0); + good.setSellingPrice(price.getCash()); + good.setIntegral(price.getPoint()); + } + } + return goods; } @Override @@ -173,7 +218,7 @@ // 指定门店 Integer appointStore = goods.getAppointStore(); - if (appointStore == 1){ + if (null != appointStore && appointStore == 1){ List<GoodsShop> goodsShopList = goods.getGoodsShopList(); if (CollectionUtils.isEmpty(goodsShopList)){ throw new NullPointerException("请选择指定门店"); @@ -286,10 +331,12 @@ for (GoodsShop goodsShop : goodsShops) { Shop shop = shopMapper.selectById(goodsShop.getShopId()); - goodsShop.setShopName(shop.getName()); - goodsShop.setOwnerName(shop.getShopManager()); - goodsShop.setPhone(shop.getPhone()); - goodsShop.setAddress(shop.getAddress()); + if(null != shop){ + goodsShop.setShopName(shop.getName()); + goodsShop.setOwnerName(shop.getShopManager()); + goodsShop.setPhone(shop.getPhone()); + goodsShop.setAddress(shop.getAddress()); + } } goods.setGoodsShopList(goodsShops); @@ -367,4 +414,112 @@ goodsArea1.setGoodsAreaList(goodsAreas); return goodsArea1; } + + + /** + * 根据商品的价格配置体系获取商品当前的价格 + * @param vip + * @param goodsId + * @param type 1普通商品,2秒杀商品 + * @param shopId + * @param provinceCode + * @param cityCode + * @param districtCode + * @return + */ + public Price getPrice(Integer vip, Integer goodsId, Integer shopId, Integer type, String provinceCode, String cityCode, String districtCode){ + //获取支付价格 + //秒杀活动>门店特价>地区价格>会员价格 + //判断是否有秒杀活动 + Price price = new Price(); + SeckillActivityInfo one = seckillActivityInfoService.getOne(new LambdaQueryWrapper<SeckillActivityInfo>().eq(SeckillActivityInfo::getGoodId, goodsId) + .eq(SeckillActivityInfo::getIsShelves, 1).eq(SeckillActivityInfo::getDelFlag, 0) + .last(" and now() between start_time and end_time and FIND_IN_SET(" + vip + ", vip_ids) order by create_time desc limit 0, 1")); + GoodsSeckill goodsSeckill = null; + if(null != one){ + goodsSeckill = goodsSeckillService.getOne(new LambdaQueryWrapper<GoodsSeckill>().eq(GoodsSeckill::getSeckillActivityInfoId, one.getId()).eq(GoodsSeckill::getVip, vip)); + } + //没有秒杀活动或者添加的普通商品则不使用秒杀活动价格 + if(null == goodsSeckill || type == 1){ + //没有秒杀价,则判断门店特价 + GoodsBargainPriceDetail bargainPriceDetail = null; + if (shopId != null){ + GoodsBargainPrice priceServiceOne = goodsBargainPriceService.getOne(new LambdaQueryWrapper<GoodsBargainPrice>().eq(GoodsBargainPrice::getGoodsId, goodsId).eq(GoodsBargainPrice::getShopId, shopId) + .eq(GoodsBargainPrice::getDelFlag, 0).eq(GoodsBargainPrice::getAuditStatus, 1).last(" order by create_time desc limit 0, 1")); + if(null != priceServiceOne){ + bargainPriceDetail = goodsBargainPriceDetailService.getOne(new LambdaQueryWrapper<GoodsBargainPriceDetail>().eq(GoodsBargainPriceDetail::getGoodsBargainPriceId, priceServiceOne.getId()).eq(GoodsBargainPriceDetail::getVip, vip)); + } + } + if(null == bargainPriceDetail){ + //没有门店特价,判断地区价格配置 + LambdaQueryWrapper<GoodsArea> queryWrapper = new LambdaQueryWrapper<GoodsArea>().eq(GoodsArea::getGoodsId, goodsId).eq(GoodsArea::getVip, vip); + if(StringUtils.isNotEmpty(districtCode)){ + queryWrapper.eq(GoodsArea::getDistrictsCode, districtCode); + } + if(StringUtils.isNotEmpty(cityCode)){ + queryWrapper.eq(GoodsArea::getCityCode, cityCode); + } + if(StringUtils.isNotEmpty(provinceCode)){ + queryWrapper.eq(GoodsArea::getProvinceCode, provinceCode); + } + GoodsArea goodsArea = goodsAreaService.getOne(queryWrapper); + if(null == goodsArea){ + //没有地区价格,则使用会员价格 + GoodsVip goodsVip = goodsVipService.getOne(new LambdaQueryWrapper<GoodsVip>().eq(GoodsVip::getGoodsId, goodsId).eq(GoodsVip::getVip, vip)); + if(null == goodsVip){ + //没有配置价格,直接使用原始基础价格 + return null; + }else{ + //构建价格数据 + if(goodsVip.getCashPayment() == 1 && goodsVip.getPointPayment() == 1){ + price.setCash(goodsVip.getSellingPrice()); + price.setPoint(goodsVip.getIntegral()); + } + if(goodsVip.getCashPayment() == 1 && goodsVip.getPointPayment() == 0){ + price.setCash(goodsVip.getSellingPrice()); + } + if(goodsVip.getCashPayment() == 0 && goodsVip.getPointPayment() == 1){ + price.setPoint(goodsVip.getIntegral()); + } + price.setCashPayment(goodsVip.getCashPayment() == 1); + price.setPointPayment(goodsVip.getPointPayment() == 1); + } + }else{ + //构建价格数据 + if(goodsArea.getCashPayment() == 1 && goodsArea.getPointPayment() == 1){ + price.setCash(goodsArea.getSellingPrice()); + price.setPoint(goodsArea.getIntegral()); + } + if(goodsArea.getCashPayment() == 1 && goodsArea.getPointPayment() == 0){ + price.setCash(goodsArea.getSellingPrice()); + } + if(goodsArea.getCashPayment() == 0 && goodsArea.getPointPayment() == 1){ + price.setPoint(goodsArea.getIntegral()); + } + price.setCashPayment(goodsArea.getCashPayment() == 1); + price.setPointPayment(goodsArea.getPointPayment() == 1); + } + }else{ + price.setCash(bargainPriceDetail.getSellingPrice()); + price.setPoint(bargainPriceDetail.getIntegral()); + price.setCashPayment(bargainPriceDetail.getSellingPrice() != null); + price.setPointPayment(bargainPriceDetail.getIntegral() != null); + } + }else{ + //构建价格数据 + if(goodsSeckill.getCashPayment() == 1 && goodsSeckill.getPointPayment() == 1){ + price.setCash(goodsSeckill.getSellingPrice()); + price.setPoint(goodsSeckill.getIntegral()); + } + if(goodsSeckill.getCashPayment() == 1 && goodsSeckill.getPointPayment() == 0){ + price.setCash(goodsSeckill.getSellingPrice()); + } + if(goodsSeckill.getCashPayment() == 0 && goodsSeckill.getPointPayment() == 1){ + price.setPoint(goodsSeckill.getIntegral()); + } + price.setCashPayment(goodsSeckill.getCashPayment() == 1); + price.setPointPayment(goodsSeckill.getPointPayment() == 1); + } + return price; + } } -- Gitblit v1.7.1