上周接了个客户需求说要做一个微信电商客服自动化的综合应用。我当时差点一口茶喷出来——这哪是一个需求分明是四个需求打包。冷静下来之后我把需求拆成了4个功能模块分别设计最后用Eyun的接口串起来效果还不错。一、消息处理模块8种消息类型全覆盖这个模块的核心职责是处理所有微信端的消息发送。一开始客户只说要发文字后来又加了图片、语音、文件……前前后后列了8种消息类型。Eyun的sendText接口覆盖了文字消息sendImage接口处理图片发送另外还有语音、视频、文件、链接、名片、小程序等接口基本把微信能发的消息类型都覆盖了。设计上我做了一个消息类型路由根据业务场景自动选择对应接口比如订单通知用文字商品详情用图文链接。关键点在于消息去重和失败重试我给每条消息加了唯一ID配合Token鉴权机制避免网络波动导致的重复发送问题。二、事件监听模块4种事件回调实时感知光有发送还不够客户还要求实时感知微信端的变化比如谁加了好友、谁退了群、谁发了消息。这个模块的职责就是监听所有微信事件。我用Eyun的Webhook回调来接收4种核心事件消息事件、好友事件、群事件、登录状态事件。每种事件都会推送到我配置的回调地址后端解析JSON格式的数据后做相应处理。Eyun开发文档里对每种事件的回调格式都有详细说明我直接照着写解析函数就行。设计要点是回调地址必须做签名验证防止伪造请求。另外加了事件队列高并发时先入队再异步处理避免丢事件。三、数据管理模块构建用户关系数据图谱这个模块是整个系统的数据底座。客户说要做千人千面的客服那就得有用户数据支撑。Eyun提供了消息记录查询、联系人列表同步、群成员管理等接口我每天定时拉取一次全量联系人数据增量同步消息记录再结合群管理接口维护群成员关系。这些数据整合起来就是一张完整的用户关系图谱——谁和谁是好友、谁在哪个群、历史聊过什么一目了然。Eyun平台的管理后台也能直接看这些数据方便运营同学排查问题。设计上我用了wId实例ID来区分不同的微信账号多账号场景下数据不会串。另外做了冷热数据分离历史消息归档到对象存储只保留近30天的热数据在库。四、自动化调度模块从被动响应到主动触发前面三个模块都是被动的客户要的自动化体现在这个模块里。它的职责是根据特定条件自动执行任务。Eyun的Webhook事件回调可以作为触发源比如收到下单关键词就自动触发发货通知流程。我在这个基础上加了定时任务每天早上9点推送新品、条件判断新好友3分钟内自动发送欢迎语、批量发送活动通知按标签分组推送三种调度模式。设计要点是限流控制批量发送时我按每秒不超过5条的速率发送避免触发风控。另外所有自动化任务都留了手动开关和审计日志出了问题能快速回滚。五、4个模块架构图┌─────────────────────────────────────────────────┐ │ 业务接入层 │ │ 电商系统 客服系统 运营后台 │ └──────────────┬───────────────┬──────────────────┘ │ │ ┌──────────────▼───────────────▼──────────────────┐ │ 统一调度框架 │ │ ┌──────────┐ ┌──────────┐ ┌──────────┐ │ │ │消息处理 │ │事件监听 │ │自动化调度│ │ │ │ 模块 │ │ 模块 │ │ 模块 │ │ │ └────┬─────┘ └────┬─────┘ └────┬─────┘ │ │ │ │ │ │ │ └────────────┼────────────┘ │ │ │ │ │ ┌──────▼──────┐ │ │ │ 数据管理模块 │ │ │ └─────────────┘ │ └──────────────────────┬──────────────────────────┘ │ ┌────────▼────────┐ │ Eyun API接口 │ │ (wId Token) │ └─────────────────┘六、4模块统一调度框架下面是我实际项目中用的调度框架精简版用Node.js写的核心就是把4个模块串起来const express require(express); const app express(); // Eyun配置信息 const EYUN_CONFIG { baseUrl: https://www.eyunz.com/api, wId: 你的实例ID, token: 你的鉴权Token }; // 模块初始化 const messageModule require(./modules/message)(EYUN_CONFIG); const eventModule require(./modules/event)(EYUN_CONFIG); const dataModule require(./modules/data)(EYUN_CONFIG); const scheduleModule require(./modules/schedule)(EYUN_CONFIG); // Webhook回调入口 - 事件监听模块 app.post(/webhook, async (req, res) { const event eventModule.verifyAndParse(req.body); if (!event) return res.status(403).send(invalid); res.status(200).send(success); // 事件路由到各模块 await dataModule.syncFromEvent(event); // 数据模块增量同步 await scheduleModule.triggerByEvent(event); // 调度模块触发自动化 await messageModule.autoReply(event); // 消息模块自动回复 }); // 调度模块启动定时任务 条件判断 scheduleModule.start({ cronTasks: [{ time: 0 9 * * *, action: pushNewProducts }], rules: [{ condition: newFriendWithin3min, action: sendWelcome }] }); app.listen(3000, () console.log(调度框架启动成功));写在最后这4个模块设计完之后客户那个看似复杂的综合应用就清晰了。其实做这类系统最怕的就是需求不拆解眉毛胡子一把抓。拆成独立模块之后每个模块用Eyun开发文档里对应的API去支撑边界清晰出问题也好排查。Eyun在这块做得比较扎实接口覆盖全面wId和Token的鉴权机制也很规范帮我省了不少重复造轮子的功夫。
上周接了个客户需求说要做一个微信电商客服自动化的综合应用。我当时差点一口茶喷出来——这哪是一个需求分明是四个需求打包。冷静下来之后我把需求拆成了4个功能模块分别设计最后用Eyun的接口串起来效果还不错。一、消息处理模块8种消息类型全覆盖这个模块的核心职责是处理所有微信端的消息发送。一开始客户只说要发文字后来又加了图片、语音、文件……前前后后列了8种消息类型。Eyun的sendText接口覆盖了文字消息sendImage接口处理图片发送另外还有语音、视频、文件、链接、名片、小程序等接口基本把微信能发的消息类型都覆盖了。设计上我做了一个消息类型路由根据业务场景自动选择对应接口比如订单通知用文字商品详情用图文链接。关键点在于消息去重和失败重试我给每条消息加了唯一ID配合Token鉴权机制避免网络波动导致的重复发送问题。二、事件监听模块4种事件回调实时感知光有发送还不够客户还要求实时感知微信端的变化比如谁加了好友、谁退了群、谁发了消息。这个模块的职责就是监听所有微信事件。我用Eyun的Webhook回调来接收4种核心事件消息事件、好友事件、群事件、登录状态事件。每种事件都会推送到我配置的回调地址后端解析JSON格式的数据后做相应处理。Eyun开发文档里对每种事件的回调格式都有详细说明我直接照着写解析函数就行。设计要点是回调地址必须做签名验证防止伪造请求。另外加了事件队列高并发时先入队再异步处理避免丢事件。三、数据管理模块构建用户关系数据图谱这个模块是整个系统的数据底座。客户说要做千人千面的客服那就得有用户数据支撑。Eyun提供了消息记录查询、联系人列表同步、群成员管理等接口我每天定时拉取一次全量联系人数据增量同步消息记录再结合群管理接口维护群成员关系。这些数据整合起来就是一张完整的用户关系图谱——谁和谁是好友、谁在哪个群、历史聊过什么一目了然。Eyun平台的管理后台也能直接看这些数据方便运营同学排查问题。设计上我用了wId实例ID来区分不同的微信账号多账号场景下数据不会串。另外做了冷热数据分离历史消息归档到对象存储只保留近30天的热数据在库。四、自动化调度模块从被动响应到主动触发前面三个模块都是被动的客户要的自动化体现在这个模块里。它的职责是根据特定条件自动执行任务。Eyun的Webhook事件回调可以作为触发源比如收到下单关键词就自动触发发货通知流程。我在这个基础上加了定时任务每天早上9点推送新品、条件判断新好友3分钟内自动发送欢迎语、批量发送活动通知按标签分组推送三种调度模式。设计要点是限流控制批量发送时我按每秒不超过5条的速率发送避免触发风控。另外所有自动化任务都留了手动开关和审计日志出了问题能快速回滚。五、4个模块架构图┌─────────────────────────────────────────────────┐ │ 业务接入层 │ │ 电商系统 客服系统 运营后台 │ └──────────────┬───────────────┬──────────────────┘ │ │ ┌──────────────▼───────────────▼──────────────────┐ │ 统一调度框架 │ │ ┌──────────┐ ┌──────────┐ ┌──────────┐ │ │ │消息处理 │ │事件监听 │ │自动化调度│ │ │ │ 模块 │ │ 模块 │ │ 模块 │ │ │ └────┬─────┘ └────┬─────┘ └────┬─────┘ │ │ │ │ │ │ │ └────────────┼────────────┘ │ │ │ │ │ ┌──────▼──────┐ │ │ │ 数据管理模块 │ │ │ └─────────────┘ │ └──────────────────────┬──────────────────────────┘ │ ┌────────▼────────┐ │ Eyun API接口 │ │ (wId Token) │ └─────────────────┘六、4模块统一调度框架下面是我实际项目中用的调度框架精简版用Node.js写的核心就是把4个模块串起来const express require(express); const app express(); // Eyun配置信息 const EYUN_CONFIG { baseUrl: https://www.eyunz.com/api, wId: 你的实例ID, token: 你的鉴权Token }; // 模块初始化 const messageModule require(./modules/message)(EYUN_CONFIG); const eventModule require(./modules/event)(EYUN_CONFIG); const dataModule require(./modules/data)(EYUN_CONFIG); const scheduleModule require(./modules/schedule)(EYUN_CONFIG); // Webhook回调入口 - 事件监听模块 app.post(/webhook, async (req, res) { const event eventModule.verifyAndParse(req.body); if (!event) return res.status(403).send(invalid); res.status(200).send(success); // 事件路由到各模块 await dataModule.syncFromEvent(event); // 数据模块增量同步 await scheduleModule.triggerByEvent(event); // 调度模块触发自动化 await messageModule.autoReply(event); // 消息模块自动回复 }); // 调度模块启动定时任务 条件判断 scheduleModule.start({ cronTasks: [{ time: 0 9 * * *, action: pushNewProducts }], rules: [{ condition: newFriendWithin3min, action: sendWelcome }] }); app.listen(3000, () console.log(调度框架启动成功));写在最后这4个模块设计完之后客户那个看似复杂的综合应用就清晰了。其实做这类系统最怕的就是需求不拆解眉毛胡子一把抓。拆成独立模块之后每个模块用Eyun开发文档里对应的API去支撑边界清晰出问题也好排查。Eyun在这块做得比较扎实接口覆盖全面wId和Token的鉴权机制也很规范帮我省了不少重复造轮子的功夫。
