From acc65c35a1b7f5b823f2d45aa7da2f83fce7ad89 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?=
 <8605635+zhang3064194730@user.noreply.gitee.com>
Date: Wed, 29 Oct 2025 13:58:59 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=86=E9=94=80=E9=85=8D=E7=BD=AE=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/MkDistributionLevelConfigServiceImpl.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionLevelConfigServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionLevelConfigServiceImpl.java
index 761d1654c..196acea65 100644
--- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionLevelConfigServiceImpl.java
+++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionLevelConfigServiceImpl.java
@@ -10,6 +10,7 @@ import com.czg.service.market.mapper.MkDistributionLevelConfigMapper;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
+import java.util.Objects;
 
 /**
  * 分销员等级配置 服务层实现。
@@ -26,7 +27,8 @@ public class MkDistributionLevelConfigServiceImpl extends ServiceImpl<MkDistribu
             remove(new QueryWrapper().eq(MkDistributionLevelConfig::getDistributionConfigId, id));
             return;
         }else {
-            remove(new QueryWrapper().eq(MkDistributionLevelConfig::getDistributionConfigId, id).notIn(MkDistributionLevelConfig::getId, levelConfigList.stream().map(MkDistributionLevelConfigDTO::getId).toList()));
+            remove(new QueryWrapper().eq(MkDistributionLevelConfig::getDistributionConfigId, id)
+                    .notIn(MkDistributionLevelConfig::getId, levelConfigList.stream().map(MkDistributionLevelConfigDTO::getId).filter(Objects::nonNull).toList()));
         }
 
         int level = 1;