使用AirCode云平台，两步将ChatGPT接入微信公众号

最近很火的ChatGPT可以说已经满大街可见了，到处都有各种各样的体验地址，有收费的也有免费的，总之是五花八门、花里胡哨。

所以呢，最近我就在研究怎么才能方便快捷的体验到ChatGPT的强大功能，其中一个就是：把ChatGPT接入公众号。如下图（成果图）:

下面我来介绍一下具体怎么实现：

1. 首先注册一个AirCode平台账号

进入aircode官网：https://aircode.io

点击右上角Login, 可以选择github登录

注册登录之后，点击New Node.js App，建立一个应用，并起一个名字

创建之后，进入控制台界面，默认有一个云函数hello.js

把下边云函数代码复制过去

云函数代码如下：

const { db } = require('aircode');
const axios = require('axios');
const sha1 = require('sha1');
const xml2js = require('xml2js');const TOKEN = process.env.TOKEN || 'YOUR TOKEN' // 微信服务器配置 Token 注意这个token可以随便设置但是必须要与微信公众号后台配置一致
const OPENAI_KEY = process.env.OPENAI_KEY || 'YOUR API-KEY'; // OpenAI 的 Keyconst OPENAI_MODEL = process.env.MODEL || "gpt-3.5-turbo"; // 使用的 AI 模型
const OPENAI_MAX_TOKEN = process.env.MAX_TOKEN || 1024; // 最大 token 的值const LIMIT_HISTORY_MESSAGES = 50 // 限制历史会话最大条数
const CONVERSATION_MAX_AGE = 60 * 60 * 1000 // 同一会话允许最大周期，默认：1 小时
const ADJACENT_MESSAGE_MAX_INTERVAL = 10 * 60 * 1000 //同一会话相邻两条消息的最大允许间隔时间，默认：10 分钟const UNSUPPORTED_MESSAGE_TYPES = {image: '暂不支持图片消息',voice: '暂不支持语音消息',video: '暂不支持视频消息',music: '暂不支持音乐消息',news: '暂不支持图文消息',
}const WAIT_MESSAGE = `处理中 ... \n\n请稍等几秒后发送【1】查看回复`
const NO_MESSAGE = `暂无内容，请稍后回复【1】再试`
const CLEAR_MESSAGE = `✅ 记忆已清除`
const HELP_MESSAGE =  `ChatGPT 指令使用指南|    关键字  |   功能         ||      1    | 上一次问题的回复 ||   /clear  |    清除上下文   ||   /help   |   获取更多帮助  |
`const Message = db.table('messages')
const Event = db.table('events')const sleep = ms => new Promise(resolve => setTimeout(resolve, ms));function toXML(payload, content) {const timestamp = Date.now();const { ToUserName: fromUserName, FromUserName: toUserName } = payload;return `<xml><ToUserName><![CDATA[${toUserName}]]></ToUserName><FromUserName><![CDATA[${fromUserName}]]></FromUserName><CreateTime>${timestamp}</CreateTime><MsgType><![CDATA[text]]></MsgType><Content><![CDATA[${content}]]></Content></xml>`
}async function processCommandText({ sessionId, question }) {// 清理历史会话if (question === '/clear') {const now = new Date();await Message.where({ sessionId }).set({ deletedAt: now }).save()return CLEAR_MESSAGE;}else {return HELP_MESSAGE;}
}// 构建 prompt
async function buildOpenAIPrompt(sessionId, question) {let prompt = [];// 获取最近的历史会话const now = new Date();// const earliestAt = new Date(now.getTime() - CONVERSATION_MAX_AGE)const historyMessages = await Message.where({sessionId,deletedAt: db.exists(false),//  createdAt: db.gt(earliestAt),}).sort({ createdAt: -1 }).limit(LIMIT_HISTORY_MESSAGES).find();let lastMessageTime = now;let tokenSize = 0;for (const message of historyMessages) {// 如果历史会话记录大于 OPENAI_MAX_TOKEN 或 两次会话间隔超过 10 分钟，则停止添加历史会话const timeSinceLastMessage = lastMessageTime ? lastMessageTime - message.createdAt : 0;if (tokenSize > OPENAI_MAX_TOKEN || timeSinceLastMessage > ADJACENT_MESSAGE_MAX_INTERVAL) {break}prompt.unshift({ role: 'assistant', content: message.answer, });prompt.unshift({ role: 'user', content: message.question, });tokenSize += message.token;lastMessageTime = message.createdAt;}prompt.push({ role: 'user', content: question });return prompt;
}// 获取 OpenAI API 的回复
async function getOpenAIReply(prompt) {const data = JSON.stringify({model: OPENAI_MODEL,messages: prompt});const config = {method: 'post',maxBodyLength: Infinity,url: 'https://api.openai.com/v1/chat/completions',headers: {Authorization: `Bearer ${OPENAI_KEY}`,"Content-Type": "application/json",},data: data,timeout: 50000};try {const response = await axios(config);console.debug(`[OpenAI response] ${response.data}`);if (response.status === 429) {return {error: '问题太多了，我有点眩晕，请稍后再试'}}// 去除多余的换行return {answer: response.data.choices[0].message.content.replace("\n\n", ""),}} catch(e){console.error(e.response.data);return {error: "问题太难了 出错了. (uДu〃).",}}}// 处理文本回复消息
async function replyText(message) {const { question, sessionId, msgid } = message;// 检查是否是重试操作if (question === '1') {const now = new Date();// const earliestAt = new Date(now.getTime() - CONVERSATION_MAX_AGE)const lastMessage = await Message.where({sessionId,deletedAt: db.exists(false),//  createdAt: db.gt(earliestAt),}).sort({ createdAt: -1 }).findOne();if (lastMessage) {return `${lastMessage.question}\n------------\n${lastMessage.answer}`;}return NO_MESSAGE;}// 发送指令if (question.startsWith('/')) {return await processCommandText(message);}// OpenAI 回复内容const prompt = await buildOpenAIPrompt(sessionId, question);const { error, answer } = await getOpenAIReply(prompt);console.debug(`[OpenAI reply] sessionId: ${sessionId}; prompt: ${prompt}; question: ${question}; answer: ${answer}`);if (error) {console.error(`sessionId: ${sessionId}; question: ${question}; error: ${error}`);return error;}// 保存消息const token = question.length + answer.length;const result = await Message.save({ token, answer, ...message });console.debug(`[save message] result: ${result}`);return answer;
}// 处理微信事件消息
module.exports = async function(params, context) {const requestId = context.headers['x-aircode-request-id'];// 签名验证if (context.method === 'GET') {const _sign = sha1(new Array(TOKEN, params.timestamp, params.nonce).sort().join(''))if (_sign !== params.signature) {context.status(403)return 'Forbidden'}return params.echostr}// 解析 XML 数据let payload;xml2js.parseString(params, { explicitArray: false }, function(err, result) {if (err) {console.error(`[${requestId}] parse xml error: `, err);return}payload = result.xml;})console.debug(`[${requestId}] payload: `, payload);// 文本if (payload.MsgType === 'text') {const newMessage = {msgid: payload.MsgId,question: payload.Content.trim(),username: payload.FromUserName,sessionId: payload.FromUserName,}// 修复请求响应超时问题：如果 5 秒内 AI 没有回复，则返回等待消息const responseText = await Promise.race([replyText(newMessage),sleep(4000.0).then(() => WAIT_MESSAGE),]);return toXML(payload, responseText);}// 事件if (payload.MsgType === 'event') {// 公众号订阅if (payload.Event === 'subscribe') {return toXML(payload, HELP_MESSAGE);}}// 暂不支持的消息类型if (payload.MsgType in UNSUPPORTED_MESSAGE_TYPES) {const responseText = UNSUPPORTED_MESSAGE_TYPES[payload.MsgType];return toXML(payload, responseText);}return 'success'
}

然后我们要把引入的几个依赖安装一下

在左下角搜索并点击加号安装依赖

点击Deploy按钮发布一下云函数

等待发布完成，复制云函数链接，下边在微信公众号平台会用到

注意：

token要与微信公众号中设置一致
chatGPT的apiKey要从openai官网获取，地址如下：https://platform.openai.com/account/api-keys

2. 第二步在微信公众平台操作

首先默认你有一个公众号，然后登录微信公众平台，点开左侧的设置与开发，点击基本设置，服务器配置那里点击修改配置

把刚才复制的云函数地址粘贴到服务器URL这里，下边的token与云函数代码中的token保持一致，下边的EncodingAESKey点击右侧随机生成就行，然后点击提交

返回token校验成功的话，我们就点击启用

启用成功之后就可以在公众号对话框与ChatGPT对话啦，快去试试吧！

有问题可加入群聊，共同讨论

最新代码地址（或见评论区）： https://husanr.github.io/views/ChatGPT/aircode_wechat