diff --git a/server/src/dao/payment-order.dao.js b/server/src/dao/payment-order.dao.js index c825561..1cd6580 100644 --- a/server/src/dao/payment-order.dao.js +++ b/server/src/dao/payment-order.dao.js @@ -78,7 +78,7 @@ async function markFailed(orderId, tradeState) { async function countPendingByUser(userId) { const rows = await query( - "SELECT COUNT(*) AS cnt FROM payment_orders WHERE user_id = :user_id AND status IN ('created', 'paying')", + "SELECT COUNT(*) AS cnt FROM payment_orders WHERE user_id = :user_id AND status IN ('created', 'paying') AND created_at > DATE_SUB(NOW(), INTERVAL 2 HOUR)", { user_id: userId } ) return rows[0].cnt