| | |
| | | |
| | | // 发送会员等级升级消息 |
| | | agentProducer.sendVipLevelUp(orderId); |
| | | // 发送分销等级升级消息 |
| | | agentProducer.sendSaleLevelUp(orderId); |
| | | } |
| | | |
| | | |
| | |
| | | * @param orderId 订单ID |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void levelUp(Long orderId) { |
| | | // 根据订单ID获取订单详细信息 |
| | | MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectOrderDetailsById(orderId); |
| | |
| | | member.setDirector(code); |
| | | // 更新会员信息 |
| | | mallMemberMapper.updateById(member); |
| | | |
| | | // 发送分销等级升级消息 |
| | | agentProducer.sendSaleLevelUp(orderId); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @param orderId 订单ID,用于识别和处理特定的订单 |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void saleLevelUp(Long orderId) { |
| | | // 根据订单ID获取订单详细信息 |
| | | MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectOrderDetailsById(orderId); |
| | |
| | | ); |
| | | // 更新会员钱包中的余额 |
| | | 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); |