1

app/etl/data_stat_daily.py

@@ -16,6 +16,7 @@ def _channel_info_daily():
     channel_info_daily(yestoday)
 
 if __name__ == '__main__':
+    ods_order(yestoday)
     _channel_by_account_daily()
     _channel_info_daily()
     dw_daily_channel(yestoday)

app/etl/data_stat_hourly.py

@@ -8,6 +8,7 @@ yestoday = du.get_n_days(-1)
 today = du.get_n_days(0)
 
 if __name__ == '__main__':
+    ods_order(today)
     dw_daily_channel(today)
 
 

app/etl/data_stat_task.py

@@ -105,7 +105,7 @@ def channel_info_daily(ymd):
 
 
 
-def clean_order(dt):
+def ods_order(dt):
     sql="""	replace into ods_order
 			select 
 			case platform when '掌中云' then DATE_FORMAT(STR_TO_DATE(order_time,'%Y-%m-%dT%H:%i:%s'),'%Y-%m-%d') 
@@ -135,8 +135,9 @@ def order_account_text():
 if __name__ == '__main__':
     # dw_daily_channel('2020-12-14')
     # channel_info_daily('2020-12-14')
-    for i in dt.getDateLists('2019-03-18','2020-12-16'):
+    for i in dt.getDateLists('2019-05-20','2020-12-16'):
         print(i)
         # channel_by_account_daily(i)
         # channel_info_daily(i)
-        dw_daily_channel(i)
+        # dw_daily_channel(i)
+        clean_order(i)