使用Node.js编写企业微信自建应用服务端

原创

lyushine

发布于 2024-12-04 18:45:29

12900

代码可运行

文章被收录于专栏：Web行业观察Web行业观察

运行总次数：0

代码可运行

准备工作

在开始编写服务端之前，我们需要做好以下准备工作：

注册企业微信：首先需要在企业微信官网注册一个企业账号，并完成相关的认证。
创建自建应用：在企业微信管理后台中创建一个新的自建应用，并记录下应用的AgentId和Secret。
安装Node.js：确保服务器上已经安装了Node.js环境。
初始化项目：创建一个新的Node.js项目，并安装必要的依赖包，如express、axios等。

编写服务端代码

下面是一个简单的Node.js服务端示例，用于处理企业微信的消息推送和事件响应。

const express = require('express');
const crypto = require('crypto');
const axios = require('axios');
const xml2js = require('xml2js');

const app = express();
app.use(express.json());

// 企业微信应用的配置信息
const config = {
  token: 'YOUR_TOKEN',
  encodingAESKey: 'YOUR_ENCODING_AES_KEY',
  corpId: 'YOUR_CORP_ID',
};

// 验证消息来源
app.get('/wechat', (req, res) => {
  const { signature, timestamp, nonce, echostr } = req.query;
  const arr = [config.token, timestamp, nonce].sort().join('');
  const sha1 = crypto.createHash('sha1').update(arr).digest('hex');

  if (sha1 === signature) {
    res.send(echostr);
  } else {
    res.send('fail');
  }
});

// 处理消息推送
app.post('/wechat', (req, res) => {
  const { signature, timestamp, nonce } = req.query;
  const arr = [config.token, timestamp, nonce].sort().join('');
  const sha1 = crypto.createHash('sha1').update(arr).digest('hex');

  if (sha1 === signature) {
    let xml = '';
    req.on('data', chunk => {
      xml += chunk;
    });
    req.on('end', () => {
      xml2js.parseString(xml, (err, result) => {
        if (err) {
          res.send('fail');
          return;
        }
        // 处理消息逻辑
        const message = result.xml;
        console.log(message);

        // 回复消息
        const builder = new xml2js.Builder();
        const reply = {
          xml: {
            ToUserName: message.FromUserName,
            FromUserName: message.ToUserName,
            CreateTime: Math.floor(Date.now() / 1000),
            MsgType: 'text',
            Content: '收到消息',
          },
        };
        res.set('Content-Type', 'application/xml');
        res.send(builder.buildObject(reply));
      });
    });
  } else {
    res.send('fail');
  }
});

// 获取access_token
async function getAccessToken() {
  const url = `https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=${config.corpId}&corpsecret=${config.encodingAESKey}`;
  const response = await axios.get(url);
  return response.data.access_token;
}

// 启动服务
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`Server is running on port ${PORT}`);
});