优化2025年3月6日

sql/dwd_before/active_account_df.sql

@@ -13,7 +13,7 @@ GROUP BY ds
          ,channel_id
          ,game_identity
          ,platform_id
-UNION
+UNION all
 SELECT  channel_id game_channel_id
         ,game_identity
         ,platform_id game_platform_id

sql/dwd_before/active_df.sql

@@ -1,16 +1,17 @@
 INSERT INTO dwd.active_df(relation_id,user_id,ds,ds_date)
-SELECT  t2.relation_id
-        ,t1.user_id
-        ,t1.ds
+
+SELECT  t1.relation_id
+        ,t2.user_id
+        ,t2.ds
         ,'${biz-date}' ds_date
-FROM    pubdata_center.ods.active_account_list t1
-INNER JOIN dim.game_product_relation t2
-ON      t1.channel_id = t2.game_channel_id
+FROM    dim.game_product_relation t1
+INNER JOIN pubdata_center.ods.active_account_list t2
+ON      t1.game_channel_id = t2.channel_id
 AND     t1.game_identity = t2.game_identity
-AND     t1.platform_id = t2.game_platform_id
+AND     t1.game_platform_id = t2.platform_id
 where ds='${bizdate}'
-GROUP BY t2.relation_id
-        ,t1.user_id
-        ,t1.ds
+GROUP BY t1.relation_id
+        ,t2.user_id
+        ,t2.ds
 ON CONFLICT (relation_id, user_id, ds)
 DO NOTHING;