From 9cbe81df411d8fcbef24077d55c15da1792bf3d0 Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Thu, 11 Dec 2025 17:15:50 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8B=E5=8D=95=E8=B5=A0=E9=80=81=E7=A7=AF?=
 =?UTF-8?q?=E5=88=86=200=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/market/service/impl/MkPointsConfigServiceImpl.java | 3 +++
 .../service/market/service/impl/MkPointsUserServiceImpl.java   | 3 +++
 2 files changed, 6 insertions(+)

diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkPointsConfigServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkPointsConfigServiceImpl.java
index a12af81d2..16c63cdb8 100644
--- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkPointsConfigServiceImpl.java
+++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkPointsConfigServiceImpl.java
@@ -59,6 +59,9 @@ public class MkPointsConfigServiceImpl extends ServiceImpl<MkPointsConfigMapper,
             }
         }
         BigDecimal awardPoints = NumberUtil.roundDown(NumberUtil.div(payAmount, consumeAmount), 0);
+        if (awardPoints.compareTo(BigDecimal.ZERO) <= 0) {
+            return;
+        }
         mkPointsUserService.alterPoints(null, shopUser.getId(), orderInfo.getShopId(), PointsConstant.ADD,
                 awardPoints.intValue(), orderInfo.getId(), StrUtil.format("消费￥{}送{}积分", payAmount, awardPoints.intValue()));
     }
diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkPointsUserServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkPointsUserServiceImpl.java
index b7b56b9aa..aa3ca39fe 100644
--- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkPointsUserServiceImpl.java
+++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkPointsUserServiceImpl.java
@@ -116,6 +116,9 @@ public class MkPointsUserServiceImpl extends ServiceImpl<MkPointsUserMapper, MkP
 
     @Override
     public Long alterPoints(Long userId, Long shopUserId, Long shopId, PointsConstant floatType, Integer points, Long sourceId, String reason) {
+        if (points <= 0) {
+            return null;
+        }
         MkPointsUser pointsUser = getPointsUser(shopId, shopUserId, userId);
         if (floatType == null) {
             throw new CzgException("积分变动类型不能为空");