From 959bd76c3dd17ff7cb0b492c7568b8b54c09dee2 Mon Sep 17 00:00:00 2001 From: Hentua <wangdoubleone@gmail.com> Date: Mon, 29 Jan 2024 23:42:27 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java | 190 ++++++++++++++++++++++++++++++++--------------- 1 files changed, 130 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 3101140..e7aa9be 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 @@ -23,6 +23,8 @@ 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.IMallVipConfigBenefitsService; +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; @@ -32,6 +34,7 @@ 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; @@ -45,6 +48,7 @@ import java.math.BigDecimal; import java.util.*; +import java.util.stream.Collectors; /** * @author wzy @@ -82,12 +86,19 @@ 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; @Override @Transactional(rollbackFor = Exception.class) public Long createOrder(AddOrderDto addOrderDto) { - MallMember member = LoginUserUtil.getLoginUser(); - //验证用户的等级 + Long memberId = LoginUserUtil.getLoginUser().getId(); + MallMember member = mallMemberMapper.selectById(memberId); + + //验证用户的等级 // if(AgentLevelEnum.ZERO_LEVEL.name().equals(member.getLevel())){ // throw new FebsException("请先申请成为代理人"); // } @@ -139,6 +150,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 +163,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 +198,53 @@ } BigDecimal amount = sku.getPresentPrice().multiply(BigDecimal.valueOf(item.getCnt())); + //是否使用优惠卷 + if(ObjectUtil.isNotEmpty(addOrderDto.getMemberCouponId())){ + Long memberCouponId = addOrderDto.getMemberCouponId(); + MallMemberCoupon 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()+"无法使用"); + } + //卷是否和商品绑定 + Long skuGoodsId = sku.getGoodsId(); + Long couponId = mallMemberCoupon.getCouponId(); + MallGoodsCoupon mallGoodsCoupon = mallGoodsCouponMapper.selectById(mallMemberCoupon.getCouponId()); + if(ObjectUtil.isEmpty(mallGoodsCoupon)){ + throw new FebsException(mallGoodsCoupon.getName()+"无法使用"); + } + Integer stateCoupon = mallGoodsCoupon.getState(); + if(2 != stateCoupon){ + throw new FebsException(mallGoodsCoupon.getName()+"无法使用"); + } + List<CouponGoods> couponGoods = couponGoodsMapper.selectByGoodIdAndCouponId(skuGoodsId, couponId); + if(ObjectUtil.isEmpty(couponGoods)){ + throw new FebsException(sku.getGoodsName()+"无法使用"+mallMemberCoupon.getCouponName()); + } +// Long goodsId = mallMemberCoupon.getGoodsId(); +// if(goodsId != sku.getGoodsId()){ +// throw new FebsException(sku.getGoodsName()+"无法使用"+mallMemberCoupon.getCouponName()); +// } + BigDecimal costAmount = mallGoodsCoupon.getCostAmount(); + BigDecimal realAmount = mallGoodsCoupon.getRealAmount(); + if(amount.compareTo(costAmount) >= 0){ + Integer type = mallGoodsCoupon.getType(); + if(MallGoodsCoupon.TYPE_TWO == type){ + BigDecimal divideTime = amount.divide(costAmount, 0, BigDecimal.ROUND_DOWN);//累计减免次数 + BigDecimal multiply = divideTime.multiply(realAmount);//实际减免金额 + amount = (amount.subtract(multiply).compareTo(BigDecimal.ZERO) > 0 ? amount.subtract(multiply) : BigDecimal.ZERO); + } + if(MallGoodsCoupon.TYPE_ONE == type){ + amount = (amount.subtract(realAmount).compareTo(BigDecimal.ZERO) > 0 ? amount.subtract(realAmount) : BigDecimal.ZERO); + } + orderItem.setMemberCouponId(memberCouponId); + mallMemberCoupon.setState(2); + mallMemberCouponMapper.updateById(mallMemberCoupon); + } + } orderItem.setAmount(amount); orderItem.setCnt(item.getCnt()); orderItem.setOrderId(orderInfo.getId()); @@ -189,6 +253,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()); @@ -225,9 +296,15 @@ orderInfo.setLatitude(address.getLatitude()); orderInfo.setLongitude(address.getLongitude()); this.baseMapper.updateById(orderInfo); - - agentProducer.sendOrderCancelDelayMsg(orderInfo.getId(), 15 * 60 * 1000L); + //过期时间修改成24小时 + agentProducer.sendOrderCancelDelayMsg(orderInfo.getId(), 24 * 60 * 60 * 1000L); return orderInfo.getId(); + } + + public static void main(String[] args) { + BigDecimal bigDecimal = new BigDecimal(980); + BigDecimal divide = bigDecimal.divide(new BigDecimal(100), 0, BigDecimal.ROUND_DOWN); + System.out.println(divide); } @@ -248,7 +325,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 +352,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 +450,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 +466,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 +477,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 +500,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("余额不足"); } @@ -462,11 +535,11 @@ OrderDetailVo orderDetailVo = MallOrderInfoConversion.INSTANCE.entityToDetailVo(orderInfo); -// if (orderInfo.getStatus() == OrderStatusEnum.WAIT_FINISH.getValue()) { -// MallExpressInfo expressInfo = expressInfoMapper.selectByOrderId(orderInfo.getId()); -// orderDetailVo.setExpressNo(expressInfo.getExpressNo()); -// orderDetailVo.setExpressCom(expressInfo.getExpressCom()); -// } + MallExpressInfo expressInfo = expressInfoMapper.selectByOrderId(orderInfo.getId()); + if(ObjectUtil.isNotEmpty(expressInfo)){ + orderDetailVo.setExpressNo(expressInfo.getExpressNo()); + orderDetailVo.setExpressCom(expressInfo.getExpressCom()); + } if (orderInfo.getStatus() == OrderStatusEnum.REFUNDING.getValue() || orderInfo.getStatus() == OrderStatusEnum.REFUNDED.getValue()) { MallOrderRefund orderRefund = mallOrderRefundMapper.selectOrderRefundByOrderId(orderInfo.getId()); @@ -475,7 +548,7 @@ } if (OrderStatusEnum.WAIT_PAY.getValue() == orderInfo.getStatus()) { - Date endTime = DateUtil.offsetMinute(orderInfo.getOrderTime(), 15); + Date endTime = DateUtil.offsetMinute(orderInfo.getOrderTime(), 1440); long remainTime = DateUtil.between(new Date(), endTime, DateUnit.SECOND, false); orderDetailVo.setRemainTime(remainTime); @@ -509,6 +582,7 @@ orderInfo.setReceivingTime(new Date()); this.baseMapper.updateById(orderInfo); + agentProducer.sendGetScoreMsg(orderInfo.getId()); //生成一条团长提成记录 // Long orderInfoId = orderInfo.getId(); // List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(orderInfoId); @@ -851,21 +925,21 @@ 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("样品".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() + "库存不足"); @@ -878,10 +952,6 @@ } return new FebsResponse().success(); - } - - public static void main(String[] args) { - System.out.print(AgentLevelEnum.ZERO_LEVEL.name()); } } -- Gitblit v1.9.1