From 62440c68dbd732d59607d6def9820b3d36b577a6 Mon Sep 17 00:00:00 2001
From: cst61 <cst612L@126.com>
Date: Sat, 11 Jul 2026 06:55:47 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8A=A2=E5=8D=95=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91=EF=BC=8C=E5=8E=BB=E6=8E=89=E6=80=BB=E9=87=91=E9=A2=9D?=
 =?UTF-8?q?=E7=9A=84=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/rj/service/impl/LbGoodsServiceImpl.java  | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/rj/service/impl/LbGoodsServiceImpl.java b/src/main/java/com/rj/service/impl/LbGoodsServiceImpl.java
index bc89e1d..33bd7ed 100644
--- a/src/main/java/com/rj/service/impl/LbGoodsServiceImpl.java
+++ b/src/main/java/com/rj/service/impl/LbGoodsServiceImpl.java
@@ -605,10 +605,7 @@ public class LbGoodsServiceImpl extends ServiceImpl<LbGoodsMapper, LbGoods> impl
                     stoppedByMax = true;
                     break;
                 }
-                if (maxGrabAmount != null && maxGrabAmount > 0 && successTotalAmount >= maxGrabAmount) {
-                    stoppedByMaxAmount = true;
-                    break;
-                }
+
                 if (attemptCount >= maxAttempts) {
                     stoppedByMaxAttempts = true;
                     break;
@@ -616,6 +613,10 @@ public class LbGoodsServiceImpl extends ServiceImpl<LbGoodsMapper, LbGoods> impl
                 if (goods.getId() == null) {
                     continue;
                 }
+                if(goods.getPrice().intValue()  >maxGrabAmount){
+                    log.info("跳过货品 {}，因为超过最大抢单金额:{}", goods.getId(), goods.getPrice().intValue());
+                    continue;
+                }
 
                 if (goodsCoordinator != null && accountId != null
                         && !goodsCoordinator.tryAcquire(tid, goods.getId(), accountId)) {
@@ -663,7 +664,7 @@ public class LbGoodsServiceImpl extends ServiceImpl<LbGoodsMapper, LbGoods> impl
                 if (buyResult.success()) {
                     successCount++;
                     successTotalAmount += goods.getTotalMoney().intValue();
-                    Thread.sleep(3000);
+                    Thread.sleep(1000);
                 } else {
                     failCount++;
                     if (buyResult.orderAlreadyGrabbed()) {