From f9ec733f074b2b5fdb7b6174779fd2822c2b386d Mon Sep 17 00:00:00 2001
From: xupei <xupei3360@163.com>
Date: Tue, 26 Aug 2025 11:53:53 +0800
Subject: [PATCH] =?UTF-8?q?BUGFIX:=20=E7=BC=96=E8=BE=91referral=E7=8A=B6?=
 =?UTF-8?q?=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/ai/da/service/impl/ReferralServiceImpl.java  | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/ai/da/service/impl/ReferralServiceImpl.java b/src/main/java/com/ai/da/service/impl/ReferralServiceImpl.java
index 6f53092d..a3fa69cd 100644
--- a/src/main/java/com/ai/da/service/impl/ReferralServiceImpl.java
+++ b/src/main/java/com/ai/da/service/impl/ReferralServiceImpl.java
@@ -21,10 +21,7 @@ import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.time.YearMonth;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 
 @Slf4j
 @Service
@@ -91,6 +88,7 @@ public class ReferralServiceImpl extends ServiceImpl<ReferralMapper, Referral> i
             BigDecimal unpaid = baseMapper.sumAmount(referral.getAffiliateId(), Collections.singletonList("Unpaid"), null, null);
 
             // 已支付和未支付的值肯定是同时发生变化
+            unpaid = Objects.isNull(unpaid) ? BigDecimal.ZERO : unpaid;
             if (BigDecimal.valueOf(affiliate.getUnpaidEarnings()).compareTo(unpaid) != 0){
                 LocalDateTime start = YearMonth.now().atDay(1).atStartOfDay();          // 本月第一天 00:00:00
                 LocalDateTime end = YearMonth.now().atEndOfMonth().atTime(23, 59, 59);
@@ -98,7 +96,7 @@ public class ReferralServiceImpl extends ServiceImpl<ReferralMapper, Referral> i
                 BigDecimal monthlyEarning = baseMapper.sumAmount(referral.getAffiliateId(), Arrays.asList("Unpaid", "Paid"), start, end);
                 // 在平台的总收入
                 BigDecimal totalEarning = baseMapper.sumAmount(referral.getAffiliateId(), Arrays.asList("Unpaid", "Paid"), null, null);
-                affiliate.setUnpaidEarnings(Objects.nonNull(unpaid) ? unpaid.floatValue() : 0);
+                affiliate.setUnpaidEarnings(unpaid.floatValue());
                 affiliate.setMonthlyEarnings(Objects.nonNull(monthlyEarning) ? monthlyEarning.floatValue() : 0);
                 affiliate.setTotalEarnings(Objects.nonNull(totalEarning) ? totalEarning.floatValue() : 0);
                 affiliate.setUpdateTime(LocalDateTime.now());