From d3e9f57c91ffc08e090bf8d4b8fcbf60f0d3a86f Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Mon, 19 May 2025 17:45:15 +0800 Subject: [PATCH] feat(mall): 添加会员等级当前进度相关数据 --- src/main/java/cc/mrbird/febs/vip/service/impl/VipCommonServiceImpl.java | 11 ++++++----- 1 files changed, 6 insertions(+), 5 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/vip/service/impl/VipCommonServiceImpl.java b/src/main/java/cc/mrbird/febs/vip/service/impl/VipCommonServiceImpl.java index 75c1f27..1740893 100644 --- a/src/main/java/cc/mrbird/febs/vip/service/impl/VipCommonServiceImpl.java +++ b/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); -- Gitblit v1.9.1