智谷直播数据中台

以桌面端为底座，嫁接弹幕游戏、流量营销、私域引流等业务模块，通过网页/公众号/微信小程序触达C端，打通平台方、公会、达人、品牌方、粉丝五方，构建基于直播数据分析与利用的多维互通生态闭环。

v3.0 Windows 10/11 x64 Electron + Node.js + SQLite + Go zegu.top 2026-05-05

1. 产品定位与愿景

一句话定位

智谷是一个以 Windows 桌面端为底座的直播数据中台。桌面端通过三种方式采集直播间全量数据，本地分析存储并定期备份至云端共享库，通过标准化接口向底座上层的业务模块（应用商城内的小程序们）提供数据服务。toB 以桌面端为主，toC 通过网页 + 公众号 + 微信小程序触达粉丝。

产品价值公式

                    智谷 = 数据底座 + 应用商城 + C端触达 + 生态闭环

    ┌────────────────────────────────────────────────────────────────────┐
    │                                                                    │
    │   底座：三通道数据采集 → 本地+云端分析存储 → 标准化接口下发           │
    │                                                                    │
    │   应用商城：弹药游戏 │ 智佳流量营销 │ 私域引流 │ 更多待定           │
    │          （底座上层的"小程序"，用户按需安装）                        │
    │                                                                    │
    │   C端触达：H5网页 + 微信公众号 + 微信小程序                         │
    │          （金币中心、兑换商城、活动中心、个人中心）                   │
    │                                                                    │
    │   生态闭环：平台方 ⇄ 公会 ⇄ 达人 ⇄ 品牌方 ⇄ 粉丝                    │
    │          （五方互通，多维共赢）                                      │
    │                                                                    │
    └────────────────────────────────────────────────────────────────────┘

核心差异化

维度	传统方案	智谷 v3.0
数据采集	单一渠道	三通道：Cookie扫码 + 代理截流 + 抖音开放平台OAuth
数据存储	纯本地或纯云端	本地SQLite为主 + 定期备份云端共享库（脱敏数据全网综合分析）
业务扩展	单体应用，功能写死	底座 + 应用商城机制，业务模块像微信小程序一样按需安装
C端触达	无或单一渠道	网页 + 公众号 + 微信小程序三端统一
生态观	服务单方	五方生态闭环：平台方/公会/达人/品牌方/粉丝多维互通
架构	传统Web或单体	桌面端底座 + 云服务（数据共享+商业变现）+ 可插拔业务模块

目标用户

用户类型	使用端	核心诉求
抖音主播/达人	桌面端 + Web后台	弹幕游戏提升互动率，查看粉丝画像，管理互动活动
公会/MCN机构	Web后台	管理旗下达人，查看多直播间数据汇总，对接品牌方
品牌方/广告主	Web后台	提交商品赞助，获取品牌曝光，查看营销效果数据
粉丝/观众	网页/公众号/小程序	参与互动赚金币，兑换奖品，查看个人数据
平台运营方	Web管理后台	审核管理、财务结算、生态运营、数据大盘
游戏/模块开发者	桌面端 + SDK	基于中台标准接口，开发新的弹幕互动游戏或业务模块

2. 四方（五方）生态闭环

生态关系全景

                              ┌──────────────────────┐
                              │     平台运营方         │
                              │                      │
                              │  审核 · 结算 · 生态运营 │
                              └──────────┬───────────┘
                                         │ 居中连接五方
                   ┌─────────────────────┼─────────────────────┐
                   │                     │                     │
              ┌────▼────┐          ┌────▼────┐          ┌────▼────┐
              │ 公会/MCN │          │ 品牌方   │          │ 达人/主播 │
              │         │          │         │          │         │
              │ 管达人   │  赞助商品 │ 提商品   │  付佣金  │ 开直播   │
              │ 看数据   │◄────────┤ 获曝光   ├────────►│ 跑游戏   │
              │ 接品牌   │  分佣金  │ 看数据   │  带商品  │ 看粉丝   │
              └────┬────┘          └────┬────┘          └────┬────┘
                   │                    │                    │
                   └────────────────────┼────────────────────┘
                                        │ 网页/公众号/小程序触达
                                        ▼
                                  ┌──────────┐
                                  │ 粉丝/C端  │
                                  │          │
                                  │ 看直播   │
                                  │ 参与互动  │
                                  │ 赚金币   │
                                  │ 兑奖品   │
                                  │ 加私域   │
                                  └──────────┘

五方价值闭环

角色	提供什么	获得什么
平台方	提供数据中台工具 + 应用商城 + 生态运营	数据沉淀、服务费/分成、生态话语权
公会/MCN	管理达人、对接品牌资源	达人管理效率、数据决策能力、品牌对接收益
达人/主播	创造直播内容、吸引粉丝	互动率提升、粉丝画像洞察、品牌合作收入
品牌方	提供商品赞助/广告费	精准品牌曝光、用户触达、转化数据
粉丝/观众	参与互动、贡献数据	金币奖励、实物奖品、更好的直播体验

核心逻辑：粉丝互动产生数据 → 平台采集分析 → 数据赋能达人 → 达人粘住粉丝 → 品牌方提供商品 → 粉丝得实惠 → 品牌得曝光 → 公会/达人/平台方共同获益。数据越用越多，生态越滚越大。

3. 整体架构

3.1 架构全景图

┌──────────────────────────────────────────────────────────────────────────────┐
│                        智谷直播数据中台（桌面端 Electron）                         │
│                                                                               │
│  ┌─────────────────────────────────────────────────────────────────────────┐ │
│  │                       底座核心 — 三层结构                               │ │
│  │                                                                          │ │
│  │  ╔════════════════════ 第一层：数据获取（三通道） ════════════════════╗     │ │
│  │  ║  ┌──────────────┐  ┌──────────────┐  ┌──────────────┐  ║     │ │
│  │  ║  │ 通道一        │  │ 通道二        │  │ 通道三        │  ║     │ │
│  │  ║  │ Cookie方式    │  │ 代理截流      │  │ 抖音开放平台   │  ║     │ │
│  │  ║  │              │  │              │  │ OAuth认证     │  ║     │ │
│  │  ║  │ 内置浏览器    │  │ MITM代理     │  │ 官方API调用   │  ║     │ │
│  │  ║  │ 扫码登录      │  │ 截获WS弹幕流  │  │ 用户画像      │  ║     │ │
│  │  ║  │ 提取Cookie   │  │ 实时互动数据  │  │ 行为数据      │  ║     │ │
│  │  ║  └──────┬───────┘  └──────┬───────┘  └──────┬───────┘  ║     │ │
│  │  ╚══════════╪════════════════╪══════════════════╪══════════╝     │ │
│  │             └────────────────┼──────────────────┘               │ │
│  │                              ▼                                   │ │
│  │  ╔════════════════════ 第二层：分析存储（本地+云端共享） ═══════════════╗   │ │
│  │  ║                                                                  ║   │ │
│  │  ║  ┌────────────────────────────────────────────────────────────┐ ║   │ │
│  │  ║  │  本地 SQLite                                                │ ║   │ │
│  │  ║  │  · 用户画像存储  · 实时事件存储  · 业务数据存储                  │ ║   │ │
│  │  ║  │  · 智能标签引擎  · 用户评分算法  · 30天自动清理                  │ ║   │ │
│  │  ║  │  · Local WS Server (127.0.0.1:9600) ← 数据实时分发            │ ║   │ │
│  │  ║  └───────────────────────────┬────────────────────────────────┘ ║   │ │
│  │  ║                              │ 定期备份（脱敏后上传）              ║   │ │
│  │  ║                              ▼                                   ║   │ │
│  │  ║  ┌────────────────────────────────────────────────────────────┐ ║   │ │
│  │  ║  │  云端共享数据库                                              │ ║   │ │
│  │  ║  │  · 所有用户脱敏数据汇总                                        │ ║   │ │
│  │  ║  │  · 全网综合分析（跨直播间/跨公会/跨品类数据对比、大盘趋势）       │ ║   │ │
│  │  ║  └────────────────────────────────────────────────────────────┘ ║   │ │
│  │  ╚══════════════════════════════════════════════════════════════════╝   │ │
│  │                              │                                          │ │
│  │  ╔════════════════════ 第三层：接口下发（对接业务模块+C端） ═════════════╗   │ │
│  │  ║  ┌────────────────────────────────────────────────────────────┐ ║   │ │
│  │  ║  │  标准化数据接口（由 Local WS Server 统一出口）                │ ║   │ │
│  │  ║  │                                                            │ ║   │ │
│  │  ║  │  · 实时事件流接口    · 用户画像查询接口    · 用户筛选接口     │ ║   │ │
│  │  ║  │  · 金币/活动/订单/会员 业务接口                              │ ║   │ │
│  │  ║  │  · C端API（供 H5网页/公众号/微信小程序 调用）                │ ║   │ │
│  │  ║  └────────────────────────────────────────────────────────────┘ ║   │ │
│  │  ╚══════════════════════════════════════════════════════════════════╝   │ │
│  └─────────────────────────────────────────────────────────────────────────┘ │
│                                    │                                         │
│  ┌─────────────────────────────────┼─────────────────────────────────────┐ │
│  │                      应用商城（底座上层业务模块）                         │ │
│  │                                                                        │ │
│  │  ┌──────────────┐  ┌──────────────┐  ┌──────────────┐  ┌──────────┐  │ │
│  │  │  弹药游戏     │  │ 智佳流量营销  │  │  私域引流     │  │  ···     │  │ │
│  │  │  (弹幕游戏)   │  │  (流量营销)   │  │  (私域引流)   │  │ 更多待定  │  │ │
│  │  │              │  │              │  │              │  │          │  │ │
│  │  │ 领地争夺      │  │ 品牌曝光      │  │ 用户筛选      │  │          │  │ │
│  │  │ 贪吃蛇       │  │ 活动裂变      │  │ 精准触达      │  │          │  │ │
│  │  │ 消消乐       │  │ 达人推广      │  │ 线索管理      │  │          │  │ │
│  │  │ 赛车3D       │  │ 数据报告      │  │ 导出投放      │  │          │  │ │
│  │  └──────────────┘  └──────────────┘  └──────────────┘  └──────────┘  │ │
│  │                                                                        │ │
│  │  像微信小程序一样，用户按需从应用商城安装，不跟底座平起平坐                 │ │
│  └────────────────────────────────────────────────────────────────────────┘ │
│                                                                               │
│  ┌─────────────────────────────────────────────────────────────────────────┐ │
│  │                    管理界面（桌面端UI）                                  │ │
│  │                                                                          │ │
│  │   仪表盘 │ 账号授权 │ 直播源 │ 应用商城 │ 用户洞察 │ 业务管理 │ 数据 │ 设置     │ │
│  └─────────────────────────────────────────────────────────────────────────┘ │
└──────────────────────────────────────────────────────────────────────────────┘
                                      │
          ┌───────────────────────────┼───────────────────────────┐
          │                           │                           │
    ┌─────▼─────┐               ┌─────▼─────┐               ┌─────▼─────┐
    │ H5网页      │               │ 微信公众号 │               │ 微信小程序 │
    │           │               │           │               │           │
    │ 金币中心   │               │ 活动推送   │               │ 互动参与   │
    │ 兑换商城   │               │ 金币通知   │               │ 兑换商城   │
    │ 活动中心   │               │ 私域入口   │               │ 个人数据   │
    │ 个人中心   │               │           │               │ 地址管理   │
    └───────────┘               └───────────┘               └───────────┘

3.2 类比微信理解架构层次

微信	智谷	角色
微信 App 本身	桌面端底座	底层基础设施，提供账号、数据、通信、支付等核心能力
微信小程序	应用商城里的小程序（弹药游戏/智佳流量营销/私域引流）	上层业务，用户按需安装，不能脱离底座独立存在
微信公众号	微信公众号 + H5网页	C端触达渠道，连接粉丝
微信支付	金币体系 + 会员体系	商业基础设施，变现闭环
微信开放平台	标准化接口 + 云端共享库	生态开放能力，供第三方开发者接入

