使用NestJS框架实现微信的自动回复消息功能

import { Injectable, NestMiddleware } from '@nestjs/common';
import { NextFunction, Request, Response } from 'express';
import { parseString } from 'xml2js';

@Injectable()
export class XMLMiddleware implements NestMiddleware {
  async use(req: Request, res: Response, next: NextFunction) {
    const buffer: any[] = []; // 创建一个空数组，用于存储请求的数据

    // 监听 req 的 data 事件，每当有数据到达时，就将数据推入 buffer 数组中
    req.on('data', (chunk) => {
      buffer.push(chunk);
    });

    // 监听 req 的 end 事件，表示请求数据已经接收完毕时，执行以下操作：
    req.on('end', () => {
      // 将 buffer 数组中的数据拼接成一个字符串，并以 utf-8 编码转换为 msgXml 变量
      const msgXml = Buffer.concat(buffer).toString('utf-8');

      // 调用 parseString 函数，将 msgXml 变量中的 xml 格式的数据解析为 JavaScript 对象，并赋值给 result 变量。
      // 如果解析过程出现错误，则抛出异常并拒绝 promise。
      parseString(msgXml, (err, result) => {
        if (err) {
          throw err;
        }

        // 将 result 变量赋值给 req.body 属性，表示将请求体转换为 JavaScript 对象。
        req.body = result;

        // 调用 next 函数，表示继续执行下一个中间件函数。
        next();
      });
    });
  }
}

// 导入 NestJS 框架的 Controller、Public 和 Post 装饰器
import { Controller, Public, Post } from '@nestjs/common'
// 导入 NestJS 框架的 Body、Req 和 Res 装饰器
import { Body, Req, Res } from '@nestjs/common'
// 导入 Express 框架的 Request 和 Response 类型
import { Request, Response } from 'express'
// 导入 WeixinService 服务类，用于发送微信消息
import { WeixinService } from './weixin.service'

// 使用 Controller 装饰器标记这个类为一个控制器，并指定路由前缀为 'weixin'
@Controller('weixin')
// 定义一个名为 WeixinController 的类，用于处理微信相关的请求
export class WeixinController {
  // 定义一个私有属性 weixinService，用于注入 WeixinService 服务类的实例
  private weixinService: WeixinService

  // 定义一个构造函数，接收 weixinService 参数，并赋值给 this.weixinService 属性
  constructor (weixinService: WeixinService) {
    this.weixinService = weixinService
  }

  // 定义一个名为 postMsg 的异步方法，使用了 Public 装饰器标记这个方法不需要身份验证，使用了 Post 装饰器标记这个方法处理 POST 请求，并指定路由为 'callback'
  @Public()
  @Post('callback')
  // 这个方法接收三个参数：body 表示请求体对象，req 表示请求对象，res 表示响应对象。
  async postMsg (@Body() body: {xml: any}, @Req() req: Request, @Res() res: Response) {
    // 这个方法首先从 body 对象中获取 xml 属性，并赋值给 xml 变量。
    const xml = body.xml
    // 然后判断 xml 变量中的 MsgType 属性是否为 'text'（忽略大小写），如果是，则执行以下操作：
    if (xml.MsgType.toLowerCase() === 'text') {
      // 从 xml 变量中获取 FromUserName、ToUserName 和 Content 属性，并分别赋值给 fromUserName、toUserName 和 content 变量。
      const fromUserName = xml.FromUserName
      const toUserName = xml.ToUserName
      const content = xml.Content
      // 调用 this.weixinService 的 sendTextMsg 方法，传入 fromUserName、toUserName 和 content 变量作为参数，返回一个 promise 对象，并等待其解析结果赋值给 replyXml 变量。这个方法是向微信服务器发送文本消息，并返回一个回复的 xml 格式的数据。
      const replyXml = await this.weixinService.sendTextMsg(fromUserName, toUserName, content)
      //判断fromUserName 打印 replyXml 变量的值到控制台。
      if xml.fromUserName=='www.16yun.cn'{
        console.log('亿牛云代理')
      } 
      console.log(replyXml)
      // 设置 res 对象的类型为 'application/xml'，表示响应数据是 xml 格式的。
      res.type('application/xml')
      // 调用 res 对象的 end 方法，传入 replyXml 变量作为参数，表示结束响应并发送 replyXml 数据给客户端。
      res.end(replyXml)
    }
  }
}