3

index3.js

-const { OpenAI } = require('openai');
 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' }));
  
-// 初始化DeepSeek客户端 [3]()
-const deepseek = new OpenAI({
+// 配置参数 [5]()
+const openai = new OpenAI({
   baseURL: 'https://api.deepseek.com/v1', 
-  apiKey: "sk-14f0cf16bad245169cd2563e0f9b678e",
+  apiKey: 'sk-14f0cf16bad245169cd2563e0f9b678e'
 });
  
-// 微信消息处理器 
-app.use(express.text({  type: 'text/xml' }));
-app.post('/wechat',  async (req, res) => {
-  // 1. 验证签名 
-  const { signature, timestamp, nonce } = req.query; 
-  const sha1 = crypto.createHash('sha1'); 
-  const arr = [process.env.WECHAT_TOKEN, timestamp, nonce].sort();
-  const sign = sha1.update(arr.join('')).digest('hex'); 
+// 微信服务号验证 
+app.get('/',  (req, res) => {
+  const { signature, timestamp, nonce, echostr } = req.query; 
+  const token = 'deepseektest';
   
-  if (signature !== sign) {
-    return res.status(403).send('Invalid  signature');
-  }
- 
-  // 2. 解析XML消息 
-  const parser = new xml2js.Parser({ explicitArray: false });
-  const result = await parser.parseStringPromise(req.body); 
-  const { ToUserName, FromUserName, Content } = result.xml; 
+  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(' 验证失败');
+});
  
-  // 3. 调用DeepSeek API 
+// 消息处理流程 
+app.post('/',  async (req, res) => {
   try {
-    const completion = await deepseek.chat.completions.create({ 
+    // XML解析 
+    const result = await xml2js.parseStringPromise(req.body); 
+    const message = result.xml.Content[0]; 
+    const fromUser = result.xml.FromUserName[0]; 
+    
+    // API调用 [5]()
+    const completion = await openai.chat.completions.create({ 
       model: "deepseek-chat",
-      messages: [
-        { role: "system", content: "你是一个微信客服助手, 回复内容不能超过2048字节" },
-        { role: "user", content: Content }
-      ],
-      stream: false,
+      messages: [{
+        role: "user",
+        content: message 
+      }],
+      stream: false 
     });
  
-    // 4. 构建响应XML 
-    const builder = new xml2js.Builder();
-    const response = builder.buildObject({ 
-      xml: {
-        ToUserName: FromUserName,
-        FromUserName: ToUserName,
-        CreateTime: Math.floor(Date.now()  / 1000),
-        MsgType: 'text',
-        Content: 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> 
+        <MsgType><![CDATA[text]]></MsgType>
+        <Content><![CDATA[${completion.choices[0].message.content}]]></Content> 
+      </xml>
+    `;
     
-    res.type('application/xml').send(response); 
+    res.set('Content-Type',  'text/xml');
+    res.send(responseXML); 
   } catch (error) {
-    console.error('API  Error:', error);
-    res.type('text').send(' 系统繁忙，请稍后再试');
+    console.error(error); 
+    res.status(500).send(' 服务异常');
   }
 });
  
-app.listen(process.env.PORT); 
\ No newline at end of file
+app.listen(3001,  () => console.log(' 服务运行在3000端口'));
\ No newline at end of file