refactor(vip): 优化会员等级升级逻辑

Administrator

2025-05-20 ed7884ad03acda123fdf09c658119d5907e7d24d

refactor(vip): 优化会员等级升级逻辑

- 移除重复的会员等级升级消息发送逻辑
- 修复推荐人会员等级升级消息发送问题
- 优化导演等级更新逻辑，避免降级情况
- 删除不必要的订单信息查询和状态判断

 src/main/java/cc/mrbird/febs/vip/service/impl/VipCommonServiceImpl.java

@@ -139,6 +139,8 @@
                );
                // 更新会员钱包中的分数
                mallMemberWalletService.add(multiply, memberId, "score");
                // 发送会员等级升级消息
                agentProducer.sendVipLevelUp(memberId);
            }
            // 计算推荐人获得的积分
            if(StrUtil.isNotEmpty(member.getReferrerId())){
@@ -170,12 +172,12 @@
                    );
                    // 更新会员钱包中的分数
                    mallMemberWalletService.add(multiply, refMember.getId(), "score");
                    // 发送会员等级升级消息
                    agentProducer.sendVipLevelUp(refMember.getId());
                }
            }
        }

        // 发送会员等级升级消息
        agentProducer.sendVipLevelUp(orderId);
        // 发送分销等级升级消息
        agentProducer.sendSaleLevelUp(orderId);
    }
@@ -190,20 +192,8 @@
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void levelUp(Long orderId) {
        // 根据订单ID获取订单详细信息
        MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectOrderDetailsById(orderId);
        // 如果订单信息为空，则直接返回
        if (mallOrderInfo == null) {
            return;
        }
        // 如果订单状态不是完成状态，则直接返回
        if (mallOrderInfo.getStatus() != OrderStatusEnum.FINISH.getValue()) {
            // 订单不是完成状态
            return;
        }

        // 根据订单中的会员ID获取会员信息
        MallMember member = mallMemberMapper.selectById(mallOrderInfo.getMemberId());
        MallMember member = mallMemberMapper.selectById(orderId);
        // 如果会员信息为空，则记录日志并返回
        if (member == null) {
            log.info("会员不存在");
@@ -238,6 +228,9 @@
        if(member.getDirector() == code){
            return;
        }
        if(member.getDirector() > code){
            return;
        }

        // 更新会员的导演等级为当前会员等级代码
        member.setDirector(code);