From df52173903a0abd50a4cf119c6ecae1a0cbeb7b9 Mon Sep 17 00:00:00 2001
From: aaron <>
Date: Wed, 12 Feb 2025 21:13:43 +0800
Subject: [PATCH] 111

---
 app/api/endpoints/wechat.py | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/app/api/endpoints/wechat.py b/app/api/endpoints/wechat.py
index 885892f..5e887d9 100644
--- a/app/api/endpoints/wechat.py
+++ b/app/api/endpoints/wechat.py
@@ -246,9 +246,11 @@ async def payment_notify(
                 return error_response(code=404, message="订单不存在")
             
             if trade_state_desc == "支付成功":
-                # 添加积分
-                point_manager = PointManager(db)
-                point_manager.add_points(order.user_id, order.gift_points, PointRecordType.CONSUME_RETURN, f"团购订单奖励", order.order_id)
+
+                if order.gift_points > 0:
+                    # 添加积分
+                    point_manager = PointManager(db)
+                    point_manager.add_points(order.user_id, order.gift_points, PointRecordType.CONSUME_RETURN, f"团购订单奖励", order.order_id)
 
                 # 更新订单状态
                 order.pay_status = True
@@ -268,9 +270,10 @@ async def payment_notify(
                 return error_response(code=404, message="订单不存在")
             
             if trade_state_desc == "支付成功":
-                # 添加积分
-                point_manager = PointManager(db)
-                point_manager.add_points(order.MerchantPayOrderDB.user_id, order.MerchantPayOrderDB.gift_points, PointRecordType.CONSUME_RETURN, f"买单订单奖励", order.MerchantPayOrderDB.order_id)
+                if order.MerchantPayOrderDB.gift_points > 0:
+                    # 添加积分
+                    point_manager = PointManager(db)
+                    point_manager.add_points(order.MerchantPayOrderDB.user_id, order.MerchantPayOrderDB.gift_points, PointRecordType.CONSUME_RETURN, f"买单订单奖励", order.MerchantPayOrderDB.order_id)
 
                 # 更新订单状态
                 order.MerchantPayOrderDB.pay_status = True