Administrator
2025-05-19 d3e9f57c91ffc08e090bf8d4b8fcbf60f0d3a86f
src/main/java/cc/mrbird/febs/vip/service/impl/VipCommonServiceImpl.java
@@ -150,6 +150,8 @@
        // 发送会员等级升级消息
        agentProducer.sendVipLevelUp(orderId);
        // 发送分销等级升级消息
        agentProducer.sendSaleLevelUp(orderId);
    }
@@ -160,6 +162,7 @@
     * @param orderId 订单ID
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void levelUp(Long orderId) {
        // 根据订单ID获取订单详细信息
        MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectOrderDetailsById(orderId);
@@ -214,9 +217,6 @@
        member.setDirector(code);
        // 更新会员信息
        mallMemberMapper.updateById(member);
        // 发送分销等级升级消息
        agentProducer.sendSaleLevelUp(orderId);
    }
    /**
@@ -225,6 +225,7 @@
     * @param orderId 订单ID,用于识别和处理特定的订单
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void saleLevelUp(Long orderId) {
        // 根据订单ID获取订单详细信息
        MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectOrderDetailsById(orderId);
@@ -301,10 +302,10 @@
        );
        // 更新会员钱包中的余额
        mallMemberWalletService.add(multiply, storeMasterMember.getId(), "commission");
        mallMemberWalletService.add(multiply, storeMasterMember.getId(), "total_score");
        mallMemberWalletService.add(multiply, storeMasterMember.getId(), "totalScore");
        MallAchieveRecord mallAchieveRecord = new MallAchieveRecord();
        mallAchieveRecord.setMemberId(mallOrderInfo.getMemberId());
        mallAchieveRecord.setMemberId(storeMasterMember.getId());
        mallAchieveRecord.setAchieveTime(new Date());
        mallAchieveRecord.setAmount(mallOrderInfo.getAmount());
        mallAchieveRecord.setCostAmount(multiply);