From 580fe843a333628795d619c5744a8353c44eb8ed Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 13 Feb 2025 11:31:53 +0800
Subject: [PATCH] feat(mall): 实现充值金额处理和唯一标识生成

---
 src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java |   15 +++++++++++++--
 1 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
index 39b108d..f5229f3 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
@@ -625,7 +625,11 @@
                 BigDecimal V3 = BigDecimal.ZERO;
                 if (flag) {
                     V2 = V1.divide(new BigDecimal("2"), 0, RoundingMode.DOWN);
-                    V3 = new BigDecimal(RandomUtil.randomInt(V2.intValue(),V1.intValue())).setScale(0,RoundingMode.DOWN);
+                    if(V1.intValue() <= V2.intValue()){
+                        V3 = new BigDecimal(RandomUtil.randomInt(V1.intValue(),V2.intValue()+1)).setScale(0,RoundingMode.DOWN);
+                    }else{
+                        V3 = new BigDecimal(RandomUtil.randomInt(V2.intValue(),V1.intValue())).setScale(0,RoundingMode.DOWN);
+                    }
                 }else{
                     List<MallMoneyFlow> mallMoneyFlows = mallMoneyFlowMapper.selectList(
                             new LambdaQueryWrapper<MallMoneyFlow>()
@@ -642,7 +646,13 @@
                     }else{
                         V2 = V1.multiply(new BigDecimal("2")).setScale(0,RoundingMode.DOWN);
                     }
-                    V3 = new BigDecimal(RandomUtil.randomInt(V1.intValue(),V2.intValue())).setScale(0,RoundingMode.DOWN);
+                    if(V1.intValue() < V2.intValue()){
+                        V3 = new BigDecimal(RandomUtil.randomInt(V1.intValue(),V2.intValue())).setScale(0,RoundingMode.DOWN);
+                    }else if(V1.intValue() == V2.intValue()){
+                        V3 = new BigDecimal(RandomUtil.randomInt(V1.intValue(),V2.intValue()+1)).setScale(0,RoundingMode.DOWN);
+                    }else{
+                        V3 = new BigDecimal(RandomUtil.randomInt(V2.intValue(),V1.intValue())).setScale(0,RoundingMode.DOWN);
+                    }
                 }
                 //会员权益的收益
                 RunVipGrow runVipGrow = runVipGrowMapper.selectList(
@@ -728,6 +738,7 @@
                     .collect(Collectors.toMap(MallMember::getId, member -> member));
             // 缓存直推成员
             Map<String, Set<MallMember>> directMembersCache = mallMembers.stream()
+                    .filter(member -> StrUtil.isNotBlank(member.getReferrerId()))
                     .collect(Collectors.groupingBy(MallMember::getReferrerId, Collectors.toSet()));
 
 

--
Gitblit v1.9.1