测试代码修改：

增加阅文异常订单提示

dgp/tests/check_order_new.py

@@ -153,19 +153,28 @@ def get_yuewen_order_task(st, et, account):
             order_item_list = response_data['list']
 
             for order_item in order_item_list:
+                order_time = order_item['order_time']
+                dtime = datetime.datetime.strptime(order_time, "%Y-%m-%d %H:%M:%S")
+                order_time_unix = int(time.mktime(dtime.timetuple()))
+                order_id = order_item['order_id']
+                if date_util.checkInterval(start_time, end_time, order_time_unix) == False:
+                    print('阅文账号【{key}】, 查询时间【{start_time} - {end_time}】，有不符合该时间范围的订单，订单Id【{order_id}】的时间为【{order_time}】'
+                          .format(key=email, start_time=date_util.getSecondsToDatetime(start_time),
+                                  end_time=date_util.getSecondsToDatetime(end_time),order_id=order_id, order_time=order_time))
+                    continue
+
                 order = {}
-                dtime = datetime.datetime.strptime(order_item['order_time'], "%Y-%m-%d %H:%M:%S")
-                order['date'] = ((int(time.mktime(dtime.timetuple())) + 8 * 3600) // 86400) * 86400 - 8 * 3600
+                order['date'] = ((order_time_unix + 8 * 3600) // 86400) * 86400 - 8 * 3600
                 order['platform'] = '阅文'
                 order['channel'] = order_item['app_name']
                 order['from_novel'] = order_item['book_name']
                 order['user_id'] = order_item['openid']
                 order['stage'] = ''
                 order['channel_id'] = 0
-                order['order_time'] = order_item['order_time']
+                order['order_time'] = order_time
                 order['amount'] = order_item['amount']
                 order['reg_time'] = order_item['reg_time']
-                order['order_id'] = order_item['order_id']
+                order['order_id'] = order_id
 
                 order = sorted(order.items(), key=lambda item: item[0])
                 order = dict(order)
@@ -677,8 +686,28 @@ def start_all_job():
     print('查询开始时间：', st_unix, date_util.getSecondsToDatetime(st_unix))
     print('查询结束时间：', et_unix, date_util.getSecondsToDatetime(et_unix))
 
-    # order_list = get_yuewen_order(st_unix, et_unix)
-    # mysql_insert_order(order_list)
+    order_list = get_yuewen_order(st_unix, et_unix)
+    mysql_insert_order(order_list)
+
+    order_id_list = []
+    for order in order_list:
+        if order[5] == '4200000691202009304870914729':
+            print('存在', order[5])
+        order_id_list.append(order[5])
+
+    print(len(order_id_list))
+    # b = set(order_id_list)
+    # for each_b in b:
+    #     count = 0
+    #     for each_a in order_id_list:
+    #         if each_b == each_a:
+    #             count += 1
+    #     print(each_b, ": ", count)
+
+    exit_flag = True
+    if exit_flag:
+        exit()
+
 
     platform_order_num_list = mysql_select_platform_order_count(date_util.getYesterdayStartTime())
     if len(platform_order_num_list) == 0:

dgp/tests/demo/test_read_ini.py

@@ -40,6 +40,15 @@ import math
 # print(10 // int(1000) + 1)
 # print(1000 // int(1000) + 1)
 # print(1001 // int(1000) + 1)
+import time
+from datetime import datetime
+
+dtime = datetime.strptime('2019-11-14 13:49:32', "%Y-%m-%d %H:%M:%S")
+dd = ((int(time.mktime(dtime.timetuple())) + 8 * 3600) // 86400) * 86400 - 8 * 3600
+print(dtime, int(time.mktime(dtime.timetuple())), type(dtime), dtime.timetuple)
+print(dd, type(dd))
+
+
 
 per_page = 1000
 total_count = 40

dgp/tests/util/date_util.py

@@ -264,6 +264,13 @@ def getCurrentWeekTime():
     timestamps = time.mktime(datetime.date.fromtimestamp(times).timetuple())
     return str(round(timestamps))
 
+def checkInterval(start_time, end_time, need_compare_time):
+    """
+    description:  判断 need_compare_time 是否在 start_time 和 end_time区间里
+    return:       true -> bool
+    """
+    return need_compare_time >= start_time and need_compare_time < end_time
+
 
 def test():
     print(getCurrentMilliSecondTime())