package cc.mrbird.febs.mall.service.impl; import cc.mrbird.febs.common.enumerates.DataDictionaryEnum; import cc.mrbird.febs.common.exception.FebsException; import cc.mrbird.febs.common.utils.AppContants; import cc.mrbird.febs.common.utils.LoginUserUtil; import cc.mrbird.febs.mall.conversion.MallGoodsConversion; import cc.mrbird.febs.mall.conversion.MallMemberConversion; import cc.mrbird.febs.mall.dto.ApiMallGoodsCommentDto; import cc.mrbird.febs.mall.dto.MallGoodsQueryDto; import cc.mrbird.febs.mall.entity.*; import cc.mrbird.febs.mall.mapper.*; import cc.mrbird.febs.mall.service.IApiMallGoodsService; import cc.mrbird.febs.mall.vo.*; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.checkerframework.checker.units.qual.A; import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; /** * @author wzy * @date 2021-09-17 **/ @Slf4j @Service @RequiredArgsConstructor public class ApiMallGoodsServiceImpl extends ServiceImpl implements IApiMallGoodsService { private final MallGoodsImagesMapper goodsImagesMapper; private final MallGoodsCommentMapper mallGoodsCommentMapper; private final DataDictionaryCustomMapper dataDictionaryCustomMapper; private final MallCarriageRuleMapper mallCarriageRuleMapper; private final MallCarriageRuleInfoMapper mallCarriageRuleInfoMapper; @Override public IPage findMallGoodsListInPage(MallGoodsQueryDto queryDto) { MallMember loginUser = LoginUserUtil.getLoginUser(); if (loginUser != null) { queryDto.setMemberId(loginUser.getId()); } Page page = new Page<>(queryDto.getPageNow(), queryDto.getPageSize()); IPage result = this.baseMapper.selectMallGoodsListQueryInPage(queryDto, page); LambdaQueryWrapper goodsQuery = new LambdaQueryWrapper<>(); goodsQuery.eq(MallGoods::getIsSale, 1) .eq(MallGoods::getIsNormal, 1) .orderByDesc(MallGoods::getVolume) .last("limit 10"); List mallGoods = this.baseMapper.selectList(goodsQuery); Map goodsMap = new HashMap<>(); AtomicInteger rank = new AtomicInteger(1); mallGoods.forEach(item -> { goodsMap.put(item.getId(), rank.getAndIncrement()); }); result.getRecords().forEach(item -> { Integer goodsRank = goodsMap.get(item.getId()); if (goodsRank != null) { item.setRank(goodsRank); } }); return result; } @Override public List findMallGoodsListNoPage(MallGoodsQueryDto queryDto) { return this.baseMapper.selectMallGoodsListQueryNoPage(queryDto); } @Override public ApiMallCarriageRuleVo findMallCarriageRuleById(Long id) { ApiMallCarriageRuleVo apiMallCarriageRuleVo = new ApiMallCarriageRuleVo(); MallCarriageRule mallCarriageRule = mallCarriageRuleMapper.selectById(id); if(ObjectUtil.isEmpty(mallCarriageRule)){ throw new FebsException("商品不存在"); } apiMallCarriageRuleVo.setName(mallCarriageRule.getName()); List mallCarriageRuleInfos = mallCarriageRuleInfoMapper.selectMallCarriageRuleInfoByRuleIdAndAreaAddress(id, null); if(CollUtil.isNotEmpty(mallCarriageRuleInfos)){ List apiMallCarriageRuleInfoVos = new ArrayList<>(); for(MallCarriageRuleInfo mallCarriageRuleInfo : mallCarriageRuleInfos){ ApiMallCarriageRuleInfoVo apiMallCarriageRuleInfoVo = new ApiMallCarriageRuleInfoVo(); apiMallCarriageRuleInfoVo.setAreaAddress(mallCarriageRuleInfo.getAreaAddress()); apiMallCarriageRuleInfoVo.setBasicPrice(mallCarriageRuleInfo.getBasicPrice()); apiMallCarriageRuleInfoVo.setBasicCnt(mallCarriageRuleInfo.getBasicCnt()); apiMallCarriageRuleInfoVo.setMoreCnt(mallCarriageRuleInfo.getMoreCnt()); apiMallCarriageRuleInfoVo.setMorePrice(mallCarriageRuleInfo.getMorePrice()); apiMallCarriageRuleInfoVos.add(apiMallCarriageRuleInfoVo); } apiMallCarriageRuleVo.setApiMallCarriageRuleInfoVos(apiMallCarriageRuleInfoVos); } return apiMallCarriageRuleVo; } @Override public MallGoodsDetailsVo findMallGoodsDetailsById(Long id) { MallGoods mallGoods = this.baseMapper.selectGoodsDetailById(id); if (mallGoods == null) { throw new FebsException("商品不存在"); } List images = goodsImagesMapper.selectGoodsImagesByGoodsId(mallGoods.getId()); MallGoodsDetailsVo mallGoodsDetailsVo = MallGoodsConversion.INSTANCE.entityToDetailsVo(mallGoods); List styles = mallGoodsDetailsVo.getStyles(); if(ObjectUtil.isNotEmpty(styles)){ for(GoodsDetailsStyleVo goodsDetailsStyleVo : styles){ List skus = goodsDetailsStyleVo.getSkus(); if(CollUtil.isNotEmpty(skus) ){ for(GoodsDetailsSkuVo goodsDetailsSkuVo : skus){ if(StrUtil.isNotEmpty(goodsDetailsSkuVo.getSample())){ goodsDetailsSkuVo.setSampleFlag(true); }else{ goodsDetailsSkuVo.setSampleFlag(false); } } } } } if (CollUtil.isNotEmpty(mallGoods.getStyles())) { Map stockAndVolume = this.baseMapper.selectGoodsStockAndVolume(id); mallGoodsDetailsVo.setStock(stockAndVolume.get("stock").intValue()); mallGoodsDetailsVo.setVolume(stockAndVolume.get("volume").intValue()); } mallGoodsDetailsVo.setImages(images); QueryWrapper objectQueryWrapper = new QueryWrapper<>(); objectQueryWrapper.eq("goods_id",id); Integer commentCount = mallGoodsCommentMapper.selectCount(objectQueryWrapper); mallGoodsDetailsVo.setCommentCount(commentCount); return mallGoodsDetailsVo; } @Override public IPage findMallGoodsCommentByGoodsId(ApiMallGoodsCommentDto queryDto) { Page page = new Page<>(queryDto.getPageNow(), queryDto.getPageSize()); MallGoodsComment mallGoodsComment = new MallGoodsComment(); mallGoodsComment.setGoodsId(queryDto.getGoodsId()); mallGoodsComment.setCommentType(queryDto.getCommentType()); return this.baseMapper.selectMallGoodsCommentListQueryInPage(page,mallGoodsComment); } @Override public ApiMallGoodsDeliveryVo findDeliverySetting() { ApiMallGoodsDeliveryVo apiMallGoodsDeliveryVo = new ApiMallGoodsDeliveryVo(); DataDictionaryCustom deliverySetting = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.HOME_DELIVERY_AMOUNT.getType(), DataDictionaryEnum.HOME_DELIVERY_AMOUNT.getCode()); if(ObjectUtil.isNotNull(deliverySetting)){ apiMallGoodsDeliveryVo.setHomeDeliveryServiceAmount(Double.parseDouble(deliverySetting.getValue())); } List homeDeliverySettings = dataDictionaryCustomMapper.selectDicByType(DataDictionaryEnum.FRIST_COST_LEVEL.getType()); if(CollUtil.isNotEmpty(homeDeliverySettings)){ List apiMallGoodsDeliverySettingVos = new ArrayList<>(); for(DataDictionaryCustom dic : homeDeliverySettings){ String apiMallGoodsDeliverySettingVoJson = dic.getValue(); ApiMallGoodsDeliverySettingVo apiMallGoodsDeliverySettingVo = JSONUtil.toBean(apiMallGoodsDeliverySettingVoJson, ApiMallGoodsDeliverySettingVo.class); apiMallGoodsDeliverySettingVos.add(apiMallGoodsDeliverySettingVo); } apiMallGoodsDeliveryVo.setApiMallGoodsDeliverySettingVos(apiMallGoodsDeliverySettingVos); } return apiMallGoodsDeliveryVo; } @Override public MallGoodsCommentVo findMallGoodsCommentLevelByGoodsId(Long id) { return this.baseMapper.findMallGoodsCommentLevelByGoodsId(id); } }