ck 4 سال پیش
والد
کامیت
9396a5d145
3فایلهای تغییر یافته به همراه30 افزوده شده و 2 حذف شده
  1. 8 1
      dgp/tests/get_order_hourly.py
  2. 3 0
      dgp/tests/util/date_util.py
  3. 19 1
      dgp/tests/util/db_order_util.py

+ 8 - 1
dgp/tests/get_order_hourly.py

@@ -30,7 +30,7 @@ def start_order_job(st,et):
 
 
 def zzy(st,et):
-    account_list_zhangzhongyun = platform_config_util.get_zhangzhongyun_account_list()
+    account_list_zhangzhongyun = db_order_util.get_account_info_list("掌中云")
     db_order_util.batch_save_order(platform_order_api_util.get_zhangzhongyun_order(st, et, account_list_zhangzhongyun))
 def zd(st,et):
     account_list_zhangdu = platform_config_util.get_zhangdu_account_list()
@@ -49,8 +49,15 @@ def run():
 
     start_order_job(st, et)
 
+
+
 if __name__ == '__main__':
     run()
+    # st = date_util.str_to_stamp('2020-12-23')
+    # et = date_util.str_to_stamp('2020-12-29')
+    #
+    # # et = date_util.get_n_day(n=-2, is_timestamp=1)
+    # zzy(st,et)
     # st = date_util.get_n_day(-20,is_timestamp=1)
     # et = date_util.get_n_day(0,is_timestamp=1)
     # zd(st,et)

+ 3 - 0
dgp/tests/util/date_util.py

@@ -60,6 +60,9 @@ def getLastDays( begin, interval):
         for _ in range(0, interval):
             start = start - delta
     return start.strftime("%Y-%m-%d")
+def str_to_stamp(str):
+    return int(time.mktime(time.strptime(str,'%Y-%m-%d')))
+
 
 
 def getLastMonthDay():

+ 19 - 1
dgp/tests/util/db_order_util.py

@@ -25,7 +25,7 @@ __title__ = '订单工具类,用于查询,修改订单等'
 """
 
 from util.MySQLConnection import MySQLConnection
-
+import pymysql
 
 # 数据导入表采用replace替换主键orderid的方法
 def batch_save_order(data):
@@ -57,3 +57,21 @@ def get_platform_order_count(date):
     finally:
         connect.close()
     return platform_order_count
+
+def get_account_info_list(platform):
+    sql=f"select text from order_account_text where platform='{platform}'"
+    db = pymysql.connect('rm-bp1c9cj79872tx3aaro.mysql.rds.aliyuncs.com', 'superc', 'Cc719199895', 'quchen_text')
+    cur=db.cursor()
+    try:
+        cur.execute(sql)
+        platform= cur.fetchall()
+    except Exception as e:
+        print(e)
+    li=[]
+    for i in platform:
+        li.append(i[0].split(","))
+    return li
+
+
+if __name__ == '__main__':
+    get_account_info_list("掌中云")