如果日记队列顺序没有发生变化，就不更新数据库了

config.py

@@ -30,3 +30,51 @@ QUEUE_ONLINE_HOST = 'rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com'
 LOCAL_HOST = 'rdsmaqevmuzj6jy.mysql.rds.aliyuncs.com'
 
 
+# import pymysql
+# import pandas as pd
+# device_id = "16CFD2C4-B965-42C8-8ADD-7BDC22D6CC57"
+# city = "wuhan"
+# queue_name_list = ["native_queue","nearby_queue","nation_queue","megacity_queue"]
+# for i in queue_name_list:
+#
+#     sql = "select {} from device_diary_queue " \
+#               "where device_id = '{}' and city_id = '{}';".format(i,device_id, city)
+#
+#     db = pymysql.connect(host='rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com', port=3306, user='doris',passwd='o5gbA27hXHHm',
+#                                  db='doris_prod')
+#     # sql = "select device_id,city_id,native_queue,nearby_queue,nation_queue,megacity_queue,get_diary_time,id from device_diary_queue" \
+#     #       "where device_id = {} and city_id = {};".format(device_id,city)
+#     cursor = db.cursor()
+#     cursor.execute(sql)
+#     result = cursor.fetchall()
+#     df = pd.DataFrame(list(result))
+#     print(df.shape)
+#     df.to_csv("/data2/models/{}.csv".format(i),index=None)
+#     print("end")
+
+
+import pandas as pd
+queue_name_list = ["native_queue","nearby_queue","nation_queue","megacity_queue"]
+id = 9454
+device_id = "16CFD2C4-B965-42C8-8ADD-7BDC22D6CC57"
+city_id = "wuhan"
+a = {}
+for i in queue_name_list:
+    a[i] = pd.read_csv("/data2/models/native_queue.csv")["0"].values.tolist()[0]
+
+    db = pymysql.connect(host='rm-m5e842126ng59jrv6.mysql.rds.aliyuncs.com', port=3306, user='doris',passwd='o5gbA27hXHHm',
+                                 db='doris_prod')
+    sql = "update device_diary_queue set {}='{}' where device_id = '{}' and city_id = '{}'".format\
+            (i,a[i],device_id,city_id)
+    cursor = db.cursor()
+    cursor.execute(sql)
+    db.commit()
+    db.close()
+    print("end")
+
+# native_queue,nearby_queue,nation_queue,megacity_queue,
+# a['native_queue'],a['nearby_queue'],a['nation_queue'],a['megacity_queue'],
+
+
+
+

diaryUpdateOnlineOffline.py

@@ -214,6 +214,7 @@ def queue_compare(old_list, new_list):
     if i >0:
         print("日记队列更新前日记总个数{}，位置发生变化个数{}，发生变化率{}%".format(len(old_list), i,
                                                           round(i / len(old_list) * 100), 2))
+        return True
 
 
 def get_queue(device_id, city_id,queue_name):
@@ -266,12 +267,11 @@ def user_update(device_id, city_id, queue_name,data_set_cid,total_video_id):
         queue_arg = [queue_predict, queue_not_predict, queue_list]
         if queue_predict != []:
             diary_queue = pipe_line(queue_name, queue_arg, device_id,total_video_id)
-            if diary_queue:
+            if diary_queue and queue_compare(queue_list, diary_queue):
                 update_sql_dairy_queue(queue_name, diary_queue, device_id, city_id)
-                queue_compare(queue_list,diary_queue)
                 print("更新结束")
             else:
-                print("获取的日记列表是空，所以不更新日记队列")
+                print("获取的日记列表是空或者日记队列顺序没有变化，所以不更新日记队列")
         else:
             print("预测集是空，不需要预测")
     else: