ck před 4 roky
rodič
revize
c08a388785
1 změnil soubory, kde provedl 4 přidání a 2 odebrání
  1. 4 2
      app/etl/dw/dw_pitcher_daily.py

+ 4 - 2
app/etl/dw/dw_pitcher_daily.py

@@ -23,10 +23,12 @@ def dw_pitcher_trend():
        sum(da10) d10,sum(da11) d11,sum(da12) d12,
        sum(da13) d13,sum(da14) d14,sum(da15) d15,sum(da16) d16,sum(da17) d17,sum(da18) d18,sum(da19) d19,
        sum(da20) d20,sum(da21) d21,sum(da22) d22,sum(da23) d23,sum(da24) d24,sum(da25) d25,
-       sum(da26) d26,sum(da27) d27,sum(da28) d28,sum(da29) d29,sum(da30) d30
+       sum(da26) d26,sum(da27) d27,sum(da28) d28,sum(da29) d29,sum(da30) d30,
+       sum(ba1),sum(ba2),sum(ba3),sum(ba4),sum(ba5),sum(ba6),sum(ba7)
 from dw_channel a
 left join dw_channel_amount_daily b on a.dt=b.dt and a.channel=b.channel
-left join src_book_info c on a.book=c.book and a.platform=c.platform and a.type=c.type and a.dt=c.dt
+left join src_book_info c on a.book=c.book and a.platform=c.platform and a.type=c.type and a.dt=c.dt 
+left join dw_channel_amount_daily_reverse d on a.dt=d.dt and a.channel=d.channel 
 group by pitcher,a.dt"""
 
     db.dm.execute("truncate table dw_pitcher_trend")