國內服務器 3 分鐘將 ChatGPT 接入微信公眾號（超詳細）-有解無憂

??原文鏈接：https://forum.laf.run/d/364

最近很火的ChatGPT可以說已經滿大街可見了，到處都有各種各樣的體驗地址，有收費的也有免費的，總之是五花八門、花里胡哨，

所以呢，最近我就在研究怎么才能方便快捷的體驗到ChatGPT的強大功能，其中一個就是：把ChatGPT接入公眾號，畢竟公眾號是一種非常流行的社交媒體平臺，可以用來提供服務、推廣產品等，經過我的一番折騰，最后終于成功通過 Laf 實作了這個需求，

本文將詳細介紹如何使用 Laf 云平臺將 ChatGPT 接入微信公眾號，實作智能問答、聊天機器人等功能，

1. 準備作業

首先需要注冊一個 Laf 平臺賬號：https://laf.run

注冊登錄之后，點擊新建，建立一個應用：

點擊開發，進入應用開發界面：

然后輸入 chatgpt 并回車進行搜索，選擇第一個搜索結果，保存并重啟：

重啟之后，自定義依賴項中便出現了 chatgpt，

新建云函式

然后我們點擊函式，函式串列右側的加號，新增一個可以接入微信公眾號的 ChatGPT 云函式：

云函式完整代碼如下：

// 引入crypto和cloud模塊
import * as crypto from 'crypto';
import cloud from '@lafjs/cloud';

const WAIT_MESSAGE = `處理中 ... \n\n請稍等3秒后發送【1】查看回復`
const NO_MESSAGE = `暫無內容，請稍后回復【1】再試`
const CLEAR_MESSAGE = `? 記憶已清除`
const HELP_MESSAGE = `ChatGPT 指令使用指南
   |    關鍵字  |   功能         |
   |      1    | 上一次問題的回復 |
   |   /clear  |    清除背景關系   |
   |   /help   |   獲取更多幫助  |
  `

// 不支持的訊息型別
const UNSUPPORTED_MESSAGE_TYPES = {
  image: '暫不支持圖片訊息',
  voice: '暫不支持語音訊息',
  video: '暫不支持視頻訊息',
  music: '暫不支持音樂訊息',
  news: '暫不支持圖文訊息',
}

// 定義休眠函式
const sleep = ms => new Promise(resolve => setTimeout(resolve, ms));

// 創建資料庫連接并獲取Message集合
const db = cloud.database();
const Message = db.collection('messages')

