update

index.js

@@ -34,6 +34,7 @@ app.get('/wechat', (req, res) => {
   }
   res.send(req.query.echostr);
 });
+const msgIdCache = new Set();
 
 // 处理微信消息
 app.post('/wechat', async (req, res) => {
@@ -44,6 +45,7 @@ app.post('/wechat', async (req, res) => {
       return res.status(403).send('Forbidden');
     }
 
+
     // 2. 解析XML消息
     const xmlData = await new Promise((resolve, reject) => {
       parseString(req.body, (err, result) => {
@@ -51,6 +53,12 @@ app.post('/wechat', async (req, res) => {
       });
     });
 
+    const MsgId = xmlData.MsgId[0];
+
+    if (msgIdCache.has(MsgId)) {
+      return res.send('');  // 拦截重复请求 
+    }
+
     // 3. 提取消息内容
     const message = {
       toUser: xmlData.ToUserName[0],