阳光小时调度单独

app/api_data/get_order.py

@@ -157,7 +157,7 @@ def hourly():
     zhangzhongyun()
     yueweng()
     youshuge()
-    yangguang()
+    # yangguang()    # 阳光接口采用回调的形式，所以单独调度
 
 
 def daily():

app/api_data/platform_order/yangguang.py

@@ -1,6 +1,6 @@
 from app.api_data.order_util import *
 from model.DataBaseUtils import MysqlUtils
-from model.DingTalkUtils import DingTalkDecorators
+from model.DingTalkUtils import DingTalkDecorators,DingTalkUtils
 
 db = MysqlUtils()
 
@@ -37,8 +37,8 @@ def yangguang(start=None, end=None):
             break
         time.sleep(60)
         x += 1
-        if x > 5:
-            # DingTalkUtils.send('阳光订单回调延时20min', '18860455786')
+        if x > 20:
+            DingTalkUtils.send('阳光订单回调延时20min', '18860455786')
             break
 
     for i in accounts:
@@ -60,3 +60,6 @@ def daily_yg():
     st = du.get_n_days(-10)
     et = du.get_n_days(-1)
     yangguang(st, et)
+
+if __name__ == '__main__':
+    yangguang()