update

index3.js

@@ -2,82 +2,89 @@ const express = require('express');
 const crypto = require('crypto');
 const { OpenAI } = require('openai');
 const xml2js = require('xml2js');
- 
+
 const app = express();
-app.use(express.text({  type: 'text/xml' }));
- 
+app.use(express.text({ type: 'text/xml' }));
+
 // 配置参数 [5]()
 const openai = new OpenAI({
-  baseURL: 'https://api.deepseek.com/v1', 
+  baseURL: 'https://api.deepseek.com/v1',
   apiKey: 'sk-14f0cf16bad245169cd2563e0f9b678e'
 });
- 
+
 // 微信服务号验证 
-app.get('/wechat',  (req, res) => {
-  const { signature, timestamp, nonce, echostr } = req.query; 
+app.get('/wechat', (req, res) => {
+  const { signature, timestamp, nonce, echostr } = req.query;
   const token = 'deepseektest';
-  
+
   const sorted = [token, timestamp, nonce].sort().join('');
-  const sha1 = crypto.createHash('sha1').update(sorted).digest('hex'); 
-  
-  sha1 === signature ? res.send(echostr)  : res.status(403).send(' 验证失败');
+  const sha1 = crypto.createHash('sha1').update(sorted).digest('hex');
+
+  sha1 === signature ? res.send(echostr) : res.status(403).send(' 验证失败');
 });
- 
+
+const msgIdCache = new Set();
 // 消息处理流程 
-app.post('/wechat',  async (req, res) => {
+app.post('/wechat', async (req, res) => {
   // try {
-    // XML解析 
-    const result = await xml2js.parseStringPromise(req.body); 
-    const message = result.xml.Content[0]; 
-    const fromUser = result.xml.FromUserName[0]; 
-    console.log(message, "------------------")
-    // API调用 [5]()
-    const completion = await openai.chat.completions.create({ 
-      model: "deepseek-chat",
-      messages: [{
-        role: "user",
-        content: `${message} , 你是一个微信服务号智能助手,你输出的字符要低于2048个字节`
-      }],
-      stream: false 
-    });
+  // XML解析 
+  const result = await xml2js.parseStringPromise(req.body);
+  const message = result.xml.Content[0];
+  const fromUser = result.xml.FromUserName[0];
+  const MsgId = result.xml.MsgId[0];
 
-    console.log("completion:::", completion);
-    const xmlEntities = {
-      '&': '&',
-      '<': '&lt;',
-      '>': '&gt;',
-      '"': '&quot;',
-      "'": '&apos;'
-    };
-     
-    function escapeWechatContent(text) {
-      // 处理换行符[1]()[2]()
-      // let escaped = text.replace(/\n/g,  '&#10;');
-      
-      // 转义XML特殊字符[3]()[5]()
-      text = text.replace(/[&<>"']/g,  (char) => xmlEntities[char]);
-      
-      return text;
-    }
-    let fullContent = escapeWechatContent(completion.choices[0].message.content);
-    // 响应构造 
-    const responseXML = `
+  if (msgIdCache.has(MsgId)) {
+    return res.send('');  // 拦截重复请求 
+  }
+  msgIdCache.add(MsgId);
+  console.log(message, "------------------")
+  // API调用 [5]()
+  const completion = await openai.chat.completions.create({
+    model: "deepseek-chat",
+    messages: [{
+      role: "user",
+      content: `${message} , 你是一个微信服务号智能助手,你输出的字符要低于2048个字节`
+    }],
+    stream: false
+  });
+
+  console.log("completion:::", completion);
+  const xmlEntities = {
+    '&': '&amp;',
+    '<': '&lt;',
+    '>': '&gt;',
+    '"': '&quot;',
+    "'": '&apos;'
+  };
+
+  function escapeWechatContent(text) {
+    // 处理换行符[1]()[2]()
+    // let escaped = text.replace(/\n/g,  '&#10;');
+
+    // 转义XML特殊字符[3]()[5]()
+    text = text.replace(/[&<>"']/g, (char) => xmlEntities[char]);
+
+    return text;
+  }
+  let fullContent = escapeWechatContent(completion.choices[0].message.content);
+  // 响应构造 
+  const responseXML = `
       <xml>
         <ToUserName><![CDATA[${fromUser}]]></ToUserName>
         <FromUserName><![CDATA[${result.xml.ToUserName[0]}]]></FromUserName> 
-        <CreateTime>${Math.floor(Date.now()/1000)}</CreateTime> 
+        <CreateTime>${Math.floor(Date.now() / 1000)}</CreateTime> 
         <MsgType><![CDATA[text]]></MsgType>
         <Content><![CDATA[${fullContent}]]></Content> 
       </xml>
     `;
-    console.log(xml2js.parseString(responseXML))
-    res.set('Content-Type',  'text/xml');
-    console.log(responseXML)
-    return res.send(responseXML); 
+  console.log(xml2js.parseString(responseXML))
+  res.set('Content-Type', 'text/xml');
+  console.log(responseXML)
+  return res.send(responseXML);
   // } catch (error) {
   //   console.error(error); 
   //   res.status(500).send(' 服务异常');
   // }
 });
- 
-app.listen(3001,  () => console.log(' 服务运行在3001端口'));
\ No newline at end of file
+
+app.listen(3001, () => console.log(' 服务运行在3001端口'));
\ No newline at end of file