Commit 69a4a514 authored by lixiaofang's avatar lixiaofang

add

parent 8442ef9e
......@@ -243,12 +243,8 @@ def get_type_info_map():
TypeInfo(
name='associate_tag',
type='associate_tag',
model=agile_tag.AgileTagType,
query_deferred=lambda: agile_tag.AgileTag.objects.filter(AGILE_TAG_TYPE.DOCTOR, AGILE_TAG_TYPE.HOSPITAL,
AGILE_TAG_TYPE.BRAND, AGILE_TAG_TYPE.INSTRUMENT,
AGILE_TAG_TYPE.PROJECT,
AGILE_TAG_TYPE.POSITION,
AGILE_TAG_TYPE.UNDEFINED).query,
model=agile_tag.AgileTag,
query_deferred=lambda: agile_tag.AgileTag.objects.all().query,
get_data_func=TagTransfer.get_tag_suggest_data_list,
bulk_insert_chunk_size=100,
round_insert_chunk_size=5,
......@@ -257,9 +253,8 @@ def get_type_info_map():
TypeInfo(
name='associate_tag_brand',
type='associate_tag_brand',
model=agile_tag.AgileTagType,
query_deferred=lambda: agile_tag.AgileTag.objects.filter(AGILE_TAG_TYPE.BRAND,
AGILE_TAG_TYPE.UNDEFINED).query,
model=agile_tag.AgileTag,
query_deferred=lambda: agile_tag.AgileTag.objects.all().query,
get_data_func=TagTransfer.get_tag_suggest_brand_data_list,
bulk_insert_chunk_size=100,
round_insert_chunk_size=5,
......@@ -268,9 +263,8 @@ def get_type_info_map():
TypeInfo(
name='associate_tag_doctor',
type='associate_tag_doctor',
model=agile_tag.AgileTagType,
query_deferred=lambda: agile_tag.AgileTag.objects.filter(AGILE_TAG_TYPE.DOCTOR,
AGILE_TAG_TYPE.UNDEFINED).query,
model=agile_tag.AgileTag,
query_deferred=lambda: agile_tag.AgileTag.objects.all().query,
get_data_func=TagTransfer.get_tag_suggest_doctor_data_list,
bulk_insert_chunk_size=100,
round_insert_chunk_size=5,
......@@ -279,9 +273,8 @@ def get_type_info_map():
TypeInfo(
name='associate_tag_hospital',
type='associate_tag_hospital',
model=agile_tag.AgileTagType,
query_deferred=lambda: agile_tag.AgileTag.objects.filter(AGILE_TAG_TYPE.UNDEFINED,
AGILE_TAG_TYPE.HOSPITAL).query,
model=agile_tag.AgileTag,
query_deferred=lambda: agile_tag.AgileTag.objects.all().query,
get_data_func=TagTransfer.get_tag_suggest_hospital_data_list,
bulk_insert_chunk_size=100,
round_insert_chunk_size=5,
......@@ -290,9 +283,8 @@ def get_type_info_map():
TypeInfo(
name='associate_tag_instrument',
type='associate_tag_instrument',
model=agile_tag.AgileTagType,
query_deferred=lambda: agile_tag.AgileTag.objects.filter(AGILE_TAG_TYPE.UNDEFINED,
AGILE_TAG_TYPE.INSTRUMENT).query,
model=agile_tag.AgileTag,
query_deferred=lambda: agile_tag.AgileTag.objects.all().query,
get_data_func=TagTransfer.get_tag_suggest_instrument_data_list,
bulk_insert_chunk_size=100,
round_insert_chunk_size=5,
......@@ -301,9 +293,8 @@ def get_type_info_map():
TypeInfo(
name='associate_tag_position',
type='associate_tag_position',
model=agile_tag.AgileTagType,
query_deferred=lambda: agile_tag.AgileTag.objects.filter(AGILE_TAG_TYPE.UNDEFINED,
AGILE_TAG_TYPE.POSITION, ).query,
model=agile_tag.AgileTag,
query_deferred=lambda: agile_tag.AgileTag.objects.all().query,
get_data_func=TagTransfer.get_tag_suggest_position_data_list,
bulk_insert_chunk_size=100,
round_insert_chunk_size=5,
......@@ -312,9 +303,8 @@ def get_type_info_map():
TypeInfo(
name='associate_tag_project',
type='associate_tag_project',
model=agile_tag.AgileTagType,
query_deferred=lambda: agile_tag.AgileTag.objects.filter(AGILE_TAG_TYPE.UNDEFINED,
AGILE_TAG_TYPE.PROJECT).query,
model=agile_tag.AgileTag,
query_deferred=lambda: agile_tag.AgileTag.objects.all().query,
get_data_func=TagTransfer.get_tag_suggest_project_data_list,
bulk_insert_chunk_size=100,
round_insert_chunk_size=5,
......@@ -340,7 +330,7 @@ def tips_attr_sync_to_redis_type_info_map():
TypeInfo(
name='associate',
type='associate_results_num', # api_wordrelresemble
model=agile_tag.AgileTagType,
model=agile_tag.AgileTag,
query_deferred=lambda: agile_tag.AgileTag.objects.all().query,
get_data_func=TagTransfer.set_data_to_redis,
bulk_insert_chunk_size=100,
......
......@@ -34,24 +34,25 @@ class TagTransfer(object):
AGILE_TAG_TYPE.PROJECT,
AGILE_TAG_TYPE.DOCTOR,
AGILE_TAG_TYPE.UNDEFINED])
ret_list = list()
item_dict = dict()
item_dict["id"] = getMd5Digest(str(instance.name))
item_dict["ori_name"] = instance.name.strip()
item_dict["is_online"] = instance.is_online
random_num = random.randint(10000, 20000)
item_dict["results_num"] = random_num
item_dict["offline_score"] = 0.0
item_dict["create_tag_type"] = instance.create_tag_type
item_dict["style"] = instance.style
item_dict["topic_recommend_sort"] = instance.topic_recommend_sort
item_dict["agile_tag_type"] = instance.get_agile_tag_type()
item_dict["agile_tag_id"] = instance.id
item_dict["api_agile_tag_recommend_type"] = instance.get_api_agile_tag_recommend_type()
ret_list.append(item_dict)
suggest_list = get_tips_suggest_list(instance.name)
logging.info("get ret_list:%s" % ret_list)
return (item_dict, suggest_list)
if result:
ret_list = list()
item_dict = dict()
item_dict["id"] = getMd5Digest(str(instance.name))
item_dict["ori_name"] = instance.name.strip()
item_dict["is_online"] = instance.is_online
random_num = random.randint(10000, 20000)
item_dict["results_num"] = random_num
item_dict["offline_score"] = 0.0
item_dict["create_tag_type"] = instance.create_tag_type
item_dict["style"] = instance.style
item_dict["topic_recommend_sort"] = instance.topic_recommend_sort
item_dict["agile_tag_type"] = instance.get_agile_tag_type()
item_dict["agile_tag_id"] = instance.id
item_dict["api_agile_tag_recommend_type"] = instance.get_api_agile_tag_recommend_type()
ret_list.append(item_dict)
suggest_list = get_tips_suggest_list(instance.name)
logging.info("get ret_list:%s" % ret_list)
return (item_dict, suggest_list)
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return ([], [])
......
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