底座是"微信"，业务模块是"小程序"，它们不在一个层级。底座提供数据获取、分析存储、接口下发三大核心能力，业务模块通过应用商城机制在底座之上运行，消费底座接口，实现各自的业务逻辑。

4. 底座核心：三层结构

4.1 第一层：数据获取（三种方式）

1 数据获取层

通道一：Cookie 扫码登录

利用 Electron 内置浏览器打开抖音登录页，用户扫码或手机号登录后，自动提取 Cookie 并持久化到本地 SQLite。后续所有需要登录态的请求（如 HTTP API 调用用户画像）都携带此 Cookie。

┌───────────────────────────────────────┐
│  管理界面 → 账号授权 → 打开登录窗口    │
│                                        │
│  BrowserWindow 加载:                    │
│  https://www.douyin.com/?modal_id=login│
│                                        │
│  用户扫码 / 手机号登录                  │
│       │                                │
│       ▼                                │
│  提取 session.cookies                  │
│  → 存入 SQLite platform_config         │
│  → 每10分钟检测Cookie有效期             │
└───────────────────────────────────────┘

通道二：代理截流（MITM）

通过 dy-barrage-grab（C# MITM 代理工具，已内置为 bin/proxypin.exe）截获抖音直播间 WebSocket 数据包，转发到本地。获取实时互动数据：弹幕、点赞、礼物、关注、进入直播间、分享、直播间统计。

通道三：抖音开放平台 OAuth 认证

通过抖音开放平台官方认证接口，在用户授权后获取合法的 API 调用权限。用于补充 Cookie 方式无法覆盖的数据场景（如批量用户查询、账号认证信息等），同时作为合规通道保障数据获取的稳定性。

通道	方式	获取内容	适用场景
通道一	Cookie 扫码	用户画像（昵称/头像/性别/年龄/IP属地/粉丝数/作品数/账号类型）	HTTP API 调用用户画像
通道二	MITM 代理截流	实时互动事件（弹幕/点赞/礼物/关注/进入/分享/统计）	WS 弹幕流实时采集
通道三	OAuth 开放平台	认证用户数据、批量查询、账号信息	合规调用 + 补充数据

4.2 第二层：分析存储（本地 + 云端共享）

2 分析存储层

本地 SQLite（主力存储）

用户画像表：全量用户画像数据（昵称/头像/性别/年龄/IP属地/粉丝数/关注数/作品数/账号类型/认证信息）
实时事件表：所有直播间事件流水（弹幕/点赞/礼物/关注/进入）
直播间会话表：每场直播的统计摘要
业务数据表：公会/达人/粉丝/品牌方/金币/会员/活动/商品/订单/合规等业务数据
平台配置表：Cookie、API密钥、系统设置
模块注册表：应用商城内所有已安装模块的注册信息

Local WebSocket Server（数据实时分发）

开在本机 ws://127.0.0.1:9600，是底座所有数据的统一出口。业务模块（弹药游戏等）和 C端服务通过此 Server 获取实时数据：

实时事件流：弹幕/礼物/关注/进入 — 中台主动推送给所有连接的模块
用户画像查询：业务模块请求 → 中台返回完整画像
用户筛选查询：按多维条件筛选用户
业务接口：金币变动、活动参与、订单操作等业务数据的读写

智能标签引擎

根据用户画像和直播间行为，自动打标：高价值用户、铁粉、活跃用户、新用户、同城、高粉丝、潜在客户、流失预警等。

用户评分算法

0-1000 分综合评分，基于粉丝数、送礼价值、互动频次、关注状态、账号质量五个维度加权计算。

云端共享数据库

定位：不是简单的"云备份"，而是所有 SaaS 用户的脱敏数据汇总分析平台。

本地 SQLite 定期将脱敏后的统计数据上传至云端

云端汇总所有用户的数据，提供全网综合分析能力

例如：跨直播间数据对比、跨公会大盘趋势、品类热度排行、用户行为共性洞察

单个用户可以看到自己的数据对比全网的排名和趋势

4.3 第三层：接口下发

3 接口下发层

底座将所有数据能力以标准化接口的形式下发，供上层业务模块和 C端服务消费。

接口体系

接口类别	方向	协议	消费方
实时事件流	底座 → 业务模块	Local WS	弹药游戏、智佳流量营销、私域引流
用户画像查询	业务模块 → 底座	Local WS	所有业务模块
用户筛选查询	业务模块 → 底座	Local WS	私域引流、智佳流量营销
业务数据接口	双向	Local WS + HTTP	业务模块、管理界面
C端API	C端 → 底座	HTTP REST	H5网页、公众号、微信小程序
云端数据接口	底座 ↔ 云端	HTTPS	云端共享数据库同步

Local WS 通信协议

业务模块(客户端)发送                      底座响应
─────────────────                      ────────
{ action: "register" }       →         { type: "registered" }
{ action: "getConfig" }      →         { type: "config" }
{ action: "status" }         →         { type: "ack" }
{ action: "getUserProfile" } →         { type: "userProfile" }
{ action: "queryUsers" }     →         { type: "userList" }
{ action: "queryEvents" }    →         { type: "eventList" }

底座主动推送
────────────
{ type: "event", event: "chat/like/gift/follow/enter" }
{ type: "command", command: "start/pause/resume/stop/reset" }
{ type: "config" }

4.4 数据库设计

核心业务表

表名	用途	关键字段
UnionList	公会/MCN管理	公会ID、公会名称、联系人、联系电话
AnchorList	达人/主播管理	达人ID、公会ID、名称、抖音账号、直播间地址、粉丝数
FunsList	粉丝管理	粉丝ID、来源达人、来源直播间、粉丝画像快照
BrandList	品牌方管理	品牌ID、品牌名称、联系人、审核状态
CoinList	金币套餐	套餐ID、金币数量、RMB价格
BalanceList	余额管理	用户ID、用户类型、金币余额、积分余额
ChangeList	金币变动流水	用户ID、变动类型、变动数量、变动原因、时间
MemberLevelList	会员等级	等级ID、等级名称、月付价格、年付价格、权益JSON
MemberRecordList	会员订阅记录	用户ID、会员等级、生效时间、到期时间
ActivityList	活动管理	活动ID、达人ID、活动名称、开始/结束时间、活动规则
GoodsList	商品/奖品	商品ID、商品名、图片、价格、库存、提供品牌
OrderList	兑换订单	订单ID、商品ID、用户ID、收货地址、物流单号、状态
AddressList	收货地址	地址ID、用户ID、姓名、电话、详细地址
ComplianceList	合规管理	记录ID、用户ID、活动ID、审核状态、合规备注
FunctionsList	功能开关	功能ID、功能名称、配置值、所属模块

数据层核心表（v2.0 原有，保留）

表名	用途	关键字段
user_profiles	用户画像（核心）	user_id、nickname、gender、age、ip_location、follower_count、user_tags、user_score
live_events	实时事件流水	event_type、user_id、content、value、raw_data
live_sessions	直播间会话	room_id、started_at、ended_at、total_events、total_users
platform_config	平台配置	key、value
modules	模块注册表	module_id、module_name、module_type、entry_file、enabled

5. 应用商城（底座上层业务模块）

应用商城是底座之上的业务层。类似于微信小程序之于微信——底座负责数据采集、存储、分发，业务模块通过标准接口消费数据，实现各自的业务逻辑。用户可根据自身需求，在应用商城中按需安装使用，不必全部安装。

5.1 弹药游戏（弹幕游戏方向）

💣 弹药游戏已设计

利用直播间实时弹幕/点赞/礼物数据驱动游戏内互动。独立无边框窗口供 OBS Window Capture 捕获投到直播间画面。

游戏类型	技术栈	游戏列表
2D 平面	Canvas 2D / Pixi.js	领地争夺、贪吃蛇大作战、消消乐对战、弹幕答题
2.5D 等距	Canvas + 等距引擎	塔防、模拟经营、战棋
3D 三维	Three.js / WebGL	赛车竞速3D、射击对战、跑酷

输入数据：实时事件流（弹幕、点赞、礼物、关注） | 输出形式：无边框游戏窗口（OBS捕获）

5.2 智佳流量营销（流量营销方向）

📣 智佳流量营销规划中

面向品牌方和达人的流量营销工具，利用直播间数据驱动精准营销活动。

品牌曝光：品牌方通过赞助奖品/活动，在直播间获得曝光，系统自动追踪曝光数据
活动裂变：创建互动裂变活动（分享有奖、邀请好友等），结合金币体系激励传播
达人推广：品牌方通过数据分析匹配适合的达人，达人通过接单获得收益
数据报告：自动生成营销效果报告（曝光量、互动率、转化率、ROI）

使用形式：管理界面内嵌面板 | 核心依赖：用户画像 + 金币体系 + 会员体系

5.3 私域引流（私域引流方向）

📮 私域引流规划中

从直播间观众中精准筛选高价值用户，支持导出到私域平台（微信、企微等）。

用户筛选器：按画像（性别/年龄/地区/粉丝数/送礼金额）+ 行为（弹幕次数/进入频次/关注状态）+ 标签（高价值/铁粉/同城），多维组合筛选，支持保存筛选条件
用户列表：表格/卡片视图，按价值评分/粉丝数/送礼金额排序，点击查看完整用户画像
线索管理：添加备注和跟进记录，线索状态流转（新线索→已联系→已转化→无效）
批量导出：CSV（Excel兼容）/ JSON（API对接用），自定义导出字段

使用形式：管理界面内嵌面板 | 核心依赖：用户画像 + 智能标签 + 用户筛选查询接口

5.4 模块管理机制

module.json 规范

JSON{
  "id": "game_territory",
  "name": "弹药游戏",
  "type": "game",
  "version": "1.0.0",
  "author": "智谷平台",
  "description": "多阵营领地争夺弹幕互动游戏",
  "category": "竞技",
  "entry": "index.html",
  "icon": "assets/icon.png",
  "defaultSize": { "width": 540, "height": 960 },
  "borderless": true,
  "minPlatformVersion": "3.0.0",
  "requiredData": ["chat", "like", "gift", "follow"]
}

模块类型

类型	窗口模式	适用场景
game	独立 BrowserWindow（无边框）	弹幕游戏，供 OBS 捕获
marketing	管理界面内嵌面板	智佳流量营销、私域引流
analytics	管理界面内嵌面板	数据分析类模块

未来展望：模块市场

基础底座只内置核心功能（授权、直播源、仪表盘、设置），其余业务模块通过模块商店按需下载安装。支持模块的独立版本发布与热更新，降低安装包体积和用户使用门槛。第三方开发者可基于标准化接口开发新的业务模块上架。

6. 业务管理层（toB 桌面端内）

以下业务管理功能全部整合在桌面端管理界面中，是底座的重要组成部分，为上层业务模块提供商业基础设施。

6.1 组织管理

公会管理（UnionList）

增删改查公会/MCN机构信息
关联旗下达人列表，查看公会整体数据概览
公会管理者可查看旗下所有达人的直播数据汇总

达人管理（AnchorList）

增删改查达人/主播信息：姓名、抖音账号、直播间地址、粉丝数、联系方式
归属公会/MCN机构，支持公会间达人转移
每个达人关联自己的直播间数据、活动列表、粉丝列表

粉丝管理（FunsList）

查看所有在直播间出现过的粉丝
显示来源达人/直播间、互动次数、标签、评分
支持按画像维度筛选和排序

品牌方管理（BrandList）

品牌方入驻申请、资料提交、审核流程
品牌方查看自家商品在直播间的曝光和兑换数据
品牌方与达人/活动的关联管理

6.2 商业体系

金币体系

功能	说明
CoinList（金币套餐）	配置充值套餐：100元=100金币、1000元=1000金币、10000元=10000金币，支持自定义套餐
BalanceList（余额管理）	每个粉丝的金币余额/积分余额，支持多币种
ChangeList（变动流水）	完整的金币变动审计日志：谁、什么时候、因为什么行为、增减多少、操作前余额、操作后余额

会员体系

功能	说明
MemberLevelList（会员等级）	普通会员（免费）/ 高级会员 / 旗舰会员，不同等级对应不同权益配额和月付/年付价格
MemberRecordList（订阅记录）	记录用户的会员订阅历史、生效时间、到期时间、自动续费状态
权益配置	不同等级差异化管理：设备数上限、商品/活动并发数、专属功能解锁、折扣比例、数据保留天数

6.3 运营工具

活动管理（ActivityList）

创建互动活动：活动名称、所属达人、开始/结束时间
配置活动规则：触发条件（什么互动行为）、奖励内容（金币/实物）、参与限制（每人每天上限）
活动效果数据：参与人数、金币消耗、商品兑换量

商品/奖品管理（GoodsList）

品牌方提交商品作为直播间奖品
商品信息：名称、图片、价格、库存数量、提供品牌
商品状态：上架/下架/已兑完

订单管理（OrderList）

粉丝用金币兑换实物奖品的订单
订单流程：待发货 → 已发货（填物流单号）→ 已签收 → 已完成
关联收货地址（AddressList）

合规管理（ComplianceList）

互动行为的合规审核记录
频率控制：单用户单日互动次数上限、行为间隔限制
异常行为标记：疑似刷金币、机器行为等

6.4 管理界面设计

┌──────────────────────────────────────────────────────────────┐
│  智谷直播数据中台                                zegu.top  ─ □ ✕ │
├──────────┬───────────────────────────────────────────────────┤
│          │                                                   │
│  📊 仪表盘 │                    主内容区                       │
│  🔐 账号授权 │                                                 │
│  📡 直播源  │   ┌─────────────────────────────────────────┐  │
│  🏪 应用商城 │   │                                         │  │
│  👥 组织管理 │   │      根据左侧导航切换内容                  │  │
│  💰 商业体系 │   │                                         │  │
│  🛠  运营工具 │   └─────────────────────────────────────────┘  │
│  📋 数据    │                                                 │
│  ⚙️  设置    │                                                 │
│          │                                                   │
├──────────┴───────────────────────────────────────────────────┤
│ 状态栏 │ 账号: ●已授权 │ 直播: ●已连接 15:23 │ 观众: 328 │ DB: 8.2MB │ 云端: ●已同步 │
└──────────────────────────────────────────────────────────────┘

📊 仪表盘

直播实时概览（在线人数、消息速率、今日礼物收入）、最近事件、新增用户、运行中的模块状态、系统资源

🔐 账号授权

三通道授权管理：Cookie扫码登录、代理截流状态、开放平台OAuth绑定

📡 直播源

dy-barrage-grab 启停、直播间ID输入、代理日志实时输出、消息速率图表

🏪 应用商城

已安装模块列表（卡片视图）、模块详情、安装/卸载、启动/停止/配置参数

👥 组织管理

公会管理、达人管理、粉丝列表、品牌方管理

💰 商业体系

金币套餐配置、余额查询、变动流水、会员等级管理、订阅记录

🛠 运营工具

活动管理、商品管理、订单管理、合规审核

📋 数据

全量事件查询（按类型/时间/用户）、用户画像库浏览、数据导出CSV/JSON

⚙ 设置

数据库路径/保留天数、WS Server端口、云端同步频率、开机自启、GPU加速

数据看板（BI视角）

为公会管理者和达人提供专属数据看板，区别于仪表盘的实时监控视角：

公会看板：旗下所有达人数据汇总对比、达人排行榜、品牌合作效果、金币消耗趋势
达人看板：粉丝画像分布（性别/年龄/地区）、弹幕词云、礼物收入趋势、用户活跃时段热力图、观众留存漏斗
品牌方看板：品牌曝光量趋势、商品兑换统计、互动参与率、ROI估算

7. C端触达层（toC）

粉丝/观众不直接使用桌面端。他们通过H5网页、微信公众号、微信小程序三个渠道参与互动。三端底层通过底座 HTTP API 打通，数据统一。

三端触达对比

渠道	优势	核心功能	入口
H5网页	灵活，无需审核，可嵌入任何地方	金币中心、兑换商城、活动中心、个人中心	抖音小风车链接、粉丝群链接
微信公众号	消息模板推送，粉丝触达率高	活动推送通知、金币变动提醒、私域入口引导	公众号菜单、模板消息
微信小程序	体验好，原生能力，留存高	互动参与、兑换商城、个人数据、地址管理	微信搜索、分享卡片

C端功能清单

🪙 金币中心

查看金币余额、收支明细流水、充值入口、金币使用记录

🎁 兑换商城

浏览奖品列表（按价值/库存排序）、金币兑换商品、查看兑换记录、物流追踪

🎉 活动中心

查看当前进行的互动活动、活动规则说明、参与记录、活动奖励领取

👤 个人中心

查看个人互动数据（点赞数/弹幕数/获得金币数）、收货地址管理、绑定信息

C端 API（底座提供）

API	方法	用途
`/api/user/balance`	GET	查询金币余额
`/api/user/balance/log`	GET	金币变动流水
`/api/goods/list`	GET	可兑换商品列表
`/api/order/create`	POST	创建兑换订单
`/api/order/list`	GET	我的订单列表
`/api/activity/list`	GET	当前活动列表
`/api/activity/join`	POST	参与活动
`/api/address/*`	CRUD	收货地址管理
`/api/user/profile`	GET	个人互动数据

8. 平台运营后台

平台运营方（智谷自身）的后台管理系统，管理整个生态的运转。

🔍 审核管理

品牌方入驻审核、活动审核、商品上架审核、达人认证审核

💰 财务结算

公会/达人/品牌方分账结算、平台服务费抽取、对账报表、提现处理

📢 系统公告

发布系统公告、版本更新通知、活动推荐、面向所有用户的消息推送

📊 数据大盘

全平台运营数据总览：用户数/活跃度/金币流通/订单量/营收趋势

🛡 风控管理

异常行为监控、刷金币检测、封禁管理、黑名单

📋 操作日志

所有管理员操作记录，可审计追溯

9. 用户画像数据模型

用户画像表（核心）

SQL-- ========== 用户画像表（核心） ==========
CREATE TABLE user_profiles (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    user_id TEXT UNIQUE NOT NULL,       -- 抖音用户ID (sec_uid)
    short_id TEXT DEFAULT '',              -- 抖音短ID
    unique_id TEXT DEFAULT '',             -- 抖音号

    -- 基本信息
    nickname TEXT DEFAULT '',
    avatar_url TEXT DEFAULT '',
    signature TEXT DEFAULT '',              -- 个人简介
    gender INTEGER DEFAULT 0,               -- 0=未知 1=男 2=女
    birthday TEXT DEFAULT '',
    age INTEGER DEFAULT 0,
    ip_location TEXT DEFAULT '',

    -- 账号信息
    account_type TEXT DEFAULT '',          -- 个人/企业/MCN
    verified TEXT DEFAULT '',

    -- 社交数据
    follower_count INTEGER DEFAULT 0,
    following_count INTEGER DEFAULT 0,
    total_favorited INTEGER DEFAULT 0,
    aweme_count INTEGER DEFAULT 0,

    -- 直播间行为（聚合统计）
    live_enter_count INTEGER DEFAULT 0,
    live_chat_count INTEGER DEFAULT 0,
    live_like_count INTEGER DEFAULT 0,
    live_gift_count INTEGER DEFAULT 0,
    live_gift_value INTEGER DEFAULT 0,
    live_followed INTEGER DEFAULT 0,

    -- 中台标签
    user_tags TEXT DEFAULT '[]',
    user_group TEXT DEFAULT '',
    user_level INTEGER DEFAULT 0,

    -- 采集元数据
    first_seen_at DATETIME,
    last_seen_at DATETIME,
    profile_fetched_at DATETIME,
    created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);

CREATE INDEX idx_profiles_user_id ON user_profiles(user_id);
CREATE INDEX idx_profiles_gender ON user_profiles(gender);
CREATE INDEX idx_profiles_location ON user_profiles(ip_location);
CREATE INDEX idx_profiles_follower ON user_profiles(follower_count DESC);
CREATE INDEX idx_profiles_last_seen ON user_profiles(last_seen_at DESC);

9.1 用户标签系统

JSON{
  "user_tags": [
    { "tag": "高价值用户", "rule": "follower_count > 10000 OR live_gift_value > 500" },
    { "tag": "活跃用户",   "rule": "live_chat_count > 10 OR live_like_count > 50" },
    { "tag": "新用户",     "rule": "first_seen_at IS NULL OR first_seen_at > datetime('now', '-7 days')" },
    { "tag": "同城",       "rule": "ip_location == '主播所在城市'" },
    { "tag": "高粉丝",     "rule": "follower_count > 50000" },
    { "tag": "铁粉",       "rule": "live_followed == 1 AND live_chat_count > 50" },
    { "tag": "潜在客户",   "rule": "live_chat_count > 3 AND live_gift_value == 0" },
    { "tag": "流失预警",   "rule": "last_seen_at < datetime('now', '-14 days')" }
  ]
}

9.2 用户评分算法

JavaScript// 用户价值评分 (0-1000)
function calculateUserScore(profile) {
  let score = 0;

  // 粉丝数：0-200 分
  score += Math.min(profile.follower_count / 500, 200);

  // 送礼价值：0-300 分
  score += Math.min(profile.live_gift_value / 10, 300);

  // 互动频次：0-200 分
  score += Math.min((profile.live_chat_count + profile.live_like_count) * 5, 200);

  // 关注主播：0-100 分
  score += profile.live_followed ? 100 : 0;

  // 账号质量：0-200 分
  if (profile.verified) score += 100;
  if (profile.aweme_count > 10) score += 50;
  if (profile.signature && profile.signature.length > 10) score += 50;

  return Math.round(score);
}

10. 核心业务流程

全流程端到端

阶段一：开播前准备

主播打开智谷桌面端
  ├── 账号授权：内置浏览器扫码登录抖音（通道一）
  ├── 启动代理截流：dy-barrage-grab 监听弹幕流（通道二）
  ├── 绑定开放平台：OAuth认证（通道三）
  ├── 打开应用商城 → 启动"弹药游戏" → 选择领地争夺
  │     └── 游戏窗口弹出（无边框），在OBS中Window Capture捕获
  ├── 创建互动活动："今晚弹幕抽奖，指定口令得10金币"
  └── 品牌方赞助商品已在后台录入："XX面膜50份"

阶段二：直播进行中

智谷底座实时运作
  ├── 通道二：WS弹幕流 → 每一条弹幕/点赞/礼物/关注 → live_events表
  ├── 通道一/三：新用户出现 → HTTP API查画像 → user_profiles表
  ├── 标签引擎：实时计算 → 打标签 → 评分
  ├── Local WS Server (9600端口)：
  │     ├── 推送给弹药游戏 → 弹幕驱动游戏画面
  │     ├── 推送给智佳流量营销 → 曝光数据实时更新
  │     └── 推送给私域引流 → 高价值用户实时标记
  ├── 活动引擎：有人发指定口令 → ChangeList记录 → BalanceList加金币
  └── 定期（如每5分钟）脱敏数据同步至云端共享库

阶段三：粉丝参与（C端）

粉丝在直播间看到游戏和活动
  ├── 发弹幕"冲左边" → 弹幕驱动弹药游戏角色移动
  ├── 发弹幕"我要面膜" → 触发活动规则
  │     └── 底座ChangeList记录 → BalanceList加10金币
  ├── 点击直播间小风车链接 → 打开H5金币中心
  │     └── 看到金币到账 → 进入兑换商城 → 用金币兑换面膜
  ├── 填写收货地址 → 提交订单
  └── 关注公众号 → 收到金币变动推送 → 进入私域流量池

阶段四：直播结束后

下播后复盘
  ├── 主播/达人：在桌面端数据页面查看本场直播报告
  │     └── 弹幕总数、互动率、金币消耗、商品兑换量、粉丝画像
  ├── 公会管理者：Web后台看旗下所有达人数据汇总
  ├── 品牌方：Web后台看品牌曝光和商品兑换数据
  ├── 平台运营方：处理待发货订单、审核新品牌入驻
  └── 云端共享库：更新全网大盘数据，用户可对比全网排名

11. 多平台支持策略

v1.0 阶段：聚焦抖音平台，深耕三通道数据采集和画像能力。

                        智谷数据中台（底座）
                              │
              ┌───────────────┼───────────────┐
              │               │               │
         ┌────▼────┐    ┌────▼────┐    ┌────▼────┐
         │ 抖音适配器│    │快手适配器│    │B站适配器 │
         │ (v1.0)  │    │ (规划中) │    │ (规划中) │
         │         │    │         │    │         │
         │ Cookie  │    │ 弹幕流   │    │ 弹幕流   │
         │ 代理截流 │    │ OAuth   │    │ OAuth   │
         │ OAuth   │    │ 用户API  │    │ 用户API  │
         └────┬────┘    └────┬────┘    └────┬────┘
              │               │               │
              └───────────────┼───────────────┘
                              ▼
                    统一标准化数据接口
              (userId/nickname/gender/age/...)

设计原则：底座定义统一的用户画像和事件数据标准，各平台通过适配器接入，将不同平台的数据格式转换为底座标准格式。业务模块不感知底层平台差异——弹药游戏不需要知道弹幕来自抖音还是快手。

平台	数据采集方式	优先级
抖音	三通道：Cookie + 代理截流 + OAuth开放平台	v1.0
快手	WebSocket 弹幕 + 开放平台 API + OAuth	v1.5
B站	WebSocket 弹幕 + B站直播 API + OAuth	v2.0
视频号	待调研	待定

12. 技术方案

12.1 整体技术栈

层级	技术选型	说明
桌面端底座	Electron 28+	桌面壳 + 内置Chromium浏览器
本地数据库	better-sqlite3	SQLite 同步API，高性能本地读写
Local WS Server	ws	WebSocket Server，本地数据分发
用户画像API调用	node-fetch	HTTP请求，携带Cookie调用抖音接口
MITM代理工具	proxypin.exe	dy-barrage-grab，截获WS弹幕流
云端服务	Go (GoFrame) / PHP	云端API + 共享数据库 + 运营后台
云端数据库	MySQL / PostgreSQL	存储脱敏后的共享数据
缓存层	Redis	实时互动计数、会话缓存
文件存储	阿里云OSS / 腾讯云COS	商品图片、头像等静态资源
C端前端	Vue.js / React	H5网页 + 公众号H5 + 微信小程序
游戏渲染	Canvas 2D / Pixi.js / Three.js	弹幕游戏的2D/2.5D/3D渲染
打包	electron-builder	NSIS安装包，Win10/Win11

12.2 部署架构

┌────────────────────────────┐       ┌──────────────────────────────┐
│      用户电脑（主播）        │       │        云端服务器              │
│                            │       │                              │
│  ┌──────────────────────┐  │ HTTPS │  ┌────────────────────────┐  │
│  │ 智谷桌面端             │  │─────→│  │ Go/PHP API Server       │  │
│  │ (Electron)           │  │ 数据  │  │                        │  │
│  │                      │  │ 同步  │  │ · 共享数据库服务         │  │
│  │ · 三通道数据采集      │  │      │  │ · 金币充值/支付回调      │  │
│  │ · SQLite本地存储      │  │      │  │ · 会员订阅管理          │  │
│  │ · Local WS:9600      │  │      │  │ · C端API（H5/小程序）    │  │
│  │ · 标签引擎+评分       │  │      │  │ · 运营后台              │  │
│  │ · 业务模块（小程序）   │  │      │  └───────────┬────────────┘  │
│  └──────────────────────┘  │       │              │               │
│                            │       │     ┌────────▼────────────┐  │
│  粉丝手机                   │       │     │ MySQL + Redis + OSS  │  │
│  ┌──────────────────────┐  │       │     └─────────────────────┘  │
│  │ H5 / 公众号 / 小程序   │──┼─────→│                              │
│  └──────────────────────┘  │       └──────────────────────────────┘
└────────────────────────────┘

12.3 数据安全与合规

本地存储优先：用户原始数据存储在本地SQLite，不上传云端，保护用户隐私
脱敏上传：上传至云端共享库的数据必须脱敏处理，去除用户ID等敏感信息，仅保留统计级别数据
抖音平台合规：三通道均基于合法授权——Cookie为用户主动扫码，OAuth为官方认证接口，代理截流为本地网络层数据采集（不修改/注入请求）
金币风控：互动行为频率限制、单日金币上限、异常行为自动检测，防止刷金币

12.4 目录结构

智谷直播数据中台/
├── package.json                   # Electron 项目配置
├── main.js                         # Electron 主进程入口
│
├── core/                           # 底座核心模块
│   ├── auth-manager.js             # 三通道授权管理
│   ├── live-data-engine.js         # 弹幕数据引擎（WS流接收/解析/分发）
│   ├── profile-engine.js           # 用户画像引擎（HTTP API/缓存/脱敏）
│   ├── db-manager.js               # SQLite 数据库管理（CRUD/迁移/清理/备份）
│   ├── ws-server.js                # Local WebSocket Server (端口 9600)
│   ├── module-manager.js           # 应用商城/模块管理器
│   ├── tag-engine.js               # 智能标签引擎
│   ├── score-engine.js             # 用户评分算法
│   ├── cloud-sync.js               # 云端数据同步（脱敏上传）
│   ├── coin-manager.js             # 金币体系管理
│   ├── member-manager.js           # 会员体系管理
│   ├── activity-engine.js          # 活动引擎
│   ├── order-manager.js            # 订单管理
│   └── scheduler.js                # 定时任务（清理/补采/Cookie检查/云端同步）
│
├── admin/                          # 管理界面（桌面端UI）
│   ├── index.html
│   ├── css/admin.css
│   └── js/
│       ├── app.js                  # 应用初始化 + 路由
│       ├── dashboard.js            # 仪表盘
│       ├── auth.js                 # 账号授权（三通道管理）
│       ├── live-source.js          # 直播源管理
│       ├── app-store.js            # 应用商城
│       ├── org-manager.js          # 组织管理（公会/达人/品牌方）
│       ├── biz-manager.js          # 商业体系（金币/会员）
│       ├── ops-tools.js            # 运营工具（活动/商品/订单）
│       ├── data-viewer.js          # 数据查看
│       └── settings.js             # 设置
│
├── modules/                        # 应用商城 — 业务模块目录
│   ├── registry.json               # 模块注册表
│   ├── _templates/                 # 开发模板 (game-2d/game-3d/embedded)
│   ├── game_territory/             # 弹药游戏
│   ├── marketing_zhijia/           # 智佳流量营销
│   └── marketing_private_domain/   # 私域引流
│
├── c-end/                          # C端触达（H5/公众号/小程序）
│   ├── h5/                         # H5网页
│   ├── mp-wechat/                  # 微信小程序
│   └── api/                        # C端API接口定义
│
├── shared/                         # 共享库
│   ├── ws-client.js                # WS 客户端 SDK（供业务模块使用）
│   ├── data-types.js               # 共享数据类型定义
│   └── utils.js                    # 工具函数
│
├── bin/                           # 外部工具
│   └── proxypin.exe                # dy-barrage-grab (MITM代理)
│
└── server/                         # 云端服务
    ├── api/                        # Go/PHP API服务
    ├── admin/                      # 平台运营后台
    └── sql/                        # 云端数据库建表脚本

13. 开发路线图

总计预估：30-40 天

底座核心 — 三通道数据采集

5-6 天

Electron 项目初始化 + GPU 配置
SQLite 数据库模块 + 全部建表脚本
通道一：Cookie扫码登录 + 提取 + 持久化 + 有效期监控
通道二：集成 dy-barrage-grab，WS弹幕流接收/解析/存储
通道三：抖音开放平台OAuth对接
Local WebSocket Server (9600端口) + 实时事件流推送
管理界面框架（侧边栏布局 + 路由） + 仪表盘

数据层完善 — 画像 + 标签 + 云端同步

4-5 天

用户画像引擎（HTTP API调用 + 限速500ms + 24h缓存）
智能标签引擎（自动打标规则 + 用户评分 0-1000分）
定时任务（数据清理30天 / 画像补采 / Cookie检查）
云端脱敏数据同步模块
云端共享数据库建表 + 数据汇总API
用户画像查询接口 + 用户筛选查询接口

应用商城 — 模块框架 + 弹药游戏迁移

5-6 天

应用商城框架：模块注册表、module.json规范、安装/卸载/启停
模块管理器（BrowserWindow创建/销毁/崩溃恢复）
业务模块 WS 客户端 SDK (ws-client.js)
游戏类/内嵌类模块开发模板
弹药游戏迁移：拆除内置引擎 → 对接底座 WS 广播 → OBS捕获测试

业务管理层 — toB 桌面端功能

5-6 天

组织管理：公会管理 + 达人管理 + 粉丝管理 + 品牌方管理
商业体系：金币套餐配置 + 余额管理 + 变动流水 + 会员等级 + 订阅记录
运营工具：活动管理 + 商品管理 + 订单管理 + 合规管理
数据看板：公会看板 + 达人看板 + 品牌方看板（BI视角）

C端触达 + 云端服务

5-6 天

C端API开发（金币/兑换/活动/订单/地址）
H5网页：金币中心 + 兑换商城 + 活动中心 + 个人中心
微信公众号：菜单配置 + 模板消息 + H5嵌入
微信小程序：互动参与 + 兑换商城 + 个人数据
平台运营后台：审核管理 + 财务结算 + 系统公告 + 数据大盘

智佳流量营销 + 私域引流

4-5 天

智佳流量营销：品牌曝光追踪 + 活动裂变 + 达人推广匹配 + 数据报告
私域引流：多维用户筛选器 + 用户列表 + 线索管理 + CSV/JSON导出

设置 + 优化 + 打包发布

3-4 天

设置页面（数据库/网络/采集频率/云端同步/开机自启/GPU加速）
系统托盘 + 关闭到托盘
Canvas/WebSocket/SQLite 性能优化 + GPU独显验证
electron-builder NSIS安装包配置 + Win10/Win11测试
产品文档完善 + 首版发布 v3.0.0

14. 附录

附录 A: 与 DYYX 1.0/2.0 的关系

DYYX 1.0 (浏览器版)
  └──→ 智谷 v3.0 应用商城中的"弹药游戏"模块
       互动引擎、通信层、配置管理全部抽离到底座
       游戏本身只保留 Canvas 渲染 + 游戏逻辑

DYYX 2.0 admin.js
  └──→ 智谷 core/live-data-engine.js     (数据采集)
       core/profile-engine.js            (用户画像)
       core/tag-engine.js                (智能标签)
       core/ws-server.js                 (数据分发)
       core/module-manager.js            (模块管理)

附录 B: 词汇对照

智谷术语	微信类比	说明
底座	微信 App	底层基础设施，提供账号、数据、通信等核心能力
应用商城	微信小程序商店	业务模块的发现和安装入口
业务模块（小程序）	微信小程序	底座上层应用，不能脱离底座独立运行
Local WS Server	微信底层API	底座给业务模块提供数据的通道
金币体系	微信支付	商业基础设施
会员体系	微信订阅	增值服务变现
云端共享库	微信开放平台	跨用户的数据共享和分析能力

附录 C: 商业模式

收入来源	付费方	说明
金币充值	粉丝	充钱买金币 → 参与互动 → 兑换奖品（如100元=100金币）
会员订阅	达人/公会	月付/年付解锁更多功能配额和专属功能
品牌方服务费	品牌方	品牌入驻、商品推广、精准投放，按曝光/转化收费
模块付费	达人/公会	高级业务模块（高级游戏/高级营销工具）单独付费
增值服务	公会/品牌方	定制数据分析报告、API对接服务、私有化部署