当前位置：首页 > news >正文

n8n + 企微API：构建自动化群发与智能回复工作流

news 2026/5/12 0:53:40

摘要

运营人员每天需要手动群发消息、回复重复咨询，效率低且容易遗漏。本文基于n8n工作流引擎与企业微信API，设计了一套自动化群发+智能回复的Pipeline。通过定时触发、标签筛选、大模型语义理解，实现千人千面的消息推送和7×24小时自动应答。方案无需复杂开发，适合技术运营快速落地私域自动化。

一、问题背景

在企业微信私域运营中，群发和自动回复是最基础也最耗时的两大操作。目前多数团队仍然依赖人工或简单工具，存在以下技术痛点：

群发效率低：运营需逐条选择客户/群聊，复制粘贴消息，无法根据标签、活跃度等条件进行精细化筛选。官方API虽支持群发，但需自建系统管理标签和发送逻辑。

回复不及时：客户在群内或1v1提问，运营无法24小时在线。关键词机器人只能匹配固定话术，无法理解用户真实意图，经常答非所问。

数据割裂：群发效果（打开率、回复率）难以统计，自动回复缺乏对话历史记忆，无法持续优化。

官方限制：

企微API的群发接口仅支持认证企业号，且每日发送次数有限
自动回复需自建应用并配置回调，涉及服务器开发和加解密
无法直接与CRM、标签系统联动

因此，我们需要一个可编排的自动化引擎，将群发、回复、数据统计串联起来，同时兼顾灵活性和可扩展性。

二、技术方案

方案架构图（文字描述）

本方案以n8n为核心编排工具，连接企微API、数据库和大模型服务：

text

[触发层] 定时触发器/Webhook → [处理层] n8n工作流 → [执行层] 企微API ├─ 数据库查询（标签/用户） ├─ 大模型生成（个性化内容/回复） └─ 数据统计与存储

工作流逻辑：

自动化群发：
- 定时每天10:00触发
- 从数据库查询今日需触达的标签组（如“活跃用户”“待激活”）
- 调用企微API获取对应标签下的客户列表
- 根据模板生成个性化消息（可结合大模型插入用户昵称）
- 分批调用企微群发接口，记录发送日志
智能自动回复：
- 企微应用接收用户消息，通过Webhook推送到n8n
- n8n调用大模型API（如DeepSeek）理解意图并生成回复
- 回复内容通过企微API发送给用户
- 同时将对话记录存入数据库，用于后续分析

技术选型说明

组件	选型理由	替代方案
工作流引擎	n8n：可视化编排，支持HTTP请求、数据库操作、条件判断	Apache Airflow（重量级）、Zapier（付费）
大模型	DeepSeek API：成本低，支持长上下文，可强制JSON输出	OpenAI（费用高）、本地模型（需GPU）
数据库	PostgreSQL/MySQL：存储标签、用户、对话记录	简道云（零代码但灵活度低）
企微API	企业微信自建应用：支持发送消息、获取客户详情	企微会话存档（仅限内部）

与其他方案对比

相比市面上的群发工具（如微伴、鲸奇），本方案完全自主可控，数据存储在自有数据库，且可通过n8n灵活接入AI能力；相比纯代码开发，n8n大幅降低开发和维护成本。

三、实现步骤

步骤1：环境准备

所需账号/工具：

n8n 实例（Docker部署或云托管）
企业微信认证账号（需自建应用，获取corpid、agentid、secret）
数据库（MySQL/PostgreSQL，用于存储标签和客户关系）
DeepSeek API Key（可选，用于智能回复）

配置要求：

企微自建应用需配置可信IP（n8n服务器IP）和接收消息服务器URL（指向n8n的Webhook）
数据库需提前建表：customers（客户id、标签）、conversations（对话记录）、send_logs（发送日志）

步骤2：功能配置

第一步：获取企微access_token

在n8n中创建“HTTP Request”节点，调用企微API获取token，并使用“IF”节点判断是否成功，将token存入变量供后续复用。

第二步：自动化群发工作流

Schedule Trigger 节点：设置cron表达式0 10 * * *（每天10点）
数据库查询节点：从标签表中查询今天需要发送的标签组，例如：
sql
```
SELECT tag_name, customer_ids FROM send_plan WHERE send_date = CURDATE()
```
循环节点：对每个标签组进行循环
企微获取客户节点：调用企微APIexternalcontact/list获取该标签下的客户列表（需提前在企微打好标签）
生成消息节点：可使用DeepSeek生成个性化文案，或简单拼接模板
- 示例Prompt：“为以下客户生成一条关怀消息，客户名：{{customer.name}}，要求亲切自然。”
企微群发节点：调用企微APIexternalcontact/add_msg_template创建群发任务
- 注意群发频率限制（每个客户每天最多接收1次）
记录日志节点：将发送记录写入数据库

第三步：智能自动回复工作流

Webhook 节点：配置为企微接收消息的URL（需支持POST）
解析消息节点：从XML中提取用户id、消息内容
查询上下文节点：从数据库获取该用户最近5条对话记录

调用大模型节点：

构建Prompt：

text

你是一个企业微信客服，请根据历史对话和用户问题，生成友好、准确的回复。 历史对话：{{history}} 用户问题：{{content}} 如果问题超出知识范围，请引导用户联系人工。

使用DeepSeek API生成回复

发送消息节点：调用企微APImessage/send发送文本消息给用户
存储对话节点：将本次对话存入数据库

参数含义解释：

企微APIexternalcontact/add_msg_template需要传入text或attachments，并指定发送范围（external_userid列表）
群发任务创建后不会立即发送，需调用externalcontact/get_group_msg_result查询状态
自动回复的Webhook需进行加解密，n8n可使用“Crypto”节点处理（需安装对应包）

步骤3：代码示例（可选）

对于复杂逻辑，n8n支持插入Python/JavaScript代码。例如，对客户列表进行分批处理：

javascript

// JavaScript 代码节点：将客户ID数组分批，每批100个（企微接口限制） const customerIds = $input.all()[0].json.customerIds; const batchSize = 100; const batches = []; for (let i = 0; i < customerIds.length; i += batchSize) { batches.push(customerIds.slice(i, i + batchSize)); } return batches.map(batch => ({ json: { batch } }));