modify linucb

linucb/views/collect_data.py

@@ -183,10 +183,15 @@ class CollectData(object):
                                     str(device_id), str(topic_id), str(click_topic_tag_list)))
                                 else:
                                     tag_name = raw_val_dict["params"]["query"]
+                                    query_type = raw_val_dict["params"]["type"]
                                     device_id = raw_val_dict["device"]["device_id"]
                                     user_id = raw_val_dict["user_id"] if "user_id" in raw_val_dict else None
-                                    tag_list = list(Tag.objects.using(settings.SLAVE_DB_NAME).filter(name=tag_name,is_online=True,is_deleted=False).values_list("id",flat=True))
-                                    click_topic_tag_list.extend(tag_list)
+                                    if query_type=="do":
+                                        tag_list = list(Tag.objects.using(settings.SLAVE_DB_NAME).filter(name=tag_name,is_online=True,is_deleted=False).values_list("id",flat=True))
+                                        click_topic_tag_list.extend(tag_list)
+                                    logging.info("query tag attention,positive tag_list,device_id:%s,query_name:%s,tag_list:%s" % (
+                                    str(device_id), tag_name, str(click_topic_tag_list)))
+
 
                                 logging.info("click_topic_tag_list:%s"%(str(click_topic_tag_list)))
 
@@ -199,7 +204,8 @@ class CollectData(object):
                                     self.update_user_linucb_tag_info(reward, device_id, tag_id, user_feature)
 
                                 # 更新该用户的推荐tag数据，放在 更新完成user tag行为信息之后
-                                self.update_recommend_tag_list(device_id, user_feature, user_id,click_topic_tag_list=click_topic_tag_list)
+                                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)
                             elif "type" in raw_val_dict and "page_precise_exposure" == raw_val_dict["type"]:
                                 if isinstance(raw_val_dict["params"]["exposure_cards"],str):
                                     exposure_cards_list = json.loads(raw_val_dict["params"]["exposure_cards"])