diff --git a/backend/app/routers/user_order.py b/backend/app/routers/user_order.py index 39203f2..24e8ddd 100644 --- a/backend/app/routers/user_order.py +++ b/backend/app/routers/user_order.py @@ -297,28 +297,28 @@ async def wxpay_notify(request: Request): # 获取数据库连接 - connection = get_connection() - cursor = connection.cursor(dictionary=True) - - # 查询订单并锁定 - cursor.execute(""" - SELECT order_id, payable_price - FROM orders - WHERE out_trade_no = %s - FOR UPDATE""", (out_trade_no,)) - order = cursor.fetchone() - - cursor.execute(""" - UPDATE orders SET - order_status = 'completed', - payment_method = 'wechat', - wx_transaction_id = %s, - settlement_time = NOW() - WHERE order_id = %s""", - (transaction_id, order['order_id'])) - - - connection.commit() + # connection = get_connection() + # cursor = connection.cursor(dictionary=True) + # + # # 查询订单并锁定 + # cursor.execute(""" + # SELECT order_id, payable_price + # FROM orders + # WHERE out_trade_no = %s + # FOR UPDATE""", (out_trade_no,)) + # order = cursor.fetchone() + # + # cursor.execute(""" + # UPDATE orders SET + # order_status = 'completed', + # payment_method = 'wechat', + # wx_transaction_id = %s, + # settlement_time = NOW() + # WHERE order_id = %s""", + # (transaction_id, order['order_id'])) + # + # + # connection.commit() # 返回微信要求的成功响应 return JSONResponse(content={"code": "SUCCESS", "message": "OK"})