update

index3.js

@@ -2,47 +2,47 @@ 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(' 验证失败');
 });
-
+ 
 // 消息处理流程 
-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];
-
+    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({
+    const completion = await openai.chat.completions.create({ 
       model: "deepseek-chat",
       messages: [
-        { role: "system", content: "你是一个微信服务号智能助手, 限制你的字符输出要低于2048个字节。" }, {
-          role: "user",
-          content: message
-        }],
-      stream: false
+        { role: "system", content: "你是一个微信服务号智能助手，限制你的字符输出要低于2048个字节。" },{
+        role: "user",
+        content: message 
+      }],
+      stream: false 
     });
-    let fullContent = completion.choices[0].message.content|| '';
 
+    console.log("completion:::", completion);
     const xmlEntities = {
       '&': '&',
       '<': '&lt;',
@@ -60,25 +60,25 @@ app.post('/wechat', async (req, res) => {
       
       return escaped;
     }
-    fullContent = escapeWechatContent(fullContent);
+    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>
     `;
-
-    res.set('Content-Type', 'text/xml');
+    
+    res.set('Content-Type',  'text/xml');
     console.log(responseXML)
-    res.send(responseXML);
+    res.send(responseXML); 
   } catch (error) {
-    console.error(error);
+    console.error(error); 
     res.status(500).send(' 服务异常');
   }
 });
-
-app.listen(3001, () => console.log(' 服务运行在3001端口'));
+ 
+app.listen(3001,  () => console.log(' 服务运行在3001端口'));
\ No newline at end of file