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

Merge branch '2.3_relaces' into 'master'

rm click push

See merge request !466
parents fdd82acb 7708d8b1
...@@ -331,29 +331,29 @@ class CollectData(object): ...@@ -331,29 +331,29 @@ class CollectData(object):
else: else:
logging.warning("unknown type msg:%s" % raw_val_dict.get("type", "missing type")) logging.warning("unknown type msg:%s" % raw_val_dict.get("type", "missing type"))
# 用户点击个性化push进linucb # 用户点击个性化push进linucb
elif "type" in raw_val_dict and raw_val_dict["type"] == "on_click_push": # elif "type" in raw_val_dict and raw_val_dict["type"] == "on_click_push":
if isinstance(raw_val_dict["params"]["tag_ids"], str): # if isinstance(raw_val_dict["params"]["tag_ids"], str):
tagid_list = json.loads(raw_val_dict["params"]["tag_ids"]) # tagid_list = json.loads(raw_val_dict["params"]["tag_ids"])
elif isinstance(raw_val_dict["params"]["tag_ids"], list): # elif isinstance(raw_val_dict["params"]["tag_ids"], list):
tagid_list = raw_val_dict["params"]["tag_ids"] # tagid_list = raw_val_dict["params"]["tag_ids"]
else: # else:
tagid_list = list() # tagid_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
if len(tagid_list) > 0: # if len(tagid_list) > 0:
tag_query_results = Tag.objects.using(settings.SLAVE_DB_NAME).filter( # tag_query_results = Tag.objects.using(settings.SLAVE_DB_NAME).filter(
id__in=tagid_list, is_online=True, is_deleted=False, # id__in=tagid_list, is_online=True, is_deleted=False,
is_category=False).values_list("id", flat=True) # is_category=False).values_list("id", flat=True)
is_click = 1 # is_click = 1
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
for tag_id in tag_query_results: # for tag_id in tag_query_results:
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)
self.update_recommend_tag_list(device_id, user_feature, user_id, # self.update_recommend_tag_list(device_id, user_feature, user_id,
new_user_click_tag_list=tag_query_results) # new_user_click_tag_list=tag_query_results)
logging.info("on_click_push topic type:%s, device_id:%s, answer_tag:%s" % # logging.info("on_click_push topic type:%s, device_id:%s, answer_tag:%s" %
(raw_val_dict.get("type", "missing type"), str(device_id), # (raw_val_dict.get("type", "missing type"), str(device_id),
str(tagid_list))) # str(tagid_list)))
# 用户点击问题清单进linucb # 用户点击问题清单进linucb
elif b'content' in raw_val_dict: elif b'content' in raw_val_dict:
data = json.loads(raw_val_dict[b'content']) data = json.loads(raw_val_dict[b'content'])
......
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