add exposure data

linucb/views/collect_data.py

@@ -116,21 +116,21 @@ class CollectData(object):
                             exposure_topic_id = item["card_id"]
                             logging.info("consume exposure topic_id:%s,device_id:%s" % (str(exposure_topic_id),str(device_id)))
 
-                        tag_list = list()
-                        sql_query_results = TopicTag.objects.filter(is_online=True,topic_id=topic_id)
-                        for sql_item in sql_query_results:
-                            tag_list.append(sql_item.tag_id)
+                            tag_list = list()
+                            sql_query_results = TopicTag.objects.filter(is_online=True,topic_id=exposure_topic_id)
+                            for sql_item in sql_query_results:
+                                tag_list.append(sql_item.tag_id)
 
-                            is_click = 0
-                            is_vote = 0
+                                is_click = 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_list:
-                                self.update_user_linucb_tag_info(reward,device_id,tag_id,user_feature)
+                                for tag_id in tag_list:
+                                    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)
+                                # 更新该用户的推荐tag数据，放在 更新完成user tag行为信息之后
+                                self.update_recommend_tag_list(device_id, user_feature)
 
             return True
         except: