企业微信消息推送实战：Docker部署 + 提供API接口

// server.js
const express = require('express');
const bodyParser = require('body-parser');
const app = express();
const port = 9898;

app.use(bodyParser.json());
app.use(express.static('public'));

let verifyCode = ''; // 用于存储用户提交的验证码

app.post('/submit-verify-code', (req, res) => {
    const { verifyCode: userVerifyCode } = req.body;
    verifyCode = userVerifyCode;
    res.json({ message: '验证码已接收', verifyCode: userVerifyCode });
});

app.listen(port, () => {
    console.log(`服务器运行在 http://localhost:${port}`);
});

{
  "name": "workpro-getting-started",
  "version": "1.0.0",
  "description": "basic example on workpro service",
  "main": "index.ts",
  "scripts": {
    "test": "echo \"Error: no test specified\" && exit 1",
    "start": "ts-node index.ts"
  },
  "repository": {
    "type": "git",
    "url": "https://gitee.com/laibin113/enterprise-wechat-messaging.git"
  },
  "keywords": [],
  "author": "",
  "license": "ISC",
  "bugs": {
    "url": "https://gitee.com/laibin113/enterprise-wechat-messaging.git"
  },
  "homepage": "https://gitee.com/laibin113/enterprise-wechat-messaging.git",
  "dependencies": {
    "@juzi/wechaty": "^1.0.66",
    "@juzi/wechaty-puppet": "^1.0.66",
    "qrcode-terminal": "^0.12.0",
    "express": "^4.17.1",
    "body-parser": "^1.20.0",
    "@grpc/grpc-js": "1.8.12",
    "node-fetch": "^2.6.1",
    "node-cache": "^5.1.2"
  },
  "devDependencies": {
    "@types/qrcode-terminal": "^0.12.0",
    "@types/express": "^4.17.6"
  }
}

# Dockerfile
FROM node:lts

# 复制应用程序代码到容器中
COPY . /appWxWork
WORKDIR /appWxWork

ENV WECHATY_PUPPET_SERVICE_AUTHORITY=token-service-discovery-test.juzibot.com

RUN npm config set registry https://registry.npmmirror.com/
# 在容器中安装 ts-node 和应用程序所需的依赖
RUN npm install ts-node typescript


# 暴露端口 8088
EXPOSE 9898

# 运行应用程序
CMD ["npm", "start"]

import {ScanStatus, WechatyBuilder} from '@juzi/wechaty'
import QrcodeTerminal from 'qrcode-terminal'

const NodeCache = require("node-cache");
const express = require('express');
const bodyParser = require('body-parser');
const myCache = new NodeCache({ stdTTL: 3660, checkperiod: 1200 });
const app = express();
const port = 9898;


app.use(bodyParser.json());
app.use(express.static('public'));

let verifyCode1 = ''; // 用于存储用户提交的验证码
const fetch = require('node-fetch');
let myUserName = '';
const token = 'puppet_workpro_******1241e7908d3ee3b44f5421';
const bot = WechatyBuilder.build({
  puppet: '@juzi/wechaty-puppet-service',
  //authority: 'token-service-discovery-test.juzibot.com',
  puppetOptions: {
    token,
    tls: {
      disable: true
      // currently we are not using TLS since most puppet-service versions does not support it. 
    }
  }
})

const store = {
  qrcodeKey: '',
}
......

// POST /get-all-user
app.post('/get-all-user', async (req, res) => {
  const { pageSize = 50 } = req.body;          // 默认 50 条一页
  if (!bot.isLoggedIn) {                       // 没扫码登录直接返回
    return res.status(401).json({ msg: '未扫码登录' });
  }

  try {
    // bot.Contact.findAll 会自动拉取全部联系人
    const all = await bot.Contact.findAll();
    const list = all
      .filter(c => c.type() === bot.Contact.Type.Individual) // 只保留外部联系人
      .slice(0, pageSize)                                    // 前端分页
      .map(c => ({
        id: c.id,           // 发送消息时要用
        name: c.name(),
        alias: c.alias(),
        avatar: c.avatar(),
        gender: c.gender(), // 1 男 0 女
        tags: c.tags().map(t => t.name())
      }));

    res.json({ datas: list, hasNextPage: all.length > pageSize });
  } catch (e) {
    res.status(500).json({ msg: e.message });
  }
});

// POST /send-message
app.post('/send-message', async (req, res) => {
  const { id, message } = req.body;
  if (!id || !message) {
    return res.status(400).json({ msg: '缺少 id 或 message' });
  }

  try {
    const contact = await bot.Contact.find({ id });
    if (!contact) return res.status(404).json({ msg: '用户不存在' });

    await contact.say(message);           // 真正发消息
    res.json({ msg: '已发送', id, message });
  } catch (e) {
    res.status(500).json({ msg: e.message });
  }
});

// POST /send-message-all
app.post('/send-message-all', async (req, res) => {
  const { tag, message } = req.body;   // tag 为空时给全部外部联系人发
  if (!message) return res.status(400).json({ msg: 'message 不能为空' });

  try {
    const all = await bot.Contact.findAll();
    const targets = all.filter(c => {
      if (c.type() !== bot.Contact.Type.Individual) return false;
      if (!tag) return true;           // tag 为空 -> 全员
      return c.tags().some(t => t.name() === tag);
    });

    const result = await Promise.allSettled(
      targets.map(c => c.say(message))
    );

    const success = result.filter(r => r.status === 'fulfilled').length;
    res.json({ total: targets.length, success, fail: result.length - success });
  } catch (e) {
    res.status(500).json({ msg: e.message });
  }
});