去掉某些没有采集的平台 powell统计过期率的时候去掉旧数据干扰

utils/mongo.py

@@ -35,7 +35,6 @@ def get_mongo_conf():
 filter_pn = ("cdi", "richardsonrfpd", "company", "wpg",)
 
 
-
 class MongoOperator:
 
     def __init__(self):
@@ -46,9 +45,9 @@ class MongoOperator:
         self.db = self.conn[config['database']]
         # element14 chip1stop ti
         self.colls = ('alliedelec', 'arrow', 'avnet', 'buerklin', 'digikey', 'master', 'rs', 'rochester',
-                      'verical', "powell", 'microchip', 'tme', 'heilind', 'maxim', 'aipco', 'company', 'rutronik',
-                      'mouser', 'corestaff', 'wpg', 'szlc', 'element14', 'chip1stop', 'future', "nep", "cdi",
-                      "nac", "richardsonrfpd", "pui")
+                      'verical', "powell", 'tme', 'heilind', 'maxim', 'aipco',
+                      'mouser', 'corestaff', 'wpg', 'szlc', 'element14', 'future', "nep", "cdi",
+                      "nac", "richardsonrfpd",)
 
     @staticmethod
     def get_unexpired_time(plat):
@@ -67,11 +66,18 @@ class MongoOperator:
     @staticmethod
     def get_query(ts, plat):
         expired_query, total_query = {'time': {"$lt": ts}}, {}
-        if plat not in ('element14', 'chip1stop', 'future'):
+
+        if plat in ('element14', 'chip1stop'):
+            expired_query = {'time': {"$gt": ts}}
+        elif plat in ("powell",): #powell 里面存在旧数据的需要过滤
+            expired_query["goods_id"] = {"$gte": 33000494159}
+            total_query["goods_id"] = {"$gte": 33000494159}
             expired_query['is_error'] = 0
             total_query['is_error'] = 0
-        elif plat in ('element14', 'chip1stop'):
-            expired_query = {'time': {"$gt": ts}}
+        elif plat not in ('element14', 'chip1stop', 'future'):
+            expired_query['is_error'] = 0
+            total_query['is_error'] = 0
+
         return expired_query, total_query
 
     @staticmethod