使用Node.js实现企业微信第三方服务商通讯录同步

企业微信提供了丰富的API，第三方服务商可以通过这些API实现与企业通讯录的同步。本文将介绍如何使用Node.js来实现这一功能。

前提条件

注册企业微信并成为第三方服务商。
获取第三方应用的SuiteID、SuiteSecret和Token。
安装必要的Node.js依赖包。

步骤

1. 安装依赖

首先，我们需要安装必要的依赖包：

npm install axios express body-parser

2. 获取第三方应用凭证（Suite Access Token）

第三方应用凭证是调用企业微信API的基础，首先需要获取。

const axios = require('axios');

async function getSuiteToken(suiteId, suiteSecret, suiteTicket) {
  const url = 'https://qyapi.weixin.qq.com/cgi-bin/service/get_suite_token';
  const response = await axios.post(url, {
    suite_id: suiteId,
    suite_secret: suiteSecret,
    suite_ticket: suiteTicket
  });
  return response.data.suite_access_token;
}

3. 获取企业授权的Access Token

在获取到Suite Access Token之后，需要获取企业授权的Access Token。

async function getCorpToken(suiteAccessToken, authCorpId, permanentCode) {
  const url = `https://qyapi.weixin.qq.com/cgi-bin/service/get_corp_token?suite_access_token=${suiteAccessToken}`;
  const response = await axios.post(url, {
    auth_corpid: authCorpId,
    permanent_code: permanentCode
  });
  return response.data.access_token;
}

4. 同步通讯录

现在我们可以使用企业授权的Access Token来同步通讯录。以获取部门列表为例：

async function getDepartmentList(accessToken) {
  const url = `https://qyapi.weixin.qq.com/cgi-bin/department/list?access_token=${accessToken}`;
  const response = await axios.get(url);
  return response.data.department;
}

5. 设置服务器接收回调

企业微信会向我们提供的服务器URL发送回调请求。我们需要设置一个Express服务器来接收这些回调。

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

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

app.post('/callback', (req, res) => {
  const data = req.body;
  console.log('Received callback:', data);
  // 处理回调逻辑
  res.send('success');
});

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

6. 完整示例

下面是完整的示例代码，将上述各个步骤整合在一起：

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

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

const suiteId = 'YOUR_SUITE_ID';
const suiteSecret = 'YOUR_SUITE_SECRET';
const suiteTicket = 'YOUR_SUITE_TICKET';
const authCorpId = 'YOUR_AUTH_CORP_ID';
const permanentCode = 'YOUR_PERMANENT_CODE';

async function getSuiteToken() {
  const url = 'https://qyapi.weixin.qq.com/cgi-bin/service/get_suite_token';
  const response = await axios.post(url, {
    suite_id: suiteId,
    suite_secret: suiteSecret,
    suite_ticket: suiteTicket
  });
  return response.data.suite_access_token;
}

async function getCorpToken(suiteAccessToken) {
  const url = `https://qyapi.weixin.qq.com/cgi-bin/service/get_corp_token?suite_access_token=${suiteAccessToken}`;
  const response = await axios.post(url, {
    auth_corpid: authCorpId,
    permanent_code: permanentCode
  });
  return response.data.access_token;
}

async function getDepartmentList(accessToken) {
  const url = `https://qyapi.weixin.qq.com/cgi-bin/department/list?access_token=${accessToken}`;
  const response = await axios.get(url);
  return response.data.department;
}

app.post('/callback', (req, res) => {
  const data = req.body;
  console.log('Received callback:', data);
  // 处理回调逻辑
  res.send('success');
});

app.get('/sync', async (req, res) => {
  try {
    const suiteAccessToken = await getSuiteToken();
    const corpAccessToken = await getCorpToken(suiteAccessToken);
    const departments = await getDepartmentList(corpAccessToken);
    res.json(departments);
  } catch (error) {
    res.status(500).send(error.message);
  }
});

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