feat(mall): 添加商品佣金设置并调整相关功能

Administrator

2025-05-22 ff55c5334fc35594d2f0c680c29afd309cf367a2

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

@@ -42,6 +42,7 @@
public class VipCommonServiceImpl implements IVipCommonService {

    private final MallOrderInfoMapper mallOrderInfoMapper;
    private final MallOrderItemMapper mallOrderItemMapper;
    private final IMallVipConfigService mallVipConfigService;
    private final IMallMoneyFlowService mallMoneyFlowService;
    private final IApiMallMemberWalletService mallMemberWalletService;
@@ -127,7 +128,7 @@
                mallMemberWalletService.add(mineScore,memberId , "prizeScore");

                // 记录会员购买获得的经验
                BigDecimal multiply = amount.multiply(minePercent);
                BigDecimal multiply = amount.multiply(minePercent).setScale(2, RoundingMode.HALF_DOWN);
                mallMoneyFlowService.addMoneyFlow(
                        memberId,
                        multiply,
@@ -139,6 +140,8 @@
                );
                // 更新会员钱包中的分数
                mallMemberWalletService.add(multiply, memberId, "score");
                // 发送会员等级升级消息
                agentProducer.sendVipLevelUp(memberId);
            }
            // 计算推荐人获得的积分
            if(StrUtil.isNotEmpty(member.getReferrerId())){
@@ -158,7 +161,7 @@
                    mallMemberWalletService.add(otherScore,refMember.getId() , "prizeScore");

                    // 记录会员购买获得的经验
                    BigDecimal multiply = amount.multiply(otherPercent);
                    BigDecimal multiply = amount.multiply(otherPercent).setScale(2, RoundingMode.HALF_DOWN);
                    mallMoneyFlowService.addMoneyFlow(
                            refMember.getId(),
                            multiply,
@@ -170,12 +173,12 @@
                    );
                    // 更新会员钱包中的分数
                    mallMemberWalletService.add(multiply, refMember.getId(), "score");
                    // 发送会员等级升级消息
                    agentProducer.sendVipLevelUp(refMember.getId());
                }
            }
        }

        // 发送会员等级升级消息
        agentProducer.sendVipLevelUp(orderId);
        // 发送分销等级升级消息
        agentProducer.sendSaleLevelUp(orderId);
    }
@@ -190,20 +193,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("会员不存在");
@@ -236,6 +227,9 @@
        Integer code = happyMemberLevel.getCode();
        // 如果当前会员等级与会员的导演等级相同，则直接返回
        if(member.getDirector() == code){
            return;
        }
        if(member.getDirector() > code){
            return;
        }

@@ -286,7 +280,7 @@
                        .eq(MallMember::getAccountStatus, MallMember.ACCOUNT_STATUS_ENABLE)
                        .eq(MallMember::getAccountType, MallMember.ACCOUNT_TYPE_NORMAL)
                        .ne(MallMember::getStoreMaster, 0)
                .orderByAsc(MallMember::getStoreMaster)
                .orderByDesc(MallMember::getId)
                .last("limit 1")
        );
        // 如果没有找到符合条件的团长，则记录日志并返回
@@ -305,15 +299,24 @@
            return;
        }
        // 计算返佣金额
        List<MallOrderItem> mallOrderItems = mallOrderItemMapper.selectList(
                new LambdaQueryWrapper<MallOrderItem>()
                        .eq(MallOrderItem::getOrderId, orderId)
                        .eq(MallOrderItem::getState, 1)
        );
        if(CollUtil.isEmpty(mallOrderItems)){
            return;
        }
        BigDecimal amount = mallOrderItems.stream().map(MallOrderItem::getLevelOnePrice).reduce(BigDecimal.ZERO, BigDecimal::add);
        BigDecimal returnPercent = happySaleLevel.getReturnPercent();
        BigDecimal multiply = mallOrderInfo.getAmount().multiply(returnPercent).setScale(2, RoundingMode.HALF_DOWN);
        BigDecimal multiply = amount.multiply(returnPercent).setScale(2, RoundingMode.HALF_DOWN);
        log.info("团长获得返佣：{}",multiply);
        // 如果返佣金额小于等于0，则直接返回
        if(BigDecimal.ZERO.compareTo(multiply) >=0){
            return;
        }
        // 如果返佣金额大于等于订单金额，则直接返回
        if(multiply.compareTo(mallOrderInfo.getAmount()) >= 0){
        if(multiply.compareTo(amount) > 0){
            return;
        }
        // 记录团长获得返佣