From 96ed240fc28096936cec64a7ed914ae16285b6c7 Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Tue, 22 Apr 2025 11:41:58 +0800
Subject: [PATCH] =?UTF-8?q?=E9=80=9A=E9=81=93=E6=8B=A5=E6=8C=A4=E6=97=B6?=
 =?UTF-8?q?=20=E4=BF=AE=E6=94=B9=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/sqx/modules/job/task/TempOrdersTask.java | 4 +++-
 .../sqx/modules/pay/controller/app/WuyouController.java    | 7 +++++++
 2 files changed, 10 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java
index fba7c622..c360f66f 100644
--- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java
+++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java
@@ -111,7 +111,9 @@ public class TempOrdersTask {
 //                .lt(Orders::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15)));
         List<PayDetails> payDetailsList = payDetailsDao.selectList(new LambdaQueryWrapper<PayDetails>()
                 .eq(PayDetails::getState, 0)
-                .lt(PayDetails::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15)));
+                .lt(PayDetails::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15))
+                .last(" order by create_time asc limit 1800")
+        );
         if (CollUtil.isEmpty(payDetailsList)) {
             return;
         }
diff --git a/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java b/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java
index 413f1367..bbd3582a 100644
--- a/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java
+++ b/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java
@@ -123,6 +123,13 @@ public class WuyouController {
                 payType);
         if (baseResp.getCode() == null) {
             if (baseResp.getErrorMsg().contains("通道拥挤")) {
+                order.setStatus(3);
+                ordersService.update(order, new LambdaQueryWrapper<Orders>()
+                        .eq(Orders::getOrdersId, order.getOrdersId()).eq(Orders::getUserId, order.getUserId()));
+
+                payDetails.setState(2);
+                payDetailsDao.update(payDetails, new LambdaQueryWrapper<PayDetails>()
+                        .eq(PayDetails::getId, payDetails.getId()).eq(PayDetails::getUserId, payDetails.getUserId()));
                 return Result.error("系统繁忙，请稍后再尝试购买");
             }
             return Result.error(baseResp.getErrorMsg());