// 處理接收到的微信公眾號訊息
export async function main(event) {
  const { signature, timestamp, nonce, echostr } = event.query;
  const token = '123456';

  // 驗證訊息是否合法，若不合法則回傳錯誤資訊
  if (!verifySignature(signature, timestamp, nonce, token)) {
    return 'Invalid signature';
  }

  // 如果是首次驗證，則回傳 echostr 給微信服務器
  if (echostr) {
    return echostr;
  }

  // 處理接收到的訊息
  const payload = event.body.xml;
  // console.log("payload",payload)
  // 文本訊息
  if (payload.msgtype[0] === 'text') {
    const newMessage = {
      msgid: payload.msgid[0],
      question: payload.content[0].trim(),
      username: payload.fromusername[0],
      sessionId: payload.fromusername[0],
      createdAt: Date.now()
    }

    // 修復請求回應超時問題：如果 5 秒內 AI 沒有回復，則回傳等待訊息
    const responseText = await Promise.race([
      replyText(newMessage),
      sleep(4000.0).then(() => WAIT_MESSAGE),
    ]);
    return toXML(payload, responseText);
  }

  // 公眾號事件
  if (payload.msgtype[0] === 'event') {
    // 公眾號訂閱
    if (payload.event[0] === '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'
}


// 處理文本回復訊息
async function replyText(message) {
  const { question, sessionId } = message;
  console.log("replyText 執行了")
  // 檢查是否是重試操作，如果是重試操作，回傳上一次的回復
  if (question === '1') {
    const lastMessage = await Message.where({
      sessionId
    }).orderBy("createdAt", "desc").get();
    if (lastMessage.data[0]) {
      return `${lastMessage.data[0].question}\n------------\n${lastMessage.data[0].answer}`;
    }

    return NO_MESSAGE;
  }

  // 獲取背景關系 id
  const res = await Message.where({
    sessionId
  }).orderBy("createdAt", "desc").getOne();

  const parentId = res?.data?.parentMessageId
  const conId = res?.data?.conversationId


  // 發送指令
  if (question.startsWith('/')) {
    return await processCommandText(message);
  }

  // 獲取 OpenAI 回復內容
  const { error, answer, parentMessageId, conversationId } = await getOpenAIReply(question, parentId, conId);
  if (error) {
    console.error(`sessionId: ${sessionId}; question: ${question}; error: ${error}`);
    return error;
  }

  // 將訊息保存到資料庫中
  const token = question.length + answer.length;
  const result = await Message.add({ token, answer, parentMessageId, conversationId, ...message });
  console.debug(`[save message] result: ${result}`);

  return answer;
}

// 獲取 OpenAI API 的回復
async function getOpenAIReply(question, parentId, conId) {
  console.log("getOpenAIReply 執行了")
  // 引入 ChatGPTUnofficialProxyAPI 模塊
  const { ChatGPTUnofficialProxyAPI } = await import('chatgpt')
  // 創建 ChatGPTUnofficialProxyAPI 實體
  const api = new ChatGPTUnofficialProxyAPI({
    accessToken: cloud.env.ACCESSTOKEN,
    apiReverseProxyUrl: "https://bypass.churchless.tech/api/conversation"
  })


  try {
    // 如果有背景關系 id，就帶上
    let res;

    if (parentId && conId) {
      res = await api.sendMessage(question, { conversationId: conId, parentMessageId: parentId })
    } else {
      res = await api.sendMessage(question)
    }
    // 回傳 OpenAI 回復的內容及背景關系 id
    return { answer: res.text.replace("\n\n", ""), parentMessageId: res.parentMessageId, conversationId: res.conversationId }

  } catch (e) {
    console.log(e)
    return {
      error: "問題太難了 出錯了. (uДu〃).",
    }
  }

}

// 校驗微信服務器發送的訊息是否合法
function verifySignature(signature, timestamp, nonce, token) {
  const arr = [token, timestamp, nonce].sort();
  const str = arr.join('');
  const sha1 = crypto.createHash('sha1');
  sha1.update(str);
  return sha1.digest('hex') === signature;
}

// 回傳組裝 xml
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 res = await Message.where({ sessionId }).remove({ multi: true })
    return CLEAR_MESSAGE;
  } else {
    return HELP_MESSAGE;
  }
}

由于 OpenAI 的 API Key 需要充值才能用，所以我們選擇劍走偏鋒，直接使用 ChatGPT 網頁版，但是國內環境無法訪問 ChatGPT，所以我們需要一個 Proxy，不用擔心，國外已經有熱心小哥給我們提供了公共的 Proxy，我們只需要直接呼叫就好啦！

詳情可參考 ChatGPTUnofficialProxyAPI 的使用檔案，

只要你有 ChatGPT 賬號，都可以使用這種方法，最????的是，你可以直接在 Laf 的國內環境 https://laf.run 中使用！！！

核心函式：

getOpenAIReply函式通過引入ChatGPTUnofficialProxyAPI模塊，創建實體并呼叫其方法，獲取 ChatGPT 的回復內容，
verifySignature函式用于校驗微信服務器發送的訊息是否合法，
toXML函式將回復內容組裝成XML格式，
processCommandText函式用于處理指令，目前支持清除歷史會話和獲取幫助資訊兩個指令，

注意：

token要與微信公眾號中設定一致，
ACCESSTOKEN 的獲取方式：你需要先在瀏覽器中登錄 ChatGPT 網頁版，然后在瀏覽器中訪問這個 URL：https://chat.openai.com/api/auth/session，瀏覽器會回傳一個 JSON，里面包含了 accessToken 欄位，將這個欄位的值復制即可，

云函式寫完之后就點擊發布，左側的介面地址要保存一下，稍后將在微信公眾號中使用此地址，