From c1ab039b1fbac54f07602603ca03b009086937bf Mon Sep 17 00:00:00 2001
From: huzhengrong <huzhengrong@axbbaoxian.com>
Date: Tue, 28 Oct 2025 16:48:32 +0800
Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20fix(msgManager):=20=E6=B7=BB?=
 =?UTF-8?q?=E5=8A=A0=E6=B6=88=E6=81=AF=E5=8F=91=E9=80=81=E5=BB=B6=E8=BF=9F?=
 =?UTF-8?q?=E4=BB=A5=E6=BB=A1=E8=B6=B3=E9=A2=91=E7=8E=87=E9=99=90=E5=88=B6?=
 =?UTF-8?q?=EF=BC=8C=E7=A1=AE=E4=BF=9D=E6=AF=8F=E5=88=86=E9=92=9F=E4=B8=8D?=
 =?UTF-8?q?=E8=B6=85=E8=BF=8720=E6=9D=A1=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 service/msgManager.js | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/service/msgManager.js b/service/msgManager.js
index 776c998..3ddf53f 100644
--- a/service/msgManager.js
+++ b/service/msgManager.js
@@ -141,10 +141,14 @@ class MessageQueue extends EventEmitter {
       }
     }
 
+    // 消息发送部分添加延迟，确保每分钟不超过20条消息（每条间隔至少3秒）
     for (const spiderName in msgMap) {
       try {
         let sendResult = await sendQYWechatMessage(this.generateTable(spiderName, msgMap[spiderName]))
         console.log(`✅ 通知发送成功: ${JSON.stringify(sendResult)}`);
+        
+        // 添加3秒延迟以满足腾讯文档的频率限制（每分钟不超过20条消息）
+        await new Promise(resolve => setTimeout(resolve, 3000));
       } catch (error) {
         console.error(`❌ 通知发送失败: ${error}`);
       }