This commit is contained in:
aaron 2025-02-12 21:13:43 +08:00
parent 82ade7e0a8
commit df52173903

View File

@ -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