Skip to content

P
physical
Commit 0166dfc1 authored by lixiaofang's avatar lixiaofang
Browse files
Options

add

parent 8a589d3c
Show whitespace changes
Inline Side-by-side
Showing with 52 additions and 52 deletions
linucb/views/collect_data.py
View file @ 0166dfc1
...@@ -197,58 +197,58 @@ class CollectData(object): ...@@ -197,58 +197,58 @@ class CollectData(object):
# 更新该用户的推荐tag数据，放在 更新完成user tag行为信息之后 # 更新该用户的推荐tag数据，放在 更新完成user tag行为信息之后
if len(click_topic_tag_list)>0: if len(click_topic_tag_list)>0:
self.update_recommend_tag_list(device_id, user_feature, user_id,click_topic_tag_list=click_topic_tag_list) self.update_recommend_tag_list(device_id, user_feature, user_id,click_topic_tag_list=click_topic_tag_list)
# elif "type" in raw_val_dict and "page_precise_exposure" == raw_val_dict["type"]: elif "type" in raw_val_dict and "page_precise_exposure" == raw_val_dict["type"]:
# if isinstance(raw_val_dict["params"]["exposure_cards"],str): if isinstance(raw_val_dict["params"]["exposure_cards"],str):
# exposure_cards_list = json.loads(raw_val_dict["params"]["exposure_cards"]) exposure_cards_list = json.loads(raw_val_dict["params"]["exposure_cards"])
# elif isinstance(raw_val_dict["params"]["exposure_cards"],list): elif isinstance(raw_val_dict["params"]["exposure_cards"],list):
# exposure_cards_list = raw_val_dict["params"]["exposure_cards"] exposure_cards_list = raw_val_dict["params"]["exposure_cards"]
# else: else:
# exposure_cards_list = list() exposure_cards_list = list()
# device_id = raw_val_dict["device"]["device_id"] device_id = raw_val_dict["device"]["device_id"]
# user_id = raw_val_dict["user_id"] if "user_id" in raw_val_dict else None user_id = raw_val_dict["user_id"] if "user_id" in raw_val_dict else None
# logging.warning("type msg:%s" % raw_val_dict.get("type")) logging.warning("type msg:%s" % raw_val_dict.get("type"))
# exposure_topic_id_list = list() exposure_topic_id_list = list()
# for item in exposure_cards_list: for item in exposure_cards_list:
# if "card_id" not in item: if "card_id" not in item:
# continue continue
# exposure_topic_id = item["card_id"] exposure_topic_id = item["card_id"]
# logging.info( logging.info(
# "consume exposure topic_id:%s,device_id:%s" % (str(exposure_topic_id), str(device_id))) "consume exposure topic_id:%s,device_id:%s" % (str(exposure_topic_id), str(device_id)))
# if exposure_topic_id: if exposure_topic_id:
# exposure_topic_id_list.append(exposure_topic_id) exposure_topic_id_list.append(exposure_topic_id)
#
# topic_tag_id_dict = dict() topic_tag_id_dict = dict()
# tag_list = list() tag_list = list()
# exposure_sql_query_results = TopicTag.objects.using(settings.SLAVE_DB_NAME).\ exposure_sql_query_results = TopicTag.objects.using(settings.SLAVE_DB_NAME).\
# filter(topic_id__in=exposure_topic_id_list).\ filter(topic_id__in=exposure_topic_id_list).\
# values_list("topic_id","tag_id","is_online","is_collection") values_list("topic_id","tag_id","is_online","is_collection")
# # if len(exposure_sql_query_results)>0: # if len(exposure_sql_query_results)>0:
# for topic_id,tag_id,is_online,is_collection in exposure_sql_query_results: for topic_id,tag_id,is_online,is_collection in exposure_sql_query_results:
# if is_online and is_collection == 1: if is_online and is_collection == 1:
# tag_list.append(tag_id) tag_list.append(tag_id)
# if is_online: if is_online:
# tag_sql_query_results = Tag.objects.using(settings.SLAVE_DB_NAME).filter( tag_sql_query_results = Tag.objects.using(settings.SLAVE_DB_NAME).filter(
# id=tag_id).values_list("id", "collection", "is_ai") id=tag_id).values_list("id", "collection", "is_ai")
# for id, collection, is_ai in tag_sql_query_results: for id, collection, is_ai in tag_sql_query_results:
# if (is_ai == 1) and id not in tag_list: if (is_ai == 1) and id not in tag_list:
# tag_list.append(id) tag_list.append(id)
#
# if topic_id not in topic_tag_id_dict: if topic_id not in topic_tag_id_dict:
# topic_tag_id_dict[topic_id] = list() topic_tag_id_dict[topic_id] = list()
# topic_tag_id_dict[topic_id].append(tag_id) topic_tag_id_dict[topic_id].append(tag_id)
#
# is_click = 0 is_click = 0
# is_vote = 0 is_vote = 0
#
# reward = 1 if is_click or is_vote else 0 reward = 1 if is_click or is_vote else 0
#
# logging.info("negative tag_list,device_id:%s,topic_tag_id_dict:%s" % ( logging.info("negative tag_list,device_id:%s,topic_tag_id_dict:%s" % (
# str(device_id), str(topic_tag_id_dict))) str(device_id), str(topic_tag_id_dict)))
# for tag_id in tag_list: for tag_id in tag_list:
# self.update_user_linucb_tag_info(reward, device_id, tag_id, user_feature) self.update_user_linucb_tag_info(reward, device_id, tag_id, user_feature)
#
# # 更新该用户的推荐tag数据，放在 更新完成user tag行为信息之后 # 更新该用户的推荐tag数据，放在 更新完成user tag行为信息之后
# self.update_recommend_tag_list(device_id, user_feature, user_id) self.update_recommend_tag_list(device_id, user_feature, user_id)
elif "type" in raw_val_dict and "interest_choice_click_next" == raw_val_dict["type"]: elif "type" in raw_val_dict and "interest_choice_click_next" == raw_val_dict["type"]:
if isinstance(raw_val_dict["params"]["tagid_list"],str): if isinstance(raw_val_dict["params"]["tagid_list"],str):
tagid_list = json.loads(raw_val_dict["params"]["tagid_list"]) tagid_list = json.loads(raw_val_dict["params"]["tagid_list"])
......
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