Browse Source

feat(table_gen): 优化曝光回流递推输出字段

- 去掉 subsessionid
- 添加 vid, uid, mid
- JOIN 视频表获取 video_title

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
yangxiaohui 1 tháng trước cách đây
mục cha
commit
1e138b473f
1 tập tin đã thay đổi với 33 bổ sung14 xóa
  1. 33 14
      table_gen/exposure_return_recursive.sql

+ 33 - 14
table_gen/exposure_return_recursive.sql

@@ -237,6 +237,8 @@ t_return AS (
             ,e.subsessionid
             ,e.ts
             ,e.vid
+            ,e.uid
+            ,e.mid
             -- B_i: 不换视频回流人数(含裂变)
             ,COALESCE(bn.B, 0) AS B
             -- Bn 带来的回流用户的 subsessions(用于计算 S(i))
@@ -289,6 +291,9 @@ t_return AS (
     SELECT  e1.exposure_id
             ,e1.subsessionid
             ,e1.ts
+            ,e1.vid
+            ,e1.uid
+            ,e1.mid
             ,e1.B
             ,e1.bn_subsessions
             -- D^(0) = Σ B_j, j > i 且同 subsession
@@ -327,6 +332,9 @@ t_return AS (
     SELECT  l0.exposure_id
             ,l0.subsessionid
             ,l0.ts
+            ,l0.vid
+            ,l0.uid
+            ,l0.mid
             ,l0.B
             ,l0.bn_subsessions
             ,l0.D_0
@@ -368,6 +376,9 @@ t_return AS (
     SELECT  l1.exposure_id
             ,l1.subsessionid
             ,l1.ts
+            ,l1.vid
+            ,l1.uid
+            ,l1.mid
             ,l1.B
             ,l1.bn_subsessions
             ,l1.D_0, l1.C_0
@@ -409,6 +420,9 @@ t_return AS (
     SELECT  l2.exposure_id
             ,l2.subsessionid
             ,l2.ts
+            ,l2.vid
+            ,l2.uid
+            ,l2.mid
             ,l2.B
             ,l2.bn_subsessions
             ,l2.D_0, l2.C_0
@@ -435,24 +449,29 @@ t_return AS (
 --========================================
 -- 10. 最终输出 (k=3)
 --========================================
-SELECT  exposure_id
-        ,subsessionid
-        ,ts
+SELECT  t.exposure_id
+        ,t.vid
+        ,v.title AS video_title
+        ,t.uid
+        ,t.mid
+        ,t.ts
         -- 基础收益
-        ,B
+        ,t.B
         -- 第0轮(初始化)
-        ,D_0
-        ,C_0
+        ,t.D_0
+        ,t.C_0
         -- 第1轮
-        ,D_1
-        ,C_1
+        ,t.D_1
+        ,t.C_1
         -- 第2轮
-        ,D_2
-        ,C_2
+        ,t.D_2
+        ,t.C_2
         -- 第3轮
-        ,D_3
-        ,C_3
+        ,t.D_3
+        ,t.C_3
         -- 最终收益 = B + D^(k) + C^(k)
-        ,B + D_3 + C_3 AS V_total
-FROM    t_layer_3
+        ,t.B + t.D_3 + t.C_3 AS V_total
+FROM    t_layer_3 t
+LEFT JOIN videoods.wx_video v
+ON      t.vid = CAST(v.id AS STRING)
 ;