ck há 4 anos atrás
pai
commit
cdc8e6b30f
1 ficheiros alterados com 3 adições e 3 exclusões
  1. 3 3
      app/etl/dm/dm_pitcher_daily_overview.py

+ 3 - 3
app/etl/dm/dm_pitcher_daily_overview.py

@@ -27,7 +27,7 @@ select
        if(last_month_cost = 0, 0, last_month_far_amount / last_month_cost) last_month_far_roi
 from (select pitcher,
              sum(follow_user) follow_user
-      from dw_daily_channel
+      from dw_daily_channel_cost
       group by pitcher) q
         left outer join
      (select count(distinct channel) channel_count, pitcher
@@ -45,14 +45,14 @@ from (select pitcher,
          left outer join (
     select pitcher,
            sum(cost)  this_month_cost
-    from dw_daily_channel
+    from dw_daily_channel_cost
     where dt >= '{du.get_n_pre_month_first_day(0)}'
     group by pitcher) r
                          on q.pitcher = r.pitcher
          left outer join(
     select pitcher,
            sum(cost)  last_month_cost
-    from dw_daily_channel
+    from dw_daily_channel_cost
     where dt >= '{du.get_n_pre_month_first_day(1)}'
       and dt < '{du.get_n_pre_month_first_day(0)}'
     group by pitcher) t on q.pitcher = t.pitcher