基于企微API与CRM对接，构建试听后的自动化跟进与转化SOP

一、问题背景试听结束后的“黄金48小时”为何总是浪费从技术视角分析试听课结束后到用户购买决策之间存在一个典型的转化漏斗但大多数机构的漏斗漏掉了大部分用户跟进滞后试听课结束后运营人员需要手动整理意向名单再逐一私聊。这个“人工处理窗口”通常需要4-8小时等销售联系用户时用户的购买冲动已大幅下降。研究表明90%的试听用户会在48小时内彻底沉默如果未及时跟进。策略不统一不同销售对同一类用户的跟进话术、节奏完全不同导致转化率波动大。有的销售急于推正价课有的销售只发资料不催单缺乏标准化的SOP标准作业程序。数据割裂用户是否观看了回放是否点击了资料链接是否在群里提问这些行为数据分散在多个系统无法整合成统一的用户画像导致销售跟进时信息不全。官方API无自动化流程能力企业微信官方API只提供基础的消息发送和标签管理接口无法实现“如果A事件发生则N小时后执行B动作”这样的条件触发逻辑。需要自研自动化引擎。二、技术方案构建“事件驱动时间触发”的自动化跟进引擎核心设计思路是将跟进流程抽象为状态机触发器用户处于某个状态如“已试听未互动”当满足特定条件时间到达行为触发则执行预设动作发送消息、打标签、分配销售。️ 方案架构行为数据源直播/回放/资料/咨询 → 事件中心 → SOP规则引擎 → 执行器企微API/短信/内部通知行为数据采集通过第三篇的直播Webhook、资料下载链接埋点、咨询会话记录收集用户行为数据。事件标准化将各类行为转化为标准事件如trial.completed试听完成、replay.watched回放观看、material.downloaded资料下载。SOP规则配置在后台配置自动化规则例如规则1用户完成试听 24小时未咨询 → 发送优惠券规则2用户观看回放超过50% 未付费 → 分配销售1v1跟进规则3用户点击购买链接但未支付 → 30分钟后发送支付提醒定时任务调度将满足条件的用户写入延迟队列在指定时间执行动作。⚙️ 技术选型对比方案原理优点缺点适用场景自研SOP引擎基于消息队列定时任务完全可控可定制复杂规则开发成本高有开发团队的中大型机构CRM内置自动化使用第三方CRM的自动化工作流快速上线无需开发规则灵活性有限中小机构快速启动企微第三方应用安装企微应用市场的营销自动化工具开箱即用集成度高数据沉淀在第三方预算充足的机构企销宝SOP模块基于iPad协议实现自动化跟进无频次限制支持复杂动作需合规使用追求极致自动化的机构本文采用自研SOP引擎企微API的组合方案兼顾灵活性与数据安全。三、实现步骤从试听结束到付费转化的自动化流水线步骤1环境准备账号企业微信已认证主体、CRM系统或自研用户数据库、消息队列RabbitMQ/Kafka。工具Node.js/Python环境、Redis存储用户状态、MySQL存储SOP规则与执行日志。配置要求需要支持定时任务调度如Celery Beat、Node-Schedule。步骤2功能配置 —— SOP规则引擎设计核心逻辑将运营策略抽象为可配置的规则支持条件组合与动作序列。配置步骤定义事件模型javascript// 事件标准格式 { event_id: xxx, // 唯一ID用于去重 event_type: trial.completed, // 事件类型 user_id: external_userid, // 用户ID course_id: python_101, // 课程ID timestamp: 1645000000000, // 发生时间 properties: { // 额外属性 duration: 3600, // 观看时长秒 interacted: true, // 是否互动 source: live // 来源live/replay } }SOP规则配置表设计规则ID触发事件条件延迟时间执行动作优先级1trial.completedproperties.duration 18001小时发送回放链接课后测验12trial.completedproperties.interacted true2小时分配销售跟进23replay.watchedproperties.watch_percent 7030分钟发送限时优惠券34material.downloaded-24小时发送相似课程推荐45cart.abandoned-30分钟发送支付提醒5规则引擎实现python# sop_engine.py - SOP规则引擎 from celery import Celery from datetime import datetime, timedelta import json app Celery(sop_engine, brokerredis://localhost:6379/0) app.task def process_event(event_json): 处理用户行为事件 event json.loads(event_json) # 查询匹配的SOP规则 rules get_matching_rules(event[event_type]) for rule in rules: # 检查条件是否满足 if check_conditions(rule[conditions], event[properties]): # 计算执行时间 execute_time datetime.now() timedelta(hoursrule[delay_hours]) # 创建待执行任务 create_scheduled_task({ rule_id: rule[id], user_id: event[user_id], course_id: event[course_id], execute_time: execute_time.timestamp(), action: rule[action] }) def check_conditions(conditions, properties): 条件检查 for key, value in conditions.items(): if key.startswith(properties.): prop_key key.replace(properties., ) if prop_key not in properties: return False if isinstance(value, dict): # 支持比较操作符 if in value: return properties[prop_key] value[] elif in value: return properties[prop_key] value[] elif in in value: return properties[prop_key] in value[in] else: if properties[prop_key] ! value: return False return True步骤3代码实现 —— 执行器与消息发送python# executor.py - 任务执行器 import requests import json from datetime import datetime class ActionExecutor: SOP动作执行器 def __init__(self): self.token_cache {} def execute(self, task): 执行SOP任务 action_type task[action][type] if action_type send_message: self.send_message(task) elif action_type assign_sales: self.assign_sales(task) elif action_type send_coupon: self.send_coupon(task) elif action_type add_tag: self.add_tag(task) # 记录执行日志 log_execution(task) def send_message(self, task): 发送企微消息 user_id task[user_id] content task[action][content] # 根据模板生成个性化内容 content content.replace({{course_name}}, task[course_name]) content content.replace({{sales_name}}, task.get(sales_name, 班主任)) # 调用企微API token self.get_access_token() url fhttps://qyapi.weixin.qq.com/cgi-bin/externalcontact/message/send?access_token{token} payload { touser: user_id, msgtype: text, text: {content: content} } resp requests.post(url, jsonpayload) return resp.json() def send_coupon(self, task): 发送优惠券需对接教务系统 user_id task[user_id] course_id task[course_id] coupon_value task[action][coupon_value] expire_days task[action].get(expire_days, 3) # 调用教务系统API生成优惠券 coupon_data { user_id: user_id, course_id: course_id, value: coupon_value, expire_at: (datetime.now() timedelta(daysexpire_days)).isoformat() } resp requests.post( https://crm.yourschool.com/api/coupons/create, jsoncoupon_data, headers{Authorization: Bearer YOUR_API_KEY} ) if resp.status_code 200: coupon_code resp.json()[coupon_code] # 发送优惠券消息 self.send_message({ user_id: user_id, action: { content: f恭喜您获得{coupon_value}元限时优惠券优惠码{coupon_code}有效期{expire_days}天。点击立即使用https://yourdomain.com/course/{course_id} } }) def get_access_token(self): 获取企微access_token带缓存 # 从Redis获取若过期则重新获取 pass # 定时任务调度器 app.task def check_scheduled_tasks(): 每分钟执行一次检查到期的SOP任务 current_time datetime.now().timestamp() # 从数据库获取需要执行的任务 tasks get_due_tasks(current_time) executor ActionExecutor() for task in tasks: executor.execute(task) mark_task_executed(task[id])运行效果说明用户完成试听直播后1小时后自动收到回放链接课后测验。若用户观看回放超过70%30分钟后自动收到限时优惠券。若用户点击优惠券但未支付进入购物车 abandonment 流程30分钟后再次提醒。所有动作执行记录存入数据库形成完整的用户转化轨迹。四、最佳实践与踩坑经验⚠️ 频次控制与疲劳度SOP虽然自动化但过度触达会引发用户反感。建议同一用户24小时内最多接收3条消息同一用户7天内最多进入1个SOP流程设置“静默期”用户付费后自动退出所有SOP性能优化SOP规则可能涉及多条件组合查询。建议使用Elasticsearch存储用户行为数据支持快速检索将常用规则编译成Lua脚本在Redis中执行使用消息队列削峰避免瞬时高并发打挂服务 踩坑经验关于SOP打断机制用户可能在SOP执行过程中发生新的行为如主动咨询此时应打断原有流程切换到更高优先级的策略。例如用户主动咨询 → 取消自动发送的资料包转由人工跟进用户已付费 → 取消所有未执行的优惠券任务需要实现动态的任务撤销机制。A/B测试支持SOP规则不是一成不变的。建议在规则引擎中加入流量分配功能同一规则可设置多个变体按比例分配用户持续优化转化率。数据闭环SOP执行后必须追踪后续转化结果。例如发送优惠券后是否有人领券领券后是否购买这些数据应回流到规则引擎用于规则的自优化。五、工具推荐企销宝如何增强SOP自动化能力尽管自研SOP引擎能够实现基础的自动化跟进但在实际运营中存在两个痛点官方API频次限制每月4条的限制对于7天体验营这类高密度触达场景远远不够。无法实现跨平台触达用户可能在企微、短信、APP等多个渠道难以统一管理。企销宝通过iPad协议技术提供了更强大的自动化能力技术优势企销宝不受官方API频次限制可对已添加好友进行高频次1v1触达完美支持7天训练营的每日打卡提醒、作业推送等场景。同时支持多渠道触达企微短信朋友圈根据用户活跃渠道智能选择最优触达方式。SOP模板库企销宝内置教育行业SOP模板如“试听后转化7步曲”“低价课转正价课SOP”等可直接套用修改大幅降低配置成本。模板包含话术库、发送时间、条件分支等完整配置。适合场景适用于高客单价课程如职业培训、考研辅导的精细化运营。通过企销宝设置长达30天的培育SOP每周推送行业干货、学员案例、限时优惠逐步建立信任最终实现转化。