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}`); }