1

app/api_data/get_order.py

@@ -156,10 +156,10 @@ def yueweng(start=None,end=None,new=None):
 
 
 def hourly():
-    # try:
-    #     yangguang()
-    # except:
-    #     pass
+    try:
+        yangguang()
+    except:
+        pass
     huasheng()
     qiyue()
     wending()
@@ -171,10 +171,10 @@ def daily():
     st = du.get_n_days(-10)
     st2=du.get_n_days(-3)
     et = du.get_n_days(-1)
-    # try:
-    #     yangguang(st, et)
-    # except:
-    #     pass
+    try:
+        yangguang(st, et)
+    except:
+        pass
     huasheng(st, et)
     qiyue(st2, et)    # 有毛病
     wending(st, et)
@@ -185,11 +185,13 @@ def daily():
 
 
 if __name__ == '__main__':
-    # yangguang()
-    # huasheng('2020-12-01','2021-02-22')
+    a=time.time()
+    yangguang()
+    print(time.time()-a)
+    # huasheng('2021-02-24','2021-02-24')
     # qiyue()
     # wending()
 
-    zhangdu('2020-11-01', '2020-12-20')
+    # zhangdu('2020-11-01', '2020-12-20')
     # zhangzhongyun('2020-11-01', '2021-02-23')
-    """要是只跑一个账号 把 get_yg_acccount() 里面的sql where 条件加上 id=xxx"""
+

app/etl/dw/dw_channel_daily.py

@@ -252,13 +252,13 @@ def dw_channel_amount_daily_reverse():
     sql = """
      select toDate(formatDateTime(reg_time,'%Y-%m-%d')) as dt,
        channel as channel,
-                sum(if(date=today(),amount,0)) ba1,
-                sum(if(addDays(date,1)=today(),amount,0)) ba2,
-                sum(if(addDays(date,2)=today(),amount,0)) ba3,
-                sum(if(addDays(date,3)=today(),amount,0)) ba4,
-                sum(if(addDays(date,4)=today(),amount,0)) ba5,
-                sum(if(addDays(date,6)=today(),amount,0)) ba6,
-                sum(if(addDays(date,7)=today(),amount,0)) ba7
+                sum(if(dt=today(),amount,0)) ba1,
+                sum(if(addDays(dt,1)=today(),amount,0)) ba2,
+                sum(if(addDays(dt,2)=today(),amount,0)) ba3,
+                sum(if(addDays(dt,3)=today(),amount,0)) ba4,
+                sum(if(addDays(dt,4)=today(),amount,0)) ba5,
+                sum(if(addDays(dt,6)=today(),amount,0)) ba6,
+                sum(if(addDays(dt,7)=today(),amount,0)) ba7
      from order where reg_time>'2019-03-18 00:00:00' and date>=subtractDays(today(),7) group by toDate(formatDateTime(reg_time,'%Y-%m-%d')),channel"""
     data = ck.execute(sql)
     isql = "replace into dw_channel_amount_daily_reverse values (%s,%s,%s,%s,%s,%s,%s,%s,%s)"