From 0a41407a35c47cba38c75f13eae69ebd49c0dfac Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Tue, 28 Sep 2021 17:29:28 +0800 Subject: [PATCH] fix agent auto level up --- src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java | 46 +++++++++++++++++++++++++++++++--------------- 1 files changed, 31 insertions(+), 15 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 5278912..9754aa7 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 @@ -1,5 +1,6 @@ package cc.mrbird.febs.mall.service.impl; +import cc.mrbird.febs.common.enumerates.AgentLevelEnum; import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum; import cc.mrbird.febs.common.enumerates.OrderRefundStatusEnum; import cc.mrbird.febs.common.enumerates.OrderStatusEnum; @@ -20,6 +21,7 @@ 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.service.IPayService; import cc.mrbird.febs.rabbit.producter.AgentProducer; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUnit; @@ -61,6 +63,7 @@ private final RedisUtils redisUtils; private final AgentProducer agentProducer; + private final IPayService payService; @Override @Transactional(rollbackFor = Exception.class) @@ -164,37 +167,53 @@ throw new FebsException("订单状态不能支付"); } - String orderNo = ""; + String payResultStr = ""; switch (payOrderDto.getType()) { case "1": - orderInfo.setPayOrderNo(payOrderDto.getPayOrderNo()); - orderInfo.setPayImage(payOrderDto.getPayImage()); +// orderInfo.setPayOrderNo(payOrderDto.getPayOrderNo()); +// orderInfo.setPayImage(payOrderDto.getPayImage()); orderInfo.setPayMethod("微信支付"); break; case "2": - orderInfo.setPayOrderNo(payOrderDto.getPayOrderNo()); - orderInfo.setPayImage(payOrderDto.getPayImage()); + if (StrUtil.isNotBlank(orderInfo.getPayOrderNo())) { + payResultStr = orderInfo.getPayOrderNo(); + } else { + payResultStr = payService.aliPay(orderInfo); + } + + orderInfo.setPayOrderNo(payResultStr); orderInfo.setPayMethod("支付宝支付"); break; case "3": - orderNo = balancePay(orderInfo, payOrderDto.getTradePwd()); + payResultStr = balancePay(orderInfo, payOrderDto.getTradePwd()); orderInfo.setPayOrderNo(orderInfo.getOrderNo()); orderInfo.setPayMethod("积分支付"); + orderInfo.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue()); + orderInfo.setPayTime(new Date()); + orderInfo.setPayResult("1"); + + MallMember mallMember = memberMapper.selectById(member.getId()); + if (AgentLevelEnum.ZERO_LEVEL.name().equals(mallMember.getLevel())) { + mallMember.setLevel(AgentLevelEnum.FIRST_LEVEL.name()); + memberMapper.updateById(mallMember); + } + + memberService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), null, null, null, null); + + agentProducer.sendAutoLevelUpMsg(member.getId()); + agentProducer.sendReturnMoneyMsg(orderInfo.getId()); default: } - orderInfo.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue()); - orderInfo.setPayTime(new Date()); - orderInfo.setPayResult("1"); this.baseMapper.updateById(orderInfo); - memberService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), null, null, null, null); - Map<String, Object> map = new HashMap<>(); - map.put("orderNo", orderNo); + map.put("orderInfo", payResultStr); + map.put("orderNo", orderInfo.getOrderNo()); map.put("orderId", orderInfo.getId()); + return map; } @@ -275,9 +294,6 @@ orderInfo.setStatus(OrderStatusEnum.FINISH.getValue()); orderInfo.setReceivingTime(new Date()); this.baseMapper.updateById(orderInfo); - - agentProducer.sendAutoLevelUpMsg(member.getId()); - agentProducer.sendReturnMoneyMsg(orderInfo.getId()); } @Override -- Gitblit v1.9.1