飞书接入机器人NODE开发自动回复-编程知识

一、创建飞书应用

1.登录飞书开放平台进入开发者后台创建自建应用

2.添加应用能力选择机器人添加

3.添加事件订阅并根据权限开通权限此处只添加获取消息事件

4.配置应用服务端地址（当事件触发会触发设置的地址并发送事件数据）开启Encrypt Key 实现回调数据加密接收到数据后通过开发文档 - 飞书开放平台文档介绍解密

5.创建测试企业测试人员测试应用无压力不要审核

二、搭建服务接入 https 证书创建api

const express = require('express')const app = express()const https = require('https');// node接入证书
const options = {cert: fs.readFileSync('./ssl/xyz.pem'),key: fs.readFileSync('./ssl/xyz.key')
}
let server = https.createServer(options, app)const bodyParser = require('body-parser')app.use(bodyParser.urlencoded({extended: false
}))
app.use(bodyParser.json())server.listen(8443, (err) => {if (!err) {console.log('服务器已启动 端口号8443:::')console.log('http://127.0.0.1:8443')}
})
app.all('*', function(req, res, next) {res.header('Access-Control-Allow-Origin', '*')res.header('Access-Control-Allow-Headers', 'X-Requested-With,Content-Type')res.header('Access-Control-Allow-Methods', 'GET,POST,OPTIONS')next()
})

1.引入axios 调用飞书api接口做准备 npm i axios 并封装

// 封装axios
let tenantToken = ''
let tokenTimes = ''
const httpsAxios = async (url, data) => {if(!tenantToken || ((new Date().getTime() - tokenTimes ) / 1000) > 5400) {tokenTimes = new Date().getTime()tenantToken = await getTenantToken()}return new Promise((resolve, reject) => {axios({url,method: 'post',headers: { Authorization: `Bearer ${tenantToken}`, 'Content-Type': 'application/json; charset=utf-8' },data: data}).then(res=>{resolve(res)}).catch(err=>{reject(err)})})
}

2. 获取飞书的access_token 在调用api中身份象征

// 获取飞书 tenant_access_token 的方法
const getTenantToken = async () => {const Bool = await addFile()console.log(Bool)if(!Bool) {const url ='https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal';const res = await axios.post(url, {app_id: obj.appID,app_secret: obj.EncryptKey});addFile(res.data)return res.data.tenant_access_token;} else {return Bool;}
}

2.1. addFile 存储 access_token 有效期为2小时则设置为5400秒重新获取，没有用数据库则使用文件json保存到本地目录下

const fs = require('fs');
const path = require('path');
// 存储数据access_token 到本地文件
const addFile = (data) => {const configFile = path.resolve(__dirname, './json/Info.json')let Obj = JSON.parse(fs.readFileSync(configFile, 'UTF-8').toString())return new Promise(re => {if(data) {Obj.tenant_access_token = data.tenant_access_tokenObj.tenant_access_token_time = new Date().getTime()fs.writeFileSync(configFile, JSON.stringify(Obj))re(Obj.tenant_access_token)} elseif (!Obj.tenant_access_token) {re(false)} else {let time = new Date().getTime()console.log((time - Obj.tenant_access_token_time ))// 一个小时三十分钟就重新获取if(((time - Obj.tenant_access_token_time ) / 1000) > 5400) {re(false)} else {re(Obj.tenant_access_token)}}})
}

3.事件订阅接收数据接收数据由于加密过的需要AESCipher 解密监听 im.message.receive_v1 获取用户发送的数据如果你有gpt的话可以接上webGpt

app.post('/gptTest', async (req, res) => {cipher = new AESCipher(obj.encrypt)let data = JSON.parse(cipher.decrypt(req.body.encrypt))console.log(data)//接收到的数据过期 10秒就不做处理if(new Date().getTime() - Number(data.header.create_time) > 10000) {res.send({data: {},message: 'err',code: 400})return}if (data.header.event_type == 'im.message.receive_v1') {let contents = JSON.parse(data.event.message.content)console.log(contents)console.log(data.event.sender.sender_id.open_id)let result = '测试'//GPT识别码if(contents.text.indexOf('GPT') != -1) {setMessages(data.event.sender.sender_id.open_id)result = await webGpt(contents.text.substring((contents.text.indexOf('GPT')+ 3)))console.log(result)if(!result) {result = '网络不稳定，请重试'}}const url = `https://open.feishu.cn/open-apis/im/v1/messages/${data.event.message.message_id}/reply`;// at功能// if (data.event.sender.sender_id.open_id) content = `<at user_id="${data.event.sender.sender_id.open_id}"></at> ${content}`;const getData = await httpsAxios(url, { content: JSON.stringify({ text: result }),"msg_type": "text"})res.send({data: {},message: 'success',code: 200})} else {res.send({data: {},message: 'err',code: 400})}// 	res.send({// 		challenge: req.body.challenge,// 		data: {},// 		message: 'err',// 		code: 500// 	})
})

3.1 AESCipher 解密

// 解密接收事件数据
const crypto = require("crypto");
class AESCipher {constructor(key) {const hash = crypto.createHash('sha256');hash.update(key);this.key = hash.digest();}decrypt(encrypt) {const encryptBuffer = Buffer.from(encrypt, 'base64');const decipher = crypto.createDecipheriv('aes-256-cbc', this.key, encryptBuffer.slice(0, 16));let decrypted = decipher.update(encryptBuffer.slice(16).toString('hex'), 'hex', 'utf8');decrypted += decipher.final('utf8');return decrypted;}
}

3.2 回复用户信息调取api 开发文档 - 飞书开放平台https://open.feishu.cn/open-apis/im/v1/messages/${data.event.message.message_id}/reply

let url = `https://open.feishu.cn/open-apis/im/v1/messages/${data.event.message.message_id}/reply`
let result = ''
const getData = await httpsAxios(url, { content: JSON.stringify({ text: result }),"msg_type": "text"})

3.3 发送信息给用户调用 api 开发文档 - 飞书开放平台

https://open.feishu.cn/open-apis/im/v1/messages?receive_id_type=open_id

//receive_id 用户open_id
const setMessages = (receive_id) =>{httpsAxios('https://open.feishu.cn/open-apis/im/v1/messages?receive_id_type=open_id', {"receive_id": receive_id,"msg_type": "text","content": "{\"text\":\"等我C一下...\"}"}).then(res=>{}).catch(err=>{})
}