同步咨询数据

src/tools/sync_consult.py

@@ -0,0 +1,43 @@
+#coding:utf-8
+import os
+import time
+import datetime
+import sys
+import django
+from django.core.cache import cache
+from django.db import connection
+
+sys.path.append('/mnt/wzbapi/src')
+os.environ['DJANGO_SETTINGS_MODULE'] = 'settings'
+django.setup()
+
+import common.models as cm
+import common.common_control as ccc
+
+def sync_consult():
+    """
+    """
+    qset = cm.WanzhuConsult.objects.filter(user_id__gt=0)
+    user_ids = list(qset.values_list("user_id",flat=True))
+    user_ids = list(set(user_ids))
+    for user_id in user_ids:
+        wzconsult = cm.WanzhuConsult.objects.filter(user_id=user_id).order_by("-ctime").first()
+        obj,flag = cm.Consult.objects.get_or_create(
+            user_id=user_id 
+        )
+        obj.user_name = wzconsult.user_name
+        obj.user_avatar = wzconsult.user_avatar
+        obj.content = wzconsult.content
+        if cm.WanzhuConsult.objects.filter(reply_user_id=user_id).exists():
+            reply = cm.WanzhuConsult.objects.filter(reply_user_id=user_id).order_by("-ctime").first()
+            obj.reply_content = reply.reply_content
+            obj.view_status = 1
+            obj.reply_status = 1
+        else:
+            obj.view_status = 0
+            obj.reply_status = 0
+        obj.ctime = wzconsult.ctime
+        obj.save()
+
+if __name__ == "__main__":
+    sync_consult()