阅文订单回补

app/api_data/get_cost_older.py

@@ -65,8 +65,8 @@ def get_q_data(y,li,st,et):
         for d in c['data']['list']:
             d['account_id'] = y[0]
             print(d['account_id'], d["cost"])
-        x = tuple(d.values())
-        li.append(x)
+            x = tuple(d.values())
+            li.append(x)
 
 def get_v_data(y,li,st,et):
     c = daily_reports_get(y[2], y[0],st,et, "REPORT_LEVEL_ADVERTISER_WECHAT", (
@@ -79,9 +79,9 @@ def get_v_data(y,li,st,et):
         for d in c['data']['list']:
             d['account_id'] = y[0]
             print(d['account_id'], d["cost"])
-        x = tuple(d.values())
-        li.append(x)
-        # print(len(li))
+            x = tuple(d.values())
+            li.append(x)
+
 
 
 

app/api_data/get_order.py

@@ -147,47 +147,6 @@ def youshuge(start=None, end=None):
         executor.submit(get_youshuge_order_task, start, end, account)
     executor.shutdown()
 
-def hourly():
-    p1 = Process(target=huasheng)
-    p2 = Process(target=qiyue)
-    p3 = Process(target=qiyueyousheng)
-    p4 = Process(target=wending)
-    p5 = Process(target=zhangdu)
-    p6 = Process(target=zhangzhongyun)
-    p7 = Process(target=yueweng)
-    p8 = Process(target=youshuge)
-    p9 = Process(target=yangguang)
-    p1.start()
-    p1.join()
-    p2.start()
-    p2.join()
-    p3.start()
-    p3.join()
-    p4.start()
-    p4.join()
-    p5.start()
-    p5.join()
-    p6.start()
-    p6.join()
-    p7.start()
-    p7.join()
-    p8.start()
-    p8.join()
-    p9.start()
-    p9.join()
-
-def daily():
-    st = du.get_n_days(-10)
-    et = du.get_n_days(-1)
-    huasheng(st, et)
-    qiyue(st, et)
-    qiyueyousheng(st, et)
-    wending(st, et)
-    zhangdu(st, et)
-    zhangzhongyun(st, et)
-    yueweng(st, et)
-    youshuge(st, et)
-    yangguang(st, et)
 
 def yestoday():
     st = et = du.get_n_days(-1)
@@ -204,7 +163,7 @@ def yestoday():
 
 if __name__ == '__main__':
     # zhangzhongyun()
-    # yangguang()
+    yangguang()
     # huasheng("2021-04-12",'2021-05-10')
     # yueweng("2021-05-11", '2021-05-11')
-    hourly()
+

app/daily08.py

@@ -1,17 +1,9 @@
-from app.api_data import get_order
-from app.etl import data_stat_run
+
 from model.DateUtils import DateUtils
-from app.api_data import get_cost
-from app.etl.dw import dw_image_cost_day
+from app.task import *
 du = DateUtils()
 
 
-
 if __name__ == '__main__':
-
-    thedate = du.get_n_days(-1)
-    # 订单数据
-    get_order.yestoday()
-
-    # 数据处理
-    data_stat_run.do_order(thedate, thedate)
+    # 阅文订单回补（特殊）
+    yueweng_order_repair()

app/task.py

@@ -2,6 +2,7 @@
 import threading
 from app.api_data.get_order import *
 from app.api_data.get_cost_older import old_cost_hourly
+from app.etl.sync_to_ck_task import order_sync_ck
 
 def hourly():
     t1 = threading.Thread(target=huasheng)
@@ -71,5 +72,12 @@ def daily():
     t10.start()
     t10.join()
 
+
+def yueweng_order_repair():
+    dt = du.get_n_days(-1)
+    yueweng(dt, dt)
+    order_sync_ck(dt)
+
+
 if __name__ == '__main__':
     hourly()