diff --git a/task/first_recharge.py b/task/first_recharge.py
index e5a0513..0070253 100644
--- a/task/first_recharge.py
+++ b/task/first_recharge.py
@@ -33,7 +33,7 @@ class FirstRecharge(Task):
                     continue
                 logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}')
                 where = {
-                    '_ut': {
+                    '_event_time': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }
diff --git a/task/summary_assets.py b/task/summary_assets.py
index f578a58..b1fc675 100644
--- a/task/summary_assets.py
+++ b/task/summary_assets.py
@@ -57,7 +57,7 @@ class SummaryAssets(Task):
                     '$or': [{'prize.a': {'$in': list(a)}, 'prize.t': {'$in': list(t)}},
                             {'need.a': {'$in': list(a)}, 'need.t': {'$in': list(t)}}],
                     '_event_name': 'res',
-                    '_ut': {
+                    '_event_time': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }
diff --git a/task/summary_func.py b/task/summary_func.py
index ae45e80..3344d5d 100644
--- a/task/summary_func.py
+++ b/task/summary_func.py
@@ -31,7 +31,7 @@ class SummaryFunc(Task):
                 logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}')
                 where = {
                     '_event_name': 'Func',
-                    '_ut': {
+                    '_event_time': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }
diff --git a/task/summary_join_hd.py b/task/summary_join_hd.py
index 4871948..85fe75f 100644
--- a/task/summary_join_hd.py
+++ b/task/summary_join_hd.py
@@ -43,7 +43,7 @@ class SummaryJoinHd(Task):
                 where = {
                     '_event_name': 'res',
                     'function': 'hdgetprize',
-                    '_ut': {
+                    '_event_time': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }
diff --git a/task/summary_login.py b/task/summary_login.py
index 242f239..588ce65 100644
--- a/task/summary_login.py
+++ b/task/summary_login.py
@@ -31,7 +31,7 @@ class SummaryLogin(Task):
                     continue
                 logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}')
                 where = {
-                    '_ut': {
+                    '_event_time': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }
diff --git a/task/summary_open_hd.py b/task/summary_open_hd.py
index f595675..665d92f 100644
--- a/task/summary_open_hd.py
+++ b/task/summary_open_hd.py
@@ -29,7 +29,7 @@ class SummaryOpenHd(Task):
                     '_event_name': 'Activity',
                     'act': 'click',
                     'htype': {"$exists": 1},
-                    '_ut': {
+                    '_event_time': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }
diff --git a/task/summary_pay.py b/task/summary_pay.py
index 728bc5a..afd49c1 100644
--- a/task/summary_pay.py
+++ b/task/summary_pay.py
@@ -39,7 +39,7 @@ class SummaryPay(Task):
                     continue
                 logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}')
                 where = {
-                    '_ut': {
+                    '_event_time': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }
diff --git a/task/summary_shopbuy.py b/task/summary_shopbuy.py
index 960c10e..b399bef 100644
--- a/task/summary_shopbuy.py
+++ b/task/summary_shopbuy.py
@@ -38,7 +38,7 @@ class SummaryShopbuy(Task):
                 where = {
                     '_event_name': 'Shop',
                     "act": "buy",
-                    '_ut': {
+                    '_event_time': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }
diff --git a/task/sync_user.py b/task/sync_user.py
index ca7bef7..241409b 100644
--- a/task/sync_user.py
+++ b/task/sync_user.py
@@ -17,7 +17,7 @@ class SyncUser(Task):
                     continue
                 logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}')
                 where = {
-                    '_ut': {
+                    '_event_time': {
                         '$gte': ts['cursor_st'],
                         '$lt': ts['cursor_et'],
                     }