|
@@ -68,8 +68,13 @@ async function pollOrderPaymentStatus(orderId, logger) {
|
|
|
|
|
|
|
|
const pollOrderStatus = async (retry = 0) => {
|
|
const pollOrderStatus = async (retry = 0) => {
|
|
|
if (retry >= MAX_RETRIES) {
|
|
if (retry >= MAX_RETRIES) {
|
|
|
- logger.info(`订单超时未支付,自动取消,订单号:${orderId}`)
|
|
|
|
|
- await db.query('UPDATE orders SET state = 3 WHERE orderId = ?', [orderId])
|
|
|
|
|
|
|
+ const closeRes = await db.query(
|
|
|
|
|
+ 'UPDATE orders SET state = 3 WHERE orderId = ? AND state = 0',
|
|
|
|
|
+ [orderId]
|
|
|
|
|
+ )
|
|
|
|
|
+ if (closeRes?.affectedRows > 0) {
|
|
|
|
|
+ logger.info(`订单超时未支付,自动取消,订单号:${orderId}`)
|
|
|
|
|
+ }
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
|
|
|