Commit fe9c72a1 authored by 段英荣's avatar 段英荣

modify

parent c57dfe40
...@@ -214,8 +214,10 @@ class TopicUtils(object): ...@@ -214,8 +214,10 @@ class TopicUtils(object):
logging.info("duan add,es query:%s" % str(q).encode("utf-8")) logging.info("duan add,es query:%s" % str(q).encode("utf-8"))
result_dict = ESPerform.get_search_results(ESPerform.get_cli(), sub_index_name="topic", query_body=q, result_dict = ESPerform.get_search_results(ESPerform.get_cli(), sub_index_name="topic", query_body=q,
offset=offset, size=size) offset=offset, size=size)
logging.info("result_dict:%s" % str(result_dict).encode("utf-8"))
group_topic_ids = list() group_topic_ids = list()
not_group_topic_ids = list() not_group_topic_ids = list()
for item in result_dict["hits"]: for item in result_dict["hits"]:
if item[b"group_id"] and item[b"group_id"]> 0: if item[b"group_id"] and item[b"group_id"]> 0:
group_topic_ids.append(item[b"id"]) group_topic_ids.append(item[b"id"])
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment