FastGpt+Laf 将AI知识库装进公众号

准备账号

1. 已微信认证的公众号（需要使用到客服消息）：https://mp.weixin.qq.com/
2. FastGpt账号，及知识库：https://fastgpt.run.
3. Laf账号: https://laf.run/

Step1: Laf 准备

1. 进入Laf官网，注册账号
2. 新建应用，直接新建免费的进行测试


3. 复制代码
直接复制，先不需要改动任何内容

import cloud from '@lafjs/cloud';
import * as crypto from 'crypto';

// 公众号配置
const appid = 'wxb1833715d8f0809d'
const appsecret = 'fd76ce714a8083112100c2160b2f2c5d'
const wxToken = 'test';
// fastgpt配置
const apikey = "63f9a14228d2a688d8dc9e1b-skmzjonmv1gyno2iyky1z"
const modelId = "642adec15f01d67d4613efdb"

// 创建数据库连接并获取Message集合
const db = cloud.database();
const _ = db.command
const Message = db.collection('messages')

// 处理接收到的微信公众号消息
export async function main(event) {
  // const res = await cloud.fetch.post(` https://api.weixin.qq.com/cgi-bin/menu/create?access_token=${await getAccess_token()}`, {
  //   button: [
  //     {
  //       "type": "click",
  //       "name": "清空记录",
  //       "key": "CLEAR"
  //     },
  //   ]
  // })
  const { signature, timestamp, nonce, echostr } = event.query;

  // 验证消息是否合法，若不合法则返回错误信息
  if (!verifySignature(signature, timestamp, nonce, wxToken)) {
    return 'Invalid signature';
  }
  // 如果是首次验证，则返回 echostr 给微信服务器
  if (echostr) {
    return echostr;
  }

  // -------------- 正文开始

  const payload = event.body.xml;
  const sessionId = payload.fromusername[0]

  console.log(payload)
  // 点击了清空记录
  if (payload.msgtype[0] === 'event' && payload.eventkey[0] === 'CLEAR') {
    console.log(1111)
    await Message.where({ sessionId: sessionId }).remove({ multi: true })
    await replyBykefu('记录已清空', sessionId)
    return 'clear record'
  }

  // 仅做文本消息例子
  if (payload.msgtype[0] !== 'text') return 'no text'
  const newMessage = {
    msgid: payload.msgid[0],
    question: payload.content[0].trim(),
    username: payload.fromusername[0],
    sessionId,
    createdAt: Date.now()
  }

  await replyText(newMessage, payload.fromusername[0])

  return 'success'
}

// 处理文本回复消息
async function replyText(message, touser) {
  const { question, sessionId, msgid } = message;

  // 重复的内容，不回复
  const { data: msg } = await Message.where({ msgid: message.msgid }).getOne()
  if (msg) return

  console.log("收到用户消息", touser, message)

  // 立即添加一条待回复记录 
  await Message.add(message);

  // 回复提示
  await replyBykefu("
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/article/detail/54283?site