add print

diaryQueueUpdate.py

@@ -7,7 +7,6 @@ import pymysql
 from datetime import datetime
 # utils 包必须要导，否则ffm转化时用到的pickle找不到utils，会报错
 import utils
-from utils import queue_compare
 import warnings
 from multiprocessing import Pool
 from userProfile import get_active_users
@@ -174,28 +173,29 @@ def update_sql_dairy_queue(queue_name, diary_id,device_id, city_id):
     print("成功写入diary_id")
 
 
-# def queue_compare(old_list, new_list):
-#     # 去掉前面的"diary|"
-#     old_list = list(map(lambda x: int(x[6:]),old_list))
-#     # print("旧表前十个")
-#     # print(old_list[:10])
-#     # print("新表前十个")
-#     # print(new_list[:10])
-#     temp = list(range(len(old_list)))
-#     x_dict = dict(zip(old_list, temp))
-#     temp = list(range(len(new_list)))
-#     y_dict = dict(zip(new_list, temp))
-#     i = 0
-#     for key in x_dict.keys():
-#         if x_dict[key] != y_dict[key]:
-#             i += 1
-#     global update_queue_numbers
-#     print("更新日记队列总数：{}".format(update_queue_numbers))
-#     if i >0:
-#         update_queue_numbers += 1
-#         print("更新日记队列总数：{}".format(update_queue_numbers))
-#         print("日记队列更新前日记总个数{}，位置发生变化个数{}，发生变化率{}%".format(len(old_list), i,
-#                                                           round(i / len(old_list) * 100), 2))
+def queue_compare(old_list, new_list):
+    global update_queue_numbers
+    print("更新日记队列总数：{}".format(update_queue_numbers))
+    # 去掉前面的"diary|"
+    old_list = list(map(lambda x: int(x[6:]),old_list))
+    # print("旧表前十个")
+    # print(old_list[:10])
+    # print("新表前十个")
+    # print(new_list[:10])
+    temp = list(range(len(old_list)))
+    x_dict = dict(zip(old_list, temp))
+    temp = list(range(len(new_list)))
+    y_dict = dict(zip(new_list, temp))
+    i = 0
+    for key in x_dict.keys():
+        if x_dict[key] != y_dict[key]:
+            i += 1
+
+    if i >0:
+        update_queue_numbers += 1
+        print("更新日记队列总数：{}".format(update_queue_numbers))
+        print("日记队列更新前日记总个数{}，位置发生变化个数{}，发生变化率{}%".format(len(old_list), i,
+                                                          round(i / len(old_list) * 100), 2))
 
 
 def get_queue(device_id, city_id,queue_name):

utils.py

@@ -55,8 +55,7 @@ def queue_compare(old_list, new_list):
     # print(old_list[:10])
     # print("新表前十个")
     # print(new_list[:10])
-    global update_queue_numbers
-    print("更新日记队列总数：{}".format(update_queue_numbers))
+
     temp = list(range(len(old_list)))
     x_dict = dict(zip(old_list, temp))
     temp = list(range(len(new_list)))