MOD:添加时间

app/etl/dw/dw_book_trend.py

@@ -20,10 +20,16 @@ def book_trend():
     sum(order_user),
     sum(order_amount),
     sum(reg_num),
-    if(sum(game_user_sum)=0,0,sum(game_user_sum*today_active_user_rate)/sum(game_user_sum)) today_active_user_rate,
+    if(max(game_user_sum)=0,0,sum(game_user_sum*today_active_user_rate)/max(game_user_sum)) today_active_user_rate,
     if(sum(reg_num)=0,0,sum(reg_num*second_stay_rate)/sum(reg_num)) second_stay_rate,
     if(sum(reg_num)=0,0,sum(reg_num*third_stay_rate)/sum(reg_num)) third_stay_rate,
-    sum(game_user_sum) game_user_sum,
+    if(sum(reg_num)=0,0,sum(reg_num*seven_stay_rate)/sum(reg_num)) seven_stay_rate,
+    if(sum(reg_num)=0,0,sum(reg_num*fifteen_stay_rate)/sum(reg_num)) fifteen_stay_rate,
+    if(sum(reg_num)=0,0,sum(reg_num*thirty_stay_rate)/sum(reg_num)) thirty_stay_rate,
+    if(sum(reg_num)=0,0,sum(reg_num*fortyfive_stay_rate)/sum(reg_num)) fortyfive_stay_rate,
+    if(sum(reg_num)=0,0,sum(reg_num*sixty_stay_rate)/sum(reg_num)) sixty_stay_rate,
+
+    max(game_user_sum) game_user_sum,
     sum(create_user_num),
                 
     sum(first_order_count) first_order_count,

app/etl/dw/dw_channel_daily.py

@@ -18,7 +18,9 @@ select
        dt1,channel1,pitcher,stage,platform,book,
        if(stage ='趣程15期' or stage ='趣程26期' or stage ='趣程30期','GDT','MP'),
        order_count,create_user_num,reg_num,
-       game_user_sum,third_stay_rate,second_stay_rate,
+       game_user_sum,third_stay_rate,sixty_stay_rate, fortyfive_stay_rate,
+       thirty_stay_rate,fifteen_stay_rate,seven_stay_rate, 
+       second_stay_rate,
        today_active_user_rate,
        order_user,order_amount,
        first_order_count,first_order_user,first_order_amount,
@@ -34,7 +36,8 @@ from (
     select 
     if(dt4='1970-01-01',dt,dt4) dt1,if(channel4='',channel,channel4) channel1,
     create_user_num,reg_num,today_active_user_rate,second_stay_rate ,third_stay_rate ,
-    game_user_sum ,
+    game_user_sum ,seven_stay_rate, fifteen_stay_rate,thirty_stay_rate,
+    fortyfive_stay_rate,sixty_stay_rate,
     pitcher,stage,platform,book,cost,view_count,click_count,   ---基础属性和消耗数据
         follow_user,web_view_count,platform_view_count,web_order_count,type,
         require_roi,require_mult,order_count,order_user,order_amount from
@@ -79,7 +82,7 @@ left outer join
     having order_amount+cost+reg_order_amount>0"""
 
     data = ck.execute(sql)
-    isql = "replace into dw_channel values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)"
+    isql = "replace into dw_channel values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)"
     # db.dm.execute("truncate table dw_channel")
     db.dm.executeMany(isql, data)