同步数据

trans2es/models/topic.py

@@ -277,12 +277,21 @@ class Topic(models.Model):
 
             related_billboard_list = list()
 
-            query_results = TopicBillBoard.objects.filter(pictorial_id__in=pictorial_ids)
+            for pictorial_id in pictorial_ids:
 
-            for items in query_results:
-                total_vote_cnt = int(items.virt_vote_cnt) + int(items.real_vote_cnt)
-                related_billboard_list.append({"pictorial_id": items.pictorial_id, "real_vote_cnt": items.real_vote_cnt,
-                                               "virt_vote_cnt": items.virt_vote_cnt, "total_vote_cnt": total_vote_cnt})
+                query_result = TopicBillBoard.objects.filter(pictorial_id=pictorial_id,
+                                                             topic_id=self.id).values().first()
+
+                if query_result == None:
+                    related_billboard_list.append({"pictorial_id": pictorial_id, "real_vote_cnt": 0,
+                                                   "virt_vote_cnt": 0, "total_vote_cnt": 0})
+
+
+                else:
+                    total_vote_cnt = int(query_result["virt_vote_cnt"]) + int(query_result["real_vote_cnt"])
+                    related_billboard_list.append(
+                        {"pictorial_id": query_result["pictorial_id"], "real_vote_cnt": query_result["real_vote_cnt"],
+                         "virt_vote_cnt": query_result["virt_vote_cnt"], "total_vote_cnt": total_vote_cnt})
 
             logging.info("product_brand_info" % related_billboard_list)