1

app/etl/dw/dw_book_trend.py

@@ -12,7 +12,7 @@ ck = CkUtils()
 
 def book_trend():
     sql="""insert into book_trend
-    select dt,book,type,
+    select a.dt,book,type,
 sum(cost) cost,
 sum(order_count),
 sum(order_user),
@@ -28,10 +28,12 @@ sum(reg_order_amount) reg_order_amount,
 sum(view_count) view_count,
 sum(click_count) click_count,
 sum(follow_user) follow_user,
-sum(da1),sum(da2),sum(da3),sum(da4),sum(da5),sum(da6),sum(da7),sum(da8),sum(da9),sum(da10),sum(da11),sum(da12),sum(da13),sum(da14),sum(da15),sum(da16),sum(da17),sum(da18),sum(da19),sum(da20),sum(da21),sum(da22),sum(da23),sum(da24),sum(da25),sum(da26),sum(da27),sum(da28),sum(da29),sum(da30),sum(da31),sum(da32),sum(da33),sum(da34),sum(da35),sum(da36),sum(da37),sum(da38),sum(da39),sum(da40),sum(da41),sum(da42),sum(da43),sum(da44),sum(da45),sum(da46),sum(da47),sum(da48),sum(da49),sum(da50),sum(da51),sum(da52),sum(da53),sum(da54),sum(da55),sum(da56),sum(da57),sum(da58),sum(da59),sum(da60),sum(dm3),sum(dm4),sum(dm5)
+sum(da1),sum(da2),sum(da3),sum(da4),sum(da5),sum(da6),sum(da7),sum(da8),sum(da9),sum(da10),sum(da11),sum(da12),sum(da13),sum(da14),sum(da15),sum(da16),sum(da17),sum(da18),sum(da19),sum(da20),sum(da21),sum(da22),sum(da23),sum(da24),sum(da25),sum(da26),sum(da27),sum(da28),sum(da29),sum(da30),sum(da31),sum(da32),sum(da33),sum(da34),sum(da35),sum(da36),sum(da37),sum(da38),sum(da39),sum(da40),sum(da41),sum(da42),sum(da43),sum(da44),sum(da45),sum(da46),sum(da47),sum(da48),sum(da49),sum(da50),sum(da51),sum(da52),sum(da53),sum(da54),sum(da55),sum(da56),sum(da57),sum(da58),sum(da59),sum(da60),sum(dm3),sum(dm4),sum(dm5),
+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 using(dt,channel) 
+left join dw_channel_amount_daily b on a.dt=b.dt and a.channel=b.channel 
+left join dw_channel_amount_daily_reverse c on a.dt=c.dt and a.channel=c.channel 
 where a.book!=''
 GROUP BY dt,book,type"""
     db.dm.execute('truncate table book_trend')

app/etl/dw/dw_channel_daily.py

@@ -252,13 +252,13 @@ def dw_channel_amount_daily_reverse():
     sql = """
      select toDate(formatDateTime(reg_time,'%Y-%m-%d')) as dt,
        channel as channel,
-                sum(if(dt=today(),amount,0)) ba1,
-                sum(if(addDays(dt,1)=today(),amount,0)) ba2,
-                sum(if(addDays(dt,2)=today(),amount,0)) ba3,
-                sum(if(addDays(dt,3)=today(),amount,0)) ba4,
-                sum(if(addDays(dt,4)=today(),amount,0)) ba5,
-                sum(if(addDays(dt,6)=today(),amount,0)) ba6,
-                sum(if(addDays(dt,7)=today(),amount,0)) ba7
+                sum(if(date=today(),amount,0)) ba1,
+                sum(if(addDays(date,1)=today(),amount,0)) ba2,
+                sum(if(addDays(date,2)=today(),amount,0)) ba3,
+                sum(if(addDays(date,3)=today(),amount,0)) ba4,
+                sum(if(addDays(date,4)=today(),amount,0)) ba5,
+                sum(if(addDays(date,6)=today(),amount,0)) ba6,
+                sum(if(addDays(date,7)=today(),amount,0)) ba7
      from order where reg_time>'2019-03-18 00:00:00' and date>=subtractDays(today(),7) group by toDate(formatDateTime(reg_time,'%Y-%m-%d')),channel"""
     data = ck.execute(sql)
     isql = "replace into dw_channel_amount_daily_reverse values (%s,%s,%s,%s,%s,%s,%s,%s,%s)"
@@ -272,12 +272,13 @@ def dw_channel():
     dw_channel_daily()
     dw_channel_user_daily()
     dw_channel_amount_daily()
+    dw_channel_amount_daily_reverse()
 
 
 if __name__ == '__main__':
 
     # dw_daily_channel()
     # dw_channel()
-    dw_channel_amount_daily()
+    # dw_channel_amount_daily()
     # dw_channel_user_daily()
-    # dw_channel_amount_daily_reverse()
+    dw_channel_amount_daily_reverse()