@@ -58,6 +58,11 @@ def main(st, et):
def hourly():
thedate = du.getTodayOrYestoday()
main(thedate, thedate)
+ #TODO:特殊---因为创建角色数量一直在变，故需要每次都跑所有数据------之后引进flink-cdc后则不需要
+ #TODO:暂时让近30天的创建角色正确
+ for i in du.getDateLists(du.get_n_days(-30), du.get_n_days(-1)):
+ dw_daily_channel_cost(i)
+ platform_data_sum(i)
def daily():
