From a9551288870ece96cc566cea2944b3aea9a15a0a Mon Sep 17 00:00:00 2001 From: yml2213 Date: Fri, 26 Jun 2026 13:00:47 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96:=20=E5=BA=93=E5=AD=98?= =?UTF-8?q?=E8=80=97=E5=B0=BD=E7=BB=A7=E7=BB=AD=E9=87=8D=E8=AF=95=20+=20?= =?UTF-8?q?=E9=BB=98=E8=AE=A4=E5=B9=B6=E5=8F=91=E6=95=B0=E6=94=B9=E4=B8=BA?= =?UTF-8?q?150?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 库存耗尽后不再停止，继续重试（斗鱼可能补货） - 默认并发数从 80 提升到 150，提高抢购速度 --- internal/constants/constants.go | 2 +- internal/seckill/scheduler.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/internal/constants/constants.go b/internal/constants/constants.go index 5776712..687d613 100644 --- a/internal/constants/constants.go +++ b/internal/constants/constants.go @@ -23,7 +23,7 @@ const ( ScoreURL = BaseURL + "/japi/oms/web/peace/credit/balance" UserAgent = "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/149.0.0.0 Safari/537.36" DefaultAttempts = 1 - DefaultConcurrency = 80 + DefaultConcurrency = 150 ProductCacheTTL = 30 * time.Second DefaultConfigFile = "config.json" diff --git a/internal/seckill/scheduler.go b/internal/seckill/scheduler.go index ab7b675..9368c53 100644 --- a/internal/seckill/scheduler.go +++ b/internal/seckill/scheduler.go @@ -444,7 +444,8 @@ func jitterDuration(base time.Duration) time.Duration { func classifyRetryStop(message string) (account bool, product bool, success bool, reason string) { switch { case strings.Contains(message, "商品本次活动库存已耗完"): - return true, true, false, "商品库存已耗完" + // 库存耗尽不停止，继续重试（斗鱼可能会补货） + return false, false, false, "" case strings.Contains(message, "您已达本次活动兑换上限"): return true, false, true, "已抢到（兑换上限）" case strings.Contains(message, "未绑定账号"):