fix

Helius

2024-02-19 60f2bee16b7431d6badf492df9047fb1cde520fc

fix

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

@@ -28,7 +28,10 @@

import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Handler;
import java.util.stream.Collectors;

@Slf4j
@@ -70,16 +73,29 @@
        mallMoneyFlowService.addMoneyFlow(memberId, new BigDecimal(score), ScoreFlowTypeEnum.BUY.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.PRIZE_SCORE.getValue(), CollUtil.join(skuNames, ","), 2);
        mallMemberWalletService.add(new BigDecimal(score), memberId, "prizeScore");

        agentProducer.sendVipLevelUp(orderId);
        if (StrUtil.isNotBlank(mallOrderInfo.getTakeCode())) {
            MallMember mallMember = mallMemberMapper.selectInfoByInviteId(mallOrderInfo.getTakeCode());
        Map<Long, BigDecimal> recommendScoreMap = new HashMap<>();
        mallOrderInfo.getItems().forEach(item -> {
            if (StrUtil.isNotBlank(item.getMemberInviteId())) {
                MallMember mallMember = mallMemberMapper.selectInfoByInviteId(item.getMemberInviteId());
            if (mallMember == null) {
                return;
            }

            mallMoneyFlowService.addMoneyFlow(mallMember.getId(), new BigDecimal(score), ScoreFlowTypeEnum.RECOMMEND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.PRIZE_SCORE.getValue(), CollUtil.join(skuNames, ","), 2);
            mallMemberWalletService.add(new BigDecimal(score), mallMember.getId(), "prizeScore");
                BigDecimal recommendScore = recommendScoreMap.get(mallMember.getId());
                if (recommendScore != null) {
                    recommendScore = recommendScore.add(item.getAmount());
        }

                recommendScoreMap.put(mallMember.getId(), recommendScore);
            }
        });

        recommendScoreMap.forEach((key, value) -> {
            mallMoneyFlowService.addMoneyFlow(key, value, ScoreFlowTypeEnum.RECOMMEND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.PRIZE_SCORE.getValue(), CollUtil.join(skuNames, ","), 2);
            mallMemberWalletService.add(new BigDecimal(score), key, "prizeScore");
        });

        agentProducer.sendVipLevelUp(orderId);
    }

    @Override