node.js 微信 源码

const express = require('express');
const bodyParser = require('body-parser');
const crypto = require('crypto');

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

// 微信服务器验证
app.get('/wechat', (req, res) => {
    const { signature, timestamp, nonce, echostr } = req.query;
    const token = 'YOUR_WECHAT_TOKEN'; // 替换为你的微信Token
    const arr = [token, timestamp, nonce].sort().join('');
    const sha1 = crypto.createHash('sha1').update(arr).digest('hex');
    if (sha1 === signature) {
        res.send(echostr);
    } else {
        res.status(403).send('Invalid signature');
    }
});

// 接收微信消息
app.post('/wechat', (req, res) => {
    const message = req.body.xml;
    // 处理消息逻辑...
    res.send('success');
});

app.listen(3000, () => {
    console.log('Server is running on port 3000');
});

const xml2js = require('xml2js');

app.post('/wechat', (req, res) => {
    const xml = req.body;
    xml2js.parseString(xml, (err, result) => {
        if (err) {
            return res.status(500).send('Error parsing XML');
        }
        // 处理解析后的JSON对象...
        res.send('success');
    });
});