renyupeng 1 년 전
부모
커밋
dfd47e04d9
1개의 변경된 파일3개의 추가작업 그리고 2개의 파일을 삭제
  1. 3 2
      spider/SpiderWeekPromoterInfo.py

+ 3 - 2
spider/SpiderWeekPromoterInfo.py

@@ -69,6 +69,7 @@ class SpiderWeekPromoterInfo:
             else:
 
                 roll = json.loads(roll)
+                print(roll, '--roll--', promoterId)
                 fanNum = roll["fanNum"]
                 totalSale = roll["totalSale"]
                 avgVideoSales = roll["avgVideoSales"]
@@ -86,8 +87,8 @@ class SpiderWeekPromoterInfo:
         """
         promoter_result = self.conn.QueryAll(sql)
         self.r.delete('promoter_week_id_list')
-        for promoter in promoter_result:
-            promoter_id = promoter[0]
+        for promoter in set(promoter_result):
+            promoter_id = str(int(promoter[0]))
             self.r.sadd('promoter_week_id_list', promoter_id)
         set_data = self.r.smembers('promoter_week_id_list')
         for promoter_id in set_data: