add logging

search/utils/topic.py

@@ -135,7 +135,7 @@ class TopicUtils(object):
         try:
             attention_user_id_list = list()
             pick_user_id_list = list()
-            # same_group_id_list = list()
+            same_pictorial_user_info_list = list()
             user_tag_list = list()
 
             result_dict = TopicUtils.get_related_user_info(user_id, 0, 1)
@@ -148,10 +148,10 @@ class TopicUtils(object):
                 pick_user_info_list = result_dict["hits"][0]["_source"]["pick_user_id_list"]
                 pick_user_id_list = [item["user_id"] for item in pick_user_info_list]
 
-                # same_pictorial_user_info_list = result_dict["hits"][0]["_source"]["same_pictorial_user_id_list"]
-                #
-                # same_pictorial_id_list = [item["user_id"] for item in same_pictorial_user_info_list]
-                # same_pictorial_id_list = same_pictorial_id_list[:100]
+                same_pictorial_user_info_list = result_dict["hits"][0]["_source"]["same_pictorial_user_id_list"]
+
+                same_pictorial_id_list = [item["user_id"] for item in same_pictorial_user_info_list]
+                same_pictorial_id_list = same_pictorial_id_list[:100]
 
                 user_tag_list = result_dict["hits"][0]["_source"]["tag_list"]
 
@@ -206,16 +206,16 @@ class TopicUtils(object):
                     }
                 )
 
-            # if len(same_pictorial_id_list) > 0:
-            #     functions_list.append(
-            #         {
-            #             "filter": {"bool": {
-            #                 "should": {"terms": {"user_id": same_pictorial_id_list}}}},
-            #             "weight": 1
-            #         }
-            #     )
+            if len(same_pictorial_id_list) > 0:
+                functions_list.append(
+                    {
+                        "filter": {"bool": {
+                            "should": {"terms": {"user_id": same_pictorial_id_list}}}},
+                        "weight": 1
+                    }
+                )
 
-            # query_tag_term_list = cls.___get_should_term_list(user_tag_list)
+            query_tag_term_list = cls.___get_should_term_list(user_tag_list)
             if len(user_tag_list) > 0:
                 functions_list.append(
                     {
@@ -330,6 +330,8 @@ class TopicUtils(object):
 
             for item in result_dict["hits"]:
                 topic_id_list.append(item["_source"]["id"])
+
+            logging.info("get home_query topic_id_list:%s"%topic_id_list)
             # for item in result_dict["hits"]:
             #     if item["_source"]["group_id"]>0 and  item["_source"]["group_id"] not in same_group_id_set:
             #         same_group_id_set.add(item["_source"]["id"])