modify

trans2es/type_info.py

@@ -252,7 +252,7 @@ def get_type_info_map():
             model=user.User,
             #query_deferred=lambda:user.User.objects.all().query,
             #query_deferred=lambda: user.User.objects.prefetch_related('myuserfollow').query,
-            query_deferred=lambda: user.User.objects.filter(create_time__isnull=False,update_time__isnull=False).query,
+            query_deferred=lambda: user.User.objects.all().query,
             get_data_func=UserTransfer.get_user_data,
             bulk_insert_chunk_size=100,
             round_insert_chunk_size=5,

trans2es/utils/user_transfer.py

@@ -69,16 +69,16 @@ class UserTransfer(object):
                 res["update_time"] = tzlc_update_time
                 res["update_time_val"] = int(time.mktime(tzlc_update_time.timetuple()))
 
-                # res["tag_list"] = []
-                # res["attention_user_id_list"] = []
-                # res["attention_group_id_list"] = []
-                # res["pick_user_id_list"] = []
-                # res["same_group_user_id_list"] = []
-                res["tag_list"] = instance.get_user_tag_id_list()
-                res["attention_user_id_list"] = cls.get_follow_user_id_list(userInstance=instance)
-                res["attention_group_id_list"] = instance.get_attention_group_id_list()
-                res["pick_user_id_list"] = instance.get_pick_user_id_list()
-                res["same_group_user_id_list"] = instance.get_same_group_user_id_list()
+                res["tag_list"] = []
+                res["attention_user_id_list"] = []
+                res["attention_group_id_list"] = []
+                res["pick_user_id_list"] = []
+                res["same_group_user_id_list"] = []
+                # res["tag_list"] = instance.get_user_tag_id_list()
+                # res["attention_user_id_list"] = cls.get_follow_user_id_list(userInstance=instance)
+                # res["attention_group_id_list"] = instance.get_attention_group_id_list()
+                # res["pick_user_id_list"] = instance.get_pick_user_id_list()
+                # res["same_group_user_id_list"] = instance.get_same_group_user_id_list()
             except:
                 logging.error("duan test,catch exception,err_msg:%s" % traceback.format_exc())
                 res["tag_list"] = []