企业微信智能表格对接MySQL发货数据源方案

摘要

本方案用于实现MySQL数据库中view_s4_deliverynotes_with_sn发货视图表数据到企业微信智能表格的自动同步，通过定时脚本、企业微信API调用完成数据拉取、清洗转换与写入，支持增量同步优化、数据去重、异常告警与同步监控，满足发货数据自动化更新、零人工干预与可视化分析的需求。

需求目标

将MySQL数据库10.32.16.38:3306/sysmexdw中的view_s4_deliverynotes_with_sn发货数据自动同步到企业微信智能表格，实现数据自动更新。

方案架构

MySQL数据源 → 定时同步脚本 → 企业微信API → 智能表格
        ↓                          ↑
        └── 数据清洗/转换/去重 ────┘

前置准备

数据库信息

主机：10.32.16.38
端口：3306
数据库：sysmexdw
视图表：view_s4_deliverynotes_with_sn

企业微信配置

已创建企业微信自建应用，获得corpid和corpsecret
已开通智能表格API权限
已创建目标智能表格，获得sheetid
已配置应用对智能表格的读写权限

实施步骤

步骤1：确认智能表格字段映射

需提前对齐智能表格列与数据库字段的对应关系，示例映射如下：

列名	类型	对应数据库字段
发货单号	文本	delivery_note_id
物料编码	文本	material_code
物料名称	文本	material_name
序列号	文本	serial_number
发货日期	日期	delivery_date
客户名称	文本	customer_name
发货数量	数字	quantity
发货状态	单选	status
创建时间	日期	create_time

步骤2：编写同步脚本

提供Node.js版本示例代码如下：

const mysql = require('mysql2/promise');
const axios = require('axios');
// 数据库配置
const dbConfig = {
  host: '10.32.16.38',
  port: 3306,
  user: '数据库用户名',
  password: '数据库密码',
  database: 'sysmexdw'
};
// 企业微信配置
const wecomConfig = {
  corpid: '企业微信corpid',
  corpsecret: '应用secret',
  sheetid: '智能表格ID',
  accessToken: ''
};
// 获取access_token
async function getAccessToken() {
  const res = await axios.get(`https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=${wecomConfig.corpid}&corpsecret=${wecomConfig.corpsecret}`);
  wecomConfig.accessToken = res.data.access_token;
}
// 从MySQL查询增量数据
async function getDeliveryData(lastSyncTime) {
  const conn = await mysql.createConnection(dbConfig);
  const [rows] = await conn.execute(`
    SELECT * FROM view_s4_deliverynotes_with_sn 
    WHERE create_time > ? 
    ORDER BY create_time ASC
  `, [lastSyncTime]);
  await conn.end();
  return rows;
}
// 写入数据到智能表格
async function writeToSheet(data) {
  if (data.length === 0) return;
  
  // 转换数据格式
  const values = data.map(row => [
    row.delivery_note_id,
    row.material_code,
    row.material_name,
    row.serial_number,
    row.delivery_date,
    row.customer_name,
    row.quantity,
    row.status,
    row.create_time
  ]);
  await axios.post(`https://qyapi.weixin.qq.com/cgi-bin/wedrive/sheet/add_rows?access_token=${wecomConfig.accessToken}`, {
    sheetid: wecomConfig.sheetid,
    values: values
  });
}
// 主同步函数
async function sync() {
  try {
    await getAccessToken();
    
    // 读取上次同步时间（可以存在本地文件或数据库）
    const lastSyncTime = '2026-03-01 00:00:00'; // 首次同步时间
    
    // 获取增量数据
    const data = await getDeliveryData(lastSyncTime);
    console.log(`获取到${data.length}条新数据`);
    
    // 写入智能表格
    await writeToSheet(data);
    console.log('同步完成');
    
    // 更新上次同步时间
    // fs.writeFileSync('last_sync_time.txt', new Date().toISOString().slice(0, 19).replace('T', ' '));
  } catch (error) {
    console.error('同步失败:', error.message);
  }
}
// 执行同步
sync();

步骤3：配置定时执行任务

可选择以下两种方式实现定时触发同步脚本：

Windows任务计划程序配置

新建任务，触发器设置为每小时执行一次
操作设置为启动程序：node "C:\scripts\sync_delivery.js"
配置错误重试和日志记录

pm2进程托管配置

npm install pm2 -g
pm2 start sync_delivery.js --cron "0 * * * *" --name "发货数据同步"

高级配置

增量同步优化

记录每次同步的最大id或create_time作为同步位点，每次只同步新增数据
避免全表扫描，提升同步效率

数据去重

以发货单号+序列号作为唯一键，避免重复写入
同步前查询智能表格是否已存在该记录

异常处理

同步失败自动重试（最多3次）
失败时发送告警通知到企业微信群
记录详细的同步日志，方便排查问题

数据统计

每日自动统计当日发货总量、异常订单
自动生成统计报表保存到微盘

同步监控

监控项	阈值	告警方式
同步失败	连续2次失败	企业微信消息
新增数据量	>1000条/小时	告警通知
同步延迟	>30分钟	告警通知

预期效果

实时性：数据延迟不超过1小时
准确性：数据准确率100%，无重复、无遗漏
自动化：无需人工干预，自动同步
可视化：在智能表格中直接查看、筛选、分析发货数据

实施所需信息

实施本方案需提前提供以下信息：

数据库的用户名和密码
企业微信应用的corpid和corpsecret
目标智能表格的链接或sheetid
智能表格的列结构和字段对应关系

EL-Notepad

探索

企业微信智能表格对接MySQL数据源方案