Commit 150b402a authored by lixiaofang's avatar lixiaofang

判断类型

parent f4c5578d
...@@ -48,10 +48,9 @@ class AgileTagType(BaseModel): ...@@ -48,10 +48,9 @@ class AgileTagType(BaseModel):
@property @property
def get_by_id_name(self): def get_by_id_name(self):
try: try:
logging.info("get self.id:%s"%self.agile_tag_id) logging.info("get self.id:%s" % self.agile_tag_id)
results =AgileTag.objects.filter(id=self.agile_tag_id).values().first() results = AgileTag.objects.filter(id=self.agile_tag_id).values().first()
if results : if results:
return results return results
else: else:
return {} return {}
......
...@@ -72,6 +72,21 @@ def get_suggest_tips(query, agile_tag_type): ...@@ -72,6 +72,21 @@ def get_suggest_tips(query, agile_tag_type):
ret_list.append( ret_list.append(
[{"ori_name": ori_name, "results_num": results_num, "highlight": highlight_name}]) [{"ori_name": ori_name, "results_num": results_num, "highlight": highlight_name}])
else:
for tips_item in result_dict["suggest"]["tips-suggest"]:
for hit_item in tips_item["options"]:
if hit_item["_source"]["ori_name"] not in have_read_tips_set:
have_read_tips_set.add(hit_item["_source"]["ori_name"])
highlight_marks = u'<ems>%s</ems>' % query
hit_item["_source"]["highlight_name"] = hit_item["_source"]["ori_name"].replace(query,
highlight_marks)
ori_name = hit_item["_source"]["ori_name"]
results_num = hit_item["_source"]["results_num"]
highlight_name = hit_item["_source"]["highlight_name"]
ret_list.append(
[{"ori_name": ori_name, "results_num": results_num, "highlight": highlight_name}])
return ret_list return ret_list
except: except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
......
...@@ -95,13 +95,12 @@ class TagTransfer(object): ...@@ -95,13 +95,12 @@ class TagTransfer(object):
def set_data_to_redis(self, instance): def set_data_to_redis(self, instance):
try: try:
query_key = "query:associate_tip:tag_id:" query_key = "query:associate_tip:tag_id:"
name = agile_tag.AgileTag.objects.filter(id=instance.agile_tag_id).values_list("name", flat=True).first() name = agile_tag.AgileTag.objects.filter(id=instance.agile_tag_id).values_list("name", flat=True).first()
tractate_results = TagTransfer.get_tractate_data_name_mapping_results_to_redis(name) tractate_results = TagTransfer.get_tractate_data_name_mapping_results_to_redis(name)
if tractate_results == None:
tractate_results =0
logging.info("get tractate_results:%s" % tractate_results) logging.info("get tractate_results:%s" % tractate_results)
key = query_key + str(instance.agile_tag_id) key = query_key + str(instance.agile_tag_id)
redis_client.set(key, tractate_results) redis_client.set(key, tractate_results)
except: except:
......
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