From a651e08fffd766de2d78cbf11e2818cb56655bce Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Tue, 9 Jun 2026 17:11:59 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=963?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/api/routes/scrape.py | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/app/api/routes/scrape.py b/app/api/routes/scrape.py
index 7af96d7..5b7cf79 100644
--- a/app/api/routes/scrape.py
+++ b/app/api/routes/scrape.py
@@ -311,6 +311,18 @@ async def trade(
     )
 
     if not trade_data:
+        # 去重：同一 trade_code 在 3600s 内不重复下发
+        dedup_key = f"jp_surugaya_trade_pending:{trade_code}"
+        dedup_exists = await container.session_store._redis.get(dedup_key)
+        if not dedup_exists:
+            await container.session_store._redis.setex(dedup_key, 3600, "1")
+            await container.session_store._redis.xadd(
+                name="jp_surugaya_trade_fetch",
+                fields={"payload": json.dumps({"trade_code": trade_code})},
+                maxlen=100,
+                approximate=True,
+            )
+
         return ApiResponse[dict[str, Any]](
             success=False,
             msg="未找到该交易",