MBE PCF 自动化实施计划

版本: v1.0
日期: 2026-02-11
关联: MBE PCF 研究计划

一、自动化架构

┌─────────────────────────────────────────────────────────────────────┐
│                         PCF 自动化流水线                              │
├─────────────────────────────────────────────────────────────────────┤
│  1. 埋点层     │ 落地页/API 携带 utm_* → 事件 payload                  │
│  2. 采集层     │ POST /api/marketing/events → Redis 存储              │
│  3. 归因层     │ 按 lead_id 关联 channel，写入 channel_attr           │
│  4. 聚合层     │ 定时任务按 channel 聚合漏斗指标                       │
│  5. 输出层     │ GET /api/marketing/pcf/dashboard → 看板/告警          │
└─────────────────────────────────────────────────────────────────────┘

二、核心自动化组件

2.1 UTM 埋点自动化

位置	实现	说明
落地页	URL 参数 → localStorage → 事件	用户访问时解析 `?utm_source=xx&utm_medium=xx`，后续事件自动携带
聊天 API	请求体 `utm_source` 等	前端传入，后端写入事件 payload
留资表单	URL 解析 + localStorage + 提交透传	访问时解析 UTM 写入 localStorage，提交时从 localStorage 读取并入 payload，后端透传

标准化字段：utm_source、utm_medium、utm_campaign、utm_content、utm_term

2.2 渠道映射规则

utm_source	渠道	说明
`direct` / 空	直接	直接访问
`google` / `baidu`	搜索	SEO/SEM
`zhihu` / `wechat`	内容	内容获客
`landing`	PLG	落地页
`referral`	PLG	推荐 Loop（试用用户分享）
`api` / `sdk` / `developer`	开发者	开发者生态
`partner_*`	渠道	渠道合作

2.3 自动化聚合

Celery 定时任务（每日 02:00）：

按 channel 统计：访问量、对话数、留资数、试用数、付费数
计算：转化率、CAC（若有人工成本输入）、平均周期
写入 Redis：mbe:marketing:pcf:daily:{date}

2.4 PCF 看板 API

GET /api/marketing/pcf/dashboard：

参数：date_from、date_to、channel（可选）
返回：各渠道漏斗、转化率、综合评分

2.5 PCF 异常告警

组件	说明
`check_pcf_anomaly()`	对比当前/基线转化率，下降超过阈值时告警
`GET /api/marketing/pcf/anomaly-check`	手动触发异常检测接口
Celery 任务 `pcf_anomaly_check`	每日 02:00 自动执行（beat_schedule）
Webhook 推送	配置 `MARKETING_PCF_ALERT_WEBHOOK_URL` 接收告警

告警逻辑：各渠道转化率与基线对比，下降超过 MARKETING_PCF_ALERT_THRESHOLD（默认 0.20）时触发。

三、实施清单

Phase 1：数据埋点（1 周）

落地页注入 UTM 解析脚本
事件 payload 支持 utm_source 等
渠道映射：utm_source → channel 枚举
留资表单 UTM 透传（URL 解析 → localStorage → 提交时透传）

Phase 2：聚合与 API（1 周）

marketing.pcf_analytics 模块
Celery 任务 pcf_daily_aggregate_task（可选，当前看板基于实时聚合）
API GET /api/marketing/pcf/dashboard

Phase 3：告警与迭代（持续）

PCF 异常告警（转化率骤降、渠道异常）
与 BI 工具对接（可选）
季度自动生成 PCF 报告

Phase 4：优先 Loop 实施（2–4 周）

详见 MBE PCF 研究计划 2.4 节。

Loop	实施项	状态
PLG 推荐奖励	落地页分享入口、`utm_source=referral`、`referral_share` 埋点、奖励逻辑（试用延长）	[x]
PLG 推荐奖励	看板指标：`referral_share`、`referral_visit_count`（utm_source=referral）、K 因子	[x]
开发者内容产出	渠道映射：`utm_source=developer` + `utm_content`	[ ]
开发者内容产出	内容登记 API 或表单、`content_referral_visit` 看板	[ ]

四、数据流

用户访问 landing?utm_source=zhihu&utm_medium=article
    → 前端解析 utm_* 写入 localStorage
    → 用户发起对话 → POST /chat { question, utm_source, utm_medium }
    → 后端触发 chatbot_start 事件，payload 含 utm_*
    → 存储到 Redis
    → 每日聚合任务按 channel 汇总
    → 看板 API 返回

五、代码位置

组件	路径
UTM 解析	落地页 `marketing_events.py` 内联脚本
留资表单 UTM	`marketing_events.py` lead-form 页面内联脚本 + `submit_lead_form` 透传
渠道映射	`marketing.pcf_analytics.map_utm_to_channel`
埋点	`workflow_engine.process_event` 调用 `record_event_for_pcf`
看板 API	`GET /api/marketing/pcf/dashboard`
异常检测	`marketing.pcf_analytics.check_pcf_anomaly`
异常 API	`GET /api/marketing/pcf/anomaly-check`
定时任务	`tasks.marketing_tasks.pcf_anomaly_check`（Celery beat 每日 02:00）
推荐分享	落地页「分享给好友」按钮，`referral_share` 埋点
推荐关联	`POST /api/marketing/referral/link`，`marketing.storage.link_referral_code_to_user`

六、使用说明

6.1 带 UTM 的落地页链接

https://your-domain/api/marketing/landing?utm_source=zhihu&utm_medium=article&utm_campaign=2026q1

6.2 看板 API 示例

GET /api/marketing/pcf/dashboard
GET /api/marketing/pcf/dashboard?date_from=2026-02-01&date_to=2026-02-11
GET /api/marketing/pcf/dashboard?channel=plg

6.3 留资表单 UTM 透传

留资表单页带 UTM 访问时，会自动解析并写入 localStorage，提交时随表单一起发送：

/api/marketing/lead-form?utm_source=zhihu&utm_medium=article&utm_campaign=2026q1

6.4 PLG 推荐 Loop

分享：落地页「分享给好友」按钮，生成 ?utm_source=referral&utm_content={share_code} 链接并复制
埋点：referral_share（分享时）、landing_page_visit（被推荐人访问时带 utm_source=referral）
关联：用户先匿名分享后注册时，需将 share_code 关联到 user_id。方式一：user_register 或 trial_start payload 传入 share_code；方式二：调用 POST /api/marketing/referral/link，Body: { "user_id", "share_code" }（share_code 来自 localStorage 的 mbe_share_code）
奖励：被推荐人 trial_start 时，若 payload 含 utm_source=referral 且 utm_content=share_code，且推荐人已关联，则推荐人试用延长 3 天
前置：平台在触发 trial_start 时需传入 utm_source、utm_content（可从前端 localStorage 的 mbe_utm_source、mbe_utm_content 读取）

6.5 PCF 异常告警

手动检测：GET /api/marketing/pcf/anomaly-check
定时任务：Celery beat 每日 02:00 执行 pcf_anomaly_check
Webhook：配置 MARKETING_PCF_ALERT_WEBHOOK_URL 接收告警推送
阈值：MARKETING_PCF_ALERT_THRESHOLD（默认 0.20，即 20% 下降告警）