ADD:添加运行示例

example/add_yangguang_accounts.py

@@ -0,0 +1,10 @@
+from app.api_data.platform_order.yangguang import get_channel_info
+
+def run():
+    pass
+    # 1.在quchen_test数据库order_account_text中添加账号
+    # 2.运行yangguang_channel
+    get_channel_info()
+
+if __name__=='__main__':
+    run()

example/update_cost_data.py

@@ -0,0 +1,34 @@
+from model.DateUtils import DateUtils
+from app.api_data.tx_ad_cost import get_cost_older
+from app.etl.data_stat_run import do_cost
+from app.etl.dm.dm_pitcher_daily_overview import dm_pitcher_daily_overview
+from app.etl.dw.dw_channel_daily import dw_channel_daily
+from app.etl.dw.dw_pitcher_daily import dw_pitcher_trend
+from app.etl.src.src_book_info import src_book_info
+from app.etl.dw.dw_book_trend import book_trend
+
+du = DateUtils()
+
+
+def get_data():
+    #1.获取数据
+    st = du.get_n_days(-2)
+    et = du.get_n_days(0)
+    print(st, et)
+    get_cost_older.run(st, et)
+
+    #同步到ck
+    do_cost(st, et)
+
+    #2.数据处理
+    src_book_info()  # 书籍卡点信息
+    # book_annual_expect_profit.run() # 年预期收益
+    dw_channel_daily()
+    dw_pitcher_trend()
+    book_trend()
+    dm_pitcher_daily_overview()
+
+
+
+if __name__=="__main__":
+    get_data()

example/update_order_data.py

@@ -0,0 +1,71 @@
+from model.DateUtils import DateUtils
+from app.api_data.tx_ad_cost import get_cost_older
+from app.etl.data_stat_run import do_order
+from app.etl.dm.dm_pitcher_daily_overview import dm_pitcher_daily_overview
+from app.etl.dw.dw_channel_daily import dw_channel_daily
+from app.etl.dw.dw_pitcher_daily import dw_pitcher_trend
+from app.etl.src.src_book_info import src_book_info
+from app.etl.dw.dw_book_trend import book_trend
+import threading
+import threading
+from app.api_data.platform_order.get_order import *
+from app.api_data.tx_ad_cost.get_cost_older import old_cost_hourly,old_cost_daily
+from app.etl.sync_to_ck_task import order_sync_ck
+from app.api_data.platform_order import yangguang
+from app.api_data.tx_ad_cost import get_cost_older
+from app.etl.data_stat_run import do_cost
+
+du = DateUtils()
+
+def order_date_get(st,et):
+
+    t1 = threading.Thread(target=huasheng, args=(st, et))
+    t2 = threading.Thread(target=qiyue, args=(st, et))
+    t3 = threading.Thread(target=qiyueyousheng, args=(st, et))
+    t4 = threading.Thread(target=wending, args=(st, et))
+    t5 = threading.Thread(target=zhangdu, args=(st, et))
+    t6 = threading.Thread(target=zhangzhongyun, args=(st, et))
+    t7 = threading.Thread(target=yueweng, args=(st, et))
+    t8 = threading.Thread(target=yangguang, args=(st, et))
+    t9 = threading.Thread(target=youshuge, args=(st, et))
+    t1.start()
+    t1.join()
+    t2.start()
+    t2.join()
+    t3.start()
+    t3.join()
+    t4.start()
+    t4.join()
+    t5.start()
+    t5.join()
+    t6.start()
+    t6.join()
+    t7.start()
+    t7.join()
+    t8.start()
+    t8.join()
+    t9.start()
+    t9.join()
+
+    yangguang.get_channel_info()
+
+def update_order():
+    # 1.获取数据
+
+    st = du.get_n_days(-2)
+    et = du.get_n_days(0)
+    print(st, et)
+    order_date_get(st,et)
+
+    st = du.get_n_days(-1)
+    et = du.get_n_days(0)
+    do_order(st, et)
+    src_book_info()  # 书籍卡点信息
+    # book_annual_expect_profit.run() # 年预期收益
+    dw_channel_daily()
+    dw_pitcher_trend()
+    book_trend()
+    dm_pitcher_daily_overview()
+
+if __name__=='__main__':
+    update_order()