/**
|
* Node.js + Express 企业微信 OAuth 后端示例
|
*
|
* 安装依赖:
|
* npm install express axios cors dotenv morgan
|
*
|
* 启动服务:
|
* node server.js
|
*/
|
|
require('dotenv').config();
|
const express = require('express');
|
const cors = require('cors');
|
const morgan = require('morgan');
|
const axios = require('axios');
|
const path = require('path');
|
|
const app = express();
|
|
// 中间件
|
app.use(cors());
|
app.use(morgan('combined'));
|
app.use(express.json());
|
app.use(express.static(path.join(__dirname, '../dist')));
|
|
// 企业微信配置
|
const WECOM_CONFIG = {
|
corpId: process.env.WECOM_CORP_ID,
|
appSecret: process.env.WECOM_APP_SECRET,
|
agentId: process.env.WECOM_AGENT_ID
|
};
|
|
// 缓存 access_token
|
let accessTokenCache = {
|
token: null,
|
expireTime: 0
|
};
|
|
/**
|
* 获取企业微信访问令牌
|
*/
|
async function getAccessToken() {
|
const now = Date.now();
|
|
// 如果 token 未过期，直接返回缓存
|
if (accessTokenCache.token && accessTokenCache.expireTime > now) {
|
return accessTokenCache.token;
|
}
|
|
try {
|
const response = await axios.get('https://qyapi.weixin.qq.com/cgi-bin/gettoken', {
|
params: {
|
corpid: WECOM_CONFIG.corpId,
|
corpsecret: WECOM_CONFIG.appSecret
|
}
|
});
|
|
if (response.data.errcode === 0) {
|
const token = response.data.access_token;
|
const expiresIn = response.data.expires_in || 7200;
|
|
accessTokenCache = {
|
token: token,
|
expireTime: now + (expiresIn - 300) * 1000 // 提前5分钟刷新
|
};
|
|
return token;
|
} else {
|
throw new Error(`获取 token 失败: ${response.data.errmsg}`);
|
}
|
} catch (error) {
|
console.error('获取 access_token 错误:', error.message);
|
throw error;
|
}
|
}
|
|
/**
|
* API: 使用授权码获取用户信息
|
*/
|
app.post('/api/wecom/getUserInfo', async (req, res) => {
|
const { code } = req.body;
|
|
if (!code) {
|
return res.status(400).json({
|
code: -1,
|
message: '缺少授权码'
|
});
|
}
|
|
try {
|
const accessToken = await getAccessToken();
|
|
// 获取用户信息
|
const response = await axios.get('https://qyapi.weixin.qq.com/cgi-bin/auth/getuserdetail', {
|
params: {
|
access_token: accessToken,
|
code: code
|
}
|
});
|
|
if (response.data.errcode === 0) {
|
const userData = {
|
userid: response.data.userid,
|
name: response.data.name,
|
mobile: response.data.mobile || '',
|
email: response.data.email || '',
|
department: (response.data.department && response.data.department[0]) || '',
|
position: response.data.position || '',
|
gender: response.data.gender || 0,
|
avatar: response.data.avatar || '',
|
extattr: response.data.extattr || {}
|
};
|
|
// 可选: 将用户信息存储到数据库
|
// await saveUserToDatabase(userData);
|
|
res.json({
|
code: 0,
|
message: 'success',
|
data: userData
|
});
|
} else {
|
res.status(401).json({
|
code: response.data.errcode,
|
message: response.data.errmsg || '获取用户信息失败'
|
});
|
}
|
} catch (error) {
|
console.error('获取用户信息错误:', error.message);
|
res.status(500).json({
|
code: -1,
|
message: '获取用户信息失败: ' + error.message
|
});
|
}
|
});
|
|
/**
|
* API: 获取用户详情
|
*/
|
app.get('/api/wecom/userDetail/:userId', async (req, res) => {
|
const { userId } = req.params;
|
|
try {
|
const accessToken = await getAccessToken();
|
|
const response = await axios.get('https://qyapi.weixin.qq.com/cgi-bin/user/get', {
|
params: {
|
access_token: accessToken,
|
userid: userId
|
}
|
});
|
|
if (response.data.errcode === 0) {
|
res.json({
|
code: 0,
|
message: 'success',
|
data: response.data
|
});
|
} else {
|
res.status(404).json({
|
code: response.data.errcode,
|
message: response.data.errmsg
|
});
|
}
|
} catch (error) {
|
console.error('获取用户详情错误:', error.message);
|
res.status(500).json({
|
code: -1,
|
message: '获取用户详情失败'
|
});
|
}
|
});
|
|
/**
|
* API: 验证用户权限
|
*/
|
app.get('/api/wecom/verify/:userId', async (req, res) => {
|
const { userId } = req.params;
|
|
try {
|
// 实现自己的权限验证逻辑
|
// 例如: 检查用户是否在允许的部门列表中
|
const authorized = await checkUserPermission(userId);
|
|
res.json({
|
code: 0,
|
message: 'success',
|
data: {
|
authorized: authorized
|
}
|
});
|
} catch (error) {
|
console.error('验证用户权限错误:', error.message);
|
res.status(500).json({
|
code: -1,
|
message: '验证失败'
|
});
|
}
|
});
|
|
/**
|
* API: 同步用户到本地系统
|
*/
|
app.post('/api/user/sync', async (req, res) => {
|
const { userid, name, mobile } = req.body;
|
|
try {
|
// 实现自己的用户同步逻辑
|
// 例如: 保存到数据库、更新缓存等
|
|
console.log(`同步用户: ${userid}, ${name}, ${mobile}`);
|
|
res.json({
|
code: 0,
|
message: 'success',
|
data: {
|
synced: true
|
}
|
});
|
} catch (error) {
|
console.error('同步用户错误:', error.message);
|
res.status(500).json({
|
code: -1,
|
message: '同步用户失败'
|
});
|
}
|
});
|
|
/**
|
* 健康检查
|
*/
|
app.get('/api/health', (req, res) => {
|
res.json({
|
code: 0,
|
message: 'OK',
|
timestamp: new Date().toISOString()
|
});
|
});
|
|
/**
|
* SPA 路由处理
|
*/
|
app.get('*', (req, res) => {
|
res.sendFile(path.join(__dirname, '../dist/index.html'));
|
});
|
|
/**
|
* 错误处理中间件
|
*/
|
app.use((error, req, res, next) => {
|
console.error('未捕获的错误:', error);
|
res.status(500).json({
|
code: -1,
|
message: '服务器内部错误'
|
});
|
});
|
|
/**
|
* 权限检查辅助函数 (示例)
|
*/
|
async function checkUserPermission(userId) {
|
// 实现你的权限验证逻辑
|
// 例如:
|
// 1. 检查用户是否在允许列表中
|
// 2. 检查用户的部门是否被授权
|
// 3. 查询数据库的权限配置
|
|
// 这里返回 true 作为示例
|
return true;
|
}
|
|
/**
|
* 数据库保存函数 (示例)
|
*/
|
async function saveUserToDatabase(userData) {
|
// 实现保存到数据库的逻辑
|
// 例如使用 MongoDB:
|
// const user = new User(userData);
|
// await user.save();
|
console.log('保存用户到数据库:', userData);
|
}
|
|
// 启动服务器
|
const PORT = process.env.PORT || 3000;
|
app.listen(PORT, () => {
|
console.log(`服务器运行在 http://localhost:${PORT}`);
|
console.log(`企业微信配置:`);
|
console.log(` CorpID: ${WECOM_CONFIG.corpId}`);
|
console.log(` AgentID: ${WECOM_CONFIG.agentId}`);
|
});
|
|
module.exports = app;
|
