From a86cfc379cd61a01182942ca34fec0adcd330df0 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 10 Jan 2025 10:25:33 +0800 Subject: [PATCH] fix(mall): 修复优惠券满减逻辑 --- src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java | 301 ++++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 241 insertions(+), 60 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java index fa8da28..1ddb84c 100644 --- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java @@ -8,30 +8,28 @@ import cc.mrbird.febs.mall.conversion.MallGoodsCommentConversion; import cc.mrbird.febs.mall.conversion.MallOrderInfoConversion; import cc.mrbird.febs.mall.conversion.MallOrderRefundConversion; -import cc.mrbird.febs.mall.conversion.MallTeamLeaderConversion; import cc.mrbird.febs.mall.dto.*; import cc.mrbird.febs.mall.entity.*; import cc.mrbird.febs.mall.mapper.*; import cc.mrbird.febs.mall.service.*; -import cc.mrbird.febs.mall.vo.ApiLeaderListVo; +import cc.mrbird.febs.mall.vo.ApiCouponAmountMapVo; import cc.mrbird.febs.mall.vo.OrderDetailVo; import cc.mrbird.febs.mall.vo.OrderListVo; import cc.mrbird.febs.mall.vo.OrderRefundVo; import cc.mrbird.febs.pay.model.BrandWCPayRequestData; -import cc.mrbird.febs.pay.model.OrderStateDto; import cc.mrbird.febs.pay.service.IPayService; import cc.mrbird.febs.pay.service.IXcxPayService; import cc.mrbird.febs.pay.util.WeixinServiceUtil; import cc.mrbird.febs.rabbit.producter.AgentProducer; +import cc.mrbird.febs.vip.service.IMallVipConfigService; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUnit; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.crypto.SecureUtil; -import cn.hutool.json.JSONArray; -import cn.hutool.json.JSONObject; 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; @@ -44,7 +42,9 @@ import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; +import java.math.RoundingMode; import java.util.*; +import java.util.stream.Collectors; /** * @author wzy @@ -82,15 +82,18 @@ private final IApiMallTeamLeaderService iApiMallTeamLeaderService; private final IMallElectronicFenceService iMallElectronicFenceService; private final MallElectronicFenceMapper mallElectronicFenceMapper; + private final MallMemberCouponMapper mallMemberCouponMapper; + private final MallGoodsCouponMapper mallGoodsCouponMapper; + private final CouponGoodsMapper couponGoodsMapper; + + private final IMallVipConfigService mallVipConfigService; + private final MallActivityMapper mallActivityMapper; @Override @Transactional(rollbackFor = Exception.class) public Long createOrder(AddOrderDto addOrderDto) { - MallMember member = LoginUserUtil.getLoginUser(); - //验证用户的等级 -// if(AgentLevelEnum.ZERO_LEVEL.name().equals(member.getLevel())){ -// throw new FebsException("请先申请成为代理人"); -// } + Long memberId = LoginUserUtil.getLoginUser().getId(); + MallMember member = mallMemberMapper.selectById(memberId); //订单范围内才允许下单 MallAddressInfo address = mallAddressInfoMapper.selectAddressInfoByMemberIdAndId(member.getId(), addOrderDto.getAddressId()); @@ -113,6 +116,24 @@ this.baseMapper.insert(orderInfo); BigDecimal total = BigDecimal.ZERO; + /** + * 根据传入的优惠卷ID和商品明细集合计算出每个商品获取的实际支付金额 + */ + Map<Long, BigDecimal> couponAmountMap = new HashMap<>(); + MallMemberCoupon mallMemberCoupon = new MallMemberCoupon(); + if(ObjectUtil.isNotEmpty(addOrderDto.getMemberCouponId())){ + Long memberCouponId = addOrderDto.getMemberCouponId(); + mallMemberCoupon = mallMemberCouponMapper.selectById(memberCouponId); + if(ObjectUtil.isEmpty(mallMemberCoupon)){ + throw new FebsException(mallMemberCoupon.getCouponName()+"无法使用"); + } + Integer state = mallMemberCoupon.getState(); + if(1 != state){ + throw new FebsException(mallMemberCoupon.getCouponName()+"无法使用"); + } + List<AddOrderItemDto> items = addOrderDto.getItems(); + couponAmountMap = getCouponAmountMap(memberCouponId, items); + } for (AddOrderItemDto item : addOrderDto.getItems()) { MallOrderItem orderItem = new MallOrderItem(); @@ -139,6 +160,12 @@ orderItem.setSkuImage(mallGoods.getThumb()); orderItem.setState(1); + if (addOrderDto.getType() == 1) { + LambdaQueryWrapper<MallShoppingCart> delQuery = new LambdaQueryWrapper<>(); + delQuery.eq(MallShoppingCart::getGoodsId, item.getSkuId()) + .eq(MallShoppingCart::getMemberId, member.getId()); + mallShoppingCartMapper.delete(delQuery); + } total = total.add(amount); } else { MallGoodsSku sku = mallGoodsSkuMapper.selectSkuInfoById(item.getSkuId()); @@ -146,17 +173,17 @@ throw new FebsException("购买商品或sku不存在"); } - if("样品".equals(sku.getSample())){ - List<MallOrderItem> items = mallOrderItemMapper.selectItemBySkuIdUnCancel(sku.getId(), member.getId()); - if (CollUtil.isNotEmpty(items)) { - throw new FebsException("样品一个用户只能购买一次"); - } - Integer cnt = item.getCnt(); - if(1 < cnt){ - throw new FebsException("样品只能购买一件"); - } - - } +// if("样品".equals(sku.getSample())){ +// List<MallOrderItem> items = mallOrderItemMapper.selectItemBySkuIdUnCancel(sku.getId(), member.getId()); +// if (CollUtil.isNotEmpty(items)) { +// throw new FebsException("样品一个用户只能购买一次"); +// } +// Integer cnt = item.getCnt(); +// if(1 < cnt){ +// throw new FebsException("样品只能购买一件"); +// } +// +// } if (sku.getStock() < item.getCnt()) { throw new FebsException(sku.getSkuName() + "库存不足"); @@ -181,6 +208,17 @@ } BigDecimal amount = sku.getPresentPrice().multiply(BigDecimal.valueOf(item.getCnt())); + //是否使用优惠卷 + if(ObjectUtil.isNotEmpty(addOrderDto.getMemberCouponId())){ + Long memberCouponId = addOrderDto.getMemberCouponId(); + if(ObjectUtil.isNotEmpty(couponAmountMap.get(item.getSkuId()))){ + BigDecimal skuCouponAmount = couponAmountMap.get(item.getSkuId());//使用折扣卷后的应该支付的钱 + if(skuCouponAmount.compareTo(BigDecimal.ZERO) > 0){ + amount = skuCouponAmount; + } + orderItem.setMemberCouponId(memberCouponId); + } + } orderItem.setAmount(amount); orderItem.setCnt(item.getCnt()); orderItem.setOrderId(orderInfo.getId()); @@ -189,6 +227,13 @@ orderItem.setGoodsName(sku.getGoodsName()); orderItem.setSkuId(sku.getId()); orderItem.setState(1); + if(ObjectUtil.isNotEmpty(member.getReferrerId())){ + orderItem.setMemberInviteId(member.getReferrerId()); + } + if(ObjectUtil.isNotEmpty(addOrderDto.getMemberInviteId())){ + orderItem.setMemberInviteId(addOrderDto.getMemberInviteId()); + } + orderItem.setStyleName(sku.getStyleName()); orderItem.setSkuName(sku.getSkuName()); orderItem.setSkuImage(sku.getSkuImage()); @@ -207,6 +252,9 @@ } mallOrderItemMapper.insert(orderItem); } + + mallMemberCoupon.setState(2); + mallMemberCouponMapper.updateById(mallMemberCoupon); //运费 BigDecimal delivaryAmount = addOrderDto.getDeliveryAmount() == null ? BigDecimal.ZERO : addOrderDto.getDeliveryAmount(); orderInfo.setCarriage(delivaryAmount); @@ -230,6 +278,130 @@ return orderInfo.getId(); } + /** + * 根据传入的优惠卷ID和商品明细集合计算出每个商品获取的实际支付金额 + * @param memberCouponId 优惠卷ID + * @param items 商品明细 + * @return Map<Long,BigDecimal> skuId,实际支付金额 + */ + @Override + public Map<Long, BigDecimal> getCouponAmountMap(Long memberCouponId, List<AddOrderItemDto> items) { + HashMap<Long, BigDecimal> couponAmountMap = new HashMap<>(); + // 获取优惠券信息 + Optional<MallMemberCoupon> optionalMallMemberCoupon = Optional.ofNullable(mallMemberCouponMapper.selectById(memberCouponId)); + MallMemberCoupon mallMemberCoupon = optionalMallMemberCoupon.orElse(null); + + if (mallMemberCoupon == null || mallMemberCoupon.getState() != 1) { + return couponAmountMap; + } + + Set<Long> intersection = items.stream().map(AddOrderItemDto::getSkuId).collect(Collectors.toSet()); // 订单中的全部skuIds + + if (intersection.isEmpty()) { + return couponAmountMap; + } + + // 获取订单详情的ID和amount的map + Map<Long, AddOrderItemDto> itemMap = items.stream() + .collect(Collectors.toMap(AddOrderItemDto::getSkuId, item -> item)); + + List<MallGoodsSku> skus = mallGoodsSkuMapper.selectList( + new LambdaQueryWrapper<MallGoodsSku>() + .select(MallGoodsSku::getId, MallGoodsSku::getPresentPrice) + .in(MallGoodsSku::getId, intersection) + ); + BigDecimal totalAmount = BigDecimal.ZERO; + Map<Long, BigDecimal> skuMap = new HashMap<>(); + + for (MallGoodsSku mallGoodsSku : skus) { + Long id = mallGoodsSku.getId(); + BigDecimal presentPrice = mallGoodsSku.getPresentPrice(); + AddOrderItemDto addOrderItemDto = itemMap.get(id); + if (addOrderItemDto != null) { + BigDecimal skuAmount = presentPrice.multiply(BigDecimal.valueOf(addOrderItemDto.getCnt())); + totalAmount = totalAmount.add(skuAmount); + skuMap.put(id, skuAmount); + } + } + + // 计算每个商品利用优惠卷打折的具体金额 + Optional<MallGoodsCoupon> optionalMallGoodsCoupon = Optional.ofNullable(mallGoodsCouponMapper.selectById(mallMemberCoupon.getCouponId())); + MallGoodsCoupon mallGoodsCoupon = optionalMallGoodsCoupon.orElse(null); + if (mallGoodsCoupon == null) { + return couponAmountMap; + } + + BigDecimal costAmount = mallGoodsCoupon.getCostAmount(); + BigDecimal realAmount = mallGoodsCoupon.getRealAmount(); + Integer type = mallGoodsCoupon.getType(); + if (MallGoodsCoupon.TYPE_ONE == type) { + realAmount = mallGoodsCoupon.getRealAmount(); + } else if (MallGoodsCoupon.TYPE_TWO == type) { + BigDecimal divideTime = totalAmount.divide(costAmount, 0, RoundingMode.DOWN); // 累计减免次数 + realAmount = divideTime.multiply(realAmount); // 实际减免金额 + } + + if (totalAmount.compareTo(costAmount) < 0) { + return couponAmountMap; + } + + BigDecimal totalDiscount = BigDecimal.ZERO; + for (Map.Entry<Long, BigDecimal> entry : skuMap.entrySet()) { + Long keySkuId = entry.getKey(); + BigDecimal valueSkuAmount = entry.getValue(); + BigDecimal divide = valueSkuAmount.divide(totalAmount, 4, RoundingMode.DOWN); // 每个商品占符合满减的总额的比例 + BigDecimal skuRealAmount = BigDecimal.ZERO; + if (MallGoodsCoupon.TYPE_ONE == type) { + BigDecimal bigDecimalOne = realAmount.multiply(divide).setScale(2, RoundingMode.DOWN); // 每个SKU的减免金额(比例*减免金额) + skuRealAmount = valueSkuAmount.subtract(bigDecimalOne.max(BigDecimal.ZERO)).setScale(2, RoundingMode.DOWN); + totalDiscount = totalDiscount.add(bigDecimalOne); + } else if (MallGoodsCoupon.TYPE_TWO == type) { + BigDecimal divideTime = totalAmount.divide(costAmount, 0, RoundingMode.DOWN); // 累计减免次数 + BigDecimal multiply = divideTime.multiply(realAmount); // 实际减免金额 + BigDecimal bigDecimalTwo = multiply.multiply(divide).setScale(2, RoundingMode.DOWN); // 每个SKU的减免金额(比例*实际减免金额) + skuRealAmount = valueSkuAmount.subtract(bigDecimalTwo.max(BigDecimal.ZERO)).setScale(2, RoundingMode.DOWN); + totalDiscount = totalDiscount.add(bigDecimalTwo); + } + couponAmountMap.put(keySkuId, skuRealAmount); + } + + // 调整最后一个商品的减免金额以确保总减免金额达到预期 + if (totalDiscount.compareTo(realAmount) < 0) { + BigDecimal difference = realAmount.subtract(totalDiscount); + for (Map.Entry<Long, BigDecimal> entry : couponAmountMap.entrySet()) { + Long keySkuId = entry.getKey(); + BigDecimal skuRealAmount = entry.getValue(); + BigDecimal newSkuRealAmount = skuRealAmount.subtract(difference).setScale(2, RoundingMode.DOWN); + couponAmountMap.put(keySkuId, newSkuRealAmount); + break; // 调整最后一个商品的减免金额 + } + } + + return couponAmountMap; + } + + + public static void main(String[] args) { + List<Integer> a = new ArrayList<>(); + a.add(1); + a.add(2); + a.add(3); + List<Integer> b = new ArrayList<>(); + b.add(3); + b.add(4); + b.add(5); + boolean b1 = a.retainAll(b); + System.out.println(b1); + System.out.println(a); + System.out.println(b); + List<Integer> intersection = a.stream() + .filter(item -> b.contains(item)) + .collect(Collectors.toList()); + + System.out.println(intersection); + + } + @Override @Transactional(rollbackFor = Exception.class) @@ -248,7 +420,11 @@ orderInfo.setCancelType(MallOrderInfo.CANCEL_BY_SELF); this.baseMapper.updateById(orderInfo); - + if (orderInfo.getOrderType() == 2) { +// mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount(), MoneyFlowTypeEnum.REFUND.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.PRIZE_SCORE.getValue()); +// memberWalletService.add(orderInfo.getAmount(), member.getId(), "prizeScore"); + return; + } List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(orderInfo.getId()); if(CollUtil.isNotEmpty(mallOrderItemList)){ @@ -271,6 +447,12 @@ Integer skuResult = mallGoodsSkuMapper.updateStockAndVolumeBySkuId(sku.getId(),mallOrderItem.getCnt()); if(1 != skuResult){ throw new FebsException(sku.getSkuName() + "库存不足"); + } + Long memberCouponId = mallOrderItem.getMemberCouponId(); + MallMemberCoupon mallMemberCoupon = mallMemberCouponMapper.selectById(memberCouponId); + if(ObjectUtil.isNotEmpty(mallMemberCoupon)){ + mallMemberCoupon.setState(1); + mallMemberCouponMapper.updateById(mallMemberCoupon); } } } @@ -363,7 +545,9 @@ orderInfo.setPayResult("1"); orderInfo.setDeliveryState(OrderDeliveryStateEnum.DELIVERY_WAIT.getValue()); - mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue()); + mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue(),"余额支付",2); + + agentProducer.sendOrderCoupon(orderInfo.getId()); break; case "4": if (orderInfo.getOrderType() != 2) { @@ -377,7 +561,7 @@ orderInfo.setPayTime(new Date()); orderInfo.setPayResult("1"); - mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.PRIZE_SCORE.getValue()); + mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), ScoreFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.PRIZE_SCORE.getValue(), null, 2); break; default: @@ -388,22 +572,6 @@ this.baseMapper.updateById(orderInfo); - - -// OrderStateDto orderStateDto = new OrderStateDto(); -// orderStateDto.setOrderNo(orderInfo.getOrderNo()); -// String productNames = getProductNames(orderInfo.getMemberId(), orderInfo.getId()); -// orderStateDto.setGoodsName(StrUtil.isEmpty(productNames)?"商品":productNames); -// orderStateDto.setOrderState("已送达自提点"); -// orderStateDto.setTakeCode(orderInfo.getTakeCode()); -// String takeUniqueCode = orderInfo.getTakeUniqueCode(); -// MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByUniqueCode(takeUniqueCode); -// orderStateDto.setAddressArea(mallTeamLeader.getAddressArea()); -// orderStateDto.setOpenId(mallMemberMapper.selectById(orderInfo.getMemberId()).getOpenId()); -// DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WX_TEMPLATE_ID_ONE.getType(), DataDictionaryEnum.WX_TEMPLATE_ID_ONE.getCode()); -// orderStateDto.setTemplateId(dataDictionaryCustom.getValue()); -//// iXcxPayService.pushOrderToAddress(orderStateDto); -// iXcxPayService.uniformMessageSend(orderStateDto); Map<String, Object> map = new HashMap<>(); map.put("orderInfo", payResultStr); map.put("orderNo", orderInfo.getOrderNo()); @@ -427,7 +595,7 @@ throw new FebsException("支付密码错误"); } - int reduce = memberWalletService.reduce(orderInfo.getAmount().add(orderInfo.getCarriage()), mallMember.getId(), field); + int reduce = memberWalletService.reduce(orderInfo.getAmount(), mallMember.getId(), field); if (reduce == 2) { throw new FebsException("余额不足"); } @@ -458,6 +626,12 @@ // if (orderInfo == null || AppContants.DEL_FLAG_Y == orderInfo.getDelFlag()) { if (ObjectUtil.isNull(orderInfo)) { throw new FebsException("订单不存在"); + } + List<MallOrderItem> items = orderInfo.getItems(); + if(CollUtil.isNotEmpty(items)){ + for(MallOrderItem mallOrderItem : items){ + mallOrderItem.setItemAmount(mallOrderItemMapper.selectById(mallOrderItem.getId()).getAmount()); + } } OrderDetailVo orderDetailVo = MallOrderInfoConversion.INSTANCE.entityToDetailVo(orderInfo); @@ -508,7 +682,10 @@ orderInfo.setStatus(OrderStatusEnum.FINISH.getValue()); orderInfo.setReceivingTime(new Date()); this.baseMapper.updateById(orderInfo); - + //普通订单才产生积分,积分订单不产生积分 + if(1 == orderInfo.getOrderType()){ + agentProducer.sendGetScoreMsg(orderInfo.getId()); + } //生成一条团长提成记录 // Long orderInfoId = orderInfo.getId(); // List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(orderInfoId); @@ -782,6 +959,7 @@ apiLeaderRefundOrderDto.setOrderId(mallOrderInfo.getId()); apiLeaderRefundOrderDto.setItemId(mallOrderItem.getId()); apiLeaderRefundOrderDto.setAgreeState(1); + apiLeaderRefundOrderDto.setAgreeType(1); iApiMallTeamLeaderService.leaderRefundOrder(apiLeaderRefundOrderDto); } return new FebsResponse().success(); @@ -851,22 +1029,6 @@ if (sku == null) { return new FebsResponse().fail().message("购买商品或sku不存在"); } - if("样品".equals(sku.getSample())){ - List<MallOrderItem> mallOrderItems = mallOrderItemMapper.selectItemBySkuIdUnCancel(sku.getId(), member.getId()); - if (CollUtil.isNotEmpty(mallOrderItems)) { - return new FebsResponse().fail().message("样品只能购买一次"); - } - Integer cnt = item.getCnt(); - if(1 < cnt){ - return new FebsResponse().fail().message("样品只能购买一件"); - } - }else{ - //验证用户的等级 - if(AgentLevelEnum.ZERO_LEVEL.name().equals(member.getLevel())){ - return new FebsResponse().fail().message("请先申请成为代理人"); - } - } - if (sku.getStock() < item.getCnt()) { return new FebsResponse().fail().message(sku.getSkuName() + "库存不足"); } @@ -875,13 +1037,32 @@ if (MallGoods.ISSALE_STATUS_DISABLED.equals(mallGoods.getIsSale())) { return new FebsResponse().fail().message(mallGoods.getGoodsName() + "已下架"); } + if(GoodsTypeEnum.HUO_DONG.getValue() == mallGoods.getIsNormal()){ + //活动商品判断是否在活动进行中 + MallActivity mallActivity = mallActivityMapper.selectById(mallGoods.getActivityId()); + if(mallActivity == null || mallActivity.getState() != 2){ + return new FebsResponse().fail().message("活动不在进行中"); + } + } + } return new FebsResponse().success(); } - public static void main(String[] args) { - System.out.print(AgentLevelEnum.ZERO_LEVEL.name()); + @Override + public FebsResponse chooseCoupon(ApiChooseCouponDto chooseCouponDto) { + Map<Long, BigDecimal> couponAmountMap = getCouponAmountMap(chooseCouponDto.getMemberCouponId(), chooseCouponDto.getItems()); + ArrayList<ApiCouponAmountMapVo> objects = new ArrayList<>(); + for (Map.Entry<Long,BigDecimal> entry : couponAmountMap.entrySet()) { + Long keySkuId = entry.getKey(); + BigDecimal valueSkuAmount = entry.getValue(); + ApiCouponAmountMapVo apiCouponAmountMapVo = new ApiCouponAmountMapVo(); + apiCouponAmountMapVo.setId(keySkuId); + apiCouponAmountMapVo.setAmount(valueSkuAmount); + objects.add(apiCouponAmountMapVo); + } + return new FebsResponse().success().data(objects); } } -- Gitblit v1.9.1