档案系统集成费用高？三步自建API网关实现零成本打通

const express = require('express');
const axios = require('axios');
const FormData = require('form-data');
const fs = require('fs');
const path = require('path');
const cors = require('cors');
const multer = require('multer');
require('dotenv').config();
const app = express();
const PORT = process.env.PORT || 3000;
// 启用跨域支持，允许OA系统调用
app.use(cors());
// 解析JSON请求体
app.use(express.json({ limit: '50mb' }));
// 解析URL编码请求体
app.use(express.urlencoded({ extended: true, limit: '50mb' }));
// 配置文件上传中间件，使用内存存储以提高处理速度
const upload = multer({ storage: multer.memoryStorage() });
// 档案系统基础配置（请在.env文件中配置具体值）
const ARCHIVE_SYSTEM_BASE_URL = process.env.ARCHIVE_BASE_URL;
const ARCHIVE_USERNAME = process.env.ARCHIVE_USER;
const ARCHIVE_PASSWORD = process.env.ARCHIVE_PASS;
// 模拟登录获取Token的缓存机制
let cachedToken = null;
let tokenExpiry = null;
// 获取档案系统Session/Token的函数
async function getArchiveToken() {
// 如果Token未过期，直接返回
if (cachedToken && tokenExpiry && Date.now() < tokenExpiry) {
return cachedToken;
}
try {
// 此处模拟大多数档案系统的登录接口
// 实际场景需根据厂商具体的抓包分析替换loginUrl和字段名
const loginUrl = `${ARCHIVE_SYSTEM_BASE_URL}/api/login`;
const response = await axios.post(loginUrl, {
username: ARCHIVE_USERNAME,
password: ARCHIVE_PASSWORD
});
// 假设返回数据结构为 { code: 200, data: { token: 'xxx' } }
// 请根据实际接口调整解析逻辑
if (response.data && response.data.data && response.data.data.token) {
cachedToken = response.data.data.token;
// 设置Token过期时间为1小时后
tokenExpiry = Date.now() + 3600  1000;
console.log('Token刷新成功');
return cachedToken;
} else {
throw new Error('登录响应格式异常');
}
} catch (error) {
console.error('获取档案系统Token失败:', error.message);
throw error;
}
}
/
核心接口：接收OA系统的文件上传请求并转发
路由示例：POST /api/gateway/upload
/
app.post('/api/gateway/upload', upload.single('file'), async (req, res) => {
try {
if (!req.file) {
return res.status(400).json({ success: false, message: '未检测到上传文件' });
}
// 1. 获取鉴权Token
const token = await getArchiveToken();
// 2. 构建转发给档案系统的FormData
const form = new FormData();
// 添加文件流
form.append('file', req.file.buffer, {
filename: req.file.originalname,
contentType: req.file.mimetype
});
// 添加业务元数据（如档案编号、归档年份等）
// 这些字段通常来自OA系统的req.body
if (req.body.metadata) {
form.append('metadata', JSON.stringify(req.body.metadata));
}
// 档案分类ID
if (req.body.categoryId) {
form.append('categoryId', req.body.categoryId);
}
// 3. 发起请求转发
const targetUrl = `${ARCHIVE_SYSTEM_BASE_URL}/api/documents/upload`;
const response = await axios.post(targetUrl, form, {
headers: {
...form.getHeaders(),
// 携带鉴权Token
'Authorization': `Bearer ${token}`
},
// 增加超时时间，防止大文件上传中断
timeout: 60000
});
// 4. 将档案系统的返回结果标准化后返回给OA
return res.json({
success: true,
data: response.data.data,
message: '归档成功'
});
} catch (error) {
console.error('转发请求失败:', error.response ? error.response.data : error.message);
return res.status(500).json({
success: false,
message: '网关转发失败: ' + (error.response ? error.response.statusText : error.message)
});
}
});
// 健康检查接口
app.get('/health', (req, res) => {
res.json({ status: 'ok', timestamp: new Date().toISOString() });
});
app.listen(PORT, () => {
console.log(`档案集成网关已启动，监听端口: ${PORT}`);
});

第三步：配置环境变量与参数映射

为了保持代码的灵活性，我们将档案系统的连接信息提取到配置文件中。在项目根目录下创建.env文件。请务必将以下内容中的URL和账号密码替换为你实际环境的真实数据。

 网关监听端口
PORT=3000
档案系统内网地址（请替换为实际IP或域名）
ARCHIVE_BASE_URL=http://192.168.1.100:8080
档案系统管理员账号（需要有归档权限）
ARCHIVE_USER=admin
ARCHIVE_PASSWORD=your_secure_password

关键配置说明：

• ARCHIVE_BASE_URL：必须指向档案系统提供的Web服务入口。如果不知道具体接口路径，建议使用浏览器F12开发者工具的Network面板，抓取登录和上传操作的真实请求地址。
• Token逻辑：上述代码中getArchiveToken函数是一个通用模板。如果档案系统使用Cookie而非Bearer Token，需修改axios请求配置，将withCredentials: true加入，并手动设置Cookie头。

npm install pm2 -g

pm2 start index.js --name "archive-gateway"

pm2 startup
pm2 save

pm2 logs archive-gateway

server {
listen 80;
server_name archive-gateway.yourdomain.com;  替换为你的域名或内网IP
client_max_body_size 100M;  允许上传大文件，根据档案大小调整
location / {
proxy_pass http://127.0.0.1:3000;
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection 'upgrade';
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_cache_bypass $http_upgrade;
超时设置，防止大文件传输超时
proxy_connect_timeout 600;
proxy_send_timeout 600;
proxy_read_timeout 600;
send_timeout 600;
}
}

nginx -t
systemctl reload nginx

curl -X POST \
http://192.168.1.200/api/gateway/upload \
-F 'file=@/path/to/test.pdf' \
-F 'categoryId=101' \
-F 'metadata={"title":"测试档案","creator":"张三"}'

{
"success": true,
"data": {
"docId": "ARC20231027001",
"status": "archived"
},
"message": "归档成功"
}