update

task/summary_shopbuy.py

@@ -36,9 +36,9 @@ class SummaryShopbuy(Task):
                     continue
                 logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}')
                 where = {
-                    '_ut': 'Shop',
+                    '_event_name': 'Shop',
                     "act": "buy",
-                    '_event_time': {
+                    '_ut': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }