行为原子拆解

2026-08-31 把上面 13 条 SQL 逐条丢进数仓跑过（业务日 2026-08-30，全站不加名单过滤）。下面三块是跑完之后补的：实跑结果、建表语句、三条调度约定。

一、13 条实跑结果

二、建表语句

类型是从 08-30 真实数据里看出来的，不是猜的。金额一律 decimal(18,2)，经验和计数用 bigint，day 做分区键。

/* 表二：房间 x 天 */
CREATE TABLE IF NOT EXISTS rpt.rpt_user_monitor_room_day_sd (
  room_id          varchar,        /* ★ 用 varchar 不用 bigint：源表三张，两种类型，
                                       json_extract_scalar 和 scene_target_id 都是 varchar */
  rm_uniq_n        bigint,         /* 当天进过这个房间的去重人数 */
  rm_bigr_n        bigint,         /* 其中荣耀用户数 */
  rm_mic_n         bigint,         /* 上麦动作总数 */
  rm_gift_val      decimal(18,2),  /* 礼物总面值 */
  rm_gift_from_n   bigint          /* 送过礼的去重人数 */
) WITH (partitioned_by = ARRAY['day']);

/* 表三：家族 x 天 */
CREATE TABLE IF NOT EXISTS rpt.rpt_user_monitor_family_day_sd (
  family_id        bigint,
  fam_name         varchar,        /* 家族名。大量特殊字符和 emoji，别做长度截断 */
  fam_level        int,            /* 家族等级 */
  fam_owner_id     bigint,         /* 族长 uid */
  fam_area         int,            /* 区域码 */
  fam_member_n     bigint,         /* 在册成员数 */
  fam_exp_day      bigint,         /* 当日家族经验 */
  fam_exp_gift     bigint,         /* 其中送礼来的 source=2 */
  fam_exp_task     bigint,         /* 其中任务来的 source=1 */
  fam_exp_month    bigint,         /* 本月累计 */
  fam_exp_cum      bigint,         /* 建族至今累计。实测最大 4,959 万，bigint 够 */
  fam_inner_val    decimal(18,2),  /* 族内互送金额 */
  fam_gift_val     decimal(18,2),  /* 族内礼物总额 */
  fam_gift_pair_n  bigint,         /* 互送的人对数 */
  fam_bigr_n       bigint,         /* 族内开通过荣耀的人数 */
  fam_bigr_live    bigint          /* 其中现在还在有效期内的 */
) WITH (partitioned_by = ARRAY['day']);

user_day 用现有的 rpt.rpt_user_monitor_user_day_sd，上面 A1~A11 是往里加列，不是新建表。

三、三条调度约定 —— SQL 里写不进去，必须在调度侧定