订单拉取改为每小时拉取前2个小时数据

dgp/tests/get_order_hourly.py

@@ -31,35 +31,28 @@ from util import platform_order_api_util
 
 def start_order_job():
     start_exec_seconds = date_util.getCurrentSecondTime()
-    st_unix, et_unix = date_util.getPreviousHourAndCurrentHourSecondTime(start_exec_seconds)
+    st_unix, et_unix = date_util.getPrevious2HourAndCurrentHourSecondTime(start_exec_seconds)
 
     # st_unix = 1602313200  # 2020/10/10 15:0:0
     # et_unix = 1602316800  # 2020/10/10 16:0:0
     print('查询开始时间：', st_unix, date_util.getSecondsToDatetime(st_unix))
     print('查询结束时间：', et_unix, date_util.getSecondsToDatetime(et_unix))
 
+
     account_list_yuewen = platform_config_util.get_yuewen_account_list()
     account_list_zhangzhongyun = platform_config_util.get_zhangzhongyun_account_list()
     account_list_huasheng = platform_config_util.get_huasheng_account_list()
     account_list_youshuge = platform_config_util.get_youshuge_account_list()
     account_list_zhangdu = platform_config_util.get_zhangdu_account_list()
 
-    ########################################## 测试开关 ##########################################
-    # order_list = platform_order_api_util.get_zhangzhongyun_order(st_unix, et_unix)
-    # # print(order_list)
-    # db_order_util.batch_save_order(order_list)
-    #
-    # exit_flag = True
-    # if exit_flag:
-    #     exit()  #这里是为了测试，不让代码继续执行
-    ########################################## 测试开关 ##########################################
-
     db_order_util.batch_save_order(platform_order_api_util.get_zhangzhongyun_order(st_unix, et_unix,account_list_zhangzhongyun))
     db_order_util.batch_save_order(platform_order_api_util.get_yuewen_order(st_unix, et_unix,account_list_yuewen))
     db_order_util.batch_save_order(platform_order_api_util.get_huasheng_order(st_unix, et_unix,account_list_huasheng))
     db_order_util.batch_save_order(platform_order_api_util.get_youshuge_order(st_unix, et_unix,account_list_youshuge))
     db_order_util.batch_save_order(platform_order_api_util.get_zhangdu_order(st_unix, et_unix,account_list_zhangdu))
 
+
+
     print('订单同步执行时间（秒）：', date_util.getCurrentSecondTime() - start_exec_seconds)
 
 

dgp/tests/util/date_util.py

@@ -263,6 +263,17 @@ def getPreviousHourAndCurrentHourSecondTime(seconds=getCurrentSecondTime()):
     current_hour_second_time = int(seconds // 3600 * 3600)
     return previous_hour_second_time, current_hour_second_time
 
+def getPrevious2HourAndCurrentHourSecondTime(seconds=getCurrentSecondTime()):
+    """
+    description:  接受时间戳并返回上2小时整点时间和当前小时整点时间
+    seconds:      默认当前时间 可传second
+    return:       1602313200,1602316800 -> （previous_hour_second_time,current_hour_second_time）
+    tips:         seconds 不传参则取当前时间
+    """
+    previous_hour_second_time = int(seconds // 3600 * 3600 - 7200)
+    current_hour_second_time = int(seconds // 3600 * 3600)
+    return previous_hour_second_time, current_hour_second_time
+
 
 def getCurrentWeekTime():
     """
@@ -331,3 +342,4 @@ def test():
 
 if __name__ == '__main__':
     print(test())
+