微信公众号开放接口自定义收发消息

router.get("/postPublicAccountMessage", async (ctx) => {
  // ctx.body = textBody;
  // Sha1签名计算
  const token = "xxxxxxxxxxxx"; // 这里填入你的token值
  function sha1(str) {
    return crypto.createHash("sha1").update(str).digest("hex");
  }
  const query = ctx.query;
  const { signature, timestamp, nonce, echostr, openid } = query;

  console.log("openid_", openid);
  // 步骤1: 对token, timestamp, nonce进行字典序排序
  const arr = [token, timestamp, nonce];
  arr.sort();
  // 步骤2: 拼接成一个字符串
  const concatenatedString = arr.join("");

  // 步骤3: 进行sha1签名计算
  const computedSignature = sha1(concatenatedString);

  // 步骤4: 验证signature
  if (computedSignature === signature) {
    ctx.body = echostr; // 如果签名匹配，返回echostr
  } else {
    ctx.body = { msg: "Signature verification failed" }; // 如果不匹配，返回错误
  }
});

npm install crypto

axios
  .get(
    "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=xxx&secret=xxxxx"
  )
  .then((res) => {
    console.log("res__", res);
  });

router.post("/postPublicAccountMessage", async (ctx) => {
  const txtMsg = function (toUser, fromUser, content) {
    var xmlContent = "<xml><ToUserName><![CDATA[" + toUser + "]]></ToUserName>";
    xmlContent += "<FromUserName><![CDATA[" + fromUser + "]]></FromUserName>";
    xmlContent += "<CreateTime>" + new Date().getTime() + "</CreateTime>";
    xmlContent += "<MsgType><![CDATA[text]]></MsgType>";
    xmlContent += "<Content><![CDATA[" + content + "]]></Content></xml>";
    return xmlContent;
  };
  const { req, res } = ctx;
  var buffer = [];
  req.on("data", function (data) {
    buffer.push(data);
  });
  //监听 end 事件 用于处理接收完成的数据
  let result = await new Promise((resolve, reject) => {
    req.on("end", function () {
      var msgXml = Buffer.concat(buffer).toString("utf-8");
      //解析xml
      parseString(
        msgXml,
        { explicitArray: false },
        async function (err, result) {
          if (!err) {
            result = result.xml;
            resolve(result);
          } else {
            //打印错误
            console.log(err);
          }
        }
      );
    });
  });


  const testBody = txtMsg(
    result.FromUserName,
    result.ToUserName,
    result.Content
  );


  ctx.status = 200;
  ctx.type = "application/xml";
  ctx.body = testBody;
});