update dairyQueueUpdate file

diaryQueueUpdate.py

@@ -205,15 +205,16 @@ def get_queue(device_id, city_id,queue_name):
     cursor.execute(sql)
     result = cursor.fetchall()
     df = pd.DataFrame(list(result))
-    if not df.empty:
-        queue_list = df.loc[0,0].split(",")
+    print(df)
+    if df.empty:
+        print("该用户对应的日记为空")
+        return False
+    else:
+        queue_list = df.loc[0, 0].split(",")
         queue_list = list(map(lambda x: "diary|" + str(x), queue_list))
         db.close()
         print("成功获取queue")
         return queue_list
-    else:
-        print("该用户对应的日记队列为空")
-        return False
 
 
 def pipe_line(queue_name, queue_arg, device_